public class StandaloneMiniCluster extends Object
FlinkMiniCluster
has been changed to use
the HighAvailabilityServices
. With this change we can no longer use the
RemoteEnvironment
to connect against the
FlinkMiniCluster
, because the remote environment cannot retrieve the current leader
session id.Constructor and Description |
---|
StandaloneMiniCluster(Configuration configuration) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
Configuration |
getConfiguration() |
String |
getHostname() |
int |
getPort() |
public StandaloneMiniCluster(Configuration configuration) throws Exception
Exception
public String getHostname()
public int getPort()
public Configuration getConfiguration()
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.