[GitHub] flink pull request #3270: [FLINK-4286] Have Kafka examples that use the Kafk...

2017-02-06 Thread mylog00
GitHub user mylog00 opened a pull request: https://github.com/apache/flink/pull/3270 [FLINK-4286] Have Kafka examples that use the Kafka 0.9 connector There were added examples of using connector for Kafka v0.9. Examples using 0.8 connector renamed to "ReadFromKa

[GitHub] flink issue #3270: [FLINK-4286] Have Kafka examples that use the Kafka 0.9 c...

2017-02-06 Thread mylog00
Github user mylog00 commented on the issue: https://github.com/apache/flink/pull/3270 I think it is independent examples and make it so similar not necessary. But if it important I can fix it and decrease difference. Thank you for review. --- If your project is set up for it, you

[GitHub] flink issue #3270: [FLINK-4286] Have Kafka examples that use the Kafka 0.9 c...

2017-02-06 Thread mylog00
Github user mylog00 commented on the issue: https://github.com/apache/flink/pull/3270 I did examples more similar. Now difference only Kafka connector version and number of properties to configure consumer. --- If your project is set up for it, you can reply to this email and have

[GitHub] flink issue #3325: [FLINK-5786] [jobmanager] Add support GetClusterStatus me...

2017-02-15 Thread mylog00
Github user mylog00 commented on the issue: https://github.com/apache/flink/pull/3325 TravisCI passed build. https://travis-ci.org/mylog00/flink/builds/201929462 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well

[GitHub] flink issue #3270: [FLINK-4286] Have Kafka examples that use the Kafka 0.9 c...

2017-02-13 Thread mylog00
Github user mylog00 commented on the issue: https://github.com/apache/flink/pull/3270 https://travis-ci.org/mylog00/flink/builds/198855164 Link to my TravisCI build of branch [FLINK-4286]. With all passed tests. --- If your project is set up for it, you can reply to this email

[GitHub] flink pull request #3325: [FLINK-5786] [jobmanager] Add support GetClusterSt...

2017-02-15 Thread mylog00
GitHub user mylog00 opened a pull request: https://github.com/apache/flink/pull/3325 [FLINK-5786] [jobmanager] Add support GetClusterStatus message for st… Moved handler for {{GetClusterStatus}} message from {{ContaineredJobManager}} to {{JobManager}} You can merge this pull

[GitHub] flink pull request #3325: [FLINK-5786] [jobmanager] Add support GetClusterSt...

2017-04-21 Thread mylog00
Github user mylog00 closed the pull request at: https://github.com/apache/flink/pull/3325 --- 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 pull request #3498: [FLINK-5476] Fail fast if trying to submit a job t...

2017-04-21 Thread mylog00
Github user mylog00 closed the pull request at: https://github.com/apache/flink/pull/3498 --- 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 #3270: [FLINK-4286] Have Kafka examples that use the Kafka 0.9 c...

2017-03-04 Thread mylog00
Github user mylog00 commented on the issue: https://github.com/apache/flink/pull/3270 Hi @rmetzger, i delete example for Kafka v0.8 and left only for Kafka v0.9. --- 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

[GitHub] flink pull request #3498: [FLINK-5476] Fail fast if trying to submit a job t...

2017-03-09 Thread mylog00
GitHub user mylog00 opened a pull request: https://github.com/apache/flink/pull/3498 [FLINK-5476] Fail fast if trying to submit a job to a non-existing Flink cluster **ATTENTION** required task [FLINK-5786] (PR https://github.com/apache/flink/pull/3325) Now at first submit we

[GitHub] flink issue #4349: [FLINK-7127] [runtime] Remove unnecessary null check or a...

2017-08-03 Thread mylog00
Github user mylog00 commented on the issue: https://github.com/apache/flink/pull/4349 Thanks for the advice. I will not repeat this mistake again in the future :) --- 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

