You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Cluster state management. PaceMakerStateStorageFactory to use pacemaker instead of Zookeeper.
storm.cluster.state.store: "org.apache.storm.cluster.PaceMakerStateStorageFactory"
Pacemaker servers and port configuration
pacemaker.servers: [""]
pacemaker.port: 6699
Minimal number of thread used to monitor topologies lifecycle
pacemaker.base.threads: 10
Maximal number of thread used to monitor topologies lifecycle
pacemaker.max.threads: 50
Number of maximum thread for each connected client
pacemaker.client.max.threads: 2
Cluster state management. PaceMakerStateStorageFactory to use pacemaker instead of Zookeeper.
storm.cluster.state.store: "org.apache.storm.cluster.PaceMakerStateStorageFactory"
Pacemaker servers and port configuration
pacemaker.servers: [""]
pacemaker.port: 6699
I submitted my topology
The topology is well submitted on the supervisor node
Observations:
I checked the from supervisor node and I am able to ping.
In the nimbus log, I observed that after a certain time the topology is reassigned because no heartbeat has been received inside Nimbus server from workers. I checked logs and content of sources and I observed that timestamps of heartbeats (time_secs and uptime_secs variables) are set into integer.
I have a test after year 2038 (ex: 2040) to validate my topology is not affected by Y2038 bug.
Context:
######################################
storm.cluster.state.store: "org.apache.storm.cluster.PaceMakerStateStorageFactory"
pacemaker.servers: [""]
pacemaker.port: 6699
pacemaker.base.threads: 10
pacemaker.max.threads: 50
pacemaker.client.max.threads: 2
pacemaker.thread.timeout: 10
pacemaker.childopts: "-Xmx4096m"
pacemaker.auth.method: "NONE"
pacemaker.kerberos.users: []
Size maximum of message sent by supervisor to pacemaker
pacemaker.thrift.message.size.max: 10485760
######################################
storm.cluster.state.store: "org.apache.storm.cluster.PaceMakerStateStorageFactory"
Pacemaker servers and port configuration
pacemaker.servers: [""]
pacemaker.port: 6699
Observations:
I checked the from supervisor node and I am able to ping.
In the nimbus log, I observed that after a certain time the topology is reassigned because no heartbeat has been received inside Nimbus server from workers. I checked logs and content of sources and I observed that timestamps of heartbeats (time_secs and uptime_secs variables) are set into integer.
This issue also been observed on 2.7.0 version.
Originally reported by alexisdureuil, imported from: Heartbeats mechanism is affected by Y2038 bug
The text was updated successfully, but these errors were encountered: