[hotfix] [kafka] Remove unused operator state store field in FlinkKafkaProducerBase
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0963718a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0963718a Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/0963718a Branch: refs/heads/release-1.3 Commit: 0963718acf7137a481d7d1c28140e04ad613e71d Parents: d3b5870 Author: Tzu-Li (Gordon) Tai <[email protected]> Authored: Fri May 19 12:11:02 2017 +0800 Committer: Tzu-Li (Gordon) Tai <[email protected]> Committed: Fri May 19 14:42:12 2017 +0800 ---------------------------------------------------------------------- .../streaming/connectors/kafka/FlinkKafkaProducerBase.java | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/0963718a/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerBase.java ---------------------------------------------------------------------- diff --git a/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerBase.java b/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerBase.java index 3a8228c..46d7d47 100644 --- a/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerBase.java +++ b/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerBase.java @@ -27,7 +27,6 @@ import java.util.Properties; import org.apache.flink.annotation.VisibleForTesting; import org.apache.flink.api.common.functions.RuntimeContext; -import org.apache.flink.api.common.state.OperatorStateStore; import org.apache.flink.api.java.ClosureCleaner; import org.apache.flink.configuration.Configuration; import org.apache.flink.metrics.MetricGroup; @@ -130,8 +129,6 @@ public abstract class FlinkKafkaProducerBase<IN> extends RichSinkFunction<IN> im /** Number of unacknowledged records. */ protected long pendingRecords; - protected OperatorStateStore stateStore; - /** * The main constructor for creating a FlinkKafkaProducer. * @@ -344,7 +341,7 @@ public abstract class FlinkKafkaProducerBase<IN> extends RichSinkFunction<IN> im @Override public void initializeState(FunctionInitializationContext context) throws Exception { - this.stateStore = context.getOperatorStateStore(); + // nothing to do } @Override
