[
https://issues.apache.org/jira/browse/FLINK-1774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377584#comment-14377584
]
ASF GitHub Bot commented on FLINK-1774:
---
Github user StephanEwen commented on the
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/505#discussion_r27017030
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/SimpleCommunityDetectionExample.java
---
@@ -0,0 +1,159 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/426#discussion_r27018880
--- Diff:
flink-scala/src/main/scala/org/apache/flink/api/scala/ExecutionEnvironment.scala
---
@@ -223,8 +224,11 @@ class ExecutionEnvironment(javaEnv:
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377708#comment-14377708
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user fhueske commented on a diff in
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/527#issuecomment-85500135
I'll merge it.
---
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
[
https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377902#comment-14377902
]
Fabian Hueske commented on FLINK-1319:
--
(Copying my response from the mailing list)
[
https://issues.apache.org/jira/browse/FLINK-1776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377789#comment-14377789
]
Stephan Ewen commented on FLINK-1776:
-
That is critical, I agree.
Can we make the
[
https://issues.apache.org/jira/browse/FLINK-1769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377847#comment-14377847
]
Robert Metzger commented on FLINK-1769:
---
I manually deployed to the snapshot
[
https://issues.apache.org/jira/browse/FLINK-1761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1761.
-
Resolution: Fixed
Fix Version/s: 0.9
Fixed in 380ef878c850f83b5e12176e465d59c737066e20 and
[
https://issues.apache.org/jira/browse/FLINK-1776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377907#comment-14377907
]
Fabian Hueske commented on FLINK-1776:
--
The fix is straight-forward.
We get the
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/525#issuecomment-85499509
Yes, I agree. The fix is more conservative than necessary.
I think we can safely relax it if we make the rule for forwarded fields on
group-wise operators as follows:
[
https://issues.apache.org/jira/browse/FLINK-1656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377846#comment-14377846
]
ASF GitHub Bot commented on FLINK-1656:
---
Github user fhueske commented on the pull
Github user matadorhong closed the pull request at:
https://github.com/apache/flink/pull/510
---
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-1769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377791#comment-14377791
]
Stephan Ewen commented on FLINK-1769:
-
Anyone looking into this already?
This
[
https://issues.apache.org/jira/browse/FLINK-1528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377816#comment-14377816
]
ASF GitHub Bot commented on FLINK-1528:
---
Github user vasia commented on the pull
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/420#issuecomment-85487676
Hi @balidani! I think it's still a bit confusing how this example works.
As far as I understand, you expect a directed graph as input, but then you
convert it to an
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/527
---
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
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/527#issuecomment-85417711
+1, please merge :-)
---
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
[
https://issues.apache.org/jira/browse/FLINK-1656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377574#comment-14377574
]
ASF GitHub Bot commented on FLINK-1656:
---
Github user StephanEwen commented on the
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/505#discussion_r27016590
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/SimpleCommunityDetectionExample.java
---
@@ -0,0 +1,159 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-1726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377629#comment-14377629
]
ASF GitHub Bot commented on FLINK-1726:
---
Github user vasia commented on a diff in
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/505#discussion_r27017296
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/SimpleCommunityDetection.java
---
@@ -0,0 +1,151 @@
+/*
+ * Licensed
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/426#discussion_r27018277
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/io/CsvInputFormat.java ---
@@ -52,103 +50,86 @@
public static final String
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/426#discussion_r27018316
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/io/CsvInputFormat.java ---
@@ -52,103 +50,86 @@
public static final String
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377716#comment-14377716
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user fhueske commented on the pull
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/426#issuecomment-85455383
Very good! Let me know, when you want me to have a look again :-)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
[
https://issues.apache.org/jira/browse/FLINK-1714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sibao Hong reassigned FLINK-1714:
-
Assignee: Sibao Hong
Fix the bug of logger class loader
--
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/522#issuecomment-85425753
Looks good, the finally block actually takes care of the cleanup.
+1 to merge
---
If your project is set up for it, you can reply to this email and have your
[
https://issues.apache.org/jira/browse/FLINK-1595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377601#comment-14377601
]
ASF GitHub Bot commented on FLINK-1595:
---
Github user szape commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377671#comment-14377671
]
ASF GitHub Bot commented on FLINK-1726:
---
Github user vasia commented on a diff in
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/505#discussion_r27017460
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/SimpleCommunityDetection.java
---
@@ -0,0 +1,151 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377681#comment-14377681
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/426#discussion_r27018151
--- Diff:
flink-scala/src/main/java/org/apache/flink/api/scala/operators/ScalaCsvInputFormat.java
---
@@ -98,98 +123,66 @@ public void setFields(int[]
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377703#comment-14377703
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user fhueske commented on a diff in
Github user szape commented on a diff in the pull request:
https://github.com/apache/flink/pull/520#discussion_r27015100
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/complex/ComplexIntegrationTest.java
---
@@ -0,0
[
https://issues.apache.org/jira/browse/FLINK-1726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377667#comment-14377667
]
ASF GitHub Bot commented on FLINK-1726:
---
Github user vasia commented on a diff in
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/515#issuecomment-85426105
+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
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/518#issuecomment-85426018
Good find, but just calling it in the beginning of every main() method
seems hacky.
I think the code should go to the AkkaUtils.createActorSystem() method.
[
https://issues.apache.org/jira/browse/FLINK-1770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377588#comment-14377588
]
ASF GitHub Bot commented on FLINK-1770:
---
Github user StephanEwen commented on the
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/426#issuecomment-85447697
I see the issue with the non-deterministic field order and FLINK-1665 as
follows. Both, FLINK-1665 and Option 3, solve the problem of non-deterministic
field order.
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377706#comment-14377706
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/426#discussion_r27018812
--- Diff:
flink-scala/src/main/java/org/apache/flink/api/scala/operators/ScalaCsvInputFormat.java
---
@@ -19,66 +19,91 @@
package
[
https://issues.apache.org/jira/browse/FLINK-1726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377663#comment-14377663
]
ASF GitHub Bot commented on FLINK-1726:
---
Github user vasia commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377664#comment-14377664
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user fhueske commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377691#comment-14377691
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377690#comment-14377690
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user fhueske commented on a diff in
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/525#issuecomment-85422608
I think this is good to fix this.
I was wondering now whether we can actually solve this a bit more
global/local property specific. Cancelling out the
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/426#discussion_r27018473
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/io/CsvInputFormat.java ---
@@ -52,103 +50,86 @@
public static final String
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377698#comment-14377698
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377712#comment-14377712
]
ASF GitHub Bot commented on FLINK-1768:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377761#comment-14377761
]
Maximilian Michels commented on FLINK-1319:
---
This looks like a very promising
[
https://issues.apache.org/jira/browse/FLINK-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377587#comment-14377587
]
ASF GitHub Bot commented on FLINK-1650:
---
Github user StephanEwen commented on the
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377700#comment-14377700
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/426#discussion_r27018597
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/io/CsvInputFormat.java ---
@@ -52,103 +50,86 @@
public static final String
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377710#comment-14377710
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user fhueske commented on a diff in
Github user derSascha commented on the pull request:
https://github.com/apache/flink/pull/506#issuecomment-85720375
Looks like the JobGraph missed the renaming.
---
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
[
https://issues.apache.org/jira/browse/FLINK-1770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henry Saputra resolved FLINK-1770.
--
Resolution: Fixed
Committed to master
Rename the variable 'contentAdressable' to
[
https://issues.apache.org/jira/browse/FLINK-1779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14378789#comment-14378789
]
ASF GitHub Bot commented on FLINK-1779:
---
Github user hsaputra commented on the pull
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/529#issuecomment-85718215
+1 LGTM
---
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 user andralungu commented on the pull request:
https://github.com/apache/flink/pull/505#issuecomment-85725549
@vasia ,
I integrated your suggestions, the example works on the cluster for Orkut,
max iter = 20.
---
If your project is set up for it, you can reply to
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/515
---
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
GitHub user fhueske opened a pull request:
https://github.com/apache/flink/pull/532
[FLINK-1776] Add offsets to field indexes of semantic properties for
operators with key selectors
You can merge this pull request into a Git repository by running:
$ git pull
[
https://issues.apache.org/jira/browse/FLINK-1756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14378806#comment-14378806
]
ASF GitHub Bot commented on FLINK-1756:
---
Github user derSascha commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14378804#comment-14378804
]
ASF GitHub Bot commented on FLINK-1756:
---
GitHub user derSascha opened a pull
GitHub user derSascha opened a pull request:
https://github.com/apache/flink/pull/531
[FLINK-1756] [streaming] Rename Stream Monitoring to Streaming
Checkpointing in JobGraph
This is improves #506 and renames Monitoring to Checkpointing in JobGraph
too.
You can merge this pull
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/525#issuecomment-85531186
Do you think this rule is easy enough for users?
It would make the handling consistent for all group-wise operators.
---
If your project is set up for it, you can
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/517#issuecomment-85578193
Pushed it to my master, merging as soon as travis comes in green.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
[
https://issues.apache.org/jira/browse/FLINK-1656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377959#comment-14377959
]
ASF GitHub Bot commented on FLINK-1656:
---
Github user StephanEwen commented on the
Stephan Ewen created FLINK-1778:
---
Summary: Improve normalized keys in composite key case
Key: FLINK-1778
URL: https://issues.apache.org/jira/browse/FLINK-1778
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14378021#comment-14378021
]
Ufuk Celebi commented on FLINK-1319:
I vote for a combination of Stephan's and
Sibao Hong created FLINK-1779:
-
Summary: Rename the function name from
getCurrentyActiveConnections to getCurrentActiveConnections in
org.apache.flink.runtime.blob
Key: FLINK-1779
URL:
[
https://issues.apache.org/jira/browse/FLINK-1544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14378059#comment-14378059
]
ASF GitHub Bot commented on FLINK-1544:
---
Github user mbalassi commented on the pull
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/525#issuecomment-85528267
Good catch, that is a critical distinction (one output record forwarded
from same input record). Mostl relevant to MapPartition, though.
---
If your project is set
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/515#issuecomment-85543938
+1
Will merge this today unless someone beats me to it :)
---
If your project is set up for it, you can reply to this email and have your
reply appear on
[
https://issues.apache.org/jira/browse/FLINK-1770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377989#comment-14377989
]
ASF GitHub Bot commented on FLINK-1770:
---
Github user hsaputra commented on the pull
Timo Walther created FLINK-1777:
---
Summary: Update Java 8 Lambdas with Eclipse documentation
Key: FLINK-1777
URL: https://issues.apache.org/jira/browse/FLINK-1777
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-1717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-1717:
Assignee: Till Rohrmann
Add support to read libSVM and SVMLight input files
GitHub user matadorhong opened a pull request:
https://github.com/apache/flink/pull/529
[FLINK-1779]Rename the function getCurrentyActiveConnections in '
org.apache.flink.runtime.blob'.
I think the function name getCurrentyActiveConnections in '
org.apache.flink.runtime.blob' is
[
https://issues.apache.org/jira/browse/FLINK-1779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14378068#comment-14378068
]
ASF GitHub Bot commented on FLINK-1779:
---
GitHub user matadorhong opened a pull
[
https://issues.apache.org/jira/browse/FLINK-1656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377965#comment-14377965
]
ASF GitHub Bot commented on FLINK-1656:
---
Github user fhueske commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377942#comment-14377942
]
ASF GitHub Bot commented on FLINK-1777:
---
GitHub user twalthr opened a pull request:
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/528
[FLINK-1777] [docs] Update Java 8 Lambdas with Eclipse documentation
See FLINK-1777.
You can merge this pull request into a Git repository by running:
$ git pull
Stephan Ewen created FLINK-1782:
---
Summary: Change Quickstart Java version to 1.7
Key: FLINK-1782
URL: https://issues.apache.org/jira/browse/FLINK-1782
Project: Flink
Issue Type: Improvement
Stephan Ewen created FLINK-1781:
---
Summary: Quickstarts broken due to Scala Version Variables
Key: FLINK-1781
URL: https://issues.apache.org/jira/browse/FLINK-1781
Project: Flink
Issue Type:
Stephan Ewen created FLINK-1783:
---
Summary: Quickstart shading should not created shaded jar and
dependency reduced pom
Key: FLINK-1783
URL: https://issues.apache.org/jira/browse/FLINK-1783
Project:
GitHub user streamnsight opened a pull request:
https://github.com/apache/flink/pull/533
Flink dev cluster on Docker with Docker Compose deployment
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/streamnsight/flink master
[
https://issues.apache.org/jira/browse/FLINK-1775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14379329#comment-14379329
]
ASF GitHub Bot commented on FLINK-1775:
---
GitHub user gyfora opened a pull request:
GitHub user gyfora opened a pull request:
https://github.com/apache/flink/pull/534
[FLINK-1775] BarrierBuffer fix to avoid end of stream deadlock
This fixes several corner-cases in the barrier buffer logic.
Still two problems remain:
- If the StreamRecordWriter is
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/426#issuecomment-85830275
Hi, I updated this PR.
* Remove `pojoType(Class? targetType)` method in `CsvReader` to force the
user to explicitly specify the fields order.
* Add
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14379285#comment-14379285
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user chiwanpark commented on the
Github user szape commented on the pull request:
https://github.com/apache/flink/pull/521#issuecomment-85409807
Only new methods are added. There are two versions of generateSequence: a
new parallel one, as in the batch API, but the old, sequential one is also
useful for testing.
[
https://issues.apache.org/jira/browse/FLINK-1687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377529#comment-14377529
]
ASF GitHub Bot commented on FLINK-1687:
---
Github user szape commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377546#comment-14377546
]
ASF GitHub Bot commented on FLINK-1687:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/521#issuecomment-85412269
Okay, cool.
Let us know when the pull request is ready for another round of reviews.
---
If your project is set up for it, you can reply to this email and have your
Fabian Hueske created FLINK-1780:
Summary: Rename FlatCombineFunction to GroupCombineFunction
Key: FLINK-1780
URL: https://issues.apache.org/jira/browse/FLINK-1780
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-1779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sibao Hong updated FLINK-1779:
--
Description: I think the function name getCurrentyActiveConnections in '
org.apache.flink.runtime.blob'
[
https://issues.apache.org/jira/browse/FLINK-1780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Suneel Marthi reassigned FLINK-1780:
Assignee: Suneel Marthi
Rename FlatCombineFunction to GroupCombineFunction
[
https://issues.apache.org/jira/browse/FLINK-1768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sibao Hong reassigned FLINK-1768:
-
Assignee: Sibao Hong
Fix the bug of BlobServerConnection's LOG.
[
https://issues.apache.org/jira/browse/FLINK-1766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sibao Hong reassigned FLINK-1766:
-
Assignee: Sibao Hong
Fix the bug of equals function of FSKey
[
https://issues.apache.org/jira/browse/FLINK-1775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377380#comment-14377380
]
ASF GitHub Bot commented on FLINK-1775:
---
Github user gyfora closed the pull request
1 - 100 of 116 matches
Mail list logo
