flink-connector-pulsar icon indicating copy to clipboard operation
flink-connector-pulsar copied to clipboard

[FLINK-35141][Connectors/Pulsar] Update flink-connector-pulsar v4.2.0 for Flink 1.19

Open thinker0 opened this issue 1 year ago • 3 comments

Purpose of the change

  • Update flink-connector-puslar for flink-1.19
  • https://issues.apache.org/jira/browse/FLINK-35141
  • #92

Brief change log

  • Change API of SourceConfiguration.
  • Fix compile error in PulsarWriterTest.
  • Fix compile error in PulsarTableTestUtils.

Verifying this change

Please make sure both new and modified tests in this PR follows the conventions defined in our code quality guide: https://flink.apache.org/contributing/code-style-and-quality-common.html#testing

(Please pick either of the following options)

This change is a trivial rework / code cleanup without any test coverage.

(or)

This change is already covered by existing tests, such as (please describe tests).

(or)

This change added tests and can be verified as follows:

(example:)

  • Added unit tests
  • Added integration tests for end-to-end deployment
  • Manually verified by running the Pulsar connector on a local Flink cluster.

Significant changes

(Please check any boxes [x] if the answer is "yes". You can first publish the PR and check them afterwards, for convenience.)

  • [x] Dependencies have been added or upgraded
  • [ ] Public API has been changed (Public API is any class annotated with @Public(Evolving))
  • [ ] Serializers have been changed
  • [ ] New feature has been introduced
    • If yes, how is this documented? (not applicable / docs / JavaDocs / not documented)

thinker0 avatar Jun 13 '24 07:06 thinker0

Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)

boring-cyborg[bot] avatar Jun 13 '24 07:06 boring-cyborg[bot]

Hi, @thinker0 Politely consult that is it any plan about continue this pr.

lvyanquan avatar Oct 31 '24 12:10 lvyanquan

@lvyanquan It works with mvn test, but not with git test, I don't know why.

thinker0 avatar Feb 03 '25 13:02 thinker0