hadoop - Hive JOIN of query with subquery takes forever -

-

lately have been playing bit hive. things have been progressing well, however, when try convert like

2015-04-01   device1   traffic    other       start    2015-04-01   device1   traffic    violation   deny  2015-04-01   device1   traffic    violation   deny  2015-04-02   device1   traffic    other       start    2015-04-03   device1   traffic    other       start    2015-04-03   device1   traffic    other       start

into

2015-04-01   1       2 2015-04-02   1        2015-04-03   2

i tried using following query reason reduce stage of query gets stuck @ 96% no matter how long wait.

select pass.date, count(pass.type), count(deny.deny_type) firewall_logs pass join ( select date, type deny_type firewall_logs device = 'device1'  , date '2015-04-%' , type = 'traffic' , subtype = 'violation' , status = 'deny'  ) deny on ( pass.date = deny.date  ) pass.device = 'device1'  , pass.date '2015-04-%' , pass.type = 'traffic' , pass.subtype = 'other' , pass.status = 'start' group pass.date order pass.date ;

all mr2 logs show is:

2015-06-11 01:54:04,206 info [main] org.apache.hadoop.hive.ql.exec.commonjoinoperator: table 0 has 9028000 rows join key [2015-04-26] 2015-06-11 01:54:04,423 info [main] org.apache.hadoop.hive.ql.exec.commonjoinoperator: table 0 has 9128000 rows join key [2015-04-26] 2015-06-11 01:54:04,638 info [main] org.apache.hadoop.hive.ql.exec.commonjoinoperator: table 0 has 9228000 rows join key [2015-04-26] 2015-06-11 01:54:04,838 info [main] org.apache.hadoop.mapred.fileinputformat: total input paths process : 1

would have idea of why?

i try avoid self-joins in hive plague. can collecting , creating map

add jar ./brickhouse-0.7.1.jar; create temporary function collect 'brickhouse.udf.collect.collectudaf';  select date   , c_map['start'] starts   , c_map['deny'] denies (   select date     , collect(status, c) c_map   (     select date, status       , count( subtype ) c     table     device='device1' , type='traffic'     group date, status ) x   group date ) y

Comments

Post a Comment

Popular posts from this blog

javascript - oscilloscope of speaker input stops rendering after a few seconds -

-
the following script reads audio user's microphone , renders oscilloscope on html canvas. the source taken example of mozilla developer network: visualizations web audio api and here fiddle: http://jsfiddle.net/b7j8pktp/ mozgetusermedia (note: code has no fork mechanism different browsers: works firefox) it works fine few seconds , stops rendering. whereas works totally stable: http://mdn.github.io/voice-change-o-matic/ the problem can reduced following code. microphone activation icon (next the address bar in firefox) disappears after 5 seconds: navigator.mozgetusermedia({audio: true}, function() {}, function() {} ); ( http://jsfiddle.net/b7j8pktp/2/ ) this known bug in firefox. take stream getusermedia call , hook window so: navigator.mozgetusermedia({audio: true}, function(stream) { window.stream = stream; // rest of code }, function err() { // handle error }); hopefully can fixed soon. problem we're f
Read more

javascript - gulp-nodemon - nodejs restart after file change - Error: listen EADDRINUSE events.js:85 -

-
i'm running nodejs 0.12.3 - gulp 3.10.8 , gulp-nodemon 2.0.3. gulpfile.js : gulp.task('serve', ['build'], function() { gulp.start('fb-flo'); nodemon({ script: paths.server, env: { 'node_env': 'development' }, // env: { 'node_env': 'production' }, execmap: { 'js': 'node_modules/babel/bin/babel-node --stage 1' //es7 cote server }, delay: '0ms', watch: ['src/shared/', 'src/server/'], ignore: ['src/shared/components'], tasks: function (changedfiles) { var tasks = []; changedfiles.foreach(function (file) { if (path.extname(file) === '.jsx' && !~tasks.indexof('bundlejs')) tasks.push('bundlejs'); if (path.extname(file) === '.less' && !~tasks.indexof('compileless')) tasks.push('compileless'); }); return tasks; }
Read more

Fatal Python error: Py_Initialize: unable to load the file system codec. ImportError: No module named 'encodings' -

-
i trying make simple python program opening list of webpages user manually download reports site. don't have previous experience preparing exe files.. , i'm in learning process python coding. of done on windows 7 x64 this python code: #!c:/python34/python.exe -u splinter import * import time import os import csv #---------------------------------- raporty = [] open('../raporty.csv', newline='') csvfile: contents = csv.reader(csvfile, delimiter=' ', quotechar='|') row in contents: r = ', '.join(row) r = r.replace(',','') raporty.append(r) #--not implemented yet zmienne = [] open('../zmienne.csv', newline='') csvfile: contents = csv.reader(csvfile, delimiter=' ', quotechar='|') row in contents: r = ', '.join(row) r = r.replace(',','') zmienne.append(r) print("start") browser = browser(
Read more