skyoct
skyoct
First of all, thank you for developing benthos for our use My usage scenario is to synchronize Kafka data to HDFS so that hive can use it. Each hive table...
hello I read the code related to batcher and found that it seems to be single thread processing. Is there any way to make this conversion parquet file faster. https://github.com/benthosdev/benthos/blob/811c58786a46085861a828f7fd606e659f872253/internal/component/output/batcher/batcher.go#L63-L156...
Hello When I set the quantity of each batch to 2W, Container memory usage approx. 8g. Here are some configurations ``` input: kafka: xxxx output: minio: xxxx buffer: memory: limit:...
This component is about cos, an object storage service provided by Tencent cloud.
spark 查询过滤string条件报错 ```Required field 'uncompressed_page_size' was not found in serialized data``` 推测是spark开启谓词下推时候需要用的该字段,请问parquet-go中是否写这个相关信息?
Hello, I see in the document that the request is marked as deprecated. This component is being used in our project. What is the main reason for deprecated.
Hello, I want to actively close the program inside the program when the program execution meets certain conditions. Is there any good method?
## Purpose of this pull request GoogleSheets source #3018 ## Check list * [x] Code changed are covered with tests, or it does not need tests for reason: third party...
## Purpose of this pull request Unified type case ## Check list * [ ] Code changed are covered with tests, or it does not need tests for reason: *...
### Search before asking - [X] I had searched in the [feature](https://github.com/apache/incubator-seatunnel/issues?q=is%3Aissue+label%3A%22Feature%22) and found no similar feature requirement. ### Description # Why At present, the support of each component for...