Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- {
- "_time": "2017-06-14T15:29:53.093Z",
- "level": "ERROR",
- "thread": 21,
- "logger": "com.foo.streams.internal.StreamsNodeImpl",
- "message": "[foo] Uncaught exception in thread:\n\tStreamsThread appId: foo-evaluator\n\tStreamsThread clientId: foo-evaluator-88638934-3500-4d91-a2da-99f5daca7ce1\n\tStreamsThread threadId: StreamThread-1\n\tActive tasks:\n\tStandby tasks:\n\n",
- "metadata": {
- },
- "stack": {
- "commonElementCount": 0,
- "localizedMessage": "This should not happen as timestamp() should only be called while a record is processed",
- "message": "This should not happen as timestamp() should only be called while a record is processed",
- "name": "java.lang.IllegalStateException",
- "extendedStackTrace": [
- {
- "class": "org.apache.kafka.streams.processor.internals.AbstractProcessorContext",
- "method": "timestamp",
- "file": "AbstractProcessorContext.java",
- "line": 150,
- "location": "foo-all.jar",
- },
- {
- "class": "org.apache.kafka.streams.state.internals.StoreChangeLogger",
- "method": "logChange",
- "file": "StoreChangeLogger.java",
- "line": 60,
- "location": "foo-all.jar",
- },
- {
- "class": "org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStore",
- "method": "put",
- "file": "ChangeLoggingKeyValueBytesStore.java",
- "line": 54,
- "exact": false,
- "location": "foo-all.jar",
- "version": "?"
- },
- {
- "class": "org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStore",
- "method": "put",
- "file": "ChangeLoggingKeyValueStore.java",
- "line": 67,
- "exact": false,
- "location": "foo-all.jar",
- "version": "?"
- },
- {
- "class": "org.apache.kafka.streams.state.internals.MeteredKeyValueStore$2",
- "method": "run",
- "file": "MeteredKeyValueStore.java",
- "line": 67,
- "exact": false,
- "location": "foo-all.jar",
- "version": "?"
- },
- {
- "class": "org.apache.kafka.streams.processor.internals.StreamsMetricsImpl",
- "method": "measureLatencyNs",
- "file": "StreamsMetricsImpl.java",
- "line": 188,
- "exact": false,
- "location": "foo-all.jar",
- "version": "?"
- },
- {
- "class": "org.apache.kafka.streams.state.internals.MeteredKeyValueStore",
- "method": "put",
- "file": "MeteredKeyValueStore.java",
- "line": 145,
- "exact": false,
- "location": "foo-all.jar",
- "version": "?"
- },
- {
- "class": "com.foo.policy.foo.evaluation.PhaseTransformer",
- "method": "transform",
- "file": "PhaseTransformer.java",
- "line": 66,
- "exact": false,
- "location": "foo-all.jar",
- "version": "?"
- },
- {
- "class": "com.foo.policy.foo.evaluation.PhaseTransformer",
- "method": "transform",
- "file": "PhaseTransformer.java",
- "line": 17,
- "exact": false,
- "location": "foo-all.jar",
- "version": "?"
- },
- {
- "class": "org.apache.kafka.streams.kstream.internals.KStreamTransform$KStreamTransformProcessor",
- "method": "process",
- "file": "KStreamTransform.java",
- "line": 57,
- "exact": false,
- "location": "foo-all.jar",
- "version": "?"
- },
- {
- "class": "org.apache.kafka.streams.processor.internals.ProcessorNode$1",
- "method": "run",
- "file": "ProcessorNode.java",
- "line": 48,
- "exact": false,
- "location": "foo-all.jar",
- "version": "?"
- },
- {
- "class": "org.apache.kafka.streams.processor.internals.StreamsMetricsImpl",
- "method": "measureLatencyNs",
- "file": "StreamsMetricsImpl.java",
- "line": 188,
- "exact": false,
- "location": "foo-all.jar",
- "version": "?"
- },
- {
- "class": "org.apache.kafka.streams.processor.internals.ProcessorNode",
- "method": "process",
- "file": "ProcessorNode.java",
- "line": 134,
- "exact": false,
- "location": "foo-all.jar",
- "version": "?"
- },
- {
- "class": "org.apache.kafka.streams.processor.internals.ProcessorContextImpl",
- "method": "forward",
- "file": "ProcessorContextImpl.java",
- "line": 83,
- "exact": false,
- "location": "foo-all.jar",
- "version": "?"
- },
- {
- "class": "org.apache.kafka.streams.kstream.internals.KStreamFilter$KStreamFilterProcessor",
- "method": "process",
- "file": "KStreamFilter.java",
- "line": 44,
- "exact": false,
- "location": "foo-all.jar",
- "version": "?"
- },
- {
- "class": "org.apache.kafka.streams.processor.internals.ProcessorNode$1",
- "method": "run",
- "file": "ProcessorNode.java",
- "line": 48,
- "exact": false,
- "location": "foo-all.jar",
- "version": "?"
- },
- {
- "class": "org.apache.kafka.streams.processor.internals.StreamsMetricsImpl",
- "method": "measureLatencyNs",
- "file": "StreamsMetricsImpl.java",
- "line": 188,
- "exact": false,
- "location": "foo-all.jar",
- "version": "?"
- },
- {
- "class": "org.apache.kafka.streams.processor.internals.ProcessorNode",
- "method": "process",
- "file": "ProcessorNode.java",
- "line": 134,
- "exact": false,
- "location": "foo-all.jar",
- "version": "?"
- },
- {
- "class": "org.apache.kafka.streams.processor.internals.ProcessorContextImpl",
- "method": "forward",
- "file": "ProcessorContextImpl.java",
- "line": 83,
- "exact": false,
- "location": "foo-all.jar",
- "version": "?"
- },
- {
- "class": "org.apache.kafka.streams.kstream.internals.KStreamPassThrough$KStreamPassThroughProcessor",
- "method": "process",
- "file": "KStreamPassThrough.java",
- "line": 34,
- "exact": false,
- "location": "foo-all.jar",
- "version": "?"
- },
- {
- "class": "org.apache.kafka.streams.processor.internals.ProcessorNode$1",
- "method": "run",
- "file": "ProcessorNode.java",
- "line": 48,
- "exact": false,
- "location": "foo-all.jar",
- "version": "?"
- },
- {
- "class": "org.apache.kafka.streams.processor.internals.StreamsMetricsImpl",
- "method": "measureLatencyNs",
- "file": "StreamsMetricsImpl.java",
- "line": 188,
- "exact": false,
- "location": "foo-all.jar",
- "version": "?"
- },
- {
- "class": "org.apache.kafka.streams.processor.internals.ProcessorNode",
- "method": "process",
- "file": "ProcessorNode.java",
- "line": 134,
- "exact": false,
- "location": "foo-all.jar",
- "version": "?"
- },
- {
- "class": "org.apache.kafka.streams.processor.internals.ProcessorContextImpl",
- "method": "forward",
- "file": "ProcessorContextImpl.java",
- "line": 83,
- "exact": false,
- "location": "foo-all.jar",
- "version": "?"
- },
- {
- "class": "org.apache.kafka.streams.kstream.internals.KStreamKStreamJoin$KStreamKStreamJoinProcessor",
- "method": "process",
- "file": "KStreamKStreamJoin.java",
- "line": 83,
- "exact": false,
- "location": "foo-all.jar",
- "version": "?"
- },
- {
- "class": "org.apache.kafka.streams.processor.internals.ProcessorNode$1",
- "method": "run",
- "file": "ProcessorNode.java",
- "line": 48,
- "exact": false,
- "location": "foo-all.jar",
- "version": "?"
- },
- {
- "class": "org.apache.kafka.streams.processor.internals.StreamsMetricsImpl",
- "method": "measureLatencyNs",
- "file": "StreamsMetricsImpl.java",
- "line": 188,
- "exact": false,
- "location": "foo-all.jar",
- "version": "?"
- },
- {
- "class": "org.apache.kafka.streams.processor.internals.ProcessorNode",
- "method": "process",
- "file": "ProcessorNode.java",
- "line": 134,
- "exact": false,
- "location": "foo-all.jar",
- "version": "?"
- },
- {
- "class": "org.apache.kafka.streams.processor.internals.ProcessorContextImpl",
- "method": "forward",
- "file": "ProcessorContextImpl.java",
- "line": 83,
- "exact": false,
- "location": "foo-all.jar",
- "version": "?"
- },
- {
- "class": "org.apache.kafka.streams.kstream.internals.KStreamJoinWindow$KStreamJoinWindowProcessor",
- "method": "process",
- "file": "KStreamJoinWindow.java",
- "line": 64,
- "exact": false,
- "location": "foo-all.jar",
- "version": "?"
- },
- {
- "class": "org.apache.kafka.streams.processor.internals.ProcessorNode$1",
- "method": "run",
- "file": "ProcessorNode.java",
- "line": 48,
- "exact": false,
- "location": "foo-all.jar",
- "version": "?"
- },
- {
- "class": "org.apache.kafka.streams.processor.internals.StreamsMetricsImpl",
- "method": "measureLatencyNs",
- "file": "StreamsMetricsImpl.java",
- "line": 188,
- "exact": false,
- "location": "foo-all.jar",
- "version": "?"
- },
- {
- "class": "org.apache.kafka.streams.processor.internals.ProcessorNode",
- "method": "process",
- "file": "ProcessorNode.java",
- "line": 134,
- "exact": false,
- "location": "foo-all.jar",
- "version": "?"
- },
- {
- "class": "org.apache.kafka.streams.processor.internals.ProcessorContextImpl",
- "method": "forward",
- "file": "ProcessorContextImpl.java",
- "line": 83,
- "exact": false,
- "location": "foo-all.jar",
- "version": "?"
- },
- {
- "class": "org.apache.kafka.streams.kstream.internals.KStreamFilter$KStreamFilterProcessor",
- "method": "process",
- "file": "KStreamFilter.java",
- "line": 44,
- "exact": false,
- "location": "foo-all.jar",
- "version": "?"
- },
- {
- "class": "org.apache.kafka.streams.processor.internals.ProcessorNode$1",
- "method": "run",
- "file": "ProcessorNode.java",
- "line": 48,
- "exact": false,
- "location": "foo-all.jar",
- "version": "?"
- },
- {
- "class": "org.apache.kafka.streams.processor.internals.StreamsMetricsImpl",
- "method": "measureLatencyNs",
- "file": "StreamsMetricsImpl.java",
- "line": 188,
- "exact": false,
- "location": "foo-all.jar",
- "version": "?"
- },
- {
- "class": "org.apache.kafka.streams.processor.internals.ProcessorNode",
- "method": "process",
- "file": "ProcessorNode.java",
- "line": 134,
- "exact": false,
- "location": "foo-all.jar",
- "version": "?"
- },
- {
- "class": "org.apache.kafka.streams.processor.internals.ProcessorContextImpl",
- "method": "forward",
- "file": "ProcessorContextImpl.java",
- "line": 83,
- "exact": false,
- "location": "foo-all.jar",
- "version": "?"
- },
- {
- "class": "org.apache.kafka.streams.processor.internals.SourceNode",
- "method": "process",
- "file": "SourceNode.java",
- "line": 70,
- "exact": false,
- "location": "foo-all.jar",
- "version": "?"
- },
- {
- "class": "org.apache.kafka.streams.processor.internals.StreamTask",
- "method": "process",
- "file": "StreamTask.java",
- "line": 197,
- "exact": false,
- "location": "foo-all.jar",
- "version": "?"
- }
- ]
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment