You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by fh...@apache.org on 2018/06/29 16:50:48 UTC
flink git commit: [FLINK-9627] [table] Extending KafkaJsonTableSource
according to comments will result in NPE.
Repository: flink
Updated Branches:
refs/heads/master 4bcf0b99a -> 65ad34ca1
[FLINK-9627] [table] Extending KafkaJsonTableSource according to comments will result in NPE.
This closes #6198.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/65ad34ca
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/65ad34ca
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/65ad34ca
Branch: refs/heads/master
Commit: 65ad34ca128d6e9b7f81df71cb7f0bbcc54e016a
Parents: 4bcf0b9
Author: yanghua <ya...@gmail.com>
Authored: Thu Jun 21 16:46:53 2018 +0800
Committer: Fabian Hueske <fh...@apache.org>
Committed: Fri Jun 29 18:18:56 2018 +0200
----------------------------------------------------------------------
.../apache/flink/streaming/connectors/kafka/KafkaTableSource.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/65ad34ca/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSource.java
----------------------------------------------------------------------
diff --git a/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSource.java b/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSource.java
index 134c483..29654b0 100644
--- a/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSource.java
+++ b/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSource.java
@@ -76,7 +76,7 @@ public abstract class KafkaTableSource
private List<RowtimeAttributeDescriptor> rowtimeAttributeDescriptors;
/** The startup mode for the contained consumer (default is {@link StartupMode#GROUP_OFFSETS}). */
- private StartupMode startupMode;
+ private StartupMode startupMode = StartupMode.GROUP_OFFSETS;
/** Specific startup offsets; only relevant when startup mode is {@link StartupMode#SPECIFIC_OFFSETS}. */
private Map<KafkaTopicPartition, Long> specificStartupOffsets;