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.
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
feat: add config for suppress buffer #5969
Conversation
It looks like @nae701 hasn't signed our Contributor License Agreement, yet.
You can read and sign our full Contributor License Agreement here. Once you've signed reply with Appreciation of efforts, clabot |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM with the usual army of nits
ksqldb-common/src/main/java/io/confluent/ksql/util/KsqlConfig.java
Outdated
Show resolved
Hide resolved
ksqldb-engine/src/main/java/io/confluent/ksql/planner/LogicalPlanner.java
Outdated
Show resolved
Hide resolved
ksqldb-engine/src/test/java/io/confluent/ksql/planner/LogicalPlannerTest.java
Outdated
Show resolved
Hide resolved
ksqldb-engine/src/test/java/io/confluent/ksql/planner/LogicalPlannerTest.java
Show resolved
Hide resolved
ksqldb-streams/src/main/java/io/confluent/ksql/execution/streams/TableSuppressBuilder.java
Outdated
Show resolved
Hide resolved
ksqldb-streams/src/main/java/io/confluent/ksql/execution/streams/TableSuppressBuilder.java
Outdated
Show resolved
Hide resolved
* fix: add config to disable suppress andbound buffer size * fix: add suppress feature flag and buffer configs * fix: fix checkstyle * fix: fix checstyle violation * fix: address feedback * fix: add commmit suggestions * fix: import order * test: fix tablesuppressbuilder test * test: fix logical planner test
Description
What behavior do you want to change, why, how does your patch achieve the changes?
Adding configs to enable/disable suppress as well as to bound suppress buffer size
Testing done
Describe the testing strategy. Unit and integration tests are expected for any behavior changes.
Unit tests and qtts have been added
Reviewer checklist