Jingsong Lee created FLINK-27415:
------------------------------------
Summary: Read empty csv file throws exception in FileSystem table
connector
Key: FLINK-27415
URL: https://issues.apache.org/jira/browse/FLINK-27415
Project: Flink
Issue Type: Bug
Components: Connectors / FileSystem, Formats (JSON, Avro, Parquet,
ORC, SequenceFile)
Affects Versions: 1.15.0
Reporter: Jingsong Lee
Fix For: 1.15.1
{code:java}
// in CsvFilesystemBatchITCase
@Test
public void testEmpty() throws Exception {
String path = new URI(resultPath()).getPath();
new File(path).mkdirs();
File file = new File(path, "test_file");
file.createNewFile();
check("select * from nonPartitionedTable", Collections.emptyList());
} {code}
Throws:
{code:java}
Caused by: java.lang.IllegalArgumentException
at org.apache.flink.util.Preconditions.checkArgument(Preconditions.java:122)
at
org.apache.flink.connector.file.src.impl.StreamFormatAdapter$TrackingFsDataInputStream.<init>(StreamFormatAdapter.java:264)
at
org.apache.flink.connector.file.src.impl.StreamFormatAdapter.lambda$openStream$3(StreamFormatAdapter.java:180)
at
org.apache.flink.connector.file.src.util.Utils.doWithCleanupOnException(Utils.java:45)
at
org.apache.flink.connector.file.src.impl.StreamFormatAdapter.openStream(StreamFormatAdapter.java:172)
at
org.apache.flink.connector.file.src.impl.StreamFormatAdapter.createReader(StreamFormatAdapter.java:70)
at
org.apache.flink.connector.file.src.impl.FileSourceSplitReader.checkSplitOrStartNext(FileSourceSplitReader.java:112)
at
org.apache.flink.connector.file.src.impl.FileSourceSplitReader.fetch(FileSourceSplitReader.java:65)
at
org.apache.flink.connector.base.source.reader.fetcher.FetchTask.run(FetchTask.java:58)
at
org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:142)
... 6 more {code}
This may be introduced by FLINK-24703
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
