[jira] [Created] (FLINK-36180) Flink pulsar connector when restoring from the state, the unconsumed messages of the first batch will be lost

Wenbing Shen created FLINK-36180: Summary: Flink pulsar connector when restoring from the state, the unconsumed messages of the first batch will be lost Key: FLINK-36180 URL: https://issues.apache.org/jira/browse/

[jira] [Created] (FLINK-35328) AutoScale supports setting the maximum floating parallelism by the number of Pulsar partitions

Wenbing Shen created FLINK-35328: Summary: AutoScale supports setting the maximum floating parallelism by the number of Pulsar partitions Key: FLINK-35328 URL: https://issues.apache.org/jira/browse/FLINK-35328

[jira] [Created] (FLINK-35196) bouncycastle class not found for flink pulsar connector

Wenbing Shen created FLINK-35196: Summary: bouncycastle class not found for flink pulsar connector Key: FLINK-35196 URL: https://issues.apache.org/jira/browse/FLINK-35196 Project: Flink Issue

[jira] [Created] (FLINK-31708) RuntimeException/KryoException thrown when deserializing an empty protobuf record

shen created FLINK-31708: Summary: RuntimeException/KryoException thrown when deserializing an empty protobuf record Key: FLINK-31708 URL: https://issues.apache.org/jira/browse/FLINK-31708 Project: Flink

[jira] [Created] (FLINK-30989) Configuration table.exec.spill-compression.block-size not take effect in batch job

shen created FLINK-30989: Summary: Configuration table.exec.spill-compression.block-size not take effect in batch job Key: FLINK-30989 URL: https://issues.apache.org/jira/browse/FLINK-30989 Project: Flink

[jira] [Created] (FLINK-30960) OutOfMemory error using jdbc sink

Bo Shen created FLINK-30960: --- Summary: OutOfMemory error using jdbc sink Key: FLINK-30960 URL: https://issues.apache.org/jira/browse/FLINK-30960 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-29347) Failed to restore from list state with empty protobuf object

shen created FLINK-29347: Summary: Failed to restore from list state with empty protobuf object Key: FLINK-29347 URL: https://issues.apache.org/jira/browse/FLINK-29347 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-29207) Pulsar message eventTime may be incorrectly set to a negative number

Wenbing Shen created FLINK-29207: Summary: Pulsar message eventTime may be incorrectly set to a negative number Key: FLINK-29207 URL: https://issues.apache.org/jira/browse/FLINK-29207 Project: Flink

[jira] [Created] (FLINK-28341) Fix comment in BytesKeyNormalizationUtil.java

shen created FLINK-28341: Summary: Fix comment in BytesKeyNormalizationUtil.java Key: FLINK-28341 URL: https://issues.apache.org/jira/browse/FLINK-28341 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-26050) Too Many small sst files in rocksdb state backend when using processing time window

shen created FLINK-26050: Summary: Too Many small sst files in rocksdb state backend when using processing time window Key: FLINK-26050 URL: https://issues.apache.org/jira/browse/FLINK-26050 Project: Flink

[jira] [Created] (FLINK-15624) Pulsar Sink

Yijie Shen created FLINK-15624: -- Summary: Pulsar Sink Key: FLINK-15624 URL: https://issues.apache.org/jira/browse/FLINK-15624 Project: Flink Issue Type: Sub-task Reporter: Yijie Shen

[jira] [Created] (FLINK-15089) Pulsar Catalog

Yijie Shen created FLINK-15089: -- Summary: Pulsar Catalog Key: FLINK-15089 URL: https://issues.apache.org/jira/browse/FLINK-15089 Project: Flink Issue Type: Sub-task Components: Connect

[jira] [Created] (FLINK-14146) Introduce Pulsar connector

Yijie Shen created FLINK-14146: -- Summary: Introduce Pulsar connector Key: FLINK-14146 URL: https://issues.apache.org/jira/browse/FLINK-14146 Project: Flink Issue Type: New Feature Re

[jira] [Created] (FLINK-10274) The stop-cluster.sh cannot stop cluster properly when there are multiple clusters running

YuFeng Shen created FLINK-10274: --- Summary: The stop-cluster.sh cannot stop cluster properly when there are multiple clusters running Key: FLINK-10274 URL: https://issues.apache.org/jira/browse/FLINK-10274

[jira] [Created] (FLINK-3976) Alias fields of physical plan node to avoid name collision with Calcite protected fields

Yijie Shen created FLINK-3976: - Summary: Alias fields of physical plan node to avoid name collision with Calcite protected fields Key: FLINK-3976 URL: https://issues.apache.org/jira/browse/FLINK-3976 Proj

[jira] [Created] (FLINK-3926) Incorrect implementation of getFieldIndex in TupleTypeInfo

Yijie Shen created FLINK-3926: - Summary: Incorrect implementation of getFieldIndex in TupleTypeInfo Key: FLINK-3926 URL: https://issues.apache.org/jira/browse/FLINK-3926 Project: Flink Issue Ty

[jira] [Created] (FLINK-3754) Add a validation phase before construct RelNode using TableAPI

Yijie Shen created FLINK-3754: - Summary: Add a validation phase before construct RelNode using TableAPI Key: FLINK-3754 URL: https://issues.apache.org/jira/browse/FLINK-3754 Project: Flink Issue

[jira] [Created] (FLINK-3736) Move toRexNode and toAggCall logic into Expressions

Yijie Shen created FLINK-3736: - Summary: Move toRexNode and toAggCall logic into Expressions Key: FLINK-3736 URL: https://issues.apache.org/jira/browse/FLINK-3736 Project: Flink Issue Type: Impro

[jira] [Created] (FLINK-3723) Aggregate Functions and scalar expressions shouldn't be mixed in select

Yijie Shen created FLINK-3723: - Summary: Aggregate Functions and scalar expressions shouldn't be mixed in select Key: FLINK-3723 URL: https://issues.apache.org/jira/browse/FLINK-3723 Project: Flink