This is an automated email from the ASF dual-hosted git repository.
cameronlee pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/samza.git.
from 4e2fa96 SAMZA-2552: Avoid logging false positive error message on
each record. (#1387)
add 188b9bb SAMZA-2551: Upgrade all modules to automatically use
checkstyle 6.11.2 (part 2: includes all modules with checkstyle currently
enabled, excluding samza-core) (#1390)
No new revisions were added by this update.
Summary of changes:
build.gradle | 3 +-
gradle.properties | 2 +-
.../org/apache/samza/metrics/SamzaHistogram.java | 2 +-
.../apache/samza/serializers/TestJsonSerdeV2.java | 12 +--
.../ExampleExpandingSystemDescriptor.java | 6 +-
.../samza/table/remote/TestTableRateLimiter.java | 8 +-
.../apache/samza/system/kinesis/KinesisConfig.java | 12 +--
.../samza/system/kinesis/KinesisSystemFactory.java | 12 +--
.../kinesis/consumer/KinesisSystemConsumer.java | 26 ++---
.../descriptors/KinesisInputDescriptor.java | 7 +-
.../descriptors/KinesisSystemDescriptor.java | 8 +-
.../metrics/KinesisSystemConsumerMetrics.java | 2 +-
.../consumer/TestKinesisRecordProcessor.java | 32 +++---
.../consumer/TestKinesisSystemConsumer.java | 114 ++++++++++-----------
.../samza/coordinator/AzureJobCoordinator.java | 12 +--
.../coordinator/scheduler/HeartbeatScheduler.java | 16 +--
.../scheduler/JMVersionUpgradeScheduler.java | 34 +++---
.../scheduler/LeaderBarrierCompleteScheduler.java | 44 ++++----
.../scheduler/LeaderLivenessCheckScheduler.java | 16 +--
.../scheduler/LivenessCheckScheduler.java | 38 +++----
.../coordinator/scheduler/RenewLeaseScheduler.java | 18 ++--
.../system/azureblob/avro/AzureBlobAvroWriter.java | 14 +--
.../azureblob/avro/AzureBlobOutputStream.java | 18 ++--
.../producer/AzureBlobSystemProducer.java | 54 +++++-----
.../samza/system/eventhub/EventHubConfig.java | 8 +-
.../system/eventhub/admin/EventHubSystemAdmin.java | 18 ++--
.../eventhub/consumer/EventHubSystemConsumer.java | 46 ++++-----
.../eventhub/producer/AsyncSystemProducer.java | 30 +++---
.../eventhub/producer/EventHubSystemProducer.java | 76 +++++++-------
.../azureblob/avro/TestAzureBlobAvroWriter.java | 8 +-
.../azureblob/avro/TestAzureBlobOutputStream.java | 24 ++---
.../producer/TestAzureBlobSystemProducer.java | 12 +--
.../eventhub/MockEventHubClientManagerFactory.java | 58 +++++------
.../eventhub/admin/TestEventHubSystemAdmin.java | 10 +-
.../samza/storage/kv/LargeMessageSafeStore.java | 20 ++--
.../org/apache/samza/storage/kv/LocalTable.java | 12 +--
.../samza/logging/log4j/TestStreamAppender.java | 24 ++---
.../samza/logging/log4j2/TestStreamAppender.java | 24 ++---
.../samza/example/AsyncApplicationExample.java | 24 ++---
.../apache/samza/test/framework/TestRunner.java | 32 +++---
.../kv/TestKeyValueSizeHistogramMetric.java | 40 ++++----
.../EndOfStreamIntegrationTest.java | 4 +-
.../controlmessages/WatermarkIntegrationTest.java | 4 +-
.../StreamApplicationIntegrationTest.java | 8 +-
.../test/operator/RepartitionJoinWindowApp.java | 10 +-
.../samza/test/operator/TestAsyncFlatMap.java | 16 +--
.../samza/test/processor/TestStreamProcessor.java | 8 +-
.../processor/TestZkLocalApplicationRunner.java | 40 ++++----
.../samza/test/samzasql/TestSamzaSqlEndToEnd.java | 34 +++---
.../samza/test/table/TestLocalTableEndToEnd.java | 18 ++--
.../TestLocalTableWithSideInputsEndToEnd.java | 16 +--
.../samza/test/util/ArraySystemConsumer.java | 10 +-
.../apache/samza/test/util/SimpleSystemAdmin.java | 26 ++---
53 files changed, 582 insertions(+), 588 deletions(-)
