flink-sink-reids报broken pipe错误的解决方案_redis broken pipe_guagua070707的博客-程序员宅基地

技术标签: flink  redis  

根据flink官网连接reids的介绍中(链接地址https://bahir.apache.org/docs/flink/current/flink-streaming-redis/

很多配置没有给开发人员开放,导致会报Broken pipe的错误

jedisConnectionException:Broken pipe

 

网上一番搜索后,是因为使用完redis的命令后,并没有将链接归还给连接池,导致该错误的发生

 

因此修改源码类RedisCommandsContainerBuilder添加:

genericObjectPoolConfig.setMaxWaitMillis(6000);
genericObjectPoolConfig.setTestOnBorrow(true);
genericObjectPoolConfig.setTestOnCreate(true);
genericObjectPoolConfig.setTestOnReturn(true);
genericObjectPoolConfig.setTestWhileIdle(true);

测试后不再报该错误

 

相关链接:

添加对setex的支持

https://www.jianshu.com/p/2c02b7c5970a

commons-pool的参数:

https://www.cnblogs.com/zhengzuozhanglina/p/9685314.html

 

 

 

版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/yilu_beiyu/article/details/109098531

智能推荐

使用TongWeb部署应用修改端口及request编码格式设置_tongweb如何更改监听端口_杜大宝的博客-程序员宅基地

1.修改应用端口:可在WEB容器配置》HTTP通道管理》tong-http-listener中修改监听端口2.设置request请求编码格式,解决接口传值中文乱码问题_tongweb如何更改监听端口

随着日益增多的新技术,如何正确的提升自己?_技术不断更新我们就要不断提高自我_Mokin_Zhao的博客-程序员宅基地

随着日益增多的新技术,如何正确的提升自己?原创 2017-06-09 于亚豪 终端研发部前言介绍随着技术的不断发展,新技术也相继出现,面对日益增多的新技术,如何正确的提升自己?于亚豪博客地址:http://blog.csdn.net/androidstarjack/article/details/72942976正_技术不断更新我们就要不断提高自我

4.2V转3V电路图,,电路设计C参考PW2053_4.2v转3.3v_usb type的博客-程序员宅基地

PW2053的PCB布局设计建议-基础篇开关电源的一个常见问题是“不稳定”的开关波形。有时,波形抖动很明显,可以听到从磁性元件发出噪声。如果问题与印刷电路板(PCB)布局有关,则很难确定原因。 EMC也是很注重(PCB)布局,这就是为什么在开关电源设计的早期正确布局PCB至关重要的原因。其重要性不可夸大。原理图走线主要器件放置CIN加并联一个旁路电容0.1uFLX节点FB反馈电阻R1,R2COUT电容容易影响输出的布线功率组件的推荐焊盘图案GND功率地的PCB布线电感器选择降压电_4.2v转3.3v

北斗短报文通信:单卡机、多卡机、指挥机介绍_指挥机卡_格林恩德高精度定位的博客-程序员宅基地

搭建北斗短报文通信息的时候,会接触到单卡机、多卡机、指挥机等概念,下面我们就分别介绍一下这3种设备。1.单卡机,设备内部只有一张北斗卡,格林恩德CD300短报文终端就是属于单卡机。2.多卡机,设备内部最多可以放置 16张北斗卡,其中一张主卡用于接收,另外 15 张卡用于发送 ,每分钟最多发送 16 次短报文。 适合用于需要频繁发送短报文的场景。3.指挥机,设备内部最多可以放置 5 张指挥卡,1 张指挥机卡最多配200张下属卡,所以一台指挥机最多可以控制 1000 台下属机。(1)指挥机卡跟下属卡是配_指挥机卡

hdu 2809 God of War //状态压缩DP_HQD因为有趣所以做题的博客-程序员宅基地

用记忆话搜索的可能时间上稍微慢点。/*几个陷阱吧一个是可能出现攻击比防御小的情况,那么取伤害为1另一种就是经验不清零,题目没提及吧*/#include #include struct LVBU{ int ATI,DEF,HP,EXP,level;}p

braft-editor富文本编辑器_contentutils.insertmedias_web_cgh的博客-程序员宅基地

import 'braft-editor/dist/index.css'import BraftEditor from 'braft-editor'import {ContentUtils} from 'braft-utils'import React, {Component, Fragment} from 'react';// 定义输入转换函数const unitImportFn =..._contentutils.insertmedias

随便推点

【渝粤题库】广东开放大学 建筑工程法规 试题_从理论上讲,评标因素指标-程序员宅基地

​????关注我,看答案????选择题题目:1、仲裁委员会裁决作出后,一方当事人不履行裁决时(   )。答案:A、另一方当事人可以向法院申请强制执行B、仲裁委员会可以强制执行C、另一方当事人可以向仲裁委员会重新提请仲裁D、另一方当事人可以向法院提起诉讼题目:2、诉讼时效因提起诉讼,当事人一方提出要求或者同意履行义务而中断,从中断时起,诉讼时效期间 ( ) 。答案:A、重新计算B、暂停计算C、继续计算D、延迟六个月题目:3、甲委托乙为其购买建材,乙为此做了大量准备工作。现甲不想要这_从理论上讲,评标因素指标

程序猿每日经典英语必读_It_Zhang0Yang的博客-程序员宅基地

程序猿每日经典英语必读:每日一句2018.04.7Be yourself, everyone else is already taken.做你自己,因为别人都有人做了。@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@每日一句2018.03.31A day is a miniature of eternity.一天是永恒...

webpack5不要再用url-loader了_webpack5 url-loader_前端精髓的博客-程序员宅基地

webpack 最出色的功能之一就是,除了引入 JavaScript,还可以通过 loader 或内置的 Asset Modules 引入任何其他类型的文件。webpack5 新增 Asset Modules 资源模块。资源模块(asset module)是一种模块类型,它允许使用资源文件(字体,图标等)而无需配置额外 loader。在 webpack 5 之前,通常使用:1、raw-loader 将文件导入为字符串。2、url-loader 将文件作为 data URI 内联到 bundle 中_webpack5 url-loader

Android第三方开源库:PopupWindow相关_android popupwindow 开源_AndroidCQC的博客-程序员宅基地

MultiSelectPopWindow效果图gradleallprojects { repositories { jcenter() maven { url 'https://jitpack.io' } }}dependencies { ... compile 'com.github.Jay-Goo:MultiSelectPopWi_android popupwindow 开源

Java技术专题——帮你彻底搞懂JNDI(附详细实例)_jndi使用示例_Jesministrator的博客-程序员宅基地

1. 什么是JNDI?JNDI(Java Naming and Directory Interface,Java命名和目录接口)是SUN公司提供的一种标准的Java命名系统接口,JNDI提供统一的客户端API,通过不同的访问提供者接口JNDI服务供应接口(SPI)的实现,由管理者将JNDI API映射为特定的命名服务和目录系统,使得Java应用程序可以和这些命名服务和目录服务之间进行交互。_jndi使用示例

IT外企那点儿事(14): 好领导和好员工,坏领导和坏员工,鸡生蛋还是蛋生鸡?_这个也不错的博客-程序员宅基地

领导和员工,似乎天然成为互相博弈的矛盾体,他们只要单独坐在一起,比如面试,或者是One on One,都时而擦出火药味,在表面的和谐谈话气氛下,心里充满的对对方的不满和不屑,而在工作外,我们常常听到这两者相互抱怨。例如在面试时,一般会问及面试者对于原来的项目的详细情况。由于在沟通中,往往伴随着信息的噪音和失真,每个信息接收者,都会根据自己以往的经验队接收到的信息进行解读,形成一定结论,存入