Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/2366
The unification looks great and now things are simple in terms of
restoration. Thanks.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as we
[
https://issues.apache.org/jira/browse/FLINK-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15425928#comment-15425928
]
ASF GitHub Bot commented on FLINK-4322:
---
Github user ramkrish86 commented on the iss
[
https://issues.apache.org/jira/browse/FLINK-4420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15425912#comment-15425912
]
ASF GitHub Bot commented on FLINK-4420:
---
GitHub user wuchong opened a pull request:
GitHub user wuchong opened a pull request:
https://github.com/apache/flink/pull/2384
[FLINK-4420] [table] Introduce star(*) to select all of the columns in the
table
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list int
Jark Wu created FLINK-4420:
--
Summary: Introduce star(*) to select all of the columns in the
table
Key: FLINK-4420
URL: https://issues.apache.org/jira/browse/FLINK-4420
Project: Flink
Issue Type: Ne
[
https://issues.apache.org/jira/browse/FLINK-4271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15425903#comment-15425903
]
ASF GitHub Bot commented on FLINK-4271:
---
Github user wuchong commented on the issue:
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/2305
I'm ok with the `with(...)` approach. In addition, we should create a JIRA
under [FLINK-3957]
"Breaking API changes for Flink 2.0", to keep track of deprecating and
changing the `apply` method r
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/2342
@uce
I saw that there were conflicts after yesterday's updates to the master.
Hence I have rebased my PR and force pushed the changes. Thanks.
---
If your project is set up for it, you can r
[
https://issues.apache.org/jira/browse/FLINK-4253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15425900#comment-15425900
]
ASF GitHub Bot commented on FLINK-4253:
---
Github user ramkrish86 commented on the iss
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/2342
@uce
The test case failures seems to be unrelated. Want to have a look at the
updated PR?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitH
[
https://issues.apache.org/jira/browse/FLINK-4253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15425876#comment-15425876
]
ASF GitHub Bot commented on FLINK-4253:
---
Github user ramkrish86 commented on the iss
shuai.xu created FLINK-4419:
---
Summary: Batch improvement for supporting dfs as a
ResultPartitionType
Key: FLINK-4419
URL: https://issues.apache.org/jira/browse/FLINK-4419
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-4406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenlong Lyu reassigned FLINK-4406:
--
Assignee: Wenlong Lyu
> Implement job master registration at resource manager
> ---
[
https://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15425768#comment-15425768
]
Renkai Ge commented on FLINK-4282:
--
Hi, [~aljoscha]. I changed the code as your last prop
[
https://issues.apache.org/jira/browse/FLINK-4418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15425664#comment-15425664
]
ASF GitHub Bot commented on FLINK-4418:
---
GitHub user rehevkor5 opened a pull request
GitHub user rehevkor5 opened a pull request:
https://github.com/apache/flink/pull/2383
[FLINK-4418] [client] Improve resilience when InetAddress.getLocalHosâ¦
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consi
[
https://issues.apache.org/jira/browse/FLINK-4418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shannon Carey updated FLINK-4418:
-
Description:
When attempting to connect to a cluster with a ClusterClient, if the machine's
hostn
Shannon Carey created FLINK-4418:
Summary: ClusterClient/ConnectionUtils#findConnectingAddress fails
immediately if InetAddress.getLocalHost throws exception
Key: FLINK-4418
URL: https://issues.apache.org/jira/bro
[
https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15425510#comment-15425510
]
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_r75219490
--- Diff:
flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/util/TestMeter.java
---
@@ -0,0 +1,55 @@
+/*
+ * Licensed to the Apa
[
https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Scott Kidder updated FLINK-4341:
Affects Version/s: 1.1.1
> Checkpoint state size grows unbounded when task parallelism not uniform
>
[
https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15425408#comment-15425408
]
Scott Kidder commented on FLINK-4341:
-
I repeated my tests using Flink 1.1.1 and conti
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15425389#comment-15425389
]
Josep Rubió edited comment on FLINK-1707 at 8/17/16 9:13 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15425389#comment-15425389
]
Josep Rubió edited comment on FLINK-1707 at 8/17/16 9:12 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15425389#comment-15425389
]
Josep Rubió edited comment on FLINK-1707 at 8/17/16 9:12 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15425389#comment-15425389
]
Josep Rubió edited comment on FLINK-1707 at 8/17/16 9:12 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15425389#comment-15425389
]
Josep Rubió commented on FLINK-1707:
Hi [~vkalavri],
I changed the implementation now
[
https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15425346#comment-15425346
]
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
Hi @zentol I've updated the PR according to your suggestions.
About the Meter interface I think we can make it more flexible in two ways:
* Update Meter to support variable number of rat
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15425292#comment-15425292
]
Jamie Grier commented on FLINK-4391:
[~maguowei] Do you have any sense of when you mig
GitHub user nssalian opened a pull request:
https://github.com/apache/flink/pull/2382
FLINK-4402: Wrong metrics parameter names in documentation
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
I
[
https://issues.apache.org/jira/browse/FLINK-4402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15425222#comment-15425222
]
ASF GitHub Bot commented on FLINK-4402:
---
GitHub user nssalian opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15425213#comment-15425213
]
ASF GitHub Bot commented on FLINK-4245:
---
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/2300#discussion_r75190837
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/AbstractMetricGroup.java
---
@@ -83,9 +88,25 @@
//
--
Github user cresny commented on the issue:
https://github.com/apache/flink/pull/2288
refactored commit here:
https://github.com/apache/flink/pull/2288/commits/8505e9c77f5ed79542af259f007be2c3a29edbc5
self-tested working in upstream master
---
If your project is set up for it
[
https://issues.apache.org/jira/browse/FLINK-4402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neelesh Srinivas Salian reassigned FLINK-4402:
--
Assignee: Neelesh Srinivas Salian
> Wrong metrics parameter names in do
[
https://issues.apache.org/jira/browse/FLINK-4402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15425084#comment-15425084
]
Neelesh Srinivas Salian commented on FLINK-4402:
Thank you. Posting a PR s
[
https://issues.apache.org/jira/browse/FLINK-4402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15425039#comment-15425039
]
RWenden commented on FLINK-4402:
Ok with me.
> Wrong metrics parameter names in documenta
[
https://issues.apache.org/jira/browse/FLINK-4271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15425006#comment-15425006
]
ASF GitHub Bot commented on FLINK-4271:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2305
I would like to come to an agreement with everyone how to proceed.
From the discussion on the mailing list, I see that quite some people are
opposed to breaking the compatibility unless w
[
https://issues.apache.org/jira/browse/FLINK-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4322.
---
> Unify CheckpointCoordinator and SavepointCoordinator
> -
[
https://issues.apache.org/jira/browse/FLINK-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424997#comment-15424997
]
ASF GitHub Bot commented on FLINK-4322:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4322.
-
Resolution: Fixed
Assignee: Stephan Ewen
Fixed via 76ca1a7955fedd8583a0af12289a14d0f1bcf868
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2366
Looked very good. Fixed a minor issue (test log level) and merged 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 pro
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2366
---
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-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424993#comment-15424993
]
ASF GitHub Bot commented on FLINK-4322:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424942#comment-15424942
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2315
Great work @EronWright. Code quality, testing and extent of this PR is
really impressive :-) I think you've nicely modularized the Mesos resource
manager with the additional actors. This makes t
[
https://issues.apache.org/jira/browse/FLINK-4414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424913#comment-15424913
]
ASF GitHub Bot commented on FLINK-4414:
---
Github user wenlong88 commented on the issu
Github user wenlong88 commented on the issue:
https://github.com/apache/flink/pull/2381
If there is a `RpcGateway.getAddress`, it will be more friendly in api.
But I also think mixing the user defined RPC methods and framework interfaces
will be a bit of odd and needs specific proces
[
https://issues.apache.org/jira/browse/FLINK-4409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424902#comment-15424902
]
ASF GitHub Bot commented on FLINK-4409:
---
Github user StephanEwen closed the pull req
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2378
Manually merged in c894896a45f895997567d5c4e86f9ca25e542e52
---
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
Github user StephanEwen closed the pull request at:
https://github.com/apache/flink/pull/2378
---
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-4409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424901#comment-15424901
]
ASF GitHub Bot commented on FLINK-4409:
---
Github user StephanEwen commented on the is
Stephan Ewen created FLINK-4417:
---
Summary: Checkpoints should be subsumed by CheckpointID not, by
timestamp
Key: FLINK-4417
URL: https://issues.apache.org/jira/browse/FLINK-4417
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424865#comment-15424865
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user vijikarthi commented on the iss
Github user vijikarthi commented on the issue:
https://github.com/apache/flink/pull/2275
@mxm - Could you please take a look and let me know if you need any further
changes.
---
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-4414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424843#comment-15424843
]
ASF GitHub Bot commented on FLINK-4414:
---
Github user wenlong88 commented on a diff i
Github user wenlong88 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2381#discussion_r75157339
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcService.java
---
@@ -197,11 +201,11 @@ public void stopService() {
}
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424837#comment-15424837
]
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_r75156694
--- Diff: flink-mesos/src/test/resources/log4j-test.properties ---
@@ -0,0 +1,32 @@
+
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424825#comment-15424825
]
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_r75154390
--- Diff:
flink-mesos/src/main/scala/org/apache/flink/runtime/clusterframework/ContaineredJobManager.scala
---
@@ -0,0 +1,174 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-4387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424813#comment-15424813
]
Ufuk Celebi commented on FLINK-4387:
Fixed in f791680 (master). In the newly introduce
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424811#comment-15424811
]
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_r75153237
--- Diff:
flink-mesos/src/main/scala/org/apache/flink/mesos/scheduler/LaunchCoordinator.scala
---
@@ -0,0 +1,349 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-4245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424800#comment-15424800
]
ASF GitHub Bot commented on FLINK-4245:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2300#discussion_r75152566
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/AbstractMetricGroup.java
---
@@ -83,9 +88,25 @@
//
-
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424783#comment-15424783
]
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_r75151735
--- Diff:
flink-mesos/src/main/scala/org/apache/flink/runtime/clusterframework/ContaineredJobManager.scala
---
@@ -0,0 +1,174 @@
+/*
+ * License
Maximilian Michels created FLINK-4416:
-
Summary: Provide a programmatic way to load a Yarn config
Key: FLINK-4416
URL: https://issues.apache.org/jira/browse/FLINK-4416
Project: Flink
Issu
[
https://issues.apache.org/jira/browse/FLINK-4409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424770#comment-15424770
]
Stephan Ewen commented on FLINK-4409:
-
[~RenkaiGe] I have pushed the fix into the 1.2-
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424766#comment-15424766
]
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_r75150474
--- Diff:
flink-mesos/src/main/scala/org/apache/flink/mesos/scheduler/Tasks.scala ---
@@ -0,0 +1,114 @@
+/*
+ * Licensed to the Apache Software F
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424758#comment-15424758
]
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_r75149938
--- Diff:
flink-mesos/src/main/scala/org/apache/flink/mesos/scheduler/Tasks.scala ---
@@ -0,0 +1,114 @@
+/*
+ * Licensed to the Apache Software F
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r75149129
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/store/ZooKeeperMesosWorkerStore.java
---
@@ -0,0 +1,290 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424744#comment-15424744
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424729#comment-15424729
]
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_r75147221
--- Diff:
flink-mesos/src/main/scala/org/apache/flink/mesos/scheduler/LaunchCoordinator.scala
---
@@ -0,0 +1,349 @@
+/*
+ * Licensed to the Apac
[
https://issues.apache.org/jira/browse/FLINK-4415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-4415:
Assignee: Kostas Kloudas
> Enhance Trigger Interface with onFire() and onCleanup()
> ---
Aljoscha Krettek created FLINK-4415:
---
Summary: Enhance Trigger Interface with onFire() and onCleanup()
Key: FLINK-4415
URL: https://issues.apache.org/jira/browse/FLINK-4415
Project: Flink
I
Github user EronWright commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r75140675
--- Diff:
flink-mesos/src/main/scala/org/apache/flink/mesos/scheduler/LaunchCoordinator.scala
---
@@ -0,0 +1,349 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424670#comment-15424670
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user EronWright commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-4414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424678#comment-15424678
]
ASF GitHub Bot commented on FLINK-4414:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2381
Maybe it makes more sense to extends `RpcGateway` interface and offer a
getAddress method which returns the remote address of the gateway. We should
also add tests.
---
If your project is set
[
https://issues.apache.org/jira/browse/FLINK-4414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424672#comment-15424672
]
ASF GitHub Bot commented on FLINK-4414:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2381#discussion_r75140948
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcService.java
---
@@ -197,11 +201,11 @@ public void stopService() {
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424665#comment-15424665
]
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_r75139941
--- Diff:
flink-mesos/src/main/scala/org/apache/flink/mesos/scheduler/ConnectionMonitor.scala
---
@@ -0,0 +1,126 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424663#comment-15424663
]
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_r75139688
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/util/ZooKeeperUtils.java ---
@@ -0,0 +1,40 @@
+/*
+ * Licensed to the Apache Software Fo
[
https://issues.apache.org/jira/browse/FLINK-4414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424660#comment-15424660
]
ASF GitHub Bot commented on FLINK-4414:
---
Github user tillrohrmann commented on the i
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424662#comment-15424662
]
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_r75139611
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/util/ZooKeeperUtils.java ---
@@ -0,0 +1,40 @@
+/*
+ * Licensed to the Apache Software Fo
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2381
Thanks for your contribution @wenlong88. The PR mixes multiple things
together. It would be better if you could separate these changes.
---
If your project is set up for it, you can reply to th
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424652#comment-15424652
]
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_r75138892
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/store/ZooKeeperMesosWorkerStore.java
---
@@ -0,0 +1,290 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-4281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-4281.
-
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed in 7ce42c2e7e332b0fafd19a3f9ed49e4554958fdd.
[
https://issues.apache.org/jira/browse/FLINK-4281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424640#comment-15424640
]
ASF GitHub Bot commented on FLINK-4281:
---
Github user asfgit closed the pull request
1 - 100 of 322 matches
Mail list logo