Skip to content

Commit 9aa0988

Browse files
committed
Stabilize FileIOTest updated-file timestamp assertions
1 parent 5e86d7e commit 9aa0988

1 file changed

Lines changed: 7 additions & 0 deletions

File tree

sdks/java/core/src/test/java/org/apache/beam/sdk/io/FileIOTest.java

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -257,10 +257,17 @@ public void processElement(ProcessContext context, @StateId("count") ValueState<
257257

258258
if (0 == current) {
259259
Thread.sleep(100);
260+
// Ensure overwrite updates get a distinct mtime even when COPY_ATTRIBUTES is enabled.
261+
Files.setLastModifiedTime(
262+
sourcePath.resolve("first"), FileTime.fromMillis(System.currentTimeMillis() + 2000));
260263
Files.copy(sourcePath.resolve("first"), watchPath.resolve("first"), updOptions);
261264
Files.copy(sourcePath.resolve("second"), watchPath.resolve("second"), cpOptions);
262265
} else if (1 == current) {
263266
Thread.sleep(100);
267+
Files.setLastModifiedTime(
268+
sourcePath.resolve("first"), FileTime.fromMillis(System.currentTimeMillis() + 4000));
269+
Files.setLastModifiedTime(
270+
sourcePath.resolve("second"), FileTime.fromMillis(System.currentTimeMillis() + 4000));
264271
Files.copy(sourcePath.resolve("first"), watchPath.resolve("first"), updOptions);
265272
Files.copy(sourcePath.resolve("second"), watchPath.resolve("second"), updOptions);
266273
Files.copy(sourcePath.resolve("third"), watchPath.resolve("third"), cpOptions);

0 commit comments

Comments
 (0)