Created
June 15, 2020 17:29
-
-
Save roger-link/1ae9c0bc06ecfd4101775479670dcbcc to your computer and use it in GitHub Desktop.
This file contains 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
| /usr/local/Cellar/apache-flink/1.8.0/bin/flink run ./processing/beam/errorrate/target/redacted-errorrate-1.0-SNAPSHOT.jar --runner=FlinkRunner --awsRegion=us-west-2 --kafkaTopic=redacted-Topic --kafkaBrokers="b-2.redacted-processing-rog.nrpwiy.c2.kafka.us-west-2.amazonaws.com:9092,b-1.redacted-processing-rog.nrpwiy.c2.kafka.us-west-2.amazonaws.com:9092,b-4.redacted-processing-rog.nrpwiy.c2.kafka.us-west-2.amazonaws.com:9092" --kinesisStream=redacted-processing | |
| Starting execution of program | |
| java.lang.VerifyError: Bad type on operand stack | |
| Exception Details: | |
| Location: | |
| org/apache/beam/runners/flink/FlinkStreamingTransformTranslators$CombinePerKeyTranslator.translateNode(Lorg/apache/beam/sdk/transforms/PTransform;Lorg/apache/beam/runners/flink/FlinkStreamingTranslationContext;)V @467: invokespecial | |
| Reason: | |
| Type 'org/apache/flink/streaming/api/transformations/TwoInputTransformation' (current frame, stack[4]) is not assignable to 'org/apache/flink/api/dag/Transformation' | |
| Current Frame: | |
| bci: @467 | |
| flags: { } | |
| locals: { 'org/apache/beam/runners/flink/FlinkStreamingTransformTranslators$CombinePerKeyTranslator', 'org/apache/beam/sdk/transforms/PTransform', 'org/apache/beam/runners/flink/FlinkStreamingTranslationContext', 'java/lang/String', 'org/apache/beam/sdk/values/PCollection', 'org/apache/beam/sdk/values/WindowingStrategy', 'org/apache/beam/sdk/coders/KvCoder', 'org/apache/beam/runners/flink/translation/wrappers/streaming/SingletonKeyedWorkItemCoder', 'org/apache/flink/streaming/api/datastream/DataStream', 'org/apache/beam/sdk/util/WindowedValue$FullWindowedValueCoder', 'org/apache/beam/runners/flink/translation/types/CoderTypeInformation', 'org/apache/flink/streaming/api/datastream/DataStream', 'org/apache/beam/runners/flink/translation/wrappers/streaming/WorkItemKeySelector', 'org/apache/flink/streaming/api/datastream/KeyedStream', 'org/apache/beam/sdk/transforms/CombineFnBase$GlobalCombineFn', 'org/apache/beam/runners/core/SystemReduceFn', 'org/apache/beam/sdk/coders/Coder', 'org/apache/flink/api/common/typeinfo/TypeInformation', 'java/util/List', 'org/apache/flink/api/java/tuple/Tuple2', 'org/apache/beam/sdk/values/TupleTag', 'org/apache/beam/runners/flink/translation/wrappers/streaming/WindowDoFnOperator', 'org/apache/flink/streaming/api/transformations/TwoInputTransformation' } | |
| stack: { uninitialized 455, uninitialized 455, 'org/apache/beam/runners/flink/FlinkStreamingTransformTranslators$CombinePerKeyTranslator', 'org/apache/flink/streaming/api/environment/StreamExecutionEnvironment', 'org/apache/flink/streaming/api/transformations/TwoInputTransformation' } | |
| Bytecode: | |
| 0x0000000: 2cb8 0065 4e2c 2bb6 003b c000 3d3a 0419 | |
| 0x0000010: 04b6 0041 3a05 1904 b600 69c0 006b 3a06 | |
| 0x0000020: 1906 b600 6e19 06b6 0071 1904 b600 41b6 | |
| 0x0000030: 0047 b600 74b8 007a 3a07 2c19 04b6 007e | |
| 0x0000040: 3a08 1907 1904 b600 41b6 0047 b600 74b8 | |
| 0x0000050: 0082 3a09 bb00 8459 1909 b700 873a 0a19 | |
| 0x0000060: 08bb 0021 592c b600 8bb7 008e b600 9419 | |
| 0x0000070: 0ab6 009a 129b b600 9f3a 0bbb 00a1 5919 | |
| 0x0000080: 06b6 006e b700 a23a 0c19 0b19 0cb6 00a6 | |
| 0x0000090: 3a0d 2bc0 001c b600 aa3a 0e19 06b6 006e | |
| 0x00000a0: 190e 1904 b600 aeb6 00b4 1906 b800 bab8 | |
| 0x00000b0: 00c0 3a0f 2c2c 2bb6 00c3 c000 3db6 00c7 | |
| 0x00000c0: 3a10 2c2c 2bb6 00c3 c000 3db6 00cb 3a11 | |
| 0x00000d0: 2bc0 001c b600 513a 1219 12b9 0056 0100 | |
| 0x00000e0: 9900 61bb 00cd 5912 cfb7 00d2 3a13 bb00 | |
| 0x00000f0: d459 190f 2d19 0919 13b8 00d9 bb00 2459 | |
| 0x0000100: 1913 1910 b700 dc19 05bb 00de 59b7 00df | |
| 0x0000110: b800 d92c b600 8b19 06b6 006e 190c b700 | |
| 0x0000120: e23a 1419 0d2d 1911 1914 b600 e72d b600 | |
| 0x0000130: ea3a 152c 2c2b b600 c319 15b6 00ee a700 | |
| 0x0000140: af19 122c b800 fa3a 13bb 00cd 5912 cfb7 | |
| 0x0000150: 00d2 3a14 bb00 d459 190f 2d19 0919 14b8 | |
| 0x0000160: 00d9 bb00 2459 1914 1910 b700 dc19 0519 | |
| 0x0000170: 13b4 0100 c001 0219 122c b600 8b19 06b6 | |
| 0x0000180: 006e 190c b700 e23a 15bb 0104 5919 0db6 | |
| 0x0000190: 0108 1913 b401 0bc0 0090 b601 0fb6 0110 | |
| 0x00001a0: 2bb6 0114 1915 1911 190d b601 18b7 011b | |
| 0x00001b0: 3a16 1916 190d b601 1fb6 0123 1916 190d | |
| 0x00001c0: b601 2701 b601 2bbb 000b 592a 190d b601 | |
| 0x00001d0: 2f19 16b7 0132 3a17 190d b601 2f19 16b6 | |
| 0x00001e0: 0138 2c2c 2bb6 00c3 1917 b600 eeb1 | |
| Stackmap Table: | |
| full_frame(@321,{Object[#2],Object[#240],Object[#55],Object[#242],Object[#61],Object[#67],Object[#107],Object[#118],Object[#144],Object[#13],Object[#132],Object[#144],Object[#161],Object[#228],Object[#18],Object[#188],Object[#244],Object[#246],Object[#83]},{}) | |
| same_frame_extended(@493) | |
| at org.apache.beam.runners.flink.FlinkStreamingTransformTranslators.<clinit>(FlinkStreamingTransformTranslators.java:156) | |
| at org.apache.beam.runners.flink.FlinkStreamingPipelineTranslator.enterCompositeTransform(FlinkStreamingPipelineTranslator.java:103) | |
| at org.apache.beam.sdk.runners.TransformHierarchy$Node.visit(TransformHierarchy.java:653) | |
| at org.apache.beam.sdk.runners.TransformHierarchy$Node.visit(TransformHierarchy.java:657) | |
| at org.apache.beam.sdk.runners.TransformHierarchy$Node.access$600(TransformHierarchy.java:317) | |
| at org.apache.beam.sdk.runners.TransformHierarchy.visit(TransformHierarchy.java:251) | |
| at org.apache.beam.sdk.Pipeline.traverseTopologically(Pipeline.java:463) | |
| at org.apache.beam.runners.flink.FlinkPipelineTranslator.translate(FlinkPipelineTranslator.java:38) | |
| at org.apache.beam.runners.flink.FlinkStreamingPipelineTranslator.translate(FlinkStreamingPipelineTranslator.java:88) | |
| at org.apache.beam.runners.flink.FlinkPipelineExecutionEnvironment.translate(FlinkPipelineExecutionEnvironment.java:116) | |
| at org.apache.beam.runners.flink.FlinkRunner.run(FlinkRunner.java:107) | |
| at org.apache.beam.sdk.Pipeline.run(Pipeline.java:317) | |
| at org.apache.beam.sdk.Pipeline.run(Pipeline.java:303) | |
| at com.redacted.redacted.processing.beam.errorrate.ErrorRate.runErrorRate(ErrorRate.java:113) | |
| at com.redacted.redacted.processing.beam.errorrate.ErrorRate.main(ErrorRate.java:54) | |
| at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) | |
| at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) | |
| at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) | |
| at java.lang.reflect.Method.invoke(Method.java:498) | |
| at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:529) | |
| at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:421) | |
| at org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:423) | |
| at org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:813) | |
| at org.apache.flink.client.cli.CliFrontend.runProgram(CliFrontend.java:287) | |
| at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:213) | |
| at org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:1050) | |
| at org.apache.flink.client.cli.CliFrontend.lambda$main$11(CliFrontend.java:1126) | |
| at org.apache.flink.runtime.security.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:30) | |
| at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1126) | |
| make: *** [flink-run] Error 31 |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment