答复: Conversion to relational algebra failed to preserve datatypes

2018-09-14 Thread Yuan,Youjun
). If I remove a few fields in the source, then everything goes fine. Thanks Youjun 发件人: Timo Walther 发送时间: Friday, September 14, 2018 9:17 PM 收件人: user@flink.apache.org 主题: Re: Conversion to relational algebra failed to preserve datatypes Hi, could you maybe post the query that caused the

Re: Conversion to relational algebra failed to preserve datatypes

2018-09-14 Thread Timo Walther
org.apache.flink.runtime.webmonitor.handlers.JarRunHandler.lambda$handleJsonRequest$0(JarRunHandler.java:69) ... 9 more Caused by: java.lang.AssertionError: Conversion to relational algebra failed to preserve datatypes: validated type: RecordType(TIMESTAMP(3) NOT NULL ts, VARCHAR(65536) CHARACTER SET "UTF-16LE" COLLATE "I

Conversion to relational algebra failed to preserve datatypes

2018-09-14 Thread Yuan,Youjun
lassLoader(JarActionHandler.java:76) at org.apache.flink.runtime.webmonitor.handlers.JarRunHandler.lambda$handleJsonRequest$0(JarRunHandler.java:69) ... 9 more Caused by: java.lang.AssertionError: Conversion to relational algebra failed to preserve datatypes: validated type: RecordType(TIMESTAMP(3) N