Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[FLINK-25222][tests] Remove NetworkFailureProxy used in Kafka tests #18101

Merged
merged 3 commits into from
Dec 15, 2021
Merged

[FLINK-25222][tests] Remove NetworkFailureProxy used in Kafka tests #18101

merged 3 commits into from
Dec 15, 2021

Commits on Dec 14, 2021

  1. [FLINK-25222][tests] Remove NetworkFailureProxy used in Kafka tests 

    We suspect that the NetworkFailureProxy is causing constant connectivity
problems to the brokers during testing resulting in either network
timeouts or corrupted results.
Since the NetworkFailureProxy is only used for testing the deprecated
FlinkKafkaProducer/Consumer we can safely remove it because we will not
add new features to the connectors.
    Fabian Paul committed Dec 14, 2021
    Configuration menu
    Copy the full SHA
    c4c8ccb View commit details
    Browse the repository at this point in the history

  2. [hotfix][tests] Close Kafka AdminClients to prevent resource leaks

    Fabian Paul committed Dec 14, 2021
    Configuration menu
    Copy the full SHA
    efbcb5c View commit details
    Browse the repository at this point in the history

  3. [hotfix][tests] Await broker shutdown during KafkaTestEnvironmentImpl… 

    …#shutdown
    Fabian Paul committed Dec 14, 2021
    Configuration menu
    Copy the full SHA
    60e9a62 View commit details
    Browse the repository at this point in the history