You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tz...@apache.org on 2017/05/19 06:42:46 UTC
[6/6] flink git commit: [hotfix] [kafka] Remove unused operator state
store field in FlinkKafkaProducerBase
[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 <tz...@apache.org>
Authored: Fri May 19 12:11:02 2017 +0800
Committer: Tzu-Li (Gordon) Tai <tz...@apache.org>
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