[ 
https://issues.apache.org/jira/browse/CASSANDRA-14005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Vincent Dumont updated CASSANDRA-14005:
---------------------------------------
    Description: 
The close() method in CqlBulkRecordWriter has the following:

{code}
                try
                {
                    future.get(1000, TimeUnit.MILLISECONDS);
                    break;
                }
                catch (ExecutionException | TimeoutException te)
                {
                    if (null != progress)
                        progress.progress();
                    if (null != context)
                        HadoopCompat.progress(context);
                }
                catch (InterruptedException e)
                {
                    throw new IOException(e);
                }
{/code}

And so any exception that happens when uploading SSTables silently gets 
swallowed and not surfaced.

  was:
The close() method in CqlBulkRecordWriter has the following:

                {{try
                {
                    future.get(1000, TimeUnit.MILLISECONDS);
                    break;
                }
                catch (ExecutionException | TimeoutException te)
                {
                    if (null != progress)
                        progress.progress();
                    if (null != context)
                        HadoopCompat.progress(context);
                }
                catch (InterruptedException e)
                {
                    throw new IOException(e);
                }}}


And so any exception that happens when uploading SSTables silently gets 
swallowed and not surfaced.


> CqlBulkRecordWriter swallows exceptions
> ---------------------------------------
>
>                 Key: CASSANDRA-14005
>                 URL: https://issues.apache.org/jira/browse/CASSANDRA-14005
>             Project: Cassandra
>          Issue Type: Bug
>          Components: CQL
>            Reporter: Vincent Dumont
>
> The close() method in CqlBulkRecordWriter has the following:
> {code}
>                 try
>                 {
>                     future.get(1000, TimeUnit.MILLISECONDS);
>                     break;
>                 }
>                 catch (ExecutionException | TimeoutException te)
>                 {
>                     if (null != progress)
>                         progress.progress();
>                     if (null != context)
>                         HadoopCompat.progress(context);
>                 }
>                 catch (InterruptedException e)
>                 {
>                     throw new IOException(e);
>                 }
> {/code}
> And so any exception that happens when uploading SSTables silently gets 
> swallowed and not surfaced.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org
For additional commands, e-mail: commits-h...@cassandra.apache.org

Reply via email to