Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/5882#discussion_r29815672
--- Diff:
extras/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisRecordProcessor.scala
---
@@ -35,7 +35,10 @@ import com.amazonaws.services.kinesis.model.Record
/**
* Kinesis-specific implementation of the Kinesis Client Library (KCL)
IRecordProcessor.
* This implementation operates on the Array[Byte] from the
KinesisReceiver.
- * The Kinesis Worker creates an instance of this KinesisRecordProcessor
upon startup.
+ * The Kinesis Worker creates an instance of this KinesisRecordProcessor
for each
+ * shard in the Kinesis stream upon startup. This is normally done in
separate threads,
--- End diff --
Why the extra indent in these comment lines
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
