Skip to content

refactor: replace writer cache with Caffeine - #58

Open
vovapraded wants to merge 3 commits into
mainfrom
issue-44-caffeine-cache
Open

refactor: replace writer cache with Caffeine#58
vovapraded wants to merge 3 commits into
mainfrom
issue-44-caffeine-cache

Conversation

@vovapraded

@vovapraded vovapraded commented Aug 26, 2026

Copy link
Copy Markdown
Collaborator

Summary

  • replace TemporalCache with an internal Caffeine-backed writer cache and writer-aware TTL cleanup
  • serialize acquire and cleanup per key, retain busy writers, and retry failed closes
  • stop cleanup before pool shutdown and remove the obsolete TemporalCache API
  • add deterministic expiration, close-failure, concurrency, and long-commit coverage

Testing

  • ./gradlew :flink-connector-ytsaurus:test (198 tests, 2 skipped)
  • ./gradlew shadowJar

Closes #44

Keep conditional writer cleanup so entries with uncommitted data are retained, and preserve the deprecated TemporalCache API for compatibility.
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.

Replace TemporalCache with Caffeine cache

1 participant