Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

com.hazelcast.client.console.HazelcastCommandLineTest.test_resumeJob_byJobId #26289

Open
olukas opened this issue Mar 18, 2024 · 1 comment
Open
Labels
Milestone

Comments

@olukas
Copy link
Contributor

olukas commented Mar 18, 2024

master (commit f495e4243cba12bac9b4028b7e14f1c3a4698986)

Failed on Openj9-17: https://jenkins.hazelcast.com/job/Hazelcast-master-Openj9-17/111/testReport/com.hazelcast.client.console/HazelcastCommandLineTest/test_resumeJob_byJobId/

Stacktrace:
java.lang.NullPointerException
	at java.base/java.lang.StringConcatHelper.simpleConcat(StringConcatHelper.java)
	at com.hazelcast.jet.core.JetTestSupport.lambda$assertJobStatusEventually$2(JetTestSupport.java:338)
	at com.hazelcast.test.HazelcastTestSupport.assertTrueEventually(HazelcastTestSupport.java:1200)
	at com.hazelcast.test.HazelcastTestSupport.assertTrueEventually(HazelcastTestSupport.java:1219)
	at com.hazelcast.jet.core.JetTestSupport.assertJobStatusEventually(JetTestSupport.java:337)
	at com.hazelcast.jet.core.JetTestSupport.assertJobStatusEventually(JetTestSupport.java:253)
	at com.hazelcast.client.console.HazelcastCommandLineTest.newJob(HazelcastCommandLineTest.java:834)
	at com.hazelcast.client.console.HazelcastCommandLineTest.newJob(HazelcastCommandLineTest.java:825)
	at com.hazelcast.client.console.HazelcastCommandLineTest.test_resumeJob_byJobId(HazelcastCommandLineTest.java:315)
	at java.base/java.lang.reflect.Method.invoke(Method.java:568)
	at com.hazelcast.test.FailOnTimeoutStatement$CallableStatement.call(FailOnTimeoutStatement.java:115)
	at com.hazelcast.test.FailOnTimeoutStatement$CallableStatement.call(FailOnTimeoutStatement.java:107)
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
	at java.base/java.lang.Thread.run(Thread.java:857)

Standard output:
Finished Running Test: testTargetsAfterCommandTakesPrecedence in 3.726 seconds.
Started Running Test: test_resumeJob_byJobId
13:07:54,072  INFO |test_resumeJob_byJobId| - [MetricsConfigHelper] Time-limited test - [LOCAL] [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Overridden metrics configuration with system property 'hazelcast.metrics.collection.frequency'='1' -> 'MetricsConfig.collectionFrequencySeconds'='1'
13:07:54,072  INFO |test_resumeJob_byJobId| - [logo] Time-limited test - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] 
    o    o     o     o---o   o--o o      o---o     o     o----o o--o--o
    |    |    / \       /         |     /         / \    |         |
    o----o       o     o   o----o |    o             o   o----o    |
    |    |  *     \   /           |     \       *     \       |    |
    o    o *       o o---o   o--o o----o o---o *       o o----o    o

13:07:54,072  INFO |test_resumeJob_byJobId| - [system] Time-limited test - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Copyright (c) 2008-2024, Hazelcast, Inc. All Rights Reserved.
13:07:54,072  INFO |test_resumeJob_byJobId| - [system] Time-limited test - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Hazelcast Platform 5.5.0-SNAPSHOT (20240314) starting at [127.0.0.1]:5701
13:07:54,072  INFO |test_resumeJob_byJobId| - [system] Time-limited test - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Cluster name: 2d5690aa-2dec-4496-ba6a-1455b1b39f2d
13:07:54,072  INFO |test_resumeJob_byJobId| - [system] Time-limited test - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Integrity Checker is disabled. Fail-fast on corrupted executables will not be performed. For more information, see the documentation for Integrity Checker.
13:07:54,072  INFO |test_resumeJob_byJobId| - [system] Time-limited test - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Jet is enabled
13:07:54,079  INFO |test_resumeJob_byJobId| - [MetricsConfigHelper] Time-limited test - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Collecting debug metrics and sending to diagnostics is enabled
13:07:54,095  WARN |test_resumeJob_byJobId| - [CPSubsystem] Time-limited test - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] CP Subsystem is not enabled. CP data structures will operate in UNSAFE mode! Please note that UNSAFE mode will not provide strong consistency guarantees.
13:07:54,109  INFO |test_resumeJob_byJobId| - [JetServiceBackend] Time-limited test - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Setting number of cooperative threads and default parallelism to 2
13:07:54,111  INFO |test_resumeJob_byJobId| - [Diagnostics] Time-limited test - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Diagnostics disabled. To enable add -Dhazelcast.diagnostics.enabled=true to the JVM arguments.
13:07:54,112  INFO |test_resumeJob_byJobId| - [LifecycleService] Time-limited test - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] [127.0.0.1]:5701 is STARTING
13:07:54,112  INFO |test_resumeJob_byJobId| - [ClusterService] Time-limited test - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] 

