提交图计算任务失败，提示:rocksdb chk error

[wgb1990]

Exception in thread "rpc-executor-1" com.antgroup.geaflow.common.exception.GeaflowRuntimeException: 
************
ERR_ID:
     RUN-00000002
CAUSE:
     Run error: rocksdb chk error
ACTION:
     Please check your code, or contact admin.
DETAIL:

************
	at com.antgroup.geaflow.store.rocksdb.RocksdbClient.checkpoint(RocksdbClient.java:142)
	at com.antgroup.geaflow.store.rocksdb.BaseRocksdbStore.archive(BaseRocksdbStore.java:75)
	at com.antgroup.geaflow.cluster.system.RocksdbClusterMetaKVStore.flush(RocksdbClusterMetaKVStore.java:54)
	at com.antgroup.geaflow.cluster.system.ClusterMetaStore.flush(ClusterMetaStore.java:158)
	at com.antgroup.geaflow.cluster.resourcemanager.DefaultResourceManager.persist(DefaultResourceManager.java:288)
	at com.antgroup.geaflow.cluster.resourcemanager.DefaultResourceManager.onRegister(DefaultResourceManager.java:252)
	at com.antgroup.geaflow.cluster.resourcemanager.DefaultResourceManager.lambda$onSuccess$2(DefaultResourceManager.java:201)
	at com.antgroup.geaflow.cluster.resourcemanager.DefaultResourceManager.withLock(DefaultResourceManager.java:276)
	at com.antgroup.geaflow.cluster.resourcemanager.DefaultResourceManager.onSuccess(DefaultResourceManager.java:194)
	at com.antgroup.geaflow.cluster.clustermanager.AbstractClusterManager.handleRegisterResponse(AbstractClusterManager.java:190)
	at com.antgroup.geaflow.cluster.clustermanager.AbstractClusterManager.access$000(AbstractClusterManager.java:47)
	at com.antgroup.geaflow.cluster.clustermanager.AbstractClusterManager$1.onSuccess(AbstractClusterManager.java:160)
	at com.antgroup.geaflow.cluster.clustermanager.AbstractClusterManager$1.onSuccess(AbstractClusterManager.java:152)
	at com.antgroup.geaflow.cluster.rpc.impl.AbstractRpcEndpointRef$1.onSuccess(AbstractRpcEndpointRef.java:75)
	at com.google.common.util.concurrent.Futures$4.run(Futures.java:1132)
	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:750)
Caused by: org.rocksdb.RocksDBException: While open a file for appending: /tmp/geaflow1686752263277105350/framework/cluster/geaflow1686752263277105350-1686799890038/0_chk1.tmp/CURRENT: No such file or directory
	at org.rocksdb.Checkpoint.createCheckpoint(Native Method)
	at org.rocksdb.Checkpoint.createCheckpoint(Checkpoint.java:51)
	at com.antgroup.geaflow.store.rocksdb.RocksdbClient.checkpoint(RocksdbClient.java:140)
	... 17 more
2023-06-15 03:31:33 ERROR Driver:135 - driver exception
com.antgroup.geaflow.common.exception.GeaflowRuntimeException: 
************
ERR_ID:
     RUN-00000002
CAUSE:
     Run error: rocksdb chk error
ACTION:
     Please check your code, or contact admin.
DETAIL:

************
	at com.antgroup.geaflow.store.rocksdb.RocksdbClient.checkpoint(RocksdbClient.java:142) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.store.rocksdb.BaseRocksdbStore.archive(BaseRocksdbStore.java:75) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.cluster.system.RocksdbClusterMetaKVStore.flush(RocksdbClusterMetaKVStore.java:54) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.cluster.system.ClusterMetaStore.flush(ClusterMetaStore.java:158) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.cluster.driver.DriverContext$PipelineCheckpointFunction.doCheckpoint(DriverContext.java:85) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.cluster.common.ReliableContainerContext.checkpoint(ReliableContainerContext.java:45) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.cluster.driver.Driver.executePipelineInternal(Driver.java:108) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.cluster.driver.Driver.lambda$executePipeline$1(Driver.java:96) ~[geaflow-geaflow.jar:?]
	at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_372]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_372]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_372]
	at java.lang.Thread.run(Thread.java:750) [?:1.8.0_372]
Caused by: org.rocksdb.RocksDBException: while link file to /tmp/geaflow1686752263277105350/framework/cluster/geaflow1686752263277105350-1686799890038/0_chk1.tmp/000011.sst: /tmp/geaflow1686752263277105350/framework/cluster/geaflow1686752263277105350-1686799890038/0/000011.sst: File exists
	at org.rocksdb.Checkpoint.createCheckpoint(Native Method) ~[geaflow-geaflow.jar:?]
	at org.rocksdb.Checkpoint.createCheckpoint(Checkpoint.java:51) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.store.rocksdb.RocksdbClient.checkpoint(RocksdbClient.java:140) ~[geaflow-geaflow.jar:?]
	... 11 more
2023-06-15 03:31:33 ERROR DriverEndpoint:51 - execute pipeline failed: java.util.concurrent.ExecutionException: com.antgroup.geaflow.common.exception.GeaflowRuntimeException: 
************
ERR_ID:
     RUN-00000002
CAUSE:
     Run error: rocksdb chk error
ACTION:
     Please check your code, or contact admin.
DETAIL:

************
com.antgroup.geaflow.common.exception.GeaflowRuntimeException: java.util.concurrent.ExecutionException: com.antgroup.geaflow.common.exception.GeaflowRuntimeException: 
************
ERR_ID:
     RUN-00000002
CAUSE:
     Run error: rocksdb chk error
ACTION:
     Please check your code, or contact admin.
DETAIL:

************
	at com.antgroup.geaflow.cluster.driver.Driver.executePipeline(Driver.java:100) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.cluster.driver.Driver.executePipeline(Driver.java:46) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.cluster.rpc.impl.DriverEndpoint.executePipeline(DriverEndpoint.java:45) [geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.rpc.proto.DriverServiceGrpc$MethodHandlers.invoke(DriverServiceGrpc.java:266) [geaflow-geaflow.jar:?]
	at io.grpc.stub.ServerCalls$UnaryServerCallHandler$UnaryServerCallListener.onHalfClose(ServerCalls.java:171) [geaflow-geaflow.jar:?]
	at io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.halfClosed(ServerCallImpl.java:283) [geaflow-geaflow.jar:?]
	at io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1HalfClosed.runInContext(ServerImpl.java:707) [geaflow-geaflow.jar:?]
	at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37) [geaflow-geaflow.jar:?]
	at io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123) [geaflow-geaflow.jar:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_372]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_372]
	at java.lang.Thread.run(Thread.java:750) [?:1.8.0_372]
Caused by: java.util.concurrent.ExecutionException: com.antgroup.geaflow.common.exception.GeaflowRuntimeException: 
************
ERR_ID:
     RUN-00000002
CAUSE:
     Run error: rocksdb chk error
ACTION:
     Please check your code, or contact admin.
DETAIL:

