[
https://issues.apache.org/jira/browse/FLINK-27415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17739977#comment-17739977
]
Danny Cranmer edited comment on FLINK-27415 at 7/6/23 1:40 PM:
---------------------------------------------------------------
Merged commit
[{{0015fd3}}|https://github.com/apache/flink/commit/0015fd3d0b7f226f31354c5792df055bc8e97d74]
into master (1.18)
Merged commit
[{{3061dee}}|https://github.com/apache/flink/commit/3061dee843b69eba62775e96f65b7f9a51f82bb5]
into release-1.17
Merged commit
[{{ad1b739}}|https://github.com/apache/flink/commit/ad1b739358efa3c58187f80ead80a81377029c48]
into release-1.16
was (Author: dannycranmer):
Merged commit
[{{0015fd3}}|https://github.com/apache/flink/commit/0015fd3d0b7f226f31354c5792df055bc8e97d74]
into master (1.18)
> 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.18.0, 1.16.3, 1.17.2
>
>
> {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)
