This is an automated email from the ASF dual-hosted git repository.
damccorm pushed a change to branch users/damccorm/debug-spark-issues
in repository https://gitbox.apache.org/repos/asf/beam.git
from 8a27d9c8398 disable cache
add c4b2f19dd91 Reapply "Add pipeline option to force GBEK (Java) (#36346)"
No new revisions were added by this update.
Summary of changes:
.github/trigger_files/beam_PostCommit_Java.json | 2 +-
.../beam_PostCommit_Java_DataflowV1.json | 2 +-
.../beam_PostCommit_Java_DataflowV2.json | 6 +-
.../dataflow/internal/DataflowGroupByKey.java | 52 ++++++-
.../resources/beam/checkstyle/suppressions.xml | 2 +
.../apache/beam/sdk/options/PipelineOptions.java | 35 +++++
.../beam/sdk/transforms/GroupByEncryptedKey.java | 34 +++-
.../org/apache/beam/sdk/transforms/GroupByKey.java | 34 ++++
.../java/org/apache/beam/sdk/util/GcpSecret.java | 9 ++
.../main/java/org/apache/beam/sdk/util/Secret.java | 49 ++++++
.../util/construction/GroupByKeyTranslation.java | 14 ++
.../util/construction/PTransformTranslation.java | 2 +
...upByEncryptedKeyTest.java => GroupByKeyIT.java} | 173 +++++++++++----------
.../apache/beam/sdk/transforms/GroupByKeyTest.java | 106 +++++++++++++
.../java/org/apache/beam/sdk/util/SecretTest.java | 67 ++++++++
15 files changed, 491 insertions(+), 96 deletions(-)
copy
sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/{GroupByEncryptedKeyTest.java
=> GroupByKeyIT.java} (54%)
create mode 100644
sdks/java/core/src/test/java/org/apache/beam/sdk/util/SecretTest.java
