damccorm opened a new issue, #20291:
URL: https://github.com/apache/beam/issues/20291
Gradle task *_:runners:samza:test_* fails during Java 11 Precommit job
Example stack trace:
```
> 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)
```
Imported from Jira
[BEAM-10079](https://issues.apache.org/jira/browse/BEAM-10079). Original Jira
may contain additional context.
Reported by: pawel.pasterz.
Subtask of issue #20290
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
