[
https://issues.apache.org/jira/browse/FLINK-27415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-27415:
---------------------------------
Fix Version/s: 1.15.4
(was: 1.15.3)
> 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
> Assignee: jia liu
> Priority: Major
> Labels: pull-request-available, stale-assigned
> Fix For: 1.15.4
>
>
> {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.10#820010)
