Skip to content

Instantly share code, notes, and snippets.

@ryan-williams

ryan-williams/1-javaPreCommit-fails Secret

Last active September 10, 2018 19:59
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save ryan-williams/d9d3f7bd5f67c7c715e68ae4107aa4a0 to your computer and use it in GitHub Desktop.
Save ryan-williams/d9d3f7bd5f67c7c715e68ae4107aa4a0 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
1-javaPreCommit-fails
$ ./gradlew javaPreCommit
Parallel execution is an incubating feature.
Parallel execution with configuration on demand is an incubating feature.
> Configure project :beam-model-fn-execution
applyPortabilityNature with default configuration for project beam-model-fn-execution
> Configure project :beam-model-job-management
applyPortabilityNature with default configuration for project beam-model-job-management
> Configure project :beam-model-pipeline
applyPortabilityNature with default configuration for project beam-model-pipeline
> Task :beam-runners-apex:buildDependencyTree
See the report at: file:///Users/ryan/c/beam/runners/apex/build/classes/java/main/org/apache/beam/runners/apex/dependency-tree
> Task :beam-sdks-java-extensions-sql:compileJavacc
Java Compiler Compiler Version 4.0 (Parser Generator)
(type "javacc" with no arguments for help)
Warning: Bad option "-grammar_encoding=UTF-8" will be ignored.
Reading from file /Users/ryan/c/beam/sdks/java/extensions/sql/build/generated/fmpp/javacc/Parser.jj . . .
Note: UNICODE_INPUT option is specified. Please make sure you create the parser/lexer using a Reader with the correct character encoding.Warning:
Lookahead adequacy checking not being performed since option LOOKAHEAD is more than 1. Set option FORCE_LA_CHECK to true to force checking.
File "TokenMgrError.java" does not exist. Will create one.
File "ParseException.java" does not exist. Will create one.
File "Token.java" does not exist. Will create one.
File "SimpleCharStream.java" does not exist. Will create one.
Parser generated with 0 errors and 1 warnings.
> Task :beam-sdks-java-io-amazon-web-services:compileJava
Note: /Users/ryan/c/beam/sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/options/AwsModule.java uses or overrides a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
> Task :beam-sdks-java-io-cassandra:compileJava
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
> Task :beam-runners-core-java:compileJava
Note: Some input files use or override a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
> Task :beam-runners-google-cloud-dataflow-java:compileJava
Note: Some input files use or override a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
> Task :beam-runners-core-construction-java:compileTestJava
Note: Some input files use or override a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
> Task :beam-runners-core-construction-java:javadoc
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/metrics/MetricFiltering.java:55: warning: no @param for haystack
public static boolean subPathMatches(String haystack, String needle) {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/metrics/MetricFiltering.java:55: warning: no @param for needle
public static boolean subPathMatches(String haystack, String needle) {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/metrics/MetricFiltering.java:55: warning: no @return
public static boolean subPathMatches(String haystack, String needle) {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/metrics/MetricFiltering.java:75: warning: no @param for actualScope
public static boolean matchesScope(String actualScope, Set<String> scopes) {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/metrics/MetricFiltering.java:75: warning: no @param for scopes
public static boolean matchesScope(String actualScope, Set<String> scopes) {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/metrics/MetricFiltering.java:75: warning: no @return
public static boolean matchesScope(String actualScope, Set<String> scopes) {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/metrics/MetricKey.java:33: warning: no @return
public abstract String stepName();
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/metrics/MetricKey.java:36: warning: no @return
public abstract MetricName metricName();
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ArtifactServiceStager.java:97: warning: no @param for stagingSessionToken
public String stage(String stagingSessionToken, Iterable<StagedFile> files)
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ArtifactServiceStager.java:97: warning: no @param for files
public String stage(String stagingSessionToken, Iterable<StagedFile> files)
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ArtifactServiceStager.java:97: warning: no @throws for java.io.IOException
public String stage(String stagingSessionToken, Iterable<StagedFile> files)
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ArtifactServiceStager.java:97: warning: no @throws for java.lang.InterruptedException
public String stage(String stagingSessionToken, Iterable<StagedFile> files)
^
> Task :beam-runners-core-construction-java:javadoc
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ArtifactServiceStager.java:258: warning: no @return
public abstract File getFile();
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ArtifactServiceStager.java:260: warning: no @return
public abstract String getStagingName();
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/BeamUrns.java:26: warning: no @param for value
public static String getUrn(ProtocolMessageEnum value) {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/BeamUrns.java:26: warning: no @return
public static String getUrn(ProtocolMessageEnum value) {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/CoderTranslator.java:36: warning: no @param for from
List<? extends Coder<?>> getComponents(T from);
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/CoderTranslator.java:36: warning: no @return
List<? extends Coder<?>> getComponents(T from);
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/CoderTranslator.java:44: warning: no @param for from
default byte[] getPayload(T from) {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/CoderTranslator.java:44: warning: no @return
default byte[] getPayload(T from) {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/CoderTranslator.java:49: warning: no @param for components
T fromComponents(List<Coder<?>> components, byte[] payload);
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/CoderTranslator.java:49: warning: no @param for payload
T fromComponents(List<Coder<?>> components, byte[] payload);
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/CoderTranslator.java:49: warning: no @return
T fromComponents(List<Coder<?>> components, byte[] payload);
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/CoderTranslatorRegistrar.java:31: warning: no @return
Map<Class<? extends Coder>, String> getCoderURNs();
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/CoderTranslatorRegistrar.java:34: warning: no @return
Map<Class<? extends Coder>, CoderTranslator<? extends Coder>> getCoderTranslators();
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/CreatePCollectionViewTranslation.java:55: warning: no @param for <ElemT>
public static <ElemT, ViewT> PCollectionView<ViewT> getView(
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/CreatePCollectionViewTranslation.java:55: warning: no @param for <ViewT>
public static <ElemT, ViewT> PCollectionView<ViewT> getView(
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/CreatePCollectionViewTranslation.java:55: warning: no @param for application
public static <ElemT, ViewT> PCollectionView<ViewT> getView(
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/CreatePCollectionViewTranslation.java:55: warning: no @return
public static <ElemT, ViewT> PCollectionView<ViewT> getView(
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/CreatePCollectionViewTranslation.java:55: warning: no @throws for java.io.IOException
public static <ElemT, ViewT> PCollectionView<ViewT> getView(
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ExecutableStageTranslation.java:35: warning: no @param for appliedTransform
public static ExecutableStagePayload getExecutableStagePayload(
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ExecutableStageTranslation.java:35: warning: no @return
public static ExecutableStagePayload getExecutableStagePayload(
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ExecutableStageTranslation.java:35: warning: no @throws for java.io.IOException
public static ExecutableStagePayload getExecutableStagePayload(
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ParDoTranslation.java:353: warning: no @param for ptransform
public static String getMainInputName(RunnerApi.PTransformOrBuilder ptransform)
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ParDoTranslation.java:353: warning: no @return
public static String getMainInputName(RunnerApi.PTransformOrBuilder ptransform)
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ParDoTranslation.java:353: warning: no @throws for java.io.IOException
public static String getMainInputName(RunnerApi.PTransformOrBuilder ptransform)
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ParDoTranslation.java:540: warning: no @param for parameter
public static @Nullable RunnerApi.Parameter translateParameter(Parameter parameter) {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ParDoTranslation.java:540: warning: no @return
public static @Nullable RunnerApi.Parameter translateParameter(Parameter parameter) {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PCollectionViewTranslation.java:43: warning: no @param for sideInput
public static PCollectionView<?> viewFromProto(
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PCollectionViewTranslation.java:43: warning: no @param for localName
public static PCollectionView<?> viewFromProto(
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PCollectionViewTranslation.java:43: warning: no @param for pCollection
public static PCollectionView<?> viewFromProto(
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PCollectionViewTranslation.java:43: warning: no @param for parDoTransform
public static PCollectionView<?> viewFromProto(
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PCollectionViewTranslation.java:43: warning: no @param for components
public static PCollectionView<?> viewFromProto(
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PCollectionViewTranslation.java:43: warning: no @return
public static PCollectionView<?> viewFromProto(
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PCollectionViewTranslation.java:43: warning: no @throws for java.io.IOException
public static PCollectionView<?> viewFromProto(
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PCollectionViewTranslation.java:79: warning: no @param for viewFn
public static ViewFn<?, ?> viewFnFromProto(RunnerApi.SdkFunctionSpec viewFn)
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PCollectionViewTranslation.java:79: warning: no @return
public static ViewFn<?, ?> viewFnFromProto(RunnerApi.SdkFunctionSpec viewFn)
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PCollectionViewTranslation.java:79: warning: no @throws for org.apache.beam.vendor.protobuf.v3.com.google.protobuf.InvalidProtocolBufferException
public static ViewFn<?, ?> viewFnFromProto(RunnerApi.SdkFunctionSpec viewFn)
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PCollectionViewTranslation.java:96: warning: no @param for windowMappingFn
public static WindowMappingFn<?> windowMappingFnFromProto(
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PCollectionViewTranslation.java:96: warning: no @return
public static WindowMappingFn<?> windowMappingFnFromProto(
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PCollectionViewTranslation.java:96: warning: no @throws for org.apache.beam.vendor.protobuf.v3.com.google.protobuf.InvalidProtocolBufferException
public static WindowMappingFn<?> windowMappingFnFromProto(
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PipelineOptionsTranslation.java:45: warning: no @param for options
public static Struct toProto(PipelineOptions options) {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PipelineOptionsTranslation.java:45: warning: no @return
public static Struct toProto(PipelineOptions options) {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PipelineOptionsTranslation.java:74: warning: no @param for protoOptions
public static PipelineOptions fromProto(Struct protoOptions) throws IOException {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PipelineOptionsTranslation.java:74: warning: no @return
public static PipelineOptions fromProto(Struct protoOptions) throws IOException {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PipelineOptionsTranslation.java:74: warning: no @throws for java.io.IOException
public static PipelineOptions fromProto(Struct protoOptions) throws IOException {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java:58: warning: no @param for urn
public static PTransformMatcher urnEqualTo(String urn) {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java:58: warning: no @return
public static PTransformMatcher urnEqualTo(String urn) {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java:84: warning: no @param for clazz
public static PTransformMatcher classEqualTo(Class<? extends PTransform> clazz) {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java:84: warning: no @return
public static PTransformMatcher classEqualTo(Class<? extends PTransform> clazz) {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java:112: warning: no @return
public static PTransformMatcher requiresStableInputParDoSingle() {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java:141: warning: no @return
public static PTransformMatcher requiresStableInputParDoMulti() {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java:170: warning: no @return
public static PTransformMatcher splittableParDoSingle() {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java:195: warning: no @return
public static PTransformMatcher stateOrTimerParDoSingle() {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java:219: warning: no @return
public static PTransformMatcher splittableParDoMulti() {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java:243: warning: no @return
public static PTransformMatcher splittableParDo() {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java:274: warning: no @return
public static PTransformMatcher splittableProcessKeyedBounded() {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java:299: warning: no @return
public static PTransformMatcher splittableProcessKeyedUnbounded() {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java:324: warning: no @return
public static PTransformMatcher stateOrTimerParDo() {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java:356: warning: no @return
public static PTransformMatcher stateOrTimerParDoMulti() {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java:380: warning: no @param for fnType
public static PTransformMatcher parDoWithFnType(final Class<? extends DoFn> fnType) {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java:380: warning: no @return
public static PTransformMatcher parDoWithFnType(final Class<? extends DoFn> fnType) {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java:420: warning: no @return
public static PTransformMatcher emptyFlatten() {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java:439: warning: no @return
public static PTransformMatcher flattenWithDuplicateInputs() {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformReplacements.java:38: warning: no @param for <T>
public static <T> PCollection<T> getSingletonMainInput(
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformReplacements.java:38: warning: no @param for application
public static <T> PCollection<T> getSingletonMainInput(
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformReplacements.java:38: warning: no @return
public static <T> PCollection<T> getSingletonMainInput(
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformTranslation.java:157: warning: no @param for transform
public static String urnForTransformOrNull(PTransform<?, ?> transform) {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformTranslation.java:157: warning: no @return
public static String urnForTransformOrNull(PTransform<?, ?> transform) {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformTranslation.java:167: warning: no @param for transform
public static String urnForTransform(PTransform<?, ?> transform) {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformTranslation.java:167: warning: no @return
public static String urnForTransform(PTransform<?, ?> transform) {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformTranslation.java:178: warning: no @param for transform
public static String urnForTransformOrNull(RunnerApi.PTransform transform) {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformTranslation.java:178: warning: no @return
public static String urnForTransformOrNull(RunnerApi.PTransform transform) {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformTranslation.java:431: warning: no @return
public String getUrn() {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformTranslation.java:437: warning: no @return
public abstract FunctionSpec getSpec();
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformTranslation.java:446: warning: no @param for components
public FunctionSpec migrate(SdkComponents components) throws IOException {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformTranslation.java:446: warning: no @return
public FunctionSpec migrate(SdkComponents components) throws IOException {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformTranslation.java:446: warning: no @throws for java.io.IOException
public FunctionSpec migrate(SdkComponents components) throws IOException {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/RehydratedComponents.java:112: warning: no @param for components
public static RehydratedComponents forComponents(RunnerApi.Components components) {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/RehydratedComponents.java:112: warning: no @return
public static RehydratedComponents forComponents(RunnerApi.Components components) {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/RehydratedComponents.java:117: warning: no @param for pipeline
public RehydratedComponents withPipeline(Pipeline pipeline) {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/RehydratedComponents.java:117: warning: no @return
public RehydratedComponents withPipeline(Pipeline pipeline) {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/RehydratedComponents.java:132: warning: no @param for pCollectionId
public PCollection<?> getPCollection(String pCollectionId) throws IOException {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/RehydratedComponents.java:132: warning: no @return
public PCollection<?> getPCollection(String pCollectionId) throws IOException {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/RehydratedComponents.java:132: warning: no @throws for java.io.IOException
public PCollection<?> getPCollection(String pCollectionId) throws IOException {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/RehydratedComponents.java:146: warning: no @param for windowingStrategyId
public WindowingStrategy<?, ?> getWindowingStrategy(String windowingStrategyId)
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/RehydratedComponents.java:146: warning: no @return
public WindowingStrategy<?, ?> getWindowingStrategy(String windowingStrategyId)
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/RehydratedComponents.java:146: warning: no @throws for java.io.IOException
public WindowingStrategy<?, ?> getWindowingStrategy(String windowingStrategyId)
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/RehydratedComponents.java:161: warning: no @param for coderId
public Coder<?> getCoder(String coderId) throws IOException {
^
/Users/ryan/c/beam/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/RehydratedComponents.java:161: warning: no @return
public Coder<?> getCoder(String coderId) throws IOException {
^
100 warnings
> Task :beam-sdks-java-io-jdbc:compileJava
Note: /Users/ryan/c/beam/sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/JdbcIO.java uses or overrides a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: /Users/ryan/c/beam/sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/JdbcIO.java uses unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
> Task :beam-runners-apex:compileJava
Note: Some input files use or override a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
> Task :beam-sdks-java-harness:compileJava
Note: Some input files use or override a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
> Task :beam-runners-spark:compileJava
Note: Some input files use or override a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
> Task :beam-runners-core-java:compileTestJava
Note: Some input files use or override a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
> Task :beam-runners-google-cloud-dataflow-java:javadoc
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowPipelineWorkerPoolOptions.java:68: warning: no @return
public String getAlgorithm() {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowWorkerHarnessOptions.java:35: warning: no @return
String getWorkerId();
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowWorkerHarnessOptions.java:41: warning: no @return
String getJobId();
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowWorkerHarnessOptions.java:52: warning: no @return
Integer getWorkerCacheMb();
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowWorkerLoggingOptions.java:152: warning: no @param for klass
public WorkerLogLevelOverrides addOverrideForClass(Class<?> klass, Level level) {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowWorkerLoggingOptions.java:152: warning: no @param for level
public WorkerLogLevelOverrides addOverrideForClass(Class<?> klass, Level level) {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowWorkerLoggingOptions.java:152: warning: no @return
public WorkerLogLevelOverrides addOverrideForClass(Class<?> klass, Level level) {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowWorkerLoggingOptions.java:165: warning: no @param for pkg
public WorkerLogLevelOverrides addOverrideForPackage(Package pkg, Level level) {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowWorkerLoggingOptions.java:165: warning: no @param for level
public WorkerLogLevelOverrides addOverrideForPackage(Package pkg, Level level) {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowWorkerLoggingOptions.java:165: warning: no @return
public WorkerLogLevelOverrides addOverrideForPackage(Package pkg, Level level) {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowWorkerLoggingOptions.java:178: warning: no @param for name
public WorkerLogLevelOverrides addOverrideForName(String name, Level level) {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowWorkerLoggingOptions.java:178: warning: no @param for level
public WorkerLogLevelOverrides addOverrideForName(String name, Level level) {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowWorkerLoggingOptions.java:178: warning: no @return
public WorkerLogLevelOverrides addOverrideForName(String name, Level level) {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowWorkerLoggingOptions.java:192: warning: no @param for values
public static WorkerLogLevelOverrides from(Map<String, String> values) {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowWorkerLoggingOptions.java:192: warning: no @return
public static WorkerLogLevelOverrides from(Map<String, String> values) {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/CloudObject.java:47: warning: no @return
public static CloudObject fromSpec(Map<String, Object> spec) {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/CloudObject.java:68: warning: no @return
public static CloudObject forClass(Class<?> cls) {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/CloudObject.java:82: warning: no @return
public static CloudObject forClassName(String className) {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/CloudObject.java:93: warning: no @return
public static CloudObject forString(String value) {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/CloudObject.java:104: warning: no @return
public static CloudObject forBoolean(Boolean value) {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/CloudObject.java:115: warning: no @return
public static CloudObject forInteger(Long value) {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/CloudObject.java:126: warning: no @return
public static CloudObject forInteger(Integer value) {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/CloudObject.java:137: warning: no @return
public static CloudObject forFloat(Float value) {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/CloudObject.java:148: warning: no @return
public static CloudObject forFloat(Double value) {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/CloudObject.java:161: warning: no @return
public static CloudObject forKnownType(Object value) {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/CloudObject.java:177: warning: no @return
public String getClassName() {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/CloudObjects.java:62: warning: no @param for coder
public static CloudObject asCloudObject(Coder<?> coder) {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/CloudObjects.java:62: warning: no @return
public static CloudObject asCloudObject(Coder<?> coder) {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/CloudObjectTranslator.java:27: warning: no @param for target
CloudObject toCloudObject(T target);
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/CloudObjectTranslator.java:27: warning: no @return
CloudObject toCloudObject(T target);
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/CloudObjectTranslator.java:30: warning: no @param for cloudObject
T fromCloudObject(CloudObject cloudObject);
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/CloudObjectTranslator.java:30: warning: no @return
T fromCloudObject(CloudObject cloudObject);
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/CloudObjectTranslator.java:33: warning: no @return
Class<? extends T> getSupportedClass();
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/CloudObjectTranslator.java:39: warning: no @return
String cloudObjectClassName();
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/CoderCloudObjectTranslatorRegistrar.java:39: warning: no @return
Map<Class<? extends Coder>, CloudObjectTranslator<? extends Coder>> classesToTranslators();
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/CoderCloudObjectTranslatorRegistrar.java:45: warning: no @return
Map<String, CloudObjectTranslator<? extends Coder>> classNamesToTranslators();
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowPipelineJob.java:133: warning: no @return
public String getJobId() {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowPipelineJob.java:138: warning: no @return
public String getProjectId() {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowPipelineJob.java:147: warning: no @return
public String getRegion() {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowPipelineJob.java:157: warning: no @return
public DataflowPipelineJob getReplacedByJob() {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowPipelineJob.java:201: warning: no @throws for java.lang.InterruptedException
public State waitUntilFinish(Duration duration, MonitoringUtil.JobMessagesHandler messageHandler)
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/DataflowTransport.java:64: warning: no @param for options
public static Dataflow.Builder newDataflowClient(DataflowPipelineOptions options) {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/DataflowTransport.java:64: warning: no @return
public static Dataflow.Builder newDataflowClient(DataflowPipelineOptions options) {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/Stager.java:35: warning: no @return
List<DataflowPackage> stageDefaultFiles();
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/Stager.java:45: warning: no @param for filesToStage
List<DataflowPackage> stageFiles(List<String> filesToStage);
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/Stager.java:45: warning: no @return
List<DataflowPackage> stageFiles(List<String> filesToStage);
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/Stager.java:48: warning: no @param for bytes
DataflowPackage stageToFile(byte[] bytes, String baseName);
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/Stager.java:48: warning: no @param for baseName
DataflowPackage stageToFile(byte[] bytes, String baseName);
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/Stager.java:48: warning: no @return
DataflowPackage stageToFile(byte[] bytes, String baseName);
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/MonitoringUtil.java:146: warning: no @throws for java.io.IOException
public List<JobMessage> getJobMessages(String jobId, long startTimestampMs) throws IOException {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/MonitoringUtil.java:183: warning: no @param for projectName
public static String getJobMonitoringPageURL(String projectName, String jobId) {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/MonitoringUtil.java:183: warning: no @param for jobId
public static String getJobMonitoringPageURL(String projectName, String jobId) {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/MonitoringUtil.java:183: warning: no @return
public static String getJobMonitoringPageURL(String projectName, String jobId) {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/MonitoringUtil.java:119: warning: no @param for dataflowClient
public MonitoringUtil(DataflowClient dataflowClient) {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/MonitoringUtil.java:80: warning: no @param for messages
void process(List<JobMessage> messages);
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/RandomAccessData.java:201: warning: no @return
public RandomAccessData increment() throws IOException {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/RandomAccessData.java:201: warning: no @throws for java.io.IOException
public RandomAccessData increment() throws IOException {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/RandomAccessData.java:236: warning: no @return
public byte[] array() {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/RandomAccessData.java:241: warning: no @return
public int size() {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/RandomAccessData.java:246: warning: no @param for position
public void resetTo(int position) {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/RandomAccessData.java:272: warning: no @return
public OutputStream asOutputStream() {
^
/Users/ryan/c/beam/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/RandomAccessData.java:282: warning: no @param for offset
public InputStream asInputStream(final int offset, final int length) {
^
> Task :beam-runners-core-java:javadoc
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricCell.java:36: warning: no @return
DirtyState getDirty();
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricCell.java:39: warning: no @return
DataT getCumulative();
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/CounterCell.java:50: warning: no @param for name
public CounterCell(MetricName name) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/DistributionCell.java:51: warning: no @param for name
public DistributionCell(MetricName name) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/GaugeCell.java:49: warning: no @param for name
public GaugeCell(MetricName name) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsContainerImpl.java:79: warning: no @param for metricName
public CounterCell tryGetCounter(MetricName metricName) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsContainerImpl.java:79: warning: no @return
public CounterCell tryGetCounter(MetricName metricName) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsContainerImpl.java:97: warning: no @param for metricName
public DistributionCell tryGetDistribution(MetricName metricName) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsContainerImpl.java:97: warning: no @return
public DistributionCell tryGetDistribution(MetricName metricName) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsContainerImpl.java:114: warning: no @param for metricName
public GaugeCell tryGetGauge(MetricName metricName) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsContainerImpl.java:114: warning: no @return
public GaugeCell tryGetGauge(MetricName metricName) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsContainerImpl.java:135: warning: no @return
public MetricUpdates getUpdates() {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsContainerImpl.java:170: warning: no @return
public MetricUpdates getCumulative() {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsContainerImpl.java:178: warning: no @param for other
public void update(MetricsContainerImpl other) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsContainerImpl.java:61: warning: no @param for stepName
public MetricsContainerImpl(String stepName) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsContainerStepMap.java:53: warning: no @param for stepName
public MetricsContainerImpl getContainer(String stepName) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsContainerStepMap.java:53: warning: no @return
public MetricsContainerImpl getContainer(String stepName) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsContainerStepMap.java:64: warning: no @param for other
public void updateAll(MetricsContainerStepMap other) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsContainerStepMap.java:74: warning: no @param for step
public void update(String step, MetricsContainerImpl container) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsContainerStepMap.java:74: warning: no @param for container
public void update(String step, MetricsContainerImpl container) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsContainerStepMap.java:103: warning: no @param for attemptedMetricsContainers
public static MetricResults asMetricResults(
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsContainerStepMap.java:103: warning: no @param for committedMetricsContainers
public static MetricResults asMetricResults(
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsContainerStepMap.java:103: warning: no @return
public static MetricResults asMetricResults(
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsContainerStepMap.java:118: warning: no @param for attemptedMetricsContainers
public static MetricResults asAttemptedOnlyMetricResults(
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsContainerStepMap.java:118: warning: no @return
public static MetricResults asAttemptedOnlyMetricResults(
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsMap.java:56: warning: no @param for key
public T get(K key) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsMap.java:56: warning: no @return
public T get(K key) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsMap.java:67: warning: no @param for key
public T tryGet(K key) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsMap.java:67: warning: no @return
public T tryGet(K key) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsMap.java:72: warning: no @return
public Iterable<Map.Entry<K, T>> entries() {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsMap.java:77: warning: no @return
public Iterable<T> values() {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsMap.java:45: warning: no @param for key
T createInstance(K key);
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsMap.java:45: warning: no @return
T createInstance(K key);
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricUpdates.java:57: warning: no @return
public boolean isEmpty() {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricUpdates.java:62: warning: no @return
public abstract Iterable<MetricUpdate<Long>> counterUpdates();
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricUpdates.java:65: warning: no @return
public abstract Iterable<MetricUpdate<DistributionData>> distributionUpdates();
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricUpdates.java:68: warning: no @return
public abstract Iterable<MetricUpdate<GaugeData>> gaugeUpdates();
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricUpdates.java:71: warning: no @param for counterUpdates
public static MetricUpdates create(
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricUpdates.java:71: warning: no @param for distributionUpdates
public static MetricUpdates create(
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricUpdates.java:71: warning: no @param for gaugeUpdates
public static MetricUpdates create(
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricUpdates.java:71: warning: no @return
public static MetricUpdates create(
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricUpdates.java:47: warning: no @return
public abstract MetricKey getKey();
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricUpdates.java:49: warning: no @return
public abstract T getUpdate();
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterAllStateMachine.java:42: warning: no @param for triggers
public static TriggerStateMachine of(TriggerStateMachine... triggers) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterAllStateMachine.java:42: warning: no @return
public static TriggerStateMachine of(TriggerStateMachine... triggers) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/TriggerStateMachine.java:259: warning: no @param for c
public abstract void onElement(OnElementContext c) throws Exception;
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/TriggerStateMachine.java:259: warning: no @throws for java.lang.Exception
public abstract void onElement(OnElementContext c) throws Exception;
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/TriggerStateMachine.java:276: warning: no @param for c
public abstract void onMerge(OnMergeContext c) throws Exception;
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/TriggerStateMachine.java:276: warning: no @throws for java.lang.Exception
public abstract void onMerge(OnMergeContext c) throws Exception;
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/TriggerStateMachine.java:282: warning: no @param for context
public abstract boolean shouldFire(TriggerContext context) throws Exception;
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/TriggerStateMachine.java:282: warning: no @return
public abstract boolean shouldFire(TriggerContext context) throws Exception;
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/TriggerStateMachine.java:282: warning: no @throws for java.lang.Exception
public abstract boolean shouldFire(TriggerContext context) throws Exception;
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/TriggerStateMachine.java:291: warning: no @param for context
public abstract void onFire(TriggerContext context) throws Exception;
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/TriggerStateMachine.java:291: warning: no @throws for java.lang.Exception
public abstract void onFire(TriggerContext context) throws Exception;
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/TriggerStateMachine.java:297: warning: no @param for state
public void prefetchOnElement(StateAccessor<?> state) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/TriggerStateMachine.java:309: warning: no @param for state
public void prefetchOnMerge(MergingStateAccessor<?, ?> state) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/TriggerStateMachine.java:321: warning: no @param for state
public void prefetchShouldFire(StateAccessor<?> state) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/TriggerStateMachine.java:333: warning: no @param for state
public void prefetchOnFire(StateAccessor<?> state) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/TriggerStateMachine.java:348: warning: no @param for c
public void clear(TriggerContext c) throws Exception {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/TriggerStateMachine.java:348: warning: no @throws for java.lang.Exception
public void clear(TriggerContext c) throws Exception {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/TriggerStateMachine.java:361: warning: no @param for other
public boolean isCompatible(TriggerStateMachine other) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/TriggerStateMachine.java:361: warning: no @return
public boolean isCompatible(TriggerStateMachine other) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/TriggerStateMachine.java:431: warning: no @param for until
public TriggerStateMachine orFinally(TriggerStateMachine until) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/TriggerStateMachine.java:431: warning: no @return
public TriggerStateMachine orFinally(TriggerStateMachine until) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterDelayFromFirstElementStateMachine.java:66: warning: no @param for context
public abstract Instant getCurrentTime(TriggerStateMachine.TriggerContext context);
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterDelayFromFirstElementStateMachine.java:66: warning: no @return
public abstract Instant getCurrentTime(TriggerStateMachine.TriggerContext context);
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterDelayFromFirstElementStateMachine.java:73: warning: no @param for transform
protected abstract AfterDelayFromFirstElementStateMachine newWith(
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterDelayFromFirstElementStateMachine.java:73: warning: no @return
protected abstract AfterDelayFromFirstElementStateMachine newWith(
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterDelayFromFirstElementStateMachine.java:97: warning: no @return
public TimeDomain getTimeDomain() {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterDelayFromFirstElementStateMachine.java:105: warning: no @return
public List<SerializableFunction<Instant, Instant>> getTimestampMappers() {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterDelayFromFirstElementStateMachine.java:116: warning: no @param for size
public AfterDelayFromFirstElementStateMachine alignedTo(
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterDelayFromFirstElementStateMachine.java:116: warning: no @param for offset
public AfterDelayFromFirstElementStateMachine alignedTo(
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterDelayFromFirstElementStateMachine.java:116: warning: no @return
public AfterDelayFromFirstElementStateMachine alignedTo(
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterDelayFromFirstElementStateMachine.java:125: warning: no @param for size
public AfterDelayFromFirstElementStateMachine alignedTo(final Duration size) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterDelayFromFirstElementStateMachine.java:125: warning: no @return
public AfterDelayFromFirstElementStateMachine alignedTo(final Duration size) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterEachStateMachine.java:53: warning: no @param for triggers
public static TriggerStateMachine inOrder(TriggerStateMachine... triggers) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterEachStateMachine.java:53: warning: no @return
public static TriggerStateMachine inOrder(TriggerStateMachine... triggers) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterFirstStateMachine.java:42: warning: no @param for triggers
public static TriggerStateMachine of(TriggerStateMachine... triggers) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterFirstStateMachine.java:42: warning: no @return
public static TriggerStateMachine of(TriggerStateMachine... triggers) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterPaneStateMachine.java:49: warning: no @return
public int getElementCount() {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterPaneStateMachine.java:54: warning: no @param for countElems
public static AfterPaneStateMachine elementCountAtLeast(int countElems) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterPaneStateMachine.java:54: warning: no @return
public static AfterPaneStateMachine elementCountAtLeast(int countElems) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterProcessingTimeStateMachine.java:56: warning: no @return
public static AfterProcessingTimeStateMachine pastFirstElementInPane() {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterWatermarkStateMachine.java:64: warning: no @return
public static FromEndOfWindow pastEndOfWindow() {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterWatermarkStateMachine.java:244: warning: no @param for earlyFirings
public AfterWatermarkEarlyAndLate withEarlyFirings(TriggerStateMachine earlyFirings) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterWatermarkStateMachine.java:244: warning: no @return
public AfterWatermarkEarlyAndLate withEarlyFirings(TriggerStateMachine earlyFirings) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterWatermarkStateMachine.java:253: warning: no @param for lateFirings
public AfterWatermarkEarlyAndLate withLateFirings(TriggerStateMachine lateFirings) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterWatermarkStateMachine.java:253: warning: no @return
public AfterWatermarkEarlyAndLate withLateFirings(TriggerStateMachine lateFirings) {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/DefaultTriggerStateMachine.java:36: warning: no @return
public static DefaultTriggerStateMachine of() {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/ExecutableTriggerStateMachine.java:84: warning: no @return
public TriggerStateMachine getSpec() {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/ExecutableTriggerStateMachine.java:119: warning: no @param for c
public void invokeOnElement(TriggerStateMachine.OnElementContext c) throws Exception {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/ExecutableTriggerStateMachine.java:119: warning: no @throws for java.lang.Exception
public void invokeOnElement(TriggerStateMachine.OnElementContext c) throws Exception {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/ExecutableTriggerStateMachine.java:127: warning: no @param for c
public void invokeOnMerge(TriggerStateMachine.OnMergeContext c) throws Exception {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/ExecutableTriggerStateMachine.java:127: warning: no @throws for java.lang.Exception
public void invokeOnMerge(TriggerStateMachine.OnMergeContext c) throws Exception {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/ExecutableTriggerStateMachine.java:141: warning: no @param for c
public void invokeClear(TriggerStateMachine.TriggerContext c) throws Exception {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/ExecutableTriggerStateMachine.java:141: warning: no @throws for java.lang.Exception
public void invokeClear(TriggerStateMachine.TriggerContext c) throws Exception {
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/FinishedTriggers.java:26: warning: no @param for trigger
boolean isFinished(ExecutableTriggerStateMachine trigger);
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/FinishedTriggers.java:26: warning: no @return
boolean isFinished(ExecutableTriggerStateMachine trigger);
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/FinishedTriggers.java:29: warning: no @param for trigger
void setFinished(ExecutableTriggerStateMachine trigger, boolean value);
^
/Users/ryan/c/beam/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/FinishedTriggers.java:29: warning: no @param for value
void setFinished(ExecutableTriggerStateMachine trigger, boolean value);
^
> Task :beam-runners-apex:test
#
# A fatal error has been detected by the Java Runtime Environment:
#
# SIGBUS (0xa) at pc=0x0000000101d2ce92, pid=72909, tid=0x0000000000005603
#
# JRE version: Java(TM) SE Runtime Environment (8.0_111-b14) (build 1.8.0_111-b14)
# Java VM: Java HotSpot(TM) 64-Bit Server VM (25.111-b14 mixed mode bsd-amd64 compressed oops)
# Problematic frame:
# C [libzip.dylib+0x2e92] newEntry+0x154
#
# Failed to write core dump. Core dumps have been disabled. To enable core dumping, try "ulimit -c unlimited" before starting Java again
#
# An error report file with more information is saved as:
# /Users/ryan/c/beam/runners/apex/hs_err_pid72909.log
#
# If you would like to submit a bug report, please visit:
# http://bugreport.java.com/bugreport/crash.jsp
# The crash happened outside the Java Virtual Machine in native code.
# See problematic frame for where to report the bug.
#
> Task :beam-runners-apex:test FAILED
> Task :beam-runners-spark:test
[Thread-4] INFO org.apache.spark.util.ShutdownHookManager - Shutdown hook called
[Thread-4] INFO org.apache.spark.util.ShutdownHookManager - Deleting directory /private/var/folders/m0/mj2x82p1527349z6mn8btgtr0000gr/T/spark-af7b8e67-5d50-40a1-b793-7eb99fb3d7a0
> Task :beam-runners-java-fn-execution:compileJava
Note: /Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/ServerFactory.java uses or overrides a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-runners-apex:test'.
> Process 'Gradle Test Executor 10' finished with non-zero exit value 134
This problem might be caused by incorrect test process configuration.
Please refer to the test execution section in the user guide at https://docs.gradle.org/4.8/userguide/java_plugin.html#sec:test_execution
* Try:
Run with --stacktrace option to get the stack trace. Run with --info or --debug option to get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
See https://docs.gradle.org/4.8/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 3m 59s
444 actionable tasks: 234 executed, 210 up-to-date
Raw
2-apex-tests-pass
$ ./gradlew :beam-runners-apex:test
Parallel execution is an incubating feature.
Parallel execution with configuration on demand is an incubating feature.
> Configure project :beam-model-pipeline
applyPortabilityNature with default configuration for project beam-model-pipeline
> Configure project :beam-model-job-management
applyPortabilityNature with default configuration for project beam-model-job-management
> Configure project :beam-model-fn-execution
applyPortabilityNature with default configuration for project beam-model-fn-execution
> Task :beam-runners-apex:buildDependencyTree
See the report at: file:///Users/ryan/c/beam/runners/apex/build/classes/java/main/org/apache/beam/runners/apex/dependency-tree
Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
See https://docs.gradle.org/4.8/userguide/command_line_interface.html#sec:command_line_warnings
BUILD SUCCESSFUL in 56s
36 actionable tasks: 4 executed, 32 up-to-date
Raw
3-compile-failures
$ ./gradlew javaPreCommit
Parallel execution is an incubating feature.
Parallel execution with configuration on demand is an incubating feature.
> Configure project :beam-model-fn-execution
applyPortabilityNature with default configuration for project beam-model-fn-execution
> Configure project :beam-model-job-management
applyPortabilityNature with default configuration for project beam-model-job-management
> Configure project :beam-model-pipeline
applyPortabilityNature with default configuration for project beam-model-pipeline
> Task :beam-runners-apex:buildDependencyTree
See the report at: file:///Users/ryan/c/beam/runners/apex/build/classes/java/main/org/apache/beam/runners/apex/dependency-tree
> Task :beam-runners-apex:compileTestJava
Could not read annotation processor declarations from /Users/ryan/c/beam/runners/core-java/build/libs/beam-runners-core-java-2.8.0-SNAPSHOT-tests.jar. Gradle will assume that this jar contains no annotation processors.
> Task :beam-runners-apex:compileTestJava
error: error reading /Users/ryan/c/beam/sdks/java/core/build/libs/beam-sdks-java-core-2.8.0-SNAPSHOT-tests.jar; error in opening zip file
> Task :beam-sdks-java-harness:compileTestJava
error: error reading /Users/ryan/c/beam/sdks/java/core/build/libs/beam-sdks-java-core-2.8.0-SNAPSHOT-tests.jar; error in opening zip file
> Task :beam-runners-java-fn-execution:javadoc
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/jobsubmission/InMemoryJobService.java:71: warning: no @param for cleanupJobFn
public static InMemoryJobService create(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/jobsubmission/JobInvocation.java:38: warning: no @return
JobState.Enum getState();
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/jobsubmission/JobInvocation.java:41: warning: no @param for stateStreamObserver
void addStateListener(Consumer<Enum> stateStreamObserver);
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/jobsubmission/JobInvocation.java:44: warning: no @param for messageStreamObserver
void addMessageListener(Consumer<JobMessage> messageStreamObserver);
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/jobsubmission/JobInvoker.java:28: warning: no @param for pipeline
JobInvocation invoke(RunnerApi.Pipeline pipeline, Struct options, @Nullable String retrievalToken)
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/jobsubmission/JobInvoker.java:28: warning: no @param for options
JobInvocation invoke(RunnerApi.Pipeline pipeline, Struct options, @Nullable String retrievalToken)
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/jobsubmission/JobInvoker.java:28: warning: no @param for retrievalToken
JobInvocation invoke(RunnerApi.Pipeline pipeline, Struct options, @Nullable String retrievalToken)
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/jobsubmission/JobInvoker.java:28: warning: no @return
JobInvocation invoke(RunnerApi.Pipeline pipeline, Struct options, @Nullable String retrievalToken)
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/jobsubmission/JobInvoker.java:28: warning: no @throws for java.io.IOException
JobInvocation invoke(RunnerApi.Pipeline pipeline, Struct options, @Nullable String retrievalToken)
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/artifact/BeamFileSystemArtifactStagingService.java:138: warning: no @throws for java.lang.Exception
public static String generateStagingSessionToken(String sessionId, String basePath)
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/DockerEnvironmentFactory.java:53: warning: no @param for controlServiceServer
public static DockerEnvironmentFactory forServices(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/DockerEnvironmentFactory.java:53: warning: no @param for loggingServiceServer
public static DockerEnvironmentFactory forServices(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/DockerEnvironmentFactory.java:53: warning: no @param for retrievalServiceServer
public static DockerEnvironmentFactory forServices(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/DockerEnvironmentFactory.java:53: warning: no @param for provisioningServiceServer
public static DockerEnvironmentFactory forServices(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/DockerEnvironmentFactory.java:53: warning: no @param for clientSource
public static DockerEnvironmentFactory forServices(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/DockerEnvironmentFactory.java:53: warning: no @param for idGenerator
public static DockerEnvironmentFactory forServices(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/DockerEnvironmentFactory.java:53: warning: no @return
public static DockerEnvironmentFactory forServices(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/EnvironmentFactory.java:28: warning: no @param for container
RemoteEnvironment createEnvironment(RunnerApi.Environment container) throws Exception;
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/EnvironmentFactory.java:28: warning: no @return
RemoteEnvironment createEnvironment(RunnerApi.Environment container) throws Exception;
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/EnvironmentFactory.java:28: warning: no @throws for java.lang.Exception
RemoteEnvironment createEnvironment(RunnerApi.Environment container) throws Exception;
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/RemoteEnvironment.java:38: warning: no @param for env
static RemoteEnvironment forHandler(Environment env, InstructionRequestHandler handler) {
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/RemoteEnvironment.java:38: warning: no @param for handler
static RemoteEnvironment forHandler(Environment env, InstructionRequestHandler handler) {
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/RemoteEnvironment.java:38: warning: no @return
static RemoteEnvironment forHandler(Environment env, InstructionRequestHandler handler) {
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/RemoteEnvironment.java:43: warning: no @return
Environment getEnvironment();
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/RemoteEnvironment.java:46: warning: no @return
InstructionRequestHandler getInstructionRequestHandler();
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/ProcessManager.java:108: warning: no @throws for java.io.IOException
public RunningProcess startProcess(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/ProcessManager.java:146: warning: no @param for id
public void stopProcess(String id) {
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/wire/WireCoders.java:43: warning: no @param for pCollectionNode
public static String addSdkWireCoder(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/wire/WireCoders.java:43: warning: no @param for components
public static String addSdkWireCoder(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/wire/WireCoders.java:56: warning: no @param for pCollectionNode
public static String addRunnerWireCoder(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/wire/WireCoders.java:56: warning: no @param for components
public static String addRunnerWireCoder(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/wire/WireCoders.java:67: warning: no @param for <T>
public static <T> Coder<WindowedValue<T>> instantiateRunnerWireCoder(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/wire/WireCoders.java:67: warning: no @param for pCollectionNode
public static <T> Coder<WindowedValue<T>> instantiateRunnerWireCoder(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/wire/WireCoders.java:67: warning: no @param for components
public static <T> Coder<WindowedValue<T>> instantiateRunnerWireCoder(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/wire/WireCoders.java:67: warning: no @throws for java.io.IOException
public static <T> Coder<WindowedValue<T>> instantiateRunnerWireCoder(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/GrpcStateService.java:37: warning: no @return
public static GrpcStateService create() {
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateDelegator.java:32: warning: no @param for processBundleInstructionId
Registration registerForProcessBundleInstructionId(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateDelegator.java:32: warning: no @param for handler
Registration registerForProcessBundleInstructionId(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateDelegator.java:32: warning: no @return
Registration registerForProcessBundleInstructionId(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateRequestHandler.java:38: warning: no @param for request
CompletionStage<StateResponse.Builder> handle(StateRequest request) throws Exception;
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateRequestHandler.java:38: warning: no @return
CompletionStage<StateResponse.Builder> handle(StateRequest request) throws Exception;
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateRequestHandler.java:38: warning: no @throws for java.lang.Exception
CompletionStage<StateResponse.Builder> handle(StateRequest request) throws Exception;
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateRequestHandlers.java:183: warning: no @param for handlers
public static StateRequestHandler delegateBasedUponType(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateRequestHandlers.java:183: warning: no @return
public static StateRequestHandler delegateBasedUponType(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateRequestHandlers.java:228: warning: no @param for sideInputSpecs
public static StateRequestHandler forSideInputHandlerFactory(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateRequestHandlers.java:228: warning: no @param for sideInputHandlerFactory
public static StateRequestHandler forSideInputHandlerFactory(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateRequestHandlers.java:228: warning: no @return
public static StateRequestHandler forSideInputHandlerFactory(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateRequestHandlers.java:336: warning: no @param for processBundleDescriptor
public static StateRequestHandler forBagUserStateHandlerFactory(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateRequestHandlers.java:336: warning: no @param for bagUserStateHandlerFactory
public static StateRequestHandler forBagUserStateHandlerFactory(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateRequestHandlers.java:336: warning: no @return
public static StateRequestHandler forBagUserStateHandlerFactory(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateRequestHandlers.java:134: warning: no @param for key
Iterable<V> get(K key, W window);
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateRequestHandlers.java:134: warning: no @param for window
Iterable<V> get(K key, W window);
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateRequestHandlers.java:134: warning: no @return
Iterable<V> get(K key, W window);
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateRequestHandlers.java:137: warning: no @param for key
void append(K key, W window, Iterator<V> values);
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateRequestHandlers.java:137: warning: no @param for window
void append(K key, W window, Iterator<V> values);
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateRequestHandlers.java:137: warning: no @param for values
void append(K key, W window, Iterator<V> values);
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateRequestHandlers.java:140: warning: no @param for key
void clear(K key, W window);
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateRequestHandlers.java:140: warning: no @param for window
void clear(K key, W window);
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateRequestHandlers.java:158: warning: no @return
static BagUserStateHandlerFactory unsupported() {
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateRequestHandlers.java:74: warning: no @param for key
Iterable<V> get(byte[] key, W window);
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateRequestHandlers.java:74: warning: no @param for window
Iterable<V> get(byte[] key, W window);
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateRequestHandlers.java:74: warning: no @return
Iterable<V> get(byte[] key, W window);
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateRequestHandlers.java:77: warning: no @return
Coder<V> resultCoder();
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateRequestHandlers.java:93: warning: no @param for <T>
<T, V, W extends BoundedWindow> SideInputHandler<V, W> forSideInput(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateRequestHandlers.java:93: warning: no @param for <V>
<T, V, W extends BoundedWindow> SideInputHandler<V, W> forSideInput(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateRequestHandlers.java:93: warning: no @param for <W>
<T, V, W extends BoundedWindow> SideInputHandler<V, W> forSideInput(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateRequestHandlers.java:93: warning: no @param for pTransformId
<T, V, W extends BoundedWindow> SideInputHandler<V, W> forSideInput(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateRequestHandlers.java:93: warning: no @param for sideInputId
<T, V, W extends BoundedWindow> SideInputHandler<V, W> forSideInput(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateRequestHandlers.java:93: warning: no @param for accessPattern
<T, V, W extends BoundedWindow> SideInputHandler<V, W> forSideInput(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateRequestHandlers.java:93: warning: no @param for elementCoder
<T, V, W extends BoundedWindow> SideInputHandler<V, W> forSideInput(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateRequestHandlers.java:93: warning: no @param for windowCoder
<T, V, W extends BoundedWindow> SideInputHandler<V, W> forSideInput(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateRequestHandlers.java:93: warning: no @return
<T, V, W extends BoundedWindow> SideInputHandler<V, W> forSideInput(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateRequestHandlers.java:101: warning: no @return
static SideInputHandlerFactory unsupported() {
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/data/FnDataService.java:47: warning: no @param for <T>
<T> InboundDataClient receive(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/data/FnDataService.java:47: warning: no @param for inputLocation
<T> InboundDataClient receive(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/data/FnDataService.java:47: warning: no @param for coder
<T> InboundDataClient receive(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/data/FnDataService.java:47: warning: no @param for listener
<T> InboundDataClient receive(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/data/FnDataService.java:47: warning: no @return
<T> InboundDataClient receive(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/data/FnDataService.java:62: warning: no @param for <T>
<T> CloseableFnDataReceiver<WindowedValue<T>> send(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/data/FnDataService.java:62: warning: no @param for outputLocation
<T> CloseableFnDataReceiver<WindowedValue<T>> send(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/data/FnDataService.java:62: warning: no @param for coder
<T> CloseableFnDataReceiver<WindowedValue<T>> send(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/data/FnDataService.java:62: warning: no @return
<T> CloseableFnDataReceiver<WindowedValue<T>> send(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/BundleProgressHandler.java:31: warning: no @param for progress
void onProgress(ProcessBundleProgressResponse progress);
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/BundleProgressHandler.java:34: warning: no @param for response
void onCompleted(ProcessBundleResponse response);
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/BundleProgressHandler.java:37: warning: no @return
static BundleProgressHandler unsupported() {
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ControlClientPool.java:49: warning: no @return
Sink getSink();
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ControlClientPool.java:52: warning: no @return
Source getSource();
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ControlClientPool.java:62: warning: no @param for workerId
void put(String workerId, InstructionRequestHandler instructionHandler) throws Exception;
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ControlClientPool.java:62: warning: no @param for instructionHandler
void put(String workerId, InstructionRequestHandler instructionHandler) throws Exception;
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ControlClientPool.java:62: warning: no @throws for java.lang.Exception
void put(String workerId, InstructionRequestHandler instructionHandler) throws Exception;
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ControlClientPool.java:78: warning: no @param for workerId
InstructionRequestHandler take(String workerId, Duration timeout) throws Exception;
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ControlClientPool.java:78: warning: no @param for timeout
InstructionRequestHandler take(String workerId, Duration timeout) throws Exception;
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ControlClientPool.java:78: warning: no @return
InstructionRequestHandler take(String workerId, Duration timeout) throws Exception;
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/JobBundleFactoryBase.java:132: warning: no @param for controlServiceServer
abstract EnvironmentFactory getEnvironmentFactory(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/JobBundleFactoryBase.java:132: warning: no @param for loggingServiceServer
abstract EnvironmentFactory getEnvironmentFactory(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/JobBundleFactoryBase.java:132: warning: no @param for retrievalServiceServer
abstract EnvironmentFactory getEnvironmentFactory(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/JobBundleFactoryBase.java:132: warning: no @param for provisioningServiceServer
abstract EnvironmentFactory getEnvironmentFactory(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/JobBundleFactoryBase.java:132: warning: no @param for clientSource
abstract EnvironmentFactory getEnvironmentFactory(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/JobBundleFactoryBase.java:132: warning: no @param for idGenerator
abstract EnvironmentFactory getEnvironmentFactory(
^
/Users/ryan/c/beam/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/JobBundleFactoryBase.java:132: warning: no @return
abstract EnvironmentFactory getEnvironmentFactory(
^
> Task :beam-runners-apex:compileTestJava FAILED
An exception has occurred in the compiler ((version info not available)). Please file a bug against the Java compiler via the Java bug reporting page (http://bugreport.java.com) after checking the Bug Database (http://bugs.java.com) for duplicates. Include your program and the following diagnostic in your report. Thank you.
java.util.zip.ZipError: zip END header not found
at com.sun.nio.zipfs.ZipFileSystem.zerror(ZipFileSystem.java:1605)
at com.sun.nio.zipfs.ZipFileSystem.findEND(ZipFileSystem.java:1021)
at com.sun.nio.zipfs.ZipFileSystem.initCEN(ZipFileSystem.java:1030)
at com.sun.nio.zipfs.ZipFileSystem.<init>(ZipFileSystem.java:130)
at com.sun.nio.zipfs.ZipFileSystemProvider.newFileSystem(ZipFileSystemProvider.java:139)
at com.sun.tools.javac.file.JavacFileManager$ArchiveContainer.<init>(JavacFileManager.java:517)
at com.sun.tools.javac.file.JavacFileManager.getContainer(JavacFileManager.java:319)
at com.sun.tools.javac.file.JavacFileManager.list(JavacFileManager.java:715)
at com.sun.tools.javac.code.ClassFinder.list(ClassFinder.java:726)
at com.sun.tools.javac.code.ClassFinder.scanUserPaths(ClassFinder.java:659)
at com.sun.tools.javac.code.ClassFinder.fillIn(ClassFinder.java:526)
at com.sun.tools.javac.code.ClassFinder.complete(ClassFinder.java:293)
at com.sun.tools.javac.code.Symbol.complete(Symbol.java:633)
at com.sun.tools.javac.code.Symbol$PackageSymbol.members(Symbol.java:1120)
at com.sun.tools.javac.code.Symtab.listPackageModules(Symtab.java:810)
at com.sun.tools.javac.comp.Enter.visitTopLevel(Enter.java:344)
at com.sun.tools.javac.tree.JCTree$JCCompilationUnit.accept(JCTree.java:529)
at com.sun.tools.javac.comp.Enter.classEnter(Enter.java:285)
at com.sun.tools.javac.comp.Enter.classEnter(Enter.java:300)
at com.sun.tools.javac.comp.Enter.complete(Enter.java:570)
at com.sun.tools.javac.comp.Enter.main(Enter.java:554)
at com.sun.tools.javac.main.JavaCompiler.enterTrees(JavaCompiler.java:1052)
at com.sun.tools.javac.main.JavaCompiler.compile(JavaCompiler.java:923)
at com.sun.tools.javac.api.JavacTaskImpl.lambda$doCall$0(JavacTaskImpl.java:100)
at com.sun.tools.javac.api.JavacTaskImpl.handleExceptions(JavacTaskImpl.java:142)
at com.sun.tools.javac.api.JavacTaskImpl.doCall(JavacTaskImpl.java:96)
at com.sun.tools.javac.api.JavacTaskImpl.call(JavacTaskImpl.java:90)
at com.google.errorprone.BaseErrorProneCompiler.run(BaseErrorProneCompiler.java:137)
at com.google.errorprone.BaseErrorProneCompiler.run(BaseErrorProneCompiler.java:108)
at com.google.errorprone.ErrorProneCompiler.run(ErrorProneCompiler.java:118)
at com.google.errorprone.ErrorProneCompiler.compile(ErrorProneCompiler.java:65)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at net.ltgt.gradle.errorprone.ErrorProneCompiler.execute(ErrorProneCompiler.java:66)
at net.ltgt.gradle.errorprone.ErrorProneCompiler.execute(ErrorProneCompiler.java:23)
at org.gradle.api.internal.tasks.compile.NormalizingJavaCompiler.delegateAndHandleErrors(NormalizingJavaCompiler.java:86)
at org.gradle.api.internal.tasks.compile.NormalizingJavaCompiler.execute(NormalizingJavaCompiler.java:47)
at org.gradle.api.internal.tasks.compile.NormalizingJavaCompiler.execute(NormalizingJavaCompiler.java:33)
at org.gradle.api.internal.tasks.compile.CleaningJavaCompilerSupport.execute(CleaningJavaCompilerSupport.java:40)
at org.gradle.api.internal.tasks.compile.CleaningJavaCompilerSupport.execute(CleaningJavaCompilerSupport.java:27)
at org.gradle.api.tasks.compile.JavaCompile.performCompilation(JavaCompile.java:161)
at org.gradle.api.tasks.compile.JavaCompile.compile(JavaCompile.java:146)
at org.gradle.api.tasks.compile.JavaCompile.compile(JavaCompile.java:118)
at sun.reflect.GeneratedMethodAccessor1627.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.gradle.internal.reflect.JavaMethod.invoke(JavaMethod.java:73)
at org.gradle.api.internal.project.taskfactory.IncrementalTaskAction.doExecute(IncrementalTaskAction.java:50)
at org.gradle.api.internal.project.taskfactory.StandardTaskAction.execute(StandardTaskAction.java:39)
at org.gradle.api.internal.project.taskfactory.StandardTaskAction.execute(StandardTaskAction.java:26)
at org.gradle.api.internal.tasks.execution.ExecuteActionsTaskExecuter$1.run(ExecuteActionsTaskExecuter.java:131)
at org.gradle.internal.operations.DefaultBuildOperationExecutor$RunnableBuildOperationWorker.execute(DefaultBuildOperationExecutor.java:317)
at org.gradle.internal.operations.DefaultBuildOperationExecutor$RunnableBuildOperationWorker.execute(DefaultBuildOperationExecutor.java:309)
at org.gradle.internal.operations.DefaultBuildOperationExecutor.execute(DefaultBuildOperationExecutor.java:185)
at org.gradle.internal.operations.DefaultBuildOperationExecutor.run(DefaultBuildOperationExecutor.java:97)
at org.gradle.internal.operations.DelegatingBuildOperationExecutor.run(DelegatingBuildOperationExecutor.java:31)
at org.gradle.api.internal.tasks.execution.ExecuteActionsTaskExecuter.executeAction(ExecuteActionsTaskExecuter.java:120)
at org.gradle.api.internal.tasks.execution.ExecuteActionsTaskExecuter.executeActions(ExecuteActionsTaskExecuter.java:99)
at org.gradle.api.internal.tasks.execution.ExecuteActionsTaskExecuter.execute(ExecuteActionsTaskExecuter.java:77)
at org.gradle.api.internal.tasks.execution.OutputDirectoryCreatingTaskExecuter.execute(OutputDirectoryCreatingTaskExecuter.java:51)
at org.gradle.api.internal.tasks.execution.SkipCachedTaskExecuter.execute(SkipCachedTaskExecuter.java:105)
at org.gradle.api.internal.tasks.execution.SkipUpToDateTaskExecuter.execute(SkipUpToDateTaskExecuter.java:59)
at org.gradle.api.internal.tasks.execution.ResolveTaskOutputCachingStateExecuter.execute(ResolveTaskOutputCachingStateExecuter.java:54)
at org.gradle.api.internal.tasks.execution.ResolveBuildCacheKeyExecuter.execute(ResolveBuildCacheKeyExecuter.java:66)
at org.gradle.api.internal.tasks.execution.ValidatingTaskExecuter.execute(ValidatingTaskExecuter.java:59)
at org.gradle.api.internal.tasks.execution.SkipEmptySourceFilesTaskExecuter.execute(SkipEmptySourceFilesTaskExecuter.java:101)
at org.gradle.api.internal.tasks.execution.FinalizeInputFilePropertiesTaskExecuter.execute(FinalizeInputFilePropertiesTaskExecuter.java:44)
at org.gradle.api.internal.tasks.execution.CleanupStaleOutputsExecuter.execute(CleanupStaleOutputsExecuter.java:91)
at org.gradle.api.internal.tasks.execution.ResolveTaskArtifactStateTaskExecuter.execute(ResolveTaskArtifactStateTaskExecuter.java:62)
at org.gradle.api.internal.tasks.execution.SkipTaskWithNoActionsExecuter.execute(SkipTaskWithNoActionsExecuter.java:59)
at org.gradle.api.internal.tasks.execution.SkipOnlyIfTaskExecuter.execute(SkipOnlyIfTaskExecuter.java:54)
at org.gradle.api.internal.tasks.execution.ExecuteAtMostOnceTaskExecuter.execute(ExecuteAtMostOnceTaskExecuter.java:43)
at org.gradle.api.internal.tasks.execution.CatchExceptionTaskExecuter.execute(CatchExceptionTaskExecuter.java:34)
at org.gradle.api.internal.tasks.execution.EventFiringTaskExecuter$1.run(EventFiringTaskExecuter.java:51)
at org.gradle.internal.operations.DefaultBuildOperationExecutor$RunnableBuildOperationWorker.execute(DefaultBuildOperationExecutor.java:317)
at org.gradle.internal.operations.DefaultBuildOperationExecutor$RunnableBuildOperationWorker.execute(DefaultBuildOperationExecutor.java:309)
at org.gradle.internal.operations.DefaultBuildOperationExecutor.execute(DefaultBuildOperationExecutor.java:185)
at org.gradle.internal.operations.DefaultBuildOperationExecutor.run(DefaultBuildOperationExecutor.java:97)
at org.gradle.internal.operations.DelegatingBuildOperationExecutor.run(DelegatingBuildOperationExecutor.java:31)
at org.gradle.api.internal.tasks.execution.EventFiringTaskExecuter.execute(EventFiringTaskExecuter.java:46)
at org.gradle.execution.taskgraph.DefaultTaskExecutionGraph$ExecuteTaskAction.execute(DefaultTaskExecutionGraph.java:262)
at org.gradle.execution.taskgraph.DefaultTaskExecutionGraph$ExecuteTaskAction.execute(DefaultTaskExecutionGraph.java:246)
at org.gradle.execution.taskgraph.DefaultTaskPlanExecutor$TaskExecutorWorker$1.execute(DefaultTaskPlanExecutor.java:136)
at org.gradle.execution.taskgraph.DefaultTaskPlanExecutor$TaskExecutorWorker$1.execute(DefaultTaskPlanExecutor.java:130)
at org.gradle.execution.taskgraph.DefaultTaskPlanExecutor$TaskExecutorWorker.execute(DefaultTaskPlanExecutor.java:201)
at org.gradle.execution.taskgraph.DefaultTaskPlanExecutor$TaskExecutorWorker.executeWithTask(DefaultTaskPlanExecutor.java:192)
at org.gradle.execution.taskgraph.DefaultTaskPlanExecutor$TaskExecutorWorker.run(DefaultTaskPlanExecutor.java:130)
at org.gradle.internal.concurrent.ExecutorPolicy$CatchAndRecordFailures.onExecute(ExecutorPolicy.java:63)
at org.gradle.internal.concurrent.ManagedExecutorImpl$1.run(ManagedExecutorImpl.java:46)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at org.gradle.internal.concurrent.ThreadFactoryImpl$ManagedThreadRunnable.run(ThreadFactoryImpl.java:55)
at java.lang.Thread.run(Thread.java:745)
> Task :beam-sdks-java-harness:compileTestJava FAILED
An exception has occurred in the compiler ((version info not available)). Please file a bug against the Java compiler via the Java bug reporting page (http://bugreport.java.com) after checking the Bug Database (http://bugs.java.com) for duplicates. Include your program and the following diagnostic in your report. Thank you.
java.util.zip.ZipError: zip END header not found
at com.sun.nio.zipfs.ZipFileSystem.zerror(ZipFileSystem.java:1605)
at com.sun.nio.zipfs.ZipFileSystem.findEND(ZipFileSystem.java:1021)
at com.sun.nio.zipfs.ZipFileSystem.initCEN(ZipFileSystem.java:1030)
at com.sun.nio.zipfs.ZipFileSystem.<init>(ZipFileSystem.java:130)
at com.sun.nio.zipfs.ZipFileSystemProvider.newFileSystem(ZipFileSystemProvider.java:139)
at com.sun.tools.javac.file.JavacFileManager$ArchiveContainer.<init>(JavacFileManager.java:517)
at com.sun.tools.javac.file.JavacFileManager.getContainer(JavacFileManager.java:319)
at com.sun.tools.javac.file.JavacFileManager.list(JavacFileManager.java:715)
at com.sun.tools.javac.code.ClassFinder.list(ClassFinder.java:726)
at com.sun.tools.javac.code.ClassFinder.scanUserPaths(ClassFinder.java:659)
at com.sun.tools.javac.code.ClassFinder.fillIn(ClassFinder.java:526)
at com.sun.tools.javac.code.ClassFinder.complete(ClassFinder.java:293)
at com.sun.tools.javac.code.Symbol.complete(Symbol.java:633)
at com.sun.tools.javac.code.Symbol$PackageSymbol.members(Symbol.java:1120)
at com.sun.tools.javac.code.Symtab.listPackageModules(Symtab.java:810)
at com.sun.tools.javac.comp.Enter.visitTopLevel(Enter.java:344)
at com.sun.tools.javac.tree.JCTree$JCCompilationUnit.accept(JCTree.java:529)
at com.sun.tools.javac.comp.Enter.classEnter(Enter.java:285)
at com.sun.tools.javac.comp.Enter.classEnter(Enter.java:300)
at com.sun.tools.javac.comp.Enter.complete(Enter.java:570)
at com.sun.tools.javac.comp.Enter.main(Enter.java:554)
at com.sun.tools.javac.main.JavaCompiler.enterTrees(JavaCompiler.java:1052)
at com.sun.tools.javac.main.JavaCompiler.compile(JavaCompiler.java:923)
at com.sun.tools.javac.api.JavacTaskImpl.lambda$doCall$0(JavacTaskImpl.java:100)
at com.sun.tools.javac.api.JavacTaskImpl.handleExceptions(JavacTaskImpl.java:142)
at com.sun.tools.javac.api.JavacTaskImpl.doCall(JavacTaskImpl.java:96)
at com.sun.tools.javac.api.JavacTaskImpl.call(JavacTaskImpl.java:90)
at com.google.errorprone.BaseErrorProneCompiler.run(BaseErrorProneCompiler.java:137)
at com.google.errorprone.BaseErrorProneCompiler.run(BaseErrorProneCompiler.java:108)
at com.google.errorprone.ErrorProneCompiler.run(ErrorProneCompiler.java:118)
at com.google.errorprone.ErrorProneCompiler.compile(ErrorProneCompiler.java:65)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at net.ltgt.gradle.errorprone.ErrorProneCompiler.execute(ErrorProneCompiler.java:66)
at net.ltgt.gradle.errorprone.ErrorProneCompiler.execute(ErrorProneCompiler.java:23)
at org.gradle.api.internal.tasks.compile.NormalizingJavaCompiler.delegateAndHandleErrors(NormalizingJavaCompiler.java:86)
at org.gradle.api.internal.tasks.compile.NormalizingJavaCompiler.execute(NormalizingJavaCompiler.java:47)
at org.gradle.api.internal.tasks.compile.NormalizingJavaCompiler.execute(NormalizingJavaCompiler.java:33)
at org.gradle.api.internal.tasks.compile.CleaningJavaCompilerSupport.execute(CleaningJavaCompilerSupport.java:40)
at org.gradle.api.internal.tasks.compile.CleaningJavaCompilerSupport.execute(CleaningJavaCompilerSupport.java:27)
at org.gradle.api.tasks.compile.JavaCompile.performCompilation(JavaCompile.java:161)
at org.gradle.api.tasks.compile.JavaCompile.compile(JavaCompile.java:146)
at org.gradle.api.tasks.compile.JavaCompile.compile(JavaCompile.java:118)
at sun.reflect.GeneratedMethodAccessor1627.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.gradle.internal.reflect.JavaMethod.invoke(JavaMethod.java:73)
at org.gradle.api.internal.project.taskfactory.IncrementalTaskAction.doExecute(IncrementalTaskAction.java:50)
at org.gradle.api.internal.project.taskfactory.StandardTaskAction.execute(StandardTaskAction.java:39)
at org.gradle.api.internal.project.taskfactory.StandardTaskAction.execute(StandardTaskAction.java:26)
at org.gradle.api.internal.tasks.execution.ExecuteActionsTaskExecuter$1.run(ExecuteActionsTaskExecuter.java:131)
at org.gradle.internal.operations.DefaultBuildOperationExecutor$RunnableBuildOperationWorker.execute(DefaultBuildOperationExecutor.java:317)
at org.gradle.internal.operations.DefaultBuildOperationExecutor$RunnableBuildOperationWorker.execute(DefaultBuildOperationExecutor.java:309)
at org.gradle.internal.operations.DefaultBuildOperationExecutor.execute(DefaultBuildOperationExecutor.java:185)
at org.gradle.internal.operations.DefaultBuildOperationExecutor.run(DefaultBuildOperationExecutor.java:97)
at org.gradle.internal.operations.DelegatingBuildOperationExecutor.run(DelegatingBuildOperationExecutor.java:31)
at org.gradle.api.internal.tasks.execution.ExecuteActionsTaskExecuter.executeAction(ExecuteActionsTaskExecuter.java:120)
at org.gradle.api.internal.tasks.execution.ExecuteActionsTaskExecuter.executeActions(ExecuteActionsTaskExecuter.java:99)
at org.gradle.api.internal.tasks.execution.ExecuteActionsTaskExecuter.execute(ExecuteActionsTaskExecuter.java:77)
at org.gradle.api.internal.tasks.execution.OutputDirectoryCreatingTaskExecuter.execute(OutputDirectoryCreatingTaskExecuter.java:51)
at org.gradle.api.internal.tasks.execution.SkipCachedTaskExecuter.execute(SkipCachedTaskExecuter.java:105)
at org.gradle.api.internal.tasks.execution.SkipUpToDateTaskExecuter.execute(SkipUpToDateTaskExecuter.java:59)
at org.gradle.api.internal.tasks.execution.ResolveTaskOutputCachingStateExecuter.execute(ResolveTaskOutputCachingStateExecuter.java:54)
at org.gradle.api.internal.tasks.execution.ResolveBuildCacheKeyExecuter.execute(ResolveBuildCacheKeyExecuter.java:66)
at org.gradle.api.internal.tasks.execution.ValidatingTaskExecuter.execute(ValidatingTaskExecuter.java:59)
at org.gradle.api.internal.tasks.execution.SkipEmptySourceFilesTaskExecuter.execute(SkipEmptySourceFilesTaskExecuter.java:101)
at org.gradle.api.internal.tasks.execution.FinalizeInputFilePropertiesTaskExecuter.execute(FinalizeInputFilePropertiesTaskExecuter.java:44)
at org.gradle.api.internal.tasks.execution.CleanupStaleOutputsExecuter.execute(CleanupStaleOutputsExecuter.java:91)
at org.gradle.api.internal.tasks.execution.ResolveTaskArtifactStateTaskExecuter.execute(ResolveTaskArtifactStateTaskExecuter.java:62)
at org.gradle.api.internal.tasks.execution.SkipTaskWithNoActionsExecuter.execute(SkipTaskWithNoActionsExecuter.java:59)
at org.gradle.api.internal.tasks.execution.SkipOnlyIfTaskExecuter.execute(SkipOnlyIfTaskExecuter.java:54)
at org.gradle.api.internal.tasks.execution.ExecuteAtMostOnceTaskExecuter.execute(ExecuteAtMostOnceTaskExecuter.java:43)
at org.gradle.api.internal.tasks.execution.CatchExceptionTaskExecuter.execute(CatchExceptionTaskExecuter.java:34)
at org.gradle.api.internal.tasks.execution.EventFiringTaskExecuter$1.run(EventFiringTaskExecuter.java:51)
at org.gradle.internal.operations.DefaultBuildOperationExecutor$RunnableBuildOperationWorker.execute(DefaultBuildOperationExecutor.java:317)
at org.gradle.internal.operations.DefaultBuildOperationExecutor$RunnableBuildOperationWorker.execute(DefaultBuildOperationExecutor.java:309)
at org.gradle.internal.operations.DefaultBuildOperationExecutor.execute(DefaultBuildOperationExecutor.java:185)
at org.gradle.internal.operations.DefaultBuildOperationExecutor.run(DefaultBuildOperationExecutor.java:97)
at org.gradle.internal.operations.DelegatingBuildOperationExecutor.run(DelegatingBuildOperationExecutor.java:31)
at org.gradle.api.internal.tasks.execution.EventFiringTaskExecuter.execute(EventFiringTaskExecuter.java:46)
at org.gradle.execution.taskgraph.DefaultTaskExecutionGraph$ExecuteTaskAction.execute(DefaultTaskExecutionGraph.java:262)
at org.gradle.execution.taskgraph.DefaultTaskExecutionGraph$ExecuteTaskAction.execute(DefaultTaskExecutionGraph.java:246)
at org.gradle.execution.taskgraph.DefaultTaskPlanExecutor$TaskExecutorWorker$1.execute(DefaultTaskPlanExecutor.java:136)
at org.gradle.execution.taskgraph.DefaultTaskPlanExecutor$TaskExecutorWorker$1.execute(DefaultTaskPlanExecutor.java:130)
at org.gradle.execution.taskgraph.DefaultTaskPlanExecutor$TaskExecutorWorker.execute(DefaultTaskPlanExecutor.java:201)
at org.gradle.execution.taskgraph.DefaultTaskPlanExecutor$TaskExecutorWorker.executeWithTask(DefaultTaskPlanExecutor.java:192)
at org.gradle.execution.taskgraph.DefaultTaskPlanExecutor$TaskExecutorWorker.run(DefaultTaskPlanExecutor.java:130)
at org.gradle.internal.concurrent.ExecutorPolicy$CatchAndRecordFailures.onExecute(ExecutorPolicy.java:63)
at org.gradle.internal.concurrent.ManagedExecutorImpl$1.run(ManagedExecutorImpl.java:46)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at org.gradle.internal.concurrent.ThreadFactoryImpl$ManagedThreadRunnable.run(ThreadFactoryImpl.java:55)
at java.lang.Thread.run(Thread.java:745)
> Task :beam-runners-java-fn-execution:javadoc
100 warnings
> Task :beam-runners-samza:compileJava
Note: Some input files use or override a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
> Task :beam-runners-flink_2.11:compileJava
Note: Some input files use or override a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
> Task :beam-runners-direct-java:compileJava
Note: Some input files use or override a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
FAILURE: Build completed with 2 failures.
1: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task ':beam-runners-apex:compileTestJava'.
> Compilation failed with exit code 1; see the compiler error output for details.
* Try:
Run with --stacktrace option to get the stack trace. Run with --info or --debug option to get more log output. Run with --scan to get full insights.
==============================================================================
2: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task ':beam-sdks-java-harness:compileTestJava'.
> Compilation failed with exit code 1; see the compiler error output for details.
* Try:
Run with --stacktrace option to get the stack trace. Run with --info or --debug option to get more log output. Run with --scan to get full insights.
==============================================================================
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
See https://docs.gradle.org/4.8/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 43s
438 actionable tasks: 61 executed, 377 up-to-date
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment