streamnative/pulsar-flink

Issues

• verify if OAuth works on 1.14 branch

  #617 opened 2 years ago by imaffe
  0

• [BUG]Flink connects pulsar ,that offtens responses PulsarAdminException HTTP 502 Bad Gateway

  #616 opened 2 years ago by Zhearts
  1

• [protobuf] infinite recursive call in protobuf-native parser

  #614 opened 2 years ago by imaffe
  3

• [BUG] Set pulsar event time when it exceed zero.

  #537 opened 3 years ago by syhily
  1

• [BUG] Question about Flink Event-time support.

  #615 opened 2 years ago by moweonlee
  0

• [QUESTION] How does this project relate to apache pulsar flink connector

  #598 opened 2 years ago by nikolasten
  1

• [FEATURE] 基于keyshare模式的简单使用

  #612 opened 2 years ago by HYBG-1126
  0

• [BUG] {"errorMsg":"org.apache.pulsar.transaction.common.exception.TransactionConflictException

  #611 opened 2 years ago by HYBG-1126
  0

• [BUG][FLINK-26980] PulsarUnorderedSourceReaderTest hang on azure

  #570 opened 2 years ago by syhily
  0

• Expose metrics/profiling in docker

  #567 opened 2 years ago by imaffe
  1

• [BUG] Cumulative Acknowledgement is not happening in the flink-connector-pulsar

  #610 opened 2 years ago by anoop-khandelwal
  0

• [BUG] Flink pulsar source upgrade from 1.13.1.4 to 1.13.6.2 fails

  #608 opened 3 years ago by nikolasten
  1

• [FEATURE] Allow USE_LATEST_WHEN_TOO_LARGE_CURSOR

  #607 opened 3 years ago by nlu90
  0

• [BUG] Exception when running Flink SQL Client

  #536 opened 3 years ago by mhaseebmlk
  5

• Upgrade pulsar-flink pulsar version to 2.10.0

  #569 opened 3 years ago by imaffe
  0

• [FEATURE] Support auto failover in Flink connector

  #606 opened 3 years ago by Lucent-Wong
  0

• Merge pulsar-flink docker build process with sql-gateway image build process

  #568 opened 3 years ago by imaffe
  0

• Json Format stores Timestamp as long but schema will be translated to Row<> type.

  #566 opened 3 years ago by imaffe
  1

• [FEATURE] Make a Flink 1.14 release branch

  #508 opened 3 years ago by nlu90
  0

• [QUESTION] Disable flink schema upload operation

  #535 opened 3 years ago by nikolasten
  2

• [DOC] Catalog config and DDL properties in README doc is out of date

  #544 opened 3 years ago by asagjj
  1

• [BUG]pulsar-flink catalog options

  #539 opened 3 years ago by bingfeng2004
  1

• [BUG] Pulsar client issue causing unacknowledged messages.

  #552 opened 3 years ago by mattisonchao
  1

• Invalid short topic name 'default_database/my_topic', it should be in the format of <tenant>/<namespace>/<topic> or <topic>

  #528 opened 3 years ago by armandxu
  1

• [BUG] NPE when extractTopicName() for pulsar native tables (table not created using CREATE by user)

  #480 opened 3 years ago by imaffe
  0

• [BUG] Cannot pass Pulsar Producer Properties

  #500 opened 3 years ago by BramVanImpeAc
  2

• [BUG] ClassNotFoundException when running sql connector jar with sql client

  #486 opened 3 years ago by imaffe
  0

• [BUG] AvroSchema is actually not supported and should be moved from documentation

  #506 opened 3 years ago by imaffe
  0

• [BUG] producedDataType assigned twice

  #505 opened 3 years ago by imaffe
  0

• [Doc] Write documentation for new Pulsar Sink

  #503 opened 3 years ago by imaffe
  0

• Complete Pulsar Sink Unit tests

  #502 opened 3 years ago by syhily
  0

• [Feature] Create Metric monitors in Pulsar Sink

  #501 opened 3 years ago by imaffe
  0

• [BUG] if isCheckpointingEnabled =false ，offset commit will not get a chance to trigger

  #496 opened 3 years ago by holmes07
  1

• [BUG] sink close blocking

  #498 opened 3 years ago by mmaxiaolei
  0

• [Enhancement] Decide whether to clean the commented code

  #484 opened 3 years ago by imaffe
  0

• [BUG] Message can not consume from latest offset of specified subscription

  #494 opened 3 years ago by KevinyhZou
  0

• [BUG] schema incompatible while use `PulsarPrimitiveSchema(String.class)` to consume pulsar topic

  #493 opened 3 years ago by KevinyhZou
  0

• [BUG] not match primitive schema of byte array

  #491 opened 3 years ago by wuzhanpeng
  0

• [BUG] Using sql does not create the expected Topic

  #478 opened 3 years ago by jianyun8023
  6

• [BUG] Multiple Topics should be supported in validateTopic() in new catalog design

  #487 opened 3 years ago by imaffe
  0

• [Enhancement][Doc] doc should inform user to use shaded jar with sql client

  #488 opened 3 years ago by imaffe
  1

• [BUG] Delay messages are not supported for the flink pulsar

  #470 opened 3 years ago by kukuzidian
  1

• [BUG] Test failure for FlinkPulsarTableITest#testStructTypesInAvro with json schema

  #475 opened 3 years ago by mmaxiaolei
  0

• SQL supports pulsar client configuration

  #472 opened 3 years ago by gaozhangmin
  0

• [BUG] Flink 1.13 SQL-Client java.lang.NoSuchMethodError

  #471 opened 3 years ago by SwimSweet
  2

• [BUG] Test failure for UpsertPulsarTableITCase#testAggregate

  #468 opened 3 years ago by syhily
  2

• [BUG] [PULSAR-12693] 1.13 FlinkPulsarSink couldn't complete checkpoint when kill one of the Pulsar Cluster using kill -9

  #465 opened 3 years ago by imaffe
  0

• [FEATURE] Support start consume from timestamp in flink sql job

  #463 opened 3 years ago by KevinyhZou
  0

• [BUG] After version update from 2.7.5.3 to 2.7.6 job can't restore from its checkpoint

  #460 opened 3 years ago by mrbazzik
  4

• [Feature] Support Pulsar message deduplication on Pulsar sink

  #459 opened 3 years ago by syhily
  0