[GitHub] flink issue #2678: [FLINK-4879] [Kafka-Connector] class KafkaTableSource sho...

2016-10-25 Thread hzyuemeng1
Github user hzyuemeng1 commented on the issue: https://github.com/apache/flink/pull/2678 thanks for ur review,i am very interesting about Table SQL,and want to make it better 2016-10-24 hzyuemeng1 发件人:Jark <notificati...@github.com>

[GitHub] flink issue #2678: [FLINK-4879] [Kafka-Connector] class KafkaTableSource sho...

2016-10-23 Thread hzyuemeng1
Github user hzyuemeng1 commented on the issue: https://github.com/apache/flink/pull/2678 @fhueske @rmetzger ,thanks all for review this pr,I am very interesting in Table SQL,can anyone merge this pr? --- If your project is set up for it, you can reply to this email and have your

[GitHub] flink issue #2678: [FLINK-4879] [Kafka-Connector] class KafkaTableSource sho...

2016-10-23 Thread hzyuemeng1
Github user hzyuemeng1 commented on the issue: https://github.com/apache/flink/pull/2678 @wuchong can u help me to inform someone to merge this pr,thanks --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project

[GitHub] flink pull request #2678: [FLINK-4879] [Kafka-Connector] class KafkaTableSou...

2016-10-21 Thread hzyuemeng1
GitHub user hzyuemeng1 opened a pull request: https://github.com/apache/flink/pull/2678 [FLINK-4879] [Kafka-Connector] class KafkaTableSource should be public just like KafkaTableSink Thanks for contributing to Apache Flink. Before you open your pull request, please take

[GitHub] flink pull request #2631: The scala example of SQL on Streaming Tables with ...

2016-10-13 Thread hzyuemeng1
GitHub user hzyuemeng1 opened a pull request: https://github.com/apache/flink/pull/2631 The scala example of SQL on Streaming Tables with wrong variable name in flink document val env = StreamExecutionEnvironment.getExecutionEnvironment val tEnv

[GitHub] flink pull request #2632: [FLINK-4827][Docs] The scala example of SQL on Str...

2016-10-13 Thread hzyuemeng1
GitHub user hzyuemeng1 opened a pull request: https://github.com/apache/flink/pull/2632 [FLINK-4827][Docs] The scala example of SQL on Streaming Tables with wrong variable name… val env = StreamExecutionEnvironment.getExecutionEnvironment val tEnv

[GitHub] flink pull request #2994: [FLINK-5324] [yarn] JVM Opitons will work for both...

2016-12-15 Thread hzyuemeng1
GitHub user hzyuemeng1 reopened a pull request: https://github.com/apache/flink/pull/2994 [FLINK-5324] [yarn] JVM Opitons will work for both YarnApplicationMas… Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list

[GitHub] flink issue #2994: [FLINK-5324] [yarn] JVM Opitons will work for both YarnAp...

2016-12-13 Thread hzyuemeng1
Github user hzyuemeng1 commented on the issue: https://github.com/apache/flink/pull/2994 @ChengXiangLi ,can u review this PR? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature

[GitHub] flink pull request #2994: [FLINK-5324] [yarn] JVM Opitons will work for both...

2016-12-13 Thread hzyuemeng1
GitHub user hzyuemeng1 opened a pull request: https://github.com/apache/flink/pull/2994 [FLINK-5324] [yarn] JVM Opitons will work for both YarnApplicationMas… Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list

[GitHub] flink pull request #2994: [FLINK-5324] [yarn] JVM Opitons will work for both...

2016-12-14 Thread hzyuemeng1
Github user hzyuemeng1 closed the pull request at: https://github.com/apache/flink/pull/2994 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature

[GitHub] flink issue #2994: [FLINK-5324] [yarn] JVM Opitons will work for both YarnAp...

2016-12-14 Thread hzyuemeng1
Github user hzyuemeng1 commented on the issue: https://github.com/apache/flink/pull/2994 @wuchong ,can u check this issue? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature

[GitHub] flink pull request #5917: [FLINK-9201] Fixed the same merge window will be f...

2018-05-14 Thread hzyuemeng1
Github user hzyuemeng1 commented on a diff in the pull request: https://github.com/apache/flink/pull/5917#discussion_r187887606 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/ProcessingTimeTrigger.java --- @@ -60,7 +60,12 @@ public

[GitHub] flink pull request #5917: [FLINK-9201] Fixed the same merge window will be f...

2018-04-26 Thread hzyuemeng1
GitHub user hzyuemeng1 opened a pull request: https://github.com/apache/flink/pull/5917 [FLINK-9201] Fixed the same merge window will be fired twice if water… …mark already passed the merge window *Thank you very much for contributing to Apache Flink - we are happy

[GitHub] flink issue #5441: [FLINK-8607] [table] Add a basic embedded SQL CLI client

2018-03-08 Thread hzyuemeng1
Github user hzyuemeng1 commented on the issue: https://github.com/apache/flink/pull/5441 @twalthr ,do we implement this base on table api such as sql -> table api -> runtime, or new plan:sql -> calcite->whole stage codegen -runtime. ---