Members {size:1, ver:1} [
	Member [127.0.0.1]:5701 - 7f588bcf-011d-491e-a293-4a8e824d18d6 this
]

13:07:54,112  INFO |test_resumeJob_byJobId| - [JobCoordinationService] Time-limited test - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Jet started scanning for jobs
13:07:54,113  INFO |test_resumeJob_byJobId| - [LifecycleService] Time-limited test - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] [127.0.0.1]:5701 is STARTED
13:07:54,113 DEBUG |test_resumeJob_byJobId| - [JobCoordinationService] hz.HazelcastCommandLineTest_romantic_ptolemy.cached.thread-1 - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Not starting jobs because partitions are not yet initialized.
13:07:54,116  INFO |test_resumeJob_byJobId| - [ClientInvocationService] Time-limited test - hz.client_4279 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Running with 2 response threads, dynamic=true
13:07:54,118  INFO |test_resumeJob_byJobId| - [LifecycleService] Time-limited test - hz.client_4279 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] HazelcastClient 5.5.0-SNAPSHOT (20240314) is STARTING
13:07:54,118  INFO |test_resumeJob_byJobId| - [LifecycleService] Time-limited test - hz.client_4279 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] HazelcastClient 5.5.0-SNAPSHOT (20240314) is STARTED
13:07:54,122  INFO |test_resumeJob_byJobId| - [ClientConnectionManager] Time-limited test - hz.client_4279 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Trying to connect to cluster: 2d5690aa-2dec-4496-ba6a-1455b1b39f2d
13:07:54,122  INFO |test_resumeJob_byJobId| - [ClientConnectionManager] Time-limited test - hz.client_4279 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Trying to connect to [127.0.0.1]:5701
13:07:54,122  INFO |test_resumeJob_byJobId| - [HazelcastClient] Time-limited test - Created connection to endpoint: [127.0.0.1]:5701, connection: MockedClientConnection{localAddress=[127.0.0.1]:40001, super=ClientConnection{alive=true, connectionId=1, channel=null, remoteAddress=null, lastReadTime=never, lastWriteTime=never, closedTime=never}}
13:07:54,122 DEBUG |test_resumeJob_byJobId| - [AuthenticationMessageTask] hz.HazelcastCommandLineTest_romantic_ptolemy.priority-generic-operation.thread-0 - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Processing authentication with clientUuid 79101fa1-ef17-4deb-bc0a-14359ef956f2 and clientName hz.client_4279
13:07:54,123  INFO |test_resumeJob_byJobId| - [AuthenticationMessageTask] hz.HazelcastCommandLineTest_romantic_ptolemy.priority-generic-operation.thread-0 - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Received auth from MockedNodeConnection{ remoteAddress = [127.0.0.1]:40001, localAddress = [127.0.0.1]:5701, connectionId = 1}, successfully authenticated, clientUuid: 79101fa1-ef17-4deb-bc0a-14359ef956f2, client name: hz.client_4279, client version: 5.5.0-SNAPSHOT
13:07:54,124  INFO |test_resumeJob_byJobId| - [ClientClusterService] Time-limited test - hz.client_4279 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] 

Members [1] {
	Member [127.0.0.1]:5701 - 7f588bcf-011d-491e-a293-4a8e824d18d6
}

