File tree Expand file tree Collapse file tree 1 file changed +8
-4
lines changed
com.ibm.streamsx.hbase/impl/java/src/com/ibm/streamsx/hbase Expand file tree Collapse file tree 1 file changed +8
-4
lines changed Original file line number Diff line number Diff line change @@ -201,12 +201,16 @@ public static void runtimeHBaseOperatorChecks(OperatorContextChecker checker) {
201
201
if (errorOutputPort .getStreamSchema ().getAttribute (0 ).getType ().getMetaType () != Type .MetaType .RSTRING ) {
202
202
checker .setInvalidContext ("The first attribute in the optional error output port must be a rstring" , null );
203
203
}
204
+
205
+ // The second attribute of error output port is optional.
206
+ if (errorOutputPort .getStreamSchema ().getAttributeCount () > 1 ){
204
207
// The second attribute of optional error output port must be a Tuple.
205
- if (errorOutputPort .getStreamSchema ().getAttribute (1 ) !=null ){
206
- if (errorOutputPort .getStreamSchema ().getAttribute (1 ).getType ().getMetaType () != Type .MetaType .TUPLE ) {
207
- checker .setInvalidContext ("The second attribute in the optional error output port must be a TUPLE" , null );
208
+ if (errorOutputPort .getStreamSchema ().getAttribute (1 ) !=null ){
209
+ if (errorOutputPort .getStreamSchema ().getAttribute (1 ).getType ().getMetaType () != Type .MetaType .TUPLE ) {
210
+ checker .setInvalidContext ("The second attribute in the optional error output port must be a TUPLE" , null );
211
+ }
212
+
208
213
}
209
-
210
214
}
211
215
212
216
}
You can’t perform that action at this time.
0 commit comments