Re: [I] [Bug][Connector-v2] [Oracle-CDC] [Paimon][checkpoint] CheckpointCoordinator inside have error. [seatunnel]

[via GitHub]

liusy-bd commented on issue #10417:
URL: https://github.com/apache/seatunnel/issues/10417#issuecomment-3958106722

   > > [@liusy-bd](https://github.com/liusy-bd)您可以尝试使用其他接收器连接器，例如 Console、Hive 
或 JDBC 吗？
   > 
   > @LeonYoah 可以通过 -s 选项恢复控制台。
   > 
   > ```
   >cat > /data/workspaces/sea_config_file/STREAMING-ZETA-ZG_ERP-Console.config 
<<EOF
   env {
     job.mode = "STREAMING"
     parallelism = 1
     checkpoint.interval = 120000      # 120s
     checkpoint.timeout =  120000
     checkpoint.max_concurrent = 1
     read_limit.rows_per_second=2000
   }
   
   source {
     Oracle-CDC {
       plugin_output = "cdc"
       url = "jdbc:oracle:thin:@db.xxxx.com:1521/ORCL"
       username = "xxxx"
       password = "xxxx"
       database-names = ["ORCL"]
       schema-names = ["ZG_ERP"]
       table-names = [
         "ORCL.ZG_ERP.TSALES_ORDER"
       ]
   
       source.reader.close.timeout = 120000
       startup.mode = "LATEST"        # INITIAL 全量后一直接增量 EARLIEST 从能拿到的最早日志位置开始 
只做增量 LATEST 从当前最新日志位置开始
       stop.mode = "never"            # 不自动停止
       exactly_once = true
       schema-changes.enabled = true  # 是否启用模式演进（新增、删除、重命名字段）
       snapshot.split.size = 5000     # 每个 split chunk 大小（行数）
       snapshot.fetch.size = 2048     # 每次 fetch 时批大小，适当调大减小交互延迟
       skip_analyze = true            # 不用 Seatunnel 自己分析表（如果你 DBA 已提前分析好）
       use_select_count=true
       connect.timeout.ms = 60000     # JDBC 连接超时时间
       connect.max-retries = 5
       connection.pool.size = 5       # JDBC 连接池大小（适当调大）
       # 控制 chunk key 的均匀分布阈值
       chunk-key.even-distribution.factor.upper-bound = 200
       chunk-key.even-distribution.factor.lower-bound = 0.01
       sample-sharding.threshold = 2000
       inverse-sampling.rate = 2000
       # dbz参数 优化
       debezium.log.mining.strategy=online_catalog # 日志挖掘策略
       debezium.log.mining.continuous.mine=true # 持续挖掘日志
        debezium.lob.enabled = false # 禁用LOB支持
        debezium.internal.log.mining.dml.parser ="legacy" # 使用传统DML解析器
     }
   }
   
   transform {
       TableRename {
           plugin_input = "cdc" # 输入插件标识
           plugin_output = "transform-result" # 输出插件标识
           convert_case = "LOWER" # 表名转换为小写
           prefix = "cdc_" # 添加表名前缀
       }
   }
   
   sink {
     Console {
       plugin_input = "transform-result"
     }
   }
   EOF
   
   
   
   
   $SEATUNNEL_HOME/bin/seatunnel.sh  \
   --async \
   -e cluster \
   --config 
/data/workspaces/sea_config_file/STREAMING-ZETA-ZG_ERP-Console.config \
   -n STREAMING-ZETA-ZG_ERP-Console
   
   
   $SEATUNNEL_HOME/bin/seatunnel.sh -s 1078976161389740036
   
   
   $SEATUNNEL_HOME/bin/seatunnel.sh \
   -c /data/workspaces/sea_config_file/STREAMING-ZETA-ZG_ERP-Console.config  \
   -r 1078976161389740036 \
   -n STREAMING-ZETA-ZG_ERP-Console
   > ```
   > 
   > <img alt="图像" width="1666" height="164" 
src="https://private-user-images.githubusercontent.com/69708156/554669200-495442e3-bb52-472f-b625-8ab8f77781db.png?jwt=eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJpc3MiOiJnaXRodWIuY29tIiwiYXVkIjoicmF3LmdpdGh1YnVzZXJjb250ZW50LmNvbSIsImtleSI6ImtleTUiLCJleHAiOjE3NzIwMTM1ODMsIm5iZiI6MTc3MjAxMzI4MywicGF0aCI6Ii82OTcwODE1Ni81NTQ2NjkyMDAtNDk1NDQyZTMtYmI1Mi00NzJmLWI2MjUtOGFiOGY3Nzc4MWRiLnBuZz9YLUFtei1BbGdvcml0aG09QVdTNC1ITUFDLVNIQTI1NiZYLUFtei1DcmVkZW50aWFsPUFLSUFWQ09EWUxTQTUzUFFLNFpBJTJGMjAyNjAyMjUlMkZ1cy1lYXN0LTElMkZzMyUyRmF3czRfcmVxdWVzdCZYLUFtei1EYXRlPTIwMjYwMjI1VDA5NTQ0M1omWC1BbXotRXhwaXJlcz0zMDAmWC1BbXotU2lnbmF0dXJlPTQyYjlhY2EyODM4ZTM3NGRmYThlZTFiZjU0MWIwMWRiNzFjMTNkNGZjNjZkMzAxOTYwNTBkOWJkZDBiMjRjZWMmWC1BbXotU2lnbmVkSGVhZGVycz1ob3N0In0.oFcEFiQaeu3T_MaU-vtNygEje9EZ27_AtUAb_2-PHcQ";>
 <img alt="图像" width="1903" height="487" 
src="https://private-user-images.githubusercontent.com/69708156/554669198-26056793-fe50-4797-8344-64fdea2c5ceb.png?jwt=
 
eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJpc3MiOiJnaXRodWIuY29tIiwiYXVkIjoicmF3LmdpdGh1YnVzZXJjb250ZW50LmNvbSIsImtleSI6ImtleTUiLCJleHAiOjE3NzIwMTM1ODMsIm5iZiI6MTc3MjAxMzI4MywicGF0aCI6Ii82OTcwODE1Ni81NTQ2NjkxOTgtMjYwNTY3OTMtZmU1MC00Nzk3LTgzNDQtNjRmZGVhMmM1Y2ViLnBuZz9YLUFtei1BbGdvcml0aG09QVdTNC1ITUFDLVNIQTI1NiZYLUFtei1DcmVkZW50aWFsPUFLSUFWQ09EWUxTQTUzUFFLNFpBJTJGMjAyNjAyMjUlMkZ1cy1lYXN0LTElMkZzMyUyRmF3czRfcmVxdWVzdCZYLUFtei1EYXRlPTIwMjYwMjI1VDA5NTQ0M1omWC1BbXotRXhwaXJlcz0zMDAmWC1BbXotU2lnbmF0dXJlPTk4ZTEwODY5MjZkYjUwZDk2ZDc2YTdhOWIxYWRjNzdlNDc4NGE2ZjFkZjAxNDljZTkzOTJhYjQ3MGY4ZjliMzgmWC1BbXotU2lnbmVkSGVhZGVycz1ob3N0In0.75Y5YcKNbt96JhV6ue_2BzhLGGBVP1xSphrXcBuMLHM">
 <img alt="图像" width="1920" height="291" 
src="https://private-user-images.githubusercontent.com/69708156/554669307-b06cccf6-013e-421d-b9c4-7303d35bb3ff.png?jwt=eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJpc3MiOiJnaXRodWIuY29tIiwiYXVkIjoicmF3LmdpdGh1YnVzZXJjb250ZW50LmNvbSIsImtleSI6ImtleTUiLCJleHAiOjE3NzIwMTM1ODMsIm5iZiI6MTc3MjAxMz
 
I4MywicGF0aCI6Ii82OTcwODE1Ni81NTQ2NjkzMDctYjA2Y2NjZjYtMDEzZS00MjFkLWI5YzQtNzMwM2QzNWJiM2ZmLnBuZz9YLUFtei1BbGdvcml0aG09QVdTNC1ITUFDLVNIQTI1NiZYLUFtei1DcmVkZW50aWFsPUFLSUFWQ09EWUxTQTUzUFFLNFpBJTJGMjAyNjAyMjUlMkZ1cy1lYXN0LTElMkZzMyUyRmF3czRfcmVxdWVzdCZYLUFtei1EYXRlPTIwMjYwMjI1VDA5NTQ0M1omWC1BbXotRXhwaXJlcz0zMDAmWC1BbXotU2lnbmF0dXJlPTFiZThhYzFjMzEzNTM2MGQyMGU5ZmIyNDViZmI1MGMzMjRmZTA4ZjY1YWQyMDk0ZWI3ZjU1N2JiOTc5ZGVkYzImWC1BbXotU2lnbmVkSGVhZGVycz1ob3N0In0.Qz9_mEpLwasIZSkk9h5e8Gu6ONH4nUQus_e3kj0skbE">
   
   
   
   > > [@liusy-bd](https://github.com/liusy-bd)您可以尝试使用其他接收器连接器，例如 Console、Hive 
或 JDBC 吗？
   > 
   > [@LeonYoah](https://github.com/LeonYoah)可以通过 -s 选项恢复控制台。
   > 
   > ```
   > sink {
   >   Console {
   >     plugin_input = "transform-result"
   >   }
   > }
   > ```
   > 
   > <img alt="图像" width="1666" height="164" 
src="https://private-user-images.githubusercontent.com/69708156/554669200-495442e3-bb52-472f-b625-8ab8f77781db.png?jwt=eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJpc3MiOiJnaXRodWIuY29tIiwiYXVkIjoicmF3LmdpdGh1YnVzZXJjb250ZW50LmNvbSIsImtleSI6ImtleTUiLCJleHAiOjE3NzIwMTM2MTgsIm5iZiI6MTc3MjAxMzMxOCwicGF0aCI6Ii82OTcwODE1Ni81NTQ2NjkyMDAtNDk1NDQyZTMtYmI1Mi00NzJmLWI2MjUtOGFiOGY3Nzc4MWRiLnBuZz9YLUFtei1BbGdvcml0aG09QVdTNC1ITUFDLVNIQTI1NiZYLUFtei1DcmVkZW50aWFsPUFLSUFWQ09EWUxTQTUzUFFLNFpBJTJGMjAyNjAyMjUlMkZ1cy1lYXN0LTElMkZzMyUyRmF3czRfcmVxdWVzdCZYLUFtei1EYXRlPTIwMjYwMjI1VDA5NTUxOFomWC1BbXotRXhwaXJlcz0zMDAmWC1BbXotU2lnbmF0dXJlPWE5NGEzMTRhMzNlZjZmZDY1Nzg0MWJmNmI2MGE4M2I3ZmU1YzMxYTY0MjdiNTAzZTdkOTI1ODUyMDc4OWY4YjgmWC1BbXotU2lnbmVkSGVhZGVycz1ob3N0In0.alZzQtxgAeKM0VKNTq3DWX6K_ooPOBEopra2Vy2IXCg";>
 <img alt="图像" width="1903" height="487" 
src="https://private-user-images.githubusercontent.com/69708156/554669198-26056793-fe50-4797-8344-64fdea2c5ceb.png?jwt=
 
eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJpc3MiOiJnaXRodWIuY29tIiwiYXVkIjoicmF3LmdpdGh1YnVzZXJjb250ZW50LmNvbSIsImtleSI6ImtleTUiLCJleHAiOjE3NzIwMTM2MTgsIm5iZiI6MTc3MjAxMzMxOCwicGF0aCI6Ii82OTcwODE1Ni81NTQ2NjkxOTgtMjYwNTY3OTMtZmU1MC00Nzk3LTgzNDQtNjRmZGVhMmM1Y2ViLnBuZz9YLUFtei1BbGdvcml0aG09QVdTNC1ITUFDLVNIQTI1NiZYLUFtei1DcmVkZW50aWFsPUFLSUFWQ09EWUxTQTUzUFFLNFpBJTJGMjAyNjAyMjUlMkZ1cy1lYXN0LTElMkZzMyUyRmF3czRfcmVxdWVzdCZYLUFtei1EYXRlPTIwMjYwMjI1VDA5NTUxOFomWC1BbXotRXhwaXJlcz0zMDAmWC1BbXotU2lnbmF0dXJlPThkYzQxN2FiNTcyMWQwNjY4M2U4NTI3MjM2MjMyNjdkOGM4OWFjMTRhMjM1ZGNjZWQ5NjhiZDZiNmFkMDIwMDkmWC1BbXotU2lnbmVkSGVhZGVycz1ob3N0In0.UuSp0aN3ooGo5UKKESJh5LZJWDBicaJllXIo4vaixJ4">
 <img alt="图像" width="1920" height="291" 
src="https://private-user-images.githubusercontent.com/69708156/554669307-b06cccf6-013e-421d-b9c4-7303d35bb3ff.png?jwt=eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJpc3MiOiJnaXRodWIuY29tIiwiYXVkIjoicmF3LmdpdGh1YnVzZXJjb250ZW50LmNvbSIsImtleSI6ImtleTUiLCJleHAiOjE3NzIwMTM2MTgsIm5iZiI6MTc3MjAxMz
 
MxOCwicGF0aCI6Ii82OTcwODE1Ni81NTQ2NjkzMDctYjA2Y2NjZjYtMDEzZS00MjFkLWI5YzQtNzMwM2QzNWJiM2ZmLnBuZz9YLUFtei1BbGdvcml0aG09QVdTNC1ITUFDLVNIQTI1NiZYLUFtei1DcmVkZW50aWFsPUFLSUFWQ09EWUxTQTUzUFFLNFpBJTJGMjAyNjAyMjUlMkZ1cy1lYXN0LTElMkZzMyUyRmF3czRfcmVxdWVzdCZYLUFtei1EYXRlPTIwMjYwMjI1VDA5NTUxOFomWC1BbXotRXhwaXJlcz0zMDAmWC1BbXotU2lnbmF0dXJlPWY2NjI3OTkzOGQ0MTcwN2UwMGYzZjg1YjZhMWM3MzliZTExOWIzOTIyNjFjNzllNDMwMTVjYTY0MzI2NWJkYTcmWC1BbXotU2lnbmVkSGVhZGVycz1ob3N0In0.LLwILCnMAwr2OgeweTcpdyrJ5ELEFoU4EquZYrmkvXQ">
   
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscr...@seatunnel.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org