Я установил воздушный поток, следуя официальной документации. Я проверял это. Теперь я хочу выполнить несколько запросов к улью. У меня установлен куст, который успешно работает. Я изменил конфигурацию hiveserver2_default так:
Conn Type : Hive Server 2 Thrift
Host : localhost
schema : default
login : hive
password : ****
port : 10000
Поэтому, когда я запускаю любой запрос в профилировании данных -> запрос ad hoc, я получаю следующее:
TExecuteStatementResp(status=TStatus(errorCode=1, errorMessage=u'Error while processing statement: Cannot modify airflow.ctx.task_id at runtime. It is not in list of params that are allowed to be modified at runtime', sqlState=u'42000', infoMessages=[u'*org.apache.hive.service.cli.HiveSQLException:Error while processing statement: Cannot modify airflow.ctx.task_id at runtime. It is not in list of params that are allowed to be modified at runtime:27:26',
u'org.apache.hive.service.cli.operation.Operation:toSQLException:Operation.java:335',
u'org.apache.hive.service.cli.operation.HiveCommandOperation:runInternal:HiveCommandOperation.java:116',
u'org.apache.hive.service.cli.operation.Operation:run:Operation.java:247',
u'org.apache.hive.service.cli.session.HiveSessionImpl:executeStatementInternal:HiveSessionImpl.java:575',
u'org.apache.hive.service.cli.session.HiveSessionImpl:executeStatement:HiveSessionImpl.java:550',
u'sun.reflect.GeneratedMethodAccessor95:invoke::-1',
u'sun.reflect.DelegatingMethodAccessorImpl:invoke:DelegatingMethodAccessorImpl.java:43',
u'java.lang.reflect.Method:invoke:Method.java:498',
u'org.apache.hive.service.cli.session.HiveSessionProxy:invoke:HiveSessionProxy.java:78',
u'org.apache.hive.service.cli.session.HiveSessionProxy:access$000:HiveSessionProxy.java:36',
u'org.apache.hive.service.cli.session.HiveSessionProxy$1:run:HiveSessionProxy.java:63',
u'java.security.AccessController:doPrivileged:AccessController.java:-2',
u'javax.security.auth.Subject:doAs:Subject.java:422',
u'org.apache.hadoop.security.UserGroupInformation:doAs:UserGroupInformation.java:1730',
u'org.apache.hive.service.cli.session.HiveSessionProxy:invoke:HiveSessionProxy.java:59',
u'com.sun.proxy.$Proxy46:executeStatement::-1',
u'org.apache.hive.service.cli.CLIService:executeStatement:CLIService.java:285',
u'org.apache.hive.service.cli.thrift.ThriftCLIService:ExecuteStatement:ThriftCLIService.java:567',
u'org.apache.hive.service.rpc.thrift.TCLIService$Processor$ExecuteStatement:getResult:TCLIService.java:1557',
u'org.apache.hive.service.rpc.thrift.TCLIService$Processor$ExecuteStatement:getResult:TCLIService.java:1542',
u'org.apache.thrift.ProcessFunction:process:ProcessFunction.java:39',
u'org.apache.thrift.TBaseProcessor:process:TBaseProcessor.java:39',
u'org.apache.hive.service.auth.TSetIpAddressProcessor:process:TSetIpAddressProcessor.java:56',
u'org.apache.thrift.server.TThreadPoolServer$WorkerProcess:run:TThreadPoolServer.java:286',
u'java.util.concurrent.ThreadPoolExecutor:runWorker:ThreadPoolExecutor.java:1142',
u'java.util.concurrent.ThreadPoolExecutor$Worker:run:ThreadPoolExecutor.java:617',
u'java.lang.Thread:run:Thread.java:745'], statusCode=3), operationHandle=None)
Я застрял здесь. Какие шаги мне нужно предпринять, чтобы решить эту проблему.
P.S. Я мог бы успешно выполнить запрос и получить результат из базы данных mysql.
