Flink Query Optimizer

changing the order of aggregation operators (e.g., join). Did I miss anything? I am thinking of extending Flink to apply query optimization as in the context of DBMS by either integrating it with Calcite or implementing it as a new module. Any feedback or guidelines will be highly appreciated. Thank you, Albert

Re: Flink session on Yarn - ClassNotFoundException

maven.org/maven2/com/google/guava/guava/23.0/guava-23.0.jar>) and also put that into Flink’s lib directory. I hope it helps other people trying to run Flink on Azure HDInsight :) Kind regards, Albert > On Aug 31, 2017, at 8:18 PM, Banias H wrote: > > We had the same issue. Get t

Re: Flink session on Yarn - ClassNotFoundException

Hi Chesnay, Thanks for your reply. I did download the binaries matching my Hadoop version (2.7), that's why I was wondering if the issue had something to do with the exact hadoop version flink is compiled again, or if there might be things that are missing in my environment. -- Sent from: http:

Flink session on Yarn - ClassNotFoundException

Hi, I’m trying to start a flink (1.3.2) session as explained in the docs (https://ci.apache.org/projects/flink/flink-docs-release-1.3/setup/yarn_setup.html#start-a-session ), but I keep getting t

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