[
https://issues.apache.org/jira/browse/FLINK-1785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henry Saputra updated FLINK-1785:
-
Description:
The master fail in flink-tachyon test when running mvn test:
{code}
Henry Saputra created FLINK-1785:
Summary: Master tests in flink-tachyon fail with
java.lang.NoSuchFieldError: IBM_JAVA
Key: FLINK-1785
URL: https://issues.apache.org/jira/browse/FLINK-1785
Project: F
[
https://issues.apache.org/jira/browse/FLINK-703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14381219#comment-14381219
]
Chiwan Park commented on FLINK-703:
---
Hi, I have a question about this issue. I think that
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14381156#comment-14381156
]
Chiwan Park commented on FLINK-1512:
Thanks for merging it down :)
> Add CsvReader fo
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 th
[
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 43ac967acb589790f5b3befd6f932e3
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 enabl
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14380612#comment-14380612
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-1775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14380332#comment-14380332
]
ASF GitHub Bot commented on FLINK-1775:
---
Github user gyfora commented on the pull re
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 ca
[
https://issues.apache.org/jira/browse/FLINK-1784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-1784:
-
Description:
I observed a non-deterministic failure of the {{KafkaITCase}} on Travis:
https://tra
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
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 appe
[
https://issues.apache.org/jira/browse/FLINK-1780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-1780.
-
Resolution: Fixed
https://github.com/apache/flink/pull/530
Merged as of 033c69f9477c63528
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/530#issuecomment-86103055
Thank you for the pull request!
---
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 t
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 enabl
Github user smarthi commented on a diff in the pull request:
https://github.com/apache/flink/pull/530#discussion_r27135717
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/RegularPactTask.java
---
@@ -1465,7 +1467,9 @@ public static void
cancelChainedTasks
Github user smarthi commented on a diff in the pull request:
https://github.com/apache/flink/pull/530#discussion_r27135877
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java
---
@@ -1425,11 +1425,9 @@ public static boolean isClassType(Type t)
Github user smarthi commented on a diff in the pull request:
https://github.com/apache/flink/pull/530#discussion_r27135686
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/RegularPactTask.java
---
@@ -525,7 +525,9 @@ protected void run() throws Exception {
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/530#discussion_r27135343
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/AllGroupCombineDriver.java
---
@@ -35,20 +35,20 @@
* Like @org.apache.flink.runtime.
Github user smarthi commented on the pull request:
https://github.com/apache/flink/pull/530#issuecomment-86091921
@mxm please go ahead
---
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 fea
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 @org.apache.flink.runt
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-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
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14380037#comment-14380037
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user fhueske commented on the pull r
[
https://issues.apache.org/jira/browse/FLINK-1694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14380041#comment-14380041
]
Fabian Hueske commented on FLINK-1694:
--
+1 for the second option with the configurati
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 an
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/503#discussion_r27127405
--- Diff:
flink-staging/flink-table/src/test/java/org/apache/flink/api/java/table/test/AggregationsITCase.java
---
@@ -0,0 +1,210 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14379926#comment-14379926
]
ASF GitHub Bot commented on FLINK-1650:
---
Github user tillrohrmann commented on the p
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
enabl
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-1766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14379924#comment-14379924
]
ASF GitHub Bot commented on FLINK-1766:
---
Github user matadorhong commented on the pu
[
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 aljoscha opened a pull request:
https://github.com/apache/flink/pull/535
[FLINK-1769] Fix deploy bug caused by ScalaDoc aggregation
I added a new profile that should be used when building the combined
JavaDoc. I will add a jira issue for changing this in the nightly java
[
https://issues.apache.org/jira/browse/FLINK-1769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14379886#comment-14379886
]
ASF GitHub Bot commented on FLINK-1769:
---
GitHub user aljoscha opened a pull request:
[
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
> --
[
https://issues.apache.org/jira/browse/FLINK-1781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14379866#comment-14379866
]
Robert Metzger commented on FLINK-1781:
---
I'll look into this.
> Quickstarts broken
[
https://issues.apache.org/jira/browse/FLINK-1783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14379859#comment-14379859
]
Robert Metzger commented on FLINK-1783:
---
To my understanding the new quickstarts are
[
https://issues.apache.org/jira/browse/FLINK-1782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14379865#comment-14379865
]
Robert Metzger commented on FLINK-1782:
---
I agree. Users should explicitly downgrade
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14379815#comment-14379815
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user chiwanpark commented on the pul
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 no
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14379813#comment-14379813
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user fhueske commented on the pull r
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 o
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14379809#comment-14379809
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user chiwanpark commented on the pul
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 w
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14379805#comment-14379805
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/426#issuecomment-86010852
@chiwanpark Thanks, the code looks good to me!
Will try and merge it if everything works.
---
If your project is set up for it, you can reply to this email and have yo
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/505#issuecomment-86007328
Thanks a lot for the updates @andralungu and for testing this on a cluster
environment :-)
The example code looks much nicer now ^-^.
Only minor issue is that the f
[
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 d
[
https://issues.apache.org/jira/browse/FLINK-1726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14379794#comment-14379794
]
ASF GitHub Bot commented on FLINK-1726:
---
Github user vasia commented on the pull req
[
https://issues.apache.org/jira/browse/FLINK-1756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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 enabl
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 +288,18
[
https://issues.apache.org/jira/browse/FLINK-1775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14379787#comment-14379787
]
ASF GitHub Bot commented on FLINK-1775:
---
Github user gyfora commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-1775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14379782#comment-14379782
]
ASF GitHub Bot commented on FLINK-1775:
---
Github user gyfora commented on a diff in t
Github user gyfora commented on a diff in the pull request:
https://github.com/apache/flink/pull/534#discussion_r27115257
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/streamvertex/StreamVertex.java
---
@@ -283,16 +288,18
[
https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-1319:
Comment: was deleted
(was: Is there a reason why Semantic Properties are not available in the Scala
[
https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14379764#comment-14379764
]
Timo Walther commented on FLINK-1319:
-
Is there a reason why Semantic Properties are n
[
https://issues.apache.org/jira/browse/FLINK-1694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14379694#comment-14379694
]
Vasia Kalavri commented on FLINK-1694:
--
Any more opinions on this?
I know it's a triv
[
https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14379653#comment-14379653
]
Timo Walther commented on FLINK-1319:
-
Thanks for your comments!
The analyzer also su
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/251#issuecomment-85970300
There seems to be a happy Flink user deploying Flink on Yarn on Myriad on
Mesos ;)
https://twitter.com/crypt_tech/status/580605081625726976
---
If your project is se
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 app
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
cancelChainedTasks(Lis
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-tabpanel&focusedCommentId=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 @org.apache.flink.runtime.
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 y
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
[
https://issues.apache.org/jira/browse/FLINK-1544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14379541#comment-14379541
]
ASF GitHub Bot commented on FLINK-1544:
---
Github user asfgit closed the pull request
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 enabl
[
https://issues.apache.org/jira/browse/FLINK-1775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14379468#comment-14379468
]
ASF GitHub Bot commented on FLINK-1775:
---
Github user uce commented on the pull reque
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 +288,
[
https://issues.apache.org/jira/browse/FLINK-1775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14379449#comment-14379449
]
ASF GitHub Bot commented on FLINK-1775:
---
Github user rmetzger commented on a diff in
76 matches
Mail list logo
