You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by "sunxiaojian (via GitHub)" <gi...@apache.org> on 2023/04/18 06:59:42 UTC
[GitHub] [incubator-seatunnel] sunxiaojian opened a new issue, #4610: [Bug] [e2e] connector-rocketmq e2e test failed
sunxiaojian opened a new issue, #4610:
URL: https://github.com/apache/incubator-seatunnel/issues/4610
### Search before asking
- [X] I had searched in the [issues](https://github.com/apache/incubator-seatunnel/issues?q=is%3Aissue+label%3A%22bug%22) and found no similar issues.
### What happened
connector-rocketmq e2e test failed
### SeaTunnel Version
2.3.1-SNAPSHOT
### SeaTunnel Config
```conf
env {
execution.parallelism = 1
job.mode = "BATCH"
#spark config
spark.app.name = "SeaTunnel"
spark.executor.instances = 1
spark.executor.cores = 1
spark.executor.memory = "1g"
spark.master = local
}
source {
FakeSource {
row.num = 10
map.size = 10
array.size = 10
bytes.length = 10
string.length = 10
schema = {
fields {
c_map = "map<string, smallint>"
c_array = "array<int>"
c_string = string
c_boolean = boolean
c_tinyint = tinyint
c_smallint = smallint
c_int = int
c_bigint = bigint
c_float = float
c_double = double
c_decimal = "decimal(30, 8)"
c_null = "null"
c_bytes = bytes
c_date = date
c_timestamp = timestamp
}
}
}
}
transform {
}
sink {
Rocketmq {
name.srv.addr = "rocketmq-e2e:9876"
topic = "test_topic"
partition.key.fields = ["c_map","c_string"]
producer.send.sync = true
}
}
```
### Running Command
```shell
无
```
### Error Exception
```log
related https://github.com/apache/incubator-seatunnel/pull/4583
```
### Flink or Spark Version
_No response_
### Java or Scala Version
_No response_
### Screenshots
_No response_
### Are you willing to submit PR?
- [X] Yes I am willing to submit a PR!
### Code of Conduct
- [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@seatunnel.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [incubator-seatunnel] hailin0 closed issue #4610: [Bug] [e2e] connector-rocketmq e2e test failed
Posted by "hailin0 (via GitHub)" <gi...@apache.org>.
hailin0 closed issue #4610: [Bug] [e2e] connector-rocketmq e2e test failed
URL: https://github.com/apache/incubator-seatunnel/issues/4610
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@seatunnel.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org