[FLINK-7802] Exception occur when empty field collection was pushed into CSVTableSource

• Type: Bug
• Status: Closed
• Priority: Critical
• Resolution: Fixed
• Fix Version/s: 1.3.4, 1.4.0
• Component/s: Table SQL / API
• Assignee: godfrey he
• Reporter: godfrey he
• Created: 11/Oct/17 03:33
• Updated: 12/Mar/18 15:30
• Resolved: 12/Mar/18 15:30

Description

Consider such SQL: select count(1) from csv_table.

When above SQL was executed, an exception will occur:

java.lang.IllegalArgumentException: At least one field must be specified
at org.apache.flink.api.java.io.RowCsvInputFormat.<init>(RowCsvInputFormat.java:50)

So if no fields will be used, we should also keep some columns for CSVTableSource to get row count.

Issue Links

• links to: GitHub Pull Request #4815