我有一个类扩展了 RichFlatmapFunction 在我的工作中。我创造了一个 Jedis 中的示例 open() 方法并关闭它 (jedis.close()) 在 close() 方法，以便通过转换的所有记录使用相同的 Jedis 示例。这种方法以前没有给我任何连接错误。但在最近的一次工作中，我犯了一个错误，
“redis.clients.jedis.exceptions.jedisconnectionexception:java.net.socketexception:connection reset”。
这可能是因为我对所有记录都使用了相同的绝地示例（它仍然是开放的）？我在创建示例时没有设置任何超时。所以超时也是默认值。
如果我使用jedispool来检索和关闭每条记录的绝地示例，我能避免这个错误吗？