[
https://issues.apache.org/jira/browse/FLINK-2584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14721488#comment-14721488
]
ASF GitHub Bot commented on FLINK-2584:
---
GitHub user rmetzger opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-2584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14721503#comment-14721503
]
ASF GitHub Bot commented on FLINK-2584:
---
Github user uce commented on the pull
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1076#issuecomment-136131254
Nice work :) This needs to go into the milestone branch as well.
What do you mean with We can easily integrate curator's netty into the jar
file.?
---
If your
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1075#issuecomment-136129581
Thanks a lot for the contribution.
Can you add a test case for the method to make sure the issue is not
re-introduced again when somebody else is changing the code?
[
https://issues.apache.org/jira/browse/FLINK-2590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14721489#comment-14721489
]
ASF GitHub Bot commented on FLINK-2590:
---
Github user rmetzger commented on the pull
GitHub user ogokal opened a pull request:
https://github.com/apache/flink/pull/1077
[FLINK-2125][streaming] Delimiter change from char to string
I tried to change based on the previous comments. I hope it is sufficient
enough.
You can merge this pull request into a Git repository
[
https://issues.apache.org/jira/browse/FLINK-2543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14721659#comment-14721659
]
ASF GitHub Bot commented on FLINK-2543:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1048
---
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-2543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2543.
-
Resolution: Fixed
Fixed via bf8c8e54094151348caedd3120931516f76c3cf3 and
[
https://issues.apache.org/jira/browse/FLINK-2543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2543.
---
State handling does not support deserializing classes through the
UserCodeClassloader
GitHub user daniel-pape opened a pull request:
https://github.com/apache/flink/pull/1078
FLINK-1737: Kronecker product
This is preparational work related to FLINK-1737: Adds an implementation of
outer/Kronecker product which can subsequently be used to compute the sample
[
https://issues.apache.org/jira/browse/FLINK-1737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14721710#comment-14721710
]
ASF GitHub Bot commented on FLINK-1737:
---
GitHub user daniel-pape opened a pull
[
https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14721481#comment-14721481
]
ASF GitHub Bot commented on FLINK-2111:
---
Github user tillrohrmann commented on a
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/750#discussion_r38270665
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
---
@@ -411,6 +411,23 @@ class TaskManager(
[
https://issues.apache.org/jira/browse/FLINK-1681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14721746#comment-14721746
]
Stephan Ewen commented on FLINK-1681:
-
Migrated a set of tests from the deprecated API
[
https://issues.apache.org/jira/browse/FLINK-2125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14721638#comment-14721638
]
ASF GitHub Bot commented on FLINK-2125:
---
GitHub user ogokal opened a pull request:
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/commit/554b77bcd9ed66d57d99d4990774a43f35f6a835#commitcomment-12965859
Currently, flink-runtime has a dependency on Hadoop, so I can assume its
always available.
Even for a binary Flink release
[
https://issues.apache.org/jira/browse/FLINK-2584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14721504#comment-14721504
]
ASF GitHub Bot commented on FLINK-2584:
---
Github user rmetzger commented on the pull
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/commit/554b77bcd9ed66d57d99d4990774a43f35f6a835#commitcomment-12965831
At some points there were thoughts about a hadoop-free version. How would
this play together?
---
If your project is set up
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/commit/554b77bcd9ed66d57d99d4990774a43f35f6a835#commitcomment-12965891
I think this is a good addition. In the future (Hadoop not present), we may
have to go for reflection, true.
---
If your
Robert Metzger created FLINK-2598:
-
Summary: NPE when arguments are missing for a -m yarn-cluster job
Key: FLINK-2598
URL: https://issues.apache.org/jira/browse/FLINK-2598
Project: Flink
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/1074#issuecomment-136152037
Test fails in instable yarn-test. Should be ready to get merged.
---
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-2475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14721542#comment-14721542
]
ASF GitHub Bot commented on FLINK-2475:
---
Github user mjsax commented on the pull
Github user ffbin commented on the pull request:
https://github.com/apache/flink/pull/1046#issuecomment-136241503
@mjsax @StephanEwen I have finish the code changes.
1.serialize Storm Config as a byte[] into the Flink configuration
2.extend ExclamationTopology such that the
Github user ChengXiangLi commented on the pull request:
https://github.com/apache/flink/pull/1067#issuecomment-136243437
Nice job, @greghogan , you just pointed out the root cause and the
solution. I add the logic to skip latest buckets as @StephanEwen suggested, and
add related unit
Github user ankurcha commented on a diff in the pull request:
https://github.com/apache/flink/pull/948#discussion_r38281174
--- Diff:
flink-mesos/src/main/scala/org/apache/flink/mesos/scheduler/SchedulerUtils.scala
---
@@ -0,0 +1,348 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14721881#comment-14721881
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user ankurcha commented on a diff in
Github user ankurcha commented on the pull request:
https://github.com/apache/flink/pull/948#issuecomment-136236719
@rmetzger I have finally got some time to work on this again. Let me
address your question one by one:
Why did you decide to start the JobManager alongside the
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14721880#comment-14721880
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user ankurcha commented on the pull
Github user HuangWHWHW commented on a diff in the pull request:
https://github.com/apache/flink/pull/1077#discussion_r38282466
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/functions/SocketTextStreamFunctionTest.java
---
[
https://issues.apache.org/jira/browse/FLINK-2125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14721923#comment-14721923
]
ASF GitHub Bot commented on FLINK-2125:
---
Github user HuangWHWHW commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-2125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14721932#comment-14721932
]
ASF GitHub Bot commented on FLINK-2125:
---
Github user HuangWHWHW commented on the
[
https://issues.apache.org/jira/browse/FLINK-2590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14721935#comment-14721935
]
ASF GitHub Bot commented on FLINK-2590:
---
Github user HuangWHWHW commented on the
[
https://issues.apache.org/jira/browse/FLINK-2525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14721918#comment-14721918
]
ASF GitHub Bot commented on FLINK-2525:
---
Github user ffbin commented on the pull
Github user HuangWHWHW commented on the pull request:
https://github.com/apache/flink/pull/1075#issuecomment-136245681
@rmetzger +1. I think add a test is helpful.
Otherwise can you give us a infomation that prove the 'id = (counter
shifter) + taskId; ' will never generate the
[
https://issues.apache.org/jira/browse/FLINK-2596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chengxiang Li reassigned FLINK-2596:
Assignee: Chengxiang Li
> Failing Test: RandomSamplerTest
>
36 matches
Mail list logo