Flink Query Optimizer

Hello, I am just wondering, does Flink use Apache Calcite's query optimizer to generate an optimal logical plan for stream queries, or does it have its own independent query optimizer? >From what I observed so far, the Flink's query optimizer only groups operator together without changing the

Re: Multiple consumers on a subpartition

Thank you for your responses and suggestions. I appreciate it. Albert On Wed, Apr 26, 2017 at 4:19 AM, Ufuk Celebi wrote: > Adding to what Zhijiang said: I think the way to go would be to create > multiple "read views" over the pipelined subpartition. You would have > to make