Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Test pr wh #64

Open
wants to merge 10,000 commits into
base: pabloem-patch-1
Choose a base branch
from
Open
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
10000 commits
Select commit Hold shift + click to select a range
cef0cf7
Merge pull request #24718 Add a couple of well-known Google propertie…
robertwb Dec 21, 2022
0917978
Refactor focusing to contextLine (#24674)
alexeyinkin Dec 21, 2022
b757ad0
Support SqlTypes Date in AvroUtils (#24756)
Abacn Dec 22, 2022
cb31ea2
Fix SingleStoreIO performance test job (#24753)
Abacn Dec 22, 2022
b877a66
Fix a small wrong url link in notebook (#24746)
yyy1000 Dec 22, 2022
46c7778
Fix POM of beam-sdks-java-core (closes #24675)
Dec 22, 2022
3b9ab77
Exclude MultimapState related tests in Dataflow legacy worker validat…
zhengbuqian Dec 22, 2022
ce5fcac
[Website] delete 404 links #24745 (#24744)
bullet03 Dec 22, 2022
3f67b2c
Merge pull request #24635: [Website] update links with 404 status code
aromanenko-dev Dec 22, 2022
f80ac00
[Release Tasks Migration] - Git Tag Workflow (#24418)
MarcoRob Dec 22, 2022
eb23b0a
Merge pull request #24760: Fix POM of beam-sdks-java-core
aromanenko-dev Dec 22, 2022
94c6212
Change Point Analysis (#23931)
AnandInguva Dec 22, 2022
97d9655
change examples to licensed ones with mentions of autors and licenses…
PhilippeMoussalli Dec 22, 2022
9810ff8
Implement PubsubWriteSchemaTransformProvider (#24443)
damondouglas Dec 22, 2022
28afd03
[CdapIO] Complete examples for CDAP Hubspot plugins (#24568)
Amar3tto Dec 22, 2022
2b6d9dc
Fix Permission denied error build beam locally (#24766)
Abacn Dec 22, 2022
baa8910
fix typo: UnmarshallWindowFn should be UnmarshalWindowFn (#24771)
zhenglin-charlie-li Dec 23, 2022
820839f
Remove slow review label after processing commands to avoid race (#24…
damccorm Dec 23, 2022
873e0d0
[#24292] Create Avro extension for Java SDK
aromanenko-dev Nov 18, 2022
8b532db
Address the review comments
aromanenko-dev Dec 22, 2022
150877e
Apply #24454 changes
aromanenko-dev Dec 26, 2022
d72fdec
[BigQueryIO] Don't update schema of destination table when no schema …
ahmedabu98 Dec 27, 2022
ffdd8d4
[Playground] Python multifile examples (#24751)
eantyshev Dec 27, 2022
5994644
[CdapIO] Complete examples for CDAP Salesforce plugins (#24567)
Amar3tto Dec 27, 2022
44c9d02
Make go vet and go staticcheck output visible in CI (#24786)
damccorm Dec 27, 2022
96f4391
[Go SDK] Fix multimap support for the direct runner (#24775)
camphillips22 Dec 27, 2022
bcfdb7b
[#24515] Ensure that Go pipelines on Dataflow are not allowed to opt …
lukecwik Dec 27, 2022
07b4329
Update Java portable container for Dataflow (#24791)
lukecwik Dec 28, 2022
46a12bf
[BigQuery] Extend timestamp precision to microseconds when writing wi…
ahmedabu98 Dec 28, 2022
a43b834
[Website] update check links, catch prod & staging links
bullet03 Jul 11, 2022
e28f6f7
[Spark Dataset runner] Trigger evaluation using write noop rather tha…
Dec 28, 2022
994f733
Merge pull request #22221: [Website] update check-links
aromanenko-dev Dec 28, 2022
bab773f
Merge pull request #24294: Create Avro extension for Java SDK
aromanenko-dev Dec 28, 2022
04694d8
Install sklearn < 1.20.0 for sklearn postcommit tests (#24788)
AnandInguva Dec 28, 2022
645bf35
[Spark Dataset runner] Skip unconsumed additional outputs of ParDo.Mu…
Dec 28, 2022
1e763ad
[Go SDK]: MongoDB IO connector (#24663)
johannaojeling Dec 28, 2022
1773067
Better naming and inference for PythonCallable. (#24735)
robertwb Dec 28, 2022
208a14e
[Spark Dataset runner] Reuse SparkSession when testing using class ru…
Dec 29, 2022
7c736e2
[#24515] Ensure that portable Java pipelines on Dataflow are not able…
lukecwik Dec 29, 2022
5b80a81
24802 fix missing test resources (#24803)
damondouglas Dec 29, 2022
c8bf5d5
Add Python xlang KafkaIO performance test (#24633)
Abacn Dec 29, 2022
598324a
Shard python precommit (#24204)
damccorm Dec 29, 2022
c5c5b35
Merge pull request #23975 Implement sibling protocol for Typescript.
robertwb Dec 29, 2022
5ab768b
Add gradle files for typescript containers and update the version info.
robertwb Dec 29, 2022
80de3ef
Refactor integration tests to use internal containers package (#24823)
johannaojeling Dec 29, 2022
c38074a
Various cleanups to the typescript SDK:
robertwb Dec 29, 2022
5911ea2
Fix issue with typescript sibling sdks.
robertwb Dec 29, 2022
ba3dcd1
[#24789][Go SDK] Fix Minor race conditions (#24808)
lostluck Dec 29, 2022
4f96e35
Add timeout to cross-language tests.
robertwb Dec 29, 2022
a67fc24
npm install before build
robertwb Dec 29, 2022
3bd5f78
Format go file.
robertwb Dec 29, 2022
3f28d55
Merge pull request #24825 Various cleanups to the typescript SDK.
robertwb Dec 29, 2022
0bba439
[#24789] Spot fix fullvalue wrapping for SDF. (#24826)
lostluck Dec 29, 2022
889fd8b
Merge pull request #24827 Add gradle files for typescript containers …
robertwb Dec 30, 2022
db1f9d2
Add thread prefix for StreamingDataflowWorker work executor
scwhittle Dec 13, 2022
ad72bac
Fix Cassandra read bug when user query has no where clause (fixes #24…
lpmarques Dec 30, 2022
3ee5b86
Retry create database in InfluxDbIOIT (#24800)
Abacn Dec 30, 2022
39a348e
BEAM-13261 added max connections setting
pas725 Jan 1, 2023
0f423dd
Merge pull request #24747: [Website] update links from absolute to re…
aromanenko-dev Jan 2, 2023
0d835cd
Support SqlTypes Date in AvroUtils (sync)
aromanenko-dev Jan 2, 2023
37358ff
Merge pull request #24854: Support SqlTypes Date in AvroUtils (sync)
aromanenko-dev Jan 2, 2023
b802c02
Revert "Shard python precommit (#24204)" (#24855)
damccorm Jan 3, 2023
a4cf26f
[Spark Dataset runner] Fix initialization of metrics accumulator on d…
Jan 3, 2023
1b1acb0
Improve error message (#24843)
zhenglin-charlie-li Jan 3, 2023
1fa9782
Playground Example CI fix for 24807 (#24819)
Jan 3, 2023
803bfa6
Bump github.com/tetratelabs/wazero from 1.0.0-pre.4 to 1.0.0-pre.7 in…
dependabot[bot] Jan 3, 2023
6d058d9
Fix beam_CleanUpGCPResources job (#24770)
Abacn Jan 3, 2023
f9fd293
Set DELETE_BEFORE_DAY in accordance with release period (#24867)
Abacn Jan 3, 2023
9a22bf6
adding parameters flag to support schema based transforms (#24864)
Jan 3, 2023
2898db9
Fix SQLIO Performance Test (#24824)
Abacn Jan 3, 2023
0b8f0b4
Reduce redundant Get API call when creating bq temp dataset (#24831)
Abacn Jan 3, 2023
c46c6d3
Disable sonarqube cron job (#24769)
Abacn Jan 4, 2023
e1daf36
Saving empty output and log precompiled objects for consistency (#24877)
Jan 4, 2023
cf15a80
Playground runners scala update (#24873)
Jan 4, 2023
0a17788
[#24801] ValueState.read() should specify returning null since it wil…
lukecwik Jan 4, 2023
12f1072
Add links to colab/github repo in notebook (#24886)
damccorm Jan 4, 2023
9cd76ea
Remove trailing space breaking website blocks (#24875)
damccorm Jan 4, 2023
a6e11d6
Bump google.golang.org/api from 0.105.0 to 0.106.0 in /sdks (#24891)
dependabot[bot] Jan 5, 2023
1f34e8d
[#21391]Increase unit testing coverage in the exec package (#24772)
zhenglin-charlie-li Jan 5, 2023
e23b373
Load categories from BEAM_EXAMPLE_CATEGORIES in checker.py (#24900)
TSultanov Jan 5, 2023
c495122
Reduce lock contention for metrics hashName hasher (#24881)
shanemhansen Jan 5, 2023
f761b9d
Bump golang.org/x/text from 0.5.0 to 0.6.0 in /sdks (#24889)
dependabot[bot] Jan 5, 2023
037e9ad
Bump golang.org/x/sys from 0.3.0 to 0.4.0 in /sdks (#24890)
dependabot[bot] Jan 5, 2023
884539b
Bump github.com/aws/aws-sdk-go from 1.30.19 to 1.33.0 in /sdks (#24896)
dependabot[bot] Jan 5, 2023
174f93b
Bump golang.org/x/net from 0.4.0 to 0.5.0 in /sdks (#24892)
dependabot[bot] Jan 5, 2023
691e247
Print logical identifier in FieldType.toString (#24888)
Abacn Jan 5, 2023
3070160
Fix PR number in 2.43.0 changelog (#24904)
rviscomi Jan 5, 2023
37c7bee
Fix poorly formatted metadata (#24905)
damccorm Jan 5, 2023
0e9fe07
Add static override for JDK TLS disabled/legacy algorithms in Java co…
cwrothrock Jan 5, 2023
49dd2df
Remove shuffle mode=appliance in tests (#24879)
Abacn Jan 6, 2023
de0cf60
Modify windmill DirectStreamObserver to call isReady only every 10 me…
scwhittle Jan 2, 2023
e724425
Sync script for grafana dashboard - github actions postcommit work…
andoni-guzman Jan 6, 2023
f9d30c3
Integration test to load the default example of the default SDK and c…
alexeyinkin Jan 6, 2023
07ba8f1
issue23923 emulated data indicator (#24708)
Malarg Jan 6, 2023
be5bdbd
Bump github.com/aws/aws-sdk-go-v2/service/s3 in /sdks (#24917)
dependabot[bot] Jan 6, 2023
de3ebdb
issue23918 extract java symbols (#24588)
Malarg Jan 6, 2023
5096daa
Attempt deserialize all non-standard portable logical types from prot…
Abacn Jan 6, 2023
6ad7540
TFT Criteo benchmarks (#24382)
AnandInguva Jan 6, 2023
e54871d
Merge pull request #24646: Add thread prefix for StreamingDataflowWor…
reuvenlax Jan 6, 2023
f9d5de3
update Java version from 11 to 17 (#24839)
zhenglin-charlie-li Jan 6, 2023
c162f4c
Merge pull request #24853: Modify windmill DirectStreamObserver to ca…
reuvenlax Jan 7, 2023
a388568
[#21384] Add unit tests to the sql package (#24811)
zhenglin-charlie-li Jan 7, 2023
95e5391
[#24927] Ensure the SDK harness handles JCL/log4j/log4j2 messages. (#…
lukecwik Jan 8, 2023
ed4cd60
Improve Error Prone configuration
cushon Jan 6, 2023
e4ae50d
Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in /sdks (#24915)
dependabot[bot] Jan 9, 2023
89f1b0f
Update comment
cushon Jan 9, 2023
a803789
update Beam GCP BOM (#24929)
reuvenlax Jan 9, 2023
e0f463c
[#24931][Go SDK] Make element checkpoints independant (#24932)
lostluck Jan 9, 2023
2901af4
Update Kafka watermark based on policy when records poll empty (#24205)
johnjcasey Jan 9, 2023
0718c59
Grafana dashboard - Github actions postcommit workflows mapping (#24176)
MarcoRob Jan 9, 2023
1e2b328
Shard Python PreCommit (#24866)
damccorm Jan 9, 2023
7d6d6de
reapply single executor to storage write API writes (#24950)
reuvenlax Jan 9, 2023
3838528
[#21368] Clean-up and use the FixedExecutorProvider (#24952)
lukecwik Jan 9, 2023
3d006da
Add doLast on Playground integration tests (#24954) (#24955)
alexeyinkin Jan 10, 2023
8e31f7a
JDBC SchemaTransform implementation. Need to break out into a separat…
byronellis Jan 10, 2023
5a57d3f
fix pinning bug in storage-api writes
reuvenlax Jan 10, 2023
92223e3
[WebSite] Add new Go quickstart (#24885)
VeronicaWasson Jan 10, 2023
c0e6893
Merge pull request #24968: Fix pinning bug in storage-api writes
reuvenlax Jan 11, 2023
d5d9afd
Add missing dependencies to maven archetype
kileys Jan 11, 2023
3a98ecb
Merge pull request #24930 from cushon/errorprone
kileys Jan 11, 2023
98aea03
Bump google.golang.org/grpc from 1.51.0 to 1.52.0 in /sdks (#24969)
dependabot[bot] Jan 11, 2023
c3a2aac
Bump github.com/containerd/containerd from 1.6.8 to 1.6.12 in /sdks (…
dependabot[bot] Jan 11, 2023
ad729f7
[Playground] Add an option for Datastore namespace value for ci_cd.py…
TSultanov Jan 11, 2023
9ec68dd
Multifile examples on frontend (#24859) (#24865)
alexeyinkin Jan 11, 2023
6de4d5f
Return only Playground examples in GetCatalog() (#24816)
TSultanov Jan 11, 2023
e21b5b7
[Website] add credit karma case-study card (#24970)
bullet03 Jan 11, 2023
ad4410a
[Playground] Fix for failing CI/CD in playground (#24984)
TSultanov Jan 12, 2023
5c27e45
Merge pull request #24975 from kileys/maven
kileys Jan 12, 2023
c3d9238
Improve error message for unencodeable types (#24844)
yyy1000 Jan 12, 2023
705c151
Add single job to run python coverage (#24988)
damccorm Jan 12, 2023
1f02c23
Bump cloud.google.com/go/bigquery from 1.44.0 to 1.45.0 in /sdks (#24…
dependabot[bot] Jan 12, 2023
ffb08ae
Update beam-master version
kileys Jan 13, 2023
4c13e14
Merge branch 'master' of github.com:apache/beam into beam-master
kileys Jan 13, 2023
5cc5b19
Bump google.golang.org/api from 0.106.0 to 0.107.0 in /sdks (#24989)
dependabot[bot] Jan 13, 2023
a5efba6
[ToB] [Frontend] Authentication, unit progress, complete unit, SDK se…
nausharipov Jan 13, 2023
15f3717
Fix example checker validation for incomplete multifile examples (#24…
Jan 13, 2023
d21c8b7
Merge pull request #24990 from kileys/beam-master
kileys Jan 13, 2023
e94aa45
Remove datastore intersphinx_dependency to fix docs job. (#25000)
damccorm Jan 13, 2023
7ab334d
Adding the registered trademark symbol to the Apache Beam title on th…
rszper Jan 13, 2023
ab4bb55
Use CC-BY image for custom remote inference notebook (#25004)
damccorm Jan 13, 2023
4534904
Fix kafka performance test write failing due to server overwhelmed (#…
Abacn Jan 13, 2023
a5e6d90
Merge pull request #25008 from rszper/rszper-trademark
aaltay Jan 14, 2023
1aa5acc
[Spark Dataset runner] Fix SparkSessionFactory to better support runn…
Jan 16, 2023
351f403
BEAM-13261 updated comment for max connection
pas725 Jan 16, 2023
6f87445
Add withDefaultHeaders to connection configuration for ElasticsearchIO
Jan 16, 2023
9f7c55f
Bump github.com/dustin/go-humanize from 1.0.0 to 1.0.1 in /sdks (#25017)
dependabot[bot] Jan 17, 2023
de21be6
Address PR comments, run spotless
Jan 17, 2023
869150c
Merge pull request #24851: BEAM-13261 added max connections setting
aromanenko-dev Jan 17, 2023
8d4c00e
Fix incorrect parsing of None value parameters. (#24948)
melaniedc Jan 17, 2023
bb7b64a
Fix PipelineOptionTest.test_display_data (#25007)
Abacn Jan 17, 2023
8cb5145
Fix Spark runner dependency (#25040)
aromanenko-dev Jan 17, 2023
9eff5f9
Bump future from 0.18.2 to 0.18.3 in /sdks/python/container/py39 (#25…
dependabot[bot] Jan 17, 2023
7e370bf
Bump torch (#24944)
dependabot[bot] Jan 17, 2023
7fd2501
Set allowDiskUse to true in MongoDB bucketAuto aggregation (#25013)
johannaojeling Jan 17, 2023
3aa5d9c
Add kafka version to pom
kileys Jan 17, 2023
120558c
add public qualifier
reuvenlax Jan 17, 2023
8b3a028
Website updates for Beam 2.44.0 release
kennknowles Jan 9, 2023
3dcb085
Merge pull request #24951: Update website metadata to 2.44.0 and blog…
kennknowles Jan 17, 2023
5a2a3a4
Merge pull request #25044: Add public qualifier to FillGaps methods
reuvenlax Jan 17, 2023
219f4f1
Merge pull request #25043 from kileys/kafka
kileys Jan 17, 2023
f40057b
Bump json5 from 1.0.1 to 1.0.2 in /sdks/python/apache_beam/runners/in…
dependabot[bot] Jan 17, 2023
e22afb0
Properly synchronize pins
reuvenlax Jan 17, 2023
6847255
typo
reuvenlax Jan 17, 2023
482c310
Merge pull request #25047: Properly synchronize pins
reuvenlax Jan 18, 2023
d9d322b
enabling public construction of typed schematransforms (#25010)
pabloem Jan 18, 2023
a05a9c0
Fix copy/paste error in Javadoc, add example for usage of withDefault…
Jan 18, 2023
55d8ecb
Add explicit error for PEP 585 type hints (#24986)
jrmccluskey Jan 18, 2023
9f42392
Updated Python Container Dependencies (#25042)
johnjcasey Jan 18, 2023
bbbbe91
[ToB][Frontend] Display hints and solutions (#25020)
nausharipov Jan 18, 2023
aba1752
upgrade clickhouse jdbc driver 0.3.2-patch10 (#24424)
mzitnik Jan 18, 2023
312cbbd
Added documentation for SingleStoreIO (#24377)
AdalbertMemSQL Jan 18, 2023
d69dbd8
Adding watermark support to DebeziumIO transform (#24757)
pabloem Jan 18, 2023
f2594c6
Moving to 2.46.0-SNAPSHOT on master branch.
johnjcasey Jan 18, 2023
b554040
Fix typo in join explanation (#25049)
smart2pet Jan 18, 2023
b50b801
Merge pull request #25024 from EgbertW/master
egalpin Jan 18, 2023
3b23290
Fix error message (add proper spacing) (#25050)
bvolpato Jan 18, 2023
95874a7
Remove trailing whitespace from blog to fix precommit (#25055)
damccorm Jan 18, 2023
187ba47
improve some errors from DoFnSignature (#25001)
pabloem Jan 18, 2023
69a1313
Bump torch (#24977)
dependabot[bot] Jan 18, 2023
aa8dc4f
Set maxConnections optional in incoming schema for JdbcSchemaIOProvid…
Abacn Jan 18, 2023
6daa6f4
Document that yield and return shouldn't be mixed. (#25060)
tvalentyn Jan 18, 2023
860b05f
Add documentation on typescript IOs.
robertwb Dec 29, 2022
13a740b
[#25070] Remove Kafka jars from Beam Java SDK Container (#25072)
lukecwik Jan 19, 2023
1c4e424
[Playground][Frontend] Run timer fix; CodeRunner and OutputType extra…
nausharipov Jan 19, 2023
876ce5b
Merge pull request #25073: Improves StorageWrite API error logging
prodriguezdefino Jan 19, 2023
60a9382
Bump google.golang.org/api from 0.107.0 to 0.108.0 in /sdks (#25075)
dependabot[bot] Jan 19, 2023
80d8d34
[Python] Fix input type for num_bytes (#25086)
riteshghorse Jan 19, 2023
6517731
Add Pyarrow support to Batched DoFn documentation (#23956)
TheNeuralBit Jan 19, 2023
3e1291c
Tour of beam learning materials CI/CD refactoring and templating (#25…
Jan 19, 2023
6203e58
Add support for using builtins typing (#25054)
DavidKatz-il Jan 19, 2023
641b556
Bump cloud.google.com/go/spanner from 1.42.0 to 1.43.0 in /sdks (#25090)
dependabot[bot] Jan 19, 2023
a99364c
Increase timeout on test_dynamic_timer_clear_then_set_timer (#25009)
damccorm Jan 19, 2023
76813c1
Bump torch (#25089)
dependabot[bot] Jan 19, 2023
148730e
Bump timeout for beam_PostCommit_Python_Examples_Dataflow to 3h (#25092)
Abacn Jan 19, 2023
fafeaa9
Add unit test to cover non built-in GenericAlias types (#25091)
jrmccluskey Jan 19, 2023
7ad44c8
Handle schema updates in Storage API writes.
reuvenlax Nov 9, 2022
6b42bda
[Website] update content of community case study page (#25023)
bullet03 Jan 19, 2023
1d4345a
Eliminate google-python-cloud-debugger dependency in base_image_requi…
Abacn Jan 19, 2023
c1b840a
Bump httplib2 upper bound to 0.22.0. (#24573)
tjni Jan 19, 2023
54aad80
Remove kileys from Java reviewers
kileys Jan 19, 2023
428ec97
improve error message for mismatched pipelines (#24834)
zhenglin-charlie-li Jan 20, 2023
f5020e7
Merge pull request #24145: Handle updates to table schema when using …
reuvenlax Jan 20, 2023
9cecec3
Bump cloud.google.com/go/storage from 1.28.1 to 1.29.0 in /sdks (#25095)
dependabot[bot] Jan 20, 2023
5e1ebee
Allow to set timeout for finishing a remote bundle in Samza portable …
alnzng Jan 20, 2023
e379c23
Fix truncate copy job when WRITE_TRUNCATE in BigQuery batch load (#25…
Abacn Jan 20, 2023
4824014
fix(sec): upgrade torch to 1.13.1 (#24933)
smart2pet Jan 20, 2023
4dad3c6
[#24515] Delete the JRH (#24967)
lukecwik Jan 21, 2023
cd20288
Support DoFn metrics in portable Samza Runner (#25068)
ryucc Jan 21, 2023
5cfc09c
Add I/O Standards Page (#24962)
hermanmak Jan 23, 2023
897fffd
Add more info in documentation (#25099)
shub-kris Jan 23, 2023
b3aa2e8
Fix Python PreCommit dependency compatibility test not run or redunda…
Abacn Jan 23, 2023
6029a57
Move CombineValues override to non portable overrides (#25106)
damccorm Jan 23, 2023
459d6b2
Merge pull request #25124 from kileys/remove
kileys Jan 23, 2023
5e3b417
Exclude UsesMultimapState in Samza validatesPortableRunner tests (#25…
xinyuiscool Jan 23, 2023
633c512
Add GraalSystems (#23651)
Treydone Jan 23, 2023
93ca2fe
Bump timeout for default transient expansion service (#25111)
Abacn Jan 23, 2023
b1aba9d
#20812 handle @RequiresStableInput in portable flink (#22889)
je-ik Jan 23, 2023
6ba6473
Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in /sdks (#25128)
dependabot[bot] Jan 24, 2023
6b8f8c0
Initial start of a yaml-based declarative way of building pipelines. …
robertwb Jan 24, 2023
3d9318b
Remove deprecated first implementations of data channel connector cod…
lukecwik Jan 24, 2023
9aa2c52
Adding autoservice annotations to all SchemaTransformProviders (#25107)
pabloem Jan 24, 2023
89cd059
Add working example for Per Entity Training (#25081)
shub-kris Jan 24, 2023
0bcb50e
Adds a reference x-lang RunInference Javadoc
chamikaramj Jan 24, 2023
d914525
Merge pull request #25071 Restore documentation on typescript IOs.
robertwb Jan 24, 2023
b7c07e2
Merge pull request #25148: Adds a reference x-lang RunInference Javadoc
chamikaramj Jan 24, 2023
299a7b0
Drop '2' from BeamFnDataGrpcMultiplexer2 and BeamFnDataInboundObserve…
lukecwik Jan 24, 2023
a96afe2
[BEAM-12164] Enable postgres IT for change streams (#25152)
nancyxu123 Jan 24, 2023
e8484a7
Fix inconsistent cache bug
reuvenlax Jan 25, 2023
b49ef57
update cloudpickle version (#25142)
johnjcasey Jan 25, 2023
72d2776
[ToB][Frontend] Gradle tasks for ToB frontend (#24919)
nausharipov Jan 25, 2023
6d6f995
Remove databaseRole from metadata DB requests in SpannerIO.ReadChange…
nuggetwheat Jan 25, 2023
d688d42
Update typehint code to allow primitive composite types in python 3.9…
jrmccluskey Jan 25, 2023
91efbd3
Fix intruction -> instruction typo
damccorm Jan 25, 2023
67b5b36
Initial commit of boilerplate setup of change stream pipeline for big…
tonytanger Jan 24, 2023
b0c5941
Increase default expansion service timeout
chamikaramj Jan 25, 2023
1ecb4ef
Merge pull request #25159: Fix inconsistent cache bug
reuvenlax Jan 25, 2023
48712b2
Merge pull request #25169: Increase default expansion service timeout
chamikaramj Jan 25, 2023
13a489e
Fix SchemaTransform identifiers
ahmedabu98 Jan 25, 2023
d39e9c5
Further increase transient expansion service timeout (#25176)
Abacn Jan 26, 2023
0c2a168
Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in /sdks (#25182)
dependabot[bot] Jan 26, 2023
b497cc4
Adds the SampleDataRequest/Response (#25065)
rohdesamuel Jan 26, 2023
76f3a59
Update chromedriver-binary requirement in /sdks/python (#25178)
dependabot[bot] Jan 26, 2023
6676646
Bump google.golang.org/grpc from 1.52.0 to 1.52.3 in /sdks (#25181)
dependabot[bot] Jan 26, 2023
f565a94
Merge pull request #25153 from tonytanger/initial_cdc
pabloem Jan 26, 2023
2c45ac4
Merge pull request #25175: Fix SchemaTransform identifiers
chamikaramj Jan 26, 2023
f07241b
Fix a couple typos caught by an internal linter (#25188)
damccorm Jan 26, 2023
61045b6
Update Dataflow container versions (#25192)
damccorm Jan 26, 2023
5fa899f
Update ci_cd.py
ruslan-ikhsan Jan 30, 2023
dd5a6b5
Test tag
ruslan-ikhsan Feb 2, 2023
6ea3eaa
Update ci_cd.py
ruslan-ikhsan Feb 3, 2023
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
The table of contents is too big for display.
Diff view
Diff view
  •  
  •  
  •  
The diff you're trying to view is too large. We only load the first 3000 changed files.
14 changes: 12 additions & 2 deletions .asf.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
# https://s.apache.org/asfyaml-notify

github:
description: "Apache Beam is a unified programming model for Batch and Streaming"
description: "Apache Beam is a unified programming model for Batch and Streaming data processing."
homepage: https://beam.apache.org/
labels:
- batch
Expand All @@ -28,6 +28,17 @@ github:
- python
- sql
- streaming
features:
# Enable issue management
issues: true
# Enable projects for project management boards
projects: true

# Give some users issue triage permissions
collaborators:
- pcoet
- olehborysevych
- rshamunov

enabled_merge_buttons:
squash: true
Expand All @@ -38,4 +49,3 @@ notifications:
commits: [email protected]
issues: [email protected]
pullrequests: [email protected]
jira_options: link worklog
5 changes: 4 additions & 1 deletion .gitattributes
Original file line number Diff line number Diff line change
Expand Up @@ -32,4 +32,7 @@ Dockerfile text
.gitignore export-ignore
.gitattributes export-ignore
/gradlew* export-ignore
/gradle export-ignore
**/gradle export-ignore

# Website is not part of archive
/website export-ignore
100 changes: 100 additions & 0 deletions .github/ACTIONS.md
Original file line number Diff line number Diff line change
@@ -0,0 +1,100 @@
<!--
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements. See the NOTICE file
distributed with this work for additional information
regarding copyright ownership. The ASF licenses this file
to you under the Apache License, Version 2.0 (the
"License"); you may not use this file except in compliance
with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing,
software distributed under the License is distributed on an
"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
KIND, either express or implied. See the License for the
specific language governing permissions and limitations
under the License.
-->

> **PLEASE update this file if you add new GitHub Action or change name/trigger phrase of a GitHub Action.**
## About GitHub Actions Runners and Self-hosted Runners
According to GitHub Docs, we can define a GitHub-hosted runner and a self-hosted runner as the following:
* A [GitHub-hosted runner](https://docs.github.com/en/actions/using-github-hosted-runners/about-github-hosted-runners) is a new virtual machine (VM) hosted by GitHub with the runner application and other tools preinstalled, and is available with Ubuntu Linux, Windows, or macOS operating systems.
* A [self-hosted runner](https://docs.github.com/en/actions/hosting-your-own-runners/about-self-hosted-runners) is a system that you deploy and manage to execute jobs from GitHub Actions on GitHub.com.

## Apache Beam GitHub Actions

Currently, we have both GitHub-hosted and self-hosted runners for running the GitHub Actions workflows, hosted on Google Cloud Platform(GCP) Virtual Machines and Google Kubernetes Engine(GKE). The majority of our workflows that run in Ubuntu and Windows run in self-hosted runners, except for those that runs on MacOS and the `Monitor Self-Hosted Runners Status` workflow that monitors our GCP self-hosted runners.

### Getting Started with self-hosted runners
* Refer to [this README](./gh-actions-self-hosted-runners/README.md) for the steps for creating your own self-hosted runners for testing your workflows.
* Depending on your workflow's needs, it must specify the following `runs-on` tags to run in the specified operating system:
* Ubuntu 20.04 self-hosted runner: `[self-hosted, ubuntu-20.04]`
* Windows Server 2019 self-hosted runner: `[self-hosted, windows-server-2019]`
* MacOS GitHub-hosted runner: `macos-latest`
* Every workflow that tests the source code, needs to have the workflow trigger `pull_request_target` instead of `pull_request`.
* The workflow must have set read permissions for all the available scopes and jobs: `permissions: read-all`. It must be set at the top of the `jobs` directive.
* For those workflows that have the `pull_request_target` trigger, in the checkout step must be added a ref to `${{ github.event.pull_request.head.sha }}`
``` yaml
- name: Checkout code
uses: actions/checkout@v#
with:
ref: ${{ github.event.pull_request.head.sha }}
```
* If your workflow runs successfully in a GitHub-hosted runner but not in the self-hosted runner, it might need a new installation step.
```yaml
- name: Setup Node
uses: actions/setup-node@v3
with:
node-version: 16
```
* You can find the GitHub-hosted runner installations in the following links:
* [Ubuntu-20.04](https://github.com/actions/runner-images/blob/main/images/linux/Ubuntu2004-Readme.md#installed-apt-packages)
* [Windows-2019](https://github.com/actions/runner-images/blob/main/images/win/Windows2019-Readme.md)

#### GitHub Actions Example
```yaml
name: GitHub Actions Example
on:
pull_request_target:
branches: ['master']
permissions: read-all
jobs:
github-actions-example:
runs-on: [self-hosted, ubuntu-20.04]
steps:
- name: Check out repository code
uses: actions/checkout@v2
with:
ref: ${{ github.event.pull_request.head.sha }}
- run: echo "This job is now running on a ubuntu server hosted by Apache Beam!"
- name: Setup Node
uses: actions/setup-node@v3
with:
node-version: 16
- name: Install npm dependencies
run: npm ci
working-directory: 'scripts/ci/your-path'
- name: Run Node.js code
run: npm run functionName
env:
VAR_1: my-var
working-directory: 'scripts/ci/your-path'
```

#### IMPORTANT for Committers
* A **detailed review** for changes in the workflows is needed due to important **security concerns**.
* **DO NOT** Approve and Run changes in the workflows in the PR Conversation tab, under "Workflow(s) awaiting approval".
* For approving the updates in the workflows, you should go to the Repository Actions and filter All Workflows by `action_required`. The search will display the workflows that need to be reviewed before running. **Please make sure reviewing the file that is referenced by the workflow.**
* Seed job will be emulated using the `Approve and Run` built-in feature of GitHub Actions, since the workflows will use the `pull_request_target` directive; no modifications would be allowed either for new or existent jobs unless a committer explicitly approves the job from GitHub Actions UI.
### Issue Management

Phrases self-assign, close, or manage labels on an issue:
| Phrase | Effect |
|--------|--------|
| `.take-issue` | Self-assign the issue |
| `.close-issue` | Close the issue as completed |
| `.close-issue not_planned` | Close the issue as not-planned |
| `.reopen-issue` | Reopen a closed issue |
| `.add-labels` | Add comma separated labels to the issue (e.g. `add-labels l1, 'l2 with spaces'`) |
| `.remove-labels` | Remove comma separated labels to the issue (e.g. `remove-labels l1, 'l2 with spaces'`) |
| `.set-labels` | Sets comma separated labels to the issue and removes any other labels (e.g. `set-labels l1, 'l2 with spaces'`) |
75 changes: 75 additions & 0 deletions .github/ISSUE_TEMPLATE/bug.yml
Original file line number Diff line number Diff line change
@@ -0,0 +1,75 @@
#
# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements. See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License. You may obtain a copy of the License at
#
# https://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
#

name: Bug Report
description: File a bug report
title: "[Bug]: "
labels: ["bug", "awaiting triage"]
assignees:
- octocat
body:
- type: markdown
attributes:
value: |
Thanks for taking the time to fill out this bug report! Once you've created an issue, you can self-assign by commenting `.take-issue` and you can close by commenting `.close-issue`.
Anyone can reopen a closed issue by commenting `.reopen-issue`.
You can also add/remove labels by commenting `.add-labels label1,label2,'label 3 with spaces'` or `.remove-labels label1,label2,'label 3 with spaces'`,
or with `.set-labels label1,label2,'label 3 with spaces'` (which removes any labels not in that set).
- type: textarea
id: what-happened
attributes:
label: What happened?
description: Please describe your issue, including the version of Beam and any other languages or tools being used.
placeholder: |
Please include steps to reproduce your issue.

If this isn't a bug and you have a question or support request, please email [email protected] with a description of the problem instead of opening this issue.
validations:
required: true
- type: dropdown
id: priority
attributes:
label: Issue Priority
description: What priority is this bug? See https://beam.apache.org/contribute/issue-priorities for the meaning and expectations around issue priorities.
options:
- "Priority: 3 (minor)"
- "Priority: 2 (default / most bugs should be filed as P2)"
- "Priority: 1 (data loss / total loss of function)"
- "Priority: 0 (outage / urgent vulnerability)"
validations:
required: true
- type: checkboxes
id: component
attributes:
label: Issue Components
description: Which languages, SDKs, or features are related to your report? (check all that apply)
options:
- label: "Component: Python SDK"
- label: "Component: Java SDK"
- label: "Component: Go SDK"
- label: "Component: Typescript SDK"
- label: "Component: IO connector"
- label: "Component: Beam examples"
- label: "Component: Beam playground"
- label: "Component: Beam katas"
- label: "Component: Website"
- label: "Component: Spark Runner"
- label: "Component: Flink Runner"
- label: "Component: Samza Runner"
- label: "Component: Twister2 Runner"
- label: "Component: Hazelcast Jet Runner"
- label: "Component: Google Cloud Dataflow Runner"
81 changes: 81 additions & 0 deletions .github/ISSUE_TEMPLATE/failing_test.yml
Original file line number Diff line number Diff line change
@@ -0,0 +1,81 @@
#
# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements. See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License. You may obtain a copy of the License at
#
# https://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
#

name: Failing Test
description: Report a failing test
title: "[Failing Test]: "
labels: ["bug", "awaiting triage", "failing test"]
assignees:
- octocat
body:
- type: markdown
attributes:
value: |
Thanks for taking the time to fill out this feature request! Once you've created an issue, you can self-assign by commenting `.take-issue` and you can close by commenting `.close-issue`.
Anyone can reopen a closed issue by commenting `.reopen-issue`.
You can also add/remove labels by commenting `.add-labels label1,label2,'label 3 with spaces'` or `.remove-labels label1,label2,'label 3 with spaces'`,
or with `.set-labels label1,label2,'label 3 with spaces'` (which removes any labels not in that set).
- type: textarea
id: what-happened
attributes:
label: What happened?
description: Please name which test is failing.
placeholder: |
If possible include: when the test started failing, a jenkins link, and any initial debugging you've done.

If this isn't a bug and you have a question or support request, please email [email protected] with a description of the problem instead of opening this issue.
- type: dropdown
id: failure
attributes:
label: Issue Failure
options:
- "Failure: Test is flaky"
- "Failure: Test is continually failing"
validations:
required: true
- type: dropdown
id: priority
attributes:
label: Issue Priority
description: What priority is this bug? A permanently failing test should be marked P1. See https://beam.apache.org/contribute/issue-priorities for the meaning and expectations around issue priorities.
options:
- "Priority: 2 (backlog / disabled test but we think the product is healthy)"
- "Priority: 1 (unhealthy code / failing or flaky postcommit so we cannot be sure the product is healthy)"
- "Priority: 0 (outage / failing precommit test impacting development)"
validations:
required: true
- type: checkboxes
id: component
attributes:
label: Issue Components
description: Which languages, SDKs, or features are related to your report? (check all that apply)
options:
- label: "Component: Python SDK"
- label: "Component: Java SDK"
- label: "Component: Go SDK"
- label: "Component: Typescript SDK"
- label: "Component: IO connector"
- label: "Component: Beam examples"
- label: "Component: Beam playground"
- label: "Component: Beam katas"
- label: "Component: Website"
- label: "Component: Spark Runner"
- label: "Component: Flink Runner"
- label: "Component: Samza Runner"
- label: "Component: Twister2 Runner"
- label: "Component: Hazelcast Jet Runner"
- label: "Component: Google Cloud Dataflow Runner"
69 changes: 69 additions & 0 deletions .github/ISSUE_TEMPLATE/feature.yml
Original file line number Diff line number Diff line change
@@ -0,0 +1,69 @@
#
# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements. See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License. You may obtain a copy of the License at
#
# https://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
#

name: Feature Request
description: File a feature request
title: "[Feature Request]: "
labels: ["new feature", "awaiting triage"]
assignees:
- octocat
body:
- type: markdown
attributes:
value: |
Thanks for taking the time to fill out this feature request! Once you've created an issue, you can self-assign by commenting `.take-issue` and you can close by commenting `.close-issue`.
Anyone can reopen a closed issue by commenting `.reopen-issue`.
You can also add/remove labels by commenting `.add-labels label1,label2,'label 3 with spaces'` or `.remove-labels label1,label2,'label 3 with spaces'`,
or with `.set-labels label1,label2,'label 3 with spaces'` (which removes any labels not in that set).
- type: textarea
id: what-happened
attributes:
label: What would you like to happen?
description: Please describe your issue
validations:
required: true
- type: dropdown
id: priority
attributes:
label: Issue Priority
description: What priority is this feature? See https://beam.apache.org/contribute/issue-priorities for the meaning and expectations around issue priorities.
options:
- "Priority: 3 (nice-to-have improvement)"
- "Priority: 2 (default / most feature requests should be filed as P2)"
validations:
required: true
- type: checkboxes
id: component
attributes:
label: Issue Components
description: Which languages, SDKs, or features are related to your report? (check all that apply)
options:
- label: "Component: Python SDK"
- label: "Component: Java SDK"
- label: "Component: Go SDK"
- label: "Component: Typescript SDK"
- label: "Component: IO connector"
- label: "Component: Beam examples"
- label: "Component: Beam playground"
- label: "Component: Beam katas"
- label: "Component: Website"
- label: "Component: Spark Runner"
- label: "Component: Flink Runner"
- label: "Component: Samza Runner"
- label: "Component: Twister2 Runner"
- label: "Component: Hazelcast Jet Runner"
- label: "Component: Google Cloud Dataflow Runner"
Loading