13:07:54,124  INFO |test_resumeJob_byJobId| - [LifecycleService] Time-limited test - hz.client_4279 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] HazelcastClient 5.5.0-SNAPSHOT (20240314) is CLIENT_CONNECTED
13:07:54,124  INFO |test_resumeJob_byJobId| - [ClientConnectionManager] Time-limited test - hz.client_4279 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Authenticated with server [127.0.0.1]:5701:7f588bcf-011d-491e-a293-4a8e824d18d6, server version: 5.5.0-SNAPSHOT, local address: /127.0.0.1:40001
13:07:54,125  INFO |test_resumeJob_byJobId| - [Diagnostics] Time-limited test - hz.client_4279 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Diagnostics disabled. To enable add -Dhazelcast.diagnostics.enabled=true to the JVM arguments.
13:07:54,125 TRACE |test_resumeJob_byJobId| - [ClientListenerService] hz.client_4279.internal-1 - hz.client_4279 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Register attempt of ClusterViewListenerHandler to MockedClientConnection{localAddress=[127.0.0.1]:40001, super=ClientConnection{alive=true, connectionId=1, channel=null, remoteAddress=[127.0.0.1]:5701, lastReadTime=2024-03-14 13:07:54.124, lastWriteTime=2024-03-14 13:07:54.122, closedTime=never}}
13:07:54,126 TRACE |test_resumeJob_byJobId| - [ClientListenerService] hz.client_4279.eventRegistration- - hz.client_4279 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Register attempt of ClientListenerRegistration{codec=com.hazelcast.client.impl.spi.impl.ClientInvocationServiceImpl$1@fa33c556, handler=com.hazelcast.client.impl.spi.impl.ClientInvocationServiceImpl$BackupEventHandler@e1006af6} to MockedClientConnection{localAddress=[127.0.0.1]:40001, super=ClientConnection{alive=true, connectionId=1, channel=null, remoteAddress=[127.0.0.1]:5701, lastReadTime=2024-03-14 13:07:54.124, lastWriteTime=2024-03-14 13:07:54.125, closedTime=never}}
13:07:54,127 TRACE |test_resumeJob_byJobId| - [ClientListenerService] ForkJoinPool.commonPool-worker-112 - hz.client_4279 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Registered ClusterViewListenerHandler to MockedClientConnection{localAddress=[127.0.0.1]:40001, super=ClientConnection{alive=true, connectionId=1, channel=null, remoteAddress=[127.0.0.1]:5701, lastReadTime=2024-03-14 13:07:54.127, lastWriteTime=2024-03-14 13:07:54.126, closedTime=never}}
13:07:54,127 TRACE |test_resumeJob_byJobId| - [ClientListenerService] hz.client_4279.eventRegistration- - hz.client_4279 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Registered ClientListenerRegistration{codec=com.hazelcast.client.impl.spi.impl.ClientInvocationServiceImpl$1@fa33c556, handler=com.hazelcast.client.impl.spi.impl.ClientInvocationServiceImpl$BackupEventHandler@e1006af6} to MockedClientConnection{localAddress=[127.0.0.1]:40001, super=ClientConnection{alive=true, connectionId=1, channel=null, remoteAddress=[127.0.0.1]:5701, lastReadTime=2024-03-14 13:07:54.127, lastWriteTime=2024-03-14 13:07:54.126, closedTime=never}}
13:07:54,128  INFO |test_resumeJob_byJobId| - [ClientStatisticsService] Time-limited test - Client statistics is enabled with period 5 seconds.
13:07:54,130  INFO |test_resumeJob_byJobId| - [PartitionStateManagerImpl] Time-limited test - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Initializing cluster partition table arrangement...
13:07:54,213 DEBUG |test_resumeJob_byJobId| - [JobRepository] hz.HazelcastCommandLineTest_romantic_ptolemy.cached.thread-1 - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Skipping job cleanup because job records IMap does not exist
13:07:54,921 DEBUG |test_resumeJob_byJobId| - [JobClassLoaderService] hz.HazelcastCommandLineTest_romantic_ptolemy.cached.thread-3 - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Creating job classLoader for job 0b63-83be-e940-0001
13:07:54,921 DEBUG |test_resumeJob_byJobId| - [JobClassLoaderService] hz.HazelcastCommandLineTest_romantic_ptolemy.cached.thread-3 - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Create processor classloader map for job 0b63-83be-e940-0001
13:07:54,924 DEBUG |test_resumeJob_byJobId| - [Planner] hz.HazelcastCommandLineTest_romantic_ptolemy.cached.thread-3 - Watermarks in the pipeline will be throttled to 1000
13:07:54,933  INFO |test_resumeJob_byJobId| - [JobCoordinationService] hz.HazelcastCommandLineTest_romantic_ptolemy.cached.thread-3 - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Starting job 0b63-83be-e940-0001 based on submit request
13:07:54,975  INFO |test_resumeJob_byJobId| - [MasterJobContext] hz.HazelcastCommandLineTest_romantic_ptolemy.cached.thread-3 - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Didn't find any snapshot to restore for job 'job-infinite-pipeline', execution 0b63-83be-e941-0001
13:07:54,976  INFO |test_resumeJob_byJobId| - [MasterJobContext] hz.HazelcastCommandLineTest_romantic_ptolemy.cached.thread-3 - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Start executing job 'job-infinite-pipeline', execution 0b63-83be-e941-0001, execution graph in DOT format:
digraph DAG {
	"mapJournalSource(source)" [localParallelism=2];
	"listSink(sink)" [localParallelism=1];
	"mapJournalSource(source)" -> "listSink(sink)" [queueSize=1024];
}
HINT: You can use graphviz or http://viz-js.com to visualize the printed graph.
13:07:54,976 DEBUG |test_resumeJob_byJobId| - [MasterJobContext] hz.HazelcastCommandLineTest_romantic_ptolemy.cached.thread-3 - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Building execution plan for job 'job-infinite-pipeline', execution 0b63-83be-e941-0001
13:07:54,978 DEBUG |test_resumeJob_byJobId| - [MasterJobContext] hz.HazelcastCommandLineTest_romantic_ptolemy.cached.thread-3 - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Built execution plans for job 'job-infinite-pipeline', execution 0b63-83be-e941-0001
13:07:54,981 DEBUG |test_resumeJob_byJobId| - [InitExecutionOperation] hz.HazelcastCommandLineTest_romantic_ptolemy.cached.thread-3 - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Initializing execution plan for job 0b63-83be-e940-0001, execution 0b63-83be-e941-0001 from [127.0.0.1]:5701
13:07:54,989  INFO |test_resumeJob_byJobId| - [JobExecutionService] hz.HazelcastCommandLineTest_romantic_ptolemy.cached.thread-4 - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Execution plan for jobId=0b63-83be-e940-0001, jobName='job-infinite-pipeline', executionId=0b63-83be-e941-0001 initialized
13:07:54,990 DEBUG |test_resumeJob_byJobId| - [MasterJobContext] hz.HazelcastCommandLineTest_romantic_ptolemy.cached.thread-5 - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Init of job 'job-infinite-pipeline', execution 0b63-83be-e941-0001 was successful
13:07:54,990 DEBUG |test_resumeJob_byJobId| - [MasterJobContext] hz.HazelcastCommandLineTest_romantic_ptolemy.cached.thread-5 - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Executing job 'job-infinite-pipeline', execution 0b63-83be-e941-0001
13:07:54,990  INFO |test_resumeJob_byJobId| - [JobExecutionService] hz.HazelcastCommandLineTest_romantic_ptolemy.cached.thread-5 - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Start execution of job 'job-infinite-pipeline', execution 0b63-83be-e941-0001 from coordinator [127.0.0.1]:5701
13:07:54,995 DEBUG |test_resumeJob_byJobId| - [AbstractJobProxy] Time-limited test - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Sending CANCEL_FORCEFUL request for job 0b63-83be-e940-0001 (name ??)
13:07:55,107 DEBUG |test_resumeJob_byJobId| - [JobExecutionService] hz.HazelcastCommandLineTest_romantic_ptolemy.cached.thread-6 - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Completed execution of job 'job-infinite-pipeline', execution 0b63-83be-e941-0001
13:07:55,107 DEBUG |test_resumeJob_byJobId| - [JobExecutionService] hz.HazelcastCommandLineTest_romantic_ptolemy.cached.thread-6 - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Execution of job 'job-infinite-pipeline', execution 0b63-83be-e941-0001 completed with failure
java.util.concurrent.CompletionException: com.hazelcast.jet.impl.exception.JobTerminateRequestedException: CANCEL_FORCEFUL
	at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:332) ~[?:?]
	at java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:347) ~[?:?]
	at java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:874) ~[?:?]
	at java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:841) ~[?:?]
	at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:510) ~[?:?]
	at java.base/java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2162) ~[?:?]
	at com.hazelcast.jet.impl.util.NonCompletableFuture.internalCompleteExceptionally(NonCompletableFuture.java:72) ~[classes/:?]
	at com.hazelcast.jet.impl.execution.TaskletExecutionService$ExecutionTracker.taskletDone(TaskletExecutionService.java:501) ~[classes/:?]
	at com.hazelcast.jet.impl.execution.TaskletExecutionService$BlockingWorker.run(TaskletExecutionService.java:333) ~[classes/:?]
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) ~[?:?]
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
	at java.base/java.lang.Thread.run(Thread.java:857) ~[?:?]
