[e2eTest] add e2eTest model
diff --git a/.github/workflows/maven-package.yml b/.github/workflows/maven-package.yml
index 02de6d3..e3b2773 100644
--- a/.github/workflows/maven-package.yml
+++ b/.github/workflows/maven-package.yml
@@ -34,9 +34,7 @@
- name: Wait for RocketMQ broker container to be ready
run: |
- docker exec rmqbroker sh -c 'while ! nc -z localhost 10911; do sleep 1; done'
- - name : create output file
- run: touch /home/runner/demo
+ docker exec rmqbroker sh -c 'while ! nc -z localhost 10911; do sleep 1; done'
- uses: actions/checkout@v3
- name: Set up JDK 8
uses: actions/setup-java@v3
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 197e34e..8acca33 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
@@ -30,7 +30,7 @@
import java.util.List;
public class FileSinkTask extends SinkTask {
- private String fileName = System.getProperty("user.home") + "/demo.eventbridge";
+ private String fileName = System.getProperty("user.home") + "/demo";
private PrintStream outputStream;
@Override public void put(List<ConnectRecord> sinkRecords) throws ConnectException {
