>> 'connector' = 'filesystem',
>>> 'path' = 'hdfs://${our_data_path}month=202307/day=20230714',
>>> 'format' = 'parquet'
>>> );
>>>
>>> SELECT `hour`
>>
-- Forwarded message -
보낸사람: Dongwoo Kim
Date: 2023년 7월 31일 (월) 오후 11:36
Subject: Re: Flink sql client doesn't work with "partition by" clause
To: liu ron
Hi, ron.
Actually I'm not receiving any exception message when executing the *partition
by* clause in
= 'filesystem',
'path' = 'hdfs://${out_data_path}/month=202307/day=20230714',
'format' = 'parquet'
);
SELECT status
FROM source_table_2
GROUP BY status;
Best,
dongwoo
2023년 7월 28일 (금) 오후 6:19, Dongwoo Kim 님이
Hello all, I have found that flink sql client doesn't work with "partition
by" clause.
Is this bug? It's bit weird since when I execute same sql with
tableEnv.executeSql(statement) code it works as expected. Has anyone
tackled this kind of issue? I have tested in flink 1.16.
