JingsongLi commented on code in PR #486:
URL: https://github.com/apache/paimon-rust/pull/486#discussion_r3544946552
##########
crates/paimon/tests/rest_catalog_test.rs:
##########
@@ -254,6 +345,146 @@ async fn test_catalog_get_table() {
assert!(table.is_ok(), "failed to get table: {table:?}");
}
+#[tokio::test]
+async fn test_rest_env_get_table_reuses_catalog_environment() {
+ let ctx = setup_catalog(vec!["default"]).await;
+
+ ctx.server.add_table_with_schema(
+ "default",
+ "current_table",
+ test_schema(),
+ "file:///tmp/test_warehouse/default.db/current_table",
+ );
+ ctx.server.add_table_with_schema(
+ "default",
+ "upstream_table",
+ test_schema(),
+ "file:///tmp/test_warehouse/default.db/upstream_table",
+ );
+
+ let current = ctx
+ .catalog
+ .get_table(&Identifier::new("default", "current_table"))
+ .await
+ .expect("current table should load");
+ let upstream = current
+ .rest_env()
+ .expect("REST table should carry RESTEnv")
+ .get_table(&Identifier::new("default", "upstream_table"))
+ .await
+ .expect("upstream table should load via RESTEnv");
+
+ assert_eq!(upstream.identifier().full_name(), "default.upstream_table");
+ assert!(upstream.rest_env().is_some());
+}
+
+#[tokio::test]
+async fn test_blob_view_prescan_filters_invalid_filtered_out_reference() {
Review Comment:
Addressed in 604d40a by gating this FileSystemCatalog-backed regression with
`#[cfg(not(windows))]`, matching the existing filesystem catalog test policy
for the opendal fs listing StripPrefixError. Verified locally with
rest_catalog_test and workspace clippy.
--
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]
