[HIVE-19552] Enable TestMiniDruidKafkaCliDriver#druidkafkamini_basic.q

• Type: Test
• Status: Closed
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 3.1.0
• Fix Version/s: 3.2.0, 4.0.0-alpha-1
• Component/s: Test
• Assignee: Nishant Bangarwa
• Reporter: Jesús Camacho Rodríguez
• Created: 15/May/18 03:06
• Updated: 27/Feb/24 22:24
• Resolved: 12/Sep/18 17:01

Description

The failure was caused by the following sequence of steps -

1. Test queries for available hosts where a segment is located and gets the location of kafka task.
2. Kafka task hands over the data and finishes
3. 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.

Issue Links

• is caused by: HIVE-20349 Implement Retry Logic in HiveDruidSplit for Scan Queries
• relates to: HIVE-19509 Disable tests that are failing continuously