[ 
https://issues.apache.org/jira/browse/HIVE-19552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16612316#comment-16612316
 ] 

Nishant Bangarwa commented on HIVE-19552:
-----------------------------------------

[~jcamachorodriguez] Please merge. This is good to be merged now.

> Enable TestMiniDruidKafkaCliDriver#druidkafkamini_basic.q
> ---------------------------------------------------------
>
>                 Key: HIVE-19552
>                 URL: https://issues.apache.org/jira/browse/HIVE-19552
>             Project: Hive
>          Issue Type: Test
>          Components: Test
>    Affects Versions: 3.1.0
>            Reporter: Jesus Camacho Rodriguez
>            Assignee: Nishant Bangarwa
>            Priority: Critical
>         Attachments: HIVE-19552.1.patch, HIVE-19552.patch
>
>
> The failure was caused by the following sequence of steps - 
> # Test queries for available hosts where a segment is located and gets the 
> location of kafka task. 
> # Kafka task hands over the data and finishes
> # Now the scan query is sent to the kafka task, but the task has already 
> completed and will fail. 
> https://issues.apache.org/jira/browse/HIVE-20349 fixes this issue by retrying 
> the broker in this case. 
> One more cause of failure was the latestOffsets and minimumLag not reported 
> when there is no task. 
> This patch masks those two values also. Query results are verified to ensure 
> that there is no lag. 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to