Skip to content

Commit e347827

Browse files
authored
Remove Spark 2.x (#2316)
1 parent f277311 commit e347827

File tree

101 files changed

+28
-11391
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

101 files changed

+28
-11391
lines changed

dist/build.gradle

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@ base {
1212
archivesName = 'elasticsearch-hadoop'
1313
}
1414

15-
def sparkVariantIncluded = 'spark20scala211'
15+
def sparkVariantIncluded = 'spark30scala212'
1616

1717
configurations {
1818
embedded {
@@ -47,17 +47,17 @@ configurations {
4747

4848
BuildPlugin.disableTransitiveDependencies(project, project.configurations.thirdPartyShaded)
4949

50-
def distProjects = [":elasticsearch-hadoop-mr", ":elasticsearch-hadoop-hive",
51-
":elasticsearch-spark-20"]
50+
def distProjects = [":elasticsearch-hadoop-mr", ":elasticsearch-hadoop-hive", ":elasticsearch-spark-30"]
5251

5352
distProjects.each { distProject ->
5453
def configureDistDependency = { Dependency dependency ->
55-
if (distProject == ":elasticsearch-spark-20") {
54+
if (distProject == ":elasticsearch-spark-30") {
5655
dependency.capabilities {
5756
requireCapability("org.elasticsearch.spark.sql.variant:$sparkVariantIncluded:$project.version")
5857
}
5958
}
6059
}
60+
6161
dependencies {
6262
// This is only going to pull in each project's regular jar to create the project-wide uberjar.
6363
add('embedded', project(distProject), configureDistDependency)
@@ -86,25 +86,25 @@ dependencies {
8686
}
8787
implementation("org.apache.hive:hive-exec:$hiveVersion")
8888
implementation("org.apache.hive:hive-metastore:$hiveVersion")
89-
implementation("org.apache.spark:spark-core_${project.ext.scala211MajorVersion}:$spark20Version") {
89+
implementation("org.apache.spark:spark-core_${project.ext.scala212MajorVersion}:$spark30Version") {
9090
exclude group: 'javax.servlet'
9191
exclude group: 'org.apache.hadoop'
9292
}
93-
implementation("org.apache.spark:spark-yarn_${project.ext.scala211MajorVersion}:$spark20Version") {
93+
implementation("org.apache.spark:spark-yarn_${project.ext.scala212MajorVersion}:$spark30Version") {
9494
exclude group: 'org.apache.hadoop'
9595
}
96-
implementation("org.apache.spark:spark-sql_${project.ext.scala211MajorVersion}:$spark20Version") {
96+
implementation("org.apache.spark:spark-sql_${project.ext.scala212MajorVersion}:$spark30Version") {
9797
exclude group: 'org.apache.hadoop'
9898
}
99-
implementation("org.apache.spark:spark-streaming_${project.ext.scala211MajorVersion}:$spark20Version") {
99+
implementation("org.apache.spark:spark-streaming_${project.ext.scala212MajorVersion}:$spark30Version") {
100100
exclude group: 'org.apache.hadoop'
101101
}
102102
implementation("org.scala-lang:scala-library:$scala211Version")
103103
implementation("org.scala-lang:scala-reflect:$scala211Version")
104104
implementation(project.ext.hadoopClient)
105105
implementation("org.apache.hadoop:hadoop-common:${project.ext.hadoopVersion}")
106106
implementation("org.apache.hadoop:hadoop-mapreduce-client-core:${project.ext.hadoopVersion}")
107-
compileOnly("org.apache.spark:spark-catalyst_${project.ext.scala211MajorVersion}:$spark20Version")
107+
compileOnly("org.apache.spark:spark-catalyst_${project.ext.scala212MajorVersion}:$spark30Version")
108108
}
109109

110110
// Configure uber jar

dist/licenses/spark-core_2.11-2.3.0.jar.sha1

Lines changed: 0 additions & 1 deletion
This file was deleted.
Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
6f7105e792cbb650eca44890f0444720bd6a8204

dist/licenses/spark-sql_2.11-2.3.0.jar.sha1

Lines changed: 0 additions & 1 deletion
This file was deleted.
Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
a28ead1aa19899654296a6f8a458f8f207f89a73

dist/licenses/spark-streaming_2.11-2.3.0.jar.sha1

Lines changed: 0 additions & 1 deletion
This file was deleted.
Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
e4a9f76eff1db09c67f855cdf60cd83bbfad69ab

dist/licenses/spark-yarn_2.11-2.3.0.jar.sha1

Lines changed: 0 additions & 1 deletion
This file was deleted.
Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
0c8dd1e45fbc589d2438a889c7fe98f0e9fd77ec

docs/src/reference/asciidoc/appendix/breaking.adoc

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,16 @@ For clarity, we always list any breaking changes at the top of the
88
//NOTE: The notable-breaking-changes tagged regions are re-used in the
99
//Installation and Upgrade Guide
1010

11+
[[breaking-changes-90]]
12+
=== Breaking Changes in 9.0
13+
14+
This section details the breaking changes when upgrading {eh} from 8.x to 9.0.
15+
16+
[[removals-9.0]]
17+
==== Removal of Spark 2.x
18+
19+
Support for the Spark 2.x has been removed in {eh} 9.0. Spark 3.x is the new default supported version.
20+
1121
=== Deprecations in 8.18
1222

1323
The following functionality has been deprecated in {eh} 8.18 and will be removed

0 commit comments

Comments
 (0)