· org.apache.flink.util.FlinkException: Global failure triggered by OperatorCoordinator for 'Source: kafka_rmc_cust_analog_u [1]' (operator ... · Caused by: org.apache.flink.util.FlinkException: Global failure triggered by OperatorCoordinator for 'Source: source_osi_inspection_task [8]' (operator … · The flink job always restart. Environment : Flink version : 1.14.4 Flink CDC version: 2.2.0、2.2.1、2.3-SNAPSHOT Database and version: MySQL 5.7.34 To Reproduc... 10: 32: 13 org.apache.flink.util.FlinkException: Global failure triggered by OperatorCoordinator for 'Source: pulsar-source-test -> (Sink: Print to Std. Out, Map -> Filter -> Map -> Filter -> Map)' … · org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: Unable to create a source for reading table 'default_catalog.default_database.f_shop'.
