java.lang.IllegalStateException: close() was called on BatchedWriteAheadLog before write request with time 1467910440000 could be fulfilled.

amazon.com | 3 weeks ago
  1. 0

    AWS Developer Forums: Unable to stop Spark 1.5.2 Streaming ...

    amazon.com | 3 weeks ago
    java.lang.IllegalStateException: close() was called on BatchedWriteAheadLog before write request with time 1467910440000 could be fulfilled.
  2. 0

    AWS Developer Forums: Unable to stop Spark 1.5.2 Streaming ...

    amazon.com | 3 weeks ago
    java.lang.IllegalStateException: close() was called on BatchedWriteAheadLog before write request with time 1467910380055 could be fulfilled.
  3. 0

    AWS Developer Forums: Unable to stop Spark 1.5.2 Streaming ...

    amazon.com | 3 weeks ago
    java.lang.IllegalStateException: close() was called on BatchedWriteAheadLog before write request with time 1454020507521 could be fulfilled.
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    Spring Async method or event throws HystrixRequestContext.initializeContext() exception

    Stack Overflow | 8 months ago | nsdiv
    java.lang.IllegalStateException: HystrixRequestContext.initializeContext() must be called at the beginning of each request before RequestVariable functionality can be used.
  6. 0

    Not finding the right solution?
    Take a tour to get the most out of Samebug.

    Tired of useless tips?

    Automated exception search integrated into your IDE

    Root Cause Analysis

    1. java.lang.IllegalStateException

      close() was called on BatchedWriteAheadLog before write request with time 1467910440000 could be fulfilled.

      at org.apache.spark.streaming.util.BatchedWriteAheadLog.write()
    2. Spark Project Streaming
      JobGenerator$$anonfun$3.apply
      1. org.apache.spark.streaming.util.BatchedWriteAheadLog.write(BatchedWriteAheadLog.scala:83)
      2. org.apache.spark.streaming.scheduler.ReceivedBlockTracker.writeToLog(ReceivedBlockTracker.scala:232)
      3. org.apache.spark.streaming.scheduler.ReceivedBlockTracker.allocateBlocksToBatch(ReceivedBlockTracker.scala:116)
      4. org.apache.spark.streaming.scheduler.ReceiverTracker.allocateBlocksToBatch(ReceiverTracker.scala:203)
      5. org.apache.spark.streaming.scheduler.JobGenerator$$anonfun$3.apply(JobGenerator.scala:247)
      6. org.apache.spark.streaming.scheduler.JobGenerator$$anonfun$3.apply(JobGenerator.scala:246)
      6 frames