dp api
07/02/2023, 10:49 AMenv_settings = <http://EnvironmentSettings.in|EnvironmentSettings.in>_streaming_mode()
t_env = TableEnvironment.create(env_settings)
t_env.get_config().set("pipeline.jars", "directory_path_to_jar_file")
t_env.get_config().set("table.exec.source.idle-timeout", "1000")
When I am writing a SQL SELECT query and Ordering by timestamp (which is converted using TO_TIMESTAMP_LTZ) I am getting an error
"Sort on a non-time-attribute field is not supported"
I searched online and found this - FLINK-18401
It suggested that I enable table.exec.non-temporal-sort.enabled=true which is false by default.
However I cannot find this in the docs and do not know how to configure this.
Any help would be greatly appreciated. π