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

[BUG] Exception running on Spark 3.1.x and 3.2.x due to different constructors of StageInfo #1260

Open
1 of 2 tasks
amahussein opened this issue Aug 5, 2024 · 1 comment
Assignees
Labels
bug Something isn't working core_tools Scope the core module (scala)

Comments

@amahussein
Copy link
Collaborator

amahussein commented Aug 5, 2024

Describe the bug

This is breaking the CI/CD

ARNING: An illegal reflective access operation has occurred
02:08:54  WARNING: Illegal reflective access by org.apache.spark.unsafe.Platform (file:/workspace/spark-qualification-tool/spark-3.1.2-bin-hadoop3.2/jars/spark-unsafe_2.12-3.1.2.jar) to constructor java.nio.DirectByteBuffer(long,int)
02:08:54  WARNING: Please consider reporting this to the maintainers of org.apache.spark.unsafe.Platform
02:08:54  WARNING: Use --illegal-access=warn to enable warnings of further illegal reflective access operations
02:08:54  WARNING: All illegal access operations will be denied in a future release
02:08:54  24/08/05 07:08:54 ERROR Qualification: Error occurred while processing file: s3a://mydirectory/qualification_testing/app-xyz-0123
02:08:54  java.lang.NoSuchMethodError: 'boolean org.apache.spark.scheduler.StageInfo$.$lessinit$greater$default$12()'
02:08:54  	at org.apache.spark.sql.rapids.tool.store.StageModel.initStageInfo(StageModel.scala:44)
02:08:54  	at org.apache.spark.sql.rapids.tool.store.StageModel.org$apache$spark$sql$rapids$tool$store$StageModel$$updateInfo(StageModel.scala:70)
02:08:54  	at org.apache.spark.sql.rapids.tool.store.StageModel.<init>(StageModel.scala:35)
02:08:54  	at org.apache.spark.sql.rapids.tool.store.StageModel$.apply(StageModel.scala:127)
02:08:54  	at org.apache.spark.sql.rapids.tool.store.StageModelManager.getOrCreateStage(StageModelManager.scala:75)
02:08:54  	at org.apache.spark.sql.rapids.tool.store.StageModelManager.addStageInfo(StageModelManager.scala:122)
02:08:54  	at org.apache.spark.sql.rapids.tool.AppBase.getOrCreateStage(AppBase.scala:169)
02:08:54  	at org.apache.spark.sql.rapids.tool.EventProcessorBase.doSparkListenerStageSubmitted(EventProcessorBase.scala:455)
02:08:54  	at org.apache.spark.sql.rapids.tool.EventProcessorBase.processAnyEvent(EventProcessorBase.scala:80)
02:08:54  	at org.apache.spark.sql.rapids.tool.qualification.QualificationAppInfo.processEvent(QualificationAppInfo.scala:87)
02:08:54  	at org.apache.spark.sql.rapids.tool.AppBase.$anonfun$processEventsInternal$6(AppBase.scala:268)
02:08:54  	at org.apache.spark.sql.rapids.tool.AppBase.$anonfun$processEventsInternal$6$adapted(AppBase.scala:263)
02:08:54  	at scala.collection.Iterator.find(Iterator.scala:993)
02:08:54  	at scala.collection.Iterator.find$(Iterator.scala:990)
02:08:54  	at scala.collection.AbstractIterator.find(Iterator.scala:1429)
02:08:54  	at org.apache.spark.sql.rapids.tool.AppBase.$anonfun$processEventsInternal$5(AppBase.scala:263)
02:08:54  	at org.apache.spark.util.Utils$.tryWithResource(Utils.scala:2622)
02:08:54  	at org.apache.spark.sql.rapids.tool.AppBase.$anonfun$processEventsInternal$3(AppBase.scala:262)
02:08:54  	at scala.collection.immutable.List.foreach(List.scala:392)
02:08:54  	at org.apache.spark.sql.rapids.tool.AppBase.processEventsInternal(AppBase.scala:261)
02:08:54  	at org.apache.spark.sql.rapids.tool.AppBase.processEvents(AppBase.scala:405)
02:08:54  	at org.apache.spark.sql.rapids.tool.qualification.QualificationAppInfo.<init>(QualificationAppInfo.scala:84)
02:08:54  	at org.apache.spark.sql.rapids.tool.qualification.QualificationAppInfo$.createApp(QualificationAppInfo.scala:1101)
02:08:54  	at com.nvidia.spark.rapids.tool.qualification.Qualification.com$nvidia$spark$rapids$tool$qualification$Qualification$$qualifyApp(Qualification.scala:148)
02:08:54  	at com.nvidia.spark.rapids.tool.qualification.Qualification$QualifyThread.run(Qualification.scala:49)
02:08:54  	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
02:08:54  	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
02:08:54  	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
02:08:54  	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
02:08:54  	at java.base/java.lang.Thread.run(Thread.java:829)
02:08:54  24/08/05 07:08:54 INFO MetricsSystemImpl: Stopping s3a-file-system metrics system...
02:08:54  24/08/05 07:08:54 INFO MetricsSystemImpl: s3a-file-system metrics system stopped.
02:08:54  24/08/05 07:08:54 INFO MetricsSystemImpl: s3a-file-system metrics system shutdown complete.

Tasks

  1. bug core_tools
    nartal1
@amahussein amahussein added bug Something isn't working core_tools Scope the core module (scala) labels Aug 5, 2024
@amahussein
Copy link
Collaborator Author

The jar on mvn is built using spark-3.5 but the runtime would be an old version.
@parthosa FYI, we might need to consider this case in our testing.

@nartal1 nartal1 assigned amahussein and unassigned nartal1 Aug 19, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
bug Something isn't working core_tools Scope the core module (scala)
Projects
None yet
Development

No branches or pull requests

2 participants