python - Airflow HiveOperator not working -

-

i trying use hive operator in airflow. have dependencies installed (pyhs2, pyhive, , ran pip install airflow[hive]).

however when use code below 

t1 = hiveoperator(     task_id='simple_query',     hql='select * cities',     dag=dag)

i error. not sure means

[2016-01-06 03:26:39,500] {models.py:1017} error - [errno 2] no such file or directory traceback (most recent call last):   file "/usr/local/lib/python2.7/dist-packages/airflow/models.py", line 977, in run     result = task_copy.execute(context=context)   file "/usr/local/lib/python2.7/dist-packages/airflow/operators/hive_operator.py", line 65, in execute     self.hook.run_cli(hql=self.hql, schema=self.schema)   file "/usr/local/lib/python2.7/dist-packages/airflow/hooks/hive_hooks.py", line 110, in run_cli     cwd=tmp_dir)   file "/usr/lib/python2.7/subprocess.py", line 710, in __init__     errread, errwrite)   file "/usr/lib/python2.7/subprocess.py", line 1327, in _execute_child     raise child_exception oserror: [errno 2] no such file or directory [2016-01-06 03:26:39,512] {models.py:1053} error - [errno 2] no such file or directory

this error occurs when hive command line interface (cli) isn't available in system path.


Comments

Post a Comment

Popular posts from this blog

multithreading - Exception in Application constructor -

-
i wanna write snake game javafx , there exception don't know , want know how fix it. ( know it's not complete yet ) and want know , class extends application ( start override ) main in other programs? see , here not static void main bc didn't need, if want add main shoud do? it's exeption... exception in application constructor exception in thread "main" java.lang.nosuchmethodexception: main_snake.main([ljava.lang.string;) @ java.lang.class.getmethod(class.java:1819) @ com.intellij.rt.execution.application.appmain.main(appmain.java:125) and code : import javafx.animation.animationtimer; import javafx.application.application; import javafx.event.eventhandler; import javafx.scene.scene; import javafx.scene.canvas.canvas; import javafx.scene.canvas.graphicscontext; import javafx.scene.input.keyevent; import javafx.scene.layout.borderpane; import javafx.scene.paint.color; import javafx.stage.stage; import java.util.arraylist; /** * creat...
Read more

React Native allow user to reorder elements in a scrollview list -

-
i'm trying let user reorder elements in scrollview list long-pressing on 1 of elements. we're trying let user use long press pick element of scrollview list, , put element somewhere else in list. have working using animated view, issue it's difficult integrate scrolling , swipe-to-delete animated view. we're hoping add "pick , reorder" scrollview. is there preferred method accomplishing this? touchablewithoutfeedback has onlongpress method, can implement this: _onlongpress() { // perform sort }, <touchablewithoutfeedback onlongpress={ () => this._onlongpress() }> <text>click , hold call onlongpress</text> </touchablewithoutfeedback> as far sorting, can use type of library such lodash or underscore, plus there ways sort using vanilla javascript. check out this thread. i've set basic project using sort function on listview here . https://rnplay.org/apps/mpbktg 'use strict'; var react = requ...
Read more

windows - CertCreateCertificateContext returns CRYPT_E_ASN1_BADTAG / 8009310b -

-
i realize similar post others (e.g. this one ), there details missing posts might significant case. to start with, here's simplified program: #include "stdafx.h" #include <windows.h> #include <wincrypt.h> int _tmain(int argc, _tchar* argv[]) { // usage: certextract certpath char keyfile[] = "c:\\certificates\\public.crt"; byte lp[65536]; security_attributes sa; handle hkeyfile; dword bytes; pccert_context certcontext; sa.nlength = sizeof(sa); sa.lpsecuritydescriptor = null; sa.binherithandle = false; hkeyfile = createfile(keyfile, generic_read, file_share_read, &sa, open_existing, file_attribute_normal, null); if (hkeyfile) { if (readfile(hkeyfile, lp, getfilesize(hkeyfile, null), &bytes, null) && bytes > 0) { certcontext = certcreatecertificatecontext(x509_asn_encoding, lp, bytes); if (certcontext) { printf("yay...
Read more