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
Dian Fu created FLINK-19027:
---
Summary:
UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnParallelRemoteChannel
failed because of test timeout
Key: FLINK-19027
URL:
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
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