Guest User

Untitled

a guest
Jun 14th, 2017
111
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
JSON 12.08 KB | None | 0 0
  1. {
  2.   "_time": "2017-06-14T15:29:53.093Z",
  3.   "level": "ERROR",
  4.   "thread": 21,
  5.   "logger": "com.foo.streams.internal.StreamsNodeImpl",
  6.   "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",
  7.   "metadata": {
  8.    
  9.   },
  10.   "stack": {
  11.     "commonElementCount": 0,
  12.     "localizedMessage": "This should not happen as timestamp() should only be called while a record is processed",
  13.     "message": "This should not happen as timestamp() should only be called while a record is processed",
  14.     "name": "java.lang.IllegalStateException",
  15.     "extendedStackTrace": [
  16.       {
  17.         "class": "org.apache.kafka.streams.processor.internals.AbstractProcessorContext",
  18.         "method": "timestamp",
  19.         "file": "AbstractProcessorContext.java",
  20.         "line": 150,
  21.         "location": "foo-all.jar",
  22.       },
  23.       {
  24.         "class": "org.apache.kafka.streams.state.internals.StoreChangeLogger",
  25.         "method": "logChange",
  26.         "file": "StoreChangeLogger.java",
  27.         "line": 60,
  28.         "location": "foo-all.jar",
  29.       },
  30.       {
  31.         "class": "org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStore",
  32.         "method": "put",
  33.         "file": "ChangeLoggingKeyValueBytesStore.java",
  34.         "line": 54,
  35.         "exact": false,
  36.         "location": "foo-all.jar",
  37.         "version": "?"
  38.       },
  39.       {
  40.         "class": "org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStore",
  41.         "method": "put",
  42.         "file": "ChangeLoggingKeyValueStore.java",
  43.         "line": 67,
  44.         "exact": false,
  45.         "location": "foo-all.jar",
  46.         "version": "?"
  47.       },
  48.       {
  49.         "class": "org.apache.kafka.streams.state.internals.MeteredKeyValueStore$2",
  50.         "method": "run",
  51.         "file": "MeteredKeyValueStore.java",
  52.         "line": 67,
  53.         "exact": false,
  54.         "location": "foo-all.jar",
  55.         "version": "?"
  56.       },
  57.       {
  58.         "class": "org.apache.kafka.streams.processor.internals.StreamsMetricsImpl",
  59.         "method": "measureLatencyNs",
  60.         "file": "StreamsMetricsImpl.java",
  61.         "line": 188,
  62.         "exact": false,
  63.         "location": "foo-all.jar",
  64.         "version": "?"
  65.       },
  66.       {
  67.         "class": "org.apache.kafka.streams.state.internals.MeteredKeyValueStore",
  68.         "method": "put",
  69.         "file": "MeteredKeyValueStore.java",
  70.         "line": 145,
  71.         "exact": false,
  72.         "location": "foo-all.jar",
  73.         "version": "?"
  74.       },
  75.       {
  76.         "class": "com.foo.policy.foo.evaluation.PhaseTransformer",
  77.         "method": "transform",
  78.         "file": "PhaseTransformer.java",
  79.         "line": 66,
  80.         "exact": false,
  81.         "location": "foo-all.jar",
  82.         "version": "?"
  83.       },
  84.       {
  85.         "class": "com.foo.policy.foo.evaluation.PhaseTransformer",
  86.         "method": "transform",
  87.         "file": "PhaseTransformer.java",
  88.         "line": 17,
  89.         "exact": false,
  90.         "location": "foo-all.jar",
  91.         "version": "?"
  92.       },
  93.       {
  94.         "class": "org.apache.kafka.streams.kstream.internals.KStreamTransform$KStreamTransformProcessor",
  95.         "method": "process",
  96.         "file": "KStreamTransform.java",
  97.         "line": 57,
  98.         "exact": false,
  99.         "location": "foo-all.jar",
  100.         "version": "?"
  101.       },
  102.       {
  103.         "class": "org.apache.kafka.streams.processor.internals.ProcessorNode$1",
  104.         "method": "run",
  105.         "file": "ProcessorNode.java",
  106.         "line": 48,
  107.         "exact": false,
  108.         "location": "foo-all.jar",
  109.         "version": "?"
  110.       },
  111.       {
  112.         "class": "org.apache.kafka.streams.processor.internals.StreamsMetricsImpl",
  113.         "method": "measureLatencyNs",
  114.         "file": "StreamsMetricsImpl.java",
  115.         "line": 188,
  116.         "exact": false,
  117.         "location": "foo-all.jar",
  118.         "version": "?"
  119.       },
  120.       {
  121.         "class": "org.apache.kafka.streams.processor.internals.ProcessorNode",
  122.         "method": "process",
  123.         "file": "ProcessorNode.java",
  124.         "line": 134,
  125.         "exact": false,
  126.         "location": "foo-all.jar",
  127.         "version": "?"
  128.       },
  129.       {
  130.         "class": "org.apache.kafka.streams.processor.internals.ProcessorContextImpl",
  131.         "method": "forward",
  132.         "file": "ProcessorContextImpl.java",
  133.         "line": 83,
  134.         "exact": false,
  135.         "location": "foo-all.jar",
  136.         "version": "?"
  137.       },
  138.       {
  139.         "class": "org.apache.kafka.streams.kstream.internals.KStreamFilter$KStreamFilterProcessor",
  140.         "method": "process",
  141.         "file": "KStreamFilter.java",
  142.         "line": 44,
  143.         "exact": false,
  144.         "location": "foo-all.jar",
  145.         "version": "?"
  146.       },
  147.       {
  148.         "class": "org.apache.kafka.streams.processor.internals.ProcessorNode$1",
  149.         "method": "run",
  150.         "file": "ProcessorNode.java",
  151.         "line": 48,
  152.         "exact": false,
  153.         "location": "foo-all.jar",
  154.         "version": "?"
  155.       },
  156.       {
  157.         "class": "org.apache.kafka.streams.processor.internals.StreamsMetricsImpl",
  158.         "method": "measureLatencyNs",
  159.         "file": "StreamsMetricsImpl.java",
  160.         "line": 188,
  161.         "exact": false,
  162.         "location": "foo-all.jar",
  163.         "version": "?"
  164.       },
  165.       {
  166.         "class": "org.apache.kafka.streams.processor.internals.ProcessorNode",
  167.         "method": "process",
  168.         "file": "ProcessorNode.java",
  169.         "line": 134,
  170.         "exact": false,
  171.         "location": "foo-all.jar",
  172.         "version": "?"
  173.       },
  174.       {
  175.         "class": "org.apache.kafka.streams.processor.internals.ProcessorContextImpl",
  176.         "method": "forward",
  177.         "file": "ProcessorContextImpl.java",
  178.         "line": 83,
  179.         "exact": false,
  180.         "location": "foo-all.jar",
  181.         "version": "?"
  182.       },
  183.       {
  184.         "class": "org.apache.kafka.streams.kstream.internals.KStreamPassThrough$KStreamPassThroughProcessor",
  185.         "method": "process",
  186.         "file": "KStreamPassThrough.java",
  187.         "line": 34,
  188.         "exact": false,
  189.         "location": "foo-all.jar",
  190.         "version": "?"
  191.       },
  192.       {
  193.         "class": "org.apache.kafka.streams.processor.internals.ProcessorNode$1",
  194.         "method": "run",
  195.         "file": "ProcessorNode.java",
  196.         "line": 48,
  197.         "exact": false,
  198.         "location": "foo-all.jar",
  199.         "version": "?"
  200.       },
  201.       {
  202.         "class": "org.apache.kafka.streams.processor.internals.StreamsMetricsImpl",
  203.         "method": "measureLatencyNs",
  204.         "file": "StreamsMetricsImpl.java",
  205.         "line": 188,
  206.         "exact": false,
  207.         "location": "foo-all.jar",
  208.         "version": "?"
  209.       },
  210.       {
  211.         "class": "org.apache.kafka.streams.processor.internals.ProcessorNode",
  212.         "method": "process",
  213.         "file": "ProcessorNode.java",
  214.         "line": 134,
  215.         "exact": false,
  216.         "location": "foo-all.jar",
  217.         "version": "?"
  218.       },
  219.       {
  220.         "class": "org.apache.kafka.streams.processor.internals.ProcessorContextImpl",
  221.         "method": "forward",
  222.         "file": "ProcessorContextImpl.java",
  223.         "line": 83,
  224.         "exact": false,
  225.         "location": "foo-all.jar",
  226.         "version": "?"
  227.       },
  228.       {
  229.         "class": "org.apache.kafka.streams.kstream.internals.KStreamKStreamJoin$KStreamKStreamJoinProcessor",
  230.         "method": "process",
  231.         "file": "KStreamKStreamJoin.java",
  232.         "line": 83,
  233.         "exact": false,
  234.         "location": "foo-all.jar",
  235.         "version": "?"
  236.       },
  237.       {
  238.         "class": "org.apache.kafka.streams.processor.internals.ProcessorNode$1",
  239.         "method": "run",
  240.         "file": "ProcessorNode.java",
  241.         "line": 48,
  242.         "exact": false,
  243.         "location": "foo-all.jar",
  244.         "version": "?"
  245.       },
  246.       {
  247.         "class": "org.apache.kafka.streams.processor.internals.StreamsMetricsImpl",
  248.         "method": "measureLatencyNs",
  249.         "file": "StreamsMetricsImpl.java",
  250.         "line": 188,
  251.         "exact": false,
  252.         "location": "foo-all.jar",
  253.         "version": "?"
  254.       },
  255.       {
  256.         "class": "org.apache.kafka.streams.processor.internals.ProcessorNode",
  257.         "method": "process",
  258.         "file": "ProcessorNode.java",
  259.         "line": 134,
  260.         "exact": false,
  261.         "location": "foo-all.jar",
  262.         "version": "?"
  263.       },
  264.       {
  265.         "class": "org.apache.kafka.streams.processor.internals.ProcessorContextImpl",
  266.         "method": "forward",
  267.         "file": "ProcessorContextImpl.java",
  268.         "line": 83,
  269.         "exact": false,
  270.         "location": "foo-all.jar",
  271.         "version": "?"
  272.       },
  273.       {
  274.         "class": "org.apache.kafka.streams.kstream.internals.KStreamJoinWindow$KStreamJoinWindowProcessor",
  275.         "method": "process",
  276.         "file": "KStreamJoinWindow.java",
  277.         "line": 64,
  278.         "exact": false,
  279.         "location": "foo-all.jar",
  280.         "version": "?"
  281.       },
  282.       {
  283.         "class": "org.apache.kafka.streams.processor.internals.ProcessorNode$1",
  284.         "method": "run",
  285.         "file": "ProcessorNode.java",
  286.         "line": 48,
  287.         "exact": false,
  288.         "location": "foo-all.jar",
  289.         "version": "?"
  290.       },
  291.       {
  292.         "class": "org.apache.kafka.streams.processor.internals.StreamsMetricsImpl",
  293.         "method": "measureLatencyNs",
  294.         "file": "StreamsMetricsImpl.java",
  295.         "line": 188,
  296.         "exact": false,
  297.         "location": "foo-all.jar",
  298.         "version": "?"
  299.       },
  300.       {
  301.         "class": "org.apache.kafka.streams.processor.internals.ProcessorNode",
  302.         "method": "process",
  303.         "file": "ProcessorNode.java",
  304.         "line": 134,
  305.         "exact": false,
  306.         "location": "foo-all.jar",
  307.         "version": "?"
  308.       },
  309.       {
  310.         "class": "org.apache.kafka.streams.processor.internals.ProcessorContextImpl",
  311.         "method": "forward",
  312.         "file": "ProcessorContextImpl.java",
  313.         "line": 83,
  314.         "exact": false,
  315.         "location": "foo-all.jar",
  316.         "version": "?"
  317.       },
  318.       {
  319.         "class": "org.apache.kafka.streams.kstream.internals.KStreamFilter$KStreamFilterProcessor",
  320.         "method": "process",
  321.         "file": "KStreamFilter.java",
  322.         "line": 44,
  323.         "exact": false,
  324.         "location": "foo-all.jar",
  325.         "version": "?"
  326.       },
  327.       {
  328.         "class": "org.apache.kafka.streams.processor.internals.ProcessorNode$1",
  329.         "method": "run",
  330.         "file": "ProcessorNode.java",
  331.         "line": 48,
  332.         "exact": false,
  333.         "location": "foo-all.jar",
  334.         "version": "?"
  335.       },
  336.       {
  337.         "class": "org.apache.kafka.streams.processor.internals.StreamsMetricsImpl",
  338.         "method": "measureLatencyNs",
  339.         "file": "StreamsMetricsImpl.java",
  340.         "line": 188,
  341.         "exact": false,
  342.         "location": "foo-all.jar",
  343.         "version": "?"
  344.       },
  345.       {
  346.         "class": "org.apache.kafka.streams.processor.internals.ProcessorNode",
  347.         "method": "process",
  348.         "file": "ProcessorNode.java",
  349.         "line": 134,
  350.         "exact": false,
  351.         "location": "foo-all.jar",
  352.         "version": "?"
  353.       },
  354.       {
  355.         "class": "org.apache.kafka.streams.processor.internals.ProcessorContextImpl",
  356.         "method": "forward",
  357.         "file": "ProcessorContextImpl.java",
  358.         "line": 83,
  359.         "exact": false,
  360.         "location": "foo-all.jar",
  361.         "version": "?"
  362.       },
  363.       {
  364.         "class": "org.apache.kafka.streams.processor.internals.SourceNode",
  365.         "method": "process",
  366.         "file": "SourceNode.java",
  367.         "line": 70,
  368.         "exact": false,
  369.         "location": "foo-all.jar",
  370.         "version": "?"
  371.       },
  372.       {
  373.         "class": "org.apache.kafka.streams.processor.internals.StreamTask",
  374.         "method": "process",
  375.         "file": "StreamTask.java",
  376.         "line": 197,
  377.         "exact": false,
  378.         "location": "foo-all.jar",
  379.         "version": "?"
  380.       }
  381.     ]
  382.   }
  383. }
Advertisement
Add Comment
Please, Sign In to add comment