spark-reviews mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From yssharma <>
Subject [GitHub] spark issue #18029: [SPARK-20168][WIP][DStream] Add changes to use kinesis f...
Date Mon, 05 Jun 2017 13:34:46 GMT
Github user yssharma commented on the issue:
    ./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 com.amazonaws:amazon-kinesis-client:1.0.0 -Ylog-classpath
    import org.apache.spark.SparkConf
    import org.apache.spark.streaming.kinesis.KinesisInputDStream
    import org.apache.spark.streaming.{Seconds, StreamingContext}
    val streamingContext = new StreamingContext(sc, Seconds(30))
    val kinesisStream = KinesisInputDStream.builder
    error: bad symbolic reference. A signature in KinesisInputDStream.class refers to term
    in package org.apache.spark.annotation which is not available.
    It may be completely missing from the current classpath, or the version on
    the classpath might be incompatible with the version used when compiling KinesisInputDStream.class.

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 or file a JIRA ticket
with INFRA.

To unsubscribe, e-mail:
For additional commands, e-mail:

View raw message