This is an automated email from the ASF dual-hosted git repository.
kenn pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 638449b Merge pull request #7668: [BEAM-6547] Release automation: use
virtualenv; use SSH URL
new 18ead0d Roll our own more strict nullness annotation
new 4c98ceb [BEAM-5658] Re-enable findbugs in Dataflow worker
new b7424c5 [BEAM-5658] Fixes return of null where it is forbidden
new 1182c41 [BEAM-5658] Fixes null warning in StreamingDataflowWorker
new c59b086 [BEAM-5658] Fix misuse of Random in StreamingDataflowWorker
new 93ab8e9 [BEAM-5658] Remove redundant null checks in Dataflow worker
new ed3833e [BEAM-5658] Clarify risky System.exit in Dataflow worker
new 2b3eed9 [BEAM-5658] Fix accidental use of integer division in
Dataflow worker GroupingTables
new 8008095 [BEAM-5658] Remove @Nullable param that always has
checkNotNull
new 60d9347 [BEAM-5658] Suppress findbugs warning about intended
reference equality check
new c0a46ad [BEAM-5658] Use %n instead of \n in Dataflow worker
new 252a3a2 [BEAM-5658] Suppress non-serializable warnings due to
superclasses
new f1c6a62 [BEAM-5658] Clarify unreachability of null worker state in
Dataflow worker
new d964be0 Use checkArgument instead of checkNotNull for checking
argument
new f32f267 [BEAM-5658] Make some finalize methods protected
new 8b6a35c [BEAM-5658] Make mutable field merely package-public, not
public
new b015ae5 [BEAM-5658] Remove dead field from WindmillStateInternals
new 1e1387a [BEAM-5658] Eliminate needless boxing and unboxing
new e9d091d [BEAM-5658] Make constant field static
new 7f76ac8 [BEAM-5658] Separate various null checks to make more legible
new 717cc58 [BEAM-5658] Suppress probable synchronization bugs in
Dataflow worker, with Jiras filed
new c81dfba [BEAM-5658] Suppress nullability error in IsmReaderImpl to be
fixed when we can
new 6838296 [BEAM-5658] Class starts thread in constructor - make it
final so this is OK
new 326c761 [BEAM-5658] note that GroupingShuffleRangeTracker is OK with
null groupStart
new eacfb90 [BEAM-5658] remove noop equals override from
ExecutionStateTracker
new 1081b2b [BEAM-5658] Suppress and note many synchronization errors in
Dataflow worker
new fb4d1f2 [BEAM-5658] Fix erroneous cases of integer division in
Dataflow worker
new f952a64 [BEAM-5658] Fix nullability in Dataflow worker AvroByteReader
and factory
new fbfe3a6 [BEAM-5658] Fix minor code issues in Dataflow worker
new 729a29c [BEAM-5658] Fix nullability checking in Dataflow worker
new 4a49269 [BEAM-5658] Suppress warning about unread field in Dataflow
worker DebugCapture
new 12db699 Remove spammy println from
BeamModulePlugin.applyPortabilityNature
new 28aff06 Suppress warning caused by our upstream dependencies
new 0a55482 [BEAM-5658] Suppress findbugs warning about pointer-based
compareTo override
new e69d69d Merge pull request #7684: [BEAM-5658] Re-enable findbugs on
Dataflow worker
The 19862 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:
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 3 ++-
.../core/metrics/ExecutionStateTracker.java | 10 ++++----
.../google-cloud-dataflow-java/worker/build.gradle | 2 +-
.../dataflow/worker/ApplianceShuffleReader.java | 2 +-
.../dataflow/worker/ApplianceShuffleWriter.java | 2 +-
.../runners/dataflow/worker/AvroByteReader.java | 13 +++++++----
.../dataflow/worker/AvroByteReaderFactory.java | 3 +++
.../dataflow/worker/BatchDataflowWorker.java | 2 ++
.../dataflow/worker/DataflowMetricsContainer.java | 4 ++++
.../dataflow/worker/DataflowWorkUnitClient.java | 2 +-
.../dataflow/worker/FnApiWindowMappingFn.java | 12 ++++++----
.../dataflow/worker/GroupAlsoByWindowFnRunner.java | 3 ++-
.../worker/GroupingShuffleReaderFactory.java | 10 ++++++--
.../runners/dataflow/worker/IsmReaderFactory.java | 10 ++++++--
.../runners/dataflow/worker/IsmReaderImpl.java | 5 ++++
.../dataflow/worker/IsmSideInputReader.java | 3 +--
.../worker/MetricTrackingWindmillServerStub.java | 4 +++-
.../beam/runners/dataflow/worker/OrderedCode.java | 2 +-
.../worker/PartitioningShuffleReaderFactory.java | 5 ++--
.../beam/runners/dataflow/worker/PubsubReader.java | 8 ++++++-
.../dataflow/worker/ShuffleSinkFactory.java | 9 +++++++-
.../dataflow/worker/StreamingDataflowWorker.java | 15 ++++++++++--
.../dataflow/worker/UngroupedWindmillReader.java | 9 +++++++-
.../dataflow/worker/WindmillStateInternals.java | 2 --
.../dataflow/worker/WindowingWindmillReader.java | 9 +++++++-
.../dataflow/worker/WorkItemStatusClient.java | 10 +++++---
.../dataflow/worker/WorkerCustomSources.java | 2 +-
.../dataflow/worker/counters/CounterFactory.java | 2 +-
.../worker/fn/control/BeamFnMapTaskExecutor.java | 5 ++--
.../control/RegisterAndProcessBundleOperation.java | 8 +++----
.../graph/CreateExecutableStageNodeFunction.java | 4 +---
.../runners/dataflow/worker/graph/Networks.java | 4 ++--
.../worker/graph/RegisterNodeFunction.java | 4 +---
.../logging/DataflowWorkerLoggingInitializer.java | 2 +-
.../dataflow/worker/status/DebugCapture.java | 12 ++++++++--
.../dataflow/worker/status/HeapzServlet.java | 4 ++++
.../dataflow/worker/status/StatuszServlet.java | 8 ++++++-
.../dataflow/worker/util/MemoryMonitor.java | 27 ++++++++++++++--------
.../common/worker/GroupingShuffleRangeTracker.java | 5 +++-
.../worker/util/common/worker/GroupingTables.java | 2 +-
.../worker/util/common/worker/ReadOperation.java | 2 +-
.../util/common/worker/ShuffleReadCounter.java | 2 ++
.../util/common/worker/WorkProgressUpdater.java | 3 +++
.../worker/windmill/GrpcWindmillServer.java | 4 ++++
.../worker/windmill/WindmillServerBase.java | 2 +-
.../apache/beam/buildtools/NonnullByDefault.java} | 23 ++++++++++--------
.../org/apache/beam/buildtools/package-info.java | 8 ++-----
47 files changed, 201 insertions(+), 91 deletions(-)
copy
sdks/java/{core/src/main/java/org/apache/beam/sdk/annotations/Internal.java =>
build-tools/src/main/java/org/apache/beam/buildtools/NonnullByDefault.java}
(72%)
copy runners/flink/job-server-container/build.gradle =>
sdks/java/build-tools/src/main/java/org/apache/beam/buildtools/package-info.java
(84%)
