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