You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by zh...@apache.org on 2022/04/14 03:05:21 UTC
[rocketmq-connect] branch master updated: [ISSUE #88] Fix stackOverflowError exception when in IDE debug (#89)
This is an automated email from the ASF dual-hosted git repository.
zhoubo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git
The following commit(s) were added to refs/heads/master by this push:
new c95713e [ISSUE #88] Fix stackOverflowError exception when in IDE debug (#89)
c95713e is described below
commit c95713e21460aacb65176c6c34f974c6253a36e4
Author: Slideee <48...@users.noreply.github.com>
AuthorDate: Thu Apr 14 11:05:17 2022 +0800
[ISSUE #88] Fix stackOverflowError exception when in IDE debug (#89)
Co-authored-by: yechun <ye...@corp.netease.com>
---
.../main/java/org/apache/rocketmq/connect/file/FileSourceTask.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileSourceTask.java b/rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileSourceTask.java
index b534fd7..8309833 100644
--- a/rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileSourceTask.java
+++ b/rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileSourceTask.java
@@ -25,6 +25,7 @@ import io.openmessaging.connector.api.data.FieldType;
import io.openmessaging.connector.api.data.RecordOffset;
import io.openmessaging.connector.api.data.RecordPartition;
import io.openmessaging.connector.api.data.Schema;
+import io.openmessaging.connector.api.data.SchemaBuilder;
import io.openmessaging.connector.api.errors.ConnectException;
import java.io.BufferedReader;
import java.io.IOException;
@@ -142,7 +143,7 @@ public class FileSourceTask extends SourceTask {
}
List<Field> fields = new ArrayList<Field>();
Schema schema = new Schema(fileConfig.getFilename() + LINE, FieldType.STRING, fields);
- final Field field = new Field(0, FileConstants.FILE_LINE_CONTENT, schema);
+ final Field field = new Field(0, FileConstants.FILE_LINE_CONTENT, SchemaBuilder.string().name(fileConfig.getFilename() + LINE).build());
fields.add(field);
schema.setFields(fields);
ConnectRecord connectRecord = new ConnectRecord(offsetKey(fileConfig.getFilename()), offsetValue(streamOffset), System.currentTimeMillis(), schema, line);
@@ -201,7 +202,6 @@ public class FileSourceTask extends SourceTask {
}
}
-
@Override public void start(SourceTaskContext sourceTaskContext) {
this.sourceTaskContext = sourceTaskContext;
fileConfig = new FileConfig();