gitfortian

u can insert into a record that which filed is string type and that content include \n would case this issue

> mysql? idont unstand

> Could you give some records in the mysql? @gitfortian i viewed the spark connector code and found that problem cased by u split content by \n default this hard...

> Could you give some records in the mysql? @gitfortian i viewed the spark connector code and found that problem cased by u split content by \n default this hard...

mkString("\n") this cause the issue happens

flink run -t yarn-per-job -c org.apache.seatunnel.core.flink.SeatunnelFlink /usr/local/apache-seatunnel-incubating-2.1.2/lib/seatunnel-core-flink.jar --config ./config/flink.streaming.conf.template flink yarn-application-mode also meet the same problem,this may be bug, because it's ok when i run on yarn-per-job mode

@complone good idea 目前元数据管理模块确实太简单了 基本就只是一个展示 按照阿里的这个设计 确实很合理 如果有接下来的roadmap 我这边可以参与贡献

> Please add hadoop dependency in classpath of flink cluster. on yarn mode, exported `hadoop classpath` already,use the same hadoop dependency,when use 2.2.beta it's ok,but 2.3.beta,it's not

i meet the same error

at_least_once mode，this problem also occurs