[
https://issues.apache.org/jira/browse/FLINK-4355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15422302#comment-15422302
]
ASF GitHub Bot commented on FLINK-4355:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2353
Really good code @StephanEwen :-) I like it a lot that you've pulled out
the registration logic from the `TaskExecutor`. This makes it much cleaner and
easier to test.
I'm actually wond
Xiaogang Shi created FLINK-4400:
---
Summary: Leadership Election among JobManagers
Key: FLINK-4400
URL: https://issues.apache.org/jira/browse/FLINK-4400
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15422213#comment-15422213
]
ASF GitHub Bot commented on FLINK-2055:
---
Github user ramkrish86 commented on a diff
Github user ramkrish86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2332#discussion_r74878005
--- Diff:
flink-streaming-connectors/flink-connector-hbase/src/main/java/org/apache/flink/streaming/connectors/hbase/MutationActionList.java
---
@@ -0,0 +
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15422210#comment-15422210
]
ASF GitHub Bot commented on FLINK-2055:
---
Github user ramkrish86 commented on a diff
Github user ramkrish86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2332#discussion_r74877942
--- Diff:
flink-streaming-connectors/flink-connector-hbase/src/main/java/org/apache/flink/streaming/connectors/hbase/MutationActionList.java
---
@@ -0,0 +
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15422153#comment-15422153
]
ASF GitHub Bot commented on FLINK-2055:
---
Github user ramkrish86 commented on a diff
Github user ramkrish86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2332#discussion_r74874857
--- Diff:
flink-streaming-connectors/flink-connector-hbase/src/main/java/org/apache/flink/streaming/connectors/hbase/HBaseSink.java
---
@@ -0,0 +1,104 @@
[
https://issues.apache.org/jira/browse/FLINK-4375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15422120#comment-15422120
]
ASF GitHub Bot commented on FLINK-4375:
---
GitHub user wenlong88 opened a pull request
GitHub user wenlong88 opened a pull request:
https://github.com/apache/flink/pull/2375
[FLINK-4375][cluster management]Introduce rpc protocols implemented by job
manager
1. Add basic RPC interface provided by job master including
2. improve RpcCompletenessTest to support RpcGate
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
david.wang reassigned FLINK-4391:
-
Assignee: david.wang
> Provide support for asynchronous operations over streams
> ---
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
david.wang updated FLINK-4391:
--
Assignee: (was: david.wang)
> Provide support for asynchronous operations over streams
> ---
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
david.wang reassigned FLINK-4391:
-
Assignee: david.wang
> Provide support for asynchronous operations over streams
> ---
Github user KurtYoung commented on the issue:
https://github.com/apache/flink/pull/2370
Hi @tillrohrmann , thanks for the reviewing, all your comments have been
addressed.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well.
[
https://issues.apache.org/jira/browse/FLINK-4399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421999#comment-15421999
]
Felix Neutatz commented on FLINK-4399:
--
Hi, what is the difference between this issue
[
https://issues.apache.org/jira/browse/FLINK-4373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421998#comment-15421998
]
ASF GitHub Bot commented on FLINK-4373:
---
Github user KurtYoung commented on the issu
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/2370#discussion_r74864046
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceProfile.java
---
@@ -0,0 +1,47 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-4373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421997#comment-15421997
]
ASF GitHub Bot commented on FLINK-4373:
---
Github user KurtYoung commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-4373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421994#comment-15421994
]
ASF GitHub Bot commented on FLINK-4373:
---
Github user KurtYoung commented on a diff i
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/2370#discussion_r74863897
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/AllocationID.java
---
@@ -0,0 +1,38 @@
+/*
+ * Licensed to th
[
https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421737#comment-15421737
]
ASF GitHub Bot commented on FLINK-3298:
---
Github user mushketyk commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421735#comment-15421735
]
ASF GitHub Bot commented on FLINK-3298:
---
Github user mushketyk commented on a diff i
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2314#discussion_r74841557
--- Diff: flink-streaming-connectors/flink-connector-activemq/pom.xml ---
@@ -0,0 +1,104 @@
+
+
+http://maven.apache.org/POM/4.0.0";
+
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2314#discussion_r74841591
--- Diff: flink-streaming-connectors/flink-connector-activemq/pom.xml ---
@@ -0,0 +1,104 @@
+
+
+http://maven.apache.org/POM/4.0.0";
+
[
https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421715#comment-15421715
]
ASF GitHub Bot commented on FLINK-3298:
---
Github user mushketyk commented on a diff i
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2314#discussion_r74839402
--- Diff:
flink-streaming-connectors/flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq/AMQSource.java
---
@@ -0,0 +1,25
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2314
>> Did you test the code on a cluster?
I tested it using the test ActiveMQ server (via an integration test), but I
can also test it using an ActiveMQ cluster.
>> Were there any any depe
[
https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421710#comment-15421710
]
ASF GitHub Bot commented on FLINK-3298:
---
Github user mushketyk commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421701#comment-15421701
]
ASF GitHub Bot commented on FLINK-3298:
---
Github user mushketyk commented on the issu
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2314
@rmetzger Thank you for your detailed review. I'll update the PR today or
tomorrow.
Despite of the fact that this connector will probably moved to Bahir it
would make sense to make sure that it
[
https://issues.apache.org/jira/browse/FLINK-3703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421692#comment-15421692
]
ASF GitHub Bot commented on FLINK-3703:
---
Github user mushketyk commented on a diff i
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2367#discussion_r74837056
--- Diff:
flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/TestBaseUtils.java
---
@@ -26,6 +26,7 @@
import akka.patte
GitHub user mushketyk opened a pull request:
https://github.com/apache/flink/pull/2374
[FLINK-3950] Add Meter Metric Type
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your changes take all
[
https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421678#comment-15421678
]
ASF GitHub Bot commented on FLINK-3950:
---
GitHub user mushketyk opened a pull request
[
https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421512#comment-15421512
]
Ivan Mushketyk commented on FLINK-3950:
---
Hi [~Zentol],
Thank you for your very deta
[
https://issues.apache.org/jira/browse/FLINK-4177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421419#comment-15421419
]
Chesnay Schepler commented on FLINK-4177:
-
I wrote my comment a a little bit befor
[
https://issues.apache.org/jira/browse/FLINK-4355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421366#comment-15421366
]
ASF GitHub Bot commented on FLINK-4355:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2353#discussion_r74803435
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/taskexecutor/TaskExecutorToResourceManagerConnection.java
---
@@ -0,0 +1,132 @@
+
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2353#discussion_r74802315
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/taskexecutor/ResourceManagerRegistration.java
---
@@ -0,0 +1,252 @@
+/*
+ * L
[
https://issues.apache.org/jira/browse/FLINK-4355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421355#comment-15421355
]
ASF GitHub Bot commented on FLINK-4355:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-4355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421333#comment-15421333
]
ASF GitHub Bot commented on FLINK-4355:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2353#discussion_r74800246
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/resourcemanager/TaskExecutorRegistrationResponse.java
---
@@ -0,0 +1,86 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421317#comment-15421317
]
Josep Rubió commented on FLINK-1707:
Hi [~vkalavri]
No worries :)
No is not, damping
[
https://issues.apache.org/jira/browse/FLINK-4355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421264#comment-15421264
]
ASF GitHub Bot commented on FLINK-4355:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-4177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421271#comment-15421271
]
Stephan Ewen commented on FLINK-4177:
-
A few days back we discussing about starting Ca
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2353#discussion_r74793706
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/taskexecutor/TaskExecutorToResourceManagerConnection.java
---
@@ -0,0 +1,80 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-4366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421256#comment-15421256
]
ASF GitHub Bot commented on FLINK-4366:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2354
Have to rerun tests on this one. The Scala API completeness check failed,
so I had to adjust it.
Will merge pending successful tests...
---
If your project is set up for it, you can reply to
[
https://issues.apache.org/jira/browse/FLINK-4397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421236#comment-15421236
]
Stephan Ewen commented on FLINK-4397:
-
The metric registry looks non-suspicious. Could
[
https://issues.apache.org/jira/browse/FLINK-4397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421233#comment-15421233
]
Stephan Ewen commented on FLINK-4397:
-
Looking at the debug logs, it seems the TaskMan
[
https://issues.apache.org/jira/browse/FLINK-4309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sunny T reassigned FLINK-4309:
--
Assignee: Sunny T
> Potential null pointer dereference in DelegatingConfiguration#keySet()
> --
[
https://issues.apache.org/jira/browse/FLINK-4373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421184#comment-15421184
]
ASF GitHub Bot commented on FLINK-4373:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2370#discussion_r74785154
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/AllocationID.java
---
@@ -0,0 +1,38 @@
+/*
+ * Licensed to
Stephan Ewen created FLINK-4399:
---
Summary: Add support for oversized messages
Key: FLINK-4399
URL: https://issues.apache.org/jira/browse/FLINK-4399
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421162#comment-15421162
]
Vasia Kalavri commented on FLINK-1707:
--
Hi [~joseprupi],
I haven't had time to look a
[
https://issues.apache.org/jira/browse/FLINK-4382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421152#comment-15421152
]
ASF GitHub Bot commented on FLINK-4382:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2358
The stashing is a feature which comes for free with Akka. Of course the
sending side should not rely on this behaviour when implementing its failure
treatment. But in cases where we have a race
Github user tillrohrmann closed the pull request at:
https://github.com/apache/flink/pull/2365
---
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 i
[
https://issues.apache.org/jira/browse/FLINK-4383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421139#comment-15421139
]
ASF GitHub Bot commented on FLINK-4383:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2365
Somehow this PR was not closed automatically.
---
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 f
[
https://issues.apache.org/jira/browse/FLINK-4383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421140#comment-15421140
]
ASF GitHub Bot commented on FLINK-4383:
---
Github user tillrohrmann closed the pull re
[
https://issues.apache.org/jira/browse/FLINK-4278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421137#comment-15421137
]
Neelesh Srinivas Salian commented on FLINK-4278:
Thanks [~tedyu]. I'll pos
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421135#comment-15421135
]
Josep Rubió commented on FLINK-1707:
Hi [~vkalavri],
I'm redoing the implementation a
[
https://issues.apache.org/jira/browse/FLINK-4281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421133#comment-15421133
]
ASF GitHub Bot commented on FLINK-4281:
---
Github user wuchong commented on the issue:
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/2372
@twalthr @mushketyk review comments addressed, and fix the conflicts.
---
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
Github user cresny commented on a diff in the pull request:
https://github.com/apache/flink/pull/2288#discussion_r74776047
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/util/HDFSCopyUtilitiesTest.java
---
@@ -70,6 +70,85 @@ public void testCopyFromLocal()
[
https://issues.apache.org/jira/browse/FLINK-4396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421110#comment-15421110
]
Chesnay Schepler commented on FLINK-4396:
-
For clarification I would like to ask w
Github user cresny commented on a diff in the pull request:
https://github.com/apache/flink/pull/2288#discussion_r74774950
--- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java ---
@@ -255,4 +257,33 @@ private Utils() {
}
return result;
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2370
Thanks for you contribution @KurtYoung. Good work!
I only had some minor comments. Once they are addressed it's good to be
merged :-)
---
If your project is set up for it, you can rep
[
https://issues.apache.org/jira/browse/FLINK-4373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421099#comment-15421099
]
ASF GitHub Bot commented on FLINK-4373:
---
Github user tillrohrmann commented on the i
[
https://issues.apache.org/jira/browse/FLINK-4396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-4396:
Issue Type: Wish (was: Bug)
> GraphiteReporter class not found at startup of jobmanager
> -
[
https://issues.apache.org/jira/browse/FLINK-4396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-4396:
Labels: (was: metrics)
> GraphiteReporter class not found at startup of jobmanager
> -
[
https://issues.apache.org/jira/browse/FLINK-4396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-4396:
Component/s: Metrics
> GraphiteReporter class not found at startup of jobmanager
> -
[
https://issues.apache.org/jira/browse/FLINK-4396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RWenden updated FLINK-4396:
---
Summary: GraphiteReporter class not found at startup of jobmanager (was:
MetricRegistry class not found at st
[
https://issues.apache.org/jira/browse/FLINK-4281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421079#comment-15421079
]
ASF GitHub Bot commented on FLINK-4281:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2372#discussion_r74772260
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/exceptions.scala
---
@@ -37,3 +37,16 @@ case class ValidationException(msg: S
[
https://issues.apache.org/jira/browse/FLINK-4281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421075#comment-15421075
]
ASF GitHub Bot commented on FLINK-4281:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2372#discussion_r74771464
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/exceptions.scala
---
@@ -37,3 +37,16 @@ case class ValidationException(msg: S
[
https://issues.apache.org/jira/browse/FLINK-4373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421061#comment-15421061
]
ASF GitHub Bot commented on FLINK-4373:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2370#discussion_r74770025
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/SlotID.java
---
@@ -0,0 +1,81 @@
+/*
+ * Licensed to the A
[
https://issues.apache.org/jira/browse/FLINK-4373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421055#comment-15421055
]
ASF GitHub Bot commented on FLINK-4373:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-4397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421059#comment-15421059
]
Ufuk Celebi commented on FLINK-4397:
I'm wondering whether we should close/rename thi
[
https://issues.apache.org/jira/browse/FLINK-4397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-4397:
---
Assignee: (was: Ufuk Celebi)
> Unstable test SlotCountExceedingParallelismTest.tearDown
>
[
https://issues.apache.org/jira/browse/FLINK-4373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421058#comment-15421058
]
ASF GitHub Bot commented on FLINK-4373:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2370#discussion_r74769869
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceProfile.java
---
@@ -0,0 +1,47 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-4397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421052#comment-15421052
]
Ufuk Celebi commented on FLINK-4397:
These shut down timeouts are recently happening f
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2370#discussion_r74769810
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceProfile.java
---
@@ -0,0 +1,47 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-4373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421050#comment-15421050
]
ASF GitHub Bot commented on FLINK-4373:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421049#comment-15421049
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2231
@radekg I've opened a PR based on your code:
https://github.com/apache/flink/issues/2369 feel free to review it.
---
If your project is set up for it, you can reply to this email and have your
repl
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2370#discussion_r74769608
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceProfile.java
---
@@ -0,0 +1,47 @@
+/*
+ * Licensed
Kostas Kloudas created FLINK-4397:
-
Summary: Unstable test SlotCountExceedingParallelismTest.tearDown
Key: FLINK-4397
URL: https://issues.apache.org/jira/browse/FLINK-4397
Project: Flink
Issu
[
https://issues.apache.org/jira/browse/FLINK-4398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-4398:
--
Assignee: Ufuk Celebi
> Unstable test KvStateServerHandlerTest.testSimpleQuery
> ---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2373
---
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 enab
[
https://issues.apache.org/jira/browse/FLINK-3097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421026#comment-15421026
]
ASF GitHub Bot commented on FLINK-3097:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421027#comment-15421027
]
ASF GitHub Bot commented on FLINK-4394:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421043#comment-15421043
]
ASF GitHub Bot commented on FLINK-4373:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421044#comment-15421044
]
Robert Metzger commented on FLINK-4035:
---
Thank you for trying this out.
I've opened
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2370#discussion_r74768989
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/SlotID.java
---
@@ -0,0 +1,81 @@
+/*
+ * Licensed to the A
1 - 100 of 200 matches
Mail list logo
