[jira] [Created] (FLINK-30026) Support database table include option in debezium-json

Zhiwen Sun created FLINK-30026: -- Summary: Support database table include option in debezium-json Key: FLINK-30026 URL: https://issues.apache.org/jira/browse/FLINK-30026 Project: Flink Issue

[jira] [Created] (FLINK-27761) Add database and table field in canal-json sink

Zhiwen Sun created FLINK-27761: -- Summary: Add database and table field in canal-json sink Key: FLINK-27761 URL: https://issues.apache.org/jira/browse/FLINK-27761 Project: Flink Issue Type:

[jira] [Created] (FLINK-27663) upsert-kafka can't process delete message from upsert-kafka sink

Zhiwen Sun created FLINK-27663: -- Summary: upsert-kafka can't process delete message from upsert-kafka sink Key: FLINK-27663 URL: https://issues.apache.org/jira/browse/FLINK-27663 Project: Flink

[jira] [Created] (FLINK-22998) Flink SQL does not support block comment before SET command

Zhiwen Sun created FLINK-22998: -- Summary: Flink SQL does not support block comment before SET command Key: FLINK-22998 URL: https://issues.apache.org/jira/browse/FLINK-22998 Project: Flink

[jira] [Created] (FLINK-22786) sql-client can not create .flink-sql-history file

Zhiwen Sun created FLINK-22786: -- Summary: sql-client can not create .flink-sql-history file Key: FLINK-22786 URL: https://issues.apache.org/jira/browse/FLINK-22786 Project: Flink Issue Type: