org.apache.zookeeper.KeeperException$InvalidACLException: KeeperErrorCode = InvalidACL for /f
2017-10-26 18:07
4852 查看
在spark streaming中更新数据到zookeeper,第一次更新的时候可能会报如上错(from kafka_0.9),
解决方案就是在测试过程中临时加入如下代码: 目的是创建相对应的文件夹
ZkUtils(zkClient, false).updatePersistentPath(path="/consumers/groupId", data="groupId")
ZkUtils(zkClient, false).updatePersistentPath(path="/consumers/groupId/offsets", data="offset")
ZkUtils(zkClient, false).updatePersistentPath("/consumers/groupIdoffsets/topic1", "partiiton=12")
ZkUtils(zkClient, false).updatePersistentPath("/consumers/groupId/offsets/topic2", "partition=3")
// 提交部分
val zkPath = s"${topicDir.consumerOffsetDir}/${o.partition}"
ZkUtils(zkClient, isZkSecurityEnabled=false).updatePersistentPath(zkPath, offset)
解决方案就是在测试过程中临时加入如下代码: 目的是创建相对应的文件夹
ZkUtils(zkClient, false).updatePersistentPath(path="/consumers/groupId", data="groupId")
ZkUtils(zkClient, false).updatePersistentPath(path="/consumers/groupId/offsets", data="offset")
ZkUtils(zkClient, false).updatePersistentPath("/consumers/groupIdoffsets/topic1", "partiiton=12")
ZkUtils(zkClient, false).updatePersistentPath("/consumers/groupId/offsets/topic2", "partition=3")
// 提交部分
val zkPath = s"${topicDir.consumerOffsetDir}/${o.partition}"
ZkUtils(zkClient, isZkSecurityEnabled=false).updatePersistentPath(zkPath, offset)
相关文章推荐
- org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss for /eclipse20171118
- org.apache.zookeeper.KeeperException$NoAuthException: KeeperErrorCode = NoAuth for /nb-conf
- org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss for /
- bug宝典 hadoop篇 org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = Connec
- HBase 建表出错 org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = Co
- Caused by: org.apache.zookeeper.KeeperException$AuthFailedException: KeeperErrorCode = AuthFailed fo
- java.io.IOException: org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode =
- HBase shell 启动出错 org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = Con
- org.apache.storm.zookeeper.KeeperException.SystemErrorException
- Hive:KeeperErrorCode = InvalidACL for /hive/cluster/delegationMETASTORE/keys
- org.apache.tomcat.dbcp.dbcp.SQLNestedException: Cannot get a connection, pool error Timeout waiting for idle object异常原因
- Zookeeper异常Exception in thread "main" org.apache.zookeeper.KeeperExcep
- ERROR org.apache.kafka.common.errors.InvalidReplicationFactorException: replication factor: 3 larger
- hadoop错误org.apache.hadoop.util.DiskChecker$DiskErrorException Could not find any valid local directory for
- org.codehaus.xfire.XFireRuntimeException: Could not invoke service.. Server returned error code = 404 for URI.. Check server logs for details
- zookeeper启动错误 transaction type: 2 error: KeeperErrorCode = NoNode for /hbase
- java连接zookeeper服务器出现“KeeperErrorCode = ConnectionLoss for /test”
- 运行hbase时zookeepersession超时问题:KeeperErrorCode = Session expired for /hbase/master
- cygwin安装 hbase 报错:ClassNotFoundException: org.apache.zookeeper.KeeperException