[
https://issues.apache.org/jira/browse/FLINK-3034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15343708#comment-15343708
]
ASF GitHub Bot commented on FLINK-3034:
---
Github user subhankarb commented on a diff in the pull
Github user subhankarb commented on a diff in the pull request:
https://github.com/apache/flink/pull/1813#discussion_r67994813
--- Diff:
Github user joseprupi commented on a diff in the pull request:
https://github.com/apache/flink/pull/2053#discussion_r67957847
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/AffinityPropagation.java
---
@@ -0,0 +1,535 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15342801#comment-15342801
]
ASF GitHub Bot commented on FLINK-1707:
---
Github user joseprupi commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15342797#comment-15342797
]
ASF GitHub Bot commented on FLINK-1707:
---
Github user joseprupi commented on a diff in the pull
Github user joseprupi commented on a diff in the pull request:
https://github.com/apache/flink/pull/2053#discussion_r67957755
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/AffinityPropagation.java
---
@@ -0,0 +1,535 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-2313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15342789#comment-15342789
]
Robert Metzger commented on FLINK-2313:
---
Another important feature here would be to make the job id,
[
https://issues.apache.org/jira/browse/FLINK-3675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-3675:
--
Priority: Critical (was: Major)
> YARN ship folder incosistent behavior
>
[
https://issues.apache.org/jira/browse/FLINK-3675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-3675:
--
Fix Version/s: 1.1.0
> YARN ship folder incosistent behavior
>
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15342704#comment-15342704
]
ASF GitHub Bot commented on FLINK-1707:
---
Github user joseprupi commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15342684#comment-15342684
]
ASF GitHub Bot commented on FLINK-1707:
---
Github user joseprupi commented on a diff in the pull
Github user joseprupi commented on a diff in the pull request:
https://github.com/apache/flink/pull/2053#discussion_r67952276
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/AffinityPropagation.java
---
@@ -0,0 +1,535 @@
+/*
+ * Licensed
Github user joseprupi commented on a diff in the pull request:
https://github.com/apache/flink/pull/2053#discussion_r67951222
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/AffinityPropagation.java
---
@@ -0,0 +1,535 @@
+/*
+ * Licensed
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2115
Looks good overall. I found 1 big issue, the rest are minor things.
---
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
[
https://issues.apache.org/jira/browse/FLINK-4017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15342677#comment-15342677
]
ASF GitHub Bot commented on FLINK-4017:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15342669#comment-15342669
]
ASF GitHub Bot commented on FLINK-4017:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2115#discussion_r67950293
--- Diff:
flink-libraries/flink-python/src/main/python/org/apache/flink/python/api/flink/plan/DataSet.py
---
@@ -192,6 +193,30 @@ def reduce(self, operator):
[
https://issues.apache.org/jira/browse/FLINK-4017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15342550#comment-15342550
]
ASF GitHub Bot commented on FLINK-4017:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-4017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15342552#comment-15342552
]
ASF GitHub Bot commented on FLINK-4017:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2115#discussion_r67941010
--- Diff:
flink-libraries/flink-python/src/main/python/org/apache/flink/python/api/flink/plan/DataSet.py
---
@@ -192,6 +193,30 @@ def reduce(self, operator):
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2115#discussion_r67940988
--- Diff:
flink-libraries/flink-python/src/main/python/org/apache/flink/python/api/flink/plan/DataSet.py
---
@@ -192,6 +193,30 @@ def reduce(self, operator):
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2115#discussion_r67940565
--- Diff:
flink-libraries/flink-python/src/main/python/org/apache/flink/python/api/flink/plan/DataSet.py
---
@@ -192,6 +193,30 @@ def reduce(self, operator):
[
https://issues.apache.org/jira/browse/FLINK-4017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15342547#comment-15342547
]
ASF GitHub Bot commented on FLINK-4017:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-4017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15342543#comment-15342543
]
ASF GitHub Bot commented on FLINK-4017:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2115#discussion_r67940433
--- Diff:
flink-libraries/flink-python/src/main/python/org/apache/flink/python/api/flink/plan/DataSet.py
---
@@ -192,6 +193,30 @@ def reduce(self, operator):
[
https://issues.apache.org/jira/browse/FLINK-3872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15342209#comment-15342209
]
ASF GitHub Bot commented on FLINK-3872:
---
Github user uce commented on the issue:
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2069
Thanks for the suggestion Fabian. I've added the table to the docs and
added an example about the Kafka JSON source. Furthermore, I've added the
configuration flag for the missing field failure
[
https://issues.apache.org/jira/browse/FLINK-4082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved FLINK-4082.
-
Resolution: Fixed
Fix Version/s: 1.1.0
Fixed in
[
https://issues.apache.org/jira/browse/FLINK-4082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15342206#comment-15342206
]
ASF GitHub Bot commented on FLINK-4082:
---
Github user aljoscha closed the pull request at:
Github user aljoscha closed the pull request at:
https://github.com/apache/flink/pull/2113
---
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 is
[
https://issues.apache.org/jira/browse/FLINK-3951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15342172#comment-15342172
]
ASF GitHub Bot commented on FLINK-3951:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2112#discussion_r67908195
--- Diff:
flink-core/src/main/java/org/apache/flink/metrics/HistogramStatistics.java ---
@@ -0,0 +1,135 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-3951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15342171#comment-15342171
]
ASF GitHub Bot commented on FLINK-3951:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2112#discussion_r67908088
--- Diff:
flink-core/src/main/java/org/apache/flink/metrics/HistogramStatistics.java ---
@@ -0,0 +1,135 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-3034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15342139#comment-15342139
]
ASF GitHub Bot commented on FLINK-3034:
---
Github user subhankarb commented on a diff in the pull
Github user subhankarb commented on a diff in the pull request:
https://github.com/apache/flink/pull/1813#discussion_r67905768
--- Diff:
[
https://issues.apache.org/jira/browse/FLINK-3034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15342111#comment-15342111
]
ASF GitHub Bot commented on FLINK-3034:
---
Github user subhankarb commented on a diff in the pull
Github user subhankarb commented on a diff in the pull request:
https://github.com/apache/flink/pull/1813#discussion_r67904127
--- Diff:
flink-streaming-connectors/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/JedisClusterConfig.java
[
https://issues.apache.org/jira/browse/FLINK-4034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15342103#comment-15342103
]
Robert Metzger commented on FLINK-4034:
---
I don't think always updating to the biggest version is a
[
https://issues.apache.org/jira/browse/FLINK-4097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrea Sella reassigned FLINK-4097:
---
Assignee: Andrea Sella
> Cassandra Sink throws NPE on closing if server is not available
>
[
https://issues.apache.org/jira/browse/FLINK-4097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15342073#comment-15342073
]
Andrea Sella commented on FLINK-4097:
-
In the close() of Sink's lifecycle session should be
[
https://issues.apache.org/jira/browse/FLINK-3647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15342069#comment-15342069
]
ASF GitHub Bot commented on FLINK-3647:
---
Github user aljoscha commented on the issue:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2124
This looks very good! I just have a few minor comments:
* It's very good that you fixed typos and added comments/Javadoc to
previously undocumented code. I would like to see them as a
[
https://issues.apache.org/jira/browse/FLINK-3859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15342053#comment-15342053
]
ASF GitHub Bot commented on FLINK-3859:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/2088
@fhueske I have changed the `ExpressionTestBase`. Now one unit tests only
needs one compilation step. The runtime is still not perfect but could be
reduced by about 75 % (at least on my PC).
---
[
https://issues.apache.org/jira/browse/FLINK-4097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15342052#comment-15342052
]
Robert Metzger commented on FLINK-4097:
---
Why are you not a fan of it?
> Cassandra Sink throws NPE
[
https://issues.apache.org/jira/browse/FLINK-4097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15342042#comment-15342042
]
Andrea Sella commented on FLINK-4097:
-
I am not a huge fan of null-checking in these cases, but it
[
https://issues.apache.org/jira/browse/FLINK-4039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15342033#comment-15342033
]
Gyula Fora commented on FLINK-4039:
---
I think the only reasonable solution I see would be to try to
[
https://issues.apache.org/jira/browse/FLINK-4040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15342024#comment-15342024
]
ASF GitHub Bot commented on FLINK-4040:
---
Github user gyfora commented on the issue:
Github user gyfora commented on the issue:
https://github.com/apache/flink/pull/2143
Looks good, this addresses the 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
[
https://issues.apache.org/jira/browse/FLINK-3222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3222:
--
Description:
Here is related code:
{code}
result = 31 * result + (int) (subTaskStats.length ^
[
https://issues.apache.org/jira/browse/FLINK-4097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15342007#comment-15342007
]
Robert Metzger commented on FLINK-4097:
---
Oh yes. You are right. Maybe it would make sense to add a
[
https://issues.apache.org/jira/browse/FLINK-4039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15342004#comment-15342004
]
Ufuk Celebi commented on FLINK-4039:
Just noticed while working on FLINK-4040, that specifying
[
https://issues.apache.org/jira/browse/FLINK-4040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15341999#comment-15341999
]
ASF GitHub Bot commented on FLINK-4040:
---
GitHub user uce opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15342001#comment-15342001
]
Andrea Sella commented on FLINK-4097:
-
I think it is correct to log the NullPointerException. The line
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/2143
[FLINK-4040] [dist] Allow JobManager/TaskManager-specific JVM args
- Adds two new config keys for the start up scripts:
* `env.java.opts.jobmanager`
* `env.java.opts.taskmanager`
-
[
https://issues.apache.org/jira/browse/FLINK-4082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15341982#comment-15341982
]
ASF GitHub Bot commented on FLINK-4082:
---
Github user uce commented on the issue:
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2113
Thanks! Looks good to merge. +1
---
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
Geoffrey Mon created FLINK-4098:
---
Summary: Iteration support in Python API
Key: FLINK-4098
URL: https://issues.apache.org/jira/browse/FLINK-4098
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-4082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15341952#comment-15341952
]
ASF GitHub Bot commented on FLINK-4082:
---
Github user aljoscha commented on the issue:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2113
@uce I addressed the 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 project does not have this feature
enabled and
[
https://issues.apache.org/jira/browse/FLINK-4040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi reassigned FLINK-4040:
--
Assignee: Ufuk Celebi
> Same env.java.opts is applied for TM , JM and ZK
>
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15341900#comment-15341900
]
ASF GitHub Bot commented on FLINK-1707:
---
Github user vasia commented on the issue:
Github user vasia commented on the issue:
https://github.com/apache/flink/pull/2053
Hi @joseprupi,
thanks a lot for this PR.
I have looked through the code and I'm quite worried about its performance
and scalability. Have you tried it out with any big inputs? We will
[
https://issues.apache.org/jira/browse/FLINK-3951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15341828#comment-15341828
]
ASF GitHub Bot commented on FLINK-3951:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2112#discussion_r67874799
--- Diff:
flink-metrics/flink-metrics-dropwizard/src/test/java/org/apache/flink/dropwizard/metrics/DropwizardHistogramWrapperTest.java
---
@@ -0,0
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15341823#comment-15341823
]
ASF GitHub Bot commented on FLINK-1707:
---
Github user vasia commented on a diff in the pull request:
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2053#discussion_r67873916
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/AffinityPropagation.java
---
@@ -0,0 +1,535 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15341820#comment-15341820
]
ASF GitHub Bot commented on FLINK-1707:
---
Github user vasia commented on a diff in the pull request:
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2053#discussion_r67873432
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/AffinityPropagation.java
---
@@ -0,0 +1,535 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15341817#comment-15341817
]
ASF GitHub Bot commented on FLINK-1707:
---
Github user vasia commented on a diff in the pull request:
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2053#discussion_r67873061
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/AffinityPropagation.java
---
@@ -0,0 +1,535 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-4082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15341808#comment-15341808
]
ASF GitHub Bot commented on FLINK-4082:
---
Github user aljoscha commented on the issue:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2113
Nope, I forgot that. Thanks for spotting!
---
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
[
https://issues.apache.org/jira/browse/FLINK-3951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15341794#comment-15341794
]
ASF GitHub Bot commented on FLINK-3951:
---
Github user tillrohrmann commented on a diff in the pull
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2053#discussion_r67871432
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/AffinityPropagation.java
---
@@ -0,0 +1,535 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15341795#comment-15341795
]
ASF GitHub Bot commented on FLINK-1707:
---
Github user vasia commented on a diff in the pull request:
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2112#discussion_r67871338
--- Diff:
flink-metrics/flink-metrics-dropwizard/src/test/java/org/apache/flink/dropwizard/metrics/DropwizardHistogramWrapperTest.java
---
@@ -0,0
[
https://issues.apache.org/jira/browse/FLINK-3951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15341788#comment-15341788
]
ASF GitHub Bot commented on FLINK-3951:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15341790#comment-15341790
]
ASF GitHub Bot commented on FLINK-3951:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2112#discussion_r67870807
--- Diff:
flink-metrics/flink-metrics-dropwizard/src/main/java/org/apache/flink/dropwizard/metrics/HistogramWrapper.java
---
@@ -0,0 +1,52 @@
+/*
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2112#discussion_r67870675
--- Diff:
flink-core/src/test/java/org/apache/flink/metrics/reporter/JMXReporterTest.java
---
@@ -51,4 +69,106 @@ public void testGenerateName() {
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15341772#comment-15341772
]
ASF GitHub Bot commented on FLINK-1707:
---
Github user vasia commented on a diff in the pull request:
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2053#discussion_r67869049
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/AffinityPropagation.java
---
@@ -0,0 +1,535 @@
+/*
+ * Licensed to
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2053#discussion_r67868962
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/AffinityPropagation.java
---
@@ -0,0 +1,535 @@
+/*
+ * Licensed to
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2053#discussion_r67868917
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/AffinityPropagation.java
---
@@ -0,0 +1,535 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15341768#comment-15341768
]
ASF GitHub Bot commented on FLINK-1707:
---
Github user vasia commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15341769#comment-15341769
]
ASF GitHub Bot commented on FLINK-1707:
---
Github user vasia commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15341770#comment-15341770
]
ASF GitHub Bot commented on FLINK-1707:
---
Github user vasia commented on a diff in the pull request:
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2053#discussion_r67868911
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/AffinityPropagation.java
---
@@ -0,0 +1,535 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-3951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15341761#comment-15341761
]
ASF GitHub Bot commented on FLINK-3951:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2112#discussion_r67868105
--- Diff:
flink-core/src/main/java/org/apache/flink/metrics/reporter/JMXReporter.java ---
@@ -99,8 +100,11 @@ public void notifyOfAddedMetric(Metric
[
https://issues.apache.org/jira/browse/FLINK-3951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15341758#comment-15341758
]
ASF GitHub Bot commented on FLINK-3951:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2112#discussion_r67867614
--- Diff:
flink-core/src/main/java/org/apache/flink/metrics/reporter/AbstractReporter.java
---
@@ -32,9 +35,11 @@
*/
@PublicEvolving
[
https://issues.apache.org/jira/browse/FLINK-3951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15341756#comment-15341756
]
ASF GitHub Bot commented on FLINK-3951:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2112#discussion_r67867222
--- Diff:
flink-core/src/main/java/org/apache/flink/metrics/groups/UnregisteredMetricsGroup.java
---
@@ -60,7 +61,17 @@ public Counter counter(String
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2112#discussion_r67866757
--- Diff:
flink-core/src/main/java/org/apache/flink/metrics/HistogramStatistics.java ---
@@ -0,0 +1,135 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-3951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15341749#comment-15341749
]
ASF GitHub Bot commented on FLINK-3951:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15341748#comment-15341748
]
ASF GitHub Bot commented on FLINK-1707:
---
Github user vasia commented on the issue:
Github user vasia commented on the issue:
https://github.com/apache/flink/pull/2053
I'll shepherd 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
enabled and wishes so,
1 - 100 of 149 matches
Mail list logo
