You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "lzh9 (JIRA)" <ji...@apache.org> on 2018/12/24 09:40:00 UTC
[jira] [Created] (FLINK-11213) Is there any condition that large
amount of redis connection created on each TM?
lzh9 created FLINK-11213:
----------------------------
Summary: Is there any condition that large amount of redis connection created on each TM?
Key: FLINK-11213
URL: https://issues.apache.org/jira/browse/FLINK-11213
Project: Flink
Issue Type: Task
Reporter: lzh9
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)
}
}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)