??????????
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?
>
>
>
