LuciferYang commented on code in PR #37225:
URL: https://github.com/apache/spark/pull/37225#discussion_r924442677
##########
connector/kinesis-asl/src/main/scala/org/apache/spark/examples/streaming/KinesisWordCountASL.scala:
##########
@@ -101,11 +101,12 @@ object KinesisWordCountASL extends Logging {
// Determine the number of shards from the stream using the low-level
Kinesis Client
// from the AWS Java SDK.
- val credentials = new DefaultAWSCredentialsProviderChain().getCredentials()
- require(credentials != null,
+ val credentialsProvider = new DefaultAWSCredentialsProviderChain()
Review Comment:
For `example`, we should manually check it is still working after change
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