************
	at java.util.concurrent.FutureTask.report(FutureTask.java:122) ~[?:1.8.0_372]
	at java.util.concurrent.FutureTask.get(FutureTask.java:192) ~[?:1.8.0_372]
	at com.antgroup.geaflow.cluster.driver.Driver.executePipeline(Driver.java:98) ~[geaflow-geaflow.jar:?]
	... 11 more
Caused by: com.antgroup.geaflow.common.exception.GeaflowRuntimeException: 
************
ERR_ID:
     RUN-00000002
CAUSE:
     Run error: rocksdb chk error
ACTION:
     Please check your code, or contact admin.
DETAIL:

************
	at com.antgroup.geaflow.store.rocksdb.RocksdbClient.checkpoint(RocksdbClient.java:142) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.store.rocksdb.BaseRocksdbStore.archive(BaseRocksdbStore.java:75) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.cluster.system.RocksdbClusterMetaKVStore.flush(RocksdbClusterMetaKVStore.java:54) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.cluster.system.ClusterMetaStore.flush(ClusterMetaStore.java:158) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.cluster.driver.DriverContext$PipelineCheckpointFunction.doCheckpoint(DriverContext.java:85) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.cluster.common.ReliableContainerContext.checkpoint(ReliableContainerContext.java:45) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.cluster.driver.Driver.executePipelineInternal(Driver.java:108) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.cluster.driver.Driver.lambda$executePipeline$1(Driver.java:96) ~[geaflow-geaflow.jar:?]
	at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[?:1.8.0_372]
	... 3 more
Caused by: org.rocksdb.RocksDBException: while link file to /tmp/geaflow1686752263277105350/framework/cluster/geaflow1686752263277105350-1686799890038/0_chk1.tmp/000011.sst: /tmp/geaflow1686752263277105350/framework/cluster/geaflow1686752263277105350-1686799890038/0/000011.sst: File exists
	at org.rocksdb.Checkpoint.createCheckpoint(Native Method) ~[geaflow-geaflow.jar:?]
	at org.rocksdb.Checkpoint.createCheckpoint(Checkpoint.java:51) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.store.rocksdb.RocksdbClient.checkpoint(RocksdbClient.java:140) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.store.rocksdb.BaseRocksdbStore.archive(BaseRocksdbStore.java:75) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.cluster.system.RocksdbClusterMetaKVStore.flush(RocksdbClusterMetaKVStore.java:54) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.cluster.system.ClusterMetaStore.flush(ClusterMetaStore.java:158) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.cluster.driver.DriverContext$PipelineCheckpointFunction.doCheckpoint(DriverContext.java:85) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.cluster.common.ReliableContainerContext.checkpoint(ReliableContainerContext.java:45) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.cluster.driver.Driver.executePipelineInternal(Driver.java:108) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.cluster.driver.Driver.lambda$executePipeline$1(Driver.java:96) ~[geaflow-geaflow.jar:?]
	at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[?:1.8.0_372]
	... 3 more
Exception in thread "main" io.grpc.StatusRuntimeException: UNKNOWN
	at io.grpc.Status.asRuntimeException(Status.java:526)
	at io.grpc.stub.ClientCalls$BlockingResponseStream.hasNext(ClientCalls.java:576)
	at com.antgroup.geaflow.cluster.client.PipelineResult.isSuccess(PipelineResult.java:37)
	at com.antgroup.geaflow.cluster.client.PipelineResult.get(PipelineResult.java:53)
	at com.antgroup.geaflow.dsl.runtime.engine.GQLPipeLine.execute(GQLPipeLine.java:116)
	at com.antgroup.geaflow.dsl.runtime.engine.GeaFlowGqlClient.main(GeaFlowGqlClient.java:56)
2023-06-15 03:31:33 WARN  RpcServiceImpl:63 - *** shutting down gRPC server since JVM is shutting down
2023-06-15 03:31:33 WARN  RpcServiceImpl:63 - *** shutting down gRPC server since JVM is shutting down
2023-06-15 03:31:33 WARN  RpcServiceImpl:63 - *** shutting down gRPC server since JVM is shutting down
2023-06-15 03:31:33 WARN  RpcServiceImpl:65 - *** server shut down
2023-06-15 03:31:33 WARN  RpcServiceImpl:65 - *** server shut down
2023-06-15 03:31:33 WARN  RpcServiceImpl:65 - *** server shut down

[pengzhiwei2018]

@wgb1990 能提供更多信息吗？比如运行方式，是本地单测还是console平台提交。什么场景下出现的这个问题。这些信息有利于我们排查问题。Thanks~

[wgb1990]

@wgb1990 能提供更多信息吗？比如运行方式，是本地单测还是console平台提交。什么场景下出现的这个问题。这些信息有利于我们排查问题。Thanks~

是console平台提交的，提交的任务是quick_start的demo，我这边是自己编译的镜像，不是用的官方的镜像，任务重新提交后，异常堆栈发送变化，具体如下：

WHERE `substr`(`text`, 1, 1) = '-'))
2023-06-15 08:00:54 ERROR Driver:135 - driver exception
java.lang.NullPointerException: null
	at com.antgroup.geaflow.dsl.validator.namespace.GQLInsertNamespace.validateImpl(GQLInsertNamespace.java:62) ~[geaflow-geaflow.jar:?]
	at org.apache.calcite.sql.validate.AbstractNamespace.validate(AbstractNamespace.java:84) ~[geaflow-geaflow.jar:?]
	at org.apache.calcite.sql.validate.SqlValidatorImpl.validateNamespace(SqlValidatorImpl.java:973) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.dsl.validator.GQLValidatorImpl.validateNamespace(GQLValidatorImpl.java:393) ~[geaflow-geaflow.jar:?]
	at org.apache.calcite.sql.validate.SqlValidatorImpl.validateInsert(SqlValidatorImpl.java:4259) ~[geaflow-geaflow.jar:?]
	at org.apache.calcite.sql.SqlInsert.validate(SqlInsert.java:152) ~[geaflow-geaflow.jar:?]
	at org.apache.calcite.sql.validate.SqlValidatorImpl.validateScopedExpression(SqlValidatorImpl.java:924) ~[geaflow-geaflow.jar:?]
	at org.apache.calcite.sql.validate.SqlValidatorImpl.validate(SqlValidatorImpl.java:628) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.dsl.validator.GQLValidatorImpl.validate(GQLValidatorImpl.java:117) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.dsl.planner.GQLContext.validate(GQLContext.java:406) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.dsl.runtime.command.QueryCommand.execute(QueryCommand.java:55) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.dsl.runtime.QueryClient.executeQuery(QueryClient.java:85) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.dsl.runtime.QueryClient.executeQuery(QueryClient.java:55) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.dsl.runtime.engine.GQLPipeLine$GQLPipelineTask.execute(GQLPipeLine.java:189) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.runtime.pipeline.task.PipelineTaskExecutor.execute(PipelineTaskExecutor.java:40) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.runtime.pipeline.executor.PipelineExecutor.runPipelineTask(PipelineExecutor.java:66) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.cluster.driver.Driver.executePipelineInternal(Driver.java:120) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.cluster.driver.Driver.lambda$executePipeline$1(Driver.java:96) ~[geaflow-geaflow.jar:?]
	at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_372]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_372]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_372]
	at java.lang.Thread.run(Thread.java:750) [?:1.8.0_372]
