Re: Why this example does not save anything to file?

2022-07-29 Thread podunk
Hi,   you mean adding:   " 'csv.field-delimiter'=';', "   like:      tEnv.executeSql("CREATE TABLE fs_table ("                 + "    column_nameA STRING, "                 + "    column_nameB DOUBLE "                 + "    ) WITH ( "                 + "    'connector'='filesystem', "

Re: Why this example does not save anything to file?

2022-07-29 Thread podunk
In Eclipse only:   WARNING: An illegal reflective access operation has occurred WARNING: Illegal reflective access by org.apache.flink.api.java.ClosureCleaner (file:/C:/Flink/flink-1.14.4/lib/flink-dist_2.11-1.14.4.jar) to field java.lang.String.value WARNING: Please consider reporting this to th

Java 17 Support?

2022-07-29 Thread Clayton Wohl
May I ask if there are any plans to support Java 17 in a future version of Flink? I see this ticket, but it is inactive: https://issues.apache.org/jira/browse/FLINK-15736 There are several Java 17 features that would help in writing+supporting Flink applications. Thank you :)