You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2020/05/20 15:31:06 UTC
[flink] branch release-1.11 updated (861efd0 -> f65f1de)
This is an automated email from the ASF dual-hosted git repository.
sewen pushed a change to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 861efd0 [FLINK-17675][docs] Update jquery dependency to 3.5.1
new 9208851 [hotfix][core] Add constant serialVersionUIDs to all serializable source API classes
new 083255e [hotfix][core] Add/remove missing/incorrect serialVersionUID fields in Timestamp Assigner classes
new f65f1de [hotfix][docs] Fix comment about RocksDB timer default
The 3 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.
Summary of changes:
docs/_includes/generated/rocks_db_configuration.html | 2 +-
docs/_includes/generated/state_backend_rocksdb_section.html | 2 +-
.../apache/flink/connector/base/source/event/NoMoreSplitsEvent.java | 3 +++
.../org/apache/flink/api/common/eventtime/IngestionTimeAssigner.java | 1 -
.../org/apache/flink/api/common/eventtime/RecordTimestampAssigner.java | 2 --
.../apache/flink/api/common/eventtime/TimestampAssignerSupplier.java | 3 +++
.../main/java/org/apache/flink/api/connector/source/ReaderInfo.java | 3 +++
.../main/java/org/apache/flink/runtime/source/event/AddSplitEvent.java | 3 +++
.../org/apache/flink/runtime/source/event/ReaderRegistrationEvent.java | 3 +++
.../java/org/apache/flink/runtime/source/event/SourceEventWrapper.java | 3 +++
.../java/org/apache/flink/contrib/streaming/state/RocksDBOptions.java | 2 +-
.../flink/streaming/api/operators/collect/CollectSinkAddressEvent.java | 2 ++
12 files changed, 23 insertions(+), 6 deletions(-)
[flink] 01/03: [hotfix][core] Add constant serialVersionUIDs to all
serializable source API classes
Posted by se...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
sewen pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 9208851087fb97636c8b9d96a73eedc59df41de3
Author: Stephan Ewen <se...@apache.org>
AuthorDate: Tue May 19 10:37:23 2020 +0200
[hotfix][core] Add constant serialVersionUIDs to all serializable source API classes
---
.../apache/flink/connector/base/source/event/NoMoreSplitsEvent.java | 3 +++
.../main/java/org/apache/flink/api/connector/source/ReaderInfo.java | 3 +++
.../main/java/org/apache/flink/runtime/source/event/AddSplitEvent.java | 3 +++
.../org/apache/flink/runtime/source/event/ReaderRegistrationEvent.java | 3 +++
.../java/org/apache/flink/runtime/source/event/SourceEventWrapper.java | 3 +++
.../flink/streaming/api/operators/collect/CollectSinkAddressEvent.java | 2 ++
6 files changed, 17 insertions(+)
diff --git a/flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/event/NoMoreSplitsEvent.java b/flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/event/NoMoreSplitsEvent.java
index af05ab9..ed3663b 100644
--- a/flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/event/NoMoreSplitsEvent.java
+++ b/flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/event/NoMoreSplitsEvent.java
@@ -26,6 +26,9 @@ import org.apache.flink.api.connector.source.SourceEvent;
* reading the currently assigned splits, they can exit.
*/
public class NoMoreSplitsEvent implements SourceEvent {
+
+ private static final long serialVersionUID = 1L;
+
@Override
public String toString() {
return "[NoMoreSplitEvent]";
diff --git a/flink-core/src/main/java/org/apache/flink/api/connector/source/ReaderInfo.java b/flink-core/src/main/java/org/apache/flink/api/connector/source/ReaderInfo.java
index 4a048d1..f4a8f8d 100644
--- a/flink-core/src/main/java/org/apache/flink/api/connector/source/ReaderInfo.java
+++ b/flink-core/src/main/java/org/apache/flink/api/connector/source/ReaderInfo.java
@@ -28,6 +28,9 @@ import java.util.Objects;
*/
@Public
public final class ReaderInfo implements Serializable {
+
+ private static final long serialVersionUID = 1L;
+
private final int subtaskId;
private final String location;
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/source/event/AddSplitEvent.java b/flink-runtime/src/main/java/org/apache/flink/runtime/source/event/AddSplitEvent.java
index 5f6cabd..066e747 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/source/event/AddSplitEvent.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/source/event/AddSplitEvent.java
@@ -28,6 +28,9 @@ import java.util.List;
* @param <SplitT> the type of splits.
*/
public class AddSplitEvent<SplitT> implements OperatorEvent {
+
+ private static final long serialVersionUID = 1L;
+
private final List<SplitT> splits;
public AddSplitEvent(List<SplitT> splits) {
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/source/event/ReaderRegistrationEvent.java b/flink-runtime/src/main/java/org/apache/flink/runtime/source/event/ReaderRegistrationEvent.java
index 4cb2aeb..32ed2f3 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/source/event/ReaderRegistrationEvent.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/source/event/ReaderRegistrationEvent.java
@@ -25,6 +25,9 @@ import org.apache.flink.runtime.operators.coordination.OperatorEvent;
* to the SourceCoordinator.
*/
public class ReaderRegistrationEvent implements OperatorEvent {
+
+ private static final long serialVersionUID = 1L;
+
private final int subtaskId;
private final String location;
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/source/event/SourceEventWrapper.java b/flink-runtime/src/main/java/org/apache/flink/runtime/source/event/SourceEventWrapper.java
index 0a5ffa3..05e621d 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/source/event/SourceEventWrapper.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/source/event/SourceEventWrapper.java
@@ -25,6 +25,9 @@ import org.apache.flink.runtime.operators.coordination.OperatorEvent;
* A wrapper operator event that contains a custom defined operator event.
*/
public class SourceEventWrapper implements OperatorEvent {
+
+ private static final long serialVersionUID = 1L;
+
private final SourceEvent sourceEvent;
public SourceEventWrapper(SourceEvent sourceEvent) {
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectSinkAddressEvent.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectSinkAddressEvent.java
index 0e1b0b0..f853e8d 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectSinkAddressEvent.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectSinkAddressEvent.java
@@ -26,6 +26,8 @@ import java.net.InetSocketAddress;
*/
public class CollectSinkAddressEvent implements OperatorEvent {
+ private static final long serialVersionUID = 1L;
+
private final InetSocketAddress address;
public CollectSinkAddressEvent(InetSocketAddress address) {
[flink] 03/03: [hotfix][docs] Fix comment about RocksDB timer
default
Posted by se...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
sewen pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git
commit f65f1de20201201b50911963f62971d4e90c1122
Author: Stephan Ewen <se...@apache.org>
AuthorDate: Tue May 19 19:17:01 2020 +0200
[hotfix][docs] Fix comment about RocksDB timer default
---
docs/_includes/generated/rocks_db_configuration.html | 2 +-
docs/_includes/generated/state_backend_rocksdb_section.html | 2 +-
.../java/org/apache/flink/contrib/streaming/state/RocksDBOptions.java | 2 +-
3 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/docs/_includes/generated/rocks_db_configuration.html b/docs/_includes/generated/rocks_db_configuration.html
index 1648ab3..ee45dc2 100644
--- a/docs/_includes/generated/rocks_db_configuration.html
+++ b/docs/_includes/generated/rocks_db_configuration.html
@@ -60,7 +60,7 @@
<td><h5>state.backend.rocksdb.timer-service.factory</h5></td>
<td style="word-wrap: break-word;">ROCKSDB</td>
<td><p>Enum</p>Possible values: [HEAP, ROCKSDB]</td>
- <td>This determines the factory for timer service state implementation. Options are either HEAP (heap-based, default) or ROCKSDB for an implementation based on RocksDB .</td>
+ <td>This determines the factory for timer service state implementation. Options are either HEAP (heap-based) or ROCKSDB for an implementation based on RocksDB.</td>
</tr>
</tbody>
</table>
diff --git a/docs/_includes/generated/state_backend_rocksdb_section.html b/docs/_includes/generated/state_backend_rocksdb_section.html
index a5c9e78..03c10b6 100644
--- a/docs/_includes/generated/state_backend_rocksdb_section.html
+++ b/docs/_includes/generated/state_backend_rocksdb_section.html
@@ -36,7 +36,7 @@
<td><h5>state.backend.rocksdb.timer-service.factory</h5></td>
<td style="word-wrap: break-word;">ROCKSDB</td>
<td><p>Enum</p>Possible values: [HEAP, ROCKSDB]</td>
- <td>This determines the factory for timer service state implementation. Options are either HEAP (heap-based, default) or ROCKSDB for an implementation based on RocksDB .</td>
+ <td>This determines the factory for timer service state implementation. Options are either HEAP (heap-based) or ROCKSDB for an implementation based on RocksDB.</td>
</tr>
</tbody>
</table>
diff --git a/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBOptions.java b/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBOptions.java
index 5a5470e..9b2e082 100644
--- a/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBOptions.java
+++ b/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBOptions.java
@@ -53,7 +53,7 @@ public class RocksDBOptions {
.enumType(PriorityQueueStateType.class)
.defaultValue(ROCKSDB)
.withDescription(String.format("This determines the factory for timer service state implementation. Options " +
- "are either %s (heap-based, default) or %s for an implementation based on RocksDB .",
+ "are either %s (heap-based) or %s for an implementation based on RocksDB.",
HEAP.name(), ROCKSDB.name()));
/**
[flink] 02/03: [hotfix][core] Add/remove missing/incorrect
serialVersionUID fields in Timestamp Assigner classes
Posted by se...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
sewen pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 083255e4cd46d5c854d756f9d1fb2f30d6dfe933
Author: Stephan Ewen <se...@apache.org>
AuthorDate: Tue May 19 18:52:38 2020 +0200
[hotfix][core] Add/remove missing/incorrect serialVersionUID fields in Timestamp Assigner classes
---
.../org/apache/flink/api/common/eventtime/IngestionTimeAssigner.java | 1 -
.../org/apache/flink/api/common/eventtime/RecordTimestampAssigner.java | 2 --
.../apache/flink/api/common/eventtime/TimestampAssignerSupplier.java | 3 +++
3 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/flink-core/src/main/java/org/apache/flink/api/common/eventtime/IngestionTimeAssigner.java b/flink-core/src/main/java/org/apache/flink/api/common/eventtime/IngestionTimeAssigner.java
index 77c400e..b6c81ea 100644
--- a/flink-core/src/main/java/org/apache/flink/api/common/eventtime/IngestionTimeAssigner.java
+++ b/flink-core/src/main/java/org/apache/flink/api/common/eventtime/IngestionTimeAssigner.java
@@ -28,7 +28,6 @@ import org.apache.flink.annotation.Public;
*/
@Public
public final class IngestionTimeAssigner<T> implements TimestampAssigner<T> {
- private static final long serialVersionUID = 1L;
private long maxTimestamp;
diff --git a/flink-core/src/main/java/org/apache/flink/api/common/eventtime/RecordTimestampAssigner.java b/flink-core/src/main/java/org/apache/flink/api/common/eventtime/RecordTimestampAssigner.java
index 1be7c07..75ee1e8 100644
--- a/flink-core/src/main/java/org/apache/flink/api/common/eventtime/RecordTimestampAssigner.java
+++ b/flink-core/src/main/java/org/apache/flink/api/common/eventtime/RecordTimestampAssigner.java
@@ -27,8 +27,6 @@ import org.apache.flink.annotation.Public;
@Public
public final class RecordTimestampAssigner<E> implements TimestampAssigner<E> {
- private static final long serialVersionUID = 1L;
-
@Override
public long extractTimestamp(E element, long recordTimestamp) {
return recordTimestamp;
diff --git a/flink-core/src/main/java/org/apache/flink/api/common/eventtime/TimestampAssignerSupplier.java b/flink-core/src/main/java/org/apache/flink/api/common/eventtime/TimestampAssignerSupplier.java
index d72cc9f..15f2af0 100644
--- a/flink-core/src/main/java/org/apache/flink/api/common/eventtime/TimestampAssignerSupplier.java
+++ b/flink-core/src/main/java/org/apache/flink/api/common/eventtime/TimestampAssignerSupplier.java
@@ -69,6 +69,9 @@ public interface TimestampAssignerSupplier<T> extends Serializable {
* into the {@link SerializableTimestampAssigner}.
*/
class SupplierFromSerializableTimestampAssigner<T> implements TimestampAssignerSupplier<T> {
+
+ private static final long serialVersionUID = 1L;
+
private final SerializableTimestampAssigner<T> assigner;
public SupplierFromSerializableTimestampAssigner(SerializableTimestampAssigner<T> assigner) {