Merge pull request apache#3 from sadhen/da/pylint

pylint
da-liii · Mar 23, 2021 · ddda826 · ddda826
2 parents 2e52297 + 0546f3c
commit ddda826
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/python/pyspark/sql/pandas/serializers.py b/python/pyspark/sql/pandas/serializers.py
@@ -208,7 +208,7 @@ def create_arrs_names(s, t: pa.DataType, dt: Optional[DataType] = None):
             if dt is None:
                 if by_field_name:
                     return [(create_array(s[field.name], field.type), field.name) for field in t]
-                else: 
+                else:
                     return [
                         (create_array(s[s.columns[i]], field.type), field.name)
                         for i, field in enumerate(t)
@@ -221,7 +221,8 @@ def create_arrs_names(s, t: pa.DataType, dt: Optional[DataType] = None):
                     ]
                 else:
                     return [
-                        (create_array(s[s.columns[i]], field.type, struct_field.dataType), field.name)
+                        (create_array(s[s.columns[i]], field.type, struct_field.dataType),
+                         field.name)
                         for i, (field, struct_field) in enumerate(zip(t, dt.fields))
                     ]
 

diff --git a/python/pyspark/testing/sqlutils.py b/python/pyspark/testing/sqlutils.py
@@ -22,7 +22,7 @@
 from contextlib import contextmanager
 
 from pyspark.sql import SparkSession
-from pyspark.sql.types import ArrayType, DoubleType, TimestampType, StructField, StructType, \
+from pyspark.sql.types import ArrayType, DoubleType, StructField, StructType, \
     UserDefinedType, Row
 from pyspark.testing.utils import ReusedPySparkTestCase