Mark some fields as transient
This commit is contained in:
parent
8d6198a112
commit
1251f4095f
@ -28,9 +28,9 @@ public class MetricSpout extends BaseRichSpout {
|
||||
private final MetricSpoutConfig metricSpoutConfig;
|
||||
private final MetricDeserializer metricDeserializer;
|
||||
|
||||
private ConsumerConnector consumerConnector;
|
||||
private transient ConsumerConnector consumerConnector;
|
||||
|
||||
private List<KafkaStream<byte[], byte[]>> streams = null;
|
||||
private transient List<KafkaStream<byte[], byte[]>> streams = null;
|
||||
|
||||
private SpoutOutputCollector collector;
|
||||
|
||||
|
Loading…
Reference in New Issue
Block a user