Yanquan Lv created FLINK-36845:
----------------------------------

             Summary: 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
             Fix For: 2.0.0


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 pass to Operator.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to