Skip to content

Commit

Permalink
test spark 4.0.0-snapshot
Browse files Browse the repository at this point in the history
  • Loading branch information
cxzl25 committed Apr 25, 2024
1 parent dc634cb commit 68f02f7
Show file tree
Hide file tree
Showing 3 changed files with 7 additions and 5 deletions.
2 changes: 1 addition & 1 deletion java/bench/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,7 @@
<parquet.version>1.13.1</parquet.version>
<scala.binary.version>2.13</scala.binary.version>
<scala.version>2.13.8</scala.version>
<spark.version>3.5.1</spark.version>
<spark.version>4.0.0-SNAPSHOT</spark.version>
</properties>

<dependencyManagement>
Expand Down
5 changes: 3 additions & 2 deletions java/bench/spark/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -171,8 +171,9 @@
<exclude>META-INF/NOTICE-binary</exclude>
<exclude>META-INF/NOTICE.md</exclude>
<exclude>META-INF/NOTICE.txt</exclude>
<exclude>META-INF/DUMMY.SF</exclude>
<exclude>META-INF/DUMMY.DSA</exclude>
<exclude>META-INF/*.SF</exclude>
<exclude>META-INF/*.DSA</exclude>
<exclude>META-INF/*.RSA</exclude>
<exclude>LICENSE</exclude>
<exclude>NOTICE</exclude>
<exclude>THIRD-PARTY</exclude>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -74,7 +74,8 @@
@BenchmarkMode(Mode.AverageTime)
@OutputTimeUnit(TimeUnit.MICROSECONDS)
@AutoService(OrcBenchmark.class)
@Fork(jvmArgsAppend = "--add-opens=java.base/sun.nio.ch=ALL-UNNAMED")
@Fork(jvmArgsAppend = {"--add-opens=java.base/sun.nio.ch=ALL-UNNAMED",
"--add-opens=java.base/sun.util.calendar=ALL-UNNAMED"})
public class SparkBenchmark implements OrcBenchmark {

private static final Path root = Utilities.getBenchmarkRoot();
Expand Down Expand Up @@ -201,7 +202,7 @@ public void fullRead(InputSource source,
default:
break;
}
Seq<Tuple2<String,String>> optionsScala = JavaConverters
Seq<Tuple2<String, String>> optionsScala = JavaConverters
.asScalaBufferConverter(options).asScala().toSeq();
@SuppressWarnings("unchecked")
Map<String,String> scalaMap = (Map<String, String>)Map$.MODULE$.apply(optionsScala);
Expand Down

0 comments on commit 68f02f7

Please sign in to comment.