Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[FEATURE] Add support for Apache Spark 3.5.1 (streaming) #496

Open
braniq opened this issue Jul 19, 2024 · 0 comments
Open

[FEATURE] Add support for Apache Spark 3.5.1 (streaming) #496

braniq opened this issue Jul 19, 2024 · 0 comments
Labels
enhancement New feature or request

Comments

@braniq
Copy link

braniq commented Jul 19, 2024

Is your feature request related to a problem?

I try to use Opensearch with Spark 3.5.1 and I found out that this version of Spark is not yet supported. This is valid for Spark streaming (writing stream to Opensearch) because there were changes made on side of Spark API. Batch processing seems to be working.

What solution would you like?

It would be good if next release would contain also support for Apache Spark 3.5.1 (streaming)

What alternatives have you considered?

There is not alternative as I know I have to use previous version of Spark (3.4.3)

Do you have any additional context?

The same problem is with Elasticsearch where the ticket is already created:
elastic/elasticsearch-hadoop#2210
I get the same exeption:
org.apache.spark.SparkException: Job aborted due to stage failure: Task 0 in stage 0.0 failed 4 times, most recent failure: Lost task 0.3 in stage 0.0 (TID 8) : java.lang.NoSuchMethodError: org.apache.spark.sql.catalyst.encoders.RowEncoder$.apply(Lorg/apache/spark/sql/types/StructType;)Lorg/apache/spark/sql/catalyst/encoders/ExpressionEncoder;

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
enhancement New feature or request
Projects
None yet
Development

No branches or pull requests

2 participants