flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tzuli...@apache.org
Subject [6/6] flink git commit: [hotfix] [kafka] Remove unused operator state store field in FlinkKafkaProducerBase
Date Fri, 19 May 2017 06:42:46 GMT
[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 <tzulitai@apache.org>
Authored: Fri May 19 12:11:02 2017 +0800
Committer: Tzu-Li (Gordon) Tai <tzulitai@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


Mime
View raw message