[
https://issues.apache.org/jira/browse/FLINK-34768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828694#comment-17828694
]
Flink CDC Issue Import commented on FLINK-34768:
------------------------------------------------
Date: Thu Jan 12 15:03:45 CST 2023, Author: [Cqz666|https://github.com/Cqz666]
@leonardBang help plz !
> simple tidb cdc demo,but caused 'java.lang.IllegalArgumentException: Invalid
> range: '
> -------------------------------------------------------------------------------------
>
> Key: FLINK-34768
> URL: https://issues.apache.org/jira/browse/FLINK-34768
> Project: Flink
> Issue Type: Bug
> Components: Flink CDC
> Reporter: Flink CDC Issue Import
> Priority: Major
> Labels: github-import
>
> **Describe the bug(Please use English)**
> A clear and concise description of what the bug is.
> **Environment :**
> - Flink version : 1.14.5
> - Flink CDC version: 2.4-SNAPSHOT
> - Database and version: TIDB v5.3.1
> **To Reproduce**
> Steps to reproduce the behavior:
> 1. The test data :
> 2. The test code :
> CREATE TABLE tidb_source (
> id INT,
> name STRING,
> description STRING,
> PRIMARY KEY (id) NOT ENFORCED
> ) WITH (
> 'connector' = 'tidb-cdc',
> 'tikv.grpc.timeout_in_ms' = '20000',
> 'pd-addresses' = '127.0.1.1:2379',
> 'database-name' = 'test',
> 'table-name' = 'products'
> );
> CREATE TABLE sink (
> id INT,
> name STRING,
> description STRING,
> PRIMARY KEY (id) NOT ENFORCED
> ) WITH (
> 'connector' = 'print'
> );
> stEnv.executeSql(sourcre);
> stEnv.executeSql(sink);
> TableResult result =
> stEnv.executeSql(
> "INSERT INTO sink select `id`, name, description FROM
> tidb_source t");
> result.print();
> 4. The error :
> Caused by: java.lang.IllegalArgumentException: Invalid range:
> [+INF..{116,128,0,0,0,0,0,0,57,95,114,85,85,85,85,85,85,85,84})
> at
> org.apache.flink.shaded.guava30.com.google.common.collect.Range.<init>(Range.java:358)
> at
> org.apache.flink.shaded.guava30.com.google.common.collect.Range.create(Range.java:156)
> at
> org.apache.flink.shaded.guava30.com.google.common.collect.Range.intersection(Range.java:558)
> at org.tikv.cdc.CDCClient.overlapWithRegion(CDCClient.java:235)
> at org.tikv.cdc.CDCClient.addRegions(CDCClient.java:185)
> at org.tikv.cdc.CDCClient.applyKeyRange(CDCClient.java:178)
> at org.tikv.cdc.CDCClient.start(CDCClient.java:98)
> at
> com.ververica.cdc.connectors.tidb.TiKVRichParallelSourceFunction.run(TiKVRichParallelSourceFunction.java:165)
> at
> org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:110)
> at
> org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:67)
> at
> org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:323)
> **Additional Description**
> If applicable, add screenshots to help explain your problem.
> ---------------- Imported from GitHub ----------------
> Url: https://github.com/apache/flink-cdc/issues/1872
> Created by: [Cqz666|https://github.com/Cqz666]
> Labels: bug,
> Created at: Thu Jan 12 14:59:54 CST 2023
> State: open
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