[GitHub] flink pull request #4294: [FLINK-7127] [runtime] Remove unnecessary null che...

2017-07-10 Thread mylog00
GitHub user mylog00 opened a pull request: https://github.com/apache/flink/pull/4294 [FLINK-7127] [runtime] Remove unnecessary null check or add null check; Hi. To avoid NPE I decided add null check instead remove it one. You can merge this pull request into a Git repository

[GitHub] flink pull request #4294: [FLINK-7127] [runtime] Remove unnecessary null che...

2017-07-15 Thread mylog00
Github user mylog00 closed the pull request at: https://github.com/apache/flink/pull/4294 --- 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 pull request #4349: [FLINK-7127] [runtime] Remove unnecessary null che...

2017-07-15 Thread mylog00
GitHub user mylog00 opened a pull request: https://github.com/apache/flink/pull/4349 [FLINK-7127] [runtime] Remove unnecessary null check or add null check; To avoid NPE I decided add null check instead remove it one. You can merge this pull request into a Git repository

[GitHub] flink issue #4349: [FLINK-7127] [runtime] Remove unnecessary null check or a...

2017-07-16 Thread mylog00
Github user mylog00 commented on the issue: https://github.com/apache/flink/pull/4349 Link to passed tests build: https://travis-ci.org/mylog00/flink/builds/253949055 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well

[GitHub] flink pull request #4250: [FLINK-4286] Have Kafka examples that use the Kafk...

2017-07-04 Thread mylog00
GitHub user mylog00 opened a pull request: https://github.com/apache/flink/pull/4250 [FLINK-4286] Have Kafka examples that use the Kafka 0.9 connector Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration

[GitHub] flink issue #4250: [FLINK-4286] Have Kafka examples that use the Kafka 0.9 c...

2017-07-04 Thread mylog00
Github user mylog00 commented on the issue: https://github.com/apache/flink/pull/4250 wouldn't to fix --- 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

[GitHub] flink pull request #4250: [FLINK-4286] Have Kafka examples that use the Kafk...

2017-07-04 Thread mylog00
Github user mylog00 closed the pull request at: https://github.com/apache/flink/pull/4250 --- 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 #3270: [FLINK-4286] Have Kafka examples that use the Kafka 0.9 c...

2017-07-03 Thread mylog00
Github user mylog00 commented on the issue: https://github.com/apache/flink/pull/3270 Many merge conflicts. --- 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

[GitHub] flink pull request #3270: [FLINK-4286] Have Kafka examples that use the Kafk...

2017-07-03 Thread mylog00
Github user mylog00 commented on a diff in the pull request: https://github.com/apache/flink/pull/3270#discussion_r125331370 --- Diff: flink-examples/flink-examples-streaming/pom.xml --- @@ -360,6 +360,26 @@ under the License

[GitHub] flink pull request #3270: [FLINK-4286] Have Kafka examples that use the Kafk...

2017-07-03 Thread mylog00
Github user mylog00 closed the pull request at: https://github.com/apache/flink/pull/3270 --- 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 pull request #5837: [FLINK-8426][docs] Error in Generating Timestamp/W...

2018-04-11 Thread mylog00
GitHub user mylog00 opened a pull request: https://github.com/apache/flink/pull/5837 [FLINK-8426][docs] Error in Generating Timestamp/Watermakr doc [FLINK-8426][docs] fix java examples for "Generating Timestamp/Watermakr" documentation. You can merge this pu

[GitHub] flink pull request #5837: [FLINK-8426][docs] Error in Generating Timestamp/W...

2018-04-12 Thread mylog00
Github user mylog00 closed the pull request at: https://github.com/apache/flink/pull/5837 ---

[GitHub] flink issue #5837: [FLINK-8426][docs] Error in Generating Timestamp/Watermak...

2018-04-12 Thread mylog00
Github user mylog00 commented on the issue: https://github.com/apache/flink/pull/5837 Already merged ---