1. 云栖社区>
  2. 全部标签>
  3. #zookeeper#
zookeeper

#zookeeper#

已有2人关注此标签

内容分类:
博客 | 问答 | 视频 | 资料 |

阿里云上本地java应用连不上本地zookeeper

java.net.ConnectException: Connection refused at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) ~[na:1.7.0_18…

java native 服务器 Apache Server session Socket SUN zookeeper

HBase2.x的RIT问题

HBase2.x版本偶然遇到RIT问题,想了各种办法都没法消除。包括unassign(对应CLOSING状态)操作、hbck -repair(不支持)、删除Zookeeper下的rit信息节点(不存在),最终以强制删除表进行问题解决,请问有…

云栖社区 大数据 zookeeper

Kylin无法更新coprocessor

Kylin创建好cube后执行查询语句报错如下: 然后找资料说是,因为做了Hadoop的HA,需要更新HBase的协处理器: 执行的时候报错: 2019-04-15 10:23:55,412 DEBUG [main] cachesync.…

大数据 java hbase hadoop Apache zookeeper kylin

HBase写入数据报错“There is a hole in the region chain”

有个问题想请教大家,hbase region server 如果down了,按照hbase 默认的设置,比如zookeeper的180秒的超时设置,那是不是可能在3分钟内这个region server的数据都处于无法访问的状态?hbase从…

hbase Server zookeeper

flink可以监听kafka, mq等。可以监听文件,或者zookeeper嘛?如果有新的消息,flink要可以读取到。

转自钉钉群21789141:flink可以监听kafka, mq等。可以监听文件,或者zookeeper嘛?如果有新的消息,flink要可以读取到。

钉钉 zookeeper 流计算 flink 实时计算

用阿里云搭建的dubbo服务器,dubbo-admin上服务也都发布 了,但是访问页面报错,本地安装虚拟机linux运行dubbo就不报错,请问是什么原因

1、启动了两个service、一个web2、启动时未报错3、连接zookeeper正常,因为dubbo-admin上可看到服务4、访问页面报上述错误

系统研发与运维 linux 分布式 java 服务器 web zookeeper service

开启kerberos后 Hbase Replication报错

官网给出 不支持从非kerberos集群到kerberos集群的HBase对等复制,我现在测试 kerberos集群向非kerberos集群做数据复制时报错 ERROR client.ZooKeeperSaslClient: An err…

云栖社区 java hbase Apache 集群 测试 replication Security zookeeper big data

flume1.8整合 kafka2.10时,kafka消费者不能实时的接受flume发过来的数据?

以上是flume的配置文件 我执行了以下操作: flume提交命令: flume-ng agent -n a0 -f ../dir-kafka.conf -c conf -Dflume.root.logger=INFO,console…

大数据 配置 agent logger zookeeper

flink 从kafka消费,savepoint后,重启拓扑,kafka topic对应的offset值不是存到zookeeper了?

flink 从kafka消费,savepoint后,重启拓扑,kafka topic对应的offset值不是存到zookeeper了?

zookeeper flink

[@wangccsy][¥20]阿里云zookeeper外部无法访问,安全策略防火墙都设置好了

您好,我这边在阿里云专有网络搭建了zookeeper,但是外网无法访问,请问需要如何处理,这边安全策略已开启,且防火墙关闭。zookeeper监听端口为 *:2181,我在网上找了还能多例子都是设置安全策略的,我这边已经开启了还是不管用,…

网络与数据通信 linux 安全 mysql 防火墙 zookeeper

Flink 从Checkpoint恢复失败

import java.util.Properties import org.apache.flink.api.common.serialization.SimpleStringSchema import org.apache.flink…

java Apache runtime scala Security REST zookeeper checkpoint flink 实时计算

有个问题想请教大家,hbase region server 如果down了,按照hbase 默认的设置,比如zookeeper的180秒的超时设置,那是不是可能在3分钟内这个region server的数据都处于无法访问的状态?hbase从感知到region server挂掉到恢复是不是在分钟级别

有个问题想请教大家,hbase region server 如果down了,按照hbase 默认的设置,比如zookeeper的180秒的超时设置,那是不是可能在3分钟内这个region server的数据都处于无法访问的状态?hbase从…

大数据 hbase Server zookeeper

[@小川游鱼][¥20]kafka的消费者stream iterator block,读不出消息?

rt,能够向kafka produce数据,kafka里也看得到,但是consumer却读不出数据,offset是0,程序在stream的iterator被阻塞了。demo代码如下: import java.util.HashMap;im…

编程语言 java Consumer stream class PUT session Group Commit zookeeper hashmap

Job-Manager无法恢复Zookeeper检查点

我们在K8s环境中部署了Flink作业集群(1个作业管理器和1个任务管理器),并将其配置为HA模式(连接到Zookeeper)。该作业是有​​状态的,并且使用RocksDB后端启用了检查点。问题是从上一个检查点正确恢复了任务管理器重新启动…

性能 集群 zookeeper service flink

Flink kafka - Flink作业不向不同分区发送消息

我有以下配置: 一个带有2个分区的kafka主题一个zookeeper实例一个kafka实例两个具有相同组ID的消费者Flink工作片段: speStream.addSink(new FlinkKafkaProducer011(kafka…

服务器 eclipse 配置 zookeeper flink

Apache flink on Kubernetes - 如果jobmanager崩溃,恢复工作

我想在kubernetes上运行flink工作,使用(持久)状态后端,似乎 crashing taskmanagers 没有问题,因为他们可以向求职者询问他们需要从哪个检查点恢复,如果我理解正确的话。 crashing jobmanage…

Apache 集群 解决方案 zookeeper flink

[@talishboy][¥20]zookeeper实现的分布式锁与redis实现的分布式锁之间的区别,如何选取。以及使用中会出现的坑?

问题来自Java技术沙龙的李少伟Java技术沙龙报名链接:https://yq.aliyun.com/promotion/796

分布式 redis java aliyun zookeeper

使用单个JobManager进行恢复

我正在尝试恢复我的工作并说明当我的JobManager失败并且我无法成功重新开始工作时。 根据我的理解,JobManager恢复由JobManager辅助(这可以按预期工作),并通过Zookeeper完成JobManager恢复。 我想知…

docker Apache runtime file REST zookeeper flink

Flink HA JobManager集群无法选择leader

我正在尝试在kubernetes上部署Apache Flink 1.6。按照作业管理器高可用性 页面上的教程进行操作。我已经从它的日志中找到了一个有效的Zookeeper 3.10集群我可以看到它没有配置为Kerberos或SASL。所有…

服务器 高可用 配置 集群 HA zookeeper service flink

Beam jar无法在远程flink群集上运行

使用带有Flink 1.5.3的beam 2.6进行测试。beam运行本地flink runner没有问题。但无法在flink群集上运行。尝试mvn和flink提交作业。当使用mvn运行时,我用过: mvn clean package -…

java 服务器 Apache pipeline REST zookeeper flink

3
GO