HyukjinKwon commented on code in PR #39947:
URL: https://github.com/apache/spark/pull/39947#discussion_r1146129611
##
connector/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SparkConnectService.scala:
##
@@ -53,19 +59,37 @@ class SparkConnectService(debug: B
HyukjinKwon commented on code in PR #39947:
URL: https://github.com/apache/spark/pull/39947#discussion_r1145632881
##
connector/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SparkConnectService.scala:
##
@@ -53,19 +59,37 @@ class SparkConnectService(debug: B
HyukjinKwon commented on code in PR #39947:
URL: https://github.com/apache/spark/pull/39947#discussion_r1102174832
##
python/pyspark/errors/exceptions/connect.py:
##
@@ -61,41 +97,34 @@ class AnalysisException(SparkConnectGrpcException,
BaseAnalysisException):
Failed to an
HyukjinKwon commented on code in PR #39947:
URL: https://github.com/apache/spark/pull/39947#discussion_r1102138582
##
python/pyspark/errors/exceptions/connect.py:
##
@@ -61,41 +97,34 @@ class AnalysisException(SparkConnectGrpcException,
BaseAnalysisException):
Failed to an
HyukjinKwon commented on code in PR #39947:
URL: https://github.com/apache/spark/pull/39947#discussion_r1102138305
##
connector/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SparkConnectService.scala:
##
@@ -83,27 +107,19 @@ class SparkConnectService(debug:
HyukjinKwon commented on code in PR #39947:
URL: https://github.com/apache/spark/pull/39947#discussion_r1101440253
##
python/pyspark/sql/tests/pandas/test_pandas_udf.py:
##
@@ -171,7 +171,7 @@ def test_stopiteration_in_udf(self):
def foo(x):
raise StopItera
HyukjinKwon commented on code in PR #39947:
URL: https://github.com/apache/spark/pull/39947#discussion_r1101386854
##
connector/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SparkConnectService.scala:
##
@@ -53,19 +59,36 @@ class SparkConnectService(debug: B
HyukjinKwon commented on code in PR #39947:
URL: https://github.com/apache/spark/pull/39947#discussion_r1101374445
##
connector/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SparkConnectService.scala:
##
@@ -53,19 +59,36 @@ class SparkConnectService(debug: B
HyukjinKwon commented on code in PR #39947:
URL: https://github.com/apache/spark/pull/39947#discussion_r1101076905
##
python/pyspark/errors/exceptions/connect.py:
##
@@ -61,41 +97,34 @@ class AnalysisException(SparkConnectGrpcException,
BaseAnalysisException):
Failed to an
HyukjinKwon commented on code in PR #39947:
URL: https://github.com/apache/spark/pull/39947#discussion_r1101075312
##
connector/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SparkConnectService.scala:
##
@@ -83,27 +107,19 @@ class SparkConnectService(debug:
HyukjinKwon commented on code in PR #39947:
URL: https://github.com/apache/spark/pull/39947#discussion_r1101075312
##
connector/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SparkConnectService.scala:
##
@@ -83,27 +107,19 @@ class SparkConnectService(debug:
HyukjinKwon commented on code in PR #39947:
URL: https://github.com/apache/spark/pull/39947#discussion_r1100994819
##
python/pyspark/errors/exceptions/connect.py:
##
@@ -61,41 +97,34 @@ class AnalysisException(SparkConnectGrpcException,
BaseAnalysisException):
Failed to an
HyukjinKwon commented on code in PR #39947:
URL: https://github.com/apache/spark/pull/39947#discussion_r1100994134
##
connector/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SparkConnectService.scala:
##
@@ -53,19 +59,37 @@ class SparkConnectService(debug: B
13 matches
Mail list logo