There turns out to be an easy solution. env_settings = EnvironmentSettings.new_instance().in_batch_mode().use_blink_planner().build() t_env = BatchTableEnvironment.create(environment_settings=env_settings)
Use batch mode instead, then the top-n will be only omitting result once, at the end of the whole processing. -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
