beliefer commented on PR #41436:
URL: https://github.com/apache/spark/pull/41436#issuecomment-1574693752
@wangyum Do we need merge this to 3.3 and 3.4?
--
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
venkateshbalaji99 commented on PR #41199:
URL: https://github.com/apache/spark/pull/41199#issuecomment-1574926819
> Hi, @venkateshbalaji99 and @abmodi . This is a very old behavior since
Apache Spark 2.3.0 (6 years). Could you elaborate which `count` metric did you
have an issue
wangyum commented on PR #41436:
URL: https://github.com/apache/spark/pull/41436#issuecomment-1574698893
I'm +1 for backporting this to 3.4 and 3.3 if you want.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
beliefer commented on PR #41421:
URL: https://github.com/apache/spark/pull/41421#issuecomment-1574767408
ping @cloud-fan @MaxGekk @HyukjinKwon @zhengruifeng cc @amaliujia
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
itholic commented on PR #41437:
URL: https://github.com/apache/spark/pull/41437#issuecomment-1574785801
It looks pretty making sense to me since it's not introduce any extra test
skipping or behavior changes.
--
This is an automated message from the Apache Git Service.
To
beliefer opened a new pull request, #41444:
URL: https://github.com/apache/spark/pull/41444
### What changes were proposed in this pull request?
Based @HyukjinKwon 's suggestion, this PR want add percentile like functions
to Scala and Python API.
These functions show below.
beliefer opened a new pull request, #41446:
URL: https://github.com/apache/spark/pull/41446
### What changes were proposed in this pull request?
This PR used to backport https://github.com/apache/spark/pull/41436 to 3.3
### Why are the changes needed?
Fix the bug doesn't
panbingkun opened a new pull request, #41447:
URL: https://github.com/apache/spark/pull/41447
### What changes were proposed in this pull request?
The pr aims to use `checkError()` to check `Exception` in `*Insert*Suite`,
include:
-
panbingkun commented on PR #41447:
URL: https://github.com/apache/spark/pull/41447#issuecomment-1574908226
cc @MaxGekk
--
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.
To
itholic commented on PR #41437:
URL: https://github.com/apache/spark/pull/41437#issuecomment-1574781900
It's pretty makes sense to me although we still need to discuss the
potential behavior changes for future updates.
--
This is an automated message from the Apache Git Service.
To
beliefer opened a new pull request, #41445:
URL: https://github.com/apache/spark/pull/41445
### What changes were proposed in this pull request?
This PR used to backport https://github.com/apache/spark/pull/41436 to 3.4
### Why are the changes needed?
Fix the bug doesn't
szehon-ho commented on PR #41398:
URL: https://github.com/apache/spark/pull/41398#issuecomment-1574901969
Thanks everyone for the warm welcome to Spark, and really fast reviews!
As I'm out of town, I will look at any follow up improvements when I'm back.
--
This is an automated
dtenedor commented on PR #41191:
URL: https://github.com/apache/spark/pull/41191#issuecomment-1575087553
Note: the CI is actually passing, the pyspark failure is spurious/unrelated.
https://github.com/apache/spark/assets/99207096/02176772-3e7c-4cbd-8308-297c6fd85066;>
--
This
beliefer commented on PR #41445:
URL: https://github.com/apache/spark/pull/41445#issuecomment-1574967814
cc @wangyum @MaxGekk
--
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
vinodkc commented on code in PR #41144:
URL: https://github.com/apache/spark/pull/41144#discussion_r1215599942
##
core/src/main/scala/org/apache/spark/api/python/PythonRunner.scala:
##
@@ -106,7 +106,7 @@ private[spark] abstract class BasePythonRunner[IN, OUT](
protected val
aokolnychyi opened a new pull request, #41448:
URL: https://github.com/apache/spark/pull/41448
### What changes were proposed in this pull request?
This PR adds `RewriteMergeIntoTable`, similar to `RewriteUpdateTable` and
`RewriteDeleteFromTable`, to handle MERGE commands
aokolnychyi commented on code in PR #41448:
URL: https://github.com/apache/spark/pull/41448#discussion_r1216251079
##
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/RewriteMergeIntoTable.scala:
##
@@ -0,0 +1,347 @@
+/*
+ * Licensed to the Apache Software
aokolnychyi commented on code in PR #41448:
URL: https://github.com/apache/spark/pull/41448#discussion_r1216250498
##
core/src/main/resources/error/error-classes.json:
##
@@ -1513,6 +1513,13 @@
"Parse Mode: . To process malformed records as null
result, try setting the
aokolnychyi opened a new pull request, #41449:
URL: https://github.com/apache/spark/pull/41449
### What changes were proposed in this pull request?
This PR makes `RowLevelOperationSuiteBase` and `AlignAssignmentsSuite`
abstract.
### Why are the changes needed?
aokolnychyi commented on PR #41449:
URL: https://github.com/apache/spark/pull/41449#issuecomment-1575408872
cc @cloud-fan @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
aokolnychyi commented on code in PR #41448:
URL: https://github.com/apache/spark/pull/41448#discussion_r1216251279
##
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/RewriteMergeIntoTable.scala:
##
@@ -0,0 +1,347 @@
+/*
+ * Licensed to the Apache Software
aokolnychyi commented on code in PR #41448:
URL: https://github.com/apache/spark/pull/41448#discussion_r1216252175
##
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/RewriteMergeIntoTable.scala:
##
@@ -0,0 +1,347 @@
+/*
+ * Licensed to the Apache Software
aokolnychyi commented on code in PR #41448:
URL: https://github.com/apache/spark/pull/41448#discussion_r1216251890
##
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/RewriteMergeIntoTable.scala:
##
@@ -0,0 +1,347 @@
+/*
+ * Licensed to the Apache Software
aokolnychyi commented on code in PR #41448:
URL: https://github.com/apache/spark/pull/41448#discussion_r1216251279
##
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/RewriteMergeIntoTable.scala:
##
@@ -0,0 +1,347 @@
+/*
+ * Licensed to the Apache Software
aokolnychyi commented on code in PR #41448:
URL: https://github.com/apache/spark/pull/41448#discussion_r1216252708
##
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/RewriteRowLevelCommand.scala:
##
@@ -167,4 +183,36 @@ trait RewriteRowLevelCommand extends
dongjoon-hyun commented on code in PR #41144:
URL: https://github.com/apache/spark/pull/41144#discussion_r1216028837
##
core/src/main/scala/org/apache/spark/api/python/PythonRunner.scala:
##
@@ -106,6 +106,7 @@ private[spark] abstract class BasePythonRunner[IN, OUT](
mcdull-zhang commented on code in PR #41419:
URL: https://github.com/apache/spark/pull/41419#discussion_r1216118752
##
sql/core/src/main/scala/org/apache/spark/sql/execution/SubqueryBroadcastExec.scala:
##
@@ -93,7 +94,9 @@ case class SubqueryBroadcastExec(
val rows =
aokolnychyi commented on code in PR #41028:
URL: https://github.com/apache/spark/pull/41028#discussion_r1216227877
##
sql/core/src/test/scala/org/apache/spark/sql/connector/RowLevelOperationSuiteBase.scala:
##
@@ -0,0 +1,95 @@
+/*
+ * Licensed to the Apache Software Foundation
MaxGekk commented on PR #41445:
URL: https://github.com/apache/spark/pull/41445#issuecomment-1575139174
+1, LGTM. Merging to 3.4.
Thank you, @beliefer.
--
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
MaxGekk closed pull request #41445: [SPARK-43956][SQL][3.4] Fix the bug doesn't
display column's sql for Percentile[Cont|Disc]
URL: https://github.com/apache/spark/pull/41445
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
MaxGekk commented on PR #41447:
URL: https://github.com/apache/spark/pull/41447#issuecomment-1575142470
+1, LGTM. Merging to master.
Thank you, @panbingkun.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
MaxGekk closed pull request #41447: [SPARK-43957][SQL][TESTS] Use
`checkError()` to check `Exception` in `*Insert*Suite`
URL: https://github.com/apache/spark/pull/41447
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
MaxGekk commented on code in PR #41424:
URL: https://github.com/apache/spark/pull/41424#discussion_r1215752166
##
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/CheckAnalysis.scala:
##
@@ -624,8 +626,8 @@ trait CheckAnalysis extends PredicateHelper with
dongjoon-hyun closed pull request #41441: [SPARK-43954][BUILD] Upgrade sbt from
1.8.3 to 1.9.0
URL: https://github.com/apache/spark/pull/41441
--
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
github-actions[bot] closed pull request #40098: [SPARK-42504][SQL]
NestedColumnAliasing support pruning adjacent projects
URL: https://github.com/apache/spark/pull/40098
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
github-actions[bot] closed pull request #39796: [SPARK-39800][SQL][WIP]
DataSourceV2: View Support
URL: https://github.com/apache/spark/pull/39796
--
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
dongjoon-hyun commented on PR #41446:
URL: https://github.com/apache/spark/pull/41446#issuecomment-1575287357
All tests passed. Merged to branch-3.3.
--
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
dongjoon-hyun commented on PR #41446:
URL: https://github.com/apache/spark/pull/41446#issuecomment-1575287810
Thank you, @beliefer and @MaxGekk .
--
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
dongjoon-hyun closed pull request #41446: [SPARK-43956][SQL][3.3] Fix the bug
doesn't display column's sql for Percentile[Cont|Disc]
URL: https://github.com/apache/spark/pull/41446
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
MaxGekk commented on PR #41445:
URL: https://github.com/apache/spark/pull/41445#issuecomment-1575140577
I have already found this https://github.com/apache/spark/pull/41446
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
MaxGekk commented on PR #41445:
URL: https://github.com/apache/spark/pull/41445#issuecomment-1575140042
@beliefer Could you backport this to branch-3.3 since it is affected
according to your ticket SPARK-43956, and Spark 3.3 is still supported
officially.
--
This is an automated message
grundprinzip opened a new pull request, #8:
URL: https://github.com/apache/spark-connect-go/pull/8
### What changes were proposed in this pull request?
Add support for parsing the connection string of Spark Connect in the same
way was it's done for the other Spark Connect clients.
sarutak commented on PR #41423:
URL: https://github.com/apache/spark/pull/41423#issuecomment-1575207847
@aminebag
This change seems ad-hocery and doesn't really address the issue.
We need some more considerations to address this issue.
Instead, how about setting a larger value to
43 matches
Mail list logo