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.

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

SAMZA-2784: Remove excessive commit logs #1695

Merged
merged 1 commit into from
Jan 20, 2024
Merged

Conversation

dxichen
Copy link
Member

@dxichen dxichen commented Jan 19, 2024

Currently we have noisy per commit logs that trigger each task.commit.ms which clogs up the users logs

2024-01-12 21:59:37.322 [Samza Task Commit Thread-46] TaskInstance [INFO] Cleaning up old checkpoint state for taskName: SystemStreamPartition [brooklin-profile-samza-euler-index-builder, profile-samza-euler-index-builder, 907] checkpointId: 1705096777263-770646
2024-01-12 21:59:37.322 [Samza Task Commit Thread-18] TaskInstance [INFO] Cleaning up old checkpoint state for taskName: SystemStreamPartition [brooklin-profile-samza-euler-index-builder, profile-samza-euler-index-builder, 1908] checkpointId: 1705096777264-482671
2024-01-12 21:59:37.321 [Samza Task Commit Thread-7] TaskInstance [INFO] Cleaning up old checkpoint state for taskName: SystemStreamPartition [brooklin-profile-samza-euler-index-builder, profile-samza-euler-index-builder, 1663] checkpointId: 1705096777264-51973

While we originally enabled these for debugging in https://github.com/apache/samza/pull/1595/files, these are no longer required. Going forward we will enabled debug logs for these classes for specific jobs we would like to debug

@dxichen dxichen requested a review from prateekm January 19, 2024 23:24
@dxichen dxichen merged commit 93b9828 into master Jan 20, 2024
2 checks passed
@dxichen dxichen deleted the dxichen/SAMZA-2784 branch January 20, 2024 02:46
khandelwal-ayush pushed a commit to khandelwal-ayush/samza that referenced this pull request Jun 12, 2024
- SAMZA-2784: Remove excessive commit logs (apache#1695)
- SAMZA-2799: Remove worker.opts handling in shell command builder (apache#1696)
khandelwal-ayush pushed a commit to khandelwal-ayush/samza that referenced this pull request Jun 12, 2024
* SAMZA-2797: Call flush during stop from CoordinatorStreamWriter (apache#1692)

* SAMZA-2798: Populate worker.opts in environment variable only if available (apache#1693)

Description
Populate worker.opts in the environment variable only if available in the configs.

Changes
Check if worker.opts is present and then add it to environment variable

Tests
Updated unit tests

* Add MAX_BACKGROUND_JOBS config for RocksDB (apache#1694)

* SAMZA-2784: Remove excessive commit logs (apache#1695)

* SAMZA-2799: Remove worker.opts handling in shell command builder (apache#1696)

---------

Co-authored-by: ajo thomas <[email protected]>
Co-authored-by: Bharath Kumarasubramanian <[email protected]>
Co-authored-by: Shekhar Sharma <[email protected]>
Co-authored-by: Daniel Chen <[email protected]>
khandelwal-ayush pushed a commit to khandelwal-ayush/samza that referenced this pull request Jun 12, 2024
* SAMZA-2797: Call flush during stop from CoordinatorStreamWriter (apache#1692)

* SAMZA-2798: Populate worker.opts in environment variable only if available (apache#1693)

Description
Populate worker.opts in the environment variable only if available in the configs.

Changes
Check if worker.opts is present and then add it to environment variable

Tests
Updated unit tests

* Add MAX_BACKGROUND_JOBS config for RocksDB (apache#1694)

* SAMZA-2784: Remove excessive commit logs (apache#1695)

* SAMZA-2799: Remove worker.opts handling in shell command builder (apache#1696)

* Create store directory paths in CSM constructor for disk space monitor (apache#1697)

* Create store directory paths in CSM constructor to be able to monitor the disk usage of the store directories

* Fix stylecheck issues

* Refactor - init all store paths together and do not mutate the storeDirPaths. Added test

* Remove ununsed method

* Remove ununsed method

* Stylecheck, Remove ununsed import

---------

Co-authored-by: ajo thomas <[email protected]>
Co-authored-by: Bharath Kumarasubramanian <[email protected]>
Co-authored-by: Shekhar Sharma <[email protected]>
Co-authored-by: Daniel Chen <[email protected]>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

1 participant