Skip to content

Commit 4815d53

Browse files
authored
Remove extra "." causing KinesisOptions to not be read (awslabs#5)
1 parent bbc5064 commit 4815d53

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

src/main/scala/org/apache/spark/sql/connector/kinesis/KinesisOptions.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -151,9 +151,9 @@ object KinesisOptions {
151151

152152
// Sink options
153153
val SINK_FLUSH_WAIT_TIME_MILLIS: String = SINK_PREFIX + "flushWaitTimeMs"
154-
val SINK_RECORD_MAX_BUFFERED_TIME: String = SINK_PREFIX + ".recordMaxBufferedTimeMs"
155-
val SINK_MAX_CONNECTIONS: String = SINK_PREFIX + ".maxConnections"
156-
val SINK_AGGREGATION_ENABLED: String = SINK_PREFIX + ".aggregationEnabled"
154+
val SINK_RECORD_MAX_BUFFERED_TIME: String = SINK_PREFIX + "recordMaxBufferedTimeMs"
155+
val SINK_MAX_CONNECTIONS: String = SINK_PREFIX + "maxConnections"
156+
val SINK_AGGREGATION_ENABLED: String = SINK_PREFIX + "aggregationEnabled"
157157

158158
val DEFAULT_SINK_FLUSH_WAIT_TIME_MILLIS: String = "100"
159159
val DEFAULT_SINK_RECORD_MAX_BUFFERED_TIME: String = "1000"

0 commit comments

Comments
 (0)