2023-06-15 08:00:54 ERROR DriverEndpoint:51 - execute pipeline failed: java.util.concurrent.ExecutionException: java.lang.NullPointerException
com.antgroup.geaflow.common.exception.GeaflowRuntimeException: java.util.concurrent.ExecutionException: java.lang.NullPointerException
	at com.antgroup.geaflow.cluster.driver.Driver.executePipeline(Driver.java:100) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.cluster.driver.Driver.executePipeline(Driver.java:46) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.cluster.rpc.impl.DriverEndpoint.executePipeline(DriverEndpoint.java:45) [geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.rpc.proto.DriverServiceGrpc$MethodHandlers.invoke(DriverServiceGrpc.java:266) [geaflow-geaflow.jar:?]
	at io.grpc.stub.ServerCalls$UnaryServerCallHandler$UnaryServerCallListener.onHalfClose(ServerCalls.java:171) [geaflow-geaflow.jar:?]
	at io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.halfClosed(ServerCallImpl.java:283) [geaflow-geaflow.jar:?]
	at io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1HalfClosed.runInContext(ServerImpl.java:707) [geaflow-geaflow.jar:?]
	at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37) [geaflow-geaflow.jar:?]
	at io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123) [geaflow-geaflow.jar:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_372]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_372]
	at java.lang.Thread.run(Thread.java:750) [?:1.8.0_372]
Caused by: java.util.concurrent.ExecutionException: java.lang.NullPointerException
	at java.util.concurrent.FutureTask.report(FutureTask.java:122) ~[?:1.8.0_372]
	at java.util.concurrent.FutureTask.get(FutureTask.java:192) ~[?:1.8.0_372]
	at com.antgroup.geaflow.cluster.driver.Driver.executePipeline(Driver.java:98) ~[geaflow-geaflow.jar:?]
	... 11 more
Caused by: java.lang.NullPointerException
	at com.antgroup.geaflow.dsl.validator.namespace.GQLInsertNamespace.validateImpl(GQLInsertNamespace.java:62) ~[geaflow-geaflow.jar:?]
	at org.apache.calcite.sql.validate.AbstractNamespace.validate(AbstractNamespace.java:84) ~[geaflow-geaflow.jar:?]
	at org.apache.calcite.sql.validate.SqlValidatorImpl.validateNamespace(SqlValidatorImpl.java:973) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.dsl.validator.GQLValidatorImpl.validateNamespace(GQLValidatorImpl.java:393) ~[geaflow-geaflow.jar:?]
	at org.apache.calcite.sql.validate.SqlValidatorImpl.validateInsert(SqlValidatorImpl.java:4259) ~[geaflow-geaflow.jar:?]
	at org.apache.calcite.sql.SqlInsert.validate(SqlInsert.java:152) ~[geaflow-geaflow.jar:?]
	at org.apache.calcite.sql.validate.SqlValidatorImpl.validateScopedExpression(SqlValidatorImpl.java:924) ~[geaflow-geaflow.jar:?]
	at org.apache.calcite.sql.validate.SqlValidatorImpl.validate(SqlValidatorImpl.java:628) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.dsl.validator.GQLValidatorImpl.validate(GQLValidatorImpl.java:117) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.dsl.planner.GQLContext.validate(GQLContext.java:406) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.dsl.runtime.command.QueryCommand.execute(QueryCommand.java:55) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.dsl.runtime.QueryClient.executeQuery(QueryClient.java:85) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.dsl.runtime.QueryClient.executeQuery(QueryClient.java:55) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.dsl.runtime.engine.GQLPipeLine$GQLPipelineTask.execute(GQLPipeLine.java:189) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.runtime.pipeline.task.PipelineTaskExecutor.execute(PipelineTaskExecutor.java:40) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.runtime.pipeline.executor.PipelineExecutor.runPipelineTask(PipelineExecutor.java:66) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.cluster.driver.Driver.executePipelineInternal(Driver.java:120) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.cluster.driver.Driver.lambda$executePipeline$1(Driver.java:96) ~[geaflow-geaflow.jar:?]
	at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[?:1.8.0_372]
	... 3 more
Exception in thread "main" io.grpc.StatusRuntimeException: UNKNOWN
	at io.grpc.Status.asRuntimeException(Status.java:526)
	at io.grpc.stub.ClientCalls$BlockingResponseStream.hasNext(ClientCalls.java:576)
	at com.antgroup.geaflow.cluster.client.PipelineResult.isSuccess(PipelineResult.java:37)
	at com.antgroup.geaflow.cluster.client.PipelineResult.get(PipelineResult.java:53)
	at com.antgroup.geaflow.dsl.runtime.engine.GQLPipeLine.execute(GQLPipeLine.java:116)
	at com.antgroup.geaflow.dsl.runtime.engine.GeaFlowGqlClient.main(GeaFlowGqlClient.java:56)
