[BEAM-10079] Samza tests failing [Java 11] - ASF JIRA

XML

Word

Printable

JSON

Details

Type: Sub-task
Status: Open
Priority: P3
Resolution: Unresolved
Affects Version/s: None
Fix Version/s: None
Component/s: runner-samza
Labels:
None

Description

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)

Attachments

Issue Links

Blocked

SAMZA-2757 Make Samza Compatible with Java 11

Resolved

Activity

People

Assignee:: Unassigned

Reporter:: Pawel Pasterz

Votes:: 0 Vote for this issue

Watchers:: 7 Start watching this issue

Dates

Created:: 26/May/20 09:10

Updated:: 26/Aug/22 17:03