[GitHub] [pulsar] devinbost commented on issue #6370: (Flaky-test) Intermittent failure of TestPulsarKeyValueSchemaHandler testSchema1 & testSchema2

[GitBox]

devinbost commented on issue #6370: (Flaky-test) Intermittent failure of 
TestPulsarKeyValueSchemaHandler testSchema1 & testSchema2
URL: https://github.com/apache/pulsar/issues/6370#issuecomment-588523970
 
 
   It appears (from the stack trace) that the NPE is getting thrown from the 
line:
   `SchemaType schemaType = schemaInfo.getType();`
   
   in this method:
   
   ```
    static List<ColumnMetadata> getPulsarColumns(TopicName topicName,
                                                    SchemaInfo schemaInfo,
                                                    boolean withInternalColumns,
                                                    
PulsarColumnHandle.HandleKeyValueType handleKeyValueType) {
           SchemaType schemaType = schemaInfo.getType();
           if (schemaType.isStruct()) {
               return getPulsarColumnsFromStructSchema(topicName, schemaInfo, 
withInternalColumns, handleKeyValueType);
           } else if (schemaType.isPrimitive()) {
               return getPulsarColumnsFromPrimitiveSchema(topicName, 
schemaInfo, withInternalColumns, handleKeyValueType);
           } else if (schemaType.equals(SchemaType.KEY_VALUE)) {
               return getPulsarColumnsFromKeyValueSchema(topicName, schemaInfo, 
withInternalColumns);
           } else {
               throw new IllegalArgumentException("Unsupported schema : " + 
schemaInfo);
           }
       }
   ```

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


With regards,
Apache Git Services