[Bug] [File Connector V2] Data file name will duplicate when use SeaTunnel Engine

[EricJoy2048]

Search before asking

• I had searched in the issues and found no similar issues.

What happened

SeaTunnel Version

ALL

SeaTunnel Config

CI: https://github.com/apache/incubator-seatunnel/pull/3456#pullrequestreview-1198820624

Running Command

CI: https://github.com/apache/incubator-seatunnel/pull/3456#pullrequestreview-1198820624

Error Exception

CI: https://github.com/apache/incubator-seatunnel/pull/3456#pullrequestreview-1198820624

Flink or Spark Version

No response

Java or Scala Version

No response

Screenshots

No response

Are you willing to submit PR?

• Yes I am willing to submit a PR!

Code of Conduct

• I agree to follow this project's Code of Conduct

[TaoZex]

I want to try this issue.Please assign to me.

[TaoZex]

JobId was initialized before dag was resolved, but PipelineId was created for executeplan after dag was resolved. Therefore,
JobId and Pipelineid were created at different locations. I have communicated with @Hisoka-X ,this does not seem to be able to pass jobId+pipelneId directly to the connector.

[EricJoy2048]

JobId was initialized before dag was resolved, but PipelineId was created for executeplan after dag was resolved. Therefore, JobId and Pipelineid were created at different locations. I have communicated with @Hisoka-X ,this does not seem to be able to pass jobId+pipelneId directly to the connector.

Yes, you are right. We plan fix it in file sink connector. @Hisoka-X will finish this work.

Thanks.

[TaoZex]

OK. Thanks for your reply.