Re:Re: Metrics & Monitoring in Flink SQL

2022-07-16 Thread casel.chen
How to get all metrics of those connectors shipped inline with flink release? any document? At 2022-07-13 11:05:43, "yuxia" wrote: With Flink SQL, You can define your own source/sink metrics [1], but you can't define the metrics for the intermediate operators. [1] https://nigh

Re: PyFlink and parallelism

2022-07-16 Thread John Tipper
I've tried this and can see there appears to be a bigger problem with PyFlink and a call to set_parallelism()​: events_table = table_env.from_path(MY_SOURCE_TABLE) filtered_table = events_table.filter( col("event_type") == "event_of_interest" ) filtered_stream = table_env.to_data_stream(filt