e-mhui opened a new pull request, #7173:
URL: https://github.com/apache/inlong/pull/7173
### Prepare a Pull Request
[INLONG-7172][Sort] Fix newly table write into iceberg failed
- Fixes #7172
### Motivation
When a newly table is added in the Flink job, and then restart the job with
status. The newly table can be successfully written to iceberg.
### Modifications
Whether the job has the restored job id when it is restarted.
```java
if (context.isRestored()) {
// Newly table doesn't have restored flink job id.
if (!jobIdState.get().iterator().hasNext()) {
return;
}
/**
* ...
*/
}
```
--
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]
