@@ -1684,8 +1684,8 @@ def test_list_tables(self):
16841684 self .assertEquals (spark .catalog .listTables (), [])
16851685 self .assertEquals (spark .catalog .listTables ("some_db" ), [])
16861686 spark .createDataFrame ([(1 , 1 )]).createOrReplaceTempView ("temp_tab" )
1687- spark .sql ("CREATE TABLE tab1 (name STRING, age INT)" )
1688- spark .sql ("CREATE TABLE some_db.tab2 (name STRING, age INT)" )
1687+ spark .sql ("CREATE TABLE tab1 (name STRING, age INT) USING parquet " )
1688+ spark .sql ("CREATE TABLE some_db.tab2 (name STRING, age INT) USING parquet " )
16891689 tables = sorted (spark .catalog .listTables (), key = lambda t : t .name )
16901690 tablesDefault = sorted (spark .catalog .listTables ("default" ), key = lambda t : t .name )
16911691 tablesSomeDb = sorted (spark .catalog .listTables ("some_db" ), key = lambda t : t .name )
@@ -1763,8 +1763,8 @@ def test_list_columns(self):
17631763 spark = self .spark
17641764 spark .catalog ._reset ()
17651765 spark .sql ("CREATE DATABASE some_db" )
1766- spark .sql ("CREATE TABLE tab1 (name STRING, age INT)" )
1767- spark .sql ("CREATE TABLE some_db.tab2 (nickname STRING, tolerance FLOAT)" )
1766+ spark .sql ("CREATE TABLE tab1 (name STRING, age INT) USING parquet " )
1767+ spark .sql ("CREATE TABLE some_db.tab2 (nickname STRING, tolerance FLOAT) USING parquet " )
17681768 columns = sorted (spark .catalog .listColumns ("tab1" ), key = lambda c : c .name )
17691769 columnsDefault = sorted (spark .catalog .listColumns ("tab1" , "default" ), key = lambda c : c .name )
17701770 self .assertEquals (columns , columnsDefault )
0 commit comments