[GitHub] [incubator-hudi] bvaradar commented on a change in pull request #1566: [HUDI-603]: DeltaStreamer can now fetch schema before every run in continuous mode

bvaradar commented on a change in pull request #1566: URL: https://github.com/apache/incubator-hudi/pull/1566#discussion_r428210549 ## File path: hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/SchemaSet.java ## @@ -0,0 +1,44 @@ +/* + * Licensed to the Apache

[GitHub] [incubator-hudi] bvaradar commented on a change in pull request #1566: [HUDI-603]: DeltaStreamer can now fetch schema before every run in continuous mode

bvaradar commented on a change in pull request #1566: URL: https://github.com/apache/incubator-hudi/pull/1566#discussion_r428209317 ## File path: hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/SchemaRegistryProvider.java ## @@ -81,11 +66,22 @@ private static

[GitHub] [incubator-hudi] bvaradar commented on a change in pull request #1566: [HUDI-603]: DeltaStreamer can now fetch schema before every run in continuous mode

bvaradar commented on a change in pull request #1566: URL: https://github.com/apache/incubator-hudi/pull/1566#discussion_r428208406 ## File path: hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/SchemaRegistryProvider.java ## @@ -81,11 +66,22 @@ private static

[GitHub] [incubator-hudi] bvaradar commented on a change in pull request #1566: [HUDI-603]: DeltaStreamer can now fetch schema before every run in continuous mode

bvaradar commented on a change in pull request #1566: URL: https://github.com/apache/incubator-hudi/pull/1566#discussion_r428206400 ## File path: hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/SchemaSet.java ## @@ -0,0 +1,44 @@ +/* + * Licensed to the Apache

[GitHub] [incubator-hudi] bvaradar commented on a change in pull request #1566: [HUDI-603]: DeltaStreamer can now fetch schema before every run in continuous mode

bvaradar commented on a change in pull request #1566: URL: https://github.com/apache/incubator-hudi/pull/1566#discussion_r416220182 ## File path: hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/DeltaSync.java ## @@ -162,18 +162,23 @@ public