(rocketmq-eventbridge) 25/33: [e2eTest] add e2eTest model

[shenlin]

This is an automated email from the ASF dual-hosted git repository.

shenlin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git

commit b885fa4e7b8f7caaa7761b97686b37a83d797446
Author: wangkai <wang...@zhongan.com>
AuthorDate: Fri Nov 3 16:00:22 2023 +0800

    [e2eTest] add e2eTest model
---
 .github/workflows/maven-package.yml                                   | 4 +---
 .../src/main/java/org/apache/rocketmq/connect/sink/FileSinkTask.java  | 2 +-
 2 files changed, 2 insertions(+), 4 deletions(-)

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 @@ jobs:
 
       - 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.nio.file.StandardOpenOption;
 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 {