[FLINK-15289] Run sql appear error of "Zero-length character strings have no serializable string representation".

• Type: Bug
• Status: Reopened
• Priority: Minor
• Resolution: Unresolved
• Affects Version/s: 1.10.0
• Component/s: Table SQL / API
• Labels: auto-deprioritized-major stale-assigned
• Assignee: Jark Wu
• Reporter: xiaojin.wy
• Created: 17/Dec/19 07:45
• Updated: 10/May/23 08:29

Description

The sql is:
CREATE TABLE `INT8_TBL` (
q1 BIGINT,
q2 BIGINT
) WITH (
'format.field-delimiter'=',',
'connector.type'='filesystem',
'format.derive-schema'='true',
'connector.path'='/defender_test_data/daily_regression_batch_postgres_1.10/test_bigint/sources/INT8_TBL.csv',
'format.type'='csv'
);

SELECT '' AS five, q1 AS plus, -q1 AS xm FROM INT8_TBL;

The error detail is :
2019-12-17 15:35:07,026 ERROR org.apache.flink.table.client.SqlClient - SQL Client must stop. Unexpected exception. This is a bug. Please consider filing an issue.
org.apache.flink.table.api.TableException: Zero-length character strings have no serializable string representation.
at org.apache.flink.table.types.logical.CharType.asSerializableString(CharType.java:116)
at org.apache.flink.table.descriptors.DescriptorProperties.putTableSchema(DescriptorProperties.java:218)
at org.apache.flink.table.catalog.CatalogTableImpl.toProperties(CatalogTableImpl.java:75)
at org.apache.flink.table.factories.TableFactoryUtil.findAndCreateTableSink(TableFactoryUtil.java:85)
at org.apache.flink.table.client.gateway.local.LocalExecutor.executeQueryAndPersistInternal(LocalExecutor.java:688)
at org.apache.flink.table.client.gateway.local.LocalExecutor.executeQueryAndPersist(LocalExecutor.java:488)
at org.apache.flink.table.client.cli.CliClient.callSelect(CliClient.java:601)
at org.apache.flink.table.client.cli.CliClient.callCommand(CliClient.java:385)
at java.util.Optional.ifPresent(Optional.java:159)
at org.apache.flink.table.client.cli.CliClient.submitSQLFile(CliClient.java:271)
at org.apache.flink.table.client.SqlClient.openCli(SqlClient.java:125)
at org.apache.flink.table.client.SqlClient.start(SqlClient.java:104)
at org.apache.flink.table.client.SqlClient.main(SqlClient.java:180)

The input data is:
123,456
123,4567890123456789
4567890123456789,123
4567890123456789,4567890123456789
4567890123456789,-4567890123456789