已有2人关注此标签
阿里云上本地java应用连不上本地zookeeper
作者： 游客h677xkqjsqs4e
47人浏览
1人回答
java.net.ConnectException: Connection refused at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) ~[na:1.7.0_18…
HBase2.x的RIT问题
作者： 游客tc2llo5wqhuqa
108人浏览
0人回答
HBase2.x版本偶然遇到RIT问题，想了各种办法都没法消除。包括unassign(对应CLOSING状态)操作、hbck -repair(不支持)、删除Zookeeper下的rit信息节点(不存在)，最终以强制删除表进行问题解决，请问有…
Kylin无法更新coprocessor
作者： mz111
298人浏览
2人回答
Kylin创建好cube后执行查询语句报错如下： 然后找资料说是，因为做了Hadoop的HA，需要更新HBase的协处理器： 执行的时候报错： 2019-04-15 10:23:55,412 DEBUG [main] cachesync.…
HBase写入数据报错“There is a hole in the region chain”
作者： hbase小能手
182人浏览
1人回答
有个问题想请教大家，hbase region server 如果down了，按照hbase 默认的设置，比如zookeeper的180秒的超时设置，那是不是可能在3分钟内这个region server的数据都处于无法访问的状态?hbase从…
flink可以监听kafka, mq等。可以监听文件，或者zookeeper嘛？如果有新的消息，flink要可以读取到。
作者： 赵慧
338人浏览
1人回答
转自钉钉群21789141：flink可以监听kafka, mq等。可以监听文件，或者zookeeper嘛？如果有新的消息，flink要可以读取到。
用阿里云搭建的dubbo服务器，dubbo-admin上服务也都发布 了，但是访问页面报错，本地安装虚拟机linux运行dubbo就不报错，请问是什么原因
作者： siyubansaluo
677人浏览
1人回答
1、启动了两个service、一个web2、启动时未报错3、连接zookeeper正常，因为dubbo-admin上可看到服务4、访问页面报上述错误
开启kerberos后 Hbase Replication报错
作者： 愚笨的超哥
364人浏览
1人回答
官网给出 不支持从非kerberos集群到kerberos集群的HBase对等复制，我现在测试 kerberos集群向非kerberos集群做数据复制时报错 ERROR client.ZooKeeperSaslClient: An err…
flume1.8整合 kafka2.10时，kafka消费者不能实时的接受flume发过来的数据？
作者： billlilililili
568人浏览
1人回答
以上是flume的配置文件 我执行了以下操作: flume提交命令: flume-ng agent -n a0 -f ../dir-kafka.conf -c conf -Dflume.root.logger=INFO,console…
flink 从kafka消费,savepoint后，重启拓扑，kafka topic对应的offset值不是存到zookeeper了？
作者： flink小助手
383人浏览
1人回答
flink 从kafka消费,savepoint后，重启拓扑，kafka topic对应的offset值不是存到zookeeper了？
[@wangccsy][¥20]阿里云zookeeper外部无法访问，安全策略防火墙都设置好了
作者： 怀喆
1551人浏览
1人回答
您好，我这边在阿里云专有网络搭建了zookeeper，但是外网无法访问，请问需要如何处理，这边安全策略已开启，且防火墙关闭。zookeeper监听端口为 *:2181，我在网上找了还能多例子都是设置安全策略的，我这边已经开启了还是不管用，…
Flink 从Checkpoint恢复失败
作者： 冷丰
1326人浏览
1人回答
import java.util.Properties import org.apache.flink.api.common.serialization.SimpleStringSchema import org.apache.flink…
有个问题想请教大家，hbase region server 如果down了，按照hbase 默认的设置，比如zookeeper的180秒的超时设置，那是不是可能在3分钟内这个region server的数据都处于无法访问的状态?hbase从感知到region server挂掉到恢复是不是在分钟级别
作者： hbase小能手
336人浏览
1人回答
有个问题想请教大家，hbase region server 如果down了，按照hbase 默认的设置，比如zookeeper的180秒的超时设置，那是不是可能在3分钟内这个region server的数据都处于无法访问的状态?hbase从…
[@小川游鱼][¥20]kafka的消费者stream iterator block，读不出消息？
作者： 晓生寒
329人浏览
0人回答
rt，能够向kafka produce数据，kafka里也看得到，但是consumer却读不出数据，offset是0，程序在stream的iterator被阻塞了。demo代码如下： import java.util.HashMap;im…
Job-Manager无法恢复Zookeeper检查点
作者： flink小助手
312人浏览
1人回答
我们在K8s环境中部署了Flink作业集群（1个作业管理器和1个任务管理器），并将其配置为HA模式（连接到Zookeeper）。该作业是有状态的，并且使用RocksDB后端启用了检查点。问题是从上一个检查点正确恢复了任务管理器重新启动…
Flink kafka - Flink作业不向不同分区发送消息
作者： 社区小助手
552人浏览
1人回答
我有以下配置： 一个带有2个分区的kafka主题一个zookeeper实例一个kafka实例两个具有相同组ID的消费者Flink工作片段： speStream.addSink(new FlinkKafkaProducer011(kafka…
Apache flink on Kubernetes - 如果jobmanager崩溃，恢复工作
作者： 社区小助手
611人浏览
1人回答
我想在kubernetes上运行flink工作，使用（持久）状态后端，似乎 crashing taskmanagers 没有问题，因为他们可以向求职者询问他们需要从哪个检查点恢复，如果我理解正确的话。 crashing jobmanage…
[@talishboy][¥20]zookeeper实现的分布式锁与redis实现的分布式锁之间的区别，如何选取。以及使用中会出现的坑？
作者： 李博 bluemind
274人浏览
1人回答
问题来自Java技术沙龙的李少伟Java技术沙龙报名链接：https://yq.aliyun.com/promotion/796
使用单个JobManager进行恢复
作者： flink小助手
378人浏览
1人回答
我正在尝试恢复我的工作并说明当我的JobManager失败并且我无法成功重新开始工作时。 根据我的理解，JobManager恢复由JobManager辅助（这可以按预期工作），并通过Zookeeper完成JobManager恢复。 我想知…
Flink HA JobManager集群无法选择leader
作者： flink小助手
814人浏览
2人回答
我正在尝试在kubernetes上部署Apache Flink 1.6。按照作业管理器高可用性 页面上的教程进行操作。我已经从它的日志中找到了一个有效的Zookeeper 3.10集群我可以看到它没有配置为Kerberos或SASL。所有…
Beam jar无法在远程flink群集上运行
作者： flink小助手
438人浏览
1人回答
使用带有Flink 1.5.3的beam 2.6进行测试。beam运行本地flink runner没有问题。但无法在flink群集上运行。尝试mvn和flink提交作业。当使用mvn运行时，我用过： mvn clean package -…
