Skip to content

Refactor 3 = Refactor 2 + refactored KafkaStreamSuite further to elimite KafkaTestUtils, and made Java testsuite more robust #8

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
jerryshao merged 6 commits into from
Nov 14, 2014
Merged

Refactor 3 = Refactor 2 + refactored KafkaStreamSuite further to elimite KafkaTestUtils, and made Java testsuite more robust #8

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
6 commits
Select commit Hold shift + click to select a range
ec2e95e
Removed the receiver's locks and essentially reverted to Saisai's ori…
tdas Nov 13, 2014
d9a452c
Minor updates.
tdas Nov 13, 2014
14630aa
Minor updates.
tdas Nov 13, 2014
149948b
Fixed mistake
tdas Nov 13, 2014
fab14c7
minor update.
tdas Nov 13, 2014
eae4ad6
Refectored KafkaStreamSuiteBased to eliminate KafkaTestUtils and made…
tdas Nov 13, 2014
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Minor updates.
  • Loading branch information
@tdas
tdas committed Nov 13, 2014
commit 14630aaf06892494ade308c93ab1d18b3d8d5207
2 changes: 1 addition & 1 deletion external/kafka/src/main/scala/org/apache/spark/streaming/kafka/ReliableKafkaReceiver.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -227,7 +227,7 @@ class ReliableKafkaReceiver[

ZkUtils.updatePersistentPath(zkClient, zkPath, offset.toString)
} catch {
case t: Throwable => logWarning(s"Exception during commit offset $offset for topic" +
case e: Exception => logWarning(s"Exception during commit offset $offset for topic" +
s"${topicAndPart.topic}, partition ${topicAndPart.partition}", t)
}

Expand Down
6 changes: 3 additions & 3 deletions streaming/src/main/scala/org/apache/spark/streaming/receiver/BlockGenerator.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -140,8 +140,8 @@ private[streaming] class BlockGenerator(
} catch {
case ie: InterruptedException =>
logInfo("Block updating timer thread was interrupted")
case t: Throwable =>
reportError("Error in block updating thread", t)
case e: Exception =>
reportError("Error in block updating thread", e)
}
}

Expand All @@ -168,7 +168,7 @@ private[streaming] class BlockGenerator(
case ie: InterruptedException =>
logInfo("Block pushing thread was interrupted")
case e: Exception =>
reportError("Error in block updating thread", e)
reportError("Error in block pushing thread", e)
}
}

Expand Down