[ 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)