rithwik-db commented on code in PR #39369:
URL: https://github.com/apache/spark/pull/39369#discussion_r1082896210
##
python/pyspark/ml/torch/tests/test_distributor.py:
##
@@ -349,6 +434,13 @@ def test_get_num_tasks_distributed(self) -> None:
lu-wang-dl commented on code in PR #39369:
URL: https://github.com/apache/spark/pull/39369#discussion_r1082894756
##
python/pyspark/ml/torch/tests/test_distributor.py:
##
@@ -349,6 +434,13 @@ def test_get_num_tasks_distributed(self) -> None:
dongjoon-hyun commented on PR #39671:
URL: https://github.com/apache/spark/pull/39671#issuecomment-1398718941
FYI, GitHub Action is currently on the old version but `jdk8u362` will be
automatically applied in one or two weeks. I'll keep monitoring the version
change.
dongjoon-hyun commented on code in PR #39677:
URL: https://github.com/apache/spark/pull/39677#discussion_r1082842120
##
connector/connect/client/jvm/src/test/scala/org/apache/spark/sql/connect/client/util/RemoteSparkSession.scala:
##
@@ -121,14 +117,14 @@ object
dongjoon-hyun commented on PR #39677:
URL: https://github.com/apache/spark/pull/39677#issuecomment-1398677709
Hi, @zhenlineo . When we use the same JIRA id, we need to add `[FOLLOWUP]`
in the PR title. I added at this time.
--
This is an automated message from the Apache Git Service.
To
dongjoon-hyun closed pull request #39671: [SPARK-40303][DOCS] Deprecate old
Java 8 versions prior to 8u362
URL: https://github.com/apache/spark/pull/39671
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to
dongjoon-hyun commented on PR #39671:
URL: https://github.com/apache/spark/pull/39671#issuecomment-1398671949
Now, both Zulu and Adoptiun(Temurin) are available. Thank you all. Merged to
master.
srowen commented on PR #39190:
URL: https://github.com/apache/spark/pull/39190#issuecomment-1398662080
FWIW, this part was last changed in
https://issues.apache.org/jira/browse/SPARK-24415 to fix a different bug (CC
@ankuriitg ) It might be worth re-running the simple example there to see
sunchao commented on PR #39633:
URL: https://github.com/apache/spark/pull/39633#issuecomment-1398661965
@cloud-fan the idea is similar to skew join but for v2 sources, let me try
to split the code into a separate rule following your idea.
--
This is an automated message from the Apache
zhenlineo commented on PR #39677:
URL: https://github.com/apache/spark/pull/39677#issuecomment-1398630857
cc @HyukjinKwon @LuciferYang Thanks for the review. I address the immediate
fix in this PR.
For other improvements, I've created tickets and we can add as follow ups.
--
This is
zhenlineo commented on code in PR #39541:
URL: https://github.com/apache/spark/pull/39541#discussion_r1082775554
##
connector/connect/client/jvm/src/test/scala/org/apache/spark/sql/connect/client/util/RemoteSparkSession.scala:
##
@@ -0,0 +1,198 @@
+/*
+ * Licensed to the Apache
zhenlineo commented on code in PR #39541:
URL: https://github.com/apache/spark/pull/39541#discussion_r1082771233
##
connector/connect/client/jvm/src/test/scala/org/apache/spark/sql/connect/client/util/RemoteSparkSession.scala:
##
@@ -0,0 +1,198 @@
+/*
+ * Licensed to the Apache
peter-toth commented on PR #38038:
URL: https://github.com/apache/spark/pull/38038#issuecomment-1398625037
cc @cloud-fan
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
zhenlineo commented on code in PR #39541:
URL: https://github.com/apache/spark/pull/39541#discussion_r1082763118
##
connector/connect/client/jvm/src/test/scala/org/apache/spark/sql/connect/client/util/RemoteSparkSession.scala:
##
@@ -0,0 +1,198 @@
+/*
+ * Licensed to the Apache
zhenlineo opened a new pull request, #39677:
URL: https://github.com/apache/spark/pull/39677
### What changes were proposed in this pull request?
Use a better env var to find the spark home in E2E tests.
Fixed the jar finding bug for RC builds.
Use Nano instead of MS for
itholic commented on PR #39505:
URL: https://github.com/apache/spark/pull/39505#issuecomment-1398592475
Test paseed. cc @MaxGekk @cloud-fan
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the
kuwii commented on PR #39190:
URL: https://github.com/apache/spark/pull/39190#issuecomment-1398579998
I'm not familiar with how Spark creates and runs jobs and stages for a
query, but I think it may be related to this case. I can reproduce this locally
using Spark on Yarn mode with this
zhenlineo commented on code in PR #39541:
URL: https://github.com/apache/spark/pull/39541#discussion_r1082698957
##
connector/connect/client/jvm/src/test/scala/org/apache/spark/sql/connect/client/SparkConnectClientSuite.scala:
##
@@ -78,7 +78,7 @@ class SparkConnectClientSuite
zhenlineo commented on code in PR #39541:
URL: https://github.com/apache/spark/pull/39541#discussion_r1082698009
##
connector/connect/client/jvm/src/main/scala/org/apache/spark/sql/connect/client/util/Cleaner.scala:
##
@@ -0,0 +1,113 @@
+/*
+ * Licensed to the Apache Software
srowen commented on code in PR #39660:
URL: https://github.com/apache/spark/pull/39660#discussion_r1082695284
##
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/JDBCRDD.scala:
##
@@ -307,11 +307,12 @@ private[jdbc] class JDBCRDD(
""
}
+
tgravescs commented on code in PR #39674:
URL: https://github.com/apache/spark/pull/39674#discussion_r1082615175
##
resource-managers/yarn/src/main/scala/org/apache/spark/deploy/yarn/Client.scala:
##
@@ -1005,26 +1005,6 @@ private[spark] class Client(
val tmpDir = new
grundprinzip commented on code in PR #39585:
URL: https://github.com/apache/spark/pull/39585#discussion_r1082600958
##
connector/connect/common/src/main/protobuf/spark/connect/expressions.proto:
##
@@ -217,6 +218,28 @@ message Expression {
bool is_user_defined_function =
ggershinsky commented on PR #39665:
URL: https://github.com/apache/spark/pull/39665#issuecomment-1398455770
Thanks Dongjoon.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
peter-toth commented on PR #39676:
URL: https://github.com/apache/spark/pull/39676#issuecomment-1398437534
cc @cloud-fan, @huaxingao
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific
peter-toth opened a new pull request, #39676:
URL: https://github.com/apache/spark/pull/39676
### What changes were proposed in this pull request?
This is a small correctness fix to
`DataSourceUtils.getPartitionFiltersAndDataFilters()` to handle filters without
any referenced attributes
srowen commented on PR #39190:
URL: https://github.com/apache/spark/pull/39190#issuecomment-1398393768
Yeah but do you know how it happens, or have a theory? Just want to see if
the change seems to match with some theory of how it arises. Or does this
change definitely change the output
LuciferYang commented on PR #39671:
URL: https://github.com/apache/spark/pull/39671#issuecomment-1398388671
Ok, plenty of time. I am fine to make this change
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
dongjoon-hyun commented on code in PR #39675:
URL: https://github.com/apache/spark/pull/39675#discussion_r1082534577
##
docs/running-on-kubernetes.md:
##
@@ -34,13 +34,13 @@ Please see [Spark Security](security.html) and the specific
security sections in
Images built from
LuciferYang commented on code in PR #39674:
URL: https://github.com/apache/spark/pull/39674#discussion_r1082533145
##
resource-managers/yarn/src/main/scala/org/apache/spark/deploy/yarn/Client.scala:
##
@@ -1005,26 +1005,6 @@ private[spark] class Client(
val tmpDir = new
dongjoon-hyun commented on code in PR #39675:
URL: https://github.com/apache/spark/pull/39675#discussion_r1082532817
##
docs/running-on-kubernetes.md:
##
@@ -34,13 +34,13 @@ Please see [Spark Security](security.html) and the specific
security sections in
Images built from
dongjoon-hyun commented on code in PR #39675:
URL: https://github.com/apache/spark/pull/39675#discussion_r1082529696
##
docs/index.md:
##
@@ -45,7 +45,6 @@ Java 8 prior to version 8u201 support is deprecated as of
Spark 3.2.0.
When using the Scala API, it is necessary for
dongjoon-hyun commented on code in PR #39674:
URL: https://github.com/apache/spark/pull/39674#discussion_r1082528460
##
resource-managers/yarn/src/main/scala/org/apache/spark/deploy/yarn/Client.scala:
##
@@ -1005,26 +1005,6 @@ private[spark] class Client(
val tmpDir = new
dongjoon-hyun commented on PR #39671:
URL: https://github.com/apache/spark/pull/39671#issuecomment-1398367056
BTW, we didn't cut the branch yet and we still have one month for Apache
Spark 3.4.0 release. I'm considering that time period for this decision,
@LuciferYang . You are also
dongjoon-hyun commented on PR #39671:
URL: https://github.com/apache/spark/pull/39671#issuecomment-1398362594
Timezone issues are inevitably which we need to adjust the code in a regular
basis, @LuciferYang .
--
This is an automated message from the Apache Git Service.
To respond to the
LuciferYang commented on PR #39671:
URL: https://github.com/apache/spark/pull/39671#issuecomment-1398356049
@dongjoon-hyun Hmm...do you remember SPARK-40846? When we upgrade from 8u345
to 8u352 for GA testing, there are some time zone issue that need to be solved
by changing the code, so I
LuciferYang commented on PR #39663:
URL: https://github.com/apache/spark/pull/39663#issuecomment-1398346083
Thanks @dongjoon-hyun
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific
LuciferYang commented on code in PR #39674:
URL: https://github.com/apache/spark/pull/39674#discussion_r1082496069
##
resource-managers/yarn/src/main/scala/org/apache/spark/deploy/yarn/Client.scala:
##
@@ -1005,26 +1005,6 @@ private[spark] class Client(
val tmpDir = new
LuciferYang commented on code in PR #39674:
URL: https://github.com/apache/spark/pull/39674#discussion_r1082496069
##
resource-managers/yarn/src/main/scala/org/apache/spark/deploy/yarn/Client.scala:
##
@@ -1005,26 +1005,6 @@ private[spark] class Client(
val tmpDir = new
panbingkun opened a new pull request, #39675:
URL: https://github.com/apache/spark/pull/39675
### What changes were proposed in this pull request?
The pr aims to update the doc of arrow & kubernetes.
### Why are the changes needed?
LuciferYang opened a new pull request, #39674:
URL: https://github.com/apache/spark/pull/39674
### What changes were proposed in this pull request?
### Why are the changes needed?
### Does this PR introduce _any_ user-facing change?
###
dongjoon-hyun closed pull request #39663: [SPARK-42129][BUILD] Upgrade
rocksdbjni to 7.9.2
URL: https://github.com/apache/spark/pull/39663
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the
dongjoon-hyun commented on PR #39671:
URL: https://github.com/apache/spark/pull/39671#issuecomment-1398319998
To @LuciferYang , I don't think this is a compatibility or any failure.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
dongjoon-hyun commented on PR #39541:
URL: https://github.com/apache/spark/pull/39541#issuecomment-1398317390
As @HyukjinKwon pointed out, this causes a failure for RC and official
release.
- https://github.com/apache/spark/pull/39668#issuecomment-1398314758
: KeyValueGroupedDataset[K, T] = {
val withGroupingKey
WeichenXu123 commented on code in PR #39299:
URL: https://github.com/apache/spark/pull/39299#discussion_r1082416985
##
python/pyspark/ml/torch/log_communication.py:
##
@@ -0,0 +1,201 @@
+#
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor
WeichenXu123 commented on code in PR #39299:
URL: https://github.com/apache/spark/pull/39299#discussion_r1082414835
##
python/pyspark/ml/torch/log_communication.py:
##
@@ -0,0 +1,201 @@
+#
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor
wangyum commented on PR #39671:
URL: https://github.com/apache/spark/pull/39671#issuecomment-1398267365
> Oh, does `Zulu` only have that released version, @wangyum ?
>
> * https://bugs.openjdk.org/browse/JDK-8296506
>
> I cannot find docker image and Adoptium (Temurin) Java
kuwii commented on PR #39190:
URL: https://github.com/apache/spark/pull/39190#issuecomment-1398263751
@srowen We found this issue in some of Spark applications. Here's the event
log of an example, which can be loaded through history server:
EnricoMi commented on PR #39673:
URL: https://github.com/apache/spark/pull/39673#issuecomment-1398246138
Ideally, `QueryPlan.rewriteAttrs` would not replace occurrences `id#0L#`
with `id#13L` in all fields of `CoGroup`, but only in `rightDeserializer`,
`rightGroup`, `rightAttr`,
EnricoMi opened a new pull request, #39673:
URL: https://github.com/apache/spark/pull/39673
### What changes were proposed in this pull request?
This deduplicate attributes that exist on both sides of a `CoGroup` by
aliasing the occurrence on the right side.
### Why are the
vicennial opened a new pull request, #39672:
URL: https://github.com/apache/spark/pull/39672
### What changes were proposed in this pull request?
Adds the following methods:
- Dataframe API methods
- project
- filter
- limit
- SparkSession
- range (and
dongjoon-hyun commented on PR #39671:
URL: https://github.com/apache/spark/pull/39671#issuecomment-1398234989
Oh, is `Zulu` only have that released version, @wangyum ?
- https://bugs.openjdk.org/browse/JDK-8296506
I cannot find docker image and Adoptium (Temurin) Java yet.
-
dongjoon-hyun commented on PR #38376:
URL: https://github.com/apache/spark/pull/38376#issuecomment-1398224853
Perfect, @antonipp !
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific
wangyum opened a new pull request, #39671:
URL: https://github.com/apache/spark/pull/39671
### What changes were proposed in this pull request?
This PR update document recommends users to use JDK 8u362 and later versions.
### Why are the changes needed?
8u362 fixed a
antonipp commented on PR #38376:
URL: https://github.com/apache/spark/pull/38376#issuecomment-1398209302
Thank you for the reviews and for the merge!
I am not 100% sure what is the backport process but I opened 2 PRs (for 3.3
and 3.2) since I believe both are still supported based on
antonipp opened a new pull request, #39669:
URL: https://github.com/apache/spark/pull/39669
### What changes were proposed in this pull request?
Backport https://github.com/apache/spark/pull/38376 to `branch-3.3`
You can find a detailed description of the issue and an example
antonipp opened a new pull request, #39670:
URL: https://github.com/apache/spark/pull/39670
### What changes were proposed in this pull request?
Backport https://github.com/apache/spark/pull/38376 to `branch-3.2`
You can find a detailed description of the issue and an example
HyukjinKwon commented on PR #39668:
URL: https://github.com/apache/spark/pull/39668#issuecomment-1398189235
cc @xinrong-meng FYI
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific
HyukjinKwon commented on code in PR #39541:
URL: https://github.com/apache/spark/pull/39541#discussion_r1082329957
##
connector/connect/client/jvm/src/test/scala/org/apache/spark/sql/ClientE2ETestSuite.scala:
##
@@ -0,0 +1,43 @@
+/*
+ * Licensed to the Apache Software
HyukjinKwon commented on code in PR #39541:
URL: https://github.com/apache/spark/pull/39541#discussion_r1082329724
##
connector/connect/client/jvm/src/test/scala/org/apache/spark/sql/connect/client/SparkConnectClientSuite.scala:
##
@@ -78,7 +78,7 @@ class
HyukjinKwon commented on code in PR #39541:
URL: https://github.com/apache/spark/pull/39541#discussion_r1082329225
##
connector/connect/client/jvm/src/test/scala/org/apache/spark/sql/connect/client/util/RemoteSparkSession.scala:
##
@@ -0,0 +1,198 @@
+/*
+ * Licensed to the
HyukjinKwon commented on code in PR #39541:
URL: https://github.com/apache/spark/pull/39541#discussion_r1082319733
##
connector/connect/client/jvm/src/test/scala/org/apache/spark/sql/connect/client/util/RemoteSparkSession.scala:
##
@@ -0,0 +1,198 @@
+/*
+ * Licensed to the
HyukjinKwon commented on code in PR #39541:
URL: https://github.com/apache/spark/pull/39541#discussion_r1082327967
##
connector/connect/client/jvm/src/test/scala/org/apache/spark/sql/connect/client/util/RemoteSparkSession.scala:
##
@@ -0,0 +1,198 @@
+/*
+ * Licensed to the
HyukjinKwon commented on code in PR #39541:
URL: https://github.com/apache/spark/pull/39541#discussion_r1082326873
##
connector/connect/client/jvm/src/test/scala/org/apache/spark/sql/connect/client/util/RemoteSparkSession.scala:
##
@@ -0,0 +1,198 @@
+/*
+ * Licensed to the
HyukjinKwon commented on code in PR #39541:
URL: https://github.com/apache/spark/pull/39541#discussion_r1082326160
##
connector/connect/client/jvm/src/test/scala/org/apache/spark/sql/connect/client/util/RemoteSparkSession.scala:
##
@@ -0,0 +1,198 @@
+/*
+ * Licensed to the
EnricoMi commented on PR #39640:
URL: https://github.com/apache/spark/pull/39640#issuecomment-1398179550
Thanks for your time!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific
dongjoon-hyun commented on PR #39541:
URL: https://github.com/apache/spark/pull/39541#issuecomment-1398177490
BTW, while I was reviewing this PR, I felt the necessity to open an official
PR to test any potential test cases on tagging.
Here is the general PR to detect any `SNAPSHOT`
HyukjinKwon commented on code in PR #39541:
URL: https://github.com/apache/spark/pull/39541#discussion_r1082323765
##
connector/connect/client/jvm/src/test/scala/org/apache/spark/sql/connect/client/util/RemoteSparkSession.scala:
##
@@ -0,0 +1,198 @@
+/*
+ * Licensed to the
HyukjinKwon commented on code in PR #39541:
URL: https://github.com/apache/spark/pull/39541#discussion_r1082319733
##
connector/connect/client/jvm/src/test/scala/org/apache/spark/sql/connect/client/util/RemoteSparkSession.scala:
##
@@ -0,0 +1,198 @@
+/*
+ * Licensed to the
HyukjinKwon commented on code in PR #39541:
URL: https://github.com/apache/spark/pull/39541#discussion_r1082320316
##
connector/connect/client/jvm/src/test/scala/org/apache/spark/sql/connect/client/util/RemoteSparkSession.scala:
##
@@ -0,0 +1,198 @@
+/*
+ * Licensed to the
dongjoon-hyun opened a new pull request, #39668:
URL: https://github.com/apache/spark/pull/39668
This aims to test the possible test failures on Spark 3.4.0 RC tag.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
HyukjinKwon commented on code in PR #39541:
URL: https://github.com/apache/spark/pull/39541#discussion_r1082316930
##
connector/connect/client/jvm/src/main/scala/org/apache/spark/sql/SparkSession.scala:
##
@@ -0,0 +1,103 @@
+/*
+ * Licensed to the Apache Software Foundation
dongjoon-hyun commented on PR #39665:
URL: https://github.com/apache/spark/pull/39665#issuecomment-1398167017
I fixed the `Affected Version` from 3.3.1 to 3.4.0 because this fails in
`branch-3.3`.
```
[info] ParquetEncryptionSuite:
[info] - SPARK-34990: Write and read an encrypted
dongjoon-hyun commented on PR #39664:
URL: https://github.com/apache/spark/pull/39664#issuecomment-1398159305
I merged the newer PR, @ggershinsky . :)
-
https://github.com/apache/spark/commit/e1c630a98c45ae07c43c8cf95979532b51bf59ec
--
This is an automated message from the Apache Git
dongjoon-hyun commented on code in PR #39666:
URL: https://github.com/apache/spark/pull/39666#discussion_r1082308565
##
core/src/main/protobuf/org/apache/spark/status/protobuf/store_types.proto:
##
@@ -22,7 +22,12 @@ package org.apache.spark.status.protobuf;
* Developer
dongjoon-hyun commented on code in PR #39666:
URL: https://github.com/apache/spark/pull/39666#discussion_r1082308565
##
core/src/main/protobuf/org/apache/spark/status/protobuf/store_types.proto:
##
@@ -22,7 +22,12 @@ package org.apache.spark.status.protobuf;
* Developer
dongjoon-hyun commented on code in PR #39666:
URL: https://github.com/apache/spark/pull/39666#discussion_r1082307793
##
core/src/main/protobuf/org/apache/spark/status/protobuf/store_types.proto:
##
@@ -22,7 +22,12 @@ package org.apache.spark.status.protobuf;
* Developer
dongjoon-hyun commented on PR #39665:
URL: https://github.com/apache/spark/pull/39665#issuecomment-1398155059
BTW, please add `ggershin...@apple.com` to your GitHub profile as the
secondary email.
```
$ git log -n1
commit e1c630a98c45ae07c43c8cf95979532b51bf59ec (HEAD -> master,
dongjoon-hyun closed pull request #39665: [SPARK-42114][SQL][TESTS] Add uniform
parquet encryption test case
URL: https://github.com/apache/spark/pull/39665
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above
gengliangwang commented on code in PR #39666:
URL: https://github.com/apache/spark/pull/39666#discussion_r1082286371
##
core/src/main/scala/org/apache/spark/status/protobuf/Utils.scala:
##
@@ -17,10 +17,24 @@
package org.apache.spark.status.protobuf
+import
gengliangwang commented on code in PR #39666:
URL: https://github.com/apache/spark/pull/39666#discussion_r1082251439
##
core/src/main/scala/org/apache/spark/status/protobuf/Utils.scala:
##
@@ -17,10 +17,24 @@
package org.apache.spark.status.protobuf
+import
zhengruifeng commented on PR #39661:
URL: https://github.com/apache/spark/pull/39661#issuecomment-1398122520
LGTM, thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
beliefer commented on code in PR #39660:
URL: https://github.com/apache/spark/pull/39660#discussion_r1082270560
##
sql/core/src/main/scala/org/apache/spark/sql/jdbc/JdbcDialects.scala:
##
@@ -544,6 +544,14 @@ abstract class JdbcDialect extends Serializable with
Logging {
beliefer opened a new pull request, #39667:
URL: https://github.com/apache/spark/pull/39667
### What changes were proposed in this pull request?
Currently, JDBCRDD uses fixed format for SELECT statement.
```
val sqlText = options.prepareQuery +
s"SELECT $columnList FROM
sadikovi commented on PR #39660:
URL: https://github.com/apache/spark/pull/39660#issuecomment-1398098578
Thanks @dongjoon-hyun. I will address your comments soon-ish .
@beliefer, Yes, you are right. The documentation describes TOP (N) returning
the N top rows when used together with
gengliangwang commented on code in PR #39666:
URL: https://github.com/apache/spark/pull/39666#discussion_r1082251439
##
core/src/main/scala/org/apache/spark/status/protobuf/Utils.scala:
##
@@ -17,10 +17,24 @@
package org.apache.spark.status.protobuf
+import
LuciferYang commented on code in PR #39666:
URL: https://github.com/apache/spark/pull/39666#discussion_r1082248889
##
core/src/main/scala/org/apache/spark/status/protobuf/Utils.scala:
##
@@ -17,10 +17,24 @@
package org.apache.spark.status.protobuf
+import
EnricoMi closed pull request #37551: [SPARK-38591][SQL] Add sortWithinGroups to
KeyValueGroupedDataset
URL: https://github.com/apache/spark/pull/37551
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go
EnricoMi commented on PR #37551:
URL: https://github.com/apache/spark/pull/37551#issuecomment-1398081395
Closing as #39640 has been merged.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the
LuciferYang commented on PR #39642:
URL: https://github.com/apache/spark/pull/39642#issuecomment-1398075391
Will refactor after https://github.com/apache/spark/pull/39666 merged
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
1 - 100 of 714839 matches
Mail list logo
