wilsonfu88 commented on issue #5831:
URL: https://github.com/apache/seatunnel/issues/5831#issuecomment-1848802881
> > I still can't find a solution,wait for seatunnel v2.3.4 release ?
>
> @wilsonfu88 Can you help to test whether the dev branch still has this
problem?
Use dev branch code run this bug disappear,but happen others error!
The detail is below
2023-12-10 09:08:05,904 INFO
com.hazelcast.client.impl.statistics.ClientStatisticsService - Client
statistics is enabled with period 5 seconds.
2023-12-10 09:08:05,952 INFO com.hazelcast.core.LifecycleService -
hz.client_1 [seatunnel-197763] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7)
is SHUTTING_DOWN
2023-12-10 09:08:05,955 INFO
com.hazelcast.internal.server.tcp.TcpServerConnection - [localhost]:5801
[seatunnel-197763] [5.1] Connection[id=1, /127.0.0.1:5801->/127.0.0.1:60751,
qualifier=null, endpoint=[127.0.0.1]:60751,
remoteUuid=785df542-0839-4f62-a375-12178e82f758, alive=false,
connectionType=JVM, planeIndex=-1] closed. Reason: Connection closed by the
other side
2023-12-10 09:08:05,955 INFO
com.hazelcast.client.impl.connection.ClientConnectionManager - hz.client_1
[seatunnel-197763] [5.1] Removed connection to endpoint:
[localhost]:5801:a1c596b5-15de-4ec1-a3b5-335fd2ff1934, connection:
ClientConnection{alive=false, connectionId=1,
channel=NioChannel{/127.0.0.1:60751->localhost/127.0.0.1:5801},
remoteAddress=[localhost]:5801, lastReadTime=2023-12-10 09:08:05.916,
lastWriteTime=2023-12-10 09:08:05.914, closedTime=2023-12-10 09:08:05.953,
connected server version=5.1}
2023-12-10 09:08:05,955 INFO com.hazelcast.core.LifecycleService -
hz.client_1 [seatunnel-197763] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7)
is CLIENT_DISCONNECTED
2023-12-10 09:08:05,959 INFO
com.hazelcast.client.impl.ClientEndpointManager - [localhost]:5801
[seatunnel-197763] [5.1] Destroying ClientEndpoint{connection=Connection[id=1,
/127.0.0.1:5801->/127.0.0.1:60751, qualifier=null, endpoint=[127.0.0.1]:60751,
remoteUuid=785df542-0839-4f62-a375-12178e82f758, alive=false,
connectionType=JVM, planeIndex=-1],
clientUuid=785df542-0839-4f62-a375-12178e82f758, clientName=hz.client_1,
authenticated=true, clientVersion=5.1, creationTime=1702170485865, latest
clientAttributes=lastStatisticsCollectionTime=1702170485904,enterprise=false,clientType=JVM,clientVersion=5.1,clusterConnectionTimestamp=1702170485854,clientAddress=127.0.0.1,clientName=hz.client_1,credentials.principal=null,os.committedVirtualMemorySize=7049457664,os.freePhysicalMemorySize=228626432,os.freeSwapSpaceSize=5254148096,os.maxFileDescriptorCount=4096,os.openFileDescriptorCount=52,os.processCpuTime=7160000000,os.systemLoadAverage=0.35,os.totalPhysicalMemorySize=33566445568,os.tot
alSwapSpaceSize=5368705024,runtime.availableProcessors=8,runtime.freeMemory=967933400,runtime.maxMemory=1029177344,runtime.totalMemory=1029177344,runtime.uptime=2952,runtime.usedMemory=61243944,
labels=[]}
2023-12-10 09:08:05,960 INFO com.hazelcast.core.LifecycleService -
hz.client_1 [seatunnel-197763] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7)
is SHUTDOWN
2023-12-10 09:08:05,961 INFO
org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand -
Closed SeaTunnel client......
2023-12-10 09:08:05,961 INFO com.hazelcast.core.LifecycleService -
[localhost]:5801 [seatunnel-197763] [5.1] [localhost]:5801 is SHUTTING_DOWN
2023-12-10 09:08:05,966 INFO com.hazelcast.instance.impl.Node -
[localhost]:5801 [seatunnel-197763] [5.1] Shutting down connection manager...
2023-12-10 09:08:05,969 INFO com.hazelcast.instance.impl.Node -
[localhost]:5801 [seatunnel-197763] [5.1] Shutting down node engine...
2023-12-10 09:08:05,977 WARN
com.hazelcast.spi.impl.operationservice.impl.Invocation - [localhost]:5801
[seatunnel-197763] [5.1] Future.complete(Object) on completed future. Request:
Invocation{op=com.hazelcast.map.impl.query.QueryOperation{serviceName='hz:impl:mapService',
identityHash=1921544358, partitionId=-1, replicaIndex=0, callId=-2,
invocationTime=1702170485961 (2023-12-10 09:08:05.961), waitTimeout=-1,
callTimeout=60000,
tenantControl=com.hazelcast.spi.impl.tenantcontrol.NoopTenantControl@0,
name=engine_runningJobInfo}, tryCount=20, tryPauseMillis=500, invokeCount=1,
callTimeoutMillis=60000, firstInvocationTimeMs=1702170485961,
firstInvocationTime='2023-12-10 09:08:05.961', lastHeartbeatMillis=0,
lastHeartbeatTime='1970-01-01 08:00:00.000', target=[localhost]:5801,
pendingResponse={VOID}, backupsAcksExpected=-1, backupsAcksReceived=0,
connection=null}, current value:
ExceptionalResult{cause=com.hazelcast.core.HazelcastInstanceNotActiveException:
Hazelcast instance is not
active!}, offered value: com.hazelcast.map.impl.query.QueryResult@4a01f35
java.lang.Exception: null
at
com.hazelcast.spi.impl.AbstractInvocationFuture.warnIfSuspiciousDoubleCompletion(AbstractInvocationFuture.java:1253)
~[seatunnel-starter.jar:2.3.4-SNAPSHOT]
at
com.hazelcast.spi.impl.AbstractInvocationFuture.complete0(AbstractInvocationFuture.java:1230)
~[seatunnel-starter.jar:2.3.4-SNAPSHOT]
at
com.hazelcast.spi.impl.AbstractInvocationFuture.complete(AbstractInvocationFuture.java:1219)
~[seatunnel-starter.jar:2.3.4-SNAPSHOT]
at
com.hazelcast.spi.impl.operationservice.impl.Invocation.complete(Invocation.java:673)
~[seatunnel-starter.jar:2.3.4-SNAPSHOT]
at
com.hazelcast.spi.impl.operationservice.impl.Invocation.sendResponse(Invocation.java:236)
~[seatunnel-starter.jar:2.3.4-SNAPSHOT]
at
com.hazelcast.spi.impl.operationservice.Operation.sendResponse(Operation.java:483)
~[seatunnel-starter.jar:2.3.4-SNAPSHOT]
at
com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.call(OperationRunnerImpl.java:283)
~[seatunnel-starter.jar:2.3.4-SNAPSHOT]
at
com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:248)
~[seatunnel-starter.jar:2.3.4-SNAPSHOT]
at
com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:213)
~[seatunnel-starter.jar:2.3.4-SNAPSHOT]
at
com.hazelcast.spi.impl.operationexecutor.impl.OperationExecutorImpl.run(OperationExecutorImpl.java:411)
~[seatunnel-starter.jar:2.3.4-SNAPSHOT]
at
com.hazelcast.spi.impl.operationexecutor.impl.OperationExecutorImpl.runOrExecute(OperationExecutorImpl.java:438)
~[seatunnel-starter.jar:2.3.4-SNAPSHOT]
at
com.hazelcast.spi.impl.operationservice.impl.Invocation.doInvokeLocal(Invocation.java:601)
~[seatunnel-starter.jar:2.3.4-SNAPSHOT]
at
com.hazelcast.spi.impl.operationservice.impl.Invocation.doInvoke(Invocation.java:580)
~[seatunnel-starter.jar:2.3.4-SNAPSHOT]
at
com.hazelcast.spi.impl.operationservice.impl.Invocation.invoke0(Invocation.java:541)
~[seatunnel-starter.jar:2.3.4-SNAPSHOT]
at
com.hazelcast.spi.impl.operationservice.impl.Invocation.invoke(Invocation.java:241)
~[seatunnel-starter.jar:2.3.4-SNAPSHOT]
at
com.hazelcast.spi.impl.operationservice.impl.OperationServiceImpl.invokeOnTarget(OperationServiceImpl.java:365)
~[seatunnel-starter.jar:2.3.4-SNAPSHOT]
at
com.hazelcast.map.impl.query.QueryEngineImpl.dispatchFullQueryOnAllMembersOnQueryThread(QueryEngineImpl.java:315)
~[seatunnel-starter.jar:2.3.4-SNAPSHOT]
at
com.hazelcast.map.impl.query.QueryEngineImpl.dispatchFullQueryOnQueryThread(QueryEngineImpl.java:284)
~[seatunnel-starter.jar:2.3.4-SNAPSHOT]
at
com.hazelcast.map.impl.query.QueryEngineImpl.dispatchOnQueryThreads(QueryEngineImpl.java:171)
~[seatunnel-starter.jar:2.3.4-SNAPSHOT]
at
com.hazelcast.map.impl.query.QueryEngineImpl.doRunOnQueryThreads(QueryEngineImpl.java:164)
~[seatunnel-starter.jar:2.3.4-SNAPSHOT]
at
com.hazelcast.map.impl.query.QueryEngineImpl.runOnGivenPartitions(QueryEngineImpl.java:141)
~[seatunnel-starter.jar:2.3.4-SNAPSHOT]
at
com.hazelcast.map.impl.query.QueryEngineImpl.execute(QueryEngineImpl.java:109)
~[seatunnel-starter.jar:2.3.4-SNAPSHOT]
at
com.hazelcast.map.impl.proxy.MapProxySupport.executeQueryInternal(MapProxySupport.java:1415)
~[seatunnel-starter.jar:2.3.4-SNAPSHOT]
at
com.hazelcast.map.impl.proxy.MapProxySupport.executeQueryInternal(MapProxySupport.java:1383)
~[seatunnel-starter.jar:2.3.4-SNAPSHOT]
at
com.hazelcast.map.impl.proxy.MapProxyImpl.executePredicate(MapProxyImpl.java:796)
~[seatunnel-starter.jar:2.3.4-SNAPSHOT]
at
com.hazelcast.map.impl.proxy.MapProxyImpl.entrySet(MapProxyImpl.java:745)
~[seatunnel-starter.jar:2.3.4-SNAPSHOT]
at
com.hazelcast.map.impl.proxy.MapProxyImpl.entrySet(MapProxyImpl.java:739)
~[seatunnel-starter.jar:2.3.4-SNAPSHOT]
at
org.apache.seatunnel.engine.server.CoordinatorService.initCoordinatorService(CoordinatorService.java:236)
~[seatunnel-starter.jar:2.3.4-SNAPSHOT]
at
org.apache.seatunnel.engine.server.CoordinatorService.checkNewActiveMaster(CoordinatorService.java:335)
~[seatunnel-starter.jar:2.3.4-SNAPSHOT]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
[?:1.8.0_202]
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
[?:1.8.0_202]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
[?:1.8.0_202]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
[?:1.8.0_202]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
[?:1.8.0_202]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
[?:1.8.0_202]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_202]
2023-12-10 09:08:06,011 ERROR
org.apache.seatunnel.engine.server.CoordinatorService - [localhost]:5801
[seatunnel-197763] [5.1]
com.hazelcast.core.HazelcastInstanceNotActiveException: Hazelcast instance is
not active!
at
com.hazelcast.spi.impl.operationservice.impl.InvocationRegistry.register(InvocationRegistry.java:140)
at
com.hazelcast.spi.impl.operationservice.impl.Invocation.doInvoke(Invocation.java:570)
at
com.hazelcast.spi.impl.operationservice.impl.Invocation.invoke0(Invocation.java:541)
at
com.hazelcast.spi.impl.operationservice.impl.Invocation.invoke(Invocation.java:241)
at
com.hazelcast.spi.impl.operationservice.impl.OperationServiceImpl.invokeOnPartition(OperationServiceImpl.java:330)
at
com.hazelcast.map.impl.query.QueryEngineImpl.dispatchPartitionScanQueryOnOwnerMemberOnPartitionThread(QueryEngineImpl.java:341)
at
com.hazelcast.map.impl.query.QueryEngineImpl.lambda$dispatchPartitionScanQueryOnOwnerMemberOnPartitionThread$1(QueryEngineImpl.java:333)
at
java.util.PrimitiveIterator$OfInt.forEachRemaining(PrimitiveIterator.java:115)
at
com.hazelcast.map.impl.query.QueryEngineImpl.dispatchPartitionScanQueryOnOwnerMemberOnPartitionThread(QueryEngineImpl.java:332)
at
com.hazelcast.map.impl.query.QueryEngineImpl.doRunOnPartitionThreads(QueryEngineImpl.java:198)
at
com.hazelcast.map.impl.query.QueryEngineImpl.runOnGivenPartitions(QueryEngineImpl.java:144)
at
com.hazelcast.map.impl.query.QueryEngineImpl.execute(QueryEngineImpl.java:109)
at
com.hazelcast.map.impl.proxy.MapProxySupport.executeQueryInternal(MapProxySupport.java:1415)
at
com.hazelcast.map.impl.proxy.MapProxySupport.executeQueryInternal(MapProxySupport.java:1383)
at
com.hazelcast.map.impl.proxy.MapProxyImpl.executePredicate(MapProxyImpl.java:796)
at
com.hazelcast.map.impl.proxy.MapProxyImpl.entrySet(MapProxyImpl.java:745)
at
com.hazelcast.map.impl.proxy.MapProxyImpl.entrySet(MapProxyImpl.java:739)
at
org.apache.seatunnel.engine.server.CoordinatorService.initCoordinatorService(CoordinatorService.java:236)
at
org.apache.seatunnel.engine.server.CoordinatorService.checkNewActiveMaster(CoordinatorService.java:335)
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
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 ------ submitted from ------.()
at
com.hazelcast.internal.util.ExceptionUtil.cloneExceptionWithFixedAsyncStackTrace(ExceptionUtil.java:336)
at
com.hazelcast.spi.impl.operationservice.impl.InvocationFuture.returnOrThrowWithGetConventions(InvocationFuture.java:112)
at
com.hazelcast.spi.impl.operationservice.impl.InvocationFuture.resolveAndThrowIfException(InvocationFuture.java:100)
at
com.hazelcast.spi.impl.AbstractInvocationFuture.get(AbstractInvocationFuture.java:609)
at
com.hazelcast.map.impl.query.QueryEngineImpl.addResultsOfPredicate(QueryEngineImpl.java:214)
at
com.hazelcast.map.impl.query.QueryEngineImpl.doRunOnPartitionThreads(QueryEngineImpl.java:200)
at
com.hazelcast.map.impl.query.QueryEngineImpl.runOnGivenPartitions(QueryEngineImpl.java:144)
at
com.hazelcast.map.impl.query.QueryEngineImpl.execute(QueryEngineImpl.java:109)
at
com.hazelcast.map.impl.proxy.MapProxySupport.executeQueryInternal(MapProxySupport.java:1415)
at
com.hazelcast.map.impl.proxy.MapProxySupport.executeQueryInternal(MapProxySupport.java:1383)
at
com.hazelcast.map.impl.proxy.MapProxyImpl.executePredicate(MapProxyImpl.java:796)
at
com.hazelcast.map.impl.proxy.MapProxyImpl.entrySet(MapProxyImpl.java:745)
at
com.hazelcast.map.impl.proxy.MapProxyImpl.entrySet(MapProxyImpl.java:739)
at
org.apache.seatunnel.engine.server.CoordinatorService.initCoordinatorService(CoordinatorService.java:236)
at
org.apache.seatunnel.engine.server.CoordinatorService.checkNewActiveMaster(CoordinatorService.java:335)
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
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)
2023-12-10 09:08:08,986 INFO com.hazelcast.instance.impl.NodeExtension -
[localhost]:5801 [seatunnel-197763] [5.1] Destroying node NodeExtension.
2023-12-10 09:08:08,991 INFO com.hazelcast.instance.impl.Node -
[localhost]:5801 [seatunnel-197763] [5.1] Hazelcast Shutdown is completed in
3026 ms.
2023-12-10 09:08:08,992 INFO com.hazelcast.core.LifecycleService -
[localhost]:5801 [seatunnel-197763] [5.1] [localhost]:5801 is SHUTDOWN
2023-12-10 09:08:08,992 INFO
org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand -
Closed HazelcastInstance ......
2023-12-10 09:08:08,992 ERROR org.apache.seatunnel.core.starter.SeaTunnel -
===============================================================================
2023-12-10 09:08:08,992 ERROR org.apache.seatunnel.core.starter.SeaTunnel -
Fatal Error,
2023-12-10 09:08:08,992 ERROR org.apache.seatunnel.core.starter.SeaTunnel -
Please submit bug report in https://github.com/apache/seatunnel/issues
2023-12-10 09:08:08,994 ERROR org.apache.seatunnel.core.starter.SeaTunnel -
Reason:SeaTunnel job executed failed
2023-12-10 09:08:08,996 ERROR org.apache.seatunnel.core.starter.SeaTunnel -
Exception
StackTrace:org.apache.seatunnel.core.starter.exception.CommandExecuteException:
SeaTunnel job executed failed
at
org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:192)
at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40)
at
org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient.main(SeaTunnelClient.java:34)
Caused by: java.lang.NullPointerException
at sun.nio.fs.UnixPath.normalizeAndCheck(UnixPath.java:77)
at sun.nio.fs.UnixPath.<init>(UnixPath.java:71)
at sun.nio.fs.UnixFileSystem.getPath(UnixFileSystem.java:281)
at java.nio.file.Paths.get(Paths.java:84)
at
org.apache.seatunnel.core.starter.utils.FileUtils.getConfigPath(FileUtils.java:50)
at
org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:123)
... 2 more
2023-12-10 09:08:08,996 ERROR org.apache.seatunnel.core.starter.SeaTunnel -
===============================================================================
Exception in thread "main"
org.apache.seatunnel.core.starter.exception.CommandExecuteException: SeaTunnel
job executed failed
at
org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:192)
at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40)
at
org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient.main(SeaTunnelClient.java:34)
Caused by: java.lang.NullPointerException
at sun.nio.fs.UnixPath.normalizeAndCheck(UnixPath.java:77)
at sun.nio.fs.UnixPath.<init>(UnixPath.java:71)
at sun.nio.fs.UnixFileSystem.getPath(UnixFileSystem.java:281)
at java.nio.file.Paths.get(Paths.java:84)
at
org.apache.seatunnel.core.starter.utils.FileUtils.getConfigPath(FileUtils.java:50)
at
org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:123)
... 2 more
--
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]