Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- java.lang.ClassCastException: test.testdriver.join.TestKey incompatible with test.testdriver.join.TestCtrl
- at test.testdriver.join.JoinTest$$Lambda$424.0000000012EB14E0.apply(Unknown Source)
- at org.apache.kafka.streams.kstream.internals.AbstractStream.lambda$reverseJoiner$0(AbstractStream.java:98)
- at org.apache.kafka.streams.kstream.internals.AbstractStream$$Lambda$428.0000000012E908F0.apply(Unknown Source)
- at org.apache.kafka.streams.kstream.internals.KStreamKStreamJoin$KStreamKStreamJoinProcessor.process(KStreamKStreamJoin.java:94)
- at org.apache.kafka.streams.processor.internals.ProcessorNode.process(ProcessorNode.java:117)
- at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:183)
- at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:162)
- at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:122)
- at org.apache.kafka.streams.kstream.internals.KStreamJoinWindow$KStreamJoinWindowProcessor.process(KStreamJoinWindow.java:55)
- at org.apache.kafka.streams.processor.internals.ProcessorNode.process(ProcessorNode.java:117)
- at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:183)
- at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:162)
- at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:122)
- at org.apache.kafka.streams.processor.internals.SourceNode.process(SourceNode.java:87)
- at org.apache.kafka.streams.processor.internals.StreamTask.process(StreamTask.java:364)
- at org.apache.kafka.streams.TopologyTestDriver.pipeInput(TopologyTestDriver.java:406)
- at org.apache.kafka.streams.TopologyTestDriver.captureOutputRecords(TopologyTestDriver.java:472)
- at org.apache.kafka.streams.TopologyTestDriver.pipeInput(TopologyTestDriver.java:409)
- at test.testdriver.join.JoinTest.testJoin(JoinTest.java:68)
- at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
- at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:90)
- at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:55)
- at java.lang.reflect.Method.invoke(Method.java:508)
- at org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:532)
- at org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:115)
- at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$6(TestMethodTestDescriptor.java:171)
- at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor$$Lambda$421.0000000012FA2660.execute(Unknown Source)
- at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:72)
- at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:167)
- at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:114)
- at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:59)
- at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$4(NodeTestTask.java:108)
- at org.junit.platform.engine.support.hierarchical.NodeTestTask$$Lambda$137.000000000F9064E0.execute(Unknown Source)
- at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:72)
- at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:98)
- at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:74)
- at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService$$Lambda$141.00000000122D1F50.accept(Unknown Source)
- at java.util.ArrayList.forEach(ArrayList.java:1268)
- at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:38)
- at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$4(NodeTestTask.java:112)
- at org.junit.platform.engine.support.hierarchical.NodeTestTask$$Lambda$137.000000000F9064E0.execute(Unknown Source)
- at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:72)
- at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:98)
- at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:74)
- at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService$$Lambda$141.00000000122D1F50.accept(Unknown Source)
- at java.util.ArrayList.forEach(ArrayList.java:1268)
- at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:38)
- at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$4(NodeTestTask.java:112)
- at org.junit.platform.engine.support.hierarchical.NodeTestTask$$Lambda$137.000000000F9064E0.execute(Unknown Source)
- at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:72)
- at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:98)
- at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:74)
- at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:32)
- at org.junit.platform.engine.support.hierarchical.HierarchicalTestExecutor.execute(HierarchicalTestExecutor.java:57)
- at org.junit.platform.engine.support.hierarchical.HierarchicalTestEngine.execute(HierarchicalTestEngine.java:51)
- at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:220)
- at org.junit.platform.launcher.core.DefaultLauncher.lambda$execute$6(DefaultLauncher.java:188)
- at org.junit.platform.launcher.core.DefaultLauncher$$Lambda$116.00000000122A2870.accept(Unknown Source)
- at org.junit.platform.launcher.core.DefaultLauncher.withInterceptedStreams(DefaultLauncher.java:202)
- at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:181)
- at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:128)
- at org.eclipse.jdt.internal.junit5.runner.JUnit5TestReference.run(JUnit5TestReference.java:86)
- at org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38)
- at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:538)
- at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:760)
- at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:460)
- at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:206)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement