[
https://issues.apache.org/jira/browse/FLINK-4021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15423994#comment-15423994
]
Zhijiang Wang commented on FLINK-4021:
--
Yeah, you are right. It is no problem in curr
[
https://issues.apache.org/jira/browse/FLINK-4021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15423984#comment-15423984
]
Zhijiang Wang commented on FLINK-4021:
--
Thank you for advice, it is indeed simple by
Wenlong Lyu created FLINK-4406:
--
Summary: Implement job master registration at resource manager
Key: FLINK-4406
URL: https://issues.apache.org/jira/browse/FLINK-4406
Project: Flink
Issue Type: S
Github user ramkrish86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2342#discussion_r75065679
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServer.java ---
@@ -77,7 +77,7 @@
/**
* Shutdown hook thread
[
https://issues.apache.org/jira/browse/FLINK-4253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15423948#comment-15423948
]
ASF GitHub Bot commented on FLINK-4253:
---
Github user ramkrish86 commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-4253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15423949#comment-15423949
]
ASF GitHub Bot commented on FLINK-4253:
---
Github user ramkrish86 commented on a diff
Github user ramkrish86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2342#discussion_r75065676
--- Diff: docs/setup/config.md ---
@@ -285,7 +285,7 @@ of the JobManager, because the same ActorSystem is
used. Its not possible to use
## High
[
https://issues.apache.org/jira/browse/FLINK-4405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Suresh Krishnappa updated FLINK-4405:
-
Description:
This issue is to address part T3-4 (Implement Blob Server TLS/SSL) of the
[S
[
https://issues.apache.org/jira/browse/FLINK-4404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Suresh Krishnappa updated FLINK-4404:
-
Description: This issue is to address part T3-3 (Implement Data Transfer
TLS/SSL) of the [
Suresh Krishnappa created FLINK-4405:
Summary: Implement Blob Server SSL
Key: FLINK-4405
URL: https://issues.apache.org/jira/browse/FLINK-4405
Project: Flink
Issue Type: Sub-task
Suresh Krishnappa created FLINK-4404:
Summary: Implement Data Transfer SSL
Key: FLINK-4404
URL: https://issues.apache.org/jira/browse/FLINK-4404
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15423463#comment-15423463
]
ASF GitHub Bot commented on FLINK-3950:
---
Github user mushketyk commented on the issu
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2374
@zentol Thank you for reviewing my PR! I'll fix these issues as soon as I
can.
On the metrics interface. Could you please elaborate why do you think
exponentially weighted rate and 15 minu
[
https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15423415#comment-15423415
]
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=15423417#comment-15423417
]
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 I've updated the PR according to your review. Could you please
take another look?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub a
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2314#discussion_r75024557
--- Diff:
flink-streaming-connectors/flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq/AMQSink.java
---
@@ -0,0 +1,155
[
https://issues.apache.org/jira/browse/FLINK-4402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15423395#comment-15423395
]
Neelesh Srinivas Salian commented on FLINK-4402:
If you don't mind, shall
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2374
Good work! Only found a minor issue in regards to the TestingMeter class.
There is one thing I would like to start a discussion on however. Right now
the Meter interface is essentially a copy
[
https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15423388#comment-15423388
]
ASF GitHub Bot commented on FLINK-3950:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15423365#comment-15423365
]
ASF GitHub Bot commented on FLINK-3950:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15423364#comment-15423364
]
ASF GitHub Bot commented on FLINK-3950:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2374#discussion_r75018180
--- Diff:
flink-metrics/flink-metrics-jmx/src/test/java/org/apache/flink/metrics/jmx/JMXReporterTest.java
---
@@ -297,4 +342,42 @@ public long getMin() {
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2374#discussion_r75018225
--- Diff:
flink-metrics/flink-metrics-statsd/src/test/java/org/apache/flink/metrics/statsd/StatsDReporterTest.java
---
@@ -261,6 +327,40 @@ public long getMin
[
https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15423358#comment-15423358
]
ASF GitHub Bot commented on FLINK-3950:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2374#discussion_r75017658
--- Diff:
flink-metrics/flink-metrics-jmx/src/test/java/org/apache/flink/metrics/jmx/JMXReporterTest.java
---
@@ -245,6 +246,50 @@ public void testHistogramRe
[
https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15423327#comment-15423327
]
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=15423325#comment-15423325
]
ASF GitHub Bot commented on FLINK-3298:
---
Github user mushketyk commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-3761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-3761:
Summary: Refactor State Backends/Make Keyed State Key-Group Aware (was:
Introduce key group
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2314#discussion_r75011941
--- 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 a diff in the pull request:
https://github.com/apache/flink/pull/2314#discussion_r75011880
--- Diff:
flink-streaming-connectors/flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq/AMQSource.java
---
@@ -0,0 +1,25
[
https://issues.apache.org/jira/browse/FLINK-3761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-3761:
---
Assignee: Aljoscha Krettek (was: Till Rohrmann)
> Introduce key group state backend
[
https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15423319#comment-15423319
]
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=15423318#comment-15423318
]
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_r75011452
--- Diff:
flink-streaming-connectors/flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq/AMQSink.java
---
@@ -0,0 +1,155
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2314#discussion_r75011407
--- Diff:
flink-streaming-connectors/flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq/AMQSink.java
---
@@ -0,0 +1,155
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2314#discussion_r75011140
--- Diff:
flink-streaming-connectors/flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq/AMQSink.java
---
@@ -0,0 +1,155
[
https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15423315#comment-15423315
]
ASF GitHub Bot commented on FLINK-3298:
---
Github user mushketyk commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-4380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-4380:
Assignee: Stefan Richter (was: Aljoscha Krettek)
> Introduce KeyGroupAssigner and Max-Paral
[
https://issues.apache.org/jira/browse/FLINK-4381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-4381:
Assignee: Stefan Richter
> Refactor State to Prepare For Key-Group State Backends
>
[
https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15423312#comment-15423312
]
ASF GitHub Bot commented on FLINK-3298:
---
Github user mushketyk commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-4380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-4380:
---
Assignee: Aljoscha Krettek
> Introduce KeyGroupAssigner and Max-Parallelism Parameter
[
https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15423313#comment-15423313
]
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_r75010803
--- 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_r75010826
--- Diff: flink-streaming-connectors/flink-connector-activemq/pom.xml ---
@@ -0,0 +1,104 @@
+
+
+http://maven.apache.org/POM/4.0.0";
+
Stephan Ewen created FLINK-4403:
---
Summary: RPC proxy classloading should use Flink class' classloader
Key: FLINK-4403
URL: https://issues.apache.org/jira/browse/FLINK-4403
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-4402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15423241#comment-15423241
]
Chesnay Schepler commented on FLINK-4402:
-
the documentation should be adjusted.
[
https://issues.apache.org/jira/browse/FLINK-4355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15423229#comment-15423229
]
ASF GitHub Bot commented on FLINK-4355:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2353
I addressed the comments by @tillrohrmann and @wenlong88
- turning the registration object into a reusable utility that can also
be used for the JobMaster registration
- I made the reg
[
https://issues.apache.org/jira/browse/FLINK-4198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15423168#comment-15423168
]
ASF GitHub Bot commented on FLINK-4198:
---
Github user kishorekgarg commented on the i
[
https://issues.apache.org/jira/browse/FLINK-4198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15423169#comment-15423169
]
ASF GitHub Bot commented on FLINK-4198:
---
Github user kishorekgarg closed the pull re
Github user kishorekgarg closed the pull request at:
https://github.com/apache/flink/pull/2359
---
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
Github user kishorekgarg commented on the issue:
https://github.com/apache/flink/pull/2359
Sure. I will close 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 feature
enabled and wish
Github user cresny commented on a diff in the pull request:
https://github.com/apache/flink/pull/2288#discussion_r74982416
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/util/HDFSCopyFromLocal.java
---
@@ -62,4 +64,34 @@ public void run() {
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r74972977
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosTaskManagerParameters.java
---
@@ -0,0 +1,69 @@
+/*
+ *
Github user cresny commented on a diff in the pull request:
https://github.com/apache/flink/pull/2288#discussion_r74974171
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/util/HDFSCopyFromLocal.java
---
@@ -62,4 +64,34 @@ public void run() {
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15423008#comment-15423008
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r74972631
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosFlinkResourceManager.java
---
@@ -0,0 +1,755 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15423014#comment-15423014
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15422998#comment-15422998
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r74971461
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosFlinkResourceManager.java
---
@@ -0,0 +1,755 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15422980#comment-15422980
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user EronWright commented on the iss
Github user EronWright commented on the issue:
https://github.com/apache/flink/pull/2315
A high-level comment to reviewers, I strove to follow the YARN
implementation closely, in anticipation of a future refactoring. The runner
and RM are prime examples where consistency was emphasi
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15422976#comment-15422976
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user EronWright commented on a diff
Github user EronWright commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r74968719
--- Diff: flink-dist/pom.xml ---
@@ -113,8 +113,13 @@ under the License.
flink-metrics-jmx
${project.version
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2364
---
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
Github user EronWright commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r74968309
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosApplicationMasterRunner.java
---
@@ -0,0 +1,618 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15422974#comment-15422974
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user EronWright commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15422970#comment-15422970
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user EronWright commented on a diff
Github user EronWright commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r74967974
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosApplicationMasterRunner.java
---
@@ -0,0 +1,618 @@
+/*
+
Github user EronWright commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r74967737
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosFlinkResourceManager.java
---
@@ -0,0 +1,755 @@
+/*
+ * L
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15422969#comment-15422969
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user EronWright commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-4293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15422960#comment-15422960
]
ASF GitHub Bot commented on FLINK-4293:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4293.
-
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed via dff986dff9af4ce23d5f98306044674d009f2649
[
https://issues.apache.org/jira/browse/FLINK-4293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4293.
---
> Malformatted Apache Headers
> ---
>
> Key: FLINK-4293
>
Github user EronWright commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r74966906
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosFlinkResourceManager.java
---
@@ -0,0 +1,755 @@
+/*
+ * L
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15422954#comment-15422954
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user EronWright commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15422942#comment-15422942
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r74965913
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosFlinkResourceManager.java
---
@@ -0,0 +1,755 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-4198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15422935#comment-15422935
]
ASF GitHub Bot commented on FLINK-4198:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2359
We can unfortunately not merge this change. The tools for API compatibility
verify that this breaks the API:
```
Failed to execute goal
com.github.siom79.japicmp:japicmp-maven-plugin:0.7.
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15422934#comment-15422934
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r74964722
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosFlinkResourceManager.java
---
@@ -0,0 +1,755 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15422933#comment-15422933
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r74963941
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosFlinkResourceManager.java
---
@@ -0,0 +1,755 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15422931#comment-15422931
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r74963589
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosFlinkResourceManager.java
---
@@ -0,0 +1,755 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-4293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15422930#comment-15422930
]
ASF GitHub Bot commented on FLINK-4293:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2364
Merging this...
---
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, o
[
https://issues.apache.org/jira/browse/FLINK-4388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4388.
---
> Race condition during initialization of MemorySegmentFactory
> -
[
https://issues.apache.org/jira/browse/FLINK-4388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4388.
-
Resolution: Fixed
Fix Version/s: (was: 1.1.2)
Fixed via 6cdf06ccb4c7ac444521ca3c3ff4317
[
https://issues.apache.org/jira/browse/FLINK-4366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4366.
-
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed via ffe406570af60057fa2ae318561aa239b99bd648
[
https://issues.apache.org/jira/browse/FLINK-4366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4366.
---
> Enforce parallelism=1 For AllWindowedStream
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-4366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15422922#comment-15422922
]
ASF GitHub Bot commented on FLINK-4366:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2354
---
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-4382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15422913#comment-15422913
]
ASF GitHub Bot commented on FLINK-4382:
---
Github user tillrohrmann closed the pull re
[
https://issues.apache.org/jira/browse/FLINK-4382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-4382.
Resolution: Fixed
Fixed via 5df27ebd73f5218a792fb53385887968c0e4ca36
> Buffer rpc calls until RpcEn
Github user tillrohrmann closed the pull request at:
https://github.com/apache/flink/pull/2358
---
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
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2288#discussion_r74961561
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/util/HDFSCopyFromLocal.java
---
@@ -62,4 +64,34 @@ public void run() {
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/2376
R: @tillrohrmann @StephanEwen for review pls
---
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
1 - 100 of 197 matches
Mail list logo
