Open glaucotiburtino opened 4 months ago
Most likely your jar is not getting loaded.
I am using jar approach as well although I am getting directly from url:
https://awslabs-code-us-east-1.s3.amazonaws.com/spark-sql-kinesis-connector/spark-streaming-sql-kinesis-connector_2.12-1.0.0.jar
Try that.
Even using it this way, I got the same error again, which version of EMR are you using?
Even using it this way, I got the same error again, which version of EMR are you using?
I am running spark 3.5 on Kubernetes using a spark operator.
Can you send full spark submit command?
Good morning, have you been having this problem with the Kinesis connector? If so, how did you fix it?
Failed to find data source: kinesis. Please find packages at https://spark.apache.org/third-party-projects.html
Caused by: java.lang.ClassNotFoundException: kinesis.DefaultSource at java.net.URLClassLoader.findClass(URLClassLoader.java:387) at java.lang.ClassLoader.loadClass(ClassLoader.java:418) at java.lang.ClassLoader.loadClass(ClassLoader.java:351) at org.apache.spark.sql.execution.datasources.DataSource$.$anonfun$lookupDataSource$5(DataSource.scala:661) at scala.util.Try$.apply(Try.scala:213) at org.apache.spark.sql.execution.datasources.DataSource$.$anonfun$lookupDataSource$4(DataSource.scala:661) at scala.util.Failure.orElse(Try.scala:224) at org.apache.spark.sql.execution.datasources.DataSource$.lookupDataSource(DataSource.scala:661) ... 14 more
i`m using --jars s3://awslabs-code-us-east-1/spark-sql-kinesis-connector/spark-streaming-sql-kinesis-connector_2.12-1.0.0.jar