This is an automated email from the ASF dual-hosted git repository.
bharathkk pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/samza.git.
from fb20518 Merge pull request #1233 from atoomula/schema_fix
add 0436528 SAMZA-2305: Stream processor should ensure previous container
is stopped during a rebalance (#1213)
No new revisions were added by this update.
Summary of changes:
.../org/apache/samza/storage/StorageEngine.java | 6 +-
.../apache/samza/processor/StreamProcessor.java | 72 ++++++++++++++++------
.../NonTransactionalStateTaskRestoreManager.java | 2 +-
.../org/apache/samza/storage/StorageRecovery.java | 9 ++-
.../apache/samza/storage/TaskRestoreManager.java | 11 +++-
.../TransactionalStateTaskRestoreManager.java | 2 +-
.../apache/samza/container/SamzaContainer.scala | 22 ++++++-
.../samza/storage/ContainerStorageManager.java | 60 ++++++++++++------
.../org/apache/samza/system/SystemConsumers.scala | 21 ++++++-
.../org/apache/samza/system/SystemProducers.scala | 17 ++++-
.../samza/processor/TestStreamProcessor.java | 62 ++++++++++++++++++-
.../samza/container/TestSamzaContainer.scala | 42 +++++++++++++
.../samza/storage/TestContainerStorageManager.java | 4 +-
.../samza/storage/kv/KeyValueStorageEngine.scala | 7 ++-
.../storage/kv/TestKeyValueStorageEngine.scala | 48 +++++++++++++++
15 files changed, 332 insertions(+), 53 deletions(-)
