You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2018/07/11 10:05:26 UTC
[4/9] flink git commit: [FLINK-9730][refactor] Fix static accesses
via instance reference
[FLINK-9730][refactor] Fix static accesses via instance reference
This closes #6247.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cad6e4d3
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cad6e4d3
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/cad6e4d3
Branch: refs/heads/master
Commit: cad6e4d396e7b901b8c83257312860021f01c060
Parents: 5ee5dbf
Author: lamber-ken <!@#123zxcQ>
Authored: Wed Jul 4 02:36:43 2018 +0800
Committer: zentol <ch...@apache.org>
Committed: Wed Jul 11 12:05:08 2018 +0200
----------------------------------------------------------------------
.../org/apache/flink/streaming/examples/async/AsyncIOExample.java | 2 +-
.../apache/flink/queryablestate/network/AbstractServerHandler.java | 2 +-
.../java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java | 2 +-
3 files changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/cad6e4d3/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/async/AsyncIOExample.java
----------------------------------------------------------------------
diff --git a/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/async/AsyncIOExample.java b/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/async/AsyncIOExample.java
index 95379e3..7fd5f88 100644
--- a/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/async/AsyncIOExample.java
+++ b/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/async/AsyncIOExample.java
@@ -179,7 +179,7 @@ public class AsyncIOExample {
@Override
public void asyncInvoke(final Integer input, final ResultFuture<String> resultFuture) throws Exception {
- this.executorService.submit(new Runnable() {
+ executorService.submit(new Runnable() {
@Override
public void run() {
// wait for while to simulate async operation here
http://git-wip-us.apache.org/repos/asf/flink/blob/cad6e4d3/flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerHandler.java
----------------------------------------------------------------------
diff --git a/flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerHandler.java b/flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerHandler.java
index b2f7a47..fb835e3 100644
--- a/flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerHandler.java
+++ b/flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerHandler.java
@@ -165,7 +165,7 @@ public abstract class AbstractServerHandler<REQ extends MessageBody, RESP extend
@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
final String msg = "Exception in server pipeline. Caused by: " + ExceptionUtils.stringifyException(cause);
- final ByteBuf err = serializer.serializeServerFailure(ctx.alloc(), new RuntimeException(msg));
+ final ByteBuf err = MessageSerializer.serializeServerFailure(ctx.alloc(), new RuntimeException(msg));
LOG.debug(msg);
ctx.writeAndFlush(err).addListener(ChannelFutureListener.CLOSE);
http://git-wip-us.apache.org/repos/asf/flink/blob/cad6e4d3/flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java
----------------------------------------------------------------------
diff --git a/flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java b/flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java
index 636ae16..089d825 100644
--- a/flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java
+++ b/flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java
@@ -517,7 +517,7 @@ public abstract class AbstractYarnClusterDescriptor implements ClusterDescriptor
throw new YarnDeploymentException("Could not retrieve information about free cluster resources.", e);
}
- final int yarnMinAllocationMB = yarnConfiguration.getInt(yarnConfiguration.RM_SCHEDULER_MINIMUM_ALLOCATION_MB, 0);
+ final int yarnMinAllocationMB = yarnConfiguration.getInt(YarnConfiguration.RM_SCHEDULER_MINIMUM_ALLOCATION_MB, 0);
final ClusterSpecification validClusterSpecification;
try {