Hey,

I’m using Flink 1.14 and having trouble ingesting data from json gz file. I’ve 
successfully created a table but number of records is wrong.
I’m using this SQL:
create table i1(
 line_item_id STRING
) with (
 'connector'='filesystem',
 'path'='/Users/egorryashin/temp/test.json',
 'format' = 'json'
);

create table i2(
 line_item_id STRING
) with (
 'connector'='filesystem',
 'path'='/Users/egorryashin/temp/test.gz',
 'format' = 'json'
);

select count(*) from i1 union all select count(*) from i2;
               EXPR$0
                   65
                  285

Thanks

Reply via email to