waryars

Results 9 comments of waryars

这边测试下,字段类型是int\varchar是没有问题,但涉及到decimal,datetime类型就不行。

试过用Unique表模型,启动都会报错的

为什么不是以sink端的指定的pimary key去处理~

Caused by: java.sql.SQLException: errCode = 2, detailMessage = errCode = 2, detailMessage = Column[area_name] is not key column or storage model is not duplicate or column type is float or...

我把 area_name,addr_name 字段类型的字段都加到key范围里了,其它字段的类型改为:sale_num float,sale_amt double 但还是报错: Column[sale_num] is not key column or storage model is not duplicate or column type is float or double. 当源表插入第二条记录时报错: insert into test_binlog(id,cname,sale_amt,ttime) values(154,'hua',10.20,now()); insert...

有解决了吗?我加了nameMapping问题仍然还没解决呢~

> 有解决了吗?我加了nameMapping问题仍然还没解决呢~ 报这个错: shade.core.com.google.common.util.concurrent.UncheckedExecutionException: com.dtstack.chunjun.throwable.ChunJunRuntimeException: error to get meta from [ROMA_LOGMINER.TEST_LOGMR] at shade.core.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2050) at shade.core.com.google.common.cache.LocalCache.get(LocalCache.java:3952) at shade.core.com.google.common.cache.LocalCache$LocalManualCache.get(LocalCache.java:4871) at com.dtstack.chunjun.connector.jdbc.sink.PreparedStmtProxy.getOrCreateFieldNamedPstmt(PreparedStmtProxy.java:154) at com.dtstack.chunjun.connector.jdbc.sink.PreparedStmtProxy.convertToExternal(PreparedStmtProxy.java:125) at com.dtstack.chunjun.connector.jdbc.sink.JdbcOutputFormat.writeMultipleRecordsInternal(JdbcOutputFormat.java:161) at com.dtstack.chunjun.sink.format.BaseRichOutputFormat.writeRecordInternal(BaseRichOutputFormat.java:496) at com.dtstack.chunjun.sink.format.BaseRichOutputFormat.lambda$initTimingSubmitTask$0(BaseRichOutputFormat.java:456) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at...

> > 有解决了吗?我加了nameMapping问题仍然还没解决呢~ > > 报这个错: > > shade.core.com.google.common.util.concurrent.UncheckedExecutionException: com.dtstack.chunjun.throwable.ChunJunRuntimeException: error to get meta from [ROMA_LOGMINER.TEST_LOGMR] at shade.core.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2050) at shade.core.com.google.common.cache.LocalCache.get(LocalCache.java:3952) at shade.core.com.google.common.cache.LocalCache$LocalManualCache.get(LocalCache.java:4871) at com.dtstack.chunjun.connector.jdbc.sink.PreparedStmtProxy.getOrCreateFieldNamedPstmt(PreparedStmtProxy.java:154) at com.dtstack.chunjun.connector.jdbc.sink.PreparedStmtProxy.convertToExternal(PreparedStmtProxy.java:125) at com.dtstack.chunjun.connector.jdbc.sink.JdbcOutputFormat.writeMultipleRecordsInternal(JdbcOutputFormat.java:161) at com.dtstack.chunjun.sink.format.BaseRichOutputFormat.writeRecordInternal(BaseRichOutputFormat.java:496)...