Re: SDK vs Connectors

2020-08-22 Thread Yun Gao
Hi Prasanna, 1) Semantically both a) and b) would be Ok. If the Custom sink could be chained with the map operator (I assume the map operator is the "Processing" in the graph), there should be also no much difference physically, if they could not chain, then writting a custom sink would

[jira] [Created] (FLINK-19027) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnParallelRemoteChannel failed because of test timeout

2020-08-22 Thread Dian Fu (Jira)
Dian Fu created FLINK-19027: --- Summary: UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnParallelRemoteChannel failed because of test timeout Key: FLINK-19027 URL:

[jira] [Created] (FLINK-19026) Improve threading model of Unaligner

2020-08-22 Thread Arvid Heise (Jira)
Arvid Heise created FLINK-19026: --- Summary: Improve threading model of Unaligner Key: FLINK-19026 URL: https://issues.apache.org/jira/browse/FLINK-19026 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-19025) table sql write orc file but hive2.1.1 can not read

2020-08-22 Thread McClone (Jira)
McClone created FLINK-19025: --- Summary: table sql write orc file but hive2.1.1 can not read Key: FLINK-19025 URL: https://issues.apache.org/jira/browse/FLINK-19025 Project: Flink Issue Type: Bug