[e2eTest] add e2eTest model
diff --git a/supports/eventbridge-connect-file/src/main/java/org/apache/rocketmq/connect/sink/FileSinkTask.java b/supports/eventbridge-connect-file/src/main/java/org/apache/rocketmq/connect/sink/FileSinkTask.java
index 39526cd..197e34e 100644
--- a/supports/eventbridge-connect-file/src/main/java/org/apache/rocketmq/connect/sink/FileSinkTask.java
+++ b/supports/eventbridge-connect-file/src/main/java/org/apache/rocketmq/connect/sink/FileSinkTask.java
@@ -44,6 +44,7 @@
throw new ConnectException("Write record to file failed.", e);
}
}
+ outputStream.flush();
}
diff --git a/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/controller/ApplicationTagControllerTest.java b/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/controller/ApplicationTagControllerTest.java
index e2f6b42..562e4cd 100644
--- a/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/controller/ApplicationTagControllerTest.java
+++ b/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/controller/ApplicationTagControllerTest.java
@@ -40,7 +40,7 @@
ResponseEntity<Void> response = Utils.request(template, url, HttpMethod.POST, "A test recrod.", Void.class, headers);
Assert.assertTrue(response.getStatusCode().is2xxSuccessful());
- File file = new File("/home/runner/demo");
+ File file = new File(System.getProperty("user.home") +"/demo");
String data = null;
int retries = 0;
while( retries < 10 ) {
@@ -48,7 +48,7 @@
if (StringUtils.isNotBlank(data)) {
break;
}
- Thread.sleep(50000);
+ Thread.sleep(5000);
retries++;
}
Assert.assertEquals("A test recrod.\n", data);
