Skip to content

Commit 1aca8f4

Browse files
committed
merge into master
2 parents d3905c3 + 6f710cd commit 1aca8f4

File tree

373 files changed

+8430
-3498
lines changed

Some content is hidden

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

373 files changed

+8430
-3498
lines changed

.github/workflows/build_and_test.yml

Lines changed: 13 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -264,20 +264,20 @@ jobs:
264264
with:
265265
distribution: zulu
266266
java-version: ${{ matrix.java }}
267-
- name: Install Python 3.9
267+
- name: Install Python 3.11
268268
uses: actions/setup-python@v5
269269
# We should install one Python that is higher than 3+ for SQL and Yarn because:
270270
# - SQL component also has Python related tests, for example, IntegratedUDFTestUtils.
271271
# - Yarn has a Python specific test too, for example, YarnClusterSuite.
272272
if: contains(matrix.modules, 'yarn') || (contains(matrix.modules, 'sql') && !contains(matrix.modules, 'sql-')) || contains(matrix.modules, 'connect')
273273
with:
274-
python-version: '3.9'
274+
python-version: '3.11'
275275
architecture: x64
276-
- name: Install Python packages (Python 3.9)
276+
- name: Install Python packages (Python 3.11)
277277
if: (contains(matrix.modules, 'sql') && !contains(matrix.modules, 'sql-')) || contains(matrix.modules, 'connect')
278278
run: |
279-
python3.9 -m pip install 'numpy>=1.20.0' pyarrow pandas scipy unittest-xml-reporting 'lxml==4.9.4' 'grpcio==1.62.0' 'grpcio-status==1.62.0' 'protobuf==4.25.1'
280-
python3.9 -m pip list
279+
python3.11 -m pip install 'numpy>=1.20.0' pyarrow pandas scipy unittest-xml-reporting 'lxml==4.9.4' 'grpcio==1.62.0' 'grpcio-status==1.62.0' 'protobuf==4.25.1'
280+
python3.11 -m pip list
281281
# Run the tests.
282282
- name: Run tests
283283
env: ${{ fromJSON(inputs.envs) }}
@@ -608,14 +608,14 @@ jobs:
608608
with:
609609
input: sql/connect/common/src/main
610610
against: 'https://github.com/apache/spark.git#branch=branch-3.5,subdir=connector/connect/common/src/main'
611-
- name: Install Python 3.9
611+
- name: Install Python 3.11
612612
uses: actions/setup-python@v5
613613
with:
614-
python-version: '3.9'
614+
python-version: '3.11'
615615
- name: Install dependencies for Python CodeGen check
616616
run: |
617-
python3.9 -m pip install 'black==23.9.1' 'protobuf==4.25.1' 'mypy==1.8.0' 'mypy-protobuf==3.3.0'
618-
python3.9 -m pip list
617+
python3.11 -m pip install 'black==23.9.1' 'protobuf==4.25.1' 'mypy==1.8.0' 'mypy-protobuf==3.3.0'
618+
python3.11 -m pip list
619619
- name: Python CodeGen check
620620
run: ./dev/connect-check-protos.py
621621

@@ -1112,6 +1112,10 @@ jobs:
11121112
with:
11131113
distribution: zulu
11141114
java-version: ${{ inputs.java }}
1115+
- name: Install R
1116+
run: |
1117+
sudo apt update
1118+
sudo apt-get install r-base
11151119
- name: Start Minikube
11161120
uses: medyagh/[email protected]
11171121
with:

.github/workflows/pages.yml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -40,6 +40,7 @@ jobs:
4040
env:
4141
SPARK_TESTING: 1 # Reduce some noise in the logs
4242
RELEASE_VERSION: 'In-Progress'
43+
if: github.repository == 'apache/spark'
4344
steps:
4445
- name: Checkout Spark repository
4546
uses: actions/checkout@v4

LICENSE-binary

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -402,7 +402,6 @@ org.xerial.snappy:snappy-java
402402
org.yaml:snakeyaml
403403
oro:oro
404404
stax:stax-api
405-
xerces:xercesImpl
406405

407406
core/src/main/java/org/apache/spark/util/collection/TimSort.java
408407
core/src/main/resources/org/apache/spark/ui/static/bootstrap*

NOTICE-binary

Lines changed: 0 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -448,27 +448,6 @@ which has the following notices:
448448
* Alec Wysoker
449449
* Performance and memory usage improvement
450450

