Commit 466b3b01 by shenjunjie

调整channelEsDao入库捕获exception等级

parent ef37d1a7
...@@ -86,7 +86,7 @@ public class ChannelEsDao extends EsClientDao { ...@@ -86,7 +86,7 @@ public class ChannelEsDao extends EsClientDao {
BulkResponse bulkResponse = retryTemplate.execute(context -> { BulkResponse bulkResponse = retryTemplate.execute(context -> {
try { try {
return channelEsClient.bulk(bulkRequest, RequestOptions.DEFAULT); return channelEsClient.bulk(bulkRequest, RequestOptions.DEFAULT);
} catch (IOException ignored) { } catch (Exception ignored) {
return null; return null;
} }
}); });
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment