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 2019/08/19 22:56:59 UTC

[flink] annotated tag release-1.9.0-rc3 created (now 69459da)

This is an automated email from the ASF dual-hosted git repository.

tzulitai pushed a change to annotated tag release-1.9.0-rc3
in repository https://gitbox.apache.org/repos/asf/flink.git.


      at 69459da  (tag)
 tagging 9c32ed989c0178a2bf3e059e897927c451188700 (commit)
 replaces pre-apache-rename
      by Tzu-Li (Gordon) Tai
      on Mon Aug 19 18:17:05 2019 +0200

- Log -----------------------------------------------------------------
release-1.9.0-rc3
-----BEGIN PGP SIGNATURE-----

iQIzBAABCAAdFiEEHB4jlNMZThlEYTSI8yCYbTXDPWoFAl1ay4EACgkQ8yCYbTXD
PWpyIg/+MPXkHL4ad3FS+yvfn0cYeUYA06Wq2M/GcEHEc1KliT1pgSCStXNfff0q
PmMvVlIYSxprVYs2gTqx6RN2G3j/NzN/9TpoF0NjDZLo/7w7FE0xEAKKxmX18Nb1
xvpRFOGIkvtn2vOfnAztHaOTNJyTfTcFHa1SJYw+GdM4+hS956JFwta+MuWtK3YJ
3L1k2a3DnX90ZuHRW0iMEhLCHYcp1WJ5zIXU5BNy14AoMm4oPc5sNQlDghNHwubp
hJ3zaWXzL6T0xnSIHaDnP4QuRKmmIlvCsPKW9HdKr0hzJ9+AppNVW7TNx1XrQAV2
I13g1bNcN/a61BpHshvLwzsT3DizK36Ld924red6pYs+Jn/xvhX0A9MZG57nCD2O
VfLwmpMC7oFAbtsLK6TrR6X9T64bc1DjnOZ1ZuvGCR4CMNMPZBzpPkFOdm9RWsw9
zVmncYOtezicVsqYfswWTXPlIX4NMpLjiMFKDhjUrwaO+m/i1rslWKIcQCmvOdwz
vKIMhNgVxPFDJx2qaIy8ZKj6hp7LLDVx6OB5zpSpZsSAW5VZm9eTIkMA/FNCpnrN
JBaH/jlShHVefR1zZY65gXNKz8721KR3uo5E2sKG6frVm5UZa+fbW2dQCPHwDKix
2c7zUd+oCgXMSbuUBJ6WYpy2S4nOFdimP8yTpLfQ8iyVIX+tkF8=
=MNm7
-----END PGP SIGNATURE-----
-----------------------------------------------------------------------

This annotated tag includes the following new commits:

     new c2d9aea  [FLINK-13231] [pubsub] Replace Max outstanding acknowledgement ids limit with a FlinkConnectorRateLimiter
     new d894171  [FLINK-13699][table-api] Fix TableFactory doesn't work with DDL when containing TIMESTAMP/DATE/TIME types
     new 04e9527  [FLINK-13752] Only references necessary variables when bookkeeping result partitions on TM
     new 9c32ed9  Commit for release 1.9.0

The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.



[flink] 03/04: [FLINK-13752] Only references necessary variables when bookkeeping result partitions on TM

Posted by tz...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

tzulitai pushed a commit to annotated tag release-1.9.0-rc3
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 04e95278777611519f5d14813dec4cbc533e2934
Author: Gao Yun <yu...@alibaba-inc.com>
AuthorDate: Fri Aug 16 21:10:18 2019 +0800

    [FLINK-13752] Only references necessary variables when bookkeeping result partitions on TM
---
 .../flink/runtime/taskexecutor/TaskExecutor.java   | 38 ++++++++++++++--------
 1 file changed, 24 insertions(+), 14 deletions(-)

diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java b/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
index 9b295dd..5b05be3 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
@@ -597,7 +597,10 @@ public class TaskExecutor extends RpcEndpoint implements TaskExecutorGateway {
 			if (taskAdded) {
 				task.startTaskThread();
 
-				setupResultPartitionBookkeeping(tdd, task.getTerminationFuture());
+				setupResultPartitionBookkeeping(
+					tdd.getJobId(),
+					tdd.getProducedPartitions(),
+					task.getTerminationFuture());
 				return CompletableFuture.completedFuture(Acknowledge.get());
 			} else {
 				final String message = "TaskManager already contains a task for id " +
@@ -611,31 +614,27 @@ public class TaskExecutor extends RpcEndpoint implements TaskExecutorGateway {
 		}
 	}
 
-	private void setupResultPartitionBookkeeping(TaskDeploymentDescriptor tdd, CompletableFuture<ExecutionState> terminationFuture) {
-		final List<ResultPartitionID> partitionsRequiringRelease = tdd.getProducedPartitions().stream()
-			// only blocking partitions require explicit release call
-			.filter(d -> d.getPartitionType().isBlocking())
-			.map(ResultPartitionDeploymentDescriptor::getShuffleDescriptor)
-			// partitions without local resources don't store anything on the TaskExecutor
-			.filter(d -> d.storesLocalResourcesOn().isPresent())
-			.map(ShuffleDescriptor::getResultPartitionID)
-			.collect(Collectors.toList());
+	private void setupResultPartitionBookkeeping(
+			JobID jobId,
+			Collection<ResultPartitionDeploymentDescriptor> producedResultPartitions,
+			CompletableFuture<ExecutionState> terminationFuture) {
+		final List<ResultPartitionID> partitionsRequiringRelease = filterPartitionsRequiringRelease(producedResultPartitions);
 
-		partitionTable.startTrackingPartitions(tdd.getJobId(), partitionsRequiringRelease);
+		partitionTable.startTrackingPartitions(jobId, partitionsRequiringRelease);
 
 		final CompletableFuture<ExecutionState> taskTerminationWithResourceCleanupFuture =
 			terminationFuture.thenApplyAsync(
 				executionState -> {
 					if (executionState != ExecutionState.FINISHED) {
-						partitionTable.stopTrackingPartitions(tdd.getJobId(), partitionsRequiringRelease);
+						partitionTable.stopTrackingPartitions(jobId, partitionsRequiringRelease);
 					}
 					return executionState;
 				},
 				getMainThreadExecutor());
 
 		taskResultPartitionCleanupFuturesPerJob.compute(
-			tdd.getJobId(),
-			(jobID, completableFutures) -> {
+			jobId,
+			(ignored, completableFutures) -> {
 				if (completableFutures == null) {
 					completableFutures = new ArrayList<>(4);
 				}
@@ -645,6 +644,17 @@ public class TaskExecutor extends RpcEndpoint implements TaskExecutorGateway {
 			});
 	}
 
+	private List<ResultPartitionID> filterPartitionsRequiringRelease(Collection<ResultPartitionDeploymentDescriptor> producedResultPartitions) {
+		return producedResultPartitions.stream()
+			// only blocking partitions require explicit release call
+			.filter(d -> d.getPartitionType().isBlocking())
+			.map(ResultPartitionDeploymentDescriptor::getShuffleDescriptor)
+			// partitions without local resources don't store anything on the TaskExecutor
+			.filter(d -> d.storesLocalResourcesOn().isPresent())
+			.map(ShuffleDescriptor::getResultPartitionID)
+			.collect(Collectors.toList());
+	}
+
 	@Override
 	public CompletableFuture<Acknowledge> cancelTask(ExecutionAttemptID executionAttemptID, Time timeout) {
 		final Task task = taskSlotTable.getTask(executionAttemptID);


[flink] 02/04: [FLINK-13699][table-api] Fix TableFactory doesn't work with DDL when containing TIMESTAMP/DATE/TIME types

Posted by tz...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

tzulitai pushed a commit to annotated tag release-1.9.0-rc3
in repository https://gitbox.apache.org/repos/asf/flink.git

commit d8941711e51f3315f543399a1030dbcf2fb07434
Author: Jark Wu <im...@gmail.com>
AuthorDate: Tue Aug 13 11:46:06 2019 +0800

    [FLINK-13699][table-api] Fix TableFactory doesn't work with DDL when containing TIMESTAMP/DATE/TIME types
    
    The solution is encode DataTypes.TIMESTAMP() as "TIMESTAMP" when translating to properties.
    And will be converted back to the old TypeInformation: Types.SQL_TIMESTAMP.
    This would fix all factories at once.
---
 .../java/org/apache/flink/table/utils/TypeStringUtils.java  |  9 ++++++---
 .../org/apache/flink/table/utils/TypeStringUtilsTest.java   | 13 +++++++++++++
 2 files changed, 19 insertions(+), 3 deletions(-)

diff --git a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/TypeStringUtils.java b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/TypeStringUtils.java
index 6bf414a..d454ffb 100644
--- a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/TypeStringUtils.java
+++ b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/TypeStringUtils.java
@@ -96,11 +96,14 @@ public class TypeStringUtils {
 			return DOUBLE;
 		} else if (typeInfo.equals(Types.BIG_DEC)) {
 			return DECIMAL;
-		} else if (typeInfo.equals(Types.SQL_DATE)) {
+		} else if (typeInfo.equals(Types.SQL_DATE) || typeInfo.equals(Types.LOCAL_DATE)) {
+			// write LOCAL_DATE as "DATE" to keep compatible when using new types
 			return DATE;
-		} else if (typeInfo.equals(Types.SQL_TIME)) {
+		} else if (typeInfo.equals(Types.SQL_TIME) || typeInfo.equals(Types.LOCAL_TIME)) {
+			// write LOCAL_TIME as "TIME" to keep compatible when using new types
 			return TIME;
-		} else if (typeInfo.equals(Types.SQL_TIMESTAMP)) {
+		} else if (typeInfo.equals(Types.SQL_TIMESTAMP) || typeInfo.equals(Types.LOCAL_DATE_TIME)) {
+			// write LOCAL_DATE_TIME as "TIMESTAMP" to keep compatible when using new types
 			return TIMESTAMP;
 		} else if (typeInfo instanceof RowTypeInfo) {
 			final RowTypeInfo rt = (RowTypeInfo) typeInfo;
diff --git a/flink-table/flink-table-common/src/test/java/org/apache/flink/table/utils/TypeStringUtilsTest.java b/flink-table/flink-table-common/src/test/java/org/apache/flink/table/utils/TypeStringUtilsTest.java
index 746a8a1..a2f3045 100644
--- a/flink-table/flink-table-common/src/test/java/org/apache/flink/table/utils/TypeStringUtilsTest.java
+++ b/flink-table/flink-table-common/src/test/java/org/apache/flink/table/utils/TypeStringUtilsTest.java
@@ -47,6 +47,9 @@ public class TypeStringUtilsTest {
 		testReadAndWrite("DATE", Types.SQL_DATE);
 		testReadAndWrite("TIME", Types.SQL_TIME);
 		testReadAndWrite("TIMESTAMP", Types.SQL_TIMESTAMP);
+		testWrite("DATE", Types.LOCAL_DATE);
+		testWrite("TIME", Types.LOCAL_TIME);
+		testWrite("TIMESTAMP", Types.LOCAL_DATE_TIME);
 
 		// unsupported type information
 		testReadAndWrite(
@@ -129,6 +132,11 @@ public class TypeStringUtilsTest {
 				Types.ROW_NAMED(
 					new String[] {"Field 1", "Field`s 2"},
 					Types.ROW(Types.BIG_DEC), Types.STRING)));
+
+		testWrite("ROW<f0 DECIMAL, f1 TIMESTAMP, f2 TIME, f3 DATE>",
+			Types.ROW_NAMED(
+				new String[] {"f0", "f1", "f2", "f3"},
+				Types.BIG_DEC, Types.LOCAL_DATE_TIME, Types.LOCAL_TIME, Types.LOCAL_DATE));
 	}
 
 	@Test(expected = ValidationException.class)
@@ -154,6 +162,11 @@ public class TypeStringUtilsTest {
 		assertEquals(expected, TypeStringUtils.writeTypeInfo(type));
 	}
 
+	private void testWrite(String expected, TypeInformation<?> type) {
+		// test write to string
+		assertEquals(expected, TypeStringUtils.writeTypeInfo(type));
+	}
+
 	// --------------------------------------------------------------------------------------------
 
 	/**


[flink] 01/04: [FLINK-13231] [pubsub] Replace Max outstanding acknowledgement ids limit with a FlinkConnectorRateLimiter

Posted by tz...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

tzulitai pushed a commit to annotated tag release-1.9.0-rc3
in repository https://gitbox.apache.org/repos/asf/flink.git

commit c2d9aeacede65724912ed9a2ef87a23181869aa8
Author: Richard Deurwaarder <rd...@bol.com>
AuthorDate: Wed Aug 7 21:21:03 2019 +0200

    [FLINK-13231] [pubsub] Replace Max outstanding acknowledgement ids limit with a FlinkConnectorRateLimiter
---
 .../connectors/gcp/pubsub/PubSubSource.java        | 46 +++++++++++-----------
 .../connectors/gcp/pubsub/PubSubSourceTest.java    | 17 ++++++--
 .../examples/gcp/pubsub/PubSubExample.java         |  1 +
 3 files changed, 37 insertions(+), 27 deletions(-)

diff --git a/flink-connectors/flink-connector-gcp-pubsub/src/main/java/org/apache/flink/streaming/connectors/gcp/pubsub/PubSubSource.java b/flink-connectors/flink-connector-gcp-pubsub/src/main/java/org/apache/flink/streaming/connectors/gcp/pubsub/PubSubSource.java
index 4ddd816..1c7baaf 100644
--- a/flink-connectors/flink-connector-gcp-pubsub/src/main/java/org/apache/flink/streaming/connectors/gcp/pubsub/PubSubSource.java
+++ b/flink-connectors/flink-connector-gcp-pubsub/src/main/java/org/apache/flink/streaming/connectors/gcp/pubsub/PubSubSource.java
@@ -18,6 +18,8 @@
 package org.apache.flink.streaming.connectors.gcp.pubsub;
 
 import org.apache.flink.api.common.functions.RuntimeContext;
+import org.apache.flink.api.common.io.ratelimiting.FlinkConnectorRateLimiter;
+import org.apache.flink.api.common.io.ratelimiting.GuavaFlinkConnectorRateLimiter;
 import org.apache.flink.api.common.serialization.DeserializationSchema;
 import org.apache.flink.api.common.typeinfo.TypeInformation;
 import org.apache.flink.api.java.typeutils.ResultTypeQueryable;
@@ -40,8 +42,6 @@ import com.google.cloud.pubsub.v1.Subscriber;
 import com.google.pubsub.v1.ProjectSubscriptionName;
 import com.google.pubsub.v1.PubsubMessage;
 import com.google.pubsub.v1.ReceivedMessage;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import java.io.IOException;
 import java.io.Serializable;
@@ -57,13 +57,12 @@ import static com.google.cloud.pubsub.v1.SubscriptionAdminSettings.defaultCreden
  */
 public class PubSubSource<OUT> extends RichSourceFunction<OUT>
 	implements ResultTypeQueryable<OUT>, ParallelSourceFunction<OUT>, CheckpointListener, ListCheckpointed<AcknowledgeIdsForCheckpoint<String>> {
-	public static final int NO_MAX_MESSAGES_TO_ACKNOWLEDGE_LIMIT = -1;
-	private static final Logger LOG = LoggerFactory.getLogger(PubSubSource.class);
 	protected final PubSubDeserializationSchema<OUT> deserializationSchema;
 	protected final PubSubSubscriberFactory pubSubSubscriberFactory;
 	protected final Credentials credentials;
-	protected final int maxMessagesToAcknowledge;
 	protected final AcknowledgeOnCheckpointFactory acknowledgeOnCheckpointFactory;
+	protected final FlinkConnectorRateLimiter rateLimiter;
+	protected final int messagePerSecondRateLimit;
 
 	protected transient AcknowledgeOnCheckpoint<String> acknowledgeOnCheckpoint;
 	protected transient PubSubSubscriber subscriber;
@@ -73,13 +72,15 @@ public class PubSubSource<OUT> extends RichSourceFunction<OUT>
 	PubSubSource(PubSubDeserializationSchema<OUT> deserializationSchema,
 				PubSubSubscriberFactory pubSubSubscriberFactory,
 				Credentials credentials,
-				int maxMessagesToAcknowledge,
-				AcknowledgeOnCheckpointFactory acknowledgeOnCheckpointFactory) {
+				AcknowledgeOnCheckpointFactory acknowledgeOnCheckpointFactory,
+				FlinkConnectorRateLimiter rateLimiter,
+				int messagePerSecondRateLimit) {
 		this.deserializationSchema = deserializationSchema;
 		this.pubSubSubscriberFactory = pubSubSubscriberFactory;
 		this.credentials = credentials;
-		this.maxMessagesToAcknowledge = maxMessagesToAcknowledge;
 		this.acknowledgeOnCheckpointFactory = acknowledgeOnCheckpointFactory;
+		this.rateLimiter = rateLimiter;
+		this.messagePerSecondRateLimit = messagePerSecondRateLimit;
 	}
 
 	@Override
@@ -92,6 +93,10 @@ public class PubSubSource<OUT> extends RichSourceFunction<OUT>
 
 		getRuntimeContext().getMetricGroup().gauge("PubSubMessagesProcessedNotAcked", this::getOutstandingMessagesToAck);
 
+		//convert per-subtask-limit to global rate limit, as FlinkConnectorRateLimiter::setRate expects a global rate limit.
+		rateLimiter.setRate(messagePerSecondRateLimit * getRuntimeContext().getNumberOfParallelSubtasks());
+		rateLimiter.open(getRuntimeContext());
+
 		createAndSetPubSubSubscriber();
 		this.isRunning = true;
 	}
@@ -104,11 +109,6 @@ public class PubSubSource<OUT> extends RichSourceFunction<OUT>
 	public void run(SourceContext<OUT> sourceContext) throws Exception {
 		while (isRunning) {
 			try {
-				if (maxMessagesToAcknowledgeLimitReached()) {
-					LOG.debug("Sleeping because there are {} messages waiting to be ack'ed but limit is {}", getOutstandingMessagesToAck(), maxMessagesToAcknowledge);
-					Thread.sleep(100);
-					continue;
-				}
 
 				processMessage(sourceContext, subscriber.pull());
 			} catch (InterruptedException | CancellationException e) {
@@ -119,6 +119,8 @@ public class PubSubSource<OUT> extends RichSourceFunction<OUT>
 	}
 
 	void processMessage(SourceContext<OUT> sourceContext, List<ReceivedMessage> messages) throws Exception {
+		rateLimiter.acquire(messages.size());
+
 		synchronized (sourceContext.getCheckpointLock()) {
 			for (ReceivedMessage message : messages) {
 				acknowledgeOnCheckpoint.addAcknowledgeId(message.getAckId());
@@ -137,10 +139,6 @@ public class PubSubSource<OUT> extends RichSourceFunction<OUT>
 		}
 	}
 
-	private boolean maxMessagesToAcknowledgeLimitReached() throws Exception {
-		return maxMessagesToAcknowledge != NO_MAX_MESSAGES_TO_ACKNOWLEDGE_LIMIT && getOutstandingMessagesToAck() > maxMessagesToAcknowledge;
-	}
-
 	private Integer getOutstandingMessagesToAck() {
 		return acknowledgeOnCheckpoint.numberOfOutstandingAcknowledgements();
 	}
@@ -197,6 +195,7 @@ public class PubSubSource<OUT> extends RichSourceFunction<OUT>
 		private PubSubSubscriberFactory pubSubSubscriberFactory;
 		private Credentials credentials;
 		private int maxMessageToAcknowledge = 10000;
+		private int messagePerSecondRateLimit = 100000;
 
 		private PubSubSourceBuilder(DeserializationSchema<OUT> deserializationSchema) {
 			Preconditions.checkNotNull(deserializationSchema);
@@ -264,12 +263,13 @@ public class PubSubSource<OUT> extends RichSourceFunction<OUT>
 		}
 
 		/**
-		 * Set a limit of the number of outstanding or to-be acknowledged messages.
-		 * default is 10000. Adjust this if you have high checkpoint intervals and / or run into memory issues
-		 * due to the amount of acknowledgement ids. Use {@link PubSubSource}.NO_MAX_MESSAGES_TO_ACKNOWLEDGE_LIMIT if you want to remove the limit.
+		 * Set a limit on the rate of messages per second received. This limit is per parallel instance of the source function.
+		 * Default is set to 100000 messages per second.
+		 *
+		 * @param messagePerSecondRateLimit the message per second rate limit.
 		 */
-		public PubSubSourceBuilder<OUT> withMaxMessageToAcknowledge(int maxMessageToAcknowledge) {
-			this.maxMessageToAcknowledge = maxMessageToAcknowledge;
+		public PubSubSourceBuilder<OUT> withMessageRateLimit(int messagePerSecondRateLimit) {
+			this.messagePerSecondRateLimit = messagePerSecondRateLimit;
 			return this;
 		}
 
@@ -292,7 +292,7 @@ public class PubSubSource<OUT> extends RichSourceFunction<OUT>
 																			100);
 			}
 
-			return new PubSubSource<>(deserializationSchema, pubSubSubscriberFactory, credentials, maxMessageToAcknowledge, new AcknowledgeOnCheckpointFactory());
+			return new PubSubSource<>(deserializationSchema, pubSubSubscriberFactory, credentials, new AcknowledgeOnCheckpointFactory(), new GuavaFlinkConnectorRateLimiter(), messagePerSecondRateLimit);
 		}
 	}
 
diff --git a/flink-connectors/flink-connector-gcp-pubsub/src/test/java/org/apache/flink/streaming/connectors/gcp/pubsub/PubSubSourceTest.java b/flink-connectors/flink-connector-gcp-pubsub/src/test/java/org/apache/flink/streaming/connectors/gcp/pubsub/PubSubSourceTest.java
index 943f075..bb6f0c3 100644
--- a/flink-connectors/flink-connector-gcp-pubsub/src/test/java/org/apache/flink/streaming/connectors/gcp/pubsub/PubSubSourceTest.java
+++ b/flink-connectors/flink-connector-gcp-pubsub/src/test/java/org/apache/flink/streaming/connectors/gcp/pubsub/PubSubSourceTest.java
@@ -17,6 +17,7 @@
 
 package org.apache.flink.streaming.connectors.gcp.pubsub;
 
+import org.apache.flink.api.common.io.ratelimiting.FlinkConnectorRateLimiter;
 import org.apache.flink.api.common.typeinfo.TypeInformation;
 import org.apache.flink.metrics.MetricGroup;
 import org.apache.flink.streaming.api.functions.source.SourceFunction;
@@ -78,6 +79,8 @@ public class PubSubSourceTest {
 	private Credentials credentials;
 	@Mock
 	private PubSubSubscriber pubsubSubscriber;
+	@Mock
+	private FlinkConnectorRateLimiter rateLimiter;
 
 	private PubSubSource<String> pubSubSource;
 
@@ -91,8 +94,9 @@ public class PubSubSourceTest {
 		pubSubSource = new PubSubSource<>(deserializationSchema,
 			pubSubSubscriberFactory,
 			credentials,
-			100,
-			acknowledgeOnCheckpointFactory);
+			acknowledgeOnCheckpointFactory,
+			rateLimiter,
+			1024);
 		pubSubSource.setRuntimeContext(streamingRuntimeContext);
 	}
 
@@ -120,10 +124,15 @@ public class PubSubSourceTest {
 		when(sourceContext.getCheckpointLock()).thenReturn("some object to lock on");
 
 		pubSubSource.open(null);
-		pubSubSource.processMessage(sourceContext, asList(receivedMessage("firstAckId", pubSubMessage(FIRST_MESSAGE)),
-															receivedMessage("secondAckId", pubSubMessage(SECOND_MESSAGE))));
+		List<ReceivedMessage> receivedMessages = asList(
+			receivedMessage("firstAckId", pubSubMessage(FIRST_MESSAGE)),
+			receivedMessage("secondAckId", pubSubMessage(SECOND_MESSAGE))
+		);
+		pubSubSource.processMessage(sourceContext, receivedMessages);
 
 		//verify handling messages
+		verify(rateLimiter, times(1)).acquire(2);
+
 		verify(sourceContext, times(1)).getCheckpointLock();
 		verify(deserializationSchema, times(1)).isEndOfStream(FIRST_MESSAGE);
 		verify(deserializationSchema, times(1)).deserialize(pubSubMessage(FIRST_MESSAGE));
diff --git a/flink-examples/flink-examples-build-helper/flink-examples-streaming-gcp-pubsub/src/main/java/org/apache/flink/streaming/examples/gcp/pubsub/PubSubExample.java b/flink-examples/flink-examples-build-helper/flink-examples-streaming-gcp-pubsub/src/main/java/org/apache/flink/streaming/examples/gcp/pubsub/PubSubExample.java
index a960176..b79c67e 100644
--- a/flink-examples/flink-examples-build-helper/flink-examples-streaming-gcp-pubsub/src/main/java/org/apache/flink/streaming/examples/gcp/pubsub/PubSubExample.java
+++ b/flink-examples/flink-examples-build-helper/flink-examples-streaming-gcp-pubsub/src/main/java/org/apache/flink/streaming/examples/gcp/pubsub/PubSubExample.java
@@ -67,6 +67,7 @@ public class PubSubExample {
 								.withDeserializationSchema(new IntegerSerializer())
 								.withProjectName(projectName)
 								.withSubscriptionName(subscriptionName)
+								.withMessageRateLimit(1)
 								.build())
 			.map(PubSubExample::printAndReturn).disableChaining()
 			.addSink(PubSubSink.newBuilder()


[flink] 04/04: Commit for release 1.9.0

Posted by tz...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

tzulitai pushed a commit to annotated tag release-1.9.0-rc3
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 9c32ed989c0178a2bf3e059e897927c451188700
Author: Tzu-Li (Gordon) Tai <tz...@apache.org>
AuthorDate: Mon Aug 19 18:16:55 2019 +0200

    Commit for release 1.9.0
---
 docs/_config.yml                                                      | 4 ++--
 flink-annotations/pom.xml                                             | 2 +-
 flink-clients/pom.xml                                                 | 2 +-
 flink-connectors/flink-connector-cassandra/pom.xml                    | 2 +-
 flink-connectors/flink-connector-elasticsearch-base/pom.xml           | 2 +-
 flink-connectors/flink-connector-elasticsearch2/pom.xml               | 2 +-
 flink-connectors/flink-connector-elasticsearch5/pom.xml               | 2 +-
 flink-connectors/flink-connector-elasticsearch6/pom.xml               | 2 +-
 flink-connectors/flink-connector-filesystem/pom.xml                   | 2 +-
 flink-connectors/flink-connector-gcp-pubsub/pom.xml                   | 2 +-
 flink-connectors/flink-connector-hive/pom.xml                         | 2 +-
 flink-connectors/flink-connector-kafka-0.10/pom.xml                   | 2 +-
 flink-connectors/flink-connector-kafka-0.11/pom.xml                   | 2 +-
 flink-connectors/flink-connector-kafka-0.8/pom.xml                    | 2 +-
 flink-connectors/flink-connector-kafka-0.9/pom.xml                    | 2 +-
 flink-connectors/flink-connector-kafka-base/pom.xml                   | 2 +-
 flink-connectors/flink-connector-kafka/pom.xml                        | 2 +-
 flink-connectors/flink-connector-kinesis/pom.xml                      | 2 +-
 flink-connectors/flink-connector-nifi/pom.xml                         | 2 +-
 flink-connectors/flink-connector-rabbitmq/pom.xml                     | 2 +-
 flink-connectors/flink-connector-twitter/pom.xml                      | 2 +-
 flink-connectors/flink-hadoop-compatibility/pom.xml                   | 2 +-
 flink-connectors/flink-hbase/pom.xml                                  | 2 +-
 flink-connectors/flink-hcatalog/pom.xml                               | 2 +-
 flink-connectors/flink-jdbc/pom.xml                                   | 2 +-
 flink-connectors/flink-orc/pom.xml                                    | 2 +-
 flink-connectors/flink-sql-connector-elasticsearch6/pom.xml           | 2 +-
 flink-connectors/flink-sql-connector-kafka-0.10/pom.xml               | 2 +-
 flink-connectors/flink-sql-connector-kafka-0.11/pom.xml               | 2 +-
 flink-connectors/flink-sql-connector-kafka-0.9/pom.xml                | 2 +-
 flink-connectors/flink-sql-connector-kafka/pom.xml                    | 2 +-
 flink-connectors/pom.xml                                              | 2 +-
 flink-container/pom.xml                                               | 2 +-
 flink-contrib/flink-connector-wikiedits/pom.xml                       | 2 +-
 flink-contrib/pom.xml                                                 | 2 +-
 flink-core/pom.xml                                                    | 2 +-
 flink-dist/pom.xml                                                    | 2 +-
 flink-docs/pom.xml                                                    | 2 +-
 flink-end-to-end-tests/flink-batch-sql-test/pom.xml                   | 2 +-
 flink-end-to-end-tests/flink-bucketing-sink-test/pom.xml              | 2 +-
 flink-end-to-end-tests/flink-cli-test/pom.xml                         | 2 +-
 flink-end-to-end-tests/flink-confluent-schema-registry/pom.xml        | 2 +-
 .../flink-connector-gcp-pubsub-emulator-tests/pom.xml                 | 2 +-
 flink-end-to-end-tests/flink-dataset-allround-test/pom.xml            | 2 +-
 .../flink-dataset-fine-grained-recovery-test/pom.xml                  | 2 +-
 flink-end-to-end-tests/flink-datastream-allround-test/pom.xml         | 2 +-
 flink-end-to-end-tests/flink-distributed-cache-via-blob-test/pom.xml  | 2 +-
 flink-end-to-end-tests/flink-e2e-test-utils/pom.xml                   | 2 +-
 flink-end-to-end-tests/flink-elasticsearch2-test/pom.xml              | 2 +-
 flink-end-to-end-tests/flink-elasticsearch5-test/pom.xml              | 2 +-
 flink-end-to-end-tests/flink-elasticsearch6-test/pom.xml              | 2 +-
 flink-end-to-end-tests/flink-end-to-end-tests-common/pom.xml          | 2 +-
 flink-end-to-end-tests/flink-heavy-deployment-stress-test/pom.xml     | 2 +-
 flink-end-to-end-tests/flink-high-parallelism-iterations-test/pom.xml | 2 +-
 .../flink-local-recovery-and-allocation-test/pom.xml                  | 2 +-
 flink-end-to-end-tests/flink-metrics-availability-test/pom.xml        | 2 +-
 flink-end-to-end-tests/flink-metrics-reporter-prometheus-test/pom.xml | 2 +-
 .../flink-parent-child-classloading-test-lib-package/pom.xml          | 2 +-
 .../flink-parent-child-classloading-test-program/pom.xml              | 2 +-
 flink-end-to-end-tests/flink-plugins-test/pom.xml                     | 2 +-
 flink-end-to-end-tests/flink-queryable-state-test/pom.xml             | 2 +-
 flink-end-to-end-tests/flink-quickstart-test/pom.xml                  | 2 +-
 flink-end-to-end-tests/flink-sql-client-test/pom.xml                  | 2 +-
 flink-end-to-end-tests/flink-state-evolution-test/pom.xml             | 2 +-
 flink-end-to-end-tests/flink-stream-sql-test/pom.xml                  | 2 +-
 flink-end-to-end-tests/flink-stream-state-ttl-test/pom.xml            | 2 +-
 flink-end-to-end-tests/flink-stream-stateful-job-upgrade-test/pom.xml | 2 +-
 flink-end-to-end-tests/flink-streaming-file-sink-test/pom.xml         | 2 +-
 flink-end-to-end-tests/flink-streaming-kafka-test-base/pom.xml        | 2 +-
 flink-end-to-end-tests/flink-streaming-kafka-test/pom.xml             | 2 +-
 flink-end-to-end-tests/flink-streaming-kafka010-test/pom.xml          | 2 +-
 flink-end-to-end-tests/flink-streaming-kafka011-test/pom.xml          | 2 +-
 flink-end-to-end-tests/flink-streaming-kinesis-test/pom.xml           | 2 +-
 flink-end-to-end-tests/flink-tpch-test/pom.xml                        | 2 +-
 flink-end-to-end-tests/pom.xml                                        | 2 +-
 flink-examples/flink-examples-batch/pom.xml                           | 2 +-
 .../flink-examples-streaming-gcp-pubsub/pom.xml                       | 2 +-
 .../flink-examples-streaming-state-machine/pom.xml                    | 2 +-
 .../flink-examples-streaming-twitter/pom.xml                          | 2 +-
 flink-examples/flink-examples-build-helper/pom.xml                    | 2 +-
 flink-examples/flink-examples-streaming/pom.xml                       | 2 +-
 flink-examples/flink-examples-table/pom.xml                           | 2 +-
 flink-examples/pom.xml                                                | 2 +-
 flink-filesystems/flink-azure-fs-hadoop/pom.xml                       | 2 +-
 flink-filesystems/flink-fs-hadoop-shaded/pom.xml                      | 2 +-
 flink-filesystems/flink-hadoop-fs/pom.xml                             | 2 +-
 flink-filesystems/flink-mapr-fs/pom.xml                               | 2 +-
 flink-filesystems/flink-oss-fs-hadoop/pom.xml                         | 2 +-
 flink-filesystems/flink-s3-fs-base/pom.xml                            | 2 +-
 flink-filesystems/flink-s3-fs-hadoop/pom.xml                          | 2 +-
 flink-filesystems/flink-s3-fs-presto/pom.xml                          | 2 +-
 flink-filesystems/flink-swift-fs-hadoop/pom.xml                       | 2 +-
 flink-filesystems/pom.xml                                             | 2 +-
 flink-formats/flink-avro-confluent-registry/pom.xml                   | 2 +-
 flink-formats/flink-avro/pom.xml                                      | 2 +-
 flink-formats/flink-csv/pom.xml                                       | 2 +-
 flink-formats/flink-json/pom.xml                                      | 2 +-
 flink-formats/flink-parquet/pom.xml                                   | 2 +-
 flink-formats/flink-sequence-file/pom.xml                             | 2 +-
 flink-formats/pom.xml                                                 | 2 +-
 flink-fs-tests/pom.xml                                                | 2 +-
 flink-java/pom.xml                                                    | 2 +-
 flink-libraries/flink-cep-scala/pom.xml                               | 2 +-
 flink-libraries/flink-cep/pom.xml                                     | 2 +-
 flink-libraries/flink-gelly-examples/pom.xml                          | 2 +-
 flink-libraries/flink-gelly-scala/pom.xml                             | 2 +-
 flink-libraries/flink-gelly/pom.xml                                   | 2 +-
 flink-libraries/flink-state-processing-api/pom.xml                    | 2 +-
 flink-libraries/pom.xml                                               | 2 +-
 flink-mesos/pom.xml                                                   | 2 +-
 flink-metrics/flink-metrics-core/pom.xml                              | 2 +-
 flink-metrics/flink-metrics-datadog/pom.xml                           | 2 +-
 flink-metrics/flink-metrics-dropwizard/pom.xml                        | 2 +-
 flink-metrics/flink-metrics-graphite/pom.xml                          | 2 +-
 flink-metrics/flink-metrics-influxdb/pom.xml                          | 2 +-
 flink-metrics/flink-metrics-jmx/pom.xml                               | 2 +-
 flink-metrics/flink-metrics-prometheus/pom.xml                        | 2 +-
 flink-metrics/flink-metrics-slf4j/pom.xml                             | 2 +-
 flink-metrics/flink-metrics-statsd/pom.xml                            | 2 +-
 flink-metrics/pom.xml                                                 | 2 +-
 flink-ml-parent/flink-ml-api/pom.xml                                  | 2 +-
 flink-ml-parent/flink-ml-lib/pom.xml                                  | 2 +-
 flink-ml-parent/pom.xml                                               | 2 +-
 flink-optimizer/pom.xml                                               | 2 +-
 flink-python/pom.xml                                                  | 2 +-
 flink-queryable-state/flink-queryable-state-client-java/pom.xml       | 2 +-
 flink-queryable-state/flink-queryable-state-runtime/pom.xml           | 2 +-
 flink-queryable-state/pom.xml                                         | 2 +-
 flink-quickstart/flink-quickstart-java/pom.xml                        | 2 +-
 flink-quickstart/flink-quickstart-scala/pom.xml                       | 2 +-
 flink-quickstart/pom.xml                                              | 2 +-
 flink-runtime-web/pom.xml                                             | 2 +-
 flink-runtime/pom.xml                                                 | 2 +-
 flink-scala-shell/pom.xml                                             | 2 +-
 flink-scala/pom.xml                                                   | 2 +-
 flink-shaded-curator/pom.xml                                          | 2 +-
 flink-state-backends/flink-statebackend-rocksdb/pom.xml               | 2 +-
 flink-state-backends/pom.xml                                          | 2 +-
 flink-streaming-java/pom.xml                                          | 2 +-
 flink-streaming-scala/pom.xml                                         | 2 +-
 flink-table/flink-sql-client/pom.xml                                  | 2 +-
 flink-table/flink-sql-parser/pom.xml                                  | 2 +-
 flink-table/flink-table-api-java-bridge/pom.xml                       | 2 +-
 flink-table/flink-table-api-java/pom.xml                              | 2 +-
 flink-table/flink-table-api-scala-bridge/pom.xml                      | 2 +-
 flink-table/flink-table-api-scala/pom.xml                             | 2 +-
 flink-table/flink-table-common/pom.xml                                | 2 +-
 flink-table/flink-table-planner-blink/pom.xml                         | 2 +-
 flink-table/flink-table-planner/pom.xml                               | 2 +-
 flink-table/flink-table-runtime-blink/pom.xml                         | 2 +-
 flink-table/flink-table-uber-blink/pom.xml                            | 2 +-
 flink-table/flink-table-uber/pom.xml                                  | 2 +-
 flink-table/pom.xml                                                   | 2 +-
 flink-test-utils-parent/flink-test-utils-junit/pom.xml                | 2 +-
 flink-test-utils-parent/flink-test-utils/pom.xml                      | 2 +-
 flink-test-utils-parent/pom.xml                                       | 2 +-
 flink-tests/pom.xml                                                   | 2 +-
 flink-yarn-tests/pom.xml                                              | 2 +-
 flink-yarn/pom.xml                                                    | 2 +-
 pom.xml                                                               | 4 ++--
 tools/force-shading/pom.xml                                           | 2 +-
 161 files changed, 163 insertions(+), 163 deletions(-)

diff --git a/docs/_config.yml b/docs/_config.yml
index c3c91b2..8235e7b 100644
--- a/docs/_config.yml
+++ b/docs/_config.yml
@@ -27,10 +27,10 @@
 # we change the version for the complete docs when forking of a release branch
 # etc.
 # The full version string as referenced in Maven (e.g. 1.2.1)
-version: "1.9-SNAPSHOT"
+version: "1.9.0"
 # For stable releases, leave the bugfix version out (e.g. 1.2). For snapshot
 # release this should be the same as the regular version
-version_title: "1.9-SNAPSHOT"
+version_title: 1.9
 # Branch on Github for this version
 github_branch: "master"
 
diff --git a/flink-annotations/pom.xml b/flink-annotations/pom.xml
index 6a31aac..ad82345 100644
--- a/flink-annotations/pom.xml
+++ b/flink-annotations/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-parent</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-clients/pom.xml b/flink-clients/pom.xml
index 6476798..ed7e6e6 100644
--- a/flink-clients/pom.xml
+++ b/flink-clients/pom.xml
@@ -26,7 +26,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-parent</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-connectors/flink-connector-cassandra/pom.xml b/flink-connectors/flink-connector-cassandra/pom.xml
index 6338b18..b878e24 100644
--- a/flink-connectors/flink-connector-cassandra/pom.xml
+++ b/flink-connectors/flink-connector-cassandra/pom.xml
@@ -26,7 +26,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-connectors</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-connectors/flink-connector-elasticsearch-base/pom.xml b/flink-connectors/flink-connector-elasticsearch-base/pom.xml
index 94761d9..a9e2900 100644
--- a/flink-connectors/flink-connector-elasticsearch-base/pom.xml
+++ b/flink-connectors/flink-connector-elasticsearch-base/pom.xml
@@ -26,7 +26,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-connectors</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-connectors/flink-connector-elasticsearch2/pom.xml b/flink-connectors/flink-connector-elasticsearch2/pom.xml
index 603af80..7e3322f 100644
--- a/flink-connectors/flink-connector-elasticsearch2/pom.xml
+++ b/flink-connectors/flink-connector-elasticsearch2/pom.xml
@@ -26,7 +26,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-connectors</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-connectors/flink-connector-elasticsearch5/pom.xml b/flink-connectors/flink-connector-elasticsearch5/pom.xml
index 0750123..00bb1fa 100644
--- a/flink-connectors/flink-connector-elasticsearch5/pom.xml
+++ b/flink-connectors/flink-connector-elasticsearch5/pom.xml
@@ -26,7 +26,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-connectors</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-connectors/flink-connector-elasticsearch6/pom.xml b/flink-connectors/flink-connector-elasticsearch6/pom.xml
index de47b58..674c761 100644
--- a/flink-connectors/flink-connector-elasticsearch6/pom.xml
+++ b/flink-connectors/flink-connector-elasticsearch6/pom.xml
@@ -26,7 +26,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-connectors</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-connectors/flink-connector-filesystem/pom.xml b/flink-connectors/flink-connector-filesystem/pom.xml
index d6af8f3..bef0273 100644
--- a/flink-connectors/flink-connector-filesystem/pom.xml
+++ b/flink-connectors/flink-connector-filesystem/pom.xml
@@ -26,7 +26,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-connectors</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-connectors/flink-connector-gcp-pubsub/pom.xml b/flink-connectors/flink-connector-gcp-pubsub/pom.xml
index 11d12a7..10fb275 100644
--- a/flink-connectors/flink-connector-gcp-pubsub/pom.xml
+++ b/flink-connectors/flink-connector-gcp-pubsub/pom.xml
@@ -26,7 +26,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-connectors</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-connectors/flink-connector-hive/pom.xml b/flink-connectors/flink-connector-hive/pom.xml
index 93757fe..9a27435 100644
--- a/flink-connectors/flink-connector-hive/pom.xml
+++ b/flink-connectors/flink-connector-hive/pom.xml
@@ -26,7 +26,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-connectors</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-connectors/flink-connector-kafka-0.10/pom.xml b/flink-connectors/flink-connector-kafka-0.10/pom.xml
index 4b18c8f..5df449e 100644
--- a/flink-connectors/flink-connector-kafka-0.10/pom.xml
+++ b/flink-connectors/flink-connector-kafka-0.10/pom.xml
@@ -26,7 +26,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-connectors</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-connectors/flink-connector-kafka-0.11/pom.xml b/flink-connectors/flink-connector-kafka-0.11/pom.xml
index 8c69539..6d6679a 100644
--- a/flink-connectors/flink-connector-kafka-0.11/pom.xml
+++ b/flink-connectors/flink-connector-kafka-0.11/pom.xml
@@ -26,7 +26,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-connectors</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-connectors/flink-connector-kafka-0.8/pom.xml b/flink-connectors/flink-connector-kafka-0.8/pom.xml
index 3b63498..74ad0d2 100644
--- a/flink-connectors/flink-connector-kafka-0.8/pom.xml
+++ b/flink-connectors/flink-connector-kafka-0.8/pom.xml
@@ -26,7 +26,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-connectors</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-connectors/flink-connector-kafka-0.9/pom.xml b/flink-connectors/flink-connector-kafka-0.9/pom.xml
index fceb1c3..ead0749 100644
--- a/flink-connectors/flink-connector-kafka-0.9/pom.xml
+++ b/flink-connectors/flink-connector-kafka-0.9/pom.xml
@@ -26,7 +26,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-connectors</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-connectors/flink-connector-kafka-base/pom.xml b/flink-connectors/flink-connector-kafka-base/pom.xml
index f8ea29f..f41a195 100644
--- a/flink-connectors/flink-connector-kafka-base/pom.xml
+++ b/flink-connectors/flink-connector-kafka-base/pom.xml
@@ -26,7 +26,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-connectors</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-connectors/flink-connector-kafka/pom.xml b/flink-connectors/flink-connector-kafka/pom.xml
index 4ca4aa0..e3a8e19 100644
--- a/flink-connectors/flink-connector-kafka/pom.xml
+++ b/flink-connectors/flink-connector-kafka/pom.xml
@@ -26,7 +26,7 @@ under the License.
 	<parent>
 		<artifactId>flink-connectors</artifactId>
 		<groupId>org.apache.flink</groupId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-connectors/flink-connector-kinesis/pom.xml b/flink-connectors/flink-connector-kinesis/pom.xml
index fcb9818..98446b2 100644
--- a/flink-connectors/flink-connector-kinesis/pom.xml
+++ b/flink-connectors/flink-connector-kinesis/pom.xml
@@ -26,7 +26,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-connectors</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-connectors/flink-connector-nifi/pom.xml b/flink-connectors/flink-connector-nifi/pom.xml
index 2b1f439..1469109 100644
--- a/flink-connectors/flink-connector-nifi/pom.xml
+++ b/flink-connectors/flink-connector-nifi/pom.xml
@@ -26,7 +26,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-connectors</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-connectors/flink-connector-rabbitmq/pom.xml b/flink-connectors/flink-connector-rabbitmq/pom.xml
index 8652376..e917305 100644
--- a/flink-connectors/flink-connector-rabbitmq/pom.xml
+++ b/flink-connectors/flink-connector-rabbitmq/pom.xml
@@ -26,7 +26,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-connectors</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-connectors/flink-connector-twitter/pom.xml b/flink-connectors/flink-connector-twitter/pom.xml
index 58365c5..9bc54be 100644
--- a/flink-connectors/flink-connector-twitter/pom.xml
+++ b/flink-connectors/flink-connector-twitter/pom.xml
@@ -26,7 +26,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-connectors</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-connectors/flink-hadoop-compatibility/pom.xml b/flink-connectors/flink-hadoop-compatibility/pom.xml
index d6b5d54..e545f69 100644
--- a/flink-connectors/flink-hadoop-compatibility/pom.xml
+++ b/flink-connectors/flink-hadoop-compatibility/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-connectors</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-connectors/flink-hbase/pom.xml b/flink-connectors/flink-hbase/pom.xml
index 9d9f579..ccbe0af 100644
--- a/flink-connectors/flink-hbase/pom.xml
+++ b/flink-connectors/flink-hbase/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-connectors</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-connectors/flink-hcatalog/pom.xml b/flink-connectors/flink-hcatalog/pom.xml
index 6a3d159..ac9693a 100644
--- a/flink-connectors/flink-hcatalog/pom.xml
+++ b/flink-connectors/flink-hcatalog/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-connectors</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-connectors/flink-jdbc/pom.xml b/flink-connectors/flink-jdbc/pom.xml
index a0d08e7..abc0110 100644
--- a/flink-connectors/flink-jdbc/pom.xml
+++ b/flink-connectors/flink-jdbc/pom.xml
@@ -26,7 +26,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-connectors</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-connectors/flink-orc/pom.xml b/flink-connectors/flink-orc/pom.xml
index 5e0f6d1..a485e45 100644
--- a/flink-connectors/flink-orc/pom.xml
+++ b/flink-connectors/flink-orc/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-connectors</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-connectors/flink-sql-connector-elasticsearch6/pom.xml b/flink-connectors/flink-sql-connector-elasticsearch6/pom.xml
index 66ba7f0..92007a2 100644
--- a/flink-connectors/flink-sql-connector-elasticsearch6/pom.xml
+++ b/flink-connectors/flink-sql-connector-elasticsearch6/pom.xml
@@ -26,7 +26,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-connectors</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-connectors/flink-sql-connector-kafka-0.10/pom.xml b/flink-connectors/flink-sql-connector-kafka-0.10/pom.xml
index b3129a6..5ed0edf 100644
--- a/flink-connectors/flink-sql-connector-kafka-0.10/pom.xml
+++ b/flink-connectors/flink-sql-connector-kafka-0.10/pom.xml
@@ -26,7 +26,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-connectors</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-connectors/flink-sql-connector-kafka-0.11/pom.xml b/flink-connectors/flink-sql-connector-kafka-0.11/pom.xml
index 75a5820..82f9e4a 100644
--- a/flink-connectors/flink-sql-connector-kafka-0.11/pom.xml
+++ b/flink-connectors/flink-sql-connector-kafka-0.11/pom.xml
@@ -26,7 +26,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-connectors</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-connectors/flink-sql-connector-kafka-0.9/pom.xml b/flink-connectors/flink-sql-connector-kafka-0.9/pom.xml
index bc6726b..5ffc782 100644
--- a/flink-connectors/flink-sql-connector-kafka-0.9/pom.xml
+++ b/flink-connectors/flink-sql-connector-kafka-0.9/pom.xml
@@ -26,7 +26,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-connectors</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-connectors/flink-sql-connector-kafka/pom.xml b/flink-connectors/flink-sql-connector-kafka/pom.xml
index 483dff8..90d8936 100644
--- a/flink-connectors/flink-sql-connector-kafka/pom.xml
+++ b/flink-connectors/flink-sql-connector-kafka/pom.xml
@@ -26,7 +26,7 @@ under the License.
 	<parent>
 		<artifactId>flink-connectors</artifactId>
 		<groupId>org.apache.flink</groupId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-connectors/pom.xml b/flink-connectors/pom.xml
index 2586002..08e6e15 100644
--- a/flink-connectors/pom.xml
+++ b/flink-connectors/pom.xml
@@ -26,7 +26,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-parent</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-container/pom.xml b/flink-container/pom.xml
index d225bff..750367f 100644
--- a/flink-container/pom.xml
+++ b/flink-container/pom.xml
@@ -24,7 +24,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-parent</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-contrib/flink-connector-wikiedits/pom.xml b/flink-contrib/flink-connector-wikiedits/pom.xml
index d04a348..3ea886f 100644
--- a/flink-contrib/flink-connector-wikiedits/pom.xml
+++ b/flink-contrib/flink-connector-wikiedits/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-contrib</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-contrib/pom.xml b/flink-contrib/pom.xml
index 8573c93..173848a 100644
--- a/flink-contrib/pom.xml
+++ b/flink-contrib/pom.xml
@@ -27,7 +27,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-parent</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-core/pom.xml b/flink-core/pom.xml
index 0768e81..afa005c 100644
--- a/flink-core/pom.xml
+++ b/flink-core/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-parent</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-dist/pom.xml b/flink-dist/pom.xml
index 2ae0c57..290e4b7 100644
--- a/flink-dist/pom.xml
+++ b/flink-dist/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-parent</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-docs/pom.xml b/flink-docs/pom.xml
index 12b09b6..0b364e3 100644
--- a/flink-docs/pom.xml
+++ b/flink-docs/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-parent</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-end-to-end-tests/flink-batch-sql-test/pom.xml b/flink-end-to-end-tests/flink-batch-sql-test/pom.xml
index 3ffd080..22c841c 100644
--- a/flink-end-to-end-tests/flink-batch-sql-test/pom.xml
+++ b/flink-end-to-end-tests/flink-batch-sql-test/pom.xml
@@ -24,7 +24,7 @@
 	<parent>
 		<artifactId>flink-end-to-end-tests</artifactId>
 		<groupId>org.apache.flink</groupId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-end-to-end-tests/flink-bucketing-sink-test/pom.xml b/flink-end-to-end-tests/flink-bucketing-sink-test/pom.xml
index 6f66159..1df11a6 100644
--- a/flink-end-to-end-tests/flink-bucketing-sink-test/pom.xml
+++ b/flink-end-to-end-tests/flink-bucketing-sink-test/pom.xml
@@ -24,7 +24,7 @@
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-end-to-end-tests</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-end-to-end-tests/flink-cli-test/pom.xml b/flink-end-to-end-tests/flink-cli-test/pom.xml
index c738d08..6f744ef 100644
--- a/flink-end-to-end-tests/flink-cli-test/pom.xml
+++ b/flink-end-to-end-tests/flink-cli-test/pom.xml
@@ -24,7 +24,7 @@
 	<parent>
 		<artifactId>flink-end-to-end-tests</artifactId>
 		<groupId>org.apache.flink</groupId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-end-to-end-tests/flink-confluent-schema-registry/pom.xml b/flink-end-to-end-tests/flink-confluent-schema-registry/pom.xml
index 12d4950..2d8d0ac 100644
--- a/flink-end-to-end-tests/flink-confluent-schema-registry/pom.xml
+++ b/flink-end-to-end-tests/flink-confluent-schema-registry/pom.xml
@@ -22,7 +22,7 @@ under the License.
 	<parent>
 		<artifactId>flink-end-to-end-tests</artifactId>
 		<groupId>org.apache.flink</groupId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 	</parent>
 	<modelVersion>4.0.0</modelVersion>
 
diff --git a/flink-end-to-end-tests/flink-connector-gcp-pubsub-emulator-tests/pom.xml b/flink-end-to-end-tests/flink-connector-gcp-pubsub-emulator-tests/pom.xml
index d7f3fc6..a9443b7 100644
--- a/flink-end-to-end-tests/flink-connector-gcp-pubsub-emulator-tests/pom.xml
+++ b/flink-end-to-end-tests/flink-connector-gcp-pubsub-emulator-tests/pom.xml
@@ -26,7 +26,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-end-to-end-tests</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-end-to-end-tests/flink-dataset-allround-test/pom.xml b/flink-end-to-end-tests/flink-dataset-allround-test/pom.xml
index 4baf81a..31143d6 100644
--- a/flink-end-to-end-tests/flink-dataset-allround-test/pom.xml
+++ b/flink-end-to-end-tests/flink-dataset-allround-test/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-end-to-end-tests</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-end-to-end-tests/flink-dataset-fine-grained-recovery-test/pom.xml b/flink-end-to-end-tests/flink-dataset-fine-grained-recovery-test/pom.xml
index 653ab3c..82748a5 100644
--- a/flink-end-to-end-tests/flink-dataset-fine-grained-recovery-test/pom.xml
+++ b/flink-end-to-end-tests/flink-dataset-fine-grained-recovery-test/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-end-to-end-tests</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-end-to-end-tests/flink-datastream-allround-test/pom.xml b/flink-end-to-end-tests/flink-datastream-allround-test/pom.xml
index 3f74400..f6309cf 100644
--- a/flink-end-to-end-tests/flink-datastream-allround-test/pom.xml
+++ b/flink-end-to-end-tests/flink-datastream-allround-test/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-end-to-end-tests</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-end-to-end-tests/flink-distributed-cache-via-blob-test/pom.xml b/flink-end-to-end-tests/flink-distributed-cache-via-blob-test/pom.xml
index b6a3764..18de854 100644
--- a/flink-end-to-end-tests/flink-distributed-cache-via-blob-test/pom.xml
+++ b/flink-end-to-end-tests/flink-distributed-cache-via-blob-test/pom.xml
@@ -24,7 +24,7 @@
 	<parent>
 		<artifactId>flink-end-to-end-tests</artifactId>
 		<groupId>org.apache.flink</groupId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-end-to-end-tests/flink-e2e-test-utils/pom.xml b/flink-end-to-end-tests/flink-e2e-test-utils/pom.xml
index b68ca25..6a9edc9 100644
--- a/flink-end-to-end-tests/flink-e2e-test-utils/pom.xml
+++ b/flink-end-to-end-tests/flink-e2e-test-utils/pom.xml
@@ -23,7 +23,7 @@ under the License.
 	<parent>
 		<artifactId>flink-end-to-end-tests</artifactId>
 		<groupId>org.apache.flink</groupId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 	</parent>
 	<modelVersion>4.0.0</modelVersion>
 
diff --git a/flink-end-to-end-tests/flink-elasticsearch2-test/pom.xml b/flink-end-to-end-tests/flink-elasticsearch2-test/pom.xml
index aad082a..c3c88a7 100644
--- a/flink-end-to-end-tests/flink-elasticsearch2-test/pom.xml
+++ b/flink-end-to-end-tests/flink-elasticsearch2-test/pom.xml
@@ -26,7 +26,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-end-to-end-tests</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-end-to-end-tests/flink-elasticsearch5-test/pom.xml b/flink-end-to-end-tests/flink-elasticsearch5-test/pom.xml
index 259627b..ce89124 100644
--- a/flink-end-to-end-tests/flink-elasticsearch5-test/pom.xml
+++ b/flink-end-to-end-tests/flink-elasticsearch5-test/pom.xml
@@ -26,7 +26,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-end-to-end-tests</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-end-to-end-tests/flink-elasticsearch6-test/pom.xml b/flink-end-to-end-tests/flink-elasticsearch6-test/pom.xml
index 5e19895..5b92978 100644
--- a/flink-end-to-end-tests/flink-elasticsearch6-test/pom.xml
+++ b/flink-end-to-end-tests/flink-elasticsearch6-test/pom.xml
@@ -26,7 +26,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-end-to-end-tests</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-end-to-end-tests/flink-end-to-end-tests-common/pom.xml b/flink-end-to-end-tests/flink-end-to-end-tests-common/pom.xml
index 791f806..1f9efc3 100644
--- a/flink-end-to-end-tests/flink-end-to-end-tests-common/pom.xml
+++ b/flink-end-to-end-tests/flink-end-to-end-tests-common/pom.xml
@@ -22,7 +22,7 @@ under the License.
 	<parent>
 		<artifactId>flink-end-to-end-tests</artifactId>
 		<groupId>org.apache.flink</groupId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 	</parent>
 
 	<modelVersion>4.0.0</modelVersion>
diff --git a/flink-end-to-end-tests/flink-heavy-deployment-stress-test/pom.xml b/flink-end-to-end-tests/flink-heavy-deployment-stress-test/pom.xml
index 677c7e6..1d39aec 100644
--- a/flink-end-to-end-tests/flink-heavy-deployment-stress-test/pom.xml
+++ b/flink-end-to-end-tests/flink-heavy-deployment-stress-test/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-end-to-end-tests</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-end-to-end-tests/flink-high-parallelism-iterations-test/pom.xml b/flink-end-to-end-tests/flink-high-parallelism-iterations-test/pom.xml
index 8f8285b..d40e0fb 100644
--- a/flink-end-to-end-tests/flink-high-parallelism-iterations-test/pom.xml
+++ b/flink-end-to-end-tests/flink-high-parallelism-iterations-test/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-end-to-end-tests</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-end-to-end-tests/flink-local-recovery-and-allocation-test/pom.xml b/flink-end-to-end-tests/flink-local-recovery-and-allocation-test/pom.xml
index 4b545bf..25ae7e7 100644
--- a/flink-end-to-end-tests/flink-local-recovery-and-allocation-test/pom.xml
+++ b/flink-end-to-end-tests/flink-local-recovery-and-allocation-test/pom.xml
@@ -23,7 +23,7 @@ under the License.
 	<parent>
 		<artifactId>flink-end-to-end-tests</artifactId>
 		<groupId>org.apache.flink</groupId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 	</parent>
 	<modelVersion>4.0.0</modelVersion>
 
diff --git a/flink-end-to-end-tests/flink-metrics-availability-test/pom.xml b/flink-end-to-end-tests/flink-metrics-availability-test/pom.xml
index e3ea572..c4b774a 100644
--- a/flink-end-to-end-tests/flink-metrics-availability-test/pom.xml
+++ b/flink-end-to-end-tests/flink-metrics-availability-test/pom.xml
@@ -22,7 +22,7 @@ under the License.
 	<parent>
 		<artifactId>flink-end-to-end-tests</artifactId>
 		<groupId>org.apache.flink</groupId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-end-to-end-tests/flink-metrics-reporter-prometheus-test/pom.xml b/flink-end-to-end-tests/flink-metrics-reporter-prometheus-test/pom.xml
index bdd1a32..2142f81 100644
--- a/flink-end-to-end-tests/flink-metrics-reporter-prometheus-test/pom.xml
+++ b/flink-end-to-end-tests/flink-metrics-reporter-prometheus-test/pom.xml
@@ -22,7 +22,7 @@ under the License.
 	<parent>
 		<artifactId>flink-end-to-end-tests</artifactId>
 		<groupId>org.apache.flink</groupId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-end-to-end-tests/flink-parent-child-classloading-test-lib-package/pom.xml b/flink-end-to-end-tests/flink-parent-child-classloading-test-lib-package/pom.xml
index 10f6f54..a07de7f 100644
--- a/flink-end-to-end-tests/flink-parent-child-classloading-test-lib-package/pom.xml
+++ b/flink-end-to-end-tests/flink-parent-child-classloading-test-lib-package/pom.xml
@@ -29,7 +29,7 @@
 	<parent>
 		<artifactId>flink-end-to-end-tests</artifactId>
 		<groupId>org.apache.flink</groupId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-end-to-end-tests/flink-parent-child-classloading-test-program/pom.xml b/flink-end-to-end-tests/flink-parent-child-classloading-test-program/pom.xml
index 8cdc708..5560e88 100644
--- a/flink-end-to-end-tests/flink-parent-child-classloading-test-program/pom.xml
+++ b/flink-end-to-end-tests/flink-parent-child-classloading-test-program/pom.xml
@@ -29,7 +29,7 @@
 	<parent>
 		<artifactId>flink-end-to-end-tests</artifactId>
 		<groupId>org.apache.flink</groupId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-end-to-end-tests/flink-plugins-test/pom.xml b/flink-end-to-end-tests/flink-plugins-test/pom.xml
index 1c68fbb..3543b3d 100644
--- a/flink-end-to-end-tests/flink-plugins-test/pom.xml
+++ b/flink-end-to-end-tests/flink-plugins-test/pom.xml
@@ -23,7 +23,7 @@ under the License.
 	<parent>
 		<artifactId>flink-end-to-end-tests</artifactId>
 		<groupId>org.apache.flink</groupId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 	</parent>
 	<modelVersion>4.0.0</modelVersion>
 
diff --git a/flink-end-to-end-tests/flink-queryable-state-test/pom.xml b/flink-end-to-end-tests/flink-queryable-state-test/pom.xml
index bc72df7..24c267a 100644
--- a/flink-end-to-end-tests/flink-queryable-state-test/pom.xml
+++ b/flink-end-to-end-tests/flink-queryable-state-test/pom.xml
@@ -23,7 +23,7 @@
 	<parent>
 		<artifactId>flink-end-to-end-tests</artifactId>
 		<groupId>org.apache.flink</groupId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 	</parent>
 	<modelVersion>4.0.0</modelVersion>
 
diff --git a/flink-end-to-end-tests/flink-quickstart-test/pom.xml b/flink-end-to-end-tests/flink-quickstart-test/pom.xml
index 55eb5b2..4a3e540 100644
--- a/flink-end-to-end-tests/flink-quickstart-test/pom.xml
+++ b/flink-end-to-end-tests/flink-quickstart-test/pom.xml
@@ -23,7 +23,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-end-to-end-tests</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 	</parent>
 	<modelVersion>4.0.0</modelVersion>
 
diff --git a/flink-end-to-end-tests/flink-sql-client-test/pom.xml b/flink-end-to-end-tests/flink-sql-client-test/pom.xml
index ea4a74e..841ebb1 100644
--- a/flink-end-to-end-tests/flink-sql-client-test/pom.xml
+++ b/flink-end-to-end-tests/flink-sql-client-test/pom.xml
@@ -22,7 +22,7 @@ under the License.
 	<parent>
 		<artifactId>flink-end-to-end-tests</artifactId>
 		<groupId>org.apache.flink</groupId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 	</parent>
 	<modelVersion>4.0.0</modelVersion>
 
diff --git a/flink-end-to-end-tests/flink-state-evolution-test/pom.xml b/flink-end-to-end-tests/flink-state-evolution-test/pom.xml
index 42f04eb..a41134e 100644
--- a/flink-end-to-end-tests/flink-state-evolution-test/pom.xml
+++ b/flink-end-to-end-tests/flink-state-evolution-test/pom.xml
@@ -22,7 +22,7 @@ under the License.
 	<parent>
 		<artifactId>flink-end-to-end-tests</artifactId>
 		<groupId>org.apache.flink</groupId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 	</parent>
 	<modelVersion>4.0.0</modelVersion>
 
diff --git a/flink-end-to-end-tests/flink-stream-sql-test/pom.xml b/flink-end-to-end-tests/flink-stream-sql-test/pom.xml
index 776b7fe..7414348 100644
--- a/flink-end-to-end-tests/flink-stream-sql-test/pom.xml
+++ b/flink-end-to-end-tests/flink-stream-sql-test/pom.xml
@@ -24,7 +24,7 @@
 	<parent>
 		<artifactId>flink-end-to-end-tests</artifactId>
 		<groupId>org.apache.flink</groupId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-end-to-end-tests/flink-stream-state-ttl-test/pom.xml b/flink-end-to-end-tests/flink-stream-state-ttl-test/pom.xml
index 0ee52f9..f5fc466 100644
--- a/flink-end-to-end-tests/flink-stream-state-ttl-test/pom.xml
+++ b/flink-end-to-end-tests/flink-stream-state-ttl-test/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-end-to-end-tests</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-end-to-end-tests/flink-stream-stateful-job-upgrade-test/pom.xml b/flink-end-to-end-tests/flink-stream-stateful-job-upgrade-test/pom.xml
index c28002f..e0865b1 100644
--- a/flink-end-to-end-tests/flink-stream-stateful-job-upgrade-test/pom.xml
+++ b/flink-end-to-end-tests/flink-stream-stateful-job-upgrade-test/pom.xml
@@ -23,7 +23,7 @@ under the License.
 	<parent>
 		<artifactId>flink-end-to-end-tests</artifactId>
 		<groupId>org.apache.flink</groupId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 	</parent>
 	<modelVersion>4.0.0</modelVersion>
 
diff --git a/flink-end-to-end-tests/flink-streaming-file-sink-test/pom.xml b/flink-end-to-end-tests/flink-streaming-file-sink-test/pom.xml
index 68802fd..a81ba43 100644
--- a/flink-end-to-end-tests/flink-streaming-file-sink-test/pom.xml
+++ b/flink-end-to-end-tests/flink-streaming-file-sink-test/pom.xml
@@ -22,7 +22,7 @@ under the License.
 	<parent>
 		<artifactId>flink-end-to-end-tests</artifactId>
 		<groupId>org.apache.flink</groupId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 	</parent>
 
 	<modelVersion>4.0.0</modelVersion>
diff --git a/flink-end-to-end-tests/flink-streaming-kafka-test-base/pom.xml b/flink-end-to-end-tests/flink-streaming-kafka-test-base/pom.xml
index c6277db..f1fddff 100644
--- a/flink-end-to-end-tests/flink-streaming-kafka-test-base/pom.xml
+++ b/flink-end-to-end-tests/flink-streaming-kafka-test-base/pom.xml
@@ -23,7 +23,7 @@ under the License.
 	<parent>
 		<artifactId>flink-end-to-end-tests</artifactId>
 		<groupId>org.apache.flink</groupId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 	<modelVersion>4.0.0</modelVersion>
diff --git a/flink-end-to-end-tests/flink-streaming-kafka-test/pom.xml b/flink-end-to-end-tests/flink-streaming-kafka-test/pom.xml
index 108eb48..1a26ecf 100644
--- a/flink-end-to-end-tests/flink-streaming-kafka-test/pom.xml
+++ b/flink-end-to-end-tests/flink-streaming-kafka-test/pom.xml
@@ -23,7 +23,7 @@ under the License.
 	<parent>
 		<artifactId>flink-end-to-end-tests</artifactId>
 		<groupId>org.apache.flink</groupId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 	<modelVersion>4.0.0</modelVersion>
diff --git a/flink-end-to-end-tests/flink-streaming-kafka010-test/pom.xml b/flink-end-to-end-tests/flink-streaming-kafka010-test/pom.xml
index 1ffb1f4..f861e09 100644
--- a/flink-end-to-end-tests/flink-streaming-kafka010-test/pom.xml
+++ b/flink-end-to-end-tests/flink-streaming-kafka010-test/pom.xml
@@ -23,7 +23,7 @@ under the License.
 	<parent>
 		<artifactId>flink-end-to-end-tests</artifactId>
 		<groupId>org.apache.flink</groupId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 	<modelVersion>4.0.0</modelVersion>
diff --git a/flink-end-to-end-tests/flink-streaming-kafka011-test/pom.xml b/flink-end-to-end-tests/flink-streaming-kafka011-test/pom.xml
index 742234c..dfe6d49 100644
--- a/flink-end-to-end-tests/flink-streaming-kafka011-test/pom.xml
+++ b/flink-end-to-end-tests/flink-streaming-kafka011-test/pom.xml
@@ -23,7 +23,7 @@ under the License.
 	<parent>
 		<artifactId>flink-end-to-end-tests</artifactId>
 		<groupId>org.apache.flink</groupId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 	<modelVersion>4.0.0</modelVersion>
diff --git a/flink-end-to-end-tests/flink-streaming-kinesis-test/pom.xml b/flink-end-to-end-tests/flink-streaming-kinesis-test/pom.xml
index d16f25f..603ed62 100644
--- a/flink-end-to-end-tests/flink-streaming-kinesis-test/pom.xml
+++ b/flink-end-to-end-tests/flink-streaming-kinesis-test/pom.xml
@@ -23,7 +23,7 @@ under the License.
 	<parent>
 		<artifactId>flink-end-to-end-tests</artifactId>
 		<groupId>org.apache.flink</groupId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 	<modelVersion>4.0.0</modelVersion>
diff --git a/flink-end-to-end-tests/flink-tpch-test/pom.xml b/flink-end-to-end-tests/flink-tpch-test/pom.xml
index 9e16ff1..6a9b598 100644
--- a/flink-end-to-end-tests/flink-tpch-test/pom.xml
+++ b/flink-end-to-end-tests/flink-tpch-test/pom.xml
@@ -21,7 +21,7 @@ under the License.
 	<parent>
 		<artifactId>flink-end-to-end-tests</artifactId>
 		<groupId>org.apache.flink</groupId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 	<modelVersion>4.0.0</modelVersion>
diff --git a/flink-end-to-end-tests/pom.xml b/flink-end-to-end-tests/pom.xml
index b7c2dc2..f4d49a4 100644
--- a/flink-end-to-end-tests/pom.xml
+++ b/flink-end-to-end-tests/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-parent</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-examples/flink-examples-batch/pom.xml b/flink-examples/flink-examples-batch/pom.xml
index c4d4927..c79f24f 100644
--- a/flink-examples/flink-examples-batch/pom.xml
+++ b/flink-examples/flink-examples-batch/pom.xml
@@ -24,7 +24,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-examples</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-examples/flink-examples-build-helper/flink-examples-streaming-gcp-pubsub/pom.xml b/flink-examples/flink-examples-build-helper/flink-examples-streaming-gcp-pubsub/pom.xml
index ab1c91f..892ab5e 100644
--- a/flink-examples/flink-examples-build-helper/flink-examples-streaming-gcp-pubsub/pom.xml
+++ b/flink-examples/flink-examples-build-helper/flink-examples-streaming-gcp-pubsub/pom.xml
@@ -24,7 +24,7 @@ under the License.
 	<parent>
 		<artifactId>flink-examples-build-helper</artifactId>
 		<groupId>org.apache.flink</groupId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-examples/flink-examples-build-helper/flink-examples-streaming-state-machine/pom.xml b/flink-examples/flink-examples-build-helper/flink-examples-streaming-state-machine/pom.xml
index 6c6f779..c427d09 100644
--- a/flink-examples/flink-examples-build-helper/flink-examples-streaming-state-machine/pom.xml
+++ b/flink-examples/flink-examples-build-helper/flink-examples-streaming-state-machine/pom.xml
@@ -24,7 +24,7 @@ under the License.
 	<parent>
 		<artifactId>flink-examples-build-helper</artifactId>
 		<groupId>org.apache.flink</groupId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-examples/flink-examples-build-helper/flink-examples-streaming-twitter/pom.xml b/flink-examples/flink-examples-build-helper/flink-examples-streaming-twitter/pom.xml
index 3c68d22..f13a175 100644
--- a/flink-examples/flink-examples-build-helper/flink-examples-streaming-twitter/pom.xml
+++ b/flink-examples/flink-examples-build-helper/flink-examples-streaming-twitter/pom.xml
@@ -24,7 +24,7 @@ under the License.
 	<parent>
 		<artifactId>flink-examples-build-helper</artifactId>
 		<groupId>org.apache.flink</groupId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-examples/flink-examples-build-helper/pom.xml b/flink-examples/flink-examples-build-helper/pom.xml
index 456de28..5d3a7db 100644
--- a/flink-examples/flink-examples-build-helper/pom.xml
+++ b/flink-examples/flink-examples-build-helper/pom.xml
@@ -24,7 +24,7 @@ under the License.
 	<parent>
 		<artifactId>flink-examples</artifactId>
 		<groupId>org.apache.flink</groupId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-examples/flink-examples-streaming/pom.xml b/flink-examples/flink-examples-streaming/pom.xml
index 814db15..6190894 100644
--- a/flink-examples/flink-examples-streaming/pom.xml
+++ b/flink-examples/flink-examples-streaming/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-examples</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-examples/flink-examples-table/pom.xml b/flink-examples/flink-examples-table/pom.xml
index 83db8e3..f78654a 100644
--- a/flink-examples/flink-examples-table/pom.xml
+++ b/flink-examples/flink-examples-table/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-examples</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-examples/pom.xml b/flink-examples/pom.xml
index c76e9f9..141bc19 100644
--- a/flink-examples/pom.xml
+++ b/flink-examples/pom.xml
@@ -24,7 +24,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-parent</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-filesystems/flink-azure-fs-hadoop/pom.xml b/flink-filesystems/flink-azure-fs-hadoop/pom.xml
index 781e851..f1fce0d 100644
--- a/flink-filesystems/flink-azure-fs-hadoop/pom.xml
+++ b/flink-filesystems/flink-azure-fs-hadoop/pom.xml
@@ -23,7 +23,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-filesystems</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-filesystems/flink-fs-hadoop-shaded/pom.xml b/flink-filesystems/flink-fs-hadoop-shaded/pom.xml
index d503c57..55ea7c9 100644
--- a/flink-filesystems/flink-fs-hadoop-shaded/pom.xml
+++ b/flink-filesystems/flink-fs-hadoop-shaded/pom.xml
@@ -23,7 +23,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-filesystems</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-filesystems/flink-hadoop-fs/pom.xml b/flink-filesystems/flink-hadoop-fs/pom.xml
index 89ee4d4..ceae389 100644
--- a/flink-filesystems/flink-hadoop-fs/pom.xml
+++ b/flink-filesystems/flink-hadoop-fs/pom.xml
@@ -23,7 +23,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-filesystems</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-filesystems/flink-mapr-fs/pom.xml b/flink-filesystems/flink-mapr-fs/pom.xml
index dfa9d89..789e595 100644
--- a/flink-filesystems/flink-mapr-fs/pom.xml
+++ b/flink-filesystems/flink-mapr-fs/pom.xml
@@ -23,7 +23,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-filesystems</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-filesystems/flink-oss-fs-hadoop/pom.xml b/flink-filesystems/flink-oss-fs-hadoop/pom.xml
index f7f94e4..8a2b3b3 100644
--- a/flink-filesystems/flink-oss-fs-hadoop/pom.xml
+++ b/flink-filesystems/flink-oss-fs-hadoop/pom.xml
@@ -21,7 +21,7 @@ under the License.
 	<parent>
 		<artifactId>flink-filesystems</artifactId>
 		<groupId>org.apache.flink</groupId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 	</parent>
 	<modelVersion>4.0.0</modelVersion>
 
diff --git a/flink-filesystems/flink-s3-fs-base/pom.xml b/flink-filesystems/flink-s3-fs-base/pom.xml
index 00d4086..e6064a8 100644
--- a/flink-filesystems/flink-s3-fs-base/pom.xml
+++ b/flink-filesystems/flink-s3-fs-base/pom.xml
@@ -23,7 +23,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-filesystems</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-filesystems/flink-s3-fs-hadoop/pom.xml b/flink-filesystems/flink-s3-fs-hadoop/pom.xml
index e7cf95e..933e2c4 100644
--- a/flink-filesystems/flink-s3-fs-hadoop/pom.xml
+++ b/flink-filesystems/flink-s3-fs-hadoop/pom.xml
@@ -23,7 +23,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-filesystems</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-filesystems/flink-s3-fs-presto/pom.xml b/flink-filesystems/flink-s3-fs-presto/pom.xml
index 3fc8e03..aad0fad 100644
--- a/flink-filesystems/flink-s3-fs-presto/pom.xml
+++ b/flink-filesystems/flink-s3-fs-presto/pom.xml
@@ -23,7 +23,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-filesystems</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-filesystems/flink-swift-fs-hadoop/pom.xml b/flink-filesystems/flink-swift-fs-hadoop/pom.xml
index 42c3839..b1f817b 100644
--- a/flink-filesystems/flink-swift-fs-hadoop/pom.xml
+++ b/flink-filesystems/flink-swift-fs-hadoop/pom.xml
@@ -23,7 +23,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-filesystems</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-filesystems/pom.xml b/flink-filesystems/pom.xml
index c84e853..c66402f 100644
--- a/flink-filesystems/pom.xml
+++ b/flink-filesystems/pom.xml
@@ -26,7 +26,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-parent</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-formats/flink-avro-confluent-registry/pom.xml b/flink-formats/flink-avro-confluent-registry/pom.xml
index aa6382f..20ff970 100644
--- a/flink-formats/flink-avro-confluent-registry/pom.xml
+++ b/flink-formats/flink-avro-confluent-registry/pom.xml
@@ -23,7 +23,7 @@ under the License.
 	<parent>
 		<artifactId>flink-formats</artifactId>
 		<groupId>org.apache.flink</groupId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 	</parent>
 	<modelVersion>4.0.0</modelVersion>
 
diff --git a/flink-formats/flink-avro/pom.xml b/flink-formats/flink-avro/pom.xml
index 1fd62e0..3104a23 100644
--- a/flink-formats/flink-avro/pom.xml
+++ b/flink-formats/flink-avro/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-formats</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-formats/flink-csv/pom.xml b/flink-formats/flink-csv/pom.xml
index 5ca4d62..88aed5c 100644
--- a/flink-formats/flink-csv/pom.xml
+++ b/flink-formats/flink-csv/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-formats</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-formats/flink-json/pom.xml b/flink-formats/flink-json/pom.xml
index 8fe48c8..e42f4f2 100644
--- a/flink-formats/flink-json/pom.xml
+++ b/flink-formats/flink-json/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-formats</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-formats/flink-parquet/pom.xml b/flink-formats/flink-parquet/pom.xml
index b43715d..378c81f 100644
--- a/flink-formats/flink-parquet/pom.xml
+++ b/flink-formats/flink-parquet/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-formats</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-formats/flink-sequence-file/pom.xml b/flink-formats/flink-sequence-file/pom.xml
index 545f9d3..b995847 100644
--- a/flink-formats/flink-sequence-file/pom.xml
+++ b/flink-formats/flink-sequence-file/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-formats</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-formats/pom.xml b/flink-formats/pom.xml
index f44cdce..87b03ea 100644
--- a/flink-formats/pom.xml
+++ b/flink-formats/pom.xml
@@ -26,7 +26,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-parent</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-fs-tests/pom.xml b/flink-fs-tests/pom.xml
index f7a845e..26e13a7 100644
--- a/flink-fs-tests/pom.xml
+++ b/flink-fs-tests/pom.xml
@@ -23,7 +23,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-parent</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-java/pom.xml b/flink-java/pom.xml
index 3d633f4..88a0085 100644
--- a/flink-java/pom.xml
+++ b/flink-java/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-parent</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-libraries/flink-cep-scala/pom.xml b/flink-libraries/flink-cep-scala/pom.xml
index e19735f..c66cf12 100644
--- a/flink-libraries/flink-cep-scala/pom.xml
+++ b/flink-libraries/flink-cep-scala/pom.xml
@@ -26,7 +26,7 @@ under the License.
     <parent>
         <groupId>org.apache.flink</groupId>
         <artifactId>flink-libraries</artifactId>
-        <version>1.9-SNAPSHOT</version>
+        <version>1.9.0</version>
         <relativePath>..</relativePath>
     </parent>
     
diff --git a/flink-libraries/flink-cep/pom.xml b/flink-libraries/flink-cep/pom.xml
index 86f44a3..e10980c 100644
--- a/flink-libraries/flink-cep/pom.xml
+++ b/flink-libraries/flink-cep/pom.xml
@@ -26,7 +26,7 @@ under the License.
     <parent>
         <groupId>org.apache.flink</groupId>
         <artifactId>flink-libraries</artifactId>
-        <version>1.9-SNAPSHOT</version>
+        <version>1.9.0</version>
         <relativePath>..</relativePath>
     </parent>
 
diff --git a/flink-libraries/flink-gelly-examples/pom.xml b/flink-libraries/flink-gelly-examples/pom.xml
index 5eca560..a630ea7 100644
--- a/flink-libraries/flink-gelly-examples/pom.xml
+++ b/flink-libraries/flink-gelly-examples/pom.xml
@@ -23,7 +23,7 @@
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-libraries</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-libraries/flink-gelly-scala/pom.xml b/flink-libraries/flink-gelly-scala/pom.xml
index d679ad0..5047831 100644
--- a/flink-libraries/flink-gelly-scala/pom.xml
+++ b/flink-libraries/flink-gelly-scala/pom.xml
@@ -23,7 +23,7 @@ under the License.
     <parent>
         <groupId>org.apache.flink</groupId>
         <artifactId>flink-libraries</artifactId>
-        <version>1.9-SNAPSHOT</version>
+        <version>1.9.0</version>
         <relativePath>..</relativePath>
     </parent>
     <modelVersion>4.0.0</modelVersion>
diff --git a/flink-libraries/flink-gelly/pom.xml b/flink-libraries/flink-gelly/pom.xml
index 7ed9deb..f048a19 100644
--- a/flink-libraries/flink-gelly/pom.xml
+++ b/flink-libraries/flink-gelly/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-libraries</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-libraries/flink-state-processing-api/pom.xml b/flink-libraries/flink-state-processing-api/pom.xml
index f136017..5d9137d 100644
--- a/flink-libraries/flink-state-processing-api/pom.xml
+++ b/flink-libraries/flink-state-processing-api/pom.xml
@@ -26,7 +26,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-libraries</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-libraries/pom.xml b/flink-libraries/pom.xml
index 9c4e63f..b582f4d 100644
--- a/flink-libraries/pom.xml
+++ b/flink-libraries/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-parent</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-mesos/pom.xml b/flink-mesos/pom.xml
index 9c496a0..2d45533 100644
--- a/flink-mesos/pom.xml
+++ b/flink-mesos/pom.xml
@@ -23,7 +23,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-parent</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 	
diff --git a/flink-metrics/flink-metrics-core/pom.xml b/flink-metrics/flink-metrics-core/pom.xml
index 8339712..b7685d2 100644
--- a/flink-metrics/flink-metrics-core/pom.xml
+++ b/flink-metrics/flink-metrics-core/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-metrics</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-metrics/flink-metrics-datadog/pom.xml b/flink-metrics/flink-metrics-datadog/pom.xml
index 53c24f0..0954ee7 100644
--- a/flink-metrics/flink-metrics-datadog/pom.xml
+++ b/flink-metrics/flink-metrics-datadog/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-metrics</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-metrics/flink-metrics-dropwizard/pom.xml b/flink-metrics/flink-metrics-dropwizard/pom.xml
index 7006594..9db8422 100644
--- a/flink-metrics/flink-metrics-dropwizard/pom.xml
+++ b/flink-metrics/flink-metrics-dropwizard/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-metrics</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-metrics/flink-metrics-graphite/pom.xml b/flink-metrics/flink-metrics-graphite/pom.xml
index fe7bd21..c05d36d 100644
--- a/flink-metrics/flink-metrics-graphite/pom.xml
+++ b/flink-metrics/flink-metrics-graphite/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-metrics</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-metrics/flink-metrics-influxdb/pom.xml b/flink-metrics/flink-metrics-influxdb/pom.xml
index 475e94b..3fb13e0 100644
--- a/flink-metrics/flink-metrics-influxdb/pom.xml
+++ b/flink-metrics/flink-metrics-influxdb/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-metrics</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-metrics/flink-metrics-jmx/pom.xml b/flink-metrics/flink-metrics-jmx/pom.xml
index f5f7285..c5b0b2d 100644
--- a/flink-metrics/flink-metrics-jmx/pom.xml
+++ b/flink-metrics/flink-metrics-jmx/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-metrics</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-metrics/flink-metrics-prometheus/pom.xml b/flink-metrics/flink-metrics-prometheus/pom.xml
index 7c5b37b..7853cc3 100644
--- a/flink-metrics/flink-metrics-prometheus/pom.xml
+++ b/flink-metrics/flink-metrics-prometheus/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-metrics</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-metrics/flink-metrics-slf4j/pom.xml b/flink-metrics/flink-metrics-slf4j/pom.xml
index 90f1875..ae0be46 100644
--- a/flink-metrics/flink-metrics-slf4j/pom.xml
+++ b/flink-metrics/flink-metrics-slf4j/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-metrics</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-metrics/flink-metrics-statsd/pom.xml b/flink-metrics/flink-metrics-statsd/pom.xml
index 5edeaa5..e8961b8 100644
--- a/flink-metrics/flink-metrics-statsd/pom.xml
+++ b/flink-metrics/flink-metrics-statsd/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-metrics</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-metrics/pom.xml b/flink-metrics/pom.xml
index 267dfa7..b8508d0 100644
--- a/flink-metrics/pom.xml
+++ b/flink-metrics/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-parent</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-ml-parent/flink-ml-api/pom.xml b/flink-ml-parent/flink-ml-api/pom.xml
index f77f068..af77af2 100644
--- a/flink-ml-parent/flink-ml-api/pom.xml
+++ b/flink-ml-parent/flink-ml-api/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-ml-parent</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 	</parent>
 
 	<artifactId>flink-ml-api</artifactId>
diff --git a/flink-ml-parent/flink-ml-lib/pom.xml b/flink-ml-parent/flink-ml-lib/pom.xml
index 00b0db2..30179ca 100644
--- a/flink-ml-parent/flink-ml-lib/pom.xml
+++ b/flink-ml-parent/flink-ml-lib/pom.xml
@@ -23,7 +23,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-ml-parent</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 	</parent>
 
 	<artifactId>flink-ml-lib</artifactId>
diff --git a/flink-ml-parent/pom.xml b/flink-ml-parent/pom.xml
index ccf4471..95ff02d 100644
--- a/flink-ml-parent/pom.xml
+++ b/flink-ml-parent/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-parent</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-optimizer/pom.xml b/flink-optimizer/pom.xml
index d979c99..d27f7ea 100644
--- a/flink-optimizer/pom.xml
+++ b/flink-optimizer/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-parent</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-python/pom.xml b/flink-python/pom.xml
index b906df5..9b94508 100644
--- a/flink-python/pom.xml
+++ b/flink-python/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<artifactId>flink-parent</artifactId>
 		<groupId>org.apache.flink</groupId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-queryable-state/flink-queryable-state-client-java/pom.xml b/flink-queryable-state/flink-queryable-state-client-java/pom.xml
index 3b28707..c7fc671 100644
--- a/flink-queryable-state/flink-queryable-state-client-java/pom.xml
+++ b/flink-queryable-state/flink-queryable-state-client-java/pom.xml
@@ -26,7 +26,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-queryable-state</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-queryable-state/flink-queryable-state-runtime/pom.xml b/flink-queryable-state/flink-queryable-state-runtime/pom.xml
index fdadf9f..a7dea74 100644
--- a/flink-queryable-state/flink-queryable-state-runtime/pom.xml
+++ b/flink-queryable-state/flink-queryable-state-runtime/pom.xml
@@ -26,7 +26,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-queryable-state</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-queryable-state/pom.xml b/flink-queryable-state/pom.xml
index 4ab736b..dd07740 100644
--- a/flink-queryable-state/pom.xml
+++ b/flink-queryable-state/pom.xml
@@ -26,7 +26,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-parent</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-quickstart/flink-quickstart-java/pom.xml b/flink-quickstart/flink-quickstart-java/pom.xml
index ebcffbd..c5575dd 100644
--- a/flink-quickstart/flink-quickstart-java/pom.xml
+++ b/flink-quickstart/flink-quickstart-java/pom.xml
@@ -27,7 +27,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-quickstart</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-quickstart/flink-quickstart-scala/pom.xml b/flink-quickstart/flink-quickstart-scala/pom.xml
index 688ae32..a45cc7c 100644
--- a/flink-quickstart/flink-quickstart-scala/pom.xml
+++ b/flink-quickstart/flink-quickstart-scala/pom.xml
@@ -27,7 +27,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-quickstart</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-quickstart/pom.xml b/flink-quickstart/pom.xml
index 7684ca2..72d0ade 100644
--- a/flink-quickstart/pom.xml
+++ b/flink-quickstart/pom.xml
@@ -23,7 +23,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-parent</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-runtime-web/pom.xml b/flink-runtime-web/pom.xml
index 5207ab8..4211098 100644
--- a/flink-runtime-web/pom.xml
+++ b/flink-runtime-web/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-parent</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-runtime/pom.xml b/flink-runtime/pom.xml
index b97e1db..6ac69c9 100644
--- a/flink-runtime/pom.xml
+++ b/flink-runtime/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-parent</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-scala-shell/pom.xml b/flink-scala-shell/pom.xml
index 10a2c82..c09fa90 100644
--- a/flink-scala-shell/pom.xml
+++ b/flink-scala-shell/pom.xml
@@ -23,7 +23,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-parent</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-scala/pom.xml b/flink-scala/pom.xml
index 29027a9..e9b091c 100644
--- a/flink-scala/pom.xml
+++ b/flink-scala/pom.xml
@@ -24,7 +24,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-parent</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-shaded-curator/pom.xml b/flink-shaded-curator/pom.xml
index 786109a..860d57b 100644
--- a/flink-shaded-curator/pom.xml
+++ b/flink-shaded-curator/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-parent</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-state-backends/flink-statebackend-rocksdb/pom.xml b/flink-state-backends/flink-statebackend-rocksdb/pom.xml
index fe2b943..a564770 100644
--- a/flink-state-backends/flink-statebackend-rocksdb/pom.xml
+++ b/flink-state-backends/flink-statebackend-rocksdb/pom.xml
@@ -27,7 +27,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-state-backends</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-state-backends/pom.xml b/flink-state-backends/pom.xml
index 8ae95d8..fd97fc7 100644
--- a/flink-state-backends/pom.xml
+++ b/flink-state-backends/pom.xml
@@ -27,7 +27,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-parent</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-streaming-java/pom.xml b/flink-streaming-java/pom.xml
index 78e6805..6e0db8a 100644
--- a/flink-streaming-java/pom.xml
+++ b/flink-streaming-java/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-parent</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-streaming-scala/pom.xml b/flink-streaming-scala/pom.xml
index 489592f..bc4aec8 100644
--- a/flink-streaming-scala/pom.xml
+++ b/flink-streaming-scala/pom.xml
@@ -24,7 +24,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-parent</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-table/flink-sql-client/pom.xml b/flink-table/flink-sql-client/pom.xml
index 83330ab..e9029f3 100644
--- a/flink-table/flink-sql-client/pom.xml
+++ b/flink-table/flink-sql-client/pom.xml
@@ -23,7 +23,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-table</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-table/flink-sql-parser/pom.xml b/flink-table/flink-sql-parser/pom.xml
index 2c5a7ce..0d6bf2e 100644
--- a/flink-table/flink-sql-parser/pom.xml
+++ b/flink-table/flink-sql-parser/pom.xml
@@ -24,7 +24,7 @@ under the License.
 	<parent>
 		<artifactId>flink-table</artifactId>
 		<groupId>org.apache.flink</groupId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 	</parent>
 
 	<artifactId>flink-sql-parser</artifactId>
diff --git a/flink-table/flink-table-api-java-bridge/pom.xml b/flink-table/flink-table-api-java-bridge/pom.xml
index 57dc342..24a1cf2 100644
--- a/flink-table/flink-table-api-java-bridge/pom.xml
+++ b/flink-table/flink-table-api-java-bridge/pom.xml
@@ -23,7 +23,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-table</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-table/flink-table-api-java/pom.xml b/flink-table/flink-table-api-java/pom.xml
index 91a369c..d14aebb 100644
--- a/flink-table/flink-table-api-java/pom.xml
+++ b/flink-table/flink-table-api-java/pom.xml
@@ -23,7 +23,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-table</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-table/flink-table-api-scala-bridge/pom.xml b/flink-table/flink-table-api-scala-bridge/pom.xml
index f49f71c..059b92e 100644
--- a/flink-table/flink-table-api-scala-bridge/pom.xml
+++ b/flink-table/flink-table-api-scala-bridge/pom.xml
@@ -23,7 +23,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-table</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-table/flink-table-api-scala/pom.xml b/flink-table/flink-table-api-scala/pom.xml
index b16a5d1..6524979 100644
--- a/flink-table/flink-table-api-scala/pom.xml
+++ b/flink-table/flink-table-api-scala/pom.xml
@@ -23,7 +23,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-table</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-table/flink-table-common/pom.xml b/flink-table/flink-table-common/pom.xml
index d1f1ee1..c11a71d 100644
--- a/flink-table/flink-table-common/pom.xml
+++ b/flink-table/flink-table-common/pom.xml
@@ -23,7 +23,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-table</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-table/flink-table-planner-blink/pom.xml b/flink-table/flink-table-planner-blink/pom.xml
index 5325c64..6f77b86 100644
--- a/flink-table/flink-table-planner-blink/pom.xml
+++ b/flink-table/flink-table-planner-blink/pom.xml
@@ -23,7 +23,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-table</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-table/flink-table-planner/pom.xml b/flink-table/flink-table-planner/pom.xml
index ea4e4fc..c909e08 100644
--- a/flink-table/flink-table-planner/pom.xml
+++ b/flink-table/flink-table-planner/pom.xml
@@ -23,7 +23,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-table</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-table/flink-table-runtime-blink/pom.xml b/flink-table/flink-table-runtime-blink/pom.xml
index abe2402..f317d8c 100644
--- a/flink-table/flink-table-runtime-blink/pom.xml
+++ b/flink-table/flink-table-runtime-blink/pom.xml
@@ -23,7 +23,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-table</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-table/flink-table-uber-blink/pom.xml b/flink-table/flink-table-uber-blink/pom.xml
index 1b91b9a..d932198 100644
--- a/flink-table/flink-table-uber-blink/pom.xml
+++ b/flink-table/flink-table-uber-blink/pom.xml
@@ -23,7 +23,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-table</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-table/flink-table-uber/pom.xml b/flink-table/flink-table-uber/pom.xml
index de4efa0..b3b424a 100644
--- a/flink-table/flink-table-uber/pom.xml
+++ b/flink-table/flink-table-uber/pom.xml
@@ -23,7 +23,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-table</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-table/pom.xml b/flink-table/pom.xml
index ed97302..2b3322d 100644
--- a/flink-table/pom.xml
+++ b/flink-table/pom.xml
@@ -23,7 +23,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-parent</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-test-utils-parent/flink-test-utils-junit/pom.xml b/flink-test-utils-parent/flink-test-utils-junit/pom.xml
index 9a7ddd9..74a17b6 100644
--- a/flink-test-utils-parent/flink-test-utils-junit/pom.xml
+++ b/flink-test-utils-parent/flink-test-utils-junit/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-test-utils-parent</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-test-utils-parent/flink-test-utils/pom.xml b/flink-test-utils-parent/flink-test-utils/pom.xml
index 09bfab8..98437d5 100644
--- a/flink-test-utils-parent/flink-test-utils/pom.xml
+++ b/flink-test-utils-parent/flink-test-utils/pom.xml
@@ -25,7 +25,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-test-utils-parent</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-test-utils-parent/pom.xml b/flink-test-utils-parent/pom.xml
index 3046552..4df74f6 100644
--- a/flink-test-utils-parent/pom.xml
+++ b/flink-test-utils-parent/pom.xml
@@ -26,7 +26,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-parent</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-tests/pom.xml b/flink-tests/pom.xml
index d3e6a49..e35cc34 100644
--- a/flink-tests/pom.xml
+++ b/flink-tests/pom.xml
@@ -26,7 +26,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-parent</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-yarn-tests/pom.xml b/flink-yarn-tests/pom.xml
index 6c0b2cb..7c2d152 100644
--- a/flink-yarn-tests/pom.xml
+++ b/flink-yarn-tests/pom.xml
@@ -23,7 +23,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-parent</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/flink-yarn/pom.xml b/flink-yarn/pom.xml
index bbccefb..9c1f44a 100644
--- a/flink-yarn/pom.xml
+++ b/flink-yarn/pom.xml
@@ -23,7 +23,7 @@ under the License.
 	<parent>
 		<groupId>org.apache.flink</groupId>
 		<artifactId>flink-parent</artifactId>
-		<version>1.9-SNAPSHOT</version>
+		<version>1.9.0</version>
 		<relativePath>..</relativePath>
 	</parent>
 
diff --git a/pom.xml b/pom.xml
index b1fc076..591e9ae 100644
--- a/pom.xml
+++ b/pom.xml
@@ -28,7 +28,7 @@ under the License.
 
 	<groupId>org.apache.flink</groupId>
 	<artifactId>flink-parent</artifactId>
-	<version>1.9-SNAPSHOT</version>
+	<version>1.9.0</version>
 
 	<name>flink</name>
 	<packaging>pom</packaging>
@@ -154,7 +154,7 @@ under the License.
 		<dependency>
 			<groupId>org.apache.flink</groupId>
 			<artifactId>force-shading</artifactId>
-			<version>1.9-SNAPSHOT</version>
+			<version>1.9.0</version>
 		</dependency>
 
 		<!-- Root dependencies for all projects -->
diff --git a/tools/force-shading/pom.xml b/tools/force-shading/pom.xml
index e62e2a1..66bf602 100644
--- a/tools/force-shading/pom.xml
+++ b/tools/force-shading/pom.xml
@@ -38,7 +38,7 @@ under the License.
 
 	<groupId>org.apache.flink</groupId>
 	<artifactId>force-shading</artifactId>
-	<version>1.9-SNAPSHOT</version>
+	<version>1.9.0</version>
 
 	<packaging>jar</packaging>