Skip to content Skip to sidebar Skip to footer
Showing posts with the label Hadoop

Unpickle File From Hdfs

I'm currently using Python 3 and would like to load a pickle file out of HDFS. from pywebhdfs.… Read more Unpickle File From Hdfs

Hive Client For Python 3.x

is it possible to connect to hadoop and run hive queries using Python 3.x? I am using Python 3.4.1.… Read more Hive Client For Python 3.x

Hadoop Streaming With Python: Keeping Track Of Line Numbers

I am trying to do what should be a simple task: I need to convert a text file to upper case using H… Read more Hadoop Streaming With Python: Keeping Track Of Line Numbers

Running A Job Using Hadoop Streaming And Mrjob: Pipemapred.waitoutputthreads(): Subprocess Failed With Code 1

Hey I'm fairly new to the world of Big Data. I came across this tutorial on http://musicmachin… Read more Running A Job Using Hadoop Streaming And Mrjob: Pipemapred.waitoutputthreads(): Subprocess Failed With Code 1

Aws Elastic Mapreduce Doesn't Seem To Be Correctly Converting The Streaming To Jar

I have a mapper and reducer that work fine when I run them in the piped version: cat data.csv | ./m… Read more Aws Elastic Mapreduce Doesn't Seem To Be Correctly Converting The Streaming To Jar

Remove Empty Line Printed From Hive Query Output Using Python

i am performing a hive query and storing the output in a tsv file in the local FS. I am running a f… Read more Remove Empty Line Printed From Hive Query Output Using Python

Hadoop: Output File Has Double Output

I am running a Hadoop program and have the following as my input file, input.txt: 1 2 mapper.py: i… Read more Hadoop: Output File Has Double Output

Hadoop-streaming : Reduce Task In Pending State Says "no Room For Reduce Task."

My map task completes successfully and I can see the application logs, but reducer stays in pending… Read more Hadoop-streaming : Reduce Task In Pending State Says "no Room For Reduce Task."

Connecting To Kerberized Hadoop Cluster Using Python Module Impyla

I am using impyla module to connect to kerberized hadoop cluster. I want to access hiveserver2/hive… Read more Connecting To Kerberized Hadoop Cluster Using Python Module Impyla

Connect To Impala Using Impyla Client With Kerberos Auth

I'm on a W8 machine, where I use Python (Anaconda distribution) to connect to Impala in our Had… Read more Connect To Impala Using Impyla Client With Kerberos Auth

Python Udfs In Pig

I've seen the documentatio here, but I confess that I feel it rather lacking. I was wondering … Read more Python Udfs In Pig

Running Hadoop Jar Using Luigi Python

I need to run a Hadoop jar job using Luigi from python. I searched and found examples of writing ma… Read more Running Hadoop Jar Using Luigi Python

Spark On Windows 10. 'files\spark\bin\..\jars""\' Is Not Recognized As An Internal Or External Command

I am very frustrated by Spark. An evening wasted thinking that I was doing something wrong but I ha… Read more Spark On Windows 10. 'files\spark\bin\..\jars""\' Is Not Recognized As An Internal Or External Command

Reading And Writing From Hive Tables With Spark After Aggregation

We have a hive warehouse, and wanted to use spark for various tasks (mainly classification). At tim… Read more Reading And Writing From Hive Tables With Spark After Aggregation

How To Populate A Postgresql Database With Mrjob And Hadoop

I would like to populate a database of Postgresql by using a mapper with MrJob and Hadoop 2.7.1. I … Read more How To Populate A Postgresql Database With Mrjob And Hadoop

Delimiting Carat A In Python

I have data in form: 37101000ssd48800^A1420asd938987^A2011-09-10^A18:47:50.000^A99.00^A1^A0^A 37101… Read more Delimiting Carat A In Python

Spark 2.2 Thrift Server Error On Dataframe Numberformatexception When Query Hive Table

I have Hortonworks HDP 2.6.3 running Spark2 (v2.2). My test case is very simple: Create a Hive tab… Read more Spark 2.2 Thrift Server Error On Dataframe Numberformatexception When Query Hive Table