Hi the team, I want to read this znode to get partitions assigned to a dead participant: "<cluster name>/INSTANCES/<participant name>/CURRENTSTATES/<session id>/<resource name>"
I use this code snippet to read: accessor = new ZkBaseDataAccessor<ZNRecord>(zkClient); String path = xxxxx; ZNRecord record = accessor.get(path, null, AccessOption.PERSISTENT); Immediately at get() I got the following exception about invalid stream header. What's the "right" way to access that znode? Thanks! [ERROR 2016-06-06 16:43:22,214 com.hcd.hcdadmin.InstancePropertyAccessor:115] failed to read znode /shawn1/INSTANCES/node5_pp1/CURRENTSTATES/10000029c4a143b/Pool0 org.I0Itec.zkclient.exception.ZkMarshallingError: java.io.StreamCorruptedException: invalid stream header: 7B0A2020 at org.I0Itec.zkclient.serialize.SerializableSerializer.deserialize(SerializableSerializer.java:37) at org.apache.helix.manager.zk.BasicZkSerializer.deserialize(BasicZkSerializer.java:41) at org.apache.helix.manager.zk.ZkClient.deserialize(ZkClient.java:231) at org.apache.helix.manager.zk.ZkClient.readData(ZkClient.java:247) at org.I0Itec.zkclient.ZkClient.readData(ZkClient.java:761) at org.apache.helix.manager.zk.ZkBaseDataAccessor.get(ZkBaseDataAccessor.java:322) at com.hcd.hcdadmin.InstancePropertyAccessor.getReplicas(InstancePropertyAccessor.java:103) at com.hcd.hcdadmin.InstancePropertyAccessor.main(InstancePropertyAccessor.java:139) Caused by: java.io.StreamCorruptedException: invalid stream header: 7B0A2020 at java.io.ObjectInputStream.readStreamHeader(ObjectInputStream.java:808) at java.io.ObjectInputStream.<init>(ObjectInputStream.java:301) at org.I0Itec.zkclient.serialize.SerializableSerializer.deserialize(SerializableSerializer.java:31) ... 7 more
