Hi,
you mean adding:
" 'csv.field-delimiter'=';', "
like:
tEnv.executeSql("CREATE TABLE fs_table ("
+ " column_nameA STRING, "
+ " column_nameB DOUBLE "
+ " ) WITH ( "
+ " 'connector'='filesystem', "
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
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 :)