Jupyter PyFlink Web UI

2021-06-08 Thread maverick
Hi, I've got a question. I'm running PyFlink code from Jupyter Notebook starting TableEnvironment with following code: env_settings = EnvironmentSettings.new_instance().in_streaming_mode().use_blink_planner().build() table_env = TableEnvironment.create(env_settings) How can I enable Web UI in thi

Watermarks in Event Time Temporal Join

2021-04-25 Thread maverick
Hi, I'm curious why Event Time Temporal Join needs watermarks from both sides to perform join. Shouldn't watermark on versioned table side be enough to perform join ? -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Re: Join a datastream with tables stored in Hive

2020-12-01 Thread maverick
Hi Kurt, Is there any Jira task for tracking progress of adding event time support to temporal joins ? Regards, Maciek -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/