Skip to content

Conversation

@shehzaadn-vd
Copy link
Contributor

This PR was split from #13686 to isolate sdks/java/extensions/sql changes.


Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily:

  • Choose reviewer(s) and mention them in a comment (R: @username).
  • Format the pull request title like [BEAM-XXX] Fixes bug in ApproximateQuantiles, where you replace BEAM-XXX with the appropriate JIRA issue, if applicable. This will automatically link the pull request to the issue.
  • Update CHANGES.md with noteworthy changes.
  • If this contribution is large, please file an Apache Individual Contributor License Agreement.

See the Contributor Guide for more tips on how to make review process smoother.

Post-Commit Tests Status (on master branch)

Lang SDK Dataflow Flink Samza Spark Twister2
Go Build Status --- Build Status --- Build Status ---
Java Build Status Build Status
Build Status
Build Status
Build Status
Build Status
Build Status
Build Status
Build Status Build Status
Build Status
Build Status
Build Status
Python Build Status
Build Status
Build Status
Build Status
Build Status
Build Status
Build Status
Build Status
--- Build Status ---
XLang Build Status Build Status Build Status --- Build Status ---

Pre-Commit Tests Status (on master branch)

--- Java Python Go Website Whitespace Typescript
Non-portable Build Status Build Status
Build Status
Build Status
Build Status
Build Status Build Status Build Status Build Status
Portable --- Build Status --- --- --- ---

See .test-infra/jenkins/README for trigger phrase, status and link of all Jenkins jobs.

GitHub Actions Tests Status (on master branch)

Build python source distribution and wheels
Python tests
Java tests

See CI.md for more information about GitHub Actions CI.

@shehzaadn-vd
Copy link
Contributor Author

R: @ibzib

Copy link

@ibzib ibzib left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

General note: if the plugin reports that a declared compile dependency is unused, there are basically three options to fix it.

  1. Keep it as compile and add permitUnusedDeclared.
  2. Change it to runtimeOnly.
  3. Remove it entirely.

Of these, 1. is the safest, since it doesn't change the build at all. 2. is slightly more risky, I am currently investigating a bug with this approach that might have slipped past our tests. 3. is the most dangerous, and should only be done if we are absolutely sure the dependency is never used at all, which is hard to verify.

cc: @apilloud

compile library.java.slf4j_api
compile library.java.vendored_guava_26_0_jre
compile project(path: ":sdks:java:core", configuration: "shadow")
compile "com.google.api.grpc:proto-google-cloud-datacatalog-v1beta1:0.32.1"
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

We should probably used the bom for this, like we discussed on the PR for GCP IO.

Copy link
Contributor Author

@shehzaadn-vd shehzaadn-vd Feb 1, 2021

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@ibzib the declaration in BeamModulePlugin is
google_cloud_datacatalog_v1beta1 : "com.google.cloud:google-cloud-datacatalog", // google_cloud_platform_libraries_bom sets version
whereas what's used here is:
"com.google.api.grpc:proto-google-cloud-datacatalog-v1beta1:0.32.1"
which doesn't exist in the BOM
https://storage.googleapis.com/java-cloud-bom-dashboard/com.google.cloud/google-cloud-bom/0.147.0/index.html
or maybe there's another BOM for com.google.api.*?

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Cancel the above comment. I see there is a layer of dependencies that can also be referred to using the BOM.

@codecov
Copy link

codecov bot commented Jan 29, 2021

Codecov Report

Merging #13830 (3835496) into master (c137e88) will increase coverage by 0.01%.
The diff coverage is n/a.

Impacted file tree graph

@@            Coverage Diff             @@
##           master   #13830      +/-   ##
==========================================
+ Coverage   82.97%   82.99%   +0.01%     
==========================================
  Files         469      469              
  Lines       58300    58330      +30     
==========================================
+ Hits        48377    48413      +36     
+ Misses       9923     9917       -6     
Impacted Files Coverage Δ
...srcs/sdks/python/apache_beam/io/localfilesystem.py
...he_beam/portability/api/standard_window_fns_pb2.py
.../srcs/sdks/python/apache_beam/portability/utils.py
...ks/python/apache_beam/runners/worker/data_plane.py
.../python/apache_beam/io/gcp/datastore/v1new/util.py
...on/apache_beam/runners/portability/flink_runner.py
...hon/apache_beam/runners/worker/worker_pool_main.py
...ache_beam/examples/cookbook/datastore_wordcount.py
...ks/python/apache_beam/io/gcp/pubsub_it_pipeline.py
...testing/benchmarks/nexmark/models/nexmark_model.py
... and 928 more

Continue to review full report at Codecov.

Legend - Click here to learn more
Δ = absolute <relative> (impact), ø = not affected, ? = missing data
Powered by Codecov. Last update c137e88...3835496. Read the comment docs.

@shehzaadn-vd shehzaadn-vd marked this pull request as draft February 6, 2021 13:57
@shehzaadn-vd
Copy link
Contributor Author

@ibzib I'm converting this to draft until PR #13910 is merged (hopefully that's a quick merge :-))

@shehzaadn-vd shehzaadn-vd marked this pull request as ready for review February 10, 2021 08:10
@shehzaadn-vd
Copy link
Contributor Author

@ibzib, requesting a review.

I've introduced permitUnusedDeclared where needed and the mongodb_java_driver is now used here as well.

compile library.java.slf4j_api
compile library.java.vendored_guava_26_0_jre
compile library.java.proto_google_common_protos // Interfaces with ZetaSQL use this
permitUnusedDeclared "com.google.api.grpc:proto-google-common-protos:2.0.1" // BEAM-11761
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

This was added twice.

Also, if you're using the library.java version in the compile statement, you should also use it in the corresponding permitUnusedDeclared.

Copy link
Contributor Author

@shehzaadn-vd shehzaadn-vd Feb 13, 2021

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I couldn't get permitUnusedDeclared to work with the library.java variable when the version is coming from the bom. It seems permitUnusedDeclared sees a blank version and fails. See #13791 (comment)

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@ibzib Regarding your comment about this being added twice, they are actually two different dependencies:
"com.google.api.grpc:proto-google-common-protos:2.0.1"
"com.google.api.grpc:grpc-google-common-protos:2.0.1"

It's possible both aren't really needed, but I think resolving that is probably a separate issue.

Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Regarding your comment about this being added twice, they are actually two different dependencies:

Oops, you're right. I didn't read carefully.

I couldn't get permitUnusedDeclared to work with the library.java variable when the version is coming from the bom. It seems permitUnusedDeclared sees a blank version and fails.

We should be able to work around this by resolving the bom versions before running analyzeClassesDependencies. But I'm not sure exactly how. Filed BEAM-11823 to track.

Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@shehzaadn-vd we can fix the issue with blank versions by using enforcedPlatform: ibzib@ef12251

@shehzaadn-vd
Copy link
Contributor Author

@ibzib please see if this is good to go. thanks!

Copy link

@ibzib ibzib left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

Can you please squash the commit history before merging?

@ibzib ibzib merged commit 5566098 into apache:master Feb 25, 2021
kennknowles added a commit to kennknowles/beam that referenced this pull request Mar 4, 2021
…gger

