[
https://issues.apache.org/jira/browse/FLINK-4255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15754310#comment-15754310
]
ASF GitHub Bot commented on FLINK-4255:
---------------------------------------
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3019#discussion_r92803960
--- Diff:
flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/WebRuntimeMonitorITCase.java
---
@@ -491,6 +445,37 @@ public void testNoCopyFromJar() throws Exception {
}
}
+ private WebRuntimeMonitor startWebRuntimeMonitor(
+ TestingCluster flink) throws Exception {
+
+ ActorSystem jmActorSystem =
flink.jobManagerActorSystems().get().head();
+ ActorRef jmActor = flink.jobManagerActors().get().head();
+
+ // Needs to match the leader address from the leader retrieval
service
+ String jobManagerAddress = AkkaUtils.getAkkaURL(jmActorSystem,
jmActor);
+
+ File logDir = temporaryFolder.newFolder("log");
+ Path logFile = Files.createFile(new File(logDir,
"jobmanager.log").toPath());
+ Files.createFile(new File(logDir, "jobmanager.out").toPath());
+
+ // Web frontend on random port
+ Configuration config = new Configuration();
+ config.setInteger(ConfigConstants.JOB_MANAGER_WEB_PORT_KEY, 0);
+ config.setString(ConfigConstants.JOB_MANAGER_WEB_LOG_PATH_KEY,
logFile.toString());
+
+ WebRuntimeMonitor webMonitor = new WebRuntimeMonitor(
+ config,
+ flink.createLeaderRetrievalService(),
+ jmActorSystem);
+
+ webMonitor.start(jobManagerAddress);
+ JobManagerRetriever retriever = Whitebox
+ .getInternalState(webMonitor, "retriever");
+
+ retriever.awaitJobManagerGatewayAndWebPort();
--- End diff --
instead you can call `flink.waitForActorsToBeAlive()`
> Unstable test WebRuntimeMonitorITCase.testNoEscape
> --------------------------------------------------
>
> Key: FLINK-4255
> URL: https://issues.apache.org/jira/browse/FLINK-4255
> Project: Flink
> Issue Type: Bug
> Reporter: Kostas Kloudas
> Assignee: Boris Osipov
> Labels: test-stability
>
> An instance of the problem can be found here:
> https://s3.amazonaws.com/archive.travis-ci.org/jobs/146615994/log.txt
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
