'Initial segment may not be null' error

2022-01-10 Thread Egor Ryashin
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/mobiled

reading gz files

2021-12-14 Thread Egor Ryashin
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' = '