* github/master: (123 commits)
  [BEAM-11899] Bump commons-pool to 2.8.1 and bump commons-dbcp to 2.8.0, Because there is a library dependency
  Update pillars.yaml (apache#14142)
  [BEAM-10632] Checkerframework nullness cleanups (apache#14107)
  [BEAM-11213] Instantiate SparkListenerApplicationStart in a Spark 3 compatible way
  Fix typos for excluding testMergingCustomWindowsWithoutCustomWindowTypes
  Specify the time resolution for TestStreamPayload.
  [BEAM-10961] Enable strict depdency checking for sdks/java/extensions/euphoria (second attempt)
  [BEAM-11848] Store Docker images in a variable for consistency.
  Splitting old Go Precommit and new ULR integration test precommit.
  Moving runner imports out of ptest.
  Add the TO_STRING capability to Java and Python
  [BEAM-11848] Fix Docker images list.
  jdbc python supported Dataflow runner (apache#13960)
  Adding a warning to use multi-workers on FnApiRunner
  Fix legend for Python Directrunner microbenchmarks
  [BEAM-11740] Estimate PCollection byte size
  [BEAM-10961] enable strict dependency checking for sdks/java/extensions/zetasketch (apache#14093)
  Map Dataflow JOB_STATE_CANCELLING to Beam RUNNING state
  [BEAM-11833] Fix reported watermark after restriction split in UnboundedSourceAsSDFRestrictionTracker
  [BEAM-10761] add reference to BEAM-11761
  [BEAM-10961] enable strict dependency checking for flink/job-server
  Exclude MapState example integration tests from Dataflow runner v2 suite
  Remove InvalidWindows from Java SDK, instead track "already merged" bit
  Fix checkstyle in watermark latency benchmark
  Fix compile breakage in WindmillStateInternals
  Improve test, error on ALREADY_MERGED.
  [BEAM-10961] Strict dependency checking for sdks/java/io/gcp (apache#13791)
  Initial watermark latency benchmark
  Attempting improvements on DirectRunner Python dash
  [BEAM-10961] enable strict dependency checking for sdks/java/extensions/google-cloud-platform-core (apache#14084)
  Merge pull request apache#13802: [BEAM-1474]. Adding MapState and SetState support for the Dataflow runner
  Remove some false positives
  Remove nullness warning suppression
  [BEAM-11861] Add methods to explicitly provide coder for ParquetIO's Parse and ParseFiles (apache#14078)
  [BEAM-11531] Use pandas 1.2 for python>=3.7 (apache#14099)
  [BEAM-10961] add reference to BEAM-11761
  [BEAM-10961] add explicit compile for auto_value_annotations in sdks/extensions/ml/build.gradle
  Attempting improvements on DirectRunner Python dash
  Recognize JOB_STATE_PENDING from Dataflow and map to RUNNING
  never run checkerframework on tests
  Puts more expensive BQ empty table check to the right of the 'and' condition (apache#14094)
  Use the windowing strategy of the input, not output, PCollection of GBK.
  Do not stage dataflow worker jar when use runner_v2.
  [BEAM-11870] Re-raise underlying exception for InvocationTargetException (apache#14098)
  [BEAM-11778] Create a wrapper for ZetaSQL catalog and refactor accordingly. (apache#13934)
  [BEAM-9378] Add ignored tests which fail in various ways when querying nested structures (apache#14077)
  Merge Fn API and runner v2 configurations for DataflowRunner
  Fix up! formatting
  Add validate runner test for testing custom merging windows fn without custom window types
  Revert "Revert "[BEAM-2914] Add portable merging window support to Python. (apache#12995)""
  [BEAM-10961] fix stray reordering of lines
  [BEAM-10961] enable strict dependency checking for sdks/java/extensions/sorter
  [BEAM-10961] enable strict dependency checking for sdks/java/extensions/sketching
  [BEAM-10961] enable strict dependency checking for sdks/java/extensions/schemaio-expansion-service
  [BEAM-10961] enable strict dependency checking for sdks/java/extensions/protobuf
  [BEAM-10961] enable strict dependency checking for sdks/java/extensions/ml
  [BEAM-10961] enable strict dependency checking for sdks/java/extensions/kyro
  [BEAM-10961] enable strict dependency checking for sdks/java/extensions/join-library
  [BEAM-10961] undo line moves (originally intended for alphabeticization)
  [BEAM-10961] enable strict dependency checking for sdks/java/extensions/jackson
  [BEAM-10961] Enable strict dependency checking on sdks/java/extensions/sql (apache#13830)
  [BEAM-10961] enable strict dependency checking for sdks/java/extensions/euphoria
  [BEAM-10961] enable strict dependency checking for sdks/java/io/parquet (apache#14062)
  [BEAM-10961] enable strict dependency checking for sdks/java/io/thrift (apache#14066)
  Refactor ZetaSqlDialectSpecTest and add some passing tests. (apache#14080)
  [BEAM-11864] Use objects.equals instead of raw comparison
  [BEAM-11707] Change WindmillStateCache cache invalidation to be based upon reference invalidation instead of expensive set management. Reduce operations of shared cache by caching per-key object sets locally and flushing as groups to shared cache. Remove byte tracking which could be racy based upon background evictions in favor of just iterating for rendering the status page. This also lets us capture more stats.
  [BEAM-11730] Reduce context switching overhead for appliance reads by issuing reads directly from calling threads in the case that there is no reads being queued.
  Fix preview
  Show string from Dataflow service when job terminates in unrecognized state
  Log a warning when Dataflow returns an unrecognized state
  Merge pull request apache#14033 from [BEAM-11408] Integrate Python BigQuery sink with GroupIntoBatches
  Remove SYNCHRONIZED_PROCESSING_TIME from model proto
  Remove use of model SYNCHRONIZED_PROCESSING_TIME
  Merge redundant model feature columns in capability matrix
  Remove MapReduce runner from capability matrix, because it is on a branch and unreleased
  Remove JStorm runner from capability matrix, because it is on a branch and unreleased
  Remove retractions from capability matrix, because they do not exist yet
  Remove metadata-driven triggers from capability matrix, because they do not exist
  [BEAM-10937] Add Tour of Beam page (apache#13747)
  [BEAM-11344] Apply "Become a Committer" changes from Website Revamp (apache#14036)
  Merge pull request apache#14046 from [BEAM-11791] Adding a microbenchmark for TestStream
  Returning successful writes in FhirIO.Write.Result (apache#14034)
  Fixup
  [BEAM-10961] enable strict dependency checking for sdks/java/io/file-based-io-tests (apache#14052)
  [BEAM-10961] enable strict dependency checking for sdks/java/io/contextualtextio (apache#14049)
  [BEAM-10961] enable strict dependency checking for sdks/java/io/kinesis (apache#14058)
  [BEAM-10961] enable strict dependency checking for sdks/java/io/bigquery-io-perf-tests (apache#14048)
  [BEAM-10961] enable strict dependency checking for sdks/java/io/elasticsearch (apache#14050)
  [BEAM-10961] enable strict dependency checking for sdks/java/io/expansion-service (apache#14051)
  [BEAM-10961] enable strict dependency checking for sdks/java/io/jdbc (apache#14055)
  [BEAM-10961] enable strict dependency checking for sdks/java/io/jms (apache#14056)
  [BEAM-10961] enable strict dependency checking for sdks/java/io/kafka (apache#14057)
  [BEAM-10961] enable strict dependency checking for sdks/java/io/hcatalog (apache#14053)
  [BEAM-11859] Fixed bug in python S3 IO
  [BEAM-10114] Fix PerSubscriptionPartitionSdf to not rely on the presence of BundleFinalizer
  [BEAM-10114] Fix PerSubscriptionPartitionSdf to not rely on the presence of BundleFinalizer
  [BEAM-10961] fix spacing
  [BEAM-10961] enable strict dependency checking for sdks/java/io/xml
  [BEAM-10961] enable strict dependency checking for sdks/java/io/tika
  ...
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants