Skip to content

Instantly share code, notes, and snippets.

@Xeli

Xeli/gist:04f6d861c5478071521ac6d2c582832a Secret

Created July 17, 2019 17:12
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save Xeli/04f6d861c5478071521ac6d2c582832a to your computer and use it in GitHub Desktop.
Save Xeli/04f6d861c5478071521ac6d2c582832a to your computer and use it in GitHub Desktop.
Download ZIP
Raw
gistfile1.txt
[zk: localhost:2181(CONNECTED) 6] ls /flink/hunch
[jobgraphs, leader, checkpoints, leaderlatch, checkpoint-counter, running_job_registry]
[zk: localhost:2181(CONNECTED) 7] ls /flink/hunch/running_job_registry
[1dccee15d84e1d2cededf89758ac2482]
[zk: localhost:2181(CONNECTED) 8] ls /flink/hunch/jobgraphs
[e6ad857af7f09b56594e95fe273e9eff, 1dccee15d84e1d2cededf89758ac2482]
[zk: localhost:2181(CONNECTED) 9] ls /flink/hunch/jobgraphs/1dccee15d84e1d2cededf89758ac2482
[]
[zk: localhost:2181(CONNECTED) 10] get /flink/hunch/jobgraphs/1dccee15d84e1d2cededf89758ac2482
??sr;org.apache.flink.runtime.state.RetrievableStreamStateHandle?U?+LwrappedStreamStateHandlet2Lorg/apache/flink/runtime/state/StreamStateHandle;xpsr9org.apache.flink.runtime.state.filesystem.FileStateHandle?u?b?J stateSizefilePathtLorg/apache/flink/core/fs/Path;xpq?srorg.apache.flink.core.fs.PathLuritLjava/net/URI;xpsr
java.net.URI?x.C?I?LstringtLjava/lang/String;xptLgs://some-project-flink-state/recovery/submittedJobGraph70dc131e0ce4x
cZxid = 0x300000499
ctime = Wed Jul 17 14:04:57 UTC 2019
mZxid = 0x300000499
mtime = Wed Jul 17 14:04:57 UTC 2019
pZxid = 0x4000000ed
cversion = 66
dataVersion = 0
aclVersion = 0
ephemeralOwner = 0x0
dataLength = 507
numChildren = 0
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment