diff --git a/ozhera-log/log-agent/pom.xml b/ozhera-log/log-agent/pom.xml index 5b974e5d..efa5872d 100644 --- a/ozhera-log/log-agent/pom.xml +++ b/ozhera-log/log-agent/pom.xml @@ -28,7 +28,7 @@ http://www.apache.org/licenses/LICENSE-2.0 4.0.0 log-agent - 2.2.9-SNAPSHOT + 2.3.0-SNAPSHOT 21 diff --git a/ozhera-log/log-agent/src/main/java/org/apache/ozhera/log/agent/channel/ChannelServiceImpl.java b/ozhera-log/log-agent/src/main/java/org/apache/ozhera/log/agent/channel/ChannelServiceImpl.java index 7efdf610..67318f71 100644 --- a/ozhera-log/log-agent/src/main/java/org/apache/ozhera/log/agent/channel/ChannelServiceImpl.java +++ b/ozhera-log/log-agent/src/main/java/org/apache/ozhera/log/agent/channel/ChannelServiceImpl.java @@ -234,7 +234,7 @@ private void startExportQueueDataThread() { private void startCollectFile(Long channelId, Input input, List patterns) { for (int i = 0; i < patterns.size(); i++) { log.info("startCollectFile,total file:{},start:{},remain:{}", patterns.size(), i + 1, patterns.size() - (i + 1)); - readFile(input.getPatternCode(), getTailPodIp(patterns.get(i)), channelId); + readFile(input.getPatternCode(), patterns.get(i), channelId); InodeFileComparator.addFile(patterns.get(i)); } lastLineRemainSendSchedule(input.getPatternCode());