Github user BryanCutler commented on a diff in the pull request:
https://github.com/apache/spark/pull/19738#discussion_r150641930
--- Diff: python/pyspark/sql/session.py ---
@@ -593,6 +593,10 @@ def createDataFrame(self, data, schema=None,
samplingRatio=None, verifySchema=Tr
if isinstance(schema, basestring):
schema = _parse_datatype_string(schema)
+ # If schema is a list of unicode strings, must change encoding
+ if isinstance(schema, (list, tuple)):
--- End diff --
This should be an `elif`
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