Caused by: com.hazelcast.jet.impl.exception.JobTerminateRequestedException: CANCEL_FORCEFUL
	at com.hazelcast.jet.impl.execution.ExecutionContext.terminateExecution(ExecutionContext.java:317) ~[classes/:?]
	at com.hazelcast.jet.impl.JobExecutionService.terminateExecution0(JobExecutionService.java:724) ~[classes/:?]
	at com.hazelcast.jet.impl.JobExecutionService.terminateExecution(JobExecutionService.java:720) ~[classes/:?]
	at com.hazelcast.jet.impl.operation.TerminateExecutionOperation.doRun(TerminateExecutionOperation.java:59) ~[classes/:?]
	at com.hazelcast.jet.impl.operation.AsyncOperation.run(AsyncOperation.java:55) ~[classes/:?]
	at com.hazelcast.spi.impl.operationservice.Operation.call(Operation.java:193) ~[classes/:?]
	at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.call(OperationRunnerImpl.java:294) ~[classes/:?]
	at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:265) ~[classes/:?]
	at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:216) ~[classes/:?]
	at com.hazelcast.spi.impl.operationexecutor.impl.OperationExecutorImpl.run(OperationExecutorImpl.java:459) ~[classes/:?]
	at com.hazelcast.spi.impl.operationexecutor.impl.OperationExecutorImpl.runOrExecute(OperationExecutorImpl.java:519) ~[classes/:?]
	at com.hazelcast.spi.impl.operationservice.impl.Invocation.doInvokeLocal(Invocation.java:618) ~[classes/:?]
	at com.hazelcast.spi.impl.operationservice.impl.Invocation.doInvoke(Invocation.java:597) ~[classes/:?]
	at com.hazelcast.spi.impl.operationservice.impl.Invocation.invoke0(Invocation.java:558) ~[classes/:?]
	at com.hazelcast.spi.impl.operationservice.impl.Invocation.invoke(Invocation.java:241) ~[classes/:?]
	at com.hazelcast.spi.impl.operationservice.impl.InvocationBuilderImpl.invoke(InvocationBuilderImpl.java:71) ~[classes/:?]
	at com.hazelcast.jet.impl.MasterContext.invokeOnParticipant(MasterContext.java:428) ~[classes/:?]
	at com.hazelcast.jet.impl.MasterContext.invokeOnParticipants(MasterContext.java:411) ~[classes/:?]
	at com.hazelcast.jet.impl.MasterContext.invokeOnParticipants(MasterContext.java:382) ~[classes/:?]
	at com.hazelcast.jet.impl.MasterJobContext.lambda$cancelExecutionInvocations$24(MasterJobContext.java:758) ~[classes/:?]
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) [?:?]
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) [?:?]
	at java.base/java.lang.Thread.run(Thread.java:857) [?:?]
	at com.hazelcast.internal.util.executor.HazelcastManagedThread.executeRun(HazelcastManagedThread.java:76) [classes/:?]
	at com.hazelcast.internal.util.executor.PoolExecutorThreadFactory$ManagedThread.executeRun(PoolExecutorThreadFactory.java:74) [classes/:?]
	at com.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:111) [classes/:?]
