HyukjinKwon commented on code in PR #39344:
URL: https://github.com/apache/spark/pull/39344#discussion_r1059901791
##########
python/pyspark/sql/tests/connect/test_connect_basic.py:
##########
@@ -389,28 +389,30 @@ def test_with_local_list(self):
self.connect.createDataFrame(data, "col1 int, col2 int, col3
int").show()
def test_with_local_rows(self):
- # SPARK-41789: Test creating a dataframe with list of Rows
- data = [
- Row(course="dotNET", year=2012, earnings=10000),
- Row(course="Java", year=2012, earnings=20000),
- Row(course="dotNET", year=2012, earnings=5000),
- Row(course="dotNET", year=2013, earnings=48000),
- Row(course="Java", year=2013, earnings=30000),
- Row(course="Scala", year=2022, earnings=None),
+ # SPARK-41789, SPARK-41810: Test creating a dataframe with list of
rows and dictionaries
+ rows = [
+ Row(course="dotNET", earnings=10000, year=2012),
+ Row(course="Java", earnings=20000, year=2012),
Review Comment:
The test data had to be fixed because PySpark sorts the names from
dictionaries when inferring the schema.
--
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 unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
