Hey,

I use Flink 1.14 and run this query with sql-client:

SET 'sql-client.execution.result-mode' = 'tableau';
SET 'execution.runtime-mode' = 'batch’; 

create table data(
 id STRING,
 account_id STRING,
 a_id STRING,
`timestamp` STRING
) with (
 'connector'='filesystem',
 'path'='/Volumes/mobiledisk/data',
 'format' = 'json'
);

select count(distinct id) from (select id from data limit 1000000);`

and get this error almost instantly:
[ERROR] Could not execute SQL statement. Reason:
java.lang.NullPointerException: Initial Segment may not be null

(This query does work in streaming mode though. )

Thanks

Reply via email to