Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2917
---
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 mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2917#discussion_r92661183
--- Diff: flink-runtime/pom.xml ---
@@ -193,8 +193,8 @@ under the License.
- com.typesafe.akka
-
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2917#discussion_r92659443
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/akka/AkkaUtils.scala ---
@@ -216,12 +219,19 @@ object AkkaUtils {
* identified by hostname
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2917#discussion_r92658704
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/akka/AkkaUtils.scala ---
@@ -216,12 +219,19 @@ object AkkaUtils {
* identified by hostname
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2917#discussion_r92658254
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/akka/AkkaUtils.scala ---
@@ -102,21 +102,24 @@ object AkkaUtils {
* specified, then the ac
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2917#discussion_r92626387
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/akka/AkkaUtils.scala ---
@@ -216,12 +219,19 @@ object AkkaUtils {
* identified by
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2917#discussion_r92626161
--- Diff: flink-core/src/main/java/org/apache/flink/util/NetUtils.java ---
@@ -111,7 +115,51 @@ public static int getAvailablePort() {
//
---
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2917#discussion_r92625848
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/akka/AkkaUtils.scala ---
@@ -216,12 +219,19 @@ object AkkaUtils {
* identified by
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2917#discussion_r92625229
--- Diff: flink-runtime/pom.xml ---
@@ -193,8 +193,8 @@ under the License.
- com.typesafe.akk
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2917#discussion_r92620428
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/akka/AkkaUtils.scala ---
@@ -102,21 +102,24 @@ object AkkaUtils {
* specified, th
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2917#discussion_r90627441
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -1891,8 +1891,8 @@ object JobManager {
// parsing the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2917#discussion_r90621937
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -2729,11 +2727,11 @@ object JobManager {
def getRemoteJ
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2917#discussion_r90621698
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -1891,8 +1891,8 @@ object JobManager {
// parsing the
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2917#discussion_r90511221
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -1891,8 +1891,8 @@ object JobManager {
// par
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2917#discussion_r90510382
--- Diff: flink-core/src/main/java/org/apache/flink/util/NetUtils.java ---
@@ -309,6 +313,19 @@ public static ServerSocket
createSocketFromPorts(Iterator
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/2917
[FLINK-2821] use custom Akka build to listen on all interfaces
This uses Flakka (a custom Akka 2.3 build) to resolve the issue that
the bind address needs to be matching the external address of the
16 matches
Mail list logo