451-
The binary distribution of this product bundles binaries of
452-
Xerces2 Java Parser 2.9.1,
453-
which has the following notices:
454-
* =========================================================================
455-
== NOTICE file corresponding to section 4(d) of the Apache License, ==
456-
== Version 2.0, in this case for the Apache Xerces Java distribution. ==
457-
=========================================================================
458-
459-
Apache Xerces Java
460-
Copyright 1999-2007 The Apache Software Foundation
461-
462-
This product includes software developed at
463-
The Apache Software Foundation (http://www.apache.org/).
464-
465-
Portions of this software were originally based on the following:
466-
- software copyright (c) 1999, IBM Corporation., http://www.ibm.com.
467-
- software copyright (c) 1999, Sun Microsystems., http://www.sun.com.
468-
- voluntary contributions made by Paul Eng on behalf of the
469-
Apache Software Foundation that were originally developed at iClick, Inc.,
470-
software copyright (c) 1999.
471-
472451
Apache Commons Collections
473452
Copyright 2001-2015 The Apache Software Foundation
474453

R/pkg/DESCRIPTION

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -57,6 +57,7 @@ Collate:
5757
'types.R'
5858
'utils.R'
5959
'window.R'
60+
'zzz.R'
6061
RoxygenNote: 7.1.2
6162
VignetteBuilder: knitr
6263
NeedsCompilation: no

R/pkg/R/sparkR.R

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -403,12 +403,6 @@ sparkR.session <- function(
403403
sparkPackages = "",
404404
enableHiveSupport = TRUE,
405405
...) {
406-
407-
if (Sys.getenv("SPARKR_SUPPRESS_DEPRECATION_WARNING") == "") {
408-
warning(
409-
"SparkR is deprecated from Apache Spark 4.0.0 and will be removed in a future version.")
410-
}
411-
412406
sparkConfigMap <- convertNamedListToEnv(sparkConfig)
413407
namedParams <- list(...)
414408
if (length(namedParams) > 0) {

R/pkg/R/zzz.R

Lines changed: 30 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,30 @@
1+
#
2+
# Licensed to the Apache Software Foundation (ASF) under one or more
3+
# contributor license agreements. See the NOTICE file distributed with
4+
# this work for additional information regarding copyright ownership.
5+
# The ASF licenses this file to You under the Apache License, Version 2.0
6+
# (the "License"); you may not use this file except in compliance with
7+
# the License. You may obtain a copy of the License at
8+
#
9+
# http://www.apache.org/licenses/LICENSE-2.0
10+
#
11+
# Unless required by applicable law or agreed to in writing, software
12+
# distributed under the License is distributed on an "AS IS" BASIS,
13+
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14+
# See the License for the specific language governing permissions and
15+
# limitations under the License.
16+
#
17+
# zzz.R - package startup message
18+
19+
.onAttach <- function(...) {
20+
if (Sys.getenv("SPARKR_SUPPRESS_DEPRECATION_WARNING") == "") {
21+
packageStartupMessage(
22+
paste0(
23+
"Warning: ",
24+
"SparkR is deprecated in Apache Spark 4.0.0 and will be removed in a future release. ",
25+
"To continue using Spark in R, we recommend using sparklyr instead: ",
26+
"https://spark.posit.co/get-started/"
27+
)
28+
)
29+
}
30+
}

assembly/pom.xml

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -117,6 +117,12 @@
117117
<groupId>org.apache.spark</groupId>
118118
<artifactId>spark-connect-client-jvm_${scala.binary.version}</artifactId>
119119
<version>${project.version}</version>
120+
<exclusions>
121+
<exclusion>
122+
<groupId>org.apache.spark</groupId>
123+
<artifactId>spark-connect-shims_${scala.binary.version}</artifactId>
124+
</exclusion>
125+
</exclusions>
120126
<scope>provided</scope>
121127
</dependency>
122128

common/unsafe/src/main/java/org/apache/spark/sql/catalyst/util/CollationAwareUTF8String.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1363,9 +1363,9 @@ public static UTF8String trimRight(
13631363

13641364
public static UTF8String[] splitSQL(final UTF8String input, final UTF8String delim,
13651365
final int limit, final int collationId) {
1366-
if (CollationFactory.fetchCollation(collationId).supportsBinaryEquality) {
1366+
if (CollationFactory.fetchCollation(collationId).isUtf8BinaryType) {
13671367
return input.split(delim, limit);
1368-
} else if (CollationFactory.fetchCollation(collationId).supportsLowercaseEquality) {
1368+
} else if (CollationFactory.fetchCollation(collationId).isUtf8LcaseType) {
13691369
return lowercaseSplitSQL(input, delim, limit);
13701370
} else {
13711371
return icuSplitSQL(input, delim, limit, collationId);

0 commit comments

Comments
 (0)