[jira] [Updated] (CASSANDRA-14005) CqlBulkRecordWriter swallows exceptions
[ https://issues.apache.org/jira/browse/CASSANDRA-14005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edward Ribeiro updated CASSANDRA-14005: --- Attachment: CASSANDRA-14005.patch > 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 >Priority: Major > Attachments: CASSANDRA-14005.patch > > > The {{close()}} method in {{CqlBulkRecordWriter}} has the following: > {code:java} > 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 (v7.6.3#76005) - To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org For additional commands, e-mail: commits-h...@cassandra.apache.org
[jira] [Updated] (CASSANDRA-14005) CqlBulkRecordWriter swallows exceptions
[ https://issues.apache.org/jira/browse/CASSANDRA-14005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edward Ribeiro updated CASSANDRA-14005: --- Attachment: (was: CASSANDRA-14005.patch) > 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 >Priority: Major > > The {{close()}} method in {{CqlBulkRecordWriter}} has the following: > {code:java} > 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 (v7.6.3#76005) - To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org For additional commands, e-mail: commits-h...@cassandra.apache.org
[jira] [Updated] (CASSANDRA-14005) CqlBulkRecordWriter swallows exceptions
[ https://issues.apache.org/jira/browse/CASSANDRA-14005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edward Ribeiro updated CASSANDRA-14005: --- Attachment: CASSANDRA-14005.patch > 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 >Priority: Major > Attachments: CASSANDRA-14005.patch > > > The {{close()}} method in {{CqlBulkRecordWriter}} has the following: > {code:java} > 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 (v7.6.3#76005) - To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org For additional commands, e-mail: commits-h...@cassandra.apache.org
[jira] [Updated] (CASSANDRA-14005) CqlBulkRecordWriter swallows exceptions
[ 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:java} 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: {code:java} 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. > 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:java} > 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
[jira] [Updated] (CASSANDRA-14005) CqlBulkRecordWriter swallows exceptions
[ 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
[jira] [Updated] (CASSANDRA-14005) CqlBulkRecordWriter swallows exceptions
[ 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:java} 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: {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. > 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:java} > 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