[
https://issues.apache.org/jira/browse/FLINK-36845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanquan Lv updated FLINK-36845:
-------------------------------
Description:
When integrating test with SourceTestSuiteBase/SinkTestSuiteBase,
SourceTestSuiteBase#testSavepoint method will always fail with the following
error message:
{panel}
Coordinator of operator 4f95f7d5494917a727023f5f0a66f498 does not exist or the
job vertex this operator belongs to is not initialized.
{panel}
It turns out that user defined operatorUid was not properly passed to Operator.
was:
When integrate test with SourceTestSuiteBase/SinkTestSuiteBase,
SourceTestSuiteBase#testSavepoint method will always fail with the following
error message:
{panel}
Coordinator of operator 4f95f7d5494917a727023f5f0a66f498 does not exist or the
job vertex this operator belongs to is not initialized.
{panel}
It turns out that user defined operatorUid was not properly passed to Operator.
> SourceTestSuiteBase/SinkTestSuiteBase will fail with `this operator belongs
> to is not initialized` error
> --------------------------------------------------------------------------------------------------------
>
> Key: FLINK-36845
> URL: https://issues.apache.org/jira/browse/FLINK-36845
> Project: Flink
> Issue Type: Bug
> Components: Tests
> Affects Versions: 2.0-preview
> Reporter: Yanquan Lv
> Priority: Minor
> Fix For: 2.0.0
>
>
> When integrating test with SourceTestSuiteBase/SinkTestSuiteBase,
> SourceTestSuiteBase#testSavepoint method will always fail with the following
> error message:
> {panel}
> Coordinator of operator 4f95f7d5494917a727023f5f0a66f498 does not exist or
> the job vertex this operator belongs to is not initialized.
> {panel}
> It turns out that user defined operatorUid was not properly passed to
> Operator.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
