This is an automated email from the ASF dual-hosted git repository.
iemejia pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 602a903 Merge pull request #5599: Fix build (missed auto service for
SQL) and model-fn-execution on Flink
add 345b8ab [BEAM-4318] Enforce ErrorProne analysis in Spark runner
add 8867671 Merge pull request #5430: [BEAM-4318] Enforce ErrorProne
analysis in Spark runner
No new revisions were added by this update.
Summary of changes:
runners/spark/build.gradle | 4 +++-
.../runners/spark/SparkNativePipelineVisitor.java | 4 ++--
.../beam/runners/spark/SparkRunnerDebugger.java | 4 ++--
.../apache/beam/runners/spark/TestSparkRunner.java | 1 +
.../beam/runners/spark/coders/CoderHelpers.java | 4 ++--
.../spark/coders/StatelessJavaSerializer.java | 4 ++--
.../beam/runners/spark/examples/WordCount.java | 1 +
.../apache/beam/runners/spark/io/CreateStream.java | 6 ++---
.../runners/spark/io/SparkUnboundedSource.java | 4 +++-
.../spark/stateful/SparkStateInternals.java | 1 +
.../spark/translation/EvaluationContext.java | 2 +-
.../spark/translation/streaming/Checkpoint.java | 2 +-
.../streaming/StreamingTransformTranslator.java | 2 +-
.../beam/runners/spark/ForceStreamingTest.java | 2 +-
.../runners/spark/ProvidedSparkContextTest.java | 9 +++----
.../aggregators/metrics/sink/InMemoryMetrics.java | 2 +-
.../metrics/sink/SparkMetricsSinkTest.java | 28 +++++++---------------
.../spark/metrics/SparkMetricsPusherTest.java | 6 ++++-
.../ResumeFromCheckpointStreamingTest.java | 1 +
19 files changed, 43 insertions(+), 44 deletions(-)
--
To stop receiving notification emails like this one, please contact
[email protected].
