[
https://issues.apache.org/jira/browse/FLINK-20311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238800#comment-17238800
]
Jark Wu commented on FLINK-20311:
---------------------------------
Cases:
1. Read from a "kafka" + "debezium-avro-confluent" table, and write into a
"filesystem" + "debezium-json" table. Check the result in the path. *As
expected*.
2. Read the above "filesystem" + "debezium-json" table in SQL CLI. Result is
*as expected*.
3. Define the above path as "filesystem" + "raw" table, and read it in SQL CLI.
The printed JSON string is *as expected*.
4. Read above "raw" filesystem table and write into anther "raw" filesystem
table, the result is *as expected*.
5. Read & write using 'filesystem' with "debezium-avro-confluent" doesn't work,
but that is a known unsupported feature.
> E2E test for Debezium, Canal, Raw of Filesystem connector
> ---------------------------------------------------------
>
> Key: FLINK-20311
> URL: https://issues.apache.org/jira/browse/FLINK-20311
> Project: Flink
> Issue Type: Sub-task
> Components: Connectors / FileSystem, Table SQL / API
> Reporter: Jingsong Lee
> Assignee: Jark Wu
> Priority: Major
> Fix For: 1.12.0
>
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
