(flink-connector-aws) branch main updated: [FLINK-36138] Add a message to KinesisStreamsSource null checks (#161)

[hong]

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

hong pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-aws.git


The following commit(s) were added to refs/heads/main by this push:
     new 5d2deb1  [FLINK-36138] Add a message to KinesisStreamsSource null 
checks (#161)
5d2deb1 is described below

commit 5d2deb18abbe0a77e4cc0fe7a73f5f65649f794c
Author: Joern Kottmann <kottm...@users.noreply.github.com>
AuthorDate: Thu Sep 12 10:42:29 2024 +0200

    [FLINK-36138] Add a message to KinesisStreamsSource null checks (#161)
    
    [FLINK-36138][Connectors/Kinesis] Add a message to KinesisStreamsSource 
null checks
---
 .../connector/kinesis/source/KinesisStreamsSource.java     | 14 ++++++++++----
 1 file changed, 10 insertions(+), 4 deletions(-)

diff --git 
a/flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/KinesisStreamsSource.java
 
b/flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/KinesisStreamsSource.java
index c0cd399..b795f7b 100644
--- 
a/flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/KinesisStreamsSource.java
+++ 
b/flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/KinesisStreamsSource.java
@@ -93,11 +93,17 @@ public class KinesisStreamsSource<T>
             KinesisDeserializationSchema<T> deserializationSchema,
             KinesisShardAssigner kinesisShardAssigner,
             boolean preserveShardOrder) {
-        Preconditions.checkNotNull(streamArn);
+        Preconditions.checkNotNull(
+                streamArn, "No stream ARN was supplied to the 
KinesisStreamsSource.");
         Preconditions.checkArgument(!streamArn.isEmpty(), "stream ARN cannot 
be empty string");
-        Preconditions.checkNotNull(sourceConfig);
-        Preconditions.checkNotNull(deserializationSchema);
-        Preconditions.checkNotNull(kinesisShardAssigner);
+        Preconditions.checkNotNull(
+                sourceConfig, "No source config was supplied to the 
KinesisStreamsSource.");
+        Preconditions.checkNotNull(
+                deserializationSchema,
+                "No KinesisDeserializationSchema was supplied to the 
KinesisStreamsSource.");
+        Preconditions.checkNotNull(
+                kinesisShardAssigner,
+                "No KinesisShardAssigner was supplied to the 
KinesisStreamsSource.");
         this.streamArn = streamArn;
         this.sourceConfig = sourceConfig;
         this.deserializationSchema = deserializationSchema;