2023-06-15 08:00:54 WARN  RpcServiceImpl:63 - *** shutting down gRPC server since JVM is shutting down
2023-06-15 08:00:54 WARN  RpcServiceImpl:63 - *** shutting down gRPC server since JVM is shutting down
2023-06-15 08:00:54 WARN  RpcServiceImpl:63 - *** shutting down gRPC server since JVM is shutting down
2023-06-15 08:00:54 WARN  RpcServiceImpl:65 - *** server shut down
2023-06-15 08:00:54 WARN  RpcServiceImpl:65 - *** server shut down
2023-06-15 08:00:54 WARN  RpcServiceImpl:65 - *** server shut down
Execute async command `[/usr/lib/jvm/java-1.8.0-openjdk-1.8.0.372.b07-1.el7_9.x86_64/jre/bin/java, -cp, /tmp/geaflow/local/versions/geaflow/geaflow-geaflow.jar:/tmp/geaflow/local/tasks/geaflow1686752263277105350-1686816050030, com.antgroup.geaflow.dsl.runtime.engine.GeaFlowGqlClient, {\"system\":{\"geaflow.job.unique.id\":\"1686752263277105350\",\"geaflow.job.cluster.id\":\"geaflow1686752263277105350-1686816050030\",\"geaflow.job.runtime.name\":\"geaflow1686752263277105350\",\"geaflow.gw.endpoint\":\"http://10.134.132.11:8081\",\"geaflow.dsl.catalog.token.key\":\"TASK-RTjaoxKTGEoQDnkvuNHEcwrn9JelGJq3\",\"geaflow.cluster.started.callback.url\":\"http://10.134.132.11:8081/api/tasks/1686752263277105350/startup-notify\",\"geaflow.dsl.catalog.instance.name\":\"instance_dw_monitor\",\"geaflow.dsl.catalog.type\":\"console\",\"stateConfig\":{\"geaflow.metric.stats.type\":\"JDBC\",\"geaflow.system.offset.backend.type\":\"JDBC\",\"geaflow.system.meta.table\":\"backend_meta\",\"geaflow.store.jdbc.driver.class\":\"com.mysql.jdbc.Driver\",\"geaflow.store.jdbc.url\":\"jdbc:mysql://10.134.132.11:3306/geaflow?useUnicode=true&characterEncoding=utf8\",\"geaflow.store.jdbc.user.name\":\"root\",\"geaflow.store.jdbc.password\":\"monitor@poizon.theduapp.com\",\"geaflow.ha.service.type\":\"REDIS\",\"geaflow.store.redis.host\":\"127.0.0.1\",\"geaflow.store.redis.port\":6379,\"geaflow.file.persistent.type\":\"LOCAL\",\"geaflow.file.persistent.root\":\"/tmp/geaflow/chk\",\"geaflow.file.persistent.config.json\":\"{}\"},\"metricConfig\":{\"geaflow.metric.reporters\":\"INFLUXDB\",\"geaflow.metric.influxdb.url\":\"http://127.0.0.1:8086\",\"geaflow.metric.influxdb.token\":\"lolFYbjQvUicB13vWaBDN4bELu7cmvYY\",\"geaflow.metric.influxdb.org\":\"geaflow\",\"geaflow.metric.influxdb.bucket\":\"geaflow\"}},\"cluster\":{\"geaflow.container.num\":1,\"geaflow.container.worker.num\":3,\"geaflow.container.memory.mb\":1024,\"geaflow.container.vcores\":1.5,\"geaflow.container.jvm.options\":\"-Xmx512m,-Xms512m,-Xmn256m\",\"geaflow.client.memory.mb\":1024,\"geaflow.master.memory.mb\":1024,\"geaflow.driver.memory.mb\":1024,\"geaflow.client.vcores\":0.5,\"geaflow.master.vcores\":1.0,\"geaflow.driver.vcores\":1.0,\"geaflow.client.jvm.options\":\"-Xmx512m,-Xms512m,-Xmn256m,-Xss512k,-XX:MaxDirectMemorySize=128m\",\"geaflow.master.jvm.options\":\"-Xmx512m,-Xms512m,-Xmn256m,-Xss512k,-XX:MaxDirectMemorySize=128m\",\"geaflow.driver.jvm.options\":\"-Xmx512m,-Xms512m,-Xmn256m,-Xss512k,-XX:MaxDirectMemorySize=128m\"},\"job\":{\"geaflow.system.state.backend.type\":\"ROCKSDB\",\"geaflow.heartbeat.timeout.ms\":\"300000\"}}]` failed
org.apache.commons.exec.ExecuteException: Process exited with an error: 1 (Exit value: 1)
	at org.apache.commons.exec.DefaultExecutor.executeInternal(DefaultExecutor.java:404)
	at org.apache.commons.exec.DefaultExecutor.access$200(DefaultExecutor.java:48)
	at org.apache.commons.exec.DefaultExecutor$1.run(DefaultExecutor.java:200)
	at `java.lang.Thread.run(Thread.java:750)`

[pengzhiwei2018]

@Leomrlin 看一下第二个报错

[pengzhiwei2018]

@wgb1990 问一下，语句有啥修改吗？另外麻烦提供一下更多日志信息

[wgb1990]

@wgb1990 问一下，语句有啥修改吗？另外麻烦提供一下更多日志信息

语句没有做修改

