Skip to content

KAFKA-9409: Supplement immutability of ClusterConfigState class in Connect#7942

Merged
kkonstantine merged 1 commit intoapache:trunkfrom
belugabehr:KAFKA-9409
May 21, 2020
Merged

KAFKA-9409: Supplement immutability of ClusterConfigState class in Connect#7942
kkonstantine merged 1 commit intoapache:trunkfrom
belugabehr:KAFKA-9409

Conversation

@belugabehr
Copy link
Copy Markdown
Contributor

@belugabehr belugabehr commented Jan 12, 2020

The class claims to be immutable, but there are some mutable features of this class.
Increase the immutability of it and add a little cleanup:

  • Pre-initialize size of ArrayList
  • Remove superfluous syntax
  • Use ArrayList instead of LinkedList since the list is created once

Committer Checklist (excluded from commit message)

  • Verify design and implementation
  • Verify test coverage and CI build status
  • Verify documentation (including upgrade notes)

Copy link
Copy Markdown
Contributor

@rondagostino rondagostino left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

@kkonstantine
Copy link
Copy Markdown
Contributor

ok to test

@kkonstantine
Copy link
Copy Markdown
Contributor

jdk8: 1 flaky failure: EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta[true]
jdk11: didn't start
jdk14: success

Copy link
Copy Markdown
Contributor

@kkonstantine kkonstantine left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

@kkonstantine kkonstantine changed the title KAFKA-9409: Increase Immutability of ClusterConfigState KAFKA-9409: Supplement immutability of ClusterConfigState class in Connect May 21, 2020
@kkonstantine kkonstantine merged commit 59efa12 into apache:trunk May 21, 2020
Kvicii pushed a commit to Kvicii/kafka that referenced this pull request May 22, 2020
* 'trunk' of github.com:apache/kafka:
  KAFKA-9980: Fix bug where alterClientQuotas could not set default client quotas (apache#8658)
  KAFKA-9780: Deprecate commit records without record metadata (apache#8379)
  MINOR: Deploy VerifiableClient in constructor to avoid test timeouts (apache#8651)
  MINOR: Added unit tests for ConnectionQuotas (apache#8650)
  MINOR: Correct MirrorMaker2 integration test configs for Connect internal topics (apache#8653)
  KAFKA-9855 - return cached Structs for Schemas with no fields (apache#8472)
  KAFKA-9950: Construct new ConfigDef for MirrorTaskConfig before defining new properties (apache#8608)
  KAFKA-8869: Remove task configs for deleted connectors from config snapshot (apache#8444)
  KAFKA-9409: Supplement immutability of ClusterConfigState class in Connect (apache#7942)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants