Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[Bug][Sort] Schema update is stuck in an endless loop and causes stack overflow in multiple sink scenes #6401

Closed
2 tasks done
thesumery opened this issue Nov 4, 2022 · 0 comments · Fixed by #6407
Closed
2 tasks done
Assignees
Labels
component/sort type/bug Something is wrong
Milestone

Comments

@thesumery
Copy link
Contributor

What happened

Schema update stuck in dead loop cause stackoverflow in multiple sink scences
image

What you expected to happen

Schema update success or fail in multiple sink scences.

How to reproduce

  1. prepare a mysql 5.7+ and flink 1.13 and iceberg env
  2. create a mysql table and insert some data
use inlong;
create table if not exists `inlong_input13` (
	`id` bigint,
	`name` varchar(63),
	PRIMARY KEY(id)
);
insert into inlong_input13 (id, name) values (1, 'haha');
insert into inlong_input13 (id, name) values (2, 'xixi');
  1. create a sort link in flink client
CREATE TABLE `table_1`(
    `data` STRING METADATA FROM 'meta.data' VIRTUAL)
WITH (
    'migrate-all' = 'true',
    'connector' = 'mysql-cdc-inlong',
    'hostname' = 'localhost',
    'database-name' = 'inlong',  -- 如果要匹配所有的则使用正则匹配
    'scan.incremental.snapshot.enabled' = 'false',
    'username' = 'root',
    'password' = '123456',
    'table-name' = '[\s\S]*.*'
);
     
CREATE TABLE `table_2`(
    `data` STRING)
WITH (
    'connector'='iceberg-inlong',
    'catalog-name'='hive_prod',
    'uri'='thrift://localhost:9083',
    'warehouse'='hdfs://localhost:8020/hive/warehouse',
    'sink.multiple.enable' = 'true',
    'sink.multiple.format' = 'canal-json',
    'sink.multiple.add-column.policy' = 'TRY_IT_BEST',
    'sink.multiple.database-pattern' = '${database}',
    'sink.multiple.table-pattern' = 'test_${table}'
);

insert into table_2 
    select 
        `data` as `data` 
    from  table_1;
  1. modify myslq table one column name
ALTER TABLE inlong_input13 RENAME  name to name1;
insert into inlong_input13 (id, name1) values (3, 'OOO');

Environment

No response

InLong version

master

InLong Component

InLong Sort

Are you willing to submit PR?

  • Yes, I am willing to submit a PR!

Code of Conduct

@thesumery thesumery added the type/bug Something is wrong label Nov 4, 2022
@dockerzhang dockerzhang added this to the 1.4.0 milestone Nov 5, 2022
@healchow healchow changed the title [Bug][Sort] Schema update stuck in dead loop cause stackoverflow in multiple sink scences [Bug][Sort] Schema update is stuck in an endless loop and causes stack overflow in multiple sink scenes Nov 5, 2022
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
component/sort type/bug Something is wrong
Projects
None yet
3 participants