You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
WARNING: [10.0.0.111]:5701 [jet] [0.5-SNAPSHOT] Execution of job f386-dc91-5e0f-6788, execution 7ba7-f70a-7961-f9f5 failed in 29242 ms
com.hazelcast.jet.JetException: Exception in ProcessorTasklet{vertex=verification, processor=tests.kafka.HashJoinP@b6112a5}: java.lang.AssertionError: produced results are not matching for ticker -> MSFT expected -> 14264.0, actual -> 13548.09687490347
at com.hazelcast.jet.impl.execution.TaskletExecutionService$CooperativeWorker.run(TaskletExecutionService.java:215)
at java.lang.Thread.run(Thread.java:748)
at ------ submitted from ------.(Unknown Source)
at com.hazelcast.spi.impl.operationservice.impl.InvocationFuture.resolve(InvocationFuture.java:127)
at com.hazelcast.spi.impl.AbstractInvocationFuture$1.run(AbstractInvocationFuture.java:243)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
at com.hazelcast.util.executor.HazelcastManagedThread.executeRun(HazelcastManagedThread.java:64)
at com.hazelcast.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:80)
at ------ submitted from ------.(Unknown Source)
at com.hazelcast.spi.impl.operationservice.impl.InvocationFuture.resolve(InvocationFuture.java:127)
at com.hazelcast.spi.impl.operationservice.impl.InvocationFuture.resolveAndThrowIfException(InvocationFuture.java:79)
at com.hazelcast.spi.impl.AbstractInvocationFuture.get(AbstractInvocationFuture.java:147)
at com.hazelcast.jet.impl.MasterContext.lambda$invoke$15(MasterContext.java:551)
at com.hazelcast.jet.impl.util.ExceptionUtil.lambda$withTryCatch$0(ExceptionUtil.java:132)
at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:760)
at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:736)
at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1962)
at com.hazelcast.jet.impl.MasterContext.lambda$invokeOnParticipants$19(MasterContext.java:600)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
at com.hazelcast.util.executor.HazelcastManagedThread.executeRun(HazelcastManagedThread.java:64)
at com.hazelcast.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:80)
Caused by: java.lang.AssertionError: produced results are not matching for ticker -> MSFT expected -> 14264.0, actual -> 13548.09687490347
at tests.kafka.HashJoinP.tryProcess(HashJoinP.java:60)
at com.hazelcast.jet.core.AbstractProcessor.tryProcess1(AbstractProcessor.java:223)
at com.hazelcast.jet.core.AbstractProcessor.process1(AbstractProcessor.java:681)
at com.hazelcast.jet.core.AbstractProcessor.process(AbstractProcessor.java:131)
at com.hazelcast.jet.impl.execution.ProcessorTasklet.stateMachineStep(ProcessorTasklet.java:141)
at com.hazelcast.jet.impl.execution.ProcessorTasklet.call(ProcessorTasklet.java:125)
at com.hazelcast.jet.impl.execution.TaskletExecutionService$CooperativeWorker.run(TaskletExecutionService.java:207)
at java.lang.Thread.run(Thread.java:748)
The text was updated successfully, but these errors were encountered:
The text was updated successfully, but these errors were encountered: