[NO ISSUE] Error codes + NCService getter + Record metadata getter
- user model changes: no
- storage format changes: no
- interface changes: no
Details:
- Task, added getter for NodeControllerService.
- RecordWithMetadataAndPK, added getter for metaTypes.
- Added extra error codes.
Change-Id: Ic3fcc6b771b4393542988cd0aa6fd992ccb81028
Reviewed-on: https://asterix-gerrit.ics.uci.edu/3423
Contrib: Jenkins <jenkins@fulliautomatix.ics.uci.edu>
Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>
Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu>
Reviewed-by: Hussain Towaileb <hussainht@gmail.com>
Reviewed-by: Michael Blow <mblow@apache.org>
diff --git a/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/exceptions/ErrorCode.java b/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/exceptions/ErrorCode.java
index 67f0170..e172b38 100644
--- a/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/exceptions/ErrorCode.java
+++ b/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/exceptions/ErrorCode.java
@@ -296,6 +296,11 @@
public static final int FEED_FAILED_WHILE_GETTING_A_NEW_RECORD = 3110;
public static final int FEED_START_FEED_WITHOUT_CONNECTION = 3111;
public static final int PARSER_COLLECTION_ITEM_CANNOT_BE_NULL = 3112;
+ public static final int FAILED_TO_PARSE_RECORD = 3113;
+ public static final int FAILED_TO_PARSE_RECORD_CONTENT = 3114;
+ public static final int FAILED_TO_PARSE_METADATA = 3115;
+ public static final int INPUT_DECODE_FAILURE = 3116;
+ public static final int FAILED_TO_PARSE_MALFORMED_LOG_RECORD = 3117;
// Lifecycle management errors
public static final int DUPLICATE_PARTITION_ID = 4000;
diff --git a/asterixdb/asterix-common/src/main/resources/asx_errormsg/en.properties b/asterixdb/asterix-common/src/main/resources/asx_errormsg/en.properties
index 8bac58c..f8262d9 100644
--- a/asterixdb/asterix-common/src/main/resources/asx_errormsg/en.properties
+++ b/asterixdb/asterix-common/src/main/resources/asx_errormsg/en.properties
@@ -294,6 +294,11 @@
3110 = Feed failed while reading a new record
3111 = Feed %1$s is not connected to any dataset
3112 = Array/Multiset item cannot be null
+3113 = Failed to parse record
+3114 = Failed to parse record content
+3115 = Failed to parse record metadata
+3116 = Failed to decode input
+3117 = Failed to parse record, malformed log record
# Lifecycle management errors
4000 = Partition id %1$s for node %2$s already in use by node %3$s
diff --git a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/RecordWithMetadataAndPK.java b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/RecordWithMetadataAndPK.java
index f9bc8b2..959e34d 100644
--- a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/RecordWithMetadataAndPK.java
+++ b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/RecordWithMetadataAndPK.java
@@ -100,6 +100,10 @@
return record;
}
+ public IAType[] getMetaTypes() {
+ return metaTypes;
+ }
+
public ArrayBackedValueStorage getMetadata(final int index) {
return fieldValueBuffers[index];
}
diff --git a/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/Task.java b/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/Task.java
index 8dd94f3..5bb713d 100644
--- a/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/Task.java
+++ b/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/Task.java
@@ -229,6 +229,10 @@
return this;
}
+ public NodeControllerService getNodeControllerService() {
+ return ncs;
+ }
+
public Joblet getJoblet() {
return joblet;
}