看起来 tableSink 由于什么原因变成null了。需要debug一下。 你能提供一下你的 conf/sql-client-defaults.yaml 吗？
On Thu, Mar 7, 2019 at 1:31 PM yuess_coder <[email protected]> wrote: > 错误日志是 > > > > > java.lang.NullPointerException > at > org.apache.flink.table.api.TableEnvironment.insertInto(TableEnvironment.scala:1300) > at > org.apache.flink.table.api.TableEnvironment.sqlUpdate(TableEnvironment.scala:1203) > at > org.apache.flink.table.api.TableEnvironment.sqlUpdate(TableEnvironment.scala:1235) > at > org.apache.flink.table.client.gateway.local.LocalExecutor.lambda$applyUpdate$10(LocalExecutor.java:605) > at > org.apache.flink.table.client.gateway.local.ExecutionContext.wrapClassLoader(ExecutionContext.java:181) > at > org.apache.flink.table.client.gateway.local.LocalExecutor.applyUpdate(LocalExecutor.java:603) > at > org.apache.flink.table.client.gateway.local.LocalExecutor.executeUpdateInternal(LocalExecutor.java:508) > at > org.apache.flink.table.client.gateway.local.LocalExecutor.executeUpdate(LocalExecutor.java:342) > at > org.apache.flink.table.client.cli.CliClient.callInsertInto(CliClient.java:483) > at > org.apache.flink.table.client.cli.CliClient.callCommand(CliClient.java:286) > at java.util.Optional.ifPresent(Optional.java:159) > at org.apache.flink.table.client.cli.CliClient.open(CliClient.java:174) > at org.apache.flink.table.client.SqlClient.openCli(SqlClient.java:125) > at org.apache.flink.table.client.SqlClient.start(SqlClient.java:107) > at org.apache.flink.table.client.SqlClient.main(SqlClient.java:202) > > > > > > val sinkFieldTypes = tableSink > .getFieldTypes > .map(_.toInternalType) > > 这里报的null。多谢回答。 > > > ------------------ 原始邮件 ------------------ > 发件人: "Kurt Young"<[email protected]>; > 发送时间: 2019年3月7日(星期四) 中午12:06 > 收件人: "user-zh"<[email protected]>; > > 主题: Re: sql-client batch 模式执行报错 > > > > 你好，看不到图，能贴成文本吗？ > > Best, > Kurt > > > On Thu, Mar 7, 2019 at 9:23 AM yuess_coder <[email protected]> wrote: > > > 我在sql-client提交任务： > > > > create table csv_source1( > > id varchar, > > name varchar > > ) with ( > > type ='csv', > > path = > '/Users/IdeaProjects/github/apache-flink/build-target/bin/test1.csv' > > ); > > > > > > create table csv_sink( > > id varchar, > > name varchar > > ) with ( > > type ='csv', > > path = > '/Users/IdeaProjects/github/apache-flink/build-target/bin/test4.csv' > > ); > > > > insert into csv_sink select t1.name,t1.id from csv_source1 t1 > > > > > > 错误是org.apache.flink.table.api.TableEnvironment这个类1300行空指针，用execution > > batch模式不行，用execution streaming模式是可以的。请问下才能batch模式执行这个sql? > > > > > >
