Hi Sergiy,
Per
https://nightlies.apache.org/flink/flink-docs-stable/docs/connectors/table/jdbc/,
do you also have the driver dependency for your database added to your POM?
Best regards,
Martijn
Op di 2 aug. 2022 om 12:52 schreef Sergiy Gonta <sergego...@gmail.com>:
> 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
>
>
