You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by pm...@apache.org on 2019/10/23 00:56:01 UTC
[samza] branch master updated (a50a62f -> 9a9b7d7)
This is an automated email from the ASF dual-hosted git repository.
pmaheshwari pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/samza.git.
from a50a62f Moving writeMetadataFile() invocation to ContainerLaunchUtil from LocalContainerRunner (#1198)
add 9a9b7d7 SAMZA-2356: [Transactional State] Do not trim changelog if time since last checkpoint is greater than min.compaction.lag. (#1196)
No new revisions were added by this update.
Summary of changes:
.../org/apache/samza/checkpoint/CheckpointId.java | 82 +++++++
.../checkpoint/CheckpointedChangelogOffset.java | 82 +++++++
.../org/apache/samza/storage/StorageEngine.java | 5 +-
.../org/apache/samza/storage/kv/KeyValueStore.java | 5 +-
.../java/org/apache/samza/config/TaskConfig.java | 8 +-
.../operators/util/InternalInMemoryStore.java | 3 +-
.../TransactionalStateTaskRestoreManager.java | 62 ++++--
.../org/apache/samza/container/TaskInstance.scala | 23 +-
.../NonTransactionalStateTaskStorageManager.scala | 8 +-
.../apache/samza/storage/TaskStorageManager.scala | 5 +-
.../TransactionalStateTaskStorageManager.scala | 12 +-
.../operators/impl/store/TestInMemoryStore.java | 4 +-
.../apache/samza/storage/MockStorageEngine.java | 3 +-
.../TestTransactionalStateTaskRestoreManager.java | 241 +++++++++++++++++++--
.../apache/samza/container/TestTaskInstance.scala | 22 +-
.../samza/storage/TestContainerStorageManager.java | 2 +-
.../TestTransactionalStateTaskStorageManager.java | 20 +-
.../kv/inmemory/InMemoryKeyValueStore.scala | 4 +-
.../samza/storage/kv/RocksDbKeyValueStore.scala | 12 +-
.../samza/storage/kv/LargeMessageSafeStore.java | 3 +-
.../samza/storage/kv/AccessLoggedStore.scala | 3 +-
.../org/apache/samza/storage/kv/CachedStore.scala | 5 +-
.../samza/storage/kv/KeyValueStorageEngine.scala | 4 +-
.../org/apache/samza/storage/kv/LoggedStore.scala | 3 +-
.../samza/storage/kv/NullSafeKeyValueStore.scala | 4 +-
.../samza/storage/kv/SerializedKeyValueStore.scala | 4 +-
.../samza/storage/kv/MockKeyValueStore.scala | 4 +-
.../kv/TransactionalStateIntegrationTest.java | 2 +-
...ransactionalStateMultiStoreIntegrationTest.java | 2 +-
29 files changed, 528 insertions(+), 109 deletions(-)
create mode 100644 samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointId.java
create mode 100644 samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointedChangelogOffset.java