Skip to content

Commit

Permalink
[hotfix] Fix the access modifiers in TaskManagerRunner
Browse files Browse the repository at this point in the history
  • Loading branch information
KarmaGYZ authored and tillrohrmann committed Jun 24, 2020
1 parent 77fd975 commit e716293
Showing 1 changed file with 7 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -18,6 +18,7 @@

package org.apache.flink.runtime.taskexecutor;

import org.apache.flink.annotation.VisibleForTesting;
import org.apache.flink.api.common.time.Time;
import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.configuration.Configuration;
Expand Down Expand Up @@ -92,7 +93,8 @@ public class TaskManagerRunner implements FatalErrorHandler, AutoCloseableAsync

private static final int STARTUP_FAILURE_RETURN_CODE = 1;

public static final int RUNTIME_FAILURE_RETURN_CODE = 2;
@VisibleForTesting
static final int RUNTIME_FAILURE_RETURN_CODE = 2;

private final Object lock = new Object();

Expand Down Expand Up @@ -414,9 +416,10 @@ static BackPressureSampleService createBackPressureSampleService(
* @param configuration The configuration for the TaskManager.
* @param haServices to use for the task manager hostname retrieval
*/
public static RpcService createRpcService(
final Configuration configuration,
final HighAvailabilityServices haServices) throws Exception {
@VisibleForTesting
static RpcService createRpcService(
final Configuration configuration,
final HighAvailabilityServices haServices) throws Exception {

checkNotNull(configuration);
checkNotNull(haServices);
Expand Down

0 comments on commit e716293

Please sign in to comment.