The call to take() holds a lock in the BlockingQueue so an
InterruptedException means that all bets are off for processLoadTable and
the Try block in run can deal with that. I could add a new Try block to
processLoadTable but my understanding is that the behaviour is identical.


On Tue, Feb 11, 2014 at 11:56 AM, Anish Khanzode
<notifications@github.com>wrote:

> In src/frontend/org/voltdb/utils/CSVPartitionProcessor.java:
>
> > @@ -383,7 +385,7 @@ private void submitWorkToServer(VoltTable table, String procName,
> >      }
> >
> >      // while there are rows and m_endOfData not seen batch and call procedure for insert.
> > -    private void processLoadTable(VoltTable table, String procName) {
> > +    private void processLoadTable(VoltTable table, String procName) throws InterruptedException {
>
> Was this change necessary for take()?
>
> --
> Reply to this email directly or view it on GitHub<https://github.com/VoltDB/voltdb/pull/1129/files#r9631866>
> .
>