Skip to content

Commit 944c2ca

Browse files
committed
Unflake testCloseIdleWriters
1 parent f3032a7 commit 944c2ca

File tree

2 files changed

+6
-6
lines changed

2 files changed

+6
-6
lines changed

plugin/trino-hive/src/test/java/io/trino/plugin/hive/TestCloseIdleWriters.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -65,9 +65,9 @@ WHEN shipmode IN ('AIR', 'FOB', 'SHIP', 'TRUCK') THEN 0
6565
WHEN shipmode IN ('MAIL', 'RAIL', 'REG AIR') THEN 1
6666
ELSE 2
6767
END AS shipmodeVal
68-
FROM tpch.tiny.lineitem
68+
FROM tpch.\"sf0.1\".lineitem
6969
ORDER BY shipmode
70-
LIMIT 60174
70+
LIMIT 600571
7171
""".formatted(tableName);
7272

7373
// Disable all kind of scaling and set idle writer threshold to 10MB
@@ -80,7 +80,7 @@ WHEN shipmode IN ('MAIL', 'RAIL', 'REG AIR') THEN 1
8080
.setSystemProperty(IDLE_WRITER_MIN_DATA_SIZE_THRESHOLD, "0.1MB")
8181
.build(),
8282
createTableSql,
83-
60174);
83+
600571);
8484
long files = (long) computeScalar("SELECT count(DISTINCT \"$path\") FROM " + tableName);
8585
// There should more than 2 files since we triggered close idle writers.
8686
assertThat(files).isGreaterThan(2);

plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/TestCloseIdleWriters.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -65,9 +65,9 @@ WHEN shipmode IN ('AIR', 'FOB', 'SHIP', 'TRUCK') THEN 0
6565
WHEN shipmode IN ('MAIL', 'RAIL', 'REG AIR') THEN 1
6666
ELSE 2
6767
END AS shipmodeVal
68-
FROM tpch.tiny.lineitem
68+
FROM tpch.\"sf0.1\".lineitem
6969
ORDER BY shipmode
70-
LIMIT 60174
70+
LIMIT 600571
7171
""".formatted(tableName);
7272

7373
// Disable all kind of scaling and set idle writer threshold to 5MB
@@ -80,7 +80,7 @@ WHEN shipmode IN ('MAIL', 'RAIL', 'REG AIR') THEN 1
8080
.setSystemProperty(IDLE_WRITER_MIN_DATA_SIZE_THRESHOLD, "0.1MB")
8181
.build(),
8282
createTableSql,
83-
60174);
83+
600571);
8484
long files = (long) computeScalar("SELECT count(DISTINCT \"$path\") FROM " + tableName);
8585
// There should more than 2 files since we triggered close idle writers.
8686
assertThat(files).isGreaterThan(2);

0 commit comments

Comments
 (0)