Thanks for the suggestions Kurt and Jingsong! Very helpful
On Thu, Jul 16, 2020 at 4:30 AM Jingsong Li wrote:
> Hi Flavio,
>
> For print:
> - As Kurt said, you can use `table.execute().print();`, records will be
> collected to the client (NOTE it is client) and print to client console.
> - But
Hi Flavio,
For print:
- As Kurt said, you can use `table.execute().print();`, records will be
collected to the client (NOTE it is client) and print to client console.
- But if you want print records in runtime tasks like DataStream.print, you
can use [1]
[1]
Hi Flavio,
In 1.11 we have provided an easier way to print table content, after you
got the `table` object,
all you need to to is calling `table.execute().print();`
Best,
Kurt
On Thu, Jul 16, 2020 at 9:35 AM Leonard Xu wrote:
> Hi, Flavio
>
>
> 在 2020年7月16日，00:19，Flavio Pompermaier 写道：
>
>
Hi, Flavio
> 在 2020年7月16日，00:19，Flavio Pompermaier 写道：
>
> final JobExecutionResult jobRes = tableEnv.execute("test-job");
>
In Flink 1.11, once a Table has transformed to DataStream, only
StreamExecutionEnvironment can execute the DataStream program, please use
env.execute(“test-job”) in
Hi to all,
I'm trying to read and print out the content of my parquet directory with
Flink 1.11 (using the bridge API). However Flink complains that there is no
topology to execute..what am I doing wrong? The exception is:
java.lang.IllegalStateException: No operators defined in streaming