2023-06-15 08:00:53 INFO  RocksdbPersistClient:152 - checkpointId 1, full [000011.sst, 000009.sst], lastFullFiles [], currentIncre [000011.sst, 000009.sst]
2023-06-15 08:00:53 INFO  RocksdbPersistClient:445 - upload to dfs size 6KB took 13ms /tmp/geaflow1686752263277105350/framework/cluster/geaflow1686752263277105350-1686816050030/0_chk1/OPTIONS-000007 -> /tmp/dsl/geaflow1686752263277105350/framework/cluster/geaflow1686752263277105350-1686816050030/0/meta.1/OPTIONS-000007
2023-06-15 08:00:53 INFO  RocksdbPersistClient:445 - upload to dfs size 0KB took 13ms /tmp/geaflow1686752263277105350/framework/cluster/geaflow1686752263277105350-1686816050030/0_chk1/FILES -> /tmp/dsl/geaflow1686752263277105350/framework/cluster/geaflow1686752263277105350-1686816050030/0/meta.1/FILES
2023-06-15 08:00:53 INFO  RocksdbPersistClient:445 - upload to dfs size 1KB took 13ms /tmp/geaflow1686752263277105350/framework/cluster/geaflow1686752263277105350-1686816050030/0_chk1/000009.sst -> /tmp/dsl/geaflow1686752263277105350/framework/cluster/geaflow1686752263277105350-1686816050030/0/datas/000009.sst
2023-06-15 08:00:53 INFO  RocksdbPersistClient:445 - upload to dfs size 0KB took 13ms /tmp/geaflow1686752263277105350/framework/cluster/geaflow1686752263277105350-1686816050030/0_chk1/MANIFEST-000005 -> /tmp/dsl/geaflow1686752263277105350/framework/cluster/geaflow1686752263277105350-1686816050030/0/meta.1/MANIFEST-000005
2023-06-15 08:00:53 INFO  RocksdbPersistClient:445 - upload to dfs size 3KB took 14ms /tmp/geaflow1686752263277105350/framework/cluster/geaflow1686752263277105350-1686816050030/0_chk1/000011.sst -> /tmp/dsl/geaflow1686752263277105350/framework/cluster/geaflow1686752263277105350-1686816050030/0/datas/000011.sst
2023-06-15 08:00:53 INFO  RocksdbPersistClient:445 - upload to dfs size 0KB took 13ms /tmp/geaflow1686752263277105350/framework/cluster/geaflow1686752263277105350-1686816050030/0_chk1/CURRENT -> /tmp/dsl/geaflow1686752263277105350/framework/cluster/geaflow1686752263277105350-1686816050030/0/meta.1/CURRENT
2023-06-15 08:00:53 INFO  RocksdbPersistClient:161 - RocksDB LOCAL archive local:/tmp/geaflow1686752263277105350/framework/cluster/geaflow1686752263277105350-1686816050030/0_chk1 to /tmp/dsl/geaflow1686752263277105350/framework/cluster/geaflow1686752263277105350-1686816050030/0 (incre[2]/full[2]) took 22.873459ms. incre data size 12KB, speed 524.8389765841712KB/s [000011.sst, 000009.sst]
2023-06-15 08:00:53 INFO  Driver:86 - driver 2 checkpoint pipeline
2023-06-15 08:00:53 INFO  RocksdbPersistClient:316 - skip remove early chk /tmp/dsl/geaflow1686752263277105350/framework/cluster/geaflow1686752263277105350-1686816050030/0 -9
2023-06-15 08:00:53 INFO  PipelineExecutor:56 - run pipeline task PipelineTask#0
2023-06-15 08:00:53 INFO  SetCommand:40 - set 'geaflow.dsl.window.size' to '1'
2023-06-15 08:00:53 INFO  SetCommand:40 - set 'geaflow.dsl.ignore.exception' to 'TRUE'
2023-06-15 08:00:53 INFO  HttpUtil:91 - get url: http://10.134.132.11:8081/api/instances/instance_dw_monitor/graphs/dy_modern
2023-06-15 08:00:54 INFO  HttpUtil:108 - get http://10.134.132.11:8081/api/instances/instance_dw_monitor/graphs/dy_modern response cost 21ms: {"code":"SUCCESS","data":{"createTime":"2023-06-14 14:24:04","creatorId":"1686663077002174733","creatorName":"dw_monitor","edges":[],"id":"1686752644169900123","modifierId":"1686663077002174733","modifierName":"dw_monitor","modifyTime":"2023-06-15 02:21:39","name":"dy_modern","pluginConfig":{"category":"GRAPH","config":{"geaflow.dsl.graph.store.type":"memory","geaflow.dsl.graph.store.shard.count":"1"},"createTime":"2023-06-14 14:24:04","creatorId":"1686663077002174733","id":"1686752644144683482","modifierId":"1686663077002174733","modifyTime":"2023-06-15 02:21:39","name":"instance_dw_monitor-dy_modern-graph-config","tenantId":"1686663084516020631","type":"ROCKSDB"},"tenantId":"1686663084516020631","tenantName":"tenant_dw_monitor","vertices":[{"createTime":"2023-06-14 14:24:04","creatorId":"1686663077002174733","fields":[{"category":"VERTEX_ID","createTime":"2023-06-14 14:24:04","creatorId":"1686663077002174733","id":"1686752644116369255","modifierId":"1686663077002174733","modifyTime":"2023-06-14 14:24:04","name":"id","tenantId":"1686663084516020631","type":"BIGINT"},{"category":"PROPERTY","createTime":"2023-06-14 14:24:04","creatorId":"1686663077002174733","id":"1686752644116108801","modifierId":"1686663077002174733","modifyTime":"2023-06-14 14:24:04","name":"name","tenantId":"1686663084516020631","type":"VARCHAR"}],"id":"1686752644112712391","modifierId":"1686663077002174733","modifyTime":"2023-06-14 14:24:04","name":"person","tenantId":"1686663084516020631","type":"VERTEX"}]},"host":"e455e3aae0df","success":true}
2023-06-15 08:00:54 INFO  GQLContext:396 - register graph : dy_modern to catalog
2023-06-15 08:00:54 INFO  CreateGraphCommand:54 - Succeed to register graph: dy_modern to catalog.
2023-06-15 08:00:54 INFO  HttpUtil:91 - get url: http://10.134.132.11:8081/api/instances/instance_dw_monitor/tables/tbl_source
2023-06-15 08:00:54 INFO  HttpUtil:108 - get http://10.134.132.11:8081/api/instances/instance_dw_monitor/tables/tbl_source response cost 12ms: {"code":"SUCCESS","data":{"createTime":"2023-06-14 14:24:04","creatorId":"1686663077002174733","creatorName":"dw_monitor","fields":[{"category":"PROPERTY","createTime":"2023-06-14 14:24:04","creatorId":"1686663077002174733","id":"1686752644233286541","modifierId":"1686663077002174733","modifyTime":"2023-06-14 14:24:04","name":"text","tenantId":"1686663084516020631","type":"VARCHAR"}],"id":"1686752644231598127","modifierId":"1686663077002174733","modifierName":"dw_monitor","modifyTime":"2023-06-14 14:24:04","name":"tbl_source","pluginConfig":{"category":"TABLE","config":{"geaflow.dsl.socket.port":"9003","geaflow.dsl.column.separator":"#","geaflow.dsl.table.type":"socket","geaflow.dsl.socket.host":"10.134.132.11"},"createTime":"2023-06-14 14:24:04","creatorId":"1686663077002174733","id":"1686752644209498699","modifierId":"1686663077002174733","modifyTime":"2023-06-14 14:24:04","name":"instance_dw_monitor-tbl_source-table-config","tenantId":"1686663084516020631","type":"SOCKET"},"tenantId":"1686663084516020631","tenantName":"tenant_dw_monitor","type":"TABLE"},"host":"e455e3aae0df","success":true}
2023-06-15 08:00:54 INFO  GQLContext:378 - register table : tbl_source to catalog
2023-06-15 08:00:54 INFO  CreateTableCommand:42 - Success to create table: 
CREATE TABLE tbl_source (
	text	BINARY_STRING
) WITH (
	geaflow.dsl.socket.port='9003'
	,geaflow.dsl.column.separator='#'
	,geaflow.dsl.table.type='socket'
	,geaflow.dsl.socket.host='10.134.132.11'
)
2023-06-15 08:00:54 INFO  HttpUtil:91 - get url: http://10.134.132.11:8081/api/instances/instance_dw_monitor/tables/tbl_result
2023-06-15 08:00:54 INFO  HttpUtil:108 - get http://10.134.132.11:8081/api/instances/instance_dw_monitor/tables/tbl_result response cost 11ms: {"code":"SUCCESS","data":{"createTime":"2023-06-14 14:24:04","creatorId":"1686663077002174733","creatorName":"dw_monitor","fields":[{"category":"PROPERTY","createTime":"2023-06-14 14:24:04","creatorId":"1686663077002174733","id":"1686752644336522249","modifierId":"1686663077002174733","modifyTime":"2023-06-14 14:24:04","name":"a_id","tenantId":"1686663084516020631","type":"BIGINT"},{"category":"PROPERTY","createTime":"2023-06-14 14:24:04","creatorId":"1686663077002174733","id":"1686752644336460762","modifierId":"1686663077002174733","modifyTime":"2023-06-14 14:24:04","name":"b_id","tenantId":"1686663084516020631","type":"BIGINT"},{"category":"PROPERTY","createTime":"2023-06-14 14:24:04","creatorId":"1686663077002174733","id":"1686752644336906191","modifierId":"1686663077002174733","modifyTime":"2023-06-14 14:24:04","name":"c_id","tenantId":"1686663084516020631","type":"BIGINT"},{"category":"PROPERTY","createTime":"2023-06-14 14:24:04","creatorId":"1686663077002174733","id":"1686752644336479245","modifierId":"1686663077002174733","modifyTime":"2023-06-14 14:24:04","name":"d_id","tenantId":"1686663084516020631","type":"BIGINT"},{"category":"PROPERTY","createTime":"2023-06-14 14:24:04","creatorId":"1686663077002174733","id":"1686752644336653848","modifierId":"1686663077002174733","modifyTime":"2023-06-14 14:24:04","name":"a1_id","tenantId":"1686663084516020631","type":"BIGINT"}],"id":"1686752644333976272","modifierId":"1686663077002174733","modifierName":"dw_monitor","modifyTime":"2023-06-14 14:24:04","name":"tbl_result","pluginConfig":{"category":"TABLE","config":{"geaflow.dsl.socket.port":"9003","geaflow.dsl.column.separator":",","geaflow.dsl.table.type":"socket","geaflow.dsl.socket.host":"10.134.132.11"},"createTime":"2023-06-14 14:24:04","creatorId":"1686663077002174733","id":"1686752644256567000","modifierId":"1686663077002174733","modifyTime":"2023-06-14 14:24:04","name":"instance_dw_monitor-tbl_result-table-config","tenantId":"1686663084516020631","type":"SOCKET"},"tenantId":"1686663084516020631","tenantName":"tenant_dw_monitor","type":"TABLE"},"host":"e455e3aae0df","success":true}
2023-06-15 08:00:54 INFO  GQLContext:378 - register table : tbl_result to catalog
2023-06-15 08:00:54 INFO  CreateTableCommand:42 - Success to create table: 
CREATE TABLE tbl_result (
	a_id	LONG
	,b_id	LONG
	,c_id	LONG
	,d_id	LONG
	,a1_id	LONG
) WITH (
	geaflow.dsl.socket.port='9003'
	,geaflow.dsl.column.separator=','
	,geaflow.dsl.table.type='socket'
	,geaflow.dsl.socket.host='10.134.132.11'
)
2023-06-15 08:00:54 INFO  QueryCommand:52 - Execute query:
INSERT INTO `dy_modern`.`person` (`id`, `name`)
(SELECT CAST(TRIM(BOTH ' ' FROM `split_ex`(`t1`, ',', 0)) AS BIGINT), `split_ex`(`t1`, ',', 1)
FROM (SELECT TRIM(BOTH ' ' FROM `substr`(`text`, 2)) AS `t1`
FROM `tbl_source`
WHERE `substr`(`text`, 1, 1) = '.'))
2023-06-15 08:00:54 INFO  HttpUtil:91 - get url: http://10.134.132.11:8081/api/instances
2023-06-15 08:00:54 INFO  HttpUtil:108 - get http://10.134.132.11:8081/api/instances response cost 7ms: {"code":"SUCCESS","data":{"list":[{"comment":"dw_monitor?dw_monitor????","createTime":"2023-06-13 13:31:25","creatorId":"1686663077002174733","creatorName":"dw_monitor","id":"1686663085092484009","modifierId":"1686663077002174733","modifierName":"dw_monitor","modifyTime":"2023-06-13 13:31:25","name":"instance_dw_monitor","tenantId":"1686663084516020631","tenantName":"tenant_dw_monitor"}],"total":1},"host":"e455e3aae0df","success":true}
2023-06-15 08:00:54 INFO  QueryCommand:58 - Convert sql to logical plan:
LogicalGraphModify(table=[dy_modern])
  LogicalProject(person=[VERTEX{id:CAST($0):BIGINT, ~label:_UTF-16LE'person', name:CAST($1):VARCHAR CHARACTER SET "UTF-16LE" COLLATE "ISO-8859-1$en_US$primary" NOT NULL}])
    LogicalProject(EXPR$0=[CAST(TRIM(FLAG(BOTH), _UTF-16LE' ', split_ex(TRIM(FLAG(BOTH), _UTF-16LE' ', substr($0, 2)), _UTF-16LE',', 0))):BIGINT], EXPR$1=[split_ex(TRIM(FLAG(BOTH), _UTF-16LE' ', substr($0, 2)), _UTF-16LE',', 1)])
      LogicalFilter(condition=[=(CAST(substr($0, 1, 1)):VARCHAR CHARACTER SET "UTF-16LE" COLLATE "ISO-8859-1$en_US$primary", _UTF-16LE'.')])
        LogicalTableScan(table=[[instance_dw_monitor, tbl_source]])

