Jingsong Lee created FLINK-13376:
------------------------------------
Summary: FileInputFormat can not be used in blink-planner
Key: FLINK-13376
URL: https://issues.apache.org/jira/browse/FLINK-13376
Project: Flink
Issue Type: Sub-task
Components: Connectors / FileSystem, Runtime / Task, Table SQL /
Runtime
Reporter: Jingsong Lee
Fix For: 1.9.0, 1.10.0
FileInputFormat use ContinuousFileReaderOperator in StreamExecutionEnvironment,
and ContinuousFileReaderOperator join the async thread in close, So before
closing, the data is incomplete.
But batch operators use endInput to do some work, this lead to incomplete
records in endInput, and lead to wrong results.
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)
