You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "Beam JIRA Bot (Jira)" <ji...@apache.org> on 2020/09/23 17:08:02 UTC
[jira] [Updated] (BEAM-10079) Samza tests failing [Java 11]
[ https://issues.apache.org/jira/browse/BEAM-10079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Beam JIRA Bot updated BEAM-10079:
---------------------------------
Labels: stale-P2 (was: )
> 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
> Labels: stale-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)