13:07:55,108 DEBUG |test_resumeJob_byJobId| - [MasterJobContext] ForkJoinPool.commonPool-worker-110 - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] job 'job-infinite-pipeline', execution 0b63-83be-e941-0001 received response to StartExecutionOperation from [127.0.0.1]:5701: com.hazelcast.jet.impl.exception.JobTerminateRequestedException: CANCEL_FORCEFUL
13:07:55,108 DEBUG |test_resumeJob_byJobId| - [MasterJobContext] ForkJoinPool.commonPool-worker-110 - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] job 'job-infinite-pipeline', execution 0b63-83be-e941-0001 to be cancelled after Execution
13:07:55,109 DEBUG |test_resumeJob_byJobId| - [JobClassLoaderService] hz.HazelcastCommandLineTest_romantic_ptolemy.cached.thread-2 - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Finish JobClassLoaders phaseCount = 0, removing classloaders for jobId=0b63-83be-e940-0001
13:07:55,109  INFO |test_resumeJob_byJobId| - [MasterJobContext] hz.HazelcastCommandLineTest_romantic_ptolemy.cached.thread-2 - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Execution of job 'job-infinite-pipeline', execution 0b63-83be-e941-0001 got terminated, reason=com.hazelcast.jet.impl.exception.CancellationByUserException
	Start time: 2024-03-14T13:07:54.934
	Duration: 00:00:00.175
	To see additional job metrics enable JobConfig.storeMetricsAfterJobCompletion
