Commits

Branch selector

 master

User selector

syhily

Datepicker

All time

Commit History

Commits on Nov 11, 2022

• [FLINK-26027][Connector/Pulsar] Expose Pulsar producer metrics and add FLIP-33 sink metrics. (apache#21249)

  syhily

  authored
  9c970b9

• [FLINK-29830][Connector/Pulsar] Create the topic with schema before consuming messages in PulsarSinkITCase. (apache#21252)

  syhily

  authored
  f8b3b33

Commits on Nov 8, 2022

• [FLINK-28083][Connector/Pulsar] PulsarSource work with object-reusing DeserializationSchema. (apache#21205)

  syhily

  authored
  27d42b2

Commits on Nov 7, 2022

• [FLINK-29709][Connector/Pulsar] Bump the Pulsar to latest 2.10.2 (apache#21204)

  syhily

  authored
  b5a4d48

Commits on Oct 18, 2022

• [FLINK-28820][Connector/Pulsar] Improve the writing performance for PulsarSink (apache#21074)

  syhily

  authored
  3f863b1

• [FLINK-29613][Connector/Pulsar] Fix wrong batch size assertion. (apache#21069)

  syhily

  authored
  8cb0297

• [FLINK-28085][Connector/Pulsar] Close the pending Pulsar transactions before closing pipeline (apache#21075)

  syhily

  authored
  713b0b1

• [FLINK-28960][Connector/Pulsar] Add jaxb-api back to pulsar-client-all dependencies. (apache#21072)

  syhily

  authored
  40cfdda

• [FLINK-29433][Connector/Pulsar] Support Auth through the builder pattern in Pulsar connector. (apache#21071)

  syhily

  authored
  25c4297

• [FLINK-29580][Connector/Pulsar] Remove pulsar.consumer.autoUpdatePartitionsIntervalSeconds option. (apache#21070)

  syhily

  authored
  2bab5ad

Commits on Sep 30, 2022

• [FLINK-26182][Connector/pulsar] Create e2e tests for the Pulsar source and sink based on the connector testing framework.

  

  syhily

  authored and

  tisonkun

  committed
  f0fe85a

• [FLINK-29381][Connector/Pulsar] Add a document on how to use Key_Shared subscription.

  

  syhily

  authored and

  tisonkun

  committed
  8027b3c

• [FLINK-29381][Connector/Pulsar] Fixes the split assignment for Key Shared subscription.

  

  syhily

  authored and

  tisonkun

  committed
  414e6ad

• [FLINK-26182][Connector/pulsar] Extract common logic from Pulsar source testing tools.

  

  syhily

  authored and

  tisonkun

  committed
  a6edcbc

• [FLINK-26182][Connector/Pulsar] Enable the transaction in the Pulsar TestContainers in a better way.

  

  syhily

  authored and

  tisonkun

  committed
  e0d444d

• [FLINK-26182][Connector/Pulsar] Drop the embedded Pulsar runtime for in favor of mock Pulsar runtime with local metastore support.

  

  syhily

  authored and

  tisonkun

  committed
  08706c8

Commits on Sep 9, 2022

• [FLINK-28934][Connector/pulsar] Support connector testing tools for Pulsar unordered source.

  

  syhily

  authored and

  tisonkun

  committed
  290137c

• [FLINK-27400][Connector/pulsar] Filter system topics for Pulsar connector.

  

  syhily

  authored and

  tisonkun

  committed
  5a35485

• [FLINK-27611][Connector/pulsar] Fix ConcurrentModificationException during checkpoint on Pulsar unordered reader.

  

  syhily

  authored and

  tisonkun

  committed
  b614e94

• [FLINK-28084][Connector/pulsar] Disable retry and delete reconsume logic on PulsarUnorderedPartitionSplitReader.

  

  syhily

  authored and

  tisonkun

  committed
  ce0d043

• [FLINK-27388][Connector/pulsar] Change the topic setup logic in Pulsar runtime operator.

  

  syhily

  authored and

  tisonkun

  committed
  d92ef3b

• [FLINK-28934][Connector/pulsar] Fix split assignment in different Pulsar subscriptions.

  

  syhily

  authored and

  tisonkun

  committed
  b0a1241

Commits on Aug 30, 2022

• [FLINK-28609][Connector/Pulsar] PulsarSchema didn't get properly serialized. (apache#20698)

  syhily

  authored
  d9bcbff

Commits on Aug 16, 2022

• [FLINK-27917][Connector/Pulsar] Drop Consumer.seek() in the testing method for fixing the race condition. (apache#20567)

  syhily

  authored
  f7af9f6

Commits on Aug 12, 2022

• [FLINK-27399][Connector/Pulsar] Change initial consuming position setting logic for better handle the checkpoint. (apache#19972)

  Show description for 18d21a0
  syhily

  authored
  18d21a0

Commits on Jul 5, 2022

• [FLINK-27199][Connector/Pulsar] Move mocked Pulsar runtime to new local memory based metastore. Drop embedded Pulsar runtime. Add a bootstrap script for Pulsar docker runtime.

  

  syhily

  authored and

  MartijnVisser

  committed
  f629b3e

• [FLINK-27199][Connector/Pulsar] Pulsar 2.10.0 deprecated the queue length, add new memory-based options.

  

  syhily

  authored and

  MartijnVisser

  committed
  aa44fc1

• [FLINK-27199][Connector/Pulsar] Bump the pulsar-client-all to latest 2.10.0.

  

  syhily

  authored and

  MartijnVisser

  committed
  688f6ab

Commits on Jun 16, 2022

• [FLINK-27881][Connector/Pulsar] Never return null for PulsarMessageBuilder.

  

  syhily

  authored and

  zentol

  committed
  6b2a3fe

Commits on Apr 3, 2022

• [FLINK-26645][Connector/pulsar] Support subscribe only one topic partition.

  

  syhily

  authored and

  AHeise

  committed
  71a9f31

Commits on Apr 1, 2022

• [FLINK-26931][Connector/pulsar] Make the producer name and consumer name unique for each instance.

  

  syhily

  authored and

  AHeise

  committed
  4956859

Commits on Mar 15, 2022

• [FLINK-26177][Connector/pulsar] Use mocked pulsar runtime instead of embedded runtime and enable tests.

  

  syhily

  authored and

  fapaul

  committed
  1572908

Commits on Feb 21, 2022

• [FLINK-26210][pulsar][tests] Add jaxb-api to e2e test

  syhily

  authored
  967e43f

Commits on Feb 16, 2022

• [FLINK-26038][connector/pulsar] Support delay message on PulsarSink.

  

  syhily

  authored and

  fapaul

  committed
  07f23e0

• [FLINK-26026][connector/pulsar] Create unit tests for Pulsar sink connector.

  

  syhily

  authored and

  fapaul

  committed
  714dd80

Pagination

Previous

Next