2023-06-15 08:00:54 INFO  QueryCommand:61 - After optimize logical plan:
LogicalGraphModify(table=[dy_modern])
  LogicalProject(person=[VERTEX{id:CAST(CAST(TRIM(FLAG(BOTH), _UTF-16LE' ', split_ex(TRIM(FLAG(BOTH), _UTF-16LE' ', substr($0, 2)), _UTF-16LE',', 0))):BIGINT):BIGINT, ~label:_UTF-16LE'person', name:CAST(split_ex(TRIM(FLAG(BOTH), _UTF-16LE' ', substr($0, 2)), _UTF-16LE',', 1)):VARCHAR CHARACTER SET "UTF-16LE" COLLATE "ISO-8859-1$en_US$primary" NOT NULL}])
    LogicalFilter(condition=[=(CAST(substr($0, 1, 1)):VARCHAR CHARACTER SET "UTF-16LE" COLLATE "ISO-8859-1$en_US$primary", _UTF-16LE'.')])
      LogicalTableScan(table=[[instance_dw_monitor, tbl_source]])

2023-06-15 08:00:54 INFO  QueryCommand:65 - Convert to physic plan:
PhysicGraphModifyRelNode(table=[dy_modern])
  PhysicProjectRelNode(person=[VERTEX{id:CAST(CAST(TRIM(FLAG(BOTH), _UTF-16LE' ', split_ex(TRIM(FLAG(BOTH), _UTF-16LE' ', substr($0, 2)), _UTF-16LE',', 0))):BIGINT):BIGINT, ~label:_UTF-16LE'person', name:CAST(split_ex(TRIM(FLAG(BOTH), _UTF-16LE' ', substr($0, 2)), _UTF-16LE',', 1)):VARCHAR CHARACTER SET "UTF-16LE" COLLATE "ISO-8859-1$en_US$primary" NOT NULL}])
    PhysicFilterRelNode(condition=[=(CAST(substr($0, 1, 1)):VARCHAR CHARACTER SET "UTF-16LE" COLLATE "ISO-8859-1$en_US$primary", _UTF-16LE'.')])
      PhysicTableScanRelNode(table=[[instance_dw_monitor, tbl_source]])

2023-06-15 08:00:54 INFO  QueryCommand:68 - After path analyzer:
PhysicGraphModifyRelNode(table=[dy_modern])
  PhysicProjectRelNode(person=[VERTEX{id:CAST(CAST(TRIM(FLAG(BOTH), _UTF-16LE' ', split_ex(TRIM(FLAG(BOTH), _UTF-16LE' ', substr($0, 2)), _UTF-16LE',', 0))):BIGINT):BIGINT, ~label:_UTF-16LE'person', name:CAST(split_ex(TRIM(FLAG(BOTH), _UTF-16LE' ', substr($0, 2)), _UTF-16LE',', 1)):VARCHAR CHARACTER SET "UTF-16LE" COLLATE "ISO-8859-1$en_US$primary" NOT NULL}])
    PhysicFilterRelNode(condition=[=(CAST(substr($0, 1, 1)):VARCHAR CHARACTER SET "UTF-16LE" COLLATE "ISO-8859-1$en_US$primary", _UTF-16LE'.')])
      PhysicTableScanRelNode(table=[[instance_dw_monitor, tbl_source]])

