Github user gberger commented on a diff in the pull request:
https://github.com/apache/spark/pull/19792#discussion_r155238727
--- Diff: python/pyspark/sql/session.py ---
@@ -405,7 +401,7 @@ def _createFromLocal(self, data, schema):
data = list(data)
if schema is None or isinstance(schema, (list, tuple)):
- struct = self._inferSchemaFromList(data)
+ struct = self._inferSchemaFromList(data, names=schema)
converter = _create_converter(struct)
data = map(converter, data)
if isinstance(schema, (list, tuple)):
--- End diff --
removed with commit 5131db2
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
