[FLINK-11213] Is there any condition that large amount of redis connection created on each TM?

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Invalid
• Assignee: Unassigned
• Reporter: lzh9
• Created: 24/Dec/18 09:39
• Updated: 27/Apr/21 18:06
• Resolved: 03/Jan/19 10:08

Description

In the job, large amount of redis connections are created on each TM, is there some ideas? code like:

def main(args:Array[String]): Unit =

{ val env = StreamExecutionEnvironment.getExecutionEnvironment env.addSource(new Source).setParallelism(4).addSink(new Sinker).setParallelism(4) env.execute() }

class Sinker extends RichSinkFunction[String]{

lazy val applicationContext = new ClassPathXmlApplicationContext("application-redis-context.xml")
lazy val redisTemplate =applicationContext.getBean("redisTemplate", classOf[RedisTemplate[String, String]])

override def invoke(value: String, context: SinkFunction.Context[_]): Unit =

{ val value = redisTemplate.opsForValue().get("key01") println(value) }

}