-
- Downloads
[SPARK-3154][STREAMING] Make FlumePollingInputDStream shutdown cleaner.
Currently lot of errors get thrown from Avro IPC layer when the dstream or sink is shutdown. This PR cleans it up. Some refactoring is done in the receiver code to put all of the RPC code into a single Try and just recover from that. The sink code has also been cleaned up. Author: Hari Shreedharan <hshreedharan@apache.org> Closes #2065 from harishreedharan/clean-flume-shutdown and squashes the following commits: f93a07c [Hari Shreedharan] Formatting fixes. d7427cc [Hari Shreedharan] More fixes! a0a8852 [Hari Shreedharan] Fix race condition, hopefully! Minor other changes. 4c9ed02 [Hari Shreedharan] Remove unneeded list in Callback handler. Other misc changes. 8fee36f [Hari Shreedharan] Scala-library is required, else maven build fails. Also catch InterruptedException in TxnProcessor. 445e700 [Hari Shreedharan] Merge remote-tracking branch 'asf/master' into clean-flume-shutdown 87232e0 [Hari Shreedharan] Refactor Flume Input Stream. Clean up code, better error handling. 9001d26 [Hari Shreedharan] Change log level to debug in TransactionProcessor#shutdown method e7b8d82 [Hari Shreedharan] Incorporate review feedback 598efa7 [Hari Shreedharan] Clean up some exception handling code e1027c6 [Hari Shreedharan] Merge remote-tracking branch 'asf/master' into clean-flume-shutdown ed608c8 [Hari Shreedharan] [SPARK-3154][STREAMING] Make FlumePollingInputDStream shutdown cleaner.
Showing
- external/flume-sink/pom.xml 4 additions, 0 deletionsexternal/flume-sink/pom.xml
- external/flume-sink/src/main/scala/org/apache/spark/streaming/flume/sink/SparkAvroCallbackHandler.scala 40 additions, 16 deletions...spark/streaming/flume/sink/SparkAvroCallbackHandler.scala
- external/flume-sink/src/main/scala/org/apache/spark/streaming/flume/sink/TransactionProcessor.scala 15 additions, 3 deletions...che/spark/streaming/flume/sink/TransactionProcessor.scala
- external/flume/src/main/scala/org/apache/spark/streaming/flume/FlumeBatchFetcher.scala 167 additions, 0 deletions.../org/apache/spark/streaming/flume/FlumeBatchFetcher.scala
- external/flume/src/main/scala/org/apache/spark/streaming/flume/FlumePollingInputDStream.scala 10 additions, 67 deletions...ache/spark/streaming/flume/FlumePollingInputDStream.scala
Loading
Please register or sign in to comment