[
https://issues.apache.org/jira/browse/FLINK-4450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15451382#comment-15451382
]
ASF GitHub Bot commented on FLINK-4450:
---
Github user liuyuzhong commented on the iss
Github user liuyuzhong commented on the issue:
https://github.com/apache/flink/pull/2439
mvn clean verify : ok
test flink-storm-examples: ok
bin/flink run WordCount-StormTopology.jar
bin/flink run WordCount-BoltTokenizer.jar
bin/flink run WordCount-SpoutSource.jar
Github user beyond1920 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2435#discussion_r76929812
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/heartbeat/HeartbeatListener.java
---
@@ -0,0 +1,61 @@
+/*
+ * Licensed to the Apach
[
https://issues.apache.org/jira/browse/FLINK-4478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15451297#comment-15451297
]
ASF GitHub Bot commented on FLINK-4478:
---
Github user beyond1920 commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-4536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15451227#comment-15451227
]
Tzu-Li (Gordon) Tai commented on FLINK-4536:
Thanks for reporting this.
Just t
Scott Kidder created FLINK-4536:
---
Summary: Possible thread leak in Task Manager
Key: FLINK-4536
URL: https://issues.apache.org/jira/browse/FLINK-4536
Project: Flink
Issue Type: Bug
Co
[
https://issues.apache.org/jira/browse/FLINK-4347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15450983#comment-15450983
]
ASF GitHub Bot commented on FLINK-4347:
---
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/2388#discussion_r76920351
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/SlotID.java
---
@@ -75,9 +75,15 @@ public int hashCode() {
[
https://issues.apache.org/jira/browse/FLINK-4347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15450971#comment-15450971
]
ASF GitHub Bot commented on FLINK-4347:
---
Github user KurtYoung commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-4347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15450970#comment-15450970
]
ASF GitHub Bot commented on FLINK-4347:
---
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/2388#discussion_r76919993
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceID.java
---
@@ -63,9 +63,7 @@ public final int hashCode() {
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/2388#discussion_r76920002
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/SlotID.java
---
@@ -75,9 +75,15 @@ public int hashCode() {
[
https://issues.apache.org/jira/browse/FLINK-4347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15450966#comment-15450966
]
ASF GitHub Bot commented on FLINK-4347:
---
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/2388#discussion_r76919953
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/SlotManager.java
---
@@ -0,0 +1,525 @@
+/*
+ * Licensed to the Apac
[
https://issues.apache.org/jira/browse/FLINK-4347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15450956#comment-15450956
]
ASF GitHub Bot commented on FLINK-4347:
---
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/2388#discussion_r76919875
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/SlotManager.java
---
@@ -0,0 +1,525 @@
+/*
+ * Licensed to the Apac
[
https://issues.apache.org/jira/browse/FLINK-4532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15450946#comment-15450946
]
Renkai Ge edited comment on FLINK-4532 at 8/31/16 3:33 AM:
---
[~St
[
https://issues.apache.org/jira/browse/FLINK-4532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15450946#comment-15450946
]
Renkai Ge commented on FLINK-4532:
--
[~StephanEwen]
Yes, I think your proposal is actually
[
https://issues.apache.org/jira/browse/FLINK-4535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangjing updated FLINK-4535:
-
Description:
When TaskExecutor register at ResourceManager, it takes the following 3 input
parameters:
1.
[
https://issues.apache.org/jira/browse/FLINK-4535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangjing updated FLINK-4535:
-
Description:
When TaskExecutor register at ResourceManager, it takes the following 3 input
parameter:
1.
[
https://issues.apache.org/jira/browse/FLINK-4535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangjing updated FLINK-4535:
-
Description:
When TaskExecutor register at ResourceManager, it takes the following 3 input
parameter:
1.
[
https://issues.apache.org/jira/browse/FLINK-4535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangjing updated FLINK-4535:
-
Description:
When TaskExecutor register at ResourceManager, it takes the following 3 input
parameter:
1.
zhangjing created FLINK-4535:
Summary: ResourceManager process registration from TaskExecutor
Key: FLINK-4535
URL: https://issues.apache.org/jira/browse/FLINK-4535
Project: Flink
Issue Type: Sub
[
https://issues.apache.org/jira/browse/FLINK-4535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangjing updated FLINK-4535:
-
Description:
When TaskExecutor register at ResourceManager, it will have the following 3
input parameter:
[
https://issues.apache.org/jira/browse/FLINK-4516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15450761#comment-15450761
]
ASF GitHub Bot commented on FLINK-4516:
---
Github user beyond1920 commented on the iss
Github user beyond1920 commented on the issue:
https://github.com/apache/flink/pull/2427
@mxm , thanks for your review. I had change the code based on your advice,
the changes are following:
1. move all code in the methods handleGrantLeadership, revokeLeadership,
onLeaderElectionE
[
https://issues.apache.org/jira/browse/FLINK-4516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15450755#comment-15450755
]
ASF GitHub Bot commented on FLINK-4516:
---
Github user beyond1920 commented on a diff
Github user beyond1920 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2427#discussion_r76912353
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/resourcemanager/ResourceManager.java
---
@@ -116,4 +142,78 @@ public SlotAssignment req
Github user beyond1920 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2427#discussion_r76910556
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/rpc/TestingSerialRpcService.java
---
@@ -0,0 +1,336 @@
+/*
+ * Licensed to the Apac
[
https://issues.apache.org/jira/browse/FLINK-4516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15450714#comment-15450714
]
ASF GitHub Bot commented on FLINK-4516:
---
Github user beyond1920 commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-4516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15450691#comment-15450691
]
ASF GitHub Bot commented on FLINK-4516:
---
Github user beyond1920 commented on a diff
Github user beyond1920 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2427#discussion_r76909719
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/rpc/TestingSerialRpcService.java
---
@@ -0,0 +1,336 @@
+/*
+ * Licensed to the Apac
[
https://issues.apache.org/jira/browse/FLINK-4516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15450685#comment-15450685
]
ASF GitHub Bot commented on FLINK-4516:
---
Github user beyond1920 commented on a diff
Github user beyond1920 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2427#discussion_r76909528
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/rpc/TestingSerialRpcService.java
---
@@ -0,0 +1,336 @@
+/*
+ * Licensed to the Apac
Github user vijikarthi commented on the issue:
https://github.com/apache/flink/pull/2275
@mxm I have rebased the code to the latest master. Please take a look.
---
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 proje
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15450140#comment-15450140
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user vijikarthi commented on the iss
[
https://issues.apache.org/jira/browse/FLINK-4245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15450018#comment-15450018
]
ASF GitHub Bot commented on FLINK-4245:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2418
it doesn't _have_ to be static., but then we would be back to square one
with users having to parse values from a string (the domain).
---
If your project is set up for it, you can reply to this emai
[
https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-4534:
--
Description:
Iteration over state.bucketStates is protected by synchronization in other
methods, except for the
[
https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-4534:
--
Description:
Iteration over state.bucketStates is protected by synchronization in other
methods, except for the
[
https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-4534:
--
Summary: Lack of synchronization in BucketingSink#restoreState() (was:
Lack of synchronization in BucketingSink
Ted Yu created FLINK-4534:
-
Summary: Lack of synchronization in BucketingSink#restoreState()
w.r.t. state.bucketStates
Key: FLINK-4534
URL: https://issues.apache.org/jira/browse/FLINK-4534
Project: Flink
Ted Yu created FLINK-4533:
-
Summary: Unprotected access to meters in StatsDReporter#report()
Key: FLINK-4533
URL: https://issues.apache.org/jira/browse/FLINK-4533
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-4514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15449397#comment-15449397
]
Tzu-Li (Gordon) Tai commented on FLINK-4514:
Resolved for master in
http://gi
[
https://issues.apache.org/jira/browse/FLINK-4514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-4514.
Resolution: Resolved
> ExpiredIteratorException in Kinesis Consumer on long catch-up
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2432
---
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-4514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15449379#comment-15449379
]
ASF GitHub Bot commented on FLINK-4514:
---
Github user asfgit closed the pull request
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2432
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 your project does not have this feature
enabled and wishes so, or if th
[
https://issues.apache.org/jira/browse/FLINK-4514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15449365#comment-15449365
]
ASF GitHub Bot commented on FLINK-4514:
---
Github user tzulitai commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-4347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15449357#comment-15449357
]
ASF GitHub Bot commented on FLINK-4347:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2388#discussion_r76822478
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/SlotID.java
---
@@ -75,9 +75,15 @@ public int hashCode() {
@O
[
https://issues.apache.org/jira/browse/FLINK-4514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15449354#comment-15449354
]
ASF GitHub Bot commented on FLINK-4514:
---
Github user tzulitai commented on the issue
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2432
Thanks for the confirmation.
The build will probably fail again due to an unused import:
https://travis-ci.org/tzulitai/flink/jobs/156191304, which was just hotfixed,
so we need to rebase again.
[
https://issues.apache.org/jira/browse/FLINK-4347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15449347#comment-15449347
]
ASF GitHub Bot commented on FLINK-4347:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-3580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15449345#comment-15449345
]
ASF GitHub Bot commented on FLINK-3580:
---
GitHub user twalthr opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15449344#comment-15449344
]
ASF GitHub Bot commented on FLINK-4347:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2388#discussion_r76821672
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/SlotID.java
---
@@ -75,9 +75,15 @@ public int hashCode() {
@O
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/2441
[FLINK-3580] [table] Add current time point functions
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2388#discussion_r76821590
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceID.java
---
@@ -63,9 +63,7 @@ public final int hashCode() {
[
https://issues.apache.org/jira/browse/FLINK-4347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15449317#comment-15449317
]
ASF GitHub Bot commented on FLINK-4347:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2388#discussion_r76819506
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/SlotManager.java
---
@@ -0,0 +1,525 @@
+/*
+ * Licensed to the Apache Sof
[
https://issues.apache.org/jira/browse/FLINK-4347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15449314#comment-15449314
]
ASF GitHub Bot commented on FLINK-4347:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2388#discussion_r76819301
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/SlotManager.java
---
@@ -0,0 +1,525 @@
+/*
+ * Licensed to the Apache Sof
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2427#discussion_r76816215
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/rpc/TestingSerialRpcService.java
---
@@ -0,0 +1,336 @@
+/*
+ * Licensed to the Apache Soft
[
https://issues.apache.org/jira/browse/FLINK-4516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15449286#comment-15449286
]
ASF GitHub Bot commented on FLINK-4516:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-4516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15449277#comment-15449277
]
ASF GitHub Bot commented on FLINK-4516:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2427#discussion_r76815420
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/rpc/TestingSerialRpcService.java
---
@@ -0,0 +1,336 @@
+/*
+ * Licensed to the Apache Soft
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2427#discussion_r76813885
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/resourcemanager/ResourceManager.java
---
@@ -116,4 +142,78 @@ public SlotAssignment requestSlo
[
https://issues.apache.org/jira/browse/FLINK-4516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15449247#comment-15449247
]
ASF GitHub Bot commented on FLINK-4516:
---
Github user mxm commented on a diff in the
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2432
+1
---
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
[
https://issues.apache.org/jira/browse/FLINK-4514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15449266#comment-15449266
]
ASF GitHub Bot commented on FLINK-4514:
---
Github user rmetzger commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-4516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15449260#comment-15449260
]
ASF GitHub Bot commented on FLINK-4516:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2427#discussion_r76813171
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/rpc/TestingSerialRpcService.java
---
@@ -0,0 +1,336 @@
+/*
+ * Licensed to the Apache Soft
[
https://issues.apache.org/jira/browse/FLINK-4520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15449216#comment-15449216
]
Hao Chen commented on FLINK-4520:
-
If there is no more problem, I would like to volunteer
[
https://issues.apache.org/jira/browse/FLINK-4516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15449232#comment-15449232
]
ASF GitHub Bot commented on FLINK-4516:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2427#discussion_r76811799
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/resourcemanager/ResourceManager.java
---
@@ -116,4 +142,78 @@ public SlotAssignment requestSlo
[
https://issues.apache.org/jira/browse/FLINK-4516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15449220#comment-15449220
]
ASF GitHub Bot commented on FLINK-4516:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2427#discussion_r76810632
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/resourcemanager/ResourceManager.java
---
@@ -116,4 +142,78 @@ public SlotAssignment requestSlo
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2427#discussion_r76810618
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/resourcemanager/ResourceManager.java
---
@@ -116,4 +142,78 @@ public SlotAssignment requestSlo
[
https://issues.apache.org/jira/browse/FLINK-4516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15449221#comment-15449221
]
ASF GitHub Bot commented on FLINK-4516:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-4516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15449218#comment-15449218
]
ASF GitHub Bot commented on FLINK-4516:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2427#discussion_r76810647
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/resourcemanager/ResourceManager.java
---
@@ -116,4 +142,78 @@ public SlotAssignment requestSlo
[
https://issues.apache.org/jira/browse/FLINK-4520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hao Chen updated FLINK-4520:
Description:
h1. Flink Siddhi CEP Integration Proposal
h2. About Siddhi CEP
Siddhi CEP is a lightweight, ea
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15449163#comment-15449163
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user mxm commented on the issue:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2275
Could you please rebase to the latest master and remove any merge commits?
---
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
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15449160#comment-15449160
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user mxm commented on the issue:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2275
Thanks for testing this on an actual secure cluster.
Hmpf, only allowing to bind to privileged ports doesn't really improve
security but we have to deal with this limitation somehow. I was initi
[
https://issues.apache.org/jira/browse/FLINK-4245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15449124#comment-15449124
]
ASF GitHub Bot commented on FLINK-4245:
---
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/2418#discussion_r76802688
--- Diff:
flink-metrics/flink-metrics-jmx/src/main/java/org/apache/flink/metrics/jmx/JMXReporter.java
---
@@ -143,23 +144,27 @@ public int getPort() {
[
https://issues.apache.org/jira/browse/FLINK-4245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15449116#comment-15449116
]
ASF GitHub Bot commented on FLINK-4245:
---
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/2418#discussion_r76802305
--- Diff:
flink-metrics/flink-metrics-jmx/src/main/java/org/apache/flink/metrics/jmx/JMXReporter.java
---
@@ -143,23 +144,27 @@ public int getPort() {
Github user mxm commented on the pull request:
https://github.com/apache/flink/commit/b13db273c200efe12f03b2e1328fce595303223d#commitcomment-18829963
In
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/store/StandaloneMesosWorkerStore.java:
In
flink-mesos
[
https://issues.apache.org/jira/browse/FLINK-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15449049#comment-15449049
]
ASF GitHub Bot commented on FLINK-4499:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2422
Does the runtime depend on the set of activated rules? If yes, should we
start with a very small set of rules that fail the build when triggered?
---
If your project is set up for it, you can re
[
https://issues.apache.org/jira/browse/FLINK-4245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15449042#comment-15449042
]
ASF GitHub Bot commented on FLINK-4245:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15449046#comment-15449046
]
ASF GitHub Bot commented on FLINK-4363:
---
Github user mxm commented on the issue:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2400
Could you please remove the merge commits from this PR? We don't use merge
commits in the Flink repository to have an easy to read code history. Thank you.
Thanks for opening FLINK-4505. For now,
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2418
Can the concatenation of the groups not be the "domain"? Currently, the
domain is static, but it does not have to be static, I think.
---
If your project is set up for it, you can reply to this
[
https://issues.apache.org/jira/browse/FLINK-4532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15449040#comment-15449040
]
Stephan Ewen commented on FLINK-4532:
-
Can you cover this by isolating running jobs vi
[
https://issues.apache.org/jira/browse/FLINK-4455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-4455:
Assignee: Till Rohrmann
> Replace ActorGateways in NetworkEnvironment by interfaces
> -
1 - 100 of 141 matches
Mail list logo
