jsingh-yelp commented on code in PR #8001:
URL: https://github.com/apache/paimon/pull/8001#discussion_r3449457503
##########
paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lineage/LineageUtils.java:
##########
@@ -73,19 +77,16 @@ private static CatalogContext catalogContext(Table table) {
}
/**
- * Builds the config map for a dataset facet. Includes filtered Paimon
{@link CoreOptions},
- * partition keys, primary keys, and a safe subset of catalog-level
options (warehouse,
- * metastore) prefixed with {@code "catalog."}.
+ * Builds the config map for a dataset facet from a {@link Table}.
Includes all table options,
+ * partition keys, and primary keys.
*/
private static Map<String, String> buildConfigMap(
Table table, @Nullable CatalogContext catalogContext) {
Map<String, String> config = new HashMap<>();
config.put("partition-keys", String.join(",", table.partitionKeys()));
config.put("primary-keys", String.join(",", table.primaryKeys()));
- table.options().entrySet().stream()
- .filter(e -> PAIMON_OPTION_KEYS.contains(e.getKey()))
- .forEach(e -> config.put(e.getKey(), e.getValue()));
+ config.putAll(table.options());
Review Comment:
@JingsongLi fixed as suggested
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
