This is an automated email from the ASF dual-hosted git repository. ningjiang pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/servicecomb-pack.git
commit 8ca383f1c48078b79e76e7dfe25d1ec90596534a Author: Lei Zhang <[email protected]> AuthorDate: Fri Sep 27 09:57:17 2019 +0800 SCB-1368 Optimize log information --- .../pack/alpha/fsm/channel/kafka/KafkaMessagePublisher.java | 3 +-- .../elasticsearch/ElasticsearchTransactionRepository.java | 8 +++++--- 2 files changed, 6 insertions(+), 5 deletions(-) diff --git a/alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/kafka/KafkaMessagePublisher.java b/alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/kafka/KafkaMessagePublisher.java index 52de8ef..fe41fb3 100644 --- a/alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/kafka/KafkaMessagePublisher.java +++ b/alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/channel/kafka/KafkaMessagePublisher.java @@ -39,12 +39,11 @@ public class KafkaMessagePublisher implements MessagePublisher<BaseEvent> { @Override public void publish(BaseEvent data) { if(LOG.isDebugEnabled()){ - LOG.debug("send to kafka {} {} to {}", data.getGlobalTxId(), data.getType(), topic); + LOG.debug("send [{}] {} {}", data.getGlobalTxId(), data.getType(), data.getLocalTxId()); } try { kafkaTemplate.send(topic, data.getGlobalTxId(), data).get(); } catch (InterruptedException | ExecutionException | UnsupportedOperationException e) { - LOG.error("publish Exception = [{}]", e.getMessage(), e); throw new RuntimeException(e); } } diff --git a/alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/repository/elasticsearch/ElasticsearchTransactionRepository.java b/alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/repository/elasticsearch/ElasticsearchTransactionRepository.java index 1a33ec9..47655e3 100644 --- a/alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/repository/elasticsearch/ElasticsearchTransactionRepository.java +++ b/alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/repository/elasticsearch/ElasticsearchTransactionRepository.java @@ -243,9 +243,11 @@ public class ElasticsearchTransactionRepository implements TransactionRepository metricsService.metrics().doRepositoryAccepted(queries.size()); long end = System.currentTimeMillis(); metricsService.metrics().doRepositoryAvgTime((end - begin) / queries.size()); - LOG.info("save queries={}, received={}, accepted={}", queries.size(), - metricsService.metrics().getRepositoryReceived(), - metricsService.metrics().getRepositoryAccepted()); + if (LOG.isDebugEnabled()) { + LOG.debug("save queries={}, received={}, accepted={}", queries.size(), + metricsService.metrics().getRepositoryReceived(), + metricsService.metrics().getRepositoryAccepted()); + } queries.clear(); }
