[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 <ches...@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 {
