public class FlinkZooKeeperQuorumPeer extends Object
QuorumPeer
, which reads a ZooKeeper config file and writes
the required 'myid' file before starting the peer.Constructor and Description |
---|
FlinkZooKeeperQuorumPeer() |
Modifier and Type | Method and Description |
---|---|
static void |
main(String[] args) |
static void |
runFlinkZkQuorumPeer(String zkConfigFile,
int peerId)
Runs a ZooKeeper
QuorumPeer if further peers are configured or a single
ZooKeeperServer if no further peers are configured. |
public static void main(String[] args)
public static void runFlinkZkQuorumPeer(String zkConfigFile, int peerId) throws Exception
QuorumPeer
if further peers are configured or a single
ZooKeeperServer
if no further peers are configured.zkConfigFile
- ZooKeeper config file 'zoo.cfg'peerId
- ID for the 'myid' fileException
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.