热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

flink链接redis时候,集群closedown是否会重连

错误日志如下:2022-08-0517:56:05,465ERRORcom.vip.realtime.data.association.connec

错误日志如下:

2022-08-05 17:56:05,465 ERROR com.vip.realtime.data.association.connector.dimtable.nosql.redis.RedisDimTable [] - RedisDimTable get data exception,{}
redis.clients.jedis.exceptions.JedisClusterException: CLUSTERDOWN The cluster is down
at redis.clients.jedis.Protocol.processError(Protocol.java:126) ~[blob_p-c8c0fac8df1ae0b55a32941a394d36cc7d425a3a-82fb806e7e23e00c7c21c71952decfce:?]
at redis.clients.jedis.Protocol.process(Protocol.java:166) ~[blob_p-c8c0fac8df1ae0b55a32941a394d36cc7d425a3a-82fb806e7e23e00c7c21c71952decfce:?]
at redis.clients.jedis.Protocol.read(Protocol.java:220) ~[blob_p-c8c0fac8df1ae0b55a32941a394d36cc7d425a3a-82fb806e7e23e00c7c21c71952decfce:?]
at redis.clients.jedis.Connection.readProtocolWithCheckingBroken(Connection.java:318) ~[blob_p-c8c0fac8df1ae0b55a32941a394d36cc7d425a3a-82fb806e7e23e00c7c21c71952decfce:?]
at redis.clients.jedis.Connection.getBinaryBulkReply(Connection.java:255) ~[blob_p-c8c0fac8df1ae0b55a32941a394d36cc7d425a3a-82fb806e7e23e00c7c21c71952decfce:?]
at redis.clients.jedis.Connection.getBulkReply(Connection.java:245) ~[blob_p-c8c0fac8df1ae0b55a32941a394d36cc7d425a3a-82fb806e7e23e00c7c21c71952decfce:?]
at redis.clients.jedis.Jedis.get(Jedis.java:181) ~[blob_p-c8c0fac8df1ae0b55a32941a394d36cc7d425a3a-82fb806e7e23e00c7c21c71952decfce:?]
at redis.clients.jedis.JedisCluster$3.execute(JedisCluster.java:161) ~[blob_p-c8c0fac8df1ae0b55a32941a394d36cc7d425a3a-82fb806e7e23e00c7c21c71952decfce:?]
at redis.clients.jedis.JedisCluster$3.execute(JedisCluster.java:158) ~[blob_p-c8c0fac8df1ae0b55a32941a394d36cc7d425a3a-82fb806e7e23e00c7c21c71952decfce:?]
at redis.clients.jedis.JedisClusterCommand.runWithRetries(JedisClusterCommand.java:106) ~[blob_p-c8c0fac8df1ae0b55a32941a394d36cc7d425a3a-82fb806e7e23e00c7c21c71952decfce:?]
at redis.clients.jedis.JedisClusterCommand.run(JedisClusterCommand.java:25) ~[blob_p-c8c0fac8df1ae0b55a32941a394d36cc7d425a3a-82fb806e7e23e00c7c21c71952decfce:?]
at redis.clients.jedis.JedisCluster.get(JedisCluster.java:163) ~[blob_p-c8c0fac8df1ae0b55a32941a394d36cc7d425a3a-82fb806e7e23e00c7c21c71952decfce:?]
at com.vip.realtime.data.association.connector.dimtable.nosql.redis.RedisDimTable$1.call(RedisDimTable.java:67) ~[blob_p-c8c0fac8df1ae0b55a32941a394d36cc7d425a3a-82fb806e7e23e00c7c21c71952decfce:?]
at com.vip.realtime.data.association.connector.dimtable.nosql.redis.RedisDimTable.get(RedisDimTable.java:92) ~[blob_p-c8c0fac8df1ae0b55a32941a394d36cc7d425a3a-82fb806e7e23e00c7c21c71952decfce:?]
at com.vip.realtime.data.association.dimtable.user.info.service.UserInfoService.getUserType(UserInfoService.java:332) ~[blob_p-c8c0fac8df1ae0b55a32941a394d36cc7d425a3a-82fb806e7e23e00c7c21c71952decfce:?]
at com.vip.realtime.data.association.dimtable.user.info.service.UserInfoService.getUserInfo(UserInfoService.java:189) ~[blob_p-c8c0fac8df1ae0b55a32941a394d36cc7d425a3a-82fb806e7e23e00c7c21c71952decfce:?]
at com.vip.realtime.data.association.logic.service.app_activityinfo.APPActivityInfoDoAssociationMain.doUserAssociation(APPActivityInfoDoAssociationMain.java:143) ~[blob_p-c8c0fac8df1ae0b55a32941a394d36cc7d425a3a-82fb806e7e23e00c7c21c71952decfce:?]
at com.vip.realtime.data.association.logic.service.app_activityinfo.APPActivityInfoDoAssociationMain.execute(APPActivityInfoDoAssociationMain.java:72) ~[blob_p-c8c0fac8df1ae0b55a32941a394d36cc7d425a3a-82fb806e7e23e00c7c21c71952decfce:?]
at com.vip.realtime.data.association.logic.service.app_activityinfo.APPActivityInfoDoAssociationMain.execute(APPActivityInfoDoAssociationMain.java:39) ~[blob_p-c8c0fac8df1ae0b55a32941a394d36cc7d425a3a-82fb806e7e23e00c7c21c71952decfce:?]
at com.vip.realtime.data.association.connector.base.processor.FieldGroupProcessorProxy.execute(FieldGroupProcessorProxy.java:47) ~[blob_p-c8c0fac8df1ae0b55a32941a394d36cc7d425a3a-82fb806e7e23e00c7c21c71952decfce:?]
at com.vip.realtime.data.association.runner.functions.CustomKeyProcessFunc.processElement(CustomKeyProcessFunc.java:70) ~[blob_p-c8c0fac8df1ae0b55a32941a394d36cc7d425a3a-82fb806e7e23e00c7c21c71952decfce:?]
at org.apache.flink.streaming.api.operators.KeyedProcessOperator.processElement(KeyedProcessOperator.java:83) ~[flink-dist_2.11-1.13-SNAPSHOT.jar:1.13-SNAPSHOT]
at org.apache.flink.streaming.runtime.tasks.OneInputStreamTask$StreamTaskNetworkOutput.emitRecord(OneInputStreamTask.java:205) ~[flink-dist_2.11-1.13-SNAPSHOT.jar:1.13-SNAPSHOT]
at org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.processElement(AbstractStreamTaskNetworkInput.java:134) ~[flink-dist_2.11-1.13-SNAPSHOT.jar:1.13-SNAPSHOT]
at org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.emitNext(AbstractStreamTaskNetworkInput.java:105) ~[flink-dist_2.11-1.13-SNAPSHOT.jar:1.13-SNAPSHOT]
at org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:66) ~[flink-dist_2.11-1.13-SNAPSHOT.jar:1.13-SNAPSHOT]
at org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:423) ~[flink-dist_2.11-1.13-SNAPSHOT.jar:1.13-SNAPSHOT]
at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:204) ~[flink-dist_2.11-1.13-SNAPSHOT.jar:1.13-SNAPSHOT]
at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:681) ~[flink-dist_2.11-1.13-SNAPSHOT.jar:1.13-SNAPSHOT]
at org.apache.flink.streaming.runtime.tasks.StreamTask.executeInvoke(StreamTask.java:636) ~[flink-dist_2.11-1.13-SNAPSHOT.jar:1.13-SNAPSHOT]
at org.apache.flink.streaming.runtime.tasks.StreamTask.runWithCleanUpOnFail(StreamTask.java:647) [flink-dist_2.11-1.13-SNAPSHOT.jar:1.13-SNAPSHOT]
at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:620) [flink-dist_2.11-1.13-SNAPSHOT.jar:1.13-SNAPSHOT]
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:779) [flink-dist_2.11-1.13-SNAPSHOT.jar:1.13-SNAPSHOT]
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:566) [flink-dist_2.11-1.13-SNAPSHOT.jar:1.13-SNAPSHOT]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_262]