13:07:55,133 DEBUG |test_resumeJob_byJobId| - [JobCoordinationService] hz.HazelcastCommandLineTest_romantic_ptolemy.cached.thread-2 - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] job 'job-infinite-pipeline', execution 0b63-83be-e941-0001 is completed
13:07:55,139  INFO |test_resumeJob_byJobId| - [JetTestSupport] Time-limited test - Terminating instanceFactory in JetTestSupport.@After
13:07:55,143  INFO |test_resumeJob_byJobId| - [LifecycleService] Thread-24622 - hz.client_4279 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] HazelcastClient 5.5.0-SNAPSHOT (20240314) is SHUTTING_DOWN
13:07:55,143  WARN |test_resumeJob_byJobId| - [TestClientRegistry$MockedServerConnection] pool-12061-thread-1 - Server connection closed: null
13:07:55,144  INFO |test_resumeJob_byJobId| - [ClientConnectionManager] Thread-24622 - hz.client_4279 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Removed connection to endpoint: [127.0.0.1]:5701:7f588bcf-011d-491e-a293-4a8e824d18d6, connection: MockedClientConnection{localAddress=[127.0.0.1]:40001, super=ClientConnection{alive=false, connectionId=1, channel=null, remoteAddress=[127.0.0.1]:5701, lastReadTime=2024-03-14 13:07:54.230, lastWriteTime=2024-03-14 13:07:54.132, closedTime=2024-03-14 13:07:55.143}}
13:07:55,144  INFO |test_resumeJob_byJobId| - [MockServer] pool-12061-thread-1 - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Removed connection to endpoint: [address=[127.0.0.1]:40001, uuid=79101fa1-ef17-4deb-bc0a-14359ef956f2], connection: MockedNodeConnection{ remoteAddress = [127.0.0.1]:40001, localAddress = [127.0.0.1]:5701, connectionId = 1}
13:07:55,144  INFO |test_resumeJob_byJobId| - [LifecycleService] Thread-24622 - hz.client_4279 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] HazelcastClient 5.5.0-SNAPSHOT (20240314) is CLIENT_DISCONNECTED
13:07:55,144  WARN |test_resumeJob_byJobId| - [TwoWayBlockableExecutor] pool-12061-thread-1 - Dropping incoming runnable since other end closed. Server Closed EOF. MockedClientConnection{localAddress=[127.0.0.1]:40001, super=ClientConnection{alive=false, connectionId=1, channel=null, remoteAddress=[127.0.0.1]:5701, lastReadTime=2024-03-14 13:07:54.230, lastWriteTime=2024-03-14 13:07:54.132, closedTime=2024-03-14 13:07:55.143}}
13:07:55,144  INFO |test_resumeJob_byJobId| - [ClientEndpointManager] hz.HazelcastCommandLineTest_romantic_ptolemy.event-81471 - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Destroying ClientEndpoint{connection=MockedNodeConnection{ remoteAddress = [127.0.0.1]:40001, localAddress = [127.0.0.1]:5701, connectionId = 1}, clientUuid=79101fa1-ef17-4deb-bc0a-14359ef956f2, clientName=hz.client_4279, authenticated=true, clientVersion=5.5.0-SNAPSHOT, creationTime=1710421674122, latest clientAttributes=lastStatisticsCollectionTime=1710421674128,enterprise=false,clientType=JVM,clientVersion=5.5.0-SNAPSHOT,clusterConnectionTimestamp=1710421674122,clientAddress=127.0.0.1,clientName=hz.client_4279,credentials.principal=null,os.committedVirtualMemorySize=14020149248,os.freePhysicalMemorySize=570806956032,os.freeSwapSpaceSize=10736623616,os.maxFileDescriptorCount=1048576,os.openFileDescriptorCount=417,os.processCpuTime=68744410836000,os.systemLoadAverage=7.50390625,os.totalPhysicalMemorySize=808603877376,os.totalSwapSpaceSize=10737410048,runtime.availableProcessors=8,runtime.freeMemory=6607396352,runtime.maxMemory=8589934592,runtime.totalMemory=8589934592,runtime.uptime=31973494,runtime.usedMemory=1982538240, labels=[]}
13:07:55,145  INFO |test_resumeJob_byJobId| - [LifecycleService] Thread-24622 - hz.client_4279 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] HazelcastClient 5.5.0-SNAPSHOT (20240314) is SHUTDOWN
13:07:55,146  INFO |test_resumeJob_byJobId| - [LifecycleService] Thread-24622 - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] [127.0.0.1]:5701 is SHUTTING_DOWN
13:07:55,146  WARN |test_resumeJob_byJobId| - [Node] Thread-24622 - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Terminating forcefully...
13:07:55,146  INFO |test_resumeJob_byJobId| - [Node] Thread-24622 - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Shutting down connection manager...
13:07:55,146  INFO |test_resumeJob_byJobId| - [Node] Thread-24622 - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Shutting down node engine...
13:07:55,154  INFO |test_resumeJob_byJobId| - [NodeExtension] Thread-24622 - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Destroying node NodeExtension.
13:07:55,154  INFO |test_resumeJob_byJobId| - [Node] Thread-24622 - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] Hazelcast Shutdown is completed in 8 ms.
13:07:55,154  INFO |test_resumeJob_byJobId| - [LifecycleService] Thread-24622 - [127.0.0.1]:5701 [2d5690aa-2dec-4496-ba6a-1455b1b39f2d] [5.5.0-SNAPSHOT] [127.0.0.1]:5701 is SHUTDOWN
13:07:55,154  INFO |test_resumeJob_byJobId| - [HazelcastTestSupport] Time-limited test - Shutting down node factory as @After action
BuildInfo right after test_resumeJob_byJobId(com.hazelcast.client.console.HazelcastCommandLineTest): BuildInfo{version='5.5.0-SNAPSHOT', build='20240314', buildNumber=20240314, revision=, enterprise=false, serializationVersion=1}
Hiccups measured while running test 'test_resumeJob_byJobId(com.hazelcast.client.console.HazelcastCommandLineTest):'
13:07:50, accumulated pauses: 76 ms, max pause: 30 ms, pauses over 1000 ms: 0
13:07:55, accumulated pauses: 1 ms, max pause: 0 ms, pauses over 1000 ms: 0


No metrics recorded during the test

Standard output can be found here - https://s3.console.aws.amazon.com/s3/buckets/j-artifacts/Hazelcast-master-Openj9-17/111/

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
Projects
None yet
Development

No branches or pull requests

3 participants