fenger0888-a11y commented on issue #9729:
URL: https://github.com/apache/seatunnel/issues/9729#issuecomment-3204393843
> > > 在table-names里的表 加上 库名.模式名.表名 试试，类似于这种： table-names =
["postgres_cdc.inventory.postgres_cdc_table_1"]
> >
> >
> > table-names = ["postgres_cdc.inventory.postgres_cdc_table_1"]
这个加过，还是同样的报错。
>
> 加了后的运行日志发一下 其次，你得ip 用户密码都泄露了，请修改帖子，并修改密码
收到，谢谢您，现在报的是checkpoint错误
/tmp/seatunnel/checkpoint_snapshot/1010436289612218369/1755671625437-830-1-4.sertmp,
state: PipelineState(jobId=1010436289612218369, pipelineId=1, checkpointId=4)
at
org.apache.seatunnel.engine.checkpoint.storage.hdfs.HdfsStorage.storeCheckPoint(HdfsStorage.java:111)
at
org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator.completePendingCheckpoint(CheckpointCoordinator.java:856)
at
org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator.lambda$null$7(CheckpointCoordinator.java:608)
... 7 more
Caused by: java.io.IOException: Mkdirs failed to create
/tmp/seatunnel/checkpoint_snapshot/1010436289612218369 (exists=false,
cwd=file:/data/dolphinscheduler/exec/process/admin/18585750364160/18642401605249_31/2409/2455)
at
org.apache.hadoop.fs.ChecksumFileSystem.create(ChecksumFileSystem.java:458)
at
org.apache.hadoop.fs.ChecksumFileSystem.create(ChecksumFileSystem.java:443)
at org.apache.hadoop.fs.FileSystem.create(FileSystem.java:1118)
at org.apache.hadoop.fs.FileSystem.create(FileSystem.java:1098)
at org.apache.hadoop.fs.FileSystem.create(FileSystem.java:987)
at
org.apache.seatunnel.engine.checkpoint.storage.hdfs.HdfsStorage.storeCheckPoint(HdfsStorage.java:107)
... 9 more
at
org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:220)
应该是权限问题吧
--
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]
