You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by pt...@apache.org on 2016/06/09 20:54:03 UTC
[22/35] storm git commit: update logger private permissions
update logger private permissions
Signed-off-by: P. Taylor Goetz <pt...@gmail.com>
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/2e10ba67
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/2e10ba67
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/2e10ba67
Branch: refs/heads/1.0.x-branch
Commit: 2e10ba6791aed701c9bbafa5c42166038d4bc61b
Parents: 315ff44
Author: darionyaphet <da...@gmail.com>
Authored: Wed Jun 1 13:27:54 2016 +0800
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Thu Jun 9 16:27:38 2016 -0400
----------------------------------------------------------------------
.../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/2e10ba67/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/2e10ba67/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/2e10ba67/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/2e10ba67/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 9eb8268..32c1c7f 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;
http://git-wip-us.apache.org/repos/asf/storm/blob/2e10ba67/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 c20f237..f9d8cf6 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/2e10ba67/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/2e10ba67/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/2e10ba67/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 9732c8c..809ed73 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/2e10ba67/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;