You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by "JackyChenPeng (via GitHub)" <gi...@apache.org> on 2023/05/15 09:44:15 UTC

[GitHub] [incubator-seatunnel] JackyChenPeng opened a new issue, #4756: [Bug] [MYSQL-CDC] [Doris-sink] 使用mysql-cdc +doris-sink同步数据时,sink.label-prefix相同会报错,导致无法任务无法通过checkpoint还原

JackyChenPeng opened a new issue, #4756:
URL: https://github.com/apache/incubator-seatunnel/issues/4756

   ### Search before asking
   
   - [X] I had searched in the [issues](https://github.com/apache/incubator-seatunnel/issues?q=is%3Aissue+label%3A%22bug%22) and found no similar issues.
   
   
   ### What happened
   
   操作过程:
   
   [duplicate-label-error.txt](https://github.com/apache/incubator-seatunnel/files/11476436/duplicate-label-error.txt)
   [error.txt](https://github.com/apache/incubator-seatunnel/files/11476397/error.txt)
   
   ### SeaTunnel Version
   
   seatunnel-2.3.1
   
   ### SeaTunnel Config
   
   ```conf
   env {
     job.name = "jacky.test"
     job.mode = "STREAMING"
     parallelism = 2
   }
   
   source {
     MySQL-CDC {
       result_table_name = "t_loan_apply_temp"
       catalog = {
       factory = "MySQL"
       }
       parallelism = 2
       server-id = 1001
       username = "biz-ro"
       password = "xx"
       table-names = ["mexico_one.t_loan_apply"]
       base-url = "jdbc:mysql://biz-rds-ro.norotech.lo:3306/mexico_one"
     }
   
   }
   
   transform {
   }
   
   sink {
       Doris {
           fenodes = "xxxx"
           username = "jacky_chen"
           password = "xx"
           source_table_name = "t_loan_apply_temp"
           table.identifier = "mexico_one.t_loan_apply"
           sink.enable-2pc = "true"
           sink.label-prefix = "biz_20230515_031906"
           doris.config = {
               format="json"
               read_json_by_line="true"
           }
       }
   }
   ```
   
   
   ### Running Command
   
   ```shell
   集群starndalone模式
   1. 手动启动一个任务: sh bin/seatunnel.sh  -c noroDwhConfig/mexico_one.t_loan_apply.conf 通过log找到job id
   2. 手动执行 sh bin/seatunnel.sh -s {job id} 存savepoint
   3. 还原任务报错   sh bin/seatunnel.sh -c noroDwhConfig/mexico_one.t_loan_apply.conf -r {job id}
   ```
   
   
   ### Error Exception
   
   ```log
   见附件
   ```
   
   
   ### Flink or Spark Version
   
   _No response_
   
   ### Java or Scala Version
   
   jdk-1.8.0-371
   
   ### Screenshots
   
   _No response_
   
   ### Are you willing to submit PR?
   
   - [ ] Yes I am willing to submit a PR!
   
   ### Code of Conduct
   
   - [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct)
   


-- 
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-unsubscribe@seatunnel.apache.org.apache.org

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


[GitHub] [seatunnel] zhongjiajie closed issue #4756: [Bug] [MYSQL-CDC] [Doris-sink] doris-sink task can not be restored from checkpoint

Posted by "zhongjiajie (via GitHub)" <gi...@apache.org>.
zhongjiajie closed issue #4756: [Bug] [MYSQL-CDC] [Doris-sink] doris-sink task can not be restored from checkpoint 
URL: https://github.com/apache/seatunnel/issues/4756


-- 
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-unsubscribe@seatunnel.apache.org

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


[GitHub] [seatunnel] Carl-Zhou-CN commented on issue #4756: [Bug] [MYSQL-CDC] [Doris-sink] doris-sink task can not be restored from checkpoint

Posted by "Carl-Zhou-CN (via GitHub)" <gi...@apache.org>.
Carl-Zhou-CN commented on issue #4756:
URL: https://github.com/apache/seatunnel/issues/4756#issuecomment-1564149988

   hi, as for your first question, the same label-prefix cannot perform the same task twice. For the time being, it may be because the two tasks finally produce the same label, which may need to be improved. As for your second question, I am not quite clear


-- 
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-unsubscribe@seatunnel.apache.org

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