Flink CDC Issue Import created FLINK-34777:
----------------------------------------------

             Summary: [Bug] Select mysql cdc table in flink sql client caused 
java.lang.NoClassDefFoundError: com/fasterxml/jackson/databind/ObjectMapper
                 Key: FLINK-34777
                 URL: https://issues.apache.org/jira/browse/FLINK-34777
             Project: Flink
          Issue Type: Bug
          Components: Flink CDC
            Reporter: Flink CDC Issue Import


### Search before asking

- [X] I searched in the 
[issues|https://github.com/ververica/flink-cdc-connectors/issues) and found 
nothing similar.


### Flink version

1.6.1

### Flink CDC version

mysql cdc 2.3.0
flink-sql-connector-mysql-cdc-2.3.0.jar

### Database and its version

MariaDB
10.10.2-MariaDB

### Minimal reproduce step

install flink from 
https://dlcdn.apache.org/flink/flink-1.16.1/flink-1.16.1-bin-scala_2.12.tgz
cd flink
cd lib
download flink-sql-connector-mysql-cdc-2.3.0.jar
cd ..
./bin/start-cluster.sh
./bin/sql-client.sh

CREATE TABLE mysql_test (
  Id bigint NULL,
  Guid varchar(255),
  PRIMARY KEY(Id) NOT ENFORCED
) WITH (
    'connector' = 'mysql-cdc',
    'hostname' = 'xxxxxx',
    'port' = 'xxxxx',
    'username' = 'xxxxx',
    'password' = 'xxxxx',
    'database-name' = 'dbo',
    'table-name' = 'testtable'
];

SELECT * FROM mysql_test;

### What did you expect to see?

able to see data in sql client

### What did you see instead?

Flink SQL> SELECT * FROM mysql_test;
[ERROR] Could not execute SQL statement. Reason:
java.lang.NoClassDefFoundError: com/fasterxml/jackson/databind/ObjectMapper


### Anything else?

_No response_

### Are you willing to submit a PR?

- [ ] I'm willing to submit a PR!

---------------- Imported from GitHub ----------------
Url: https://github.com/apache/flink-cdc/issues/1958
Created by: [gojumprope|https://github.com/gojumprope]
Labels: bug, 
Created at: Fri Mar 03 10:03:51 CST 2023
State: open




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

Reply via email to