[HUDI-1429] NPE HoodieMultiTableDeltaStreamer when using parquet DFS source

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.9.0
• Fix Version/s: 0.8.0
• Component/s: deltastreamer
• Labels: easyfix user-support-issues
• Assignee: sivabalan narayanan
• Reporter: Nagabhushanam
• Created: 02/Dec/20 11:18
• Updated: 06/Apr/21 01:55
• Resolved: 26/Mar/21 21:48

Description

NPE HoodieMultiTableDeltaStreamer when using parquet DFS source at 

org/apache/hudi/utilities/deltastreamer/HoodieMultiTableDeltaStreamer.java:150

Below is the error causing snippet

if (cfg.schemaProviderClassName.equals(SchemaRegistryProvider.class.getName())) {

 in case of parquest dfs schema provider is not provided.

cfg.schemaProviderClassName is null 

so the above should be 

if (SchemaRegistryProvider.class.getName().equals(cfg.schemaProviderClassName)) {