2023-06-15 08:00:54 INFO  QueryCommand:91 - Finish execute query, spend: 503ms
2023-06-15 08:00:54 INFO  QueryCommand:52 - Execute query:
INSERT INTO `dy_modern`.`knows`
(SELECT CAST(`split_ex`(`t1`, ',', 0) AS BIGINT), CAST(`split_ex`(`t1`, ',', 1) AS BIGINT), CAST(`split_ex`(`t1`, ',', 2) AS DOUBLE)
FROM (SELECT TRIM(BOTH ' ' FROM `substr`(`text`, 2)) AS `t1`
FROM `tbl_source`
WHERE `substr`(`text`, 1, 1) = '-'))
2023-06-15 08:00:54 ERROR Driver:135 - driver exception
java.lang.NullPointerException: null
	at com.antgroup.geaflow.dsl.validator.namespace.GQLInsertNamespace.validateImpl(GQLInsertNamespace.java:62) ~[geaflow-geaflow.jar:?]
	at org.apache.calcite.sql.validate.AbstractNamespace.validate(AbstractNamespace.java:84) ~[geaflow-geaflow.jar:?]
	at org.apache.calcite.sql.validate.SqlValidatorImpl.validateNamespace(SqlValidatorImpl.java:973) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.dsl.validator.GQLValidatorImpl.validateNamespace(GQLValidatorImpl.java:393) ~[geaflow-geaflow.jar:?]
	at org.apache.calcite.sql.validate.SqlValidatorImpl.validateInsert(SqlValidatorImpl.java:4259) ~[geaflow-geaflow.jar:?]
	at org.apache.calcite.sql.SqlInsert.validate(SqlInsert.java:152) ~[geaflow-geaflow.jar:?]
	at org.apache.calcite.sql.validate.SqlValidatorImpl.validateScopedExpression(SqlValidatorImpl.java:924) ~[geaflow-geaflow.jar:?]
	at org.apache.calcite.sql.validate.SqlValidatorImpl.validate(SqlValidatorImpl.java:628) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.dsl.validator.GQLValidatorImpl.validate(GQLValidatorImpl.java:117) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.dsl.planner.GQLContext.validate(GQLContext.java:406) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.dsl.runtime.command.QueryCommand.execute(QueryCommand.java:55) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.dsl.runtime.QueryClient.executeQuery(QueryClient.java:85) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.dsl.runtime.QueryClient.executeQuery(QueryClient.java:55) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.dsl.runtime.engine.GQLPipeLine$GQLPipelineTask.execute(GQLPipeLine.java:189) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.runtime.pipeline.task.PipelineTaskExecutor.execute(PipelineTaskExecutor.java:40) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.runtime.pipeline.executor.PipelineExecutor.runPipelineTask(PipelineExecutor.java:66) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.cluster.driver.Driver.executePipelineInternal(Driver.java:120) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.cluster.driver.Driver.lambda$executePipeline$1(Driver.java:96) ~[geaflow-geaflow.jar:?]
	at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_372]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_372]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_372]
	at java.lang.Thread.run(Thread.java:750) [?:1.8.0_372]
2023-06-15 08:00:54 ERROR DriverEndpoint:51 - execute pipeline failed: java.util.concurrent.ExecutionException: java.lang.NullPointerException
com.antgroup.geaflow.common.exception.GeaflowRuntimeException: java.util.concurrent.ExecutionException: java.lang.NullPointerException
	at com.antgroup.geaflow.cluster.driver.Driver.executePipeline(Driver.java:100) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.cluster.driver.Driver.executePipeline(Driver.java:46) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.cluster.rpc.impl.DriverEndpoint.executePipeline(DriverEndpoint.java:45) [geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.rpc.proto.DriverServiceGrpc$MethodHandlers.invoke(DriverServiceGrpc.java:266) [geaflow-geaflow.jar:?]
	at io.grpc.stub.ServerCalls$UnaryServerCallHandler$UnaryServerCallListener.onHalfClose(ServerCalls.java:171) [geaflow-geaflow.jar:?]
	at io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.halfClosed(ServerCallImpl.java:283) [geaflow-geaflow.jar:?]
	at io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1HalfClosed.runInContext(ServerImpl.java:707) [geaflow-geaflow.jar:?]
	at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37) [geaflow-geaflow.jar:?]
	at io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123) [geaflow-geaflow.jar:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_372]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_372]
	at java.lang.Thread.run(Thread.java:750) [?:1.8.0_372]
Caused by: java.util.concurrent.ExecutionException: java.lang.NullPointerException
	at java.util.concurrent.FutureTask.report(FutureTask.java:122) ~[?:1.8.0_372]
	at java.util.concurrent.FutureTask.get(FutureTask.java:192) ~[?:1.8.0_372]
	at com.antgroup.geaflow.cluster.driver.Driver.executePipeline(Driver.java:98) ~[geaflow-geaflow.jar:?]
	... 11 more
Caused by: java.lang.NullPointerException
	at com.antgroup.geaflow.dsl.validator.namespace.GQLInsertNamespace.validateImpl(GQLInsertNamespace.java:62) ~[geaflow-geaflow.jar:?]
	at org.apache.calcite.sql.validate.AbstractNamespace.validate(AbstractNamespace.java:84) ~[geaflow-geaflow.jar:?]
	at org.apache.calcite.sql.validate.SqlValidatorImpl.validateNamespace(SqlValidatorImpl.java:973) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.dsl.validator.GQLValidatorImpl.validateNamespace(GQLValidatorImpl.java:393) ~[geaflow-geaflow.jar:?]
	at org.apache.calcite.sql.validate.SqlValidatorImpl.validateInsert(SqlValidatorImpl.java:4259) ~[geaflow-geaflow.jar:?]
	at org.apache.calcite.sql.SqlInsert.validate(SqlInsert.java:152) ~[geaflow-geaflow.jar:?]
	at org.apache.calcite.sql.validate.SqlValidatorImpl.validateScopedExpression(SqlValidatorImpl.java:924) ~[geaflow-geaflow.jar:?]
	at org.apache.calcite.sql.validate.SqlValidatorImpl.validate(SqlValidatorImpl.java:628) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.dsl.validator.GQLValidatorImpl.validate(GQLValidatorImpl.java:117) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.dsl.planner.GQLContext.validate(GQLContext.java:406) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.dsl.runtime.command.QueryCommand.execute(QueryCommand.java:55) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.dsl.runtime.QueryClient.executeQuery(QueryClient.java:85) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.dsl.runtime.QueryClient.executeQuery(QueryClient.java:55) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.dsl.runtime.engine.GQLPipeLine$GQLPipelineTask.execute(GQLPipeLine.java:189) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.runtime.pipeline.task.PipelineTaskExecutor.execute(PipelineTaskExecutor.java:40) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.runtime.pipeline.executor.PipelineExecutor.runPipelineTask(PipelineExecutor.java:66) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.cluster.driver.Driver.executePipelineInternal(Driver.java:120) ~[geaflow-geaflow.jar:?]
	at com.antgroup.geaflow.cluster.driver.Driver.lambda$executePipeline$1(Driver.java:96) ~[geaflow-geaflow.jar:?]
	at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[?:1.8.0_372]
	... 3 more
Exception in thread "main" io.grpc.StatusRuntimeException: UNKNOWN
	at io.grpc.Status.asRuntimeException(Status.java:526)
	at io.grpc.stub.ClientCalls$BlockingResponseStream.hasNext(ClientCalls.java:576)
	at com.antgroup.geaflow.cluster.client.PipelineResult.isSuccess(PipelineResult.java:37)
	at com.antgroup.geaflow.cluster.client.PipelineResult.get(PipelineResult.java:53)
	at com.antgroup.geaflow.dsl.runtime.engine.GQLPipeLine.execute(GQLPipeLine.java:116)
	at com.antgroup.geaflow.dsl.runtime.engine.GeaFlowGqlClient.main(GeaFlowGqlClient.java:56)
2023-06-15 08:00:54 WARN  RpcServiceImpl:63 - *** shutting down gRPC server since JVM is shutting down
2023-06-15 08:00:54 WARN  RpcServiceImpl:63 - *** shutting down gRPC server since JVM is shutting down
2023-06-15 08:00:54 WARN  RpcServiceImpl:63 - *** shutting down gRPC server since JVM is shutting down
2023-06-15 08:00:54 WARN  RpcServiceImpl:65 - *** server shut down
2023-06-15 08:00:54 WARN  RpcServiceImpl:65 - *** server shut down
2023-06-15 08:00:54 WARN  RpcServiceImpl:65 - *** server shut down
Execute async command `[/usr/lib/jvm/java-1.8.0-openjdk-1.8.0.372.b07-1.el7_9.x86_64/jre/bin/java, -cp, /tmp/geaflow/local/versions/geaflow/geaflow-geaflow.jar:/tmp/geaflow/local/tasks/geaflow1686752263277105350-1686816050030, com.antgroup.geaflow.dsl.runtime.engine.GeaFlowGqlClient, {\"system\":{\"geaflow.job.unique.id\":\"1686752263277105350\",\"geaflow.job.cluster.id\":\"geaflow1686752263277105350-1686816050030\",\"geaflow.job.runtime.name\":\"geaflow1686752263277105350\",\"geaflow.gw.endpoint\":\"http://10.134.132.11:8081\",\"geaflow.dsl.catalog.token.key\":\"TASK-RTjaoxKTGEoQDnkvuNHEcwrn9JelGJq3\",\"geaflow.cluster.started.callback.url\":\"http://10.134.132.11:8081/api/tasks/1686752263277105350/startup-notify\",\"geaflow.dsl.catalog.instance.name\":\"instance_dw_monitor\",\"geaflow.dsl.catalog.type\":\"console\",\"stateConfig\":{\"geaflow.metric.stats.type\":\"JDBC\",\"geaflow.system.offset.backend.type\":\"JDBC\",\"geaflow.system.meta.table\":\"backend_meta\",\"geaflow.store.jdbc.driver.class\":\"com.mysql.jdbc.Driver\",\"geaflow.store.jdbc.url\":\"jdbc:mysql://10.134.132.11:3306/geaflow?useUnicode=true&characterEncoding=utf8\",\"geaflow.store.jdbc.user.name\":\"root\",\"geaflow.store.jdbc.password\":\"monitor@poizon.theduapp.com\",\"geaflow.ha.service.type\":\"REDIS\",\"geaflow.store.redis.host\":\"127.0.0.1\",\"geaflow.store.redis.port\":6379,\"geaflow.file.persistent.type\":\"LOCAL\",\"geaflow.file.persistent.root\":\"/tmp/geaflow/chk\",\"geaflow.file.persistent.config.json\":\"{}\"},\"metricConfig\":{\"geaflow.metric.reporters\":\"INFLUXDB\",\"geaflow.metric.influxdb.url\":\"http://127.0.0.1:8086\",\"geaflow.metric.influxdb.token\":\"lolFYbjQvUicB13vWaBDN4bELu7cmvYY\",\"geaflow.metric.influxdb.org\":\"geaflow\",\"geaflow.metric.influxdb.bucket\":\"geaflow\"}},\"cluster\":{\"geaflow.container.num\":1,\"geaflow.container.worker.num\":3,\"geaflow.container.memory.mb\":1024,\"geaflow.container.vcores\":1.5,\"geaflow.container.jvm.options\":\"-Xmx512m,-Xms512m,-Xmn256m\",\"geaflow.client.memory.mb\":1024,\"geaflow.master.memory.mb\":1024,\"geaflow.driver.memory.mb\":1024,\"geaflow.client.vcores\":0.5,\"geaflow.master.vcores\":1.0,\"geaflow.driver.vcores\":1.0,\"geaflow.client.jvm.options\":\"-Xmx512m,-Xms512m,-Xmn256m,-Xss512k,-XX:MaxDirectMemorySize=128m\",\"geaflow.master.jvm.options\":\"-Xmx512m,-Xms512m,-Xmn256m,-Xss512k,-XX:MaxDirectMemorySize=128m\",\"geaflow.driver.jvm.options\":\"-Xmx512m,-Xms512m,-Xmn256m,-Xss512k,-XX:MaxDirectMemorySize=128m\"},\"job\":{\"geaflow.system.state.backend.type\":\"ROCKSDB\",\"geaflow.heartbeat.timeout.ms\":\"300000\"}}]` failed
org.apache.commons.exec.ExecuteException: Process exited with an error: 1 (Exit value: 1)
	at org.apache.commons.exec.DefaultExecutor.executeInternal(DefaultExecutor.java:404)
	at org.apache.commons.exec.DefaultExecutor.access$200(DefaultExecutor.java:48)
	at org.apache.commons.exec.DefaultExecutor$1.run(DefaultExecutor.java:200)
	at java.lang.Thread.run(Thread.java:750)

[pengzhiwei2018]

好的，我们看一下

[pengzhiwei2018]

@wgb1990 从报错信息来看，你的graph定义里面应该是缺少了对knows表的定义。你是在console上先定义的dy_morden,然后DSL作业里面去掉了dy_morden的定义吧？因为从日志来看没看到create graph的任何日志

[Leomrlin]

@wgb1990 从这一段日志来看，Console的catalog正确返回了"vertices"字段，但似乎边字段是空的，可以检索：
"edges":[]
似乎注册的graph只具有点person而缺少了边knows，我不确定是什么原因导致，可以更换一个图名，比如创建一个新的作业，把demo中的dy_morden全部替换为dy_morden_2，再次运行quick_start吗，以确定注册graph出错的真正原因

[wgb1990]

@wgb1990 从报错信息来看，你的graph定义里面应该是缺少了对knows表的定义。你是在console上先定义的dy_morden,然后DSL作业里面去掉了dy_morden的定义吧？因为从日志来看没看到create graph的任何日志

原因找到了，确实缺少knowns定义，删除后重新提交任务后，解决。