kevinyhzou

Results 24 issues of kevinyhzou

bug fix for topic offset not auto commit in flink job while disable flink checkpoint.

#494 bug fix cannot consume latest message of specified subscription

**Describe the bug** I want to consume a pulsar topic from latest offset of a subcription, and I try to use the code below ``` FlinkPulsarSource flinkPulsarSource = new FlinkPulsarSource(...

type/bug

**Describe the bug** I use FlinkPulsarSource consume a pulsar topic, the code as below ``` FlinkPulsarSource flinkPulsarSource = new FlinkPulsarSource( serviceUrl, adminUrl, new PulsarPrimitiveSchema(String.class), properties).setStartFromSubscription(groupid_antisdk, MessageId.latest); ``` while submit the...

type/bug

**Describe the bug** generate the parquet table file by use tpch-dbgen: https://github.com/databricks/tpch-dbgen then convert the parquet file to dwrf format by use the tpch_convert_parquet_dwrf.sh script, and submit the spark job...

bug

## What changes were proposed in this pull request? bug fix for convert parquet to dwrf memory double free error as describe in #349 ## How was this patch tested?...

## What changes were proposed in this pull request? (Please fill in changes proposed in this fix) (Fixes: \#5208) ## How was this patch tested? (Please explain how this patch...

### Backend CH (ClickHouse) ### Bug description HiveText format file read diff from spark 1. when the hive text file first line has different number of fields from the table...

bug
triage

## What changes were proposed in this pull request? (Please fill in changes proposed in this fix) (Fixes: \#5196) Fix comments mentioned in pr: https://github.com/apache/incubator-gluten/pull/5100 ## How was this patch...

### Description The regexp_extract has some code-style problem and some suitation maybe lack of consideration

enhancement