[ https://issues.apache.org/jira/browse/BEAM-10079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17125394#comment-17125394 ]
Kenneth Knowles commented on BEAM-10079: ---------------------------------------- [~xinyu] are you familiar with this error? I have never seen it actually. > Samza tests failing [Java 11] > ----------------------------- > > Key: BEAM-10079 > URL: https://issues.apache.org/jira/browse/BEAM-10079 > Project: Beam > Issue Type: Sub-task > Components: runner-samza > Reporter: Pawel Pasterz > Priority: P2 > > Gradle task *_:runners:samza:test_* fails during Java 11 Precommit job > > Example stack trace: > {code:java} > > Task :runners:samza:test > May 26, 2020 7:33:55 AM > org.apache.beam.runners.samza.runtime.SamzaTimerInternalsFactory$SamzaTimerState > loadEventTimeTimers > INFO: Loaded 0 event time timers in memory > May 26, 2020 7:33:55 AM > org.apache.beam.runners.samza.runtime.SamzaTimerInternalsFactory$SamzaTimerState > loadProcessingTimeTimers > INFO: Loaded 0 processing time timers in memory > May 26, 2020 7:33:56 AM org.apache.samza.util.Logging$class info > INFO: Registering task instances with consumers. > May 26, 2020 7:33:56 AM org.apache.samza.util.Logging$class info > INFO: Starting consumer multiplexer. > May 26, 2020 7:33:56 AM org.apache.samza.util.Logging$class info > INFO: Entering run loop. > May 26, 2020 7:33:56 AM > org.apache.samza.processor.StreamProcessor$ContainerListener afterStart > WARNING: Received container start notification for container: > org.apache.samza.container.SamzaContainer@af148fb in stream processor: 1. > May 26, 2020 7:33:56 AM org.apache.samza.util.Logging$class info > INFO: End of stream reached for partition: SystemStreamPartition > [11-PAssert_0_GroupGlobally_Create_Values_Read_CreateSource__out__PCollection_, > > 11-PAssert_0_GroupGlobally_Create_Values_Read_CreateSource__out__PCollection_, > 0] > May 26, 2020 7:33:56 AM org.apache.beam.runners.samza.runtime.OpAdapter > processWatermark > SEVERE: Op org.apache.beam.runners.samza.runtime.OpAdapter threw an > exception during processing watermark > java.lang.RuntimeException: org.apache.beam.sdk.util.UserCodeException: > java.lang.IncompatibleClassChangeError: Method > org.apache.samza.storage.kv.KeyValueStore.deleteAll(Ljava/util/List;)V must > be InterfaceMethodref constant > at > org.apache.beam.runners.samza.metrics.DoFnRunnerWithMetrics.withMetrics(DoFnRunnerWithMetrics.java:98) > at > org.apache.beam.runners.samza.metrics.DoFnRunnerWithMetrics.processElement(DoFnRunnerWithMetrics.java:55) > at > org.apache.beam.runners.samza.runtime.GroupByKeyOp.fireTimer(GroupByKeyOp.java:225) > at > org.apache.beam.runners.samza.runtime.GroupByKeyOp.processWatermark(GroupByKeyOp.java:203) > at > org.apache.beam.runners.samza.runtime.OpAdapter.processWatermark(OpAdapter.java:109) > at > org.apache.samza.operators.impl.OperatorImpl.onWatermark(OperatorImpl.java:399) > at > org.apache.samza.operators.impl.OperatorImpl.lambda$propagateWatermark$26(OperatorImpl.java:433) > at > java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195) > at > java.base/java.util.HashMap$KeySpliterator.forEachRemaining(HashMap.java:1603) > at > java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) > at > java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) > at > java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:550) > at > java.base/java.util.stream.AbstractPipeline.evaluateToArrayNode(AbstractPipeline.java:260) > at > java.base/java.util.stream.ReferencePipeline.toArray(ReferencePipeline.java:517) > at > org.apache.samza.operators.impl.OperatorImpl.propagateWatermark(OperatorImpl.java:434) > at > org.apache.samza.operators.impl.OperatorImpl.lambda$onWatermark$25(OperatorImpl.java:416) > at > java.base/java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:1106) > at > java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2235) > at > java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:143) > at > org.apache.samza.operators.impl.OperatorImpl.onWatermark(OperatorImpl.java:416) > at > org.apache.samza.operators.impl.OperatorImpl.lambda$propagateWatermark$26(OperatorImpl.java:433) > at > java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195) > at > java.base/java.util.HashMap$KeySpliterator.forEachRemaining(HashMap.java:1603) > at > java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) > at > java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) > at > java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:550) > at > java.base/java.util.stream.AbstractPipeline.evaluateToArrayNode(AbstractPipeline.java:260) > at > java.base/java.util.stream.ReferencePipeline.toArray(ReferencePipeline.java:517) > at > org.apache.samza.operators.impl.OperatorImpl.propagateWatermark(OperatorImpl.java:434) > at > org.apache.samza.operators.impl.OperatorImpl.lambda$onWatermark$25(OperatorImpl.java:416) > at > java.base/java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:1106) > at > java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2235) > at > java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:143) > at > org.apache.samza.operators.impl.OperatorImpl.onWatermark(OperatorImpl.java:416) > at > org.apache.samza.operators.impl.OperatorImpl.lambda$propagateWatermark$26(OperatorImpl.java:433) > at > java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195) > at > java.base/java.util.HashMap$KeySpliterator.forEachRemaining(HashMap.java:1603) > at > java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) > at > java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) > at > java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:550) > at > java.base/java.util.stream.AbstractPipeline.evaluateToArrayNode(AbstractPipeline.java:260) > at > java.base/java.util.stream.ReferencePipeline.toArray(ReferencePipeline.java:517) > at > org.apache.samza.operators.impl.OperatorImpl.propagateWatermark(OperatorImpl.java:434) > at > org.apache.samza.operators.impl.OperatorImpl.lambda$onWatermark$25(OperatorImpl.java:416) > at > java.base/java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:1106) > at > java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2235) > at > java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:143) > at > org.apache.samza.operators.impl.OperatorImpl.onWatermark(OperatorImpl.java:416) > at > org.apache.samza.operators.impl.OperatorImpl.lambda$propagateWatermark$26(OperatorImpl.java:433) > at > java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195) > at > java.base/java.util.HashMap$KeySpliterator.forEachRemaining(HashMap.java:1603) > at > java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) > at > java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) > at > java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:550) > at > java.base/java.util.stream.AbstractPipeline.evaluateToArrayNode(AbstractPipeline.java:260) > at > java.base/java.util.stream.ReferencePipeline.toArray(ReferencePipeline.java:517) > at > org.apache.samza.operators.impl.OperatorImpl.propagateWatermark(OperatorImpl.java:434) > at > org.apache.samza.operators.impl.OperatorImpl.lambda$onWatermark$25(OperatorImpl.java:416) > at > java.base/java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:1106) > at > java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2235) > at > java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:143) > at > org.apache.samza.operators.impl.OperatorImpl.onWatermark(OperatorImpl.java:416) > at > org.apache.samza.operators.impl.OperatorImpl.lambda$propagateWatermark$26(OperatorImpl.java:433) > at > java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195) > at > java.base/java.util.HashMap$KeySpliterator.forEachRemaining(HashMap.java:1603) > at > java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) > at > java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) > at > java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:550) > at > java.base/java.util.stream.AbstractPipeline.evaluateToArrayNode(AbstractPipeline.java:260) > at > java.base/java.util.stream.ReferencePipeline.toArray(ReferencePipeline.java:517) > at > org.apache.samza.operators.impl.OperatorImpl.propagateWatermark(OperatorImpl.java:434) > at > org.apache.samza.operators.impl.OperatorImpl.lambda$onWatermark$25(OperatorImpl.java:416) > at > java.base/java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:1106) > at > java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2235) > at > java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:143) > at > org.apache.samza.operators.impl.OperatorImpl.onWatermark(OperatorImpl.java:416) > at > org.apache.samza.operators.impl.OperatorImpl.lambda$propagateWatermark$26(OperatorImpl.java:433) > at > java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195) > at > java.base/java.util.HashMap$KeySpliterator.forEachRemaining(HashMap.java:1603) > at > java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) > at > java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) > at > java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:550) > at > java.base/java.util.stream.AbstractPipeline.evaluateToArrayNode(AbstractPipeline.java:260) > at > java.base/java.util.stream.ReferencePipeline.toArray(ReferencePipeline.java:517) > at > org.apache.samza.operators.impl.OperatorImpl.propagateWatermark(OperatorImpl.java:434) > at > org.apache.samza.operators.impl.OperatorImpl.lambda$onWatermark$25(OperatorImpl.java:416) > at > java.base/java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:1106) > at > java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2235) > at > java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:143) > at > org.apache.samza.operators.impl.OperatorImpl.onWatermark(OperatorImpl.java:416) > at > org.apache.samza.operators.impl.OperatorImpl.lambda$propagateWatermark$26(OperatorImpl.java:433) > at > java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195) > at > java.base/java.util.HashMap$KeySpliterator.forEachRemaining(HashMap.java:1603) > at > java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) > at > java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) > at > java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:550) > at > java.base/java.util.stream.AbstractPipeline.evaluateToArrayNode(AbstractPipeline.java:260) > at > java.base/java.util.stream.ReferencePipeline.toArray(ReferencePipeline.java:517) > at > org.apache.samza.operators.impl.OperatorImpl.propagateWatermark(OperatorImpl.java:434) > at > org.apache.samza.operators.impl.OperatorImpl.lambda$onWatermark$25(OperatorImpl.java:416) > at > java.base/java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:1106) > at > java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2235) > at > java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:143) > at > org.apache.samza.operators.impl.OperatorImpl.onWatermark(OperatorImpl.java:416) > at > org.apache.samza.operators.impl.OperatorImpl.lambda$propagateWatermark$26(OperatorImpl.java:433) > at > java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195) > at > java.base/java.util.HashMap$KeySpliterator.forEachRemaining(HashMap.java:1603) > at > java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) > at > java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) > at > java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:550) > at > java.base/java.util.stream.AbstractPipeline.evaluateToArrayNode(AbstractPipeline.java:260) > at > java.base/java.util.stream.ReferencePipeline.toArray(ReferencePipeline.java:517) > at > org.apache.samza.operators.impl.OperatorImpl.propagateWatermark(OperatorImpl.java:434) > at > org.apache.samza.operators.impl.OperatorImpl.lambda$onWatermark$25(OperatorImpl.java:416) > at > java.base/java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:1106) > at > java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2235) > at > java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:143) > at > org.apache.samza.operators.impl.OperatorImpl.onWatermark(OperatorImpl.java:416) > at > org.apache.samza.operators.impl.OperatorImpl.lambda$propagateWatermark$26(OperatorImpl.java:433) > at > java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195) > at > java.base/java.util.HashMap$KeySpliterator.forEachRemaining(HashMap.java:1603) > at > java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) > at > java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) > at > java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:550) > at > java.base/java.util.stream.AbstractPipeline.evaluateToArrayNode(AbstractPipeline.java:260) > at > java.base/java.util.stream.ReferencePipeline.toArray(ReferencePipeline.java:517) > at > org.apache.samza.operators.impl.OperatorImpl.propagateWatermark(OperatorImpl.java:434) > at > org.apache.samza.operators.impl.OperatorImpl.lambda$onWatermark$25(OperatorImpl.java:416) > at > java.base/java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:1106) > at > java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2235) > at > java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:143) > at > org.apache.samza.operators.impl.OperatorImpl.onWatermark(OperatorImpl.java:416) > at > org.apache.samza.operators.impl.OperatorImpl.lambda$propagateWatermark$26(OperatorImpl.java:433) > at > java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195) > at > java.base/java.util.HashMap$KeySpliterator.forEachRemaining(HashMap.java:1603) > at > java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) > at > java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) > at > java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:550) > at > java.base/java.util.stream.AbstractPipeline.evaluateToArrayNode(AbstractPipeline.java:260) > at > java.base/java.util.stream.ReferencePipeline.toArray(ReferencePipeline.java:517) > at > org.apache.samza.operators.impl.OperatorImpl.propagateWatermark(OperatorImpl.java:434) > at > org.apache.samza.operators.impl.OperatorImpl.lambda$onWatermark$25(OperatorImpl.java:416) > at > java.base/java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:1106) > at > java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2235) > at > java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:143) > at > org.apache.samza.operators.impl.OperatorImpl.onWatermark(OperatorImpl.java:416) > at > org.apache.samza.operators.impl.OperatorImpl.lambda$propagateWatermark$26(OperatorImpl.java:433) > at > java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195) > at > java.base/java.util.HashMap$KeySpliterator.forEachRemaining(HashMap.java:1603) > at > java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) > at > java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) > at > java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:550) > at > java.base/java.util.stream.AbstractPipeline.evaluateToArrayNode(AbstractPipeline.java:260) > at > java.base/java.util.stream.ReferencePipeline.toArray(ReferencePipeline.java:517) > at > org.apache.samza.operators.impl.OperatorImpl.propagateWatermark(OperatorImpl.java:434) > at > org.apache.samza.operators.impl.OperatorImpl.lambda$onWatermark$25(OperatorImpl.java:416) > at > java.base/java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:1106) > at > java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2235) > at > java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:143) > at > org.apache.samza.operators.impl.OperatorImpl.onWatermark(OperatorImpl.java:416) > at > org.apache.samza.operators.impl.OperatorImpl.lambda$propagateWatermark$26(OperatorImpl.java:433) > at > java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195) > at > java.base/java.util.HashMap$KeySpliterator.forEachRemaining(HashMap.java:1603) > at > java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) > at > java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) > at > java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:550) > at > java.base/java.util.stream.AbstractPipeline.evaluateToArrayNode(AbstractPipeline.java:260) > at > java.base/java.util.stream.ReferencePipeline.toArray(ReferencePipeline.java:517) > at > org.apache.samza.operators.impl.OperatorImpl.propagateWatermark(OperatorImpl.java:434) > at > org.apache.samza.operators.impl.OperatorImpl.lambda$onWatermark$25(OperatorImpl.java:416) > at > java.base/java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:1106) > at > java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2235) > at > java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:143) > at > org.apache.samza.operators.impl.OperatorImpl.onWatermark(OperatorImpl.java:416) > at > org.apache.samza.operators.impl.OperatorImpl.lambda$propagateWatermark$26(OperatorImpl.java:433) > at > java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195) > at > java.base/java.util.HashMap$KeySpliterator.forEachRemaining(HashMap.java:1603) > at > java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) > at > java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) > at > java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:550) > at > java.base/java.util.stream.AbstractPipeline.evaluateToArrayNode(AbstractPipeline.java:260) > at > java.base/java.util.stream.ReferencePipeline.toArray(ReferencePipeline.java:517) > at > org.apache.samza.operators.impl.OperatorImpl.propagateWatermark(OperatorImpl.java:434) > at > org.apache.samza.operators.impl.OperatorImpl.lambda$onWatermark$25(OperatorImpl.java:416) > at > java.base/java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:1106) > at > java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2235) > at > java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:143) > at > org.apache.samza.operators.impl.OperatorImpl.onWatermark(OperatorImpl.java:416) > at > org.apache.samza.operators.impl.OperatorImpl.lambda$propagateWatermark$26(OperatorImpl.java:433) > at > java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195) > at > java.base/java.util.HashMap$KeySpliterator.forEachRemaining(HashMap.java:1603) > at > java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) > at > java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) > at > java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:550) > at > java.base/java.util.stream.AbstractPipeline.evaluateToArrayNode(AbstractPipeline.java:260) > at > java.base/java.util.stream.ReferencePipeline.toArray(ReferencePipeline.java:517) > at > org.apache.samza.operators.impl.OperatorImpl.propagateWatermark(OperatorImpl.java:434) > at > org.apache.samza.operators.impl.OperatorImpl.lambda$onWatermark$25(OperatorImpl.java:416) > at > java.base/java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:1106) > at > java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2235) > at > java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:143) > at > org.apache.samza.operators.impl.OperatorImpl.onWatermark(OperatorImpl.java:416) > at > org.apache.samza.operators.impl.OperatorImpl.lambda$propagateWatermark$26(OperatorImpl.java:433) > at > java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195) > at > java.base/java.util.HashMap$KeySpliterator.forEachRemaining(HashMap.java:1603) > at > java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) > at > java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) > at > java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:550) > at > java.base/java.util.stream.AbstractPipeline.evaluateToArrayNode(AbstractPipeline.java:260) > at > java.base/java.util.stream.ReferencePipeline.toArray(ReferencePipeline.java:517) > at > org.apache.samza.operators.impl.OperatorImpl.propagateWatermark(OperatorImpl.java:434) > at > org.apache.samza.operators.impl.OperatorImpl.lambda$onWatermark$25(OperatorImpl.java:416) > at > java.base/java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:1106) > at > java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2235) > at > java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:143) > at > org.apache.samza.operators.impl.OperatorImpl.onWatermark(OperatorImpl.java:416) > at > org.apache.samza.operators.impl.OperatorImpl.aggregateWatermark(OperatorImpl.java:360) > at > org.apache.samza.task.StreamOperatorTask.lambda$processAsync$1(StreamOperatorTask.java:133) > at > org.apache.samza.task.StreamOperatorTask.processAsync(StreamOperatorTask.java:161) > at > org.apache.samza.container.TaskInstance$$anonfun$process$1.apply$mcV$sp(TaskInstance.scala:187) > at > org.apache.samza.container.TaskInstanceExceptionHandler.maybeHandle(TaskInstanceExceptionHandler.scala:54) > at > org.apache.samza.container.TaskInstance.process(TaskInstance.scala:185) > at > org.apache.samza.container.RunLoop$AsyncTaskWorker.process(RunLoop.java:481) > at > org.apache.samza.container.RunLoop$AsyncTaskWorker.run(RunLoop.java:423) > at > org.apache.samza.container.RunLoop$AsyncTaskWorker.access$300(RunLoop.java:357) > at org.apache.samza.container.RunLoop.runTasks(RunLoop.java:244) > at org.apache.samza.container.RunLoop.run(RunLoop.java:176) > at > org.apache.samza.container.SamzaContainer.run(SamzaContainer.scala:768) > at > java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) > at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) > at > java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) > at > java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) > at java.base/java.lang.Thread.run(Thread.java:834) > Caused by: org.apache.beam.sdk.util.UserCodeException: > java.lang.IncompatibleClassChangeError: Method > org.apache.samza.storage.kv.KeyValueStore.deleteAll(Ljava/util/List;)V must > be InterfaceMethodref constant > at > org.apache.beam.sdk.util.UserCodeException.wrap(UserCodeException.java:36) > at > org.apache.beam.runners.core.GroupAlsoByWindowViaWindowSetNewDoFn$DoFnInvoker.invokeProcessElement(Unknown > Source) > at > org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:227) > at > org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:186) > at > org.apache.beam.runners.samza.metrics.DoFnRunnerWithMetrics.lambda$processElement$0(DoFnRunnerWithMetrics.java:55) > at > org.apache.beam.runners.samza.metrics.DoFnRunnerWithMetrics.lambda$withMetrics$2(DoFnRunnerWithMetrics.java:93) > at > org.apache.beam.runners.samza.metrics.FnWithMetricsWrapper.wrap(FnWithMetricsWrapper.java:42) > at > org.apache.beam.runners.samza.metrics.DoFnRunnerWithMetrics.withMetrics(DoFnRunnerWithMetrics.java:91) > ... 232 more > Caused by: java.lang.IncompatibleClassChangeError: Method > org.apache.samza.storage.kv.KeyValueStore.deleteAll(Ljava/util/List;)V must > be InterfaceMethodref constant > at > org.apache.samza.storage.kv.CachedStore.deleteAll(CachedStore.scala:252) > at > org.apache.samza.storage.kv.NullSafeKeyValueStore.deleteAll(NullSafeKeyValueStore.scala:71) > at > org.apache.samza.storage.kv.KeyValueStorageEngine$$anonfun$deleteAll$1.apply$mcV$sp(KeyValueStorageEngine.scala:91) > at > org.apache.samza.storage.kv.KeyValueStorageEngine$$anonfun$deleteAll$1.apply(KeyValueStorageEngine.scala:88) > at > org.apache.samza.storage.kv.KeyValueStorageEngine$$anonfun$deleteAll$1.apply(KeyValueStorageEngine.scala:88) > at org.apache.samza.util.TimerUtil$class.updateTimer(TimerUtil.scala:37) > at > org.apache.samza.storage.kv.KeyValueStorageEngine.updateTimer(KeyValueStorageEngine.scala:39) > at > org.apache.samza.storage.kv.KeyValueStorageEngine.deleteAll(KeyValueStorageEngine.scala:88) > at > org.apache.beam.runners.samza.runtime.SamzaStoreStateInternals$SamzaBagState.clear(SamzaStoreStateInternals.java:459) > at > org.apache.beam.runners.core.SystemReduceFn.clearState(SystemReduceFn.java:130) > at > org.apache.beam.runners.core.ReduceFnRunner.clearAllState(ReduceFnRunner.java:846) > at > org.apache.beam.runners.core.ReduceFnRunner.onTimers(ReduceFnRunner.java:778) > at > org.apache.beam.runners.core.GroupAlsoByWindowViaWindowSetNewDoFn.processElement(GroupAlsoByWindowViaWindowSetNewDoFn.java:137) > {code} -- This message was sent by Atlassian Jira (v8.3.4#803005)