[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14379359#comment-14379359
]
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-85866221
Cool, thanks. Will have a look shortly.
Did you rebase to the latest master? We had a few build issues with the
master branch a few days ago.
It is a
[
https://issues.apache.org/jira/browse/FLINK-1775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14379468#comment-14379468
]
ASF GitHub Bot commented on FLINK-1775:
---
Github user uce commented on the pull
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/534#issuecomment-85909585
Hey gyula,
What is the problem with the stream writer? And how can I reproduce the
record writer broadcast problem? If you give me some instructions to reproduce
the
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/534#discussion_r27100141
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/streamvertex/StreamVertex.java
---
@@ -283,16
[
https://issues.apache.org/jira/browse/FLINK-1775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14379449#comment-14379449
]
ASF GitHub Bot commented on FLINK-1775:
---
Github user rmetzger commented on a diff in
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/517
---
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 mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/530#discussion_r27104700
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java
---
@@ -1425,11 +1425,9 @@ public static boolean isClassType(Type t) {
[
https://issues.apache.org/jira/browse/FLINK-1544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi resolved FLINK-1544.
---
Resolution: Implemented
Fix Version/s: 0.9
Implemented via 597d8b8
Extend streaming
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/531#issuecomment-85951702
Thanks for spotting it, it was my bad. LGTM, merging.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
[
https://issues.apache.org/jira/browse/FLINK-1544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14379541#comment-14379541
]
ASF GitHub Bot commented on FLINK-1544:
---
Github user asfgit closed the pull request
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/530#discussion_r27104945
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/RegularPactTask.java
---
@@ -1465,7 +1467,9 @@ public static void
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/530#discussion_r27104851
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/RegularPactTask.java
---
@@ -525,7 +525,9 @@ protected void run() throws Exception {
[
https://issues.apache.org/jira/browse/FLINK-1756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14379549#comment-14379549
]
ASF GitHub Bot commented on FLINK-1756:
---
Github user mbalassi commented on the pull
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/530#discussion_r27104741
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/AllGroupCombineDriver.java
---
@@ -35,20 +35,20 @@
* Like
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/530#issuecomment-85954079
+1 This rename makes a lot of sense. Looks good to me apart from the minor
comments.
---
If your project is set up for it, you can reply to this email and have your
reply
[
https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14379653#comment-14379653
]
Timo Walther commented on FLINK-1319:
-
Thanks for your comments!
The analyzer also
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14379809#comment-14379809
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user chiwanpark commented on the
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/426#issuecomment-86011099
Oops, I pushed a intermediate commit a8a5c37. I will fix it.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
[
https://issues.apache.org/jira/browse/FLINK-1766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sibao Hong updated FLINK-1766:
--
Issue Type: Improvement (was: Bug)
Fix the bug of equals function of FSKey
Github user gyfora commented on a diff in the pull request:
https://github.com/apache/flink/pull/534#discussion_r27115550
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/streamvertex/StreamVertex.java
---
@@ -283,16
[
https://issues.apache.org/jira/browse/FLINK-1775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14379787#comment-14379787
]
ASF GitHub Bot commented on FLINK-1775:
---
Github user gyfora commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14379792#comment-14379792
]
ASF GitHub Bot commented on FLINK-1756:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/531
---
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:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-1769:
---
Assignee: Aljoscha Krettek
Maven deploy is broken (build artifacts are cleaned in
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14379815#comment-14379815
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user chiwanpark commented on the
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/426#issuecomment-86011531
Sure, no problem :-)
Can I check it now or do you need a bit more time?
---
If your project is set up for it, you can reply to this email and have your
reply appear
[
https://issues.apache.org/jira/browse/FLINK-1783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14379859#comment-14379859
]
Robert Metzger commented on FLINK-1783:
---
To my understanding the new quickstarts are
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14379805#comment-14379805
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user fhueske commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-1781:
-
Assignee: Robert Metzger
Quickstarts broken due to Scala Version Variables
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/518#issuecomment-86050697
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 chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/426#issuecomment-86011782
@fhueske You can check it now :)
---
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
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14379813#comment-14379813
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user fhueske commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14379866#comment-14379866
]
Robert Metzger commented on FLINK-1781:
---
I'll look into this.
Quickstarts broken
Github user matadorhong commented on the pull request:
https://github.com/apache/flink/pull/511#issuecomment-86050415
@StephanEwen I have fixed the code style issue and changed the PR to an
Improvement one in jira.
Finally, great thanks for your help. And I will take more time to
[
https://issues.apache.org/jira/browse/FLINK-1729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-1729:
-
Description:
In order to validate Flink's classification algorithms (in terms of performance
and
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/426#issuecomment-86079595
@chiwanpark excellent job, thanks!
Will merge it after a final round of Travis tests passed.
---
If your project is set up for it, you can reply to this email
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/530#issuecomment-86090016
The documentation also needs to be adapted to use the new interface name.
@smarthi If you don't mind I will merge your commit with my remarks
addressed.
---
If your
[
https://issues.apache.org/jira/browse/FLINK-1694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14380041#comment-14380041
]
Fabian Hueske commented on FLINK-1694:
--
+1 for the second option with the
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14380037#comment-14380037
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user fhueske commented on the pull
Github user smarthi commented on a diff in the pull request:
https://github.com/apache/flink/pull/530#discussion_r27133810
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/AllGroupCombineDriver.java
---
@@ -35,20 +35,20 @@
* Like
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/530
---
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 gyfora commented on the pull request:
https://github.com/apache/flink/pull/534#issuecomment-86140841
Should we merge this anyway? The recordwriter issue seems to be independent
from this, and this commit solves some other bugs.
---
If your project is set up for it, you
[
https://issues.apache.org/jira/browse/FLINK-1775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14380332#comment-14380332
]
ASF GitHub Bot commented on FLINK-1775:
---
Github user gyfora commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/503#issuecomment-86112294
I fixed @rmetzger's remarks. Still waiting for a solution to the naming
issue.
---
If your project is set up for it, you can reply to this email and have your
reply
Fabian Hueske created FLINK-1784:
Summary: KafkaITCase
Key: FLINK-1784
URL: https://issues.apache.org/jira/browse/FLINK-1784
Project: Flink
Issue Type: Bug
Components: Streaming
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14380612#comment-14380612
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/426
---
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-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske resolved FLINK-1512.
--
Resolution: Implemented
Fix Version/s: 0.9
Implemented in
Github user balidani commented on the pull request:
https://github.com/apache/flink/pull/491#issuecomment-86219748
Thanks, I did that, hopefully the tests will pass now.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/491#issuecomment-86199581
I had a look at the Travis logs and it seems that the build failures are
not related to your change.
We had a few issues with build stability on the master branch in
[
https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14379764#comment-14379764
]
Timo Walther commented on FLINK-1319:
-
Is there a reason why Semantic Properties are
52 matches
Mail list logo