Commits

Commits on Aug 6, 2024

[FLINK-35974 ][e2e] Use docker compose v2 for E2E tests

PatrickRen
authored and
reswqa
committedAug 6, 2024

Commits on Jun 26, 2023

[FLINK-32392 ][ci] Invalidate Maven repo cache on Azure every year to reduce its disk usage
PatrickRen
committedJun 26, 2023

Commits on Mar 24, 2023

[FLINK-31567 ][release] Add 1.17 to previous docs list (#22261 )
PatrickRen
committedMar 24, 2023

Commits on Mar 23, 2023

Commits on Feb 9, 2023

[FLINK-30972 ][e2e] Update libssl download link
PatrickRen
committedFeb 9, 2023

Commits on Feb 3, 2023

[FLINK-29427 ][table] Let reload task to always use user code classloader in full caching
PatrickRen
committedFeb 3, 2023

Commits on Oct 20, 2022

[FLINK-29567 ][connector/common] Change numRecordsSend / numBytesSend / numRecordsSendError back to numRecordsOut / numBytesOut / numRecordsOutError in sink
PatrickRen
committedOct 20, 2022

Commits on Sep 23, 2022

Commits on Sep 13, 2022

[FLINK-28975 ][connector/base] Add IdlenessManager for main and per-split output in source operator to mark idleness only if both outputs are idle
PatrickRen
committedSep 13, 2022

Commits on Sep 9, 2022

[FLINK-29153 ][connector/kafka] Retry KafkaConsumer#commitAsync on WakeupException in KafkaConsumerThread
PatrickRen
committedSep 9, 2022

Commits on Aug 9, 2022

Commits on Aug 8, 2022

[FLINK-28420 ][table] Support partial caching in sync and async lookup runner
PatrickRen
committedAug 8, 2022

Commits on Aug 3, 2022

Commits on Jul 27, 2022

[FLINK-28416 ][table] Add (Async)LookupFunction and providers in replace of (Async)TableFunction as the API for lookup table (#20177 )
PatrickRen
committedJul 27, 2022

Commits on Jun 23, 2022

[FLINK-27865 ][docs] Add example for configuring SASL and SSL in Kafka DataStream and SQL connector (#19904 )
PatrickRen
committedJun 23, 2022

Commits on Jun 15, 2022

[FLINK-27762 ][connector/kafka] Catch WakeupException and retry KafkaConsumer invocations in split assignment
PatrickRen
committedJun 15, 2022

Commits on Jun 14, 2022

[FLINK-27041 ][connector/kafka] Catch IllegalStateException in KafkaPartitionSplitReader.fetch() to handle no valid partition case
PatrickRen
committedJun 14, 2022

Commits on Mar 31, 2022

[FLINK-26928 ][connector/kafka] Remove unnecessary docker network creation in tests and close network on shutdown()
PatrickRen
committedMar 31, 2022

Commits on Mar 15, 2022

[FLINK-26018 ][connector/common] Create per-split output on split addition in SourceOperator

PatrickRen
authored and
AHeise
committedMar 15, 2022
[hotfix][connector/common] Fix typo of variable in SourceOperator

PatrickRen
authored and
AHeise
committedMar 15, 2022

Commits on Mar 4, 2022

[hotfix][connector/kafka] Cleanup unused helper method in KafkaTestEnvironmentImpl

PatrickRen
authored and
leonardBang
committedMar 4, 2022
[FLINK-26387 ][connector/kafka] Use multi-broker kafka cluster in broker failure tests

PatrickRen
authored and
leonardBang
committedMar 4, 2022

Commits on Feb 25, 2022

[FLINK-25249 ][connector/kafka] Use 1 broker in Kafka tests to reduce complexity of environment

PatrickRen
authored and
fapaul
committedFeb 25, 2022
[FLINK-26143 ][connector/kafka] Temporarily disable FlinkKafkaProducerITCase.testFlinkKafkaProducerFailBeforeNotify because it hangs in IDE and CI

PatrickRen
authored and
fapaul
committedFeb 25, 2022
[FLINK-25249 ][connector/kafka] Reimplement KafkaTestEnvironment with KafkaContainer

PatrickRen
authored and
fapaul
committedFeb 25, 2022

Commits on Jan 23, 2022

[FLINK-25712 ][connectors/testing-framework] Merge flink-connector-testing module to flink-connector-test-utils module

PatrickRen
authored and
leonardBang
committedJan 23, 2022
[FLINK-25287 ][formats/avro] Use connector testing framework interface for Avro format IT case

PatrickRen
authored and
leonardBang
committedJan 23, 2022
[FLINK-25287 ][connectors/pulsar] Use connector testing framework interface for Pulsar tests

PatrickRen
authored and
leonardBang
committedJan 23, 2022
[FLINK-25287 ][connectors/kafka] Use connector testing framework for Kafka tests

PatrickRen
authored and
leonardBang
committedJan 23, 2022
[FLINK-25287 ][connectors/testing-framework] Refactor connector testing framework interfaces for more scenarios

PatrickRen
authored and
leonardBang
committedJan 23, 2022