Created
February 2, 2017 16:02
-
-
Save mfenniak/cd108ad655ca63252be550c7b96414c5 to your computer and use it in GitHub Desktop.
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
... more running log data ... | |
15:51:30.488 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Flushing state stores of task 19_2 | |
15:51:30.488 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Flushing state stores of task 20_1 | |
15:51:30.488 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Flushing state stores of task 21_1 | |
15:51:30.488 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Flushing state stores of task 21_3 | |
15:51:30.489 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 2_0 | |
15:51:30.501 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 3_0 | |
15:51:30.501 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 1_2 | |
15:51:30.518 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 4_0 | |
15:51:30.530 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 2_2 | |
15:51:30.534 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 1_3 | |
15:51:30.554 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 2_3 | |
15:51:30.563 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 3_3 | |
15:51:30.563 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 4_2 | |
15:51:30.596 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 6_0 | |
15:51:30.619 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 5_2 | |
15:51:30.626 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 6_1 | |
15:51:30.644 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 7_1 | |
15:51:30.650 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 8_0 | |
15:51:30.650 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 6_2 | |
15:51:30.666 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 7_2 | |
15:51:30.670 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 8_1 | |
15:51:30.670 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 6_3 | |
15:51:30.682 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 8_2 | |
15:51:30.683 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 11_0 | |
15:51:30.687 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 10_1 | |
15:51:30.693 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 9_2 | |
15:51:30.712 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 11_1 | |
15:51:30.742 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 11_2 | |
15:51:30.747 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 12_1 | |
15:51:30.763 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 13_1 | |
15:51:30.771 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 12_3 | |
15:51:30.788 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 15_1 | |
15:51:30.794 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 14_2 | |
15:51:30.813 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 16_0 | |
15:51:30.818 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 14_3 | |
15:51:30.836 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 17_0 | |
15:51:30.841 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 18_0 | |
15:51:30.856 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 16_2 | |
15:51:30.862 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 17_1 | |
15:51:30.879 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 19_0 | |
15:51:30.880 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 16_3 | |
15:51:30.893 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 17_2 | |
15:51:30.898 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 18_2 | |
15:51:30.914 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 17_3 | |
15:51:30.918 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 19_2 | |
15:51:30.919 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 20_1 | |
15:51:30.935 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 21_1 | |
15:51:30.959 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 21_3 | |
15:51:30.963 [StreamThread-1] INFO o.a.k.clients.producer.KafkaProducer - Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. | |
15:51:31.048 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Removing all active tasks [[2_0, 3_0, 1_2, 4_0, 2_2, 1_3, 2_3, 3_3, 4_2, 6_0, 5_2, 6_1, 7_1, 8_0, 6_2, 7_2, 8_1, 6_3, 8_2, 11_0, 10_1, 9_2, 11_1, 11_2, 12_1, 13_1, 12_3, 15_1, 14_2, 16_0, 14_3, 17_0, 18_0, 16_2, 17_1, 19_0, 16_3, 17_2, 18_2, 17_3, 19_2, 20_1, 21_1, 21_3]] | |
15:51:31.049 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Removing all standby tasks [[]] | |
15:51:31.049 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Stream thread shutdown complete | |
15:51:31.049 [StreamThread-1] WARN o.a.k.s.p.internals.StreamThread - Unexpected state transition from RUNNING to NOT_RUNNING | |
15:51:31.051 [StreamThread-1] ERROR c.r.s.timesheetList.Main$LOG$1 - Uncaught exception from stream processing | |
org.apache.kafka.streams.errors.StreamsException: Exception caught in process. taskId=21_1, processor=projectTimeAllocation-projectBillingRateHistory-base-update-repartition-source, topic=timesheet-list-projectTimeAllocation-projectBillingRateHistory-base-update-repartition, partition=1, offset=9549 | |
at org.apache.kafka.streams.processor.internals.StreamTask.process(StreamTask.java:216) | |
at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:641) | |
at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:368) | |
Caused by: org.apache.kafka.streams.errors.InvalidStateStoreException: Store projectTimeAllocation-projectBillingRateHistory-historical-lookup-store is currently closed | |
at org.apache.kafka.streams.state.internals.RocksDBStore.validateStoreOpen(RocksDBStore.java:205) | |
at org.apache.kafka.streams.state.internals.RocksDBStore.put(RocksDBStore.java:221) | |
at org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStore.put(ChangeLoggingKeyValueBytesStore.java:46) | |
at org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStore.put(ChangeLoggingKeyValueStore.java:66) | |
at org.apache.kafka.streams.state.internals.MeteredKeyValueStore$2.run(MeteredKeyValueStore.java:67) | |
at org.apache.kafka.streams.processor.internals.StreamsMetricsImpl.measureLatencyNs(StreamsMetricsImpl.java:188) | |
at org.apache.kafka.streams.state.internals.MeteredKeyValueStore.put(MeteredKeyValueStore.java:145) | |
at com.replicon.streamProcessing.processing.historicalJoin.BaseUpdateProcessor.process(BaseUpdateProcessor.kt:73) | |
at com.replicon.streamProcessing.processing.historicalJoin.BaseUpdateProcessor.process(BaseUpdateProcessor.kt:11) | |
at org.apache.kafka.streams.processor.internals.ProcessorNode$1.run(ProcessorNode.java:48) | |
at org.apache.kafka.streams.processor.internals.StreamsMetricsImpl.measureLatencyNs(StreamsMetricsImpl.java:188) | |
at org.apache.kafka.streams.processor.internals.ProcessorNode.process(ProcessorNode.java:134) | |
at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:83) | |
at org.apache.kafka.streams.processor.internals.SourceNode.process(SourceNode.java:70) | |
at org.apache.kafka.streams.processor.internals.StreamTask.process(StreamTask.java:197) | |
... 2 common frames omitted |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment