Хотя запрос содержит данные, но при использовании клиента pyodbc
для подключения к Drill и выполнения запроса SQL я получаю ноль записей, в чем причина? Пожалуйста, найдите фрагмент кода здесь
conn = pyodbc.connect("DSN=drill64prd", autocommit=True)
cursor = conn.cursor()
pdf = pandas.read_sql(statement,conn)
df0 = sparkSession.createDataFrame(pdf, jaschema.finalSchema)
sparkSession.saveToMapRDB(df0, config['paths']['job_aggregate_interim_table'],create_table=False)
В окончательном типе схемы всех столбцов есть строка.