Excellent! I'll give it a try. Thanks!
Le On Wed, Jun 30, 2021 at 10:14 PM JING ZHANG <beyond1...@gmail.com> wrote: > Hi Le, > AFAIK, there are following ways to look deeper into the job, hope it helps. > Before executing the job, > 1. Use `explain` statement to explain the logical and optimized plans of a > query[1]. > 2. Use `ExecutionEnvironment#getExecutionPlan` to print the > execution plan, And use `visualizer` to visualize the execution plan [2]. > After executing the job, > 1. Find jobGraph in Flink web UI. > > [1] > https://ci.apache.org/projects/flink/flink-docs-release-1.13/zh/docs/dev/table/sql/explain/ > [2] > https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/execution/execution_plans/ > > Best regards, > JING ZHANG > > Le Xu <sharonx...@gmail.com> 于2021年7月1日周四 上午5:51写道： > >> Thanks -- Is there a way to quickly visualize the Stream operator DAG >> generated by the TableAPI/SQL queries? >> >> Le >> >> On Tue, Jun 29, 2021 at 9:34 PM JING ZHANG <beyond1...@gmail.com> wrote: >> >>> Hi Le, >>> link >>> <https://stackoverflow.com/questions/51618273/difference-between-datastream-and-table-api-in-apache-flink> >>> is >>> a bit outdated. Since Flink 1.9 version, TableAPI & SQL is no longer >>> translated to DataStream API. TableAPI & SQL and DataStream are at the same >>> level, and both translated into StreamOperator DAG. >>> >>> Best regards, >>> JING ZHANG >>> >>> Le Xu <sharonx...@gmail.com> 于2021年6月30日周三 上午1:11写道： >>> >>>> Hello! I have a basic question about the concept of using Flink Table >>>> API. >>>> Based on the link >>>> <https://stackoverflow.com/questions/51618273/difference-between-datastream-and-table-api-in-apache-flink> >>>> here it seems like if I implement stream query with Table API the program >>>> is translated to datastream API eventually during execution. But is there a >>>> way to visualize how the datastream program looks like >>>> >>>> Thanks, >>>> >>>> Le >>>> >>>
