Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/18029
Thanks for being so helpful and patient on this one @brkyvz . I will leave
this with you now for your final âï¸ if you're happy
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/18029
@brkyvz could you please have a look if it looks good. Would be great if
you're happy with the changes and we could merge
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/18029
@brkyvz Squashed multiple commits into one for better readability. Please
have a look when you get time. Thanks
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/18029
@brkyvz Please have a look once you have time. Thanks.
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/18029
Thanks for the review @brkyvz . Updated the pull request with version 2.3.0.
---
-
To unsubscribe, e-mail: reviews-unsubscr
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/19427
I don't think there is an automated way. You could create a JIRA ticket
and rename this title with the ticket id and component name
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/19427
@ssaavedra Could you also update the Title as [SPARK-X][component]
Title... please.
---
-
To unsubscribe, e-mail: reviews
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/18029
Thanks for the review @brkyvz .
Please have a look at the new PR. I have implemented the review comments.
For the API hygiene, I have added both the new and old API, and have marked
the old
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/18029
Thanks @brkyvz . Appreciate the review comments.
I am facing some issues with the scala packaging. I will keep working on it
and update the patch soon
Github user yssharma commented on a diff in the pull request:
https://github.com/apache/spark/pull/19416#discussion_r142368186
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/FlatMapGroupsWithState_StateManager.scala
---
@@ -0,0 +1,143
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/18029
Hi @brkyvz can I get some love here please.
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/18029
@brkyvz Could you please check this for the last suggestions ?
---
-
To unsubscribe, e-mail: reviews-unsubscr
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/18029
@budde could you please do one last review of this one.
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
Github user yssharma commented on a diff in the pull request:
https://github.com/apache/spark/pull/18029#discussion_r137926490
--- Diff:
external/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/InitialPosition.scala
---
@@ -0,0 +1,104 @@
+/*
+ * Licensed
Github user yssharma commented on a diff in the pull request:
https://github.com/apache/spark/pull/18029#discussion_r137684968
--- Diff:
external/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/InitialPosition.scala
---
@@ -0,0 +1,104 @@
+/*
+ * Licensed
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/18029
Thanks for the comments @brkyvz . I will be working on the changes and
update the PR very soon.
---
-
To unsubscribe, e-mail
Github user yssharma commented on a diff in the pull request:
https://github.com/apache/spark/pull/18029#discussion_r137245127
--- Diff:
external/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/InitialPosition.scala
---
@@ -0,0 +1,104 @@
+/*
+ * Licensed
Github user yssharma commented on a diff in the pull request:
https://github.com/apache/spark/pull/18029#discussion_r137237166
--- Diff:
external/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/InitialPosition.scala
---
@@ -0,0 +1,104 @@
+/*
+ * Licensed
Github user yssharma commented on a diff in the pull request:
https://github.com/apache/spark/pull/18029#discussion_r137235013
--- Diff:
external/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/InitialPosition.scala
---
@@ -0,0 +1,104 @@
+/*
+ * Licensed
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/18029
Resolved conflict introduced by other code commits.
---
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
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/18029
Could I get some love here from the committers please @brkyvz @HyukjinKwon
@srowen . Would love to work on any changes if required.
---
If your project is set up for it, you can reply
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/18029
Hi @srowen we've iterated this patch to bring it in a good state. Need a
committer âï¸ before we can go ahead merging it.
---
If your project is set up for it, you can reply to this email
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/18029
Will wait for @brkyvz , @HyukjinKwon for final âï¸
---
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
Github user yssharma commented on a diff in the pull request:
https://github.com/apache/spark/pull/18029#discussion_r134138994
--- Diff:
external/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/InitialPosition.scala
---
@@ -0,0 +1,104 @@
+/*
+ * Licensed
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/18029
Added review suggestions @budde !
---
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
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/18029
Will update and post another request seen. Thanks.
---
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
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/18029
@brkyvz I have made the suggested modifications to the code. Please have a
look when you get time. Thanks
---
If your project is set up for it, you can reply to this email and have your
reply
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/18029
Thanks @budde for the review . Love the suggestions. ð
---
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
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/18029
@brkyvz , @budde, @HyukjinKwon could you please review this sometime.
---
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
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/18029
Would love to work on the review feedback here @budde @brkyvz . Please
have a look when you have time.
---
If your project is set up for it, you can reply to this email and have your
reply
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/18071
Thanks @budde @srowen
---
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
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/18071
Updated the patch @HyukjinKwon . Thanks for the note. ð
---
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
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/18071
I noticed that now. Yes I will post an updated patch today. Thanks
@HyukjinKwon
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/18071
@HyukjinKwon The PR is ready. Just waiting for some ð from the reviewers.
---
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
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/18029
@budde @brkyvz - could I get some love here please.
---
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
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/18029
Hi, @budde , @brkyvz would love to hear your thoughts on the new patch
---
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
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/18029
I really appreciate you taking time to review the changes. I know balancing
work and foss contributions is difficult :)
I have given a clean new stab at the issue with all the feedbacks. Let me
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/18029
@budde @brkyvz could you suggest if the current patch seems ok, or I should
make something similar to the case class/ trait ?
---
If your project is set up for it, you can reply to this email
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/18029
@budde What would that mean for existing applications that are sending an
`InitialPositionInStream.SOMETHING` to the the builder. We would need to
provide multiple overloaded versions
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/18029
Thoughts - @budde @brkyvz ?
---
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
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/18029
For review @budde @brkyvz ^ this looks in a good state.
@brkyvz - I still didn't quite get the code bit you shared, would love to
make changes if you could explain that piece of your mind
Github user yssharma commented on a diff in the pull request:
https://github.com/apache/spark/pull/18029#discussion_r120236128
--- Diff:
external/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisInputDStream.scala
---
@@ -193,6 +197,21 @@ object
Github user yssharma commented on a diff in the pull request:
https://github.com/apache/spark/pull/18029#discussion_r120236059
--- Diff:
external/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisInputDStream.scala
---
@@ -100,6 +103,7 @@ object
Github user yssharma commented on a diff in the pull request:
https://github.com/apache/spark/pull/18029#discussion_r120235619
--- Diff:
external/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisInputDStream.scala
---
@@ -193,6 +197,21 @@ object
Github user yssharma commented on a diff in the pull request:
https://github.com/apache/spark/pull/18029#discussion_r120234200
--- Diff:
external/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisInputDStream.scala
---
@@ -100,6 +103,7 @@ object
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/18029
```
./bin/spark-shell --jars
/Users/ysharma/.m2/repository/org/apache/spark/spark-streaming-kinesis-asl_2.11/2.3.0-SNAPSHOT/spark-streaming-kinesis-asl_2.11-2.3.0-SNAPSHOT.jar
--packages
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/18029
@budde @brkyvz - Would appreciate if you could share some tips by which I
could include these external kinesis modules on spark-shell to test this
directly from shell (both for scala and python
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/18029
@budde Added a new method to pass the timestamp more elegantly.
---
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
Github user yssharma commented on a diff in the pull request:
https://github.com/apache/spark/pull/18029#discussion_r119986035
--- Diff:
external/kinesis-asl/src/test/java/org/apache/spark/streaming/kinesis/JavaKinesisInputDStreamBuilderSuite.java
---
@@ -45,7 +46,7 @@ public
Github user yssharma commented on a diff in the pull request:
https://github.com/apache/spark/pull/18029#discussion_r119986280
--- Diff:
external/kinesis-asl/src/test/scala/org/apache/spark/streaming/kinesis/KinesisInputDStreamBuilderSuite.scala
---
@@ -111,5 +110,28 @@ class
Github user yssharma commented on a diff in the pull request:
https://github.com/apache/spark/pull/18029#discussion_r119984045
--- Diff:
external/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisInputDStream.scala
---
@@ -38,6 +40,7 @@ private[kinesis] class
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/18029
Could I get some love here please @budde @brkyvz
This change is pretty useful for us and I would like to bake this patch
well so others can take advantage of this feature.
---
If your
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/18071
Hey @budde , drawing your attention here please.
Just wanted to update the docs with the new Builder interface by you. Few
questions on top of my mind -
- Is it compatible with the python
GitHub user yssharma opened a pull request:
https://github.com/apache/spark/pull/18071
[SPARK-20855][WIP][DStream] Update the Spark kinesis docs to use the
KinesisInputDStream builder instead of deprecated KinesisUtils
## What changes were proposed in this pull request
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/18029
Simplified how timestamp is passed to Kinesis for
InitialPositionInStream.AT_TIMESTAMP.
cc: @budde , @brkyvz
---
If your project is set up for it, you can reply to this email and have your
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/18029
Commit
https://github.com/apache/spark/commit/424550c8450937f78ce608ff7b18e46f41478a8a
should fix the timeouts mentioned in the
https://github.com/apache/spark/commit
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/18029
@budde @brkyvz would love to hear your thoughts if this is the best way to
add this functionality
---
If your project is set up for it, you can reply to this email and have your
reply appear
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/18028
Thanks @brkyvz
---
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
GitHub user yssharma opened a pull request:
https://github.com/apache/spark/pull/18029
[SPARK-20168][WIP][DStream] Add changes to use kinesis fetches from
specified timestamp
## What changes were proposed in this pull request?
Kinesis client can resume from a specified
GitHub user yssharma opened a pull request:
https://github.com/apache/spark/pull/18028
[DStream][DOC]Add documentation for kinesis retry configurations
## What changes were proposed in this pull request?
The changes were merged as part of -
https://github.com/apache/spark
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/17467
Awesome. Thanks @budde @brkyvz for reviews and patch improvements.
---
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
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/17467
@budde @brkyvz - Any feed back on this one please ?
---
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
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/17467
Thanks for all the review comments @budde @brkyvz . Added new review
changes.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well
Github user yssharma commented on a diff in the pull request:
https://github.com/apache/spark/pull/17467#discussion_r115110773
--- Diff:
external/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisReadConfigurations.scala
---
@@ -0,0 +1,71
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/17467
Thanks for the comments @budde @brkyvz . Would be adding the changes soon.
I too liked pulling the values of spark conf directly and got it working
with the private val
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/17467
@brkyvz - Thanks for the review comments. Updated the patch, please review.
---
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
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/17467
@budde would you like to share your thoughts on the new changes when you
have time ?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/17467
@brkyvz - Added new changes that adds -
- A case class `KinesisReadConfigurations` that adds all the kinesis read
configs in a single place
- A test class that passes the kinesis configs
Github user yssharma commented on a diff in the pull request:
https://github.com/apache/spark/pull/17467#discussion_r112848855
--- Diff:
external/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisBackedBlockRDD.scala
---
@@ -135,7 +139,8 @@ class
Github user yssharma commented on a diff in the pull request:
https://github.com/apache/spark/pull/17467#discussion_r112848762
--- Diff:
external/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisBackedBlockRDD.scala
---
@@ -135,7 +139,8 @@ class
Github user yssharma commented on a diff in the pull request:
https://github.com/apache/spark/pull/17467#discussion_r112848401
--- Diff:
external/kinesis-asl/src/test/scala/org/apache/spark/streaming/kinesis/KinesisBackedBlockRDDSuite.scala
---
@@ -101,6 +103,36 @@ abstract class
Github user yssharma commented on a diff in the pull request:
https://github.com/apache/spark/pull/17467#discussion_r112848373
--- Diff:
external/kinesis-asl/src/test/scala/org/apache/spark/streaming/kinesis/KinesisBackedBlockRDDSuite.scala
---
@@ -101,6 +103,36 @@ abstract class
Github user yssharma commented on a diff in the pull request:
https://github.com/apache/spark/pull/17467#discussion_r112848363
--- Diff:
external/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisBackedBlockRDD.scala
---
@@ -135,7 +139,8 @@ class
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/17467
@felixcheung : would love to get more review comments to improve the patch.
---
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
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/17467
@budde - Added changes for the minor review comments and docs.
---
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
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/17467
@budde - Not sure if we can exactly test the configured timeouts. I have
debugged the flow in my testcase to verify that the custom values are passed
down to the Kinesis backed block rdd
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/17467
@budde : Implemented review changes and checked scala code style checks
---
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
Github user yssharma commented on a diff in the pull request:
https://github.com/apache/spark/pull/17467#discussion_r112614624
--- Diff:
external/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisBackedBlockRDD.scala
---
@@ -83,7 +83,8 @@ class
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/17467
@budde @brkyvz - Implemented the review changes. Please review.
- Using SparkConf for all the user parameters
- removed kinesisWait to be val instead of var
- fixed documentation
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/17467
@budde - thanks for taking time to review it. Appreciate it.
---
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
Github user yssharma commented on a diff in the pull request:
https://github.com/apache/spark/pull/17467#discussion_r112347174
--- Diff:
external/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisInputDStream.scala
---
@@ -249,6 +252,17 @@ object
Github user yssharma commented on a diff in the pull request:
https://github.com/apache/spark/pull/17467#discussion_r112346805
--- Diff:
external/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisBackedBlockRDD.scala
---
@@ -147,6 +152,14 @@ class
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/17506
Thanks @srowen
---
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
Github user yssharma commented on a diff in the pull request:
https://github.com/apache/spark/pull/17506#discussion_r111292109
--- Diff:
external/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisInputDStream.scala
---
@@ -267,7 +267,7 @@ object
Github user yssharma commented on a diff in the pull request:
https://github.com/apache/spark/pull/17506#discussion_r111291842
--- Diff:
external/kinesis-asl/src/test/scala/org/apache/spark/streaming/kinesis/KinesisStreamSuite.scala
---
@@ -233,11 +241,15 @@ abstract class
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/17467
Waiting for review @brkyvz . Thanks.
---
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
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/17506
@srowen do you feel this patch could be merged now ?
Thanks
---
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
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/17467
Just for info, while trying to use the `sc` in the `KinesisBackedBlockRDD `
:
`- Basic reading from Kinesis *** FAILED ***
org.apache.spark.SparkException: Task not serializable
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/17506
Is there anything else that can be done on this patch. The patch fixes all
the deprecated api testcases that try to use the aws secret/id credentials
instead of the builder.
---
If your project
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/17467
@brkyvz - thanks for taking time to review the patch. appreciate it.
Implemented all your suggestions. Now passing a new map for the kinesis
configs and added mechanism to use the builder
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/17506
Thanks @srowen
---
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
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/17506
@srowen - does the Jenkins re-test trigger automatically?
else, could I request a retest on this patch please ?
---
If your project is set up for it, you can reply to this email and have your
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/17506
@srowen : It failed on the earlier patch with KinesisTestUtils.scala
changes. This version is clean. Will wait for the next automated build :)
Build logs:
https://amplab.cs.berkeley.edu
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/17506
The Scala style check fail because of the double spaced lines probably. But
that's how the existing code was so thought of keeping it that way.
---
If your project is set up for it, you can reply
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/17467
@srowen - Could I get some love here as well. Thanks
---
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
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/17506
@srowen - Thanks for the feedback. Appreciate it. Added a minimal
simplified patch which fixes the testcases that fail with the old api.
---
If your project is set up for it, you can reply
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/17506
@srowen - Yes, 2 objectives for the patch:
- add new testcases for new api (that also tests aws session tokens)
- ability to disable old api test cases
For now I have added new test
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/17467
Can I get some feedback here please @tdas @brkyvz Thanks :)
---
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
Github user yssharma commented on the issue:
https://github.com/apache/spark/pull/17506
@srowen - Have made following improvements to the patch to incorporate your
points:
- Did not remove old testcases for keeping the checks on old api
- Added new testcases that test the new
Github user yssharma commented on a diff in the pull request:
https://github.com/apache/spark/pull/17506#discussion_r109304637
--- Diff:
external/kinesis-asl/src/test/java/org/apache/spark/streaming/kinesis/JavaKinesisStreamSuite.java
---
@@ -50,48 +56,86 @@ public void
1 - 100 of 109 matches
Mail list logo
