abdullah alamoudi has uploaded a new patch set (#2). Change subject: [NO ISSUE][ING] Close and return on interrupt of ingestion ......................................................................
[NO ISSUE][ING] Close and return on interrupt of ingestion - user model changes: no - storage format changes: no - interface changes: no Details: - Previously, we would still attempt to write through the network in case an ingestion task is interrupted. - The goal was to try and get as much data in as possible but in the case where the cluster was in a bad state, this could lead to hanging threads. - After this change, each record reader must implement the stop method correctly to allow for graceful stop while interrupts will always mean abort the task and return as soon as possible. Change-Id: I6119617d133fb161a48b39f9812ec79e0189975b --- M asterixdb/asterix-common/src/main/java/org/apache/asterix/common/exceptions/ErrorCode.java M asterixdb/asterix-common/src/main/resources/asx_errormsg/en.properties M asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/FeedRecordDataFlowController.java M asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/twitter/TwitterPullRecordReader.java M asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedIntakeOperatorNodePushable.java 5 files changed, 10 insertions(+), 19 deletions(-) git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb refs/changes/28/2428/2 -- To view, visit https://asterix-gerrit.ics.uci.edu/2428 To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings Gerrit-MessageType: newpatchset Gerrit-Change-Id: I6119617d133fb161a48b39f9812ec79e0189975b Gerrit-PatchSet: 2 Gerrit-Project: asterixdb Gerrit-Branch: master Gerrit-Owner: abdullah alamoudi <bamou...@gmail.com> Gerrit-Reviewer: Jenkins <jenk...@fulliautomatix.ics.uci.edu>
