Hi,
It seems you hit this issue:
https://issues.apache.org/jira/browse/SPARK-18020
// maropu
On Tue, Jan 17, 2017 at 11:51 AM, noppanit <noppani...@gmail.com> wrote:
> I'm totally new to Spark and I'm trying to learn from the example. I'm
> following this example
>
> https://github.com/apache/spark/blob/master/external/
> kinesis-asl/src/main/scala/org/apache/spark/examples/
> streaming/KinesisWordCountASL.scala.
>
> It works well. But I do have one question. Every time I split/merge Kinesis
> shards from the Amazon API, I have to restart the application. Is there a
> way for Spark application to automatically rebalance or to notify the
> application that Kinesis shards have been split or merged? I have to
> restart
> the application so I can see more shards in DynamoDB.
>
>
>
> --
> View this message in context: http://apache-spark-user-list.
> 1001560.n3.nabble.com/Apache-Spark-example-split-merge-shards-tp28311.html
> Sent from the Apache Spark User List mailing list archive at Nabble.com.
>
> -
> To unsubscribe e-mail: user-unsubscr...@spark.apache.org
>
>
--
---
Takeshi Yamamuro
