[GitHub] flink pull request #3568: [FLINK-6119]: ClusterClient Detach Mode configurab...

2017-03-19 Thread RalphSu
GitHub user RalphSu opened a pull request: https://github.com/apache/flink/pull/3568 [FLINK-6119]: ClusterClient Detach Mode configurable in client-api Author: ralp...@apache.org This closes #FLINK-6119 Thanks for contributing to Apache Flink. Before you open your

[GitHub] flink pull request #3615: support flink-storm metrics

2017-03-25 Thread RalphSu
GitHub user RalphSu opened a pull request: https://github.com/apache/flink/pull/3615 support flink-storm metrics Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If your changes take all of the

[GitHub] flink issue #3615: support flink-storm metrics

2017-03-26 Thread RalphSu
Github user RalphSu commented on the issue: https://github.com/apache/flink/pull/3615 Referring to https://github.com/apache/flink/pull/1157. Not sure how to have two PR for one jira? Any suggestion --- If your project is set up for it, you can reply to this email and have your

[GitHub] flink issue #1157: [FLINK-2720][storm-compatibility]Add Storm-CountMetric fo...

2017-03-26 Thread RalphSu
Github user RalphSu commented on the issue: https://github.com/apache/flink/pull/1157 I added https://github.com/apache/flink/pull/3615, welcome for comments. --- 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 #1157: [FLINK-2720][storm-compatibility]Add Storm-CountMe...

2017-03-05 Thread RalphSu
Github user RalphSu commented on a diff in the pull request: https://github.com/apache/flink/pull/1157#discussion_r104311065 --- Diff: flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/main/java/org/apache/flink/stormcompatibility/api/FlinkTopologyContext.java

[GitHub] flink pull request #1157: [FLINK-2720][storm-compatibility]Add Storm-CountMe...

2017-03-05 Thread RalphSu
Github user RalphSu commented on a diff in the pull request: https://github.com/apache/flink/pull/1157#discussion_r104311095 --- Diff: flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/main/java/org/apache/flink/stormcompatibility/api/FlinkTopologyContext.java

[GitHub] flink issue #1157: [FLINK-2720][storm-compatibility]Add Storm-CountMetric fo...

2017-03-05 Thread RalphSu
Github user RalphSu commented on the issue: https://github.com/apache/flink/pull/1157 Any progress on this one? Looks this has been stop for a while. --- 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

[GitHub] flink issue #1157: [FLINK-2720][storm-compatibility]Add Storm-CountMetric fo...

2017-03-05 Thread RalphSu
Github user RalphSu commented on the issue: https://github.com/apache/flink/pull/1157 Here it looks user need to change code to make metrics work --- 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

[GitHub] flink issue #1157: [FLINK-2720][storm-compatibility]Add Storm-CountMetric fo...

2017-03-05 Thread RalphSu
Github user RalphSu commented on the issue: https://github.com/apache/flink/pull/1157 Here it looks user need to change code to make metrics work --- 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

[GitHub] flink issue #1157: [FLINK-2720][storm-compatibility]Add Storm-CountMetric fo...

2017-03-05 Thread RalphSu
Github user RalphSu commented on the issue: https://github.com/apache/flink/pull/1157 ? --- 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 #1157: [FLINK-2720][storm-compatibility]Add Storm-CountMetric fo...

2017-03-05 Thread RalphSu
Github user RalphSu commented on the issue: https://github.com/apache/flink/pull/1157 okey, would try file a PR on this soon --- 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 issue #6103: [FLINK-9413] [distributed coordination] Tasks can fail wi...

2018-07-11 Thread RalphSu
Github user RalphSu commented on the issue: https://github.com/apache/flink/pull/6103 okey... I encounter issue when submit jobs, stack as below, looks the same with this one. Is this a regression, or are we thinking the fix will break existing code

[GitHub] flink issue #6103: [FLINK-9413] [distributed coordination] Tasks can fail wi...

2018-07-11 Thread RalphSu
Github user RalphSu commented on the issue: https://github.com/apache/flink/pull/6103 @zhangminglei does the description of this issue indicate a workaround for this? I'm using 1.4.2. With dozens of jobs been submitted to my cluster, i'm constantly see this Partiti

[GitHub] flink issue #6103: [FLINK-9413] [distributed coordination] Tasks can fail wi...

2018-07-12 Thread RalphSu
Github user RalphSu commented on the issue: https://github.com/apache/flink/pull/6103 @tillrohrmann already did that, it looks alleviate though not fix. I'm upgrade from 1.2.0 to 1.4.2. Major thing i can see is TM now connection to HDFS instead of only talk to JobManager,

[GitHub] flink issue #3615: [FLINK-2720] support flink-storm metrics

2018-03-01 Thread RalphSu
Github user RalphSu commented on the issue: https://github.com/apache/flink/pull/3615 update with latest master. Along fix the comments above. ---