Hi,
Could you tell me please, why the Flink cluster can't find
org.apache.flink.connector.jdbc.table.JdbcRowDataInputFormat
if it is present in JAR? (the screenshot is attached)
[image: image.png]
Caused by: java.lang.Exception: Loading the input/output formats failed:
at org.apache.flink.runtime.jobgraph.InputOutputFormatVertex
.initInputOutputformatContainer(InputOutputFormatVertex.java:172)
at org.apache.flink.runtime.jobgraph.InputOutputFormatVertex
.initializeOnMaster(InputOutputFormatVertex.java:57)
at org.apache.flink.runtime.executiongraph.DefaultExecutionGraphBuilder
.buildGraph(DefaultExecutionGraphBuilder.java:172)
... 16 more
Caused by: java.lang.RuntimeException: Deserializing the input/output
formats failed: Could not read the user code wrapper:
org.apache.flink.connector.jdbc.table.JdbcRowDataInputFormat
at org.apache.flink.runtime.jobgraph.InputOutputFormatContainer.<init>(
InputOutputFormatContainer.java:69)
at org.apache.flink.runtime.jobgraph.InputOutputFormatVertex
.initInputOutputformatContainer(InputOutputFormatVertex.java:168)
... 18 more
Caused by: org.apache.flink.runtime.operators.util.
CorruptConfigurationException: Could not read the user code wrapper:
org.apache.flink.connector.jdbc.table.JdbcRowDataInputFormat
at org.apache.flink.runtime.operators.util.TaskConfig.getStubWrapper(
TaskConfig.java:307)
at org.apache.flink.runtime.jobgraph.InputOutputFormatContainer.<init>(
InputOutputFormatContainer.java:66)
... 19 more
Caused by: java.lang.ClassNotFoundException:
org.apache.flink.connector.jdbc.table.JdbcRowDataInputFormat
Here are my POM dependencies:
<properties>
<flink.version>1.15.1</flink.version>
</properties>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-java</artifactId>
<version>${flink.version}</version>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-clients</artifactId>
<version>${flink.version}</version>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-avro</artifactId>
<version>${flink.version}</version>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-api-java-bridge</artifactId>
<version>${flink.version}</version>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-connector-jdbc</artifactId>
<version>${flink.version}</version>
</dependency>
Thank you in advance!
Best regards,
Sergiy Gonta