推荐阅读
  • 开机自启动的几种方式
    0x01快速自启动目录快速启动目录自启动方式源于Windows中的一个目录,这个目录一般叫启动或者Startup。位于该目录下的PE文件会在开机后进行自启动 ... [详细]
  • Ihavetwomethodsofgeneratingmdistinctrandomnumbersintherange[0..n-1]我有两种方法在范围[0.n-1]中生 ... [详细]
  • 本文详细介绍了 InfluxDB、collectd 和 Grafana 的安装与配置流程。首先,按照启动顺序依次安装并配置 InfluxDB、collectd 和 Grafana。InfluxDB 作为时序数据库,用于存储时间序列数据;collectd 负责数据的采集与传输;Grafana 则用于数据的可视化展示。文中提供了 collectd 的官方文档链接,便于用户参考和进一步了解其配置选项。通过本指南,读者可以轻松搭建一个高效的数据监控系统。 ... [详细]
  • MySQL Decimal 类型的最大值解析及其在数据处理中的应用艺术
    在关系型数据库中,表的设计与SQL语句的编写对性能的影响至关重要,甚至可占到90%以上。本文将重点探讨MySQL中Decimal类型的最大值及其在数据处理中的应用技巧,通过实例分析和优化建议,帮助读者深入理解并掌握这一重要知识点。 ... [详细]
  • 本文详细解析了 Android 系统启动过程中的核心文件 `init.c`,探讨了其在系统初始化阶段的关键作用。通过对 `init.c` 的源代码进行深入分析,揭示了其如何管理进程、解析配置文件以及执行系统启动脚本。此外,文章还介绍了 `init` 进程的生命周期及其与内核的交互方式,为开发者提供了深入了解 Android 启动机制的宝贵资料。 ... [详细]
  • 在Cisco IOS XR系统中,存在提供服务的服务器和使用这些服务的客户端。本文深入探讨了进程与线程状态转换机制,分析了其在系统性能优化中的关键作用,并提出了改进措施,以提高系统的响应速度和资源利用率。通过详细研究状态转换的各个环节,本文为开发人员和系统管理员提供了实用的指导,旨在提升整体系统效率和稳定性。 ... [详细]
  • 在本地环境中部署了两个不同版本的 Flink 集群,分别为 1.9.1 和 1.9.2。近期在尝试启动 1.9.1 版本的 Flink 任务时,遇到了 TaskExecutor 启动失败的问题。尽管 TaskManager 日志显示正常,但任务仍无法成功启动。经过详细分析,发现该问题是由 Kafka 版本不兼容引起的。通过调整 Kafka 客户端配置并升级相关依赖,最终成功解决了这一故障。 ... [详细]
  • 探索聚类分析中的K-Means与DBSCAN算法及其应用
    聚类分析是一种用于解决样本或特征分类问题的统计分析方法,也是数据挖掘领域的重要算法之一。本文主要探讨了K-Means和DBSCAN两种聚类算法的原理及其应用场景。K-Means算法通过迭代优化簇中心来实现数据点的划分,适用于球形分布的数据集;而DBSCAN算法则基于密度进行聚类,能够有效识别任意形状的簇,并且对噪声数据具有较好的鲁棒性。通过对这两种算法的对比分析,本文旨在为实际应用中选择合适的聚类方法提供参考。 ... [详细]
  • 本文详细介绍了如何在 Linux 系统上安装 JDK 1.8、MySQL 和 Redis,并提供了相应的环境配置和验证步骤。 ... [详细]
  • 本文详细介绍了在 CentOS 7 系统中配置 fstab 文件以实现开机自动挂载 NFS 共享目录的方法,并解决了常见的配置失败问题。 ... [详细]
  • Java高并发与多线程(二):线程的实现方式详解
    本文将深入探讨Java中线程的三种主要实现方式,包括继承Thread类、实现Runnable接口和实现Callable接口,并分析它们之间的异同及其应用场景。 ... [详细]
  • poj 3352 Road Construction ... [详细]
  • Python多线程编程技巧与实战应用详解 ... [详细]
  • 在CICS应用环境中,众多客户端通过网络与CICS服务器进行连接。系统管理员可以通过CICS系统交易CEMT查询当前连接的客户端信息。然而,在非客户端模式下,识别用户连接并解决信息获取错误的问题变得更为复杂。本文将探讨如何在CICS服务器端准确识别非客户端模式的用户连接,并提供有效的解决方案,以确保系统的稳定性和数据的准确性。此外,还将介绍一些常用的诊断工具和技术,帮助管理员快速定位和解决问题。 ... [详细]
  • 【前端开发】深入探讨 RequireJS 与性能优化策略
    随着前端技术的迅速发展,RequireJS虽然不再像以往那样吸引关注,但其在模块化加载方面的优势仍然值得深入探讨。本文将详细介绍RequireJS的基本概念及其作为模块加载工具的核心功能,并重点分析其性能优化策略,帮助开发者更好地理解和应用这一工具,提升前端项目的加载速度和整体性能。 ... [详细]
author-avatar
mobiledu2502905213
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有