You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by Sergiy Gonta <se...@gmail.com> on 2022/08/02 10:34:56 UTC

Flink Table issue

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

Re: Flink Table issue

Posted by Martijn Visser <ma...@2symbols.com.INVALID>.

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 <se...@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
>
>