[HIVE-8343] Return value from BlockingQueue.offer() is not checked in DynamicPartitionPruner

• Type: Bug
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 0.14.0, 1.0.0, 1.1.0, 1.2.0
• Fix Version/s: 2.1.0
• Assignee: JongWon Park
• Reporter: Ted Yu
• Created: 03/Oct/14 22:33
• Updated: 21/Jun/16 15:52
• Resolved: 06/May/16 23:28

Description

In addEvent() and processVertex(), there is call such as the following:

          queue.offer(event);

The return value should be checked. If false is returned, event would not have been queued.
Take a look at line 328 in:
http://fuseyism.com/classpath/doc/java/util/concurrent/LinkedBlockingQueue-source.html