Skip to content
This repository has been archived by the owner on Dec 14, 2022. It is now read-only.

Issues: streamnative/pulsar-flink

When will Flink 1.14.0 be supported?
#455 by cleverblue was closed Nov 11, 2021
Closed 3
Clear current search query, filters, and sorts
52 Open 199 Closed
52 Open 199 Closed
Author
Filter by author
Loading
Label
Filter by label
Loading
Use alt + click/return to exclude labels
or ⇧ + click/return for logical OR
Projects
Filter by project
Loading
Milestones
Filter by milestone
Loading
Assignee
Filter by who’s assigned
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Issues list

[FEATURE] It would be good to have a way to emit Pulsar source and sink configuration property values to logs compute/data-processing type/feature Indicates new functionality
#335 opened May 20, 2021 by subbu107
1
@syhily
👍 1
[Feature] Support for exposing key and event_time columns when reading data from pulsar compute/data-processing type/enhancement Indicates an improvement to an existing feature
#447 opened Oct 27, 2021 by nlu90
👍 1
[Documentation] Documentation for the PulsarDeserializationSchema compute/data-processing type/documentation
#244 opened Jan 22, 2021 by rec7y33
@jianyun8023
3
[BUG] FlinkPulsarSource parallelism change compute/data-processing type/bug
#248 opened Jan 26, 2021 by aryemazouz
@jianyun8023
1
[BUG] OOM occurs when a new task is submitted after the pulsar connector is closed compute/data-processing type/bug
#267 opened Mar 16, 2021 by jianyun8023
@jianyun8023
3
[FEATURE] Flink 1.11 add support upsert-pulsar compute/data-processing type/feature Indicates new functionality
#303 opened Apr 25, 2021 by Coder-WangXiang
@jianyun8023
3
[FEATURE] Add the ability to read multiple types of messages from the same topic compute/data-processing type/feature Indicates new functionality
#307 opened Apr 28, 2021 by kirill-kosenko
1
[BUG] Failure to write to topic causes checkpoint to be declined, and all subsequent checkpoints are aborted. compute/data-processing type/bug
#324 opened May 11, 2021 by subbu107
1
[BUG] NoClassDefFoundError and NPE when using PulsarDeserializer to deserialize messages in avro to flink row compute/data-processing type/bug
#326 opened May 13, 2021 by longtengz
5
[Feature] Support compacted topics with tomb-stone messages compute/data-processing type/feature Indicates new functionality
#337 opened May 25, 2021 by vanmeete
@syhily
2
Does FlinkPulsarSource support multiple thread to consume one topic? compute/data-processing type/question
#356 opened Jun 15, 2021 by Johnnyhooyo
@jianyun8023
6
Ingress/Egress for Flink stateful functions compute/data-processing Epic type/feature Indicates new functionality
#375 opened Jul 15, 2021 by omidb
3
[Task] Add test case for backup & restore the connector state compute/data-processing type/task Indicates a chore or a small item of work
#103 opened Jun 30, 2020 by sijie
[FEATURE]: Configure CryptoKeyReader in FlinkPulsarSource and FlinkPulsarSink compute/data-processing type/feature Indicates new functionality
#386 opened Aug 8, 2021 by objecttrouve
@syhily
4
[BUG] A topic created by the pulsar-flink connector is always created as a partitioned topic with 1 partition compute/data-processing type/bug
#398 opened Aug 23, 2021 by mathieudruart
@jianyun8023
6
Documentation Regarding the PulsarSerializationSchema in compute/data-processing type/documentation
#404 opened Sep 4, 2021 by lonerzzz
@jianyun8023
1
PulsarSerializationSchema and parent code documentation issue erroneous and confusing compute/data-processing type/bug
#405 opened Sep 6, 2021 by lonerzzz
@jianyun8023
[BUG] Fail to Insert into an upsert table compute/data-processing type/bug
#412 opened Sep 10, 2021 by nlu90
@jianyun8023
2
[BUG] DOC-BUG properties.pulsar.reader config format should Use "-" instead of dots or camel case compute/data-processing type/bug
#414 opened Sep 10, 2021 by Aaronzk
@syhily
1
[BUG] FlinkPulsarSink does not support schema evolution into schema registry compute/data-processing type/bug
#418 opened Sep 28, 2021 by ghost
@syhily
2
[BUG] Pulsar Properties is not handled correctly when creating sink compute/data-processing type/bug
#419 opened Sep 30, 2021 by nlu90
@syhily
1
[BUG] Flink SQL cannot use UpsertPulsar compute/data-processing type/bug
#420 opened Sep 30, 2021 by nlu90
[BUG] Property values for the FlinkPulsarSink and FlinkPulsarSource are not documented or handled gracefully compute/data-processing type/bug
#421 opened Oct 2, 2021 by lonerzzz
[BUG]Flink connects pulsar ,that offtens responses PulsarAdminException HTTP 502 Bad Gateway type/bug
#616 opened Nov 3, 2022 by Zhearts
1
[BUG] pulsar debezium-json format will produce 2 rowdata update_before and update_after, but only update_after compute/data-processing type/bug
#381 opened Aug 3, 2021 by haormj
ProTip! Follow long discussions with comments:>50.