[jira] [Created] (FLINK-34768) simple tidb cdc demo,but caused 'java.lang.IllegalArgumentException: Invalid range: '

[Flink CDC Issue Import (Jira)]

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

             Summary: 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


**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)