This is an automated email from the ASF dual-hosted git repository.
lhaiesp pushed a change to branch 1.3.1
in repository https://gitbox.apache.org/repos/asf/samza.git.
from a02c8c4 SAMZA-2423: Heartbeat failure causes incorrect container
shutdown (#1240)
new 7d90cc2 Clean up unused org.apache.samza.autoscaling module (#1250)
new 3c2863c Fix the coordinator stream creation workflow.
new e250678 SAMZA-2431: Fix the checkpoint and changelog topic
auto-creation. (#1251)
new cccca7c Fix the RocksDB TTL type conversion in change log properties
generation. (#1254)
new 964252a SAMZA-2446: Invoke onCheckpoint only for registered SSPs
(#1260)
new 17be867 SAMZA-2447: Checkpoint dir removal should only search in
valid store dirs (#1261)
The 6 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
build.gradle | 40 ---
.../java/org/apache/samza/system/StreamSpec.java | 4 +-
.../samza/autoscaling/deployer/ConfigManager.java | 376 ---------------------
.../apache/samza/autoscaling/utils/YarnUtil.java | 158 ---------
.../samza/autoscaling/utils/YarnUtilTest.java | 38 ---
.../resources/exampleResourceManagerOutput.json | 121 -------
.../apache/samza/checkpoint/OffsetManager.scala | 17 +-
.../TransactionalStateTaskStorageManager.scala | 12 +-
.../samza/checkpoint/TestOffsetManager.scala | 10 +-
.../TestTransactionalStateTaskStorageManager.java | 27 ++
.../samza/system/kafka/KafkaSystemAdmin.java | 17 +-
.../org/apache/samza/config/KafkaConfig.scala | 6 +-
.../system/kafka/TestKafkaSystemAdminJava.java | 65 ++++
.../org/apache/samza/config/TestKafkaConfig.scala | 65 +++-
samza-shell/src/main/bash/run-config-manager.sh | 25 --
settings.gradle | 1 -
sonar-project.properties | 2 +-
17 files changed, 200 insertions(+), 784 deletions(-)
delete mode 100644
samza-autoscaling/src/main/java/org/apache/samza/autoscaling/deployer/ConfigManager.java
delete mode 100644
samza-autoscaling/src/main/java/org/apache/samza/autoscaling/utils/YarnUtil.java
delete mode 100644
samza-autoscaling/src/test/java/org/apache/samza/autoscaling/utils/YarnUtilTest.java
delete mode 100644
samza-autoscaling/src/test/resources/exampleResourceManagerOutput.json
delete mode 100755 samza-shell/src/main/bash/run-config-manager.sh
