[
https://issues.apache.org/jira/browse/HIVE-8842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14208867#comment-14208867
]
Hive QA commented on HIVE-8842:
-------------------------------
{color:red}Overall{color}: -1 no tests executed
Here are the results of testing the latest attachment:
https://issues.apache.org/jira/secure/attachment/12681153/HIVE-8842.1-spark.patch
Test results:
http://ec2-174-129-184-35.compute-1.amazonaws.com/jenkins/job/PreCommit-HIVE-SPARK-Build/343/testReport
Console output:
http://ec2-174-129-184-35.compute-1.amazonaws.com/jenkins/job/PreCommit-HIVE-SPARK-Build/343/console
Test logs:
http://ec2-174-129-184-35.compute-1.amazonaws.com/logs/PreCommit-HIVE-SPARK-Build-343/
Messages:
{noformat}
Executing org.apache.hive.ptest.execution.PrepPhase
Executing org.apache.hive.ptest.execution.ExecutionPhase
Tests exited with: ExecutionException: java.util.concurrent.ExecutionException:
org.apache.hive.ptest.execution.ssh.SSHExecutionException: RSyncResult
[localFile=/data/hive-ptest/logs/PreCommit-HIVE-SPARK-Build-343/succeeded/TestSchedulerQueue,
remoteFile=/home/hiveptest/54.176.21.26-hiveptest-2/logs/, getExitCode()=255,
getException()=null, getUser()=hiveptest, getHost()=54.176.21.26,
getInstance()=2]: 'Address 54.176.21.26 maps to
ec2-54-176-21-26.us-west-1.compute.amazonaws.com, but this does not map back to
the address - POSSIBLE BREAK-IN ATTEMPT!
receiving incremental file list
./
TEST-TestSchedulerQueue-TEST-org.apache.hive.jdbc.TestSchedulerQueue.xml
0 0% 0.00kB/s 0:00:00
5158 100% 4.92MB/s 0:00:00 (xfer#1, to-check=3/5)
hive.log
0 0% 0.00kB/s 0:00:00
Write failed: Broken pipe
rsync: connection unexpectedly closed (23535727 bytes received so far)
[receiver]
rsync error: error in rsync protocol data stream (code 12) at io.c(600)
[receiver=3.0.6]
rsync: connection unexpectedly closed (195 bytes received so far) [generator]
rsync error: unexplained error (code 255) at io.c(600) [generator=3.0.6]
ssh: connect to host 54.176.21.26 port 22: Connection timed out
rsync: connection unexpectedly closed (0 bytes received so far) [receiver]
rsync error: unexplained error (code 255) at io.c(600) [receiver=3.0.6]
ssh: connect to host 54.176.21.26 port 22: Connection timed out
rsync: connection unexpectedly closed (0 bytes received so far) [receiver]
rsync error: unexplained error (code 255) at io.c(600) [receiver=3.0.6]
ssh: connect to host 54.176.21.26 port 22: Connection timed out
rsync: connection unexpectedly closed (0 bytes received so far) [receiver]
rsync error: unexplained error (code 255) at io.c(600) [receiver=3.0.6]
ssh: connect to host 54.176.21.26 port 22: Connection timed out
rsync: connection unexpectedly closed (0 bytes received so far) [receiver]
rsync error: unexplained error (code 255) at io.c(600) [receiver=3.0.6]
'
{noformat}
This message is automatically generated.
ATTACHMENT ID: 12681153 - PreCommit-HIVE-SPARK-Build
> auto_join2.q produces incorrect tree [Spark Branch]
> ---------------------------------------------------
>
> Key: HIVE-8842
> URL: https://issues.apache.org/jira/browse/HIVE-8842
> Project: Hive
> Issue Type: Sub-task
> Components: Spark
> Reporter: Szehon Ho
> Attachments: HIVE-8842.1-spark.patch
>
>
> Enabling the SparkMapJoinResolver and SparkReduceSinkMapJoinProc, I see the
> following:
> {noformat}
> explain select * from src src1 JOIN src src2 ON (src1.key = src2.key) JOIN
> src src3 ON (src1.key + src2.key = src3.key);
> {noformat}
> produces too many stages (six), and too many HashTableSink.
> {noformat}
> STAGE DEPENDENCIES:
> Stage-5 is a root stage
> Stage-4 depends on stages: Stage-5
> Stage-3 depends on stages: Stage-4
> Stage-7 is a root stage
> Stage-6 depends on stages: Stage-7
> Stage-0 is a root stage
> STAGE PLANS:
> Stage: Stage-5
> Spark
> DagName: szehon_20141112105656_dd50e07d-94ad-4f9d-899e-bcb6d9a39c13:3
> Vertices:
> Map 1
> Map Operator Tree:
> TableScan
> alias: src2
> Statistics: Num rows: 29 Data size: 5812 Basic stats:
> COMPLETE Column stats: NONE
> Filter Operator
> predicate: key is not null (type: boolean)
> Statistics: Num rows: 15 Data size: 3006 Basic stats:
> COMPLETE Column stats: NONE
> HashTable Sink Operator
> condition expressions:
> 0 {key} {value}
> 1 {key} {value}
> keys:
> 0 key (type: string)
> 1 key (type: string)
> Stage: Stage-4
> Spark
> DagName: szehon_20141112105656_dd50e07d-94ad-4f9d-899e-bcb6d9a39c13:2
> Vertices:
> Map 3
> Map Operator Tree:
> TableScan
> alias: src1
> Statistics: Num rows: 29 Data size: 5812 Basic stats:
> COMPLETE Column stats: NONE
> Filter Operator
> predicate: key is not null (type: boolean)
> Statistics: Num rows: 15 Data size: 3006 Basic stats:
> COMPLETE Column stats: NONE
> Map Join Operator
> condition map:
> Inner Join 0 to 1
> condition expressions:
> 0 {key} {value}
> 1 {key} {value}
> keys:
> 0 key (type: string)
> 1 key (type: string)
> outputColumnNames: _col0, _col1, _col5, _col6
> input vertices:
> 1 Map 1
> Statistics: Num rows: 16 Data size: 3306 Basic stats:
> COMPLETE Column stats: NONE
> Filter Operator
> predicate: (_col0 + _col5) is not null (type: boolean)
> Statistics: Num rows: 8 Data size: 1653 Basic stats:
> COMPLETE Column stats: NONE
> HashTable Sink Operator
> condition expressions:
> 0 {_col0} {_col1} {_col5} {_col6}
> 1 {key} {value}
> keys:
> 0 (_col0 + _col5) (type: double)
> 1 UDFToDouble(key) (type: double)
> Stage: Stage-3
> Spark
> DagName: szehon_20141112105656_dd50e07d-94ad-4f9d-899e-bcb6d9a39c13:1
> Vertices:
> Map 2
> Map Operator Tree:
> TableScan
> alias: src3
> Statistics: Num rows: 29 Data size: 5812 Basic stats:
> COMPLETE Column stats: NONE
> Filter Operator
> predicate: UDFToDouble(key) is not null (type: boolean)
> Statistics: Num rows: 15 Data size: 3006 Basic stats:
> COMPLETE Column stats: NONE
> Map Join Operator
> condition map:
> Inner Join 0 to 1
> condition expressions:
> 0 {_col0} {_col1} {_col5} {_col6}
> 1 {key} {value}
> keys:
> 0 (_col0 + _col5) (type: double)
> 1 UDFToDouble(key) (type: double)
> outputColumnNames: _col0, _col1, _col5, _col6, _col10,
> _col11
> input vertices:
> 0 Map 3
> Statistics: Num rows: 16 Data size: 3306 Basic stats:
> COMPLETE Column stats: NONE
> Select Operator
> expressions: _col0 (type: string), _col1 (type:
> string), _col5 (type: string), _col6 (type: string), _col10 (type: string),
> _col11 (type: string)
> outputColumnNames: _col0, _col1, _col2, _col3, _col4,
> _col5
> Statistics: Num rows: 16 Data size: 3306 Basic stats:
> COMPLETE Column stats: NONE
> File Output Operator
> compressed: false
> Statistics: Num rows: 16 Data size: 3306 Basic
> stats: COMPLETE Column stats: NONE
> table:
> input format:
> org.apache.hadoop.mapred.TextInputFormat
> output format:
> org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
> serde:
> org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
> Stage: Stage-7
> Spark
> DagName: szehon_20141112105656_dd50e07d-94ad-4f9d-899e-bcb6d9a39c13:3
> Vertices:
> Map 1
> Map Operator Tree:
> TableScan
> alias: src2
> Statistics: Num rows: 29 Data size: 5812 Basic stats:
> COMPLETE Column stats: NONE
> Filter Operator
> predicate: key is not null (type: boolean)
> Statistics: Num rows: 15 Data size: 3006 Basic stats:
> COMPLETE Column stats: NONE
> HashTable Sink Operator
> condition expressions:
> 0 {key} {value}
> 1 {key} {value}
> keys:
> 0 key (type: string)
> 1 key (type: string)
> Stage: Stage-6
> Spark
> DagName: szehon_20141112105656_dd50e07d-94ad-4f9d-899e-bcb6d9a39c13:2
> Vertices:
> Map 3
> Map Operator Tree:
> TableScan
> alias: src1
> Statistics: Num rows: 29 Data size: 5812 Basic stats:
> COMPLETE Column stats: NONE
> Filter Operator
> predicate: key is not null (type: boolean)
> Statistics: Num rows: 15 Data size: 3006 Basic stats:
> COMPLETE Column stats: NONE
> Map Join Operator
> condition map:
> Inner Join 0 to 1
> condition expressions:
> 0 {key} {value}
> 1 {key} {value}
> keys:
> 0 key (type: string)
> 1 key (type: string)
> outputColumnNames: _col0, _col1, _col5, _col6
> input vertices:
> 1 Map 1
> Statistics: Num rows: 16 Data size: 3306 Basic stats:
> COMPLETE Column stats: NONE
> Filter Operator
> predicate: (_col0 + _col5) is not null (type: boolean)
> Statistics: Num rows: 8 Data size: 1653 Basic stats:
> COMPLETE Column stats: NONE
> HashTable Sink Operator
> condition expressions:
> 0 {_col0} {_col1} {_col5} {_col6}
> 1 {key} {value}
> keys:
> 0 (_col0 + _col5) (type: double)
> 1 UDFToDouble(key) (type: double)
> Stage: Stage-0
> Fetch Operator
> limit: -1
> Processor Tree:
> ListSink
> {noformat}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
