skyoct

Results 28 issues of 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...

enhancement
cool idea

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...

question

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:...

question

This component is about cos, an object storage service provided by Tencent cloud.

enhancement
inputs
outputs

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.

question
processors
needs more info

Hello, I want to actively close the program inside the program when the program execution meets certain conditions. Is there any good method?

question
plugin api
needs more info

## 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...

First-time contributor
connectors-v2

## 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...