update logger private permissions
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/d0162b72 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/d0162b72 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/d0162b72 Branch: refs/heads/master Commit: d0162b726fe63759cb67473185b4ad836bcc6e88 Parents: 671e21e Author: darionyaphet <[email protected]> Authored: Wed Jun 1 13:27:54 2016 +0800 Committer: darionyaphet <[email protected]> Committed: Wed Jun 1 13:27:54 2016 +0800 ---------------------------------------------------------------------- .../src/jvm/org/apache/storm/kafka/DynamicBrokersReader.java | 2 +- .../jvm/org/apache/storm/kafka/DynamicPartitionConnections.java | 2 +- .../storm-kafka/src/jvm/org/apache/storm/kafka/KafkaSpout.java | 2 +- .../storm-kafka/src/jvm/org/apache/storm/kafka/KafkaUtils.java | 2 +- .../src/jvm/org/apache/storm/kafka/PartitionManager.java | 2 +- .../storm-kafka/src/jvm/org/apache/storm/kafka/ZkCoordinator.java | 2 +- external/storm-kafka/src/jvm/org/apache/storm/kafka/ZkState.java | 2 +- .../jvm/org/apache/storm/kafka/trident/TridentKafkaEmitter.java | 2 +- .../src/jvm/org/apache/storm/kafka/trident/ZkBrokerReader.java | 2 +- 9 files changed, 9 insertions(+), 9 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/d0162b72/external/storm-kafka/src/jvm/org/apache/storm/kafka/DynamicBrokersReader.java ---------------------------------------------------------------------- diff --git a/external/storm-kafka/src/jvm/org/apache/storm/kafka/DynamicBrokersReader.java b/external/storm-kafka/src/jvm/org/apache/storm/kafka/DynamicBrokersReader.java index 0fc85b3..2ad90da 100644 --- a/external/storm-kafka/src/jvm/org/apache/storm/kafka/DynamicBrokersReader.java +++ b/external/storm-kafka/src/jvm/org/apache/storm/kafka/DynamicBrokersReader.java @@ -37,7 +37,7 @@ import java.util.Map; public class DynamicBrokersReader { - public static final Logger LOG = LoggerFactory.getLogger(DynamicBrokersReader.class); + private static final Logger LOG = LoggerFactory.getLogger(DynamicBrokersReader.class); private CuratorFramework _curator; private String _zkPath; http://git-wip-us.apache.org/repos/asf/storm/blob/d0162b72/external/storm-kafka/src/jvm/org/apache/storm/kafka/DynamicPartitionConnections.java ---------------------------------------------------------------------- diff --git a/external/storm-kafka/src/jvm/org/apache/storm/kafka/DynamicPartitionConnections.java b/external/storm-kafka/src/jvm/org/apache/storm/kafka/DynamicPartitionConnections.java index 6d30139..19f0452 100644 --- a/external/storm-kafka/src/jvm/org/apache/storm/kafka/DynamicPartitionConnections.java +++ b/external/storm-kafka/src/jvm/org/apache/storm/kafka/DynamicPartitionConnections.java @@ -30,7 +30,7 @@ import java.util.Set; public class DynamicPartitionConnections { - public static final Logger LOG = LoggerFactory.getLogger(DynamicPartitionConnections.class); + private static final Logger LOG = LoggerFactory.getLogger(DynamicPartitionConnections.class); static class ConnectionInfo { SimpleConsumer consumer; http://git-wip-us.apache.org/repos/asf/storm/blob/d0162b72/external/storm-kafka/src/jvm/org/apache/storm/kafka/KafkaSpout.java ---------------------------------------------------------------------- diff --git a/external/storm-kafka/src/jvm/org/apache/storm/kafka/KafkaSpout.java b/external/storm-kafka/src/jvm/org/apache/storm/kafka/KafkaSpout.java index d1da446..7bacd0b 100644 --- a/external/storm-kafka/src/jvm/org/apache/storm/kafka/KafkaSpout.java +++ b/external/storm-kafka/src/jvm/org/apache/storm/kafka/KafkaSpout.java @@ -40,7 +40,7 @@ public class KafkaSpout extends BaseRichSpout { NO_EMITTED } - public static final Logger LOG = LoggerFactory.getLogger(KafkaSpout.class); + private static final Logger LOG = LoggerFactory.getLogger(KafkaSpout.class); SpoutConfig _spoutConfig; SpoutOutputCollector _collector; http://git-wip-us.apache.org/repos/asf/storm/blob/d0162b72/external/storm-kafka/src/jvm/org/apache/storm/kafka/KafkaUtils.java ---------------------------------------------------------------------- diff --git a/external/storm-kafka/src/jvm/org/apache/storm/kafka/KafkaUtils.java b/external/storm-kafka/src/jvm/org/apache/storm/kafka/KafkaUtils.java index 090b6d1..88b29c5 100644 --- a/external/storm-kafka/src/jvm/org/apache/storm/kafka/KafkaUtils.java +++ b/external/storm-kafka/src/jvm/org/apache/storm/kafka/KafkaUtils.java @@ -47,7 +47,7 @@ import kafka.message.Message; public class KafkaUtils { - public static final Logger LOG = LoggerFactory.getLogger(KafkaUtils.class); + private static final Logger LOG = LoggerFactory.getLogger(KafkaUtils.class); private static final int NO_OFFSET = -5; //suppress default constructor for noninstantiablility http://git-wip-us.apache.org/repos/asf/storm/blob/d0162b72/external/storm-kafka/src/jvm/org/apache/storm/kafka/PartitionManager.java ---------------------------------------------------------------------- diff --git a/external/storm-kafka/src/jvm/org/apache/storm/kafka/PartitionManager.java b/external/storm-kafka/src/jvm/org/apache/storm/kafka/PartitionManager.java index 535e589..f8d2c41 100644 --- a/external/storm-kafka/src/jvm/org/apache/storm/kafka/PartitionManager.java +++ b/external/storm-kafka/src/jvm/org/apache/storm/kafka/PartitionManager.java @@ -39,7 +39,7 @@ import kafka.javaapi.message.ByteBufferMessageSet; import kafka.message.MessageAndOffset; public class PartitionManager { - public static final Logger LOG = LoggerFactory.getLogger(PartitionManager.class); + private static final Logger LOG = LoggerFactory.getLogger(PartitionManager.class); private final CombinedMetric _fetchAPILatencyMax; private final ReducedMetric _fetchAPILatencyMean; http://git-wip-us.apache.org/repos/asf/storm/blob/d0162b72/external/storm-kafka/src/jvm/org/apache/storm/kafka/ZkCoordinator.java ---------------------------------------------------------------------- diff --git a/external/storm-kafka/src/jvm/org/apache/storm/kafka/ZkCoordinator.java b/external/storm-kafka/src/jvm/org/apache/storm/kafka/ZkCoordinator.java index a53d566..98bf8a0 100644 --- a/external/storm-kafka/src/jvm/org/apache/storm/kafka/ZkCoordinator.java +++ b/external/storm-kafka/src/jvm/org/apache/storm/kafka/ZkCoordinator.java @@ -26,7 +26,7 @@ import java.util.*; import static org.apache.storm.kafka.KafkaUtils.taskId; public class ZkCoordinator implements PartitionCoordinator { - public static final Logger LOG = LoggerFactory.getLogger(ZkCoordinator.class); + private static final Logger LOG = LoggerFactory.getLogger(ZkCoordinator.class); SpoutConfig _spoutConfig; int _taskIndex; http://git-wip-us.apache.org/repos/asf/storm/blob/d0162b72/external/storm-kafka/src/jvm/org/apache/storm/kafka/ZkState.java ---------------------------------------------------------------------- diff --git a/external/storm-kafka/src/jvm/org/apache/storm/kafka/ZkState.java b/external/storm-kafka/src/jvm/org/apache/storm/kafka/ZkState.java index d12016b..1428bb7 100644 --- a/external/storm-kafka/src/jvm/org/apache/storm/kafka/ZkState.java +++ b/external/storm-kafka/src/jvm/org/apache/storm/kafka/ZkState.java @@ -33,7 +33,7 @@ import java.util.List; import java.util.Map; public class ZkState { - public static final Logger LOG = LoggerFactory.getLogger(ZkState.class); + private static final Logger LOG = LoggerFactory.getLogger(ZkState.class); CuratorFramework _curator; private CuratorFramework newCurator(Map stateConf) throws Exception { http://git-wip-us.apache.org/repos/asf/storm/blob/d0162b72/external/storm-kafka/src/jvm/org/apache/storm/kafka/trident/TridentKafkaEmitter.java ---------------------------------------------------------------------- diff --git a/external/storm-kafka/src/jvm/org/apache/storm/kafka/trident/TridentKafkaEmitter.java b/external/storm-kafka/src/jvm/org/apache/storm/kafka/trident/TridentKafkaEmitter.java index 512363c..4bf3076 100644 --- a/external/storm-kafka/src/jvm/org/apache/storm/kafka/trident/TridentKafkaEmitter.java +++ b/external/storm-kafka/src/jvm/org/apache/storm/kafka/trident/TridentKafkaEmitter.java @@ -41,7 +41,7 @@ import kafka.message.MessageAndOffset; public class TridentKafkaEmitter { - public static final Logger LOG = LoggerFactory.getLogger(TridentKafkaEmitter.class); + private static final Logger LOG = LoggerFactory.getLogger(TridentKafkaEmitter.class); private DynamicPartitionConnections _connections; private String _topologyName; http://git-wip-us.apache.org/repos/asf/storm/blob/d0162b72/external/storm-kafka/src/jvm/org/apache/storm/kafka/trident/ZkBrokerReader.java ---------------------------------------------------------------------- diff --git a/external/storm-kafka/src/jvm/org/apache/storm/kafka/trident/ZkBrokerReader.java b/external/storm-kafka/src/jvm/org/apache/storm/kafka/trident/ZkBrokerReader.java index d26c341..abc10db 100644 --- a/external/storm-kafka/src/jvm/org/apache/storm/kafka/trident/ZkBrokerReader.java +++ b/external/storm-kafka/src/jvm/org/apache/storm/kafka/trident/ZkBrokerReader.java @@ -29,7 +29,7 @@ import java.util.Map; public class ZkBrokerReader implements IBrokerReader { - public static final Logger LOG = LoggerFactory.getLogger(ZkBrokerReader.class); + private static final Logger LOG = LoggerFactory.getLogger(ZkBrokerReader.class); List<GlobalPartitionInformation> cachedBrokers = new ArrayList<GlobalPartitionInformation>(); DynamicBrokersReader reader;
