The role of CREATE TABLE is to provide the necessary metadata for the table -- the location of the data, its format, etc. Executing CREATE TABLE creates an entry in the catalog, but otherwise doesn't do anything.
In a case like this one CREATE TABLE Table1 (column_name1 STRING, column_name2 DOUBLE) WITH ('connector' = 'filesystem', 'path' = 'file:///C:/temp/test4.txt', 'format' = 'csv', 'csv.field-delimiter' = ';'); Flink doesn't need to know in advance if you will be reading from or writing to Table1 (or both). The CREATE TABLE DDL statement includes enough information to handle either case. David On Mon, Aug 29, 2022 at 8:15 AM <pod...@gmx.com> wrote: > > To create table from file: > > "CREATE TABLE Table1 (column_name1 STRING, column_name2 DOUBLE) WITH > ('connector' = 'filesystem', 'path' = 'file:///C:/temp/test4.txt', 'format' > = 'csv', 'csv.field-delimiter' = ';')"); > > To create file: > > "CREATE TABLE Table1 (column_name1 STRING, column_name2 DOUBLE) WITH ( > 'connector'='filesystem', 'path'='file:///C:/temp/test', 'format' = 'csv', > 'csv.field-delimiter'= ';')"); > > Till I add 'sink.partition-commit.delay' or something - syntax is same. > >