Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
427 commits
Select commit Hold shift + click to select a range
37ff054
Test with auth
Amar3tto Feb 18, 2025
479408d
Merge pull request #463 from akvelon/fix-xvr-gojava
Amar3tto Feb 18, 2025
0a7b667
Test with rep
Amar3tto Feb 18, 2025
4075303
Merge pull request #464 from akvelon/fix-xvr-gojava
Amar3tto Feb 18, 2025
895d083
Test with github runner
Amar3tto Feb 18, 2025
3e684a8
Merge pull request #465 from akvelon/fix-xvr-gojava
Amar3tto Feb 18, 2025
0744b0a
Test with one task
Amar3tto Feb 18, 2025
d443ba3
Merge pull request #466 from akvelon/fix-xvr-gojava
Amar3tto Feb 18, 2025
fa24d43
Test with python container
Amar3tto Feb 18, 2025
9313145
Merge pull request #467 from akvelon/fix-xvr-gojava
Amar3tto Feb 18, 2025
1673400
Test with tag
Amar3tto Feb 19, 2025
f6dc622
Merge pull request #468 from akvelon/fix-xvr-gojava
Amar3tto Feb 19, 2025
d401958
hugging face 4.49.0
Amar3tto Feb 19, 2025
21dd62d
Merge pull request #469 from akvelon/fix-xvr-gojava
Amar3tto Feb 19, 2025
118fa3c
Test without tag
Amar3tto Feb 19, 2025
d7a521b
Merge pull request #470 from akvelon/fix-xvr-gojava
Amar3tto Feb 19, 2025
ef34909
Test with timeout 600
Amar3tto Feb 19, 2025
6f5096e
Merge pull request #471 from akvelon/fix-xvr-gojava
Amar3tto Feb 19, 2025
2d3629e
Test with wait until
Amar3tto Feb 19, 2025
3c5ab2d
Merge pull request #472 from akvelon/fix-xvr-gojava
Amar3tto Feb 19, 2025
75a86a7
Test with triggering frequency
Amar3tto Feb 19, 2025
a6d7723
Merge pull request #473 from akvelon/fix-xvr-gojava
Amar3tto Feb 19, 2025
16702d1
Fix
Amar3tto Feb 19, 2025
ac0b015
Merge pull request #474 from akvelon/fix-xvr-gojava
Amar3tto Feb 19, 2025
388bdfc
Test with expansion
Amar3tto Feb 19, 2025
c3f0ac5
Merge pull request #475 from akvelon/fix-xvr-gojava
Amar3tto Feb 19, 2025
6f98964
Test with cancel
Amar3tto Feb 20, 2025
2761781
Merge pull request #476 from akvelon/fix-xvr-gojava
Amar3tto Feb 20, 2025
340c8ac
Test with read records
Amar3tto Feb 20, 2025
443cfc7
Merge pull request #477 from akvelon/fix-xvr-gojava
Amar3tto Feb 20, 2025
96fa27d
Test with clean up wait
Amar3tto Feb 20, 2025
b5219c9
Merge branch 'master' into fix-xvr-gojava
Amar3tto Feb 20, 2025
650cce0
Merge pull request #478 from akvelon/fix-xvr-gojava
Amar3tto Feb 20, 2025
4df228c
Test jenkins
Amar3tto Feb 20, 2025
5504f29
Merge remote-tracking branch 'origin/fix-xvr-gojava' into fix-xvr-gojava
Amar3tto Feb 20, 2025
7f4a817
Merge pull request #479 from akvelon/fix-xvr-gojava
Amar3tto Feb 20, 2025
8284134
Test with cleanup
Amar3tto Feb 20, 2025
ab72a4d
Merge pull request #480 from akvelon/fix-xvr-gojava
Amar3tto Feb 20, 2025
91f086f
Test with salt
Amar3tto Feb 20, 2025
a35cb37
Merge pull request #481 from akvelon/fix-xvr-gojava
Amar3tto Feb 20, 2025
8e21b13
Test with salt 2
Amar3tto Feb 20, 2025
2757ff1
Merge pull request #482 from akvelon/fix-xvr-gojava
Amar3tto Feb 20, 2025
3f46912
Test with safe delete tables
Amar3tto Feb 20, 2025
acbc654
Merge pull request #483 from akvelon/fix-xvr-gojava
Amar3tto Feb 20, 2025
34ba436
Test with sleep and random
Amar3tto Feb 20, 2025
0d6006a
Merge pull request #484 from akvelon/fix-xvr-gojava
Amar3tto Feb 20, 2025
9de4a94
Test with sleep and random
Amar3tto Feb 20, 2025
19a25ff
Merge pull request #485 from akvelon/fix-xvr-gojava
Amar3tto Feb 20, 2025
1014e9f
Test with long sleep
Amar3tto Feb 20, 2025
b2377fb
Merge pull request #486 from akvelon/fix-xvr-gojava
Amar3tto Feb 20, 2025
333b14f
Test with long sleep
Amar3tto Feb 20, 2025
3b14b54
Test with interrupt
Amar3tto Feb 20, 2025
c08e6eb
Merge pull request #487 from akvelon/fix-xvr-gojava
Amar3tto Feb 20, 2025
89a8f34
Test without delete
Amar3tto Feb 20, 2025
9015c4c
Merge pull request #488 from akvelon/fix-xvr-gojava
Amar3tto Feb 20, 2025
dda50e9
Test without return
Amar3tto Feb 20, 2025
8f4b19d
Merge pull request #489 from akvelon/fix-xvr-gojava
Amar3tto Feb 20, 2025
e2722da
Test with normal sleep
Amar3tto Feb 20, 2025
43f6b02
Merge pull request #490 from akvelon/fix-xvr-gojava
Amar3tto Feb 20, 2025
def5384
Fix creating tables
Amar3tto Feb 21, 2025
5da232c
Fix removing tables
Amar3tto Feb 21, 2025
994ecf7
Merge pull request #491 from akvelon/fix-xvr-gojava
Amar3tto Feb 21, 2025
fd4a7f2
TestWatcher
Amar3tto Feb 21, 2025
eea5387
Merge pull request #492 from akvelon/fix-xvr-gojava
Amar3tto Feb 21, 2025
5b25db8
Test with countdown
Amar3tto Feb 21, 2025
33566ec
Merge pull request #493 from akvelon/fix-xvr-gojava
Amar3tto Feb 21, 2025
cff30a2
Fix hive db
Amar3tto Feb 24, 2025
934bc69
Merge pull request #494 from akvelon/fix-xvr-gojava
Amar3tto Feb 24, 2025
5bff6f4
test with cleanup gcs
Amar3tto Feb 24, 2025
4fb5070
Merge pull request #495 from akvelon/fix-xvr-gojava
Amar3tto Feb 24, 2025
5c37dca
test with no timeout
Amar3tto Feb 24, 2025
d19f147
Merge pull request #496 from akvelon/fix-xvr-gojava
Amar3tto Feb 24, 2025
963d282
test with 600
Amar3tto Feb 24, 2025
dac9695
Merge pull request #497 from akvelon/fix-xvr-gojava
Amar3tto Feb 24, 2025
c632524
test with catalog name
Amar3tto Feb 24, 2025
a7e10ad
Merge pull request #498 from akvelon/fix-xvr-gojava
Amar3tto Feb 24, 2025
a54580a
test without cancel
Amar3tto Feb 24, 2025
5be3444
Merge pull request #499 from akvelon/fix-xvr-gojava
Amar3tto Feb 24, 2025
d540ba5
test with refresh
Amar3tto Feb 24, 2025
b9f512d
Merge pull request #500 from akvelon/fix-xvr-gojava
Amar3tto Feb 24, 2025
86efe30
Add refresh looker .yml workflow and .py script
Amar3tto Feb 26, 2025
6b7f707
Merge pull request #502 from akvelon/fix-xvr-gojava
Amar3tto Feb 26, 2025
86becf5
Update code
Amar3tto Feb 26, 2025
2459ade
Merge pull request #503 from akvelon/fix-xvr-gojava
Amar3tto Feb 26, 2025
e4ab6de
Upgrade version
Amar3tto Feb 26, 2025
7842fa9
Merge pull request #504 from akvelon/fix-xvr-gojava
Amar3tto Feb 26, 2025
3261a8a
Use version 0 for auth
Amar3tto Feb 26, 2025
96ae953
Merge pull request #505 from akvelon/fix-xvr-gojava
Amar3tto Feb 26, 2025
8f48a87
Use number ids
Amar3tto Feb 26, 2025
1ff3542
Merge pull request #506 from akvelon/fix-xvr-gojava
Amar3tto Feb 26, 2025
02e1685
Use string ids
Amar3tto Feb 26, 2025
4fc0c55
Merge pull request #507 from akvelon/fix-xvr-gojava
Amar3tto Feb 26, 2025
921a88a
Refactor
Amar3tto Feb 26, 2025
85e8843
Try results
Amar3tto Feb 26, 2025
a6f920f
Merge pull request #508 from akvelon/fix-xvr-gojava
Amar3tto Feb 26, 2025
5f512f8
With logging
Amar3tto Feb 26, 2025
3875285
Merge pull request #509 from akvelon/fix-xvr-gojava
Amar3tto Feb 26, 2025
1301e5b
With sleep
Amar3tto Feb 26, 2025
8719298
Merge pull request #510 from akvelon/fix-xvr-gojava
Amar3tto Feb 26, 2025
6fd870f
With try except
Amar3tto Feb 26, 2025
36d7a7e
Merge pull request #511 from akvelon/fix-xvr-gojava
Amar3tto Feb 26, 2025
bc97fcd
Refactoring
Amar3tto Feb 26, 2025
304149e
Merge pull request #512 from akvelon/fix-xvr-gojava
Amar3tto Feb 26, 2025
4041417
Use login
Amar3tto Feb 26, 2025
72a5444
Merge pull request #513 from akvelon/fix-xvr-gojava
Amar3tto Feb 26, 2025
79377ec
Use role ids
Amar3tto Feb 26, 2025
b3affae
Merge pull request #514 from akvelon/fix-xvr-gojava
Amar3tto Feb 26, 2025
200eaa8
Verify table exists
Amar3tto Feb 27, 2025
3d77952
Merge pull request #515 from akvelon/fix-xvr-gojava
Amar3tto Feb 27, 2025
e863e91
Verify table exists fix
Amar3tto Feb 27, 2025
92c6525
Verify table exists fix
Amar3tto Feb 27, 2025
c685ed0
20 attempts
Amar3tto Feb 27, 2025
800dbef
Merge pull request #516 from akvelon/fix-xvr-gojava
Amar3tto Feb 27, 2025
14213be
30 attempts
Amar3tto Feb 27, 2025
a398549
Merge pull request #517 from akvelon/fix-xvr-gojava
Amar3tto Feb 27, 2025
bafbe69
Try without cleanup
Amar3tto Feb 27, 2025
20c0c32
Merge pull request #518 from akvelon/fix-xvr-gojava
Amar3tto Feb 27, 2025
c9a7244
Try streaming 100 ms
Amar3tto Feb 27, 2025
69c57e0
Merge pull request #519 from akvelon/fix-xvr-gojava
Amar3tto Feb 27, 2025
b1e22d2
Fix render task polling
Amar3tto Feb 27, 2025
6c7c6b5
Merge pull request #520 from akvelon/fix-xvr-gojava
Amar3tto Feb 27, 2025
80ea300
Fix return
Amar3tto Feb 27, 2025
31d3002
Merge pull request #521 from akvelon/fix-xvr-gojava
Amar3tto Feb 27, 2025
3834531
Test with folders
Amar3tto Feb 27, 2025
7bf9705
Merge pull request #522 from akvelon/fix-xvr-gojava
Amar3tto Feb 27, 2025
bbee52e
Test with 100
Amar3tto Feb 27, 2025
63c4c0b
Merge pull request #523 from akvelon/fix-xvr-gojava
Amar3tto Feb 27, 2025
fb5b67d
Refactoring
Amar3tto Feb 27, 2025
2bad358
Return 1000 ms
Amar3tto Feb 27, 2025
dc93ed3
Fix mobile dataflow
Amar3tto Feb 27, 2025
91bbb67
Merge pull request #524 from akvelon/fix-xvr-gojava
Amar3tto Feb 27, 2025
c6878e2
Fix mobile dataflow
Amar3tto Feb 28, 2025
991397c
Merge pull request #525 from akvelon/fix-xvr-gojava
Amar3tto Feb 28, 2025
3682cb9
Test
Amar3tto Feb 28, 2025
a2b486f
Merge pull request #526 from akvelon/fix-xvr-gojava
Amar3tto Feb 28, 2025
228d390
Refactoring
Amar3tto Feb 28, 2025
e8519b2
Merge pull request #527 from akvelon/fix-xvr-gojava
Amar3tto Feb 28, 2025
aea4800
Disable localy
Amar3tto Mar 4, 2025
44e5c02
Merge branch 'master' into local-march
Amar3tto Mar 4, 2025
ab2b375
Merge pull request #528 from akvelon/local-march
Amar3tto Mar 4, 2025
5326f2e
Use 300 timeout for RC
Amar3tto Mar 4, 2025
baa6f5c
Merge remote-tracking branch 'origin/local-march' into local-march
Amar3tto Mar 4, 2025
071b849
Return runner
Amar3tto Mar 4, 2025
da28638
Merge pull request #529 from akvelon/local-march
Amar3tto Mar 4, 2025
cdfa288
use 2.64.0 beam
Amar3tto Mar 5, 2025
7f2ca89
Merge pull request #530 from akvelon/local-march
Amar3tto Mar 5, 2025
cfe09af
wait 250
Amar3tto Mar 5, 2025
d804c5c
Merge pull request #531 from akvelon/local-march
Amar3tto Mar 5, 2025
0e00d57
6077 timeout
Amar3tto Mar 5, 2025
0bed9ab
Merge pull request #532 from akvelon/local-march
Amar3tto Mar 5, 2025
f0ec4fd
Add more time for grpc cleanup
Amar3tto Mar 5, 2025
e6bef51
Merge pull request #533 from akvelon/fix-grpc-cleanup
Amar3tto Mar 6, 2025
dc7a0ac
Decrease num of futures
Amar3tto Mar 6, 2025
ba79884
Merge pull request #534 from akvelon/fix-flink-8
Amar3tto Mar 6, 2025
bc41d36
Fail test
Amar3tto Mar 6, 2025
1c78377
Test 1M
Amar3tto Mar 6, 2025
71619bf
test 1K
Amar3tto Mar 6, 2025
859797d
Merge pull request #535 from akvelon/fix-flink-8
Amar3tto Mar 6, 2025
5af3f3b
Fix validate container
Amar3tto Mar 10, 2025
a125587
Merge pull request #536 from akvelon/local-march-10
Amar3tto Mar 10, 2025
281385d
Refactoring
Amar3tto Mar 10, 2025
0a036b3
Merge pull request #537 from akvelon/local-march-10
Amar3tto Mar 10, 2025
0f4c7a3
Refactoring
Amar3tto Mar 10, 2025
a154e33
Merge pull request #538 from akvelon/local-march-10
Amar3tto Mar 10, 2025
3ab54c8
Fix deleting
Amar3tto Mar 10, 2025
dbbf276
Merge pull request #539 from akvelon/local-march-10
Amar3tto Mar 10, 2025
034c21b
change cron
Amar3tto Mar 10, 2025
14b4528
Refactoring
Amar3tto Mar 10, 2025
b1861fe
Merge pull request #540 from akvelon/local-march-10
Amar3tto Mar 10, 2025
22e320d
Delete by digest
Amar3tto Mar 10, 2025
16da3e8
Merge pull request #541 from akvelon/local-march-10
Amar3tto Mar 10, 2025
e57c0da
Fix
Amar3tto Mar 11, 2025
786b469
Merge pull request #542 from akvelon/local-march-10
Amar3tto Mar 11, 2025
1ad8961
Test spark 3
Amar3tto Mar 11, 2025
381f6fd
Merge pull request #543 from akvelon/local-march-10
Amar3tto Mar 11, 2025
c215309
Test spark 3
Amar3tto Mar 11, 2025
a2f2942
Merge pull request #544 from akvelon/local-march-10
Amar3tto Mar 11, 2025
2efc0f9
Test spark 3
Amar3tto Mar 11, 2025
8bfd7c3
Merge pull request #545 from akvelon/local-march-10
Amar3tto Mar 11, 2025
c5e5119
Test spark 3 and 2
Amar3tto Mar 11, 2025
13dddc7
Merge pull request #546 from akvelon/local-march-10
Amar3tto Mar 11, 2025
de62c7b
Cancel Flink jobClient
Amar3tto Mar 12, 2025
c0fafa8
Merge pull request #547 from akvelon/local-march-10
Amar3tto Mar 12, 2025
b995457
Try detached mode
Amar3tto Mar 12, 2025
20a56d2
Merge pull request #548 from akvelon/local-march-10
Amar3tto Mar 12, 2025
f37425e
Shutdown executor
Amar3tto Mar 12, 2025
3ea6e5c
Merge pull request #549 from akvelon/local-march-10
Amar3tto Mar 12, 2025
046e295
Add try catch
Amar3tto Mar 12, 2025
4be53c1
throw
Amar3tto Mar 12, 2025
9c8098f
Merge pull request #550 from akvelon/local-march-10
Amar3tto Mar 12, 2025
c2b0b1d
Flaky tests detection for 5 last failed
Amar3tto Mar 17, 2025
fc7ba07
Merge pull request #551 from akvelon/local-march-10
Amar3tto Mar 17, 2025
240c6ea
Sort runs
Amar3tto Mar 17, 2025
def188b
Merge pull request #552 from akvelon/local-march-10
Amar3tto Mar 17, 2025
a27b341
Do not sort runs
Amar3tto Mar 17, 2025
9da9d43
Merge pull request #553 from akvelon/local-march-10
Amar3tto Mar 17, 2025
f4ed821
fix return
Amar3tto Mar 17, 2025
65729ef
Add pytorch pipeline
Amar3tto Mar 17, 2025
eb61ae6
Merge pull request #554 from akvelon/local-march-10
Amar3tto Mar 17, 2025
68a57b1
Logging metrics
Amar3tto Mar 18, 2025
b91cf92
Merge pull request #555 from akvelon/local-march-10
Amar3tto Mar 18, 2025
e79091a
Update website: add ML pipelines performance metrics
Amar3tto Mar 18, 2025
2e75fe0
Update dataflow_cost_benchmark.py to get throughput and run time metrics
Amar3tto Mar 19, 2025
34074b5
Update yml workflow
Amar3tto Mar 19, 2025
ff9dfda
Update pcollection name
Amar3tto Mar 19, 2025
c066e5a
Merge pull request #556 from akvelon/local-march-18
Amar3tto Mar 19, 2025
2a7a0d5
Update install
Amar3tto Mar 19, 2025
129e5ca
Merge pull request #557 from akvelon/local-march-18
Amar3tto Mar 19, 2025
8106bf1
Fix import
Amar3tto Mar 19, 2025
e2007c8
Merge pull request #558 from akvelon/local-march-18
Amar3tto Mar 19, 2025
e155702
Refactoring
Amar3tto Mar 19, 2025
d75efbc
Merge pull request #559 from akvelon/local-march-18
Amar3tto Mar 19, 2025
b650adf
Fix requirements
Amar3tto Mar 19, 2025
feb5e2b
Merge pull request #560 from akvelon/local-march-18
Amar3tto Mar 19, 2025
f9fbd36
Fix project
Amar3tto Mar 19, 2025
7c803ff
Merge pull request #561 from akvelon/local-march-18
Amar3tto Mar 19, 2025
02b21ea
Refactoring
Amar3tto Mar 19, 2025
4e4550c
Merge pull request #562 from akvelon/local-march-18
Amar3tto Mar 19, 2025
3d85247
Remove beam version from metrics
Amar3tto Mar 19, 2025
98fae21
Merge pull request #563 from akvelon/local-march-18
Amar3tto Mar 19, 2025
e20567d
Remove beam version
Amar3tto Mar 19, 2025
50bccb6
Merge pull request #564 from akvelon/local-march-18
Amar3tto Mar 19, 2025
3cedb5a
Fix tensor flow requirements
Amar3tto Mar 19, 2025
3b81453
Remove redundant files
Amar3tto Mar 19, 2025
211d9c4
Merge pull request #565 from akvelon/local-march-18
Amar3tto Mar 19, 2025
02c8eb5
Fix log
Amar3tto Mar 19, 2025
9da84f7
Merge pull request #566 from akvelon/local-march-18
Amar3tto Mar 19, 2025
da98223
Install monitoring
Amar3tto Mar 20, 2025
dece331
Merge pull request #567 from akvelon/local-march-18
Amar3tto Mar 20, 2025
6296fbd
Add requirements for wordcount
Amar3tto Mar 20, 2025
fcaffcd
Merge pull request #568 from akvelon/local-march-18
Amar3tto Mar 20, 2025
9543b0d
Add requirements for wordcount
Amar3tto Mar 20, 2025
f325ecb
Merge pull request #569 from akvelon/local-march-18
Amar3tto Mar 20, 2025
eea3330
Add pcollection
Amar3tto Mar 20, 2025
ea2efa4
Merge pull request #570 from akvelon/local-march-18
Amar3tto Mar 20, 2025
70f00ea
Fill looks ids
Amar3tto Mar 20, 2025
bc235e4
Remove redundant step
Amar3tto Mar 20, 2025
40938b3
Fix PythonFormatter
Amar3tto Mar 20, 2025
21d71f7
Merge branch 'master' into local-march-18
Amar3tto Mar 20, 2025
1b0ef2e
Merge pull request #571 from akvelon/local-march-18
Amar3tto Mar 20, 2025
9bfa142
Fix PythonLint
Amar3tto Mar 20, 2025
30480ea
Merge remote-tracking branch 'origin/local-march-18' into local-march-18
Amar3tto Mar 20, 2025
955e622
Merge pull request #572 from akvelon/local-march-18
Amar3tto Mar 20, 2025
f4637d9
Fix Python Formatter and Lint
Amar3tto Mar 20, 2025
98a212e
Merge pull request #573 from akvelon/local-march-18
Amar3tto Mar 20, 2025
63cd3b4
Test change localhost
Amar3tto Mar 21, 2025
cd803e4
Merge pull request #574 from akvelon/local-march-18
Amar3tto Mar 21, 2025
3c9e409
Change address to 0.0.0.0
Amar3tto Mar 21, 2025
40296f8
Merge pull request #575 from akvelon/local-march-18
Amar3tto Mar 21, 2025
1011e15
Update Python Dependencies
Mar 23, 2025
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion .github/workflows/beam_CleanUpPrebuiltSDKImages.yml
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,7 @@ jobs:
beam_CleanUpPrebuiltSDKImages:
name: ${{ matrix.job_name }} (${{ matrix.job_phrase }})
runs-on: [self-hosted, ubuntu-20.04, main]
timeout-minutes: 180
timeout-minutes: 360
strategy:
matrix:
job_name: [beam_CleanUpPrebuiltSDKImages]
Expand Down
4 changes: 2 additions & 2 deletions .github/workflows/beam_LoadTests_Go_CoGBK_Flink_batch.yml
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,7 @@ env:
GCS_BUCKET: gs://beam-flink-cluster
FLINK_DOWNLOAD_URL: https://archive.apache.org/dist/flink/flink-1.17.0/flink-1.17.0-bin-scala_2.12.tgz
HADOOP_DOWNLOAD_URL: https://repo.maven.apache.org/maven2/org/apache/flink/flink-shaded-hadoop-2-uber/2.8.3-10.0/flink-shaded-hadoop-2-uber-2.8.3-10.0.jar
FLINK_TASKMANAGER_SLOTS: 5
FLINK_TASKMANAGER_SLOTS: 1
DETACHED_MODE: true
HARNESS_IMAGES_TO_PULL: gcr.io/apache-beam-testing/beam-sdk/beam_go_sdk:latest
JOB_SERVER_IMAGE: gcr.io/apache-beam-testing/beam_portability/beam_flink1.17_job_server:latest
Expand All @@ -64,7 +64,7 @@ jobs:
github.event_name == 'workflow_dispatch' ||
(github.event_name == 'schedule' && github.repository == 'apache/beam') ||
github.event.comment.body == 'Run Load Tests Go CoGBK Flink Batch'
runs-on: [self-hosted, ubuntu-20.04, main]
runs-on: [self-hosted, ubuntu-20.04, highmem]
timeout-minutes: 720
name: ${{ matrix.job_name }} (${{ matrix.job_phrase }})
strategy:
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -64,7 +64,7 @@ jobs:
github.event_name == 'workflow_dispatch' ||
(github.event_name == 'schedule' && github.repository == 'apache/beam') ||
github.event.comment.body == 'Run Load Tests Go Combine Flink Batch'
runs-on: [self-hosted, ubuntu-20.04, main]
runs-on: [self-hosted, ubuntu-20.04, highmem]
timeout-minutes: 720
name: ${{ matrix.job_name }} (${{ matrix.job_phrase }})
strategy:
Expand Down
4 changes: 2 additions & 2 deletions .github/workflows/beam_LoadTests_Go_GBK_Flink_Batch.yml
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,7 @@ env:
GCS_BUCKET: gs://beam-flink-cluster
FLINK_DOWNLOAD_URL: https://archive.apache.org/dist/flink/flink-1.17.0/flink-1.17.0-bin-scala_2.12.tgz
HADOOP_DOWNLOAD_URL: https://repo.maven.apache.org/maven2/org/apache/flink/flink-shaded-hadoop-2-uber/2.8.3-10.0/flink-shaded-hadoop-2-uber-2.8.3-10.0.jar
FLINK_TASKMANAGER_SLOTS: 5
FLINK_TASKMANAGER_SLOTS: 1
DETACHED_MODE: true
HARNESS_IMAGES_TO_PULL: gcr.io/apache-beam-testing/beam-sdk/beam_go_sdk:latest
JOB_SERVER_IMAGE: gcr.io/apache-beam-testing/beam_portability/beam_flink1.17_job_server:latest
Expand All @@ -64,7 +64,7 @@ jobs:
github.event_name == 'workflow_dispatch' ||
(github.event_name == 'schedule' && github.repository == 'apache/beam') ||
github.event.comment.body == 'Run Load Tests Go GBK Flink Batch'
runs-on: [self-hosted, ubuntu-20.04, main]
runs-on: [self-hosted, ubuntu-20.04, highmem]
timeout-minutes: 720
name: ${{ matrix.job_name }} (${{ matrix.job_phrase }})
strategy:
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@ name: PostCommit Python ValidatesContainer Dataflow With RC

on:
schedule:
- cron: '15 5/6 * * *'
- cron: '15 8/6 * * *'
pull_request_target:
paths: ['release/trigger_all_tests.json', '.github/trigger_files/beam_PostCommit_Python_ValidatesContainer_Dataflow_With_RC.json']
workflow_dispatch:
Expand Down Expand Up @@ -56,7 +56,7 @@ jobs:
github.event_name == 'pull_request_target' ||
startsWith(github.event.comment.body, 'Run Python RC Dataflow ValidatesContainer')
runs-on: [self-hosted, ubuntu-20.04, main]
timeout-minutes: 100
timeout-minutes: 300
name: ${{ matrix.job_name }} (${{ matrix.job_phrase }} ${{ matrix.python_version }})
strategy:
fail-fast: false
Expand Down
34 changes: 26 additions & 8 deletions .github/workflows/beam_PostCommit_XVR_GoUsingJava_Dataflow.yml
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@
# TODO(https://github.com/apache/beam/issues/32492): re-enable the suite
# on cron and add release/trigger_all_tests.json to trigger path once fixed.

name: PostCommit XVR GoUsingJava Dataflow (DISABLED)
name: PostCommit XVR GoUsingJava Dataflow

on:
# schedule:
Expand Down Expand Up @@ -59,7 +59,7 @@ jobs:
(github.event_name == 'schedule' && github.repository == 'apache/beam') ||
github.event.comment.body == 'Run XVR_GoUsingJava_Dataflow PostCommit'
runs-on: [self-hosted, ubuntu-20.04, main]
timeout-minutes: 100
timeout-minutes: 300
name: ${{ matrix.job_name }} (${{ matrix.job_phrase }})
strategy:
matrix:
Expand All @@ -77,15 +77,33 @@ jobs:
uses: ./.github/actions/setup-environment-action
with:
python-version: default
- name: Set up Docker Buildx
uses: docker/setup-buildx-action@v1
# - name: Java container
# uses: ./.github/actions/gradle-command-self-hosted-action
# with:
# gradle-command: :sdks:java:container:java11:docker
# - name: Java expansion service
# uses: ./.github/actions/gradle-command-self-hosted-action
# with:
# gradle-command: :sdks:java:testing:expansion-service:buildTestExpansionServiceJar
# - name: Python container
# uses: ./.github/actions/gradle-command-self-hosted-action
# with:
# gradle-command: :sdks:python:container:py39:docker
# - name: Go container
# uses: ./.github/actions/gradle-command-self-hosted-action
# with:
# gradle-command: :sdks:go:container:docker
# - name: Set up Docker Buildx
# uses: docker/setup-buildx-action@v3
# with:
# install: true
# driver: 'docker-container' # Required for multi-platform builds
- name: GCloud Docker credential helper
run: |
gcloud auth configure-docker us.gcr.io
- name: run XVR GoUsingJava Dataflow script
- name: run PostCommit XVR GoUsingJava Dataflow script
env:
USER: github-actions
CLOUDSDK_CONFIG: ${{ env.KUBELET_GCLOUD_CONFIG_PATH}}
USER: jenkins
uses: ./.github/actions/gradle-command-self-hosted-action
with:
gradle-command: :runners:google-cloud-dataflow-java:validatesCrossLanguageRunnerGoUsingJava
Expand All @@ -102,4 +120,4 @@ jobs:
commit: '${{ env.prsha || env.GITHUB_SHA }}'
comment_mode: ${{ github.event_name == 'issue_comment' && 'always' || 'off' }}
files: '**/build/test-results/**/*.xml'
large_files: true
large_files: true
6 changes: 3 additions & 3 deletions .github/workflows/beam_PostRelease_NightlySnapshot.yml
Original file line number Diff line number Diff line change
Expand Up @@ -20,11 +20,11 @@ on:
inputs:
RELEASE:
description: Beam version of current release (e.g. 2.XX.0)
required: true
default: '2.XX.0'
required: false
default: ''
SNAPSHOT_URL:
description: Location of the staged artifacts in Maven central (https://repository.apache.org/content/repositories/orgapachebeam-NNNN/).
required: true
required: false
schedule:
- cron: '15 16 * * *'

Expand Down
41 changes: 19 additions & 22 deletions .github/workflows/beam_PreCommit_Flink_Container.yml
Original file line number Diff line number Diff line change
Expand Up @@ -16,28 +16,25 @@
name: PreCommit Flink Container

on:
pull_request_target:
paths:
- 'model/**'
- 'sdks/python/apache_beam/runners/portability/**'
- 'release/**'
- 'runners/core-java/**'
- 'runners/flink/**'
- 'runners/java-fn-execution/**'
- '.github/trigger_files/beam_PreCommit_Flink_Container.json'
- 'release/trigger_all_tests.json'
push:
tags: [ 'v*' ]
branches: [ 'master', 'release-*' ]
paths:
- 'model/**'
- 'sdks/python/apache_beam/runners/portability/**'
- 'release/**'
- 'runners/core-java/**'
- 'runners/flink/**'
- 'runners/java-fn-execution/**'
schedule:
- cron: '0 */6 * * *'
# pull_request_target:
# paths:
# - 'model/**'
# - 'sdks/python/**'
# - 'release/**'
# - 'sdks/java/io/kafka/**'
# - 'runners/core-construction-java/**'
# - 'runners/core-java/**'
# - 'runners/extensions-java/**'
# - 'runners/flink/**'
# - 'runners/java-fn-execution/**'
# - 'runners/reference/**'
# - '.github/trigger_files/beam_PreCommit_Flink_Container.json'
# - 'release/trigger_all_tests.json'
# push:
# branches: ['master', 'release-*']
# tags: 'v*'
# schedule:
# - cron: '0 */6 * * *'
workflow_dispatch:

# Setting explicit permissions for the action to avoid the default permissions which are `write-all`
Expand Down
22 changes: 11 additions & 11 deletions .github/workflows/beam_PreCommit_GHA.yml
Original file line number Diff line number Diff line change
Expand Up @@ -16,17 +16,17 @@
name: PreCommit GHA

on:
push:
tags: ['v*']
branches: ['master', 'release-*']
paths: ['.github/**/*.yml']
pull_request_target:
branches: ['master', 'release-*' ]
paths: ['.github/**/*.yml', 'release/trigger_all_tests.json', '.github/trigger_files/beam_PreCommit_GHA.json']
issue_comment:
types: [created]
schedule:
- cron: '0 */6 * * *'
# push:
# tags: ['v*']
# branches: ['master', 'release-*']
# paths: ['.github/**/*.yml']
# pull_request_target:
# branches: ['master', 'release-*' ]
# paths: ['.github/**/*.yml', 'release/trigger_all_tests.json', '.github/trigger_files/beam_PreCommit_GHA.json']
# issue_comment:
# types: [created]
# schedule:
# - cron: '0 */6 * * *'
workflow_dispatch:

#Setting explicit permissions for the action to avoid the default permissions which are `write-all` in case of pull_request_target event
Expand Down
22 changes: 11 additions & 11 deletions .github/workflows/beam_PreCommit_Go.yml
Original file line number Diff line number Diff line change
Expand Up @@ -16,17 +16,17 @@
name: PreCommit Go

on:
push:
tags: ['v*']
branches: ['master', 'release-*']
paths: ['model/**', 'sdks/go.mod', 'sdks/go.sum', 'sdks/go/**', 'release/**', '.github/workflows/beam_PreCommit_Go.yml']
pull_request_target:
branches: ['master', 'release-*']
paths: ['model/**', 'sdks/go.mod', 'sdks/go.sum', 'sdks/go/**', 'release/**', 'release/trigger_all_tests.json', '.github/trigger_files/beam_PreCommit_Go.json']
issue_comment:
types: [created]
schedule:
- cron: '0 1/6 * * *'
# push:
# tags: ['v*']
# branches: ['master', 'release-*']
# paths: ['model/**', 'sdks/go.mod', 'sdks/go.sum', 'sdks/go/**', 'release/**', '.github/workflows/beam_PreCommit_Go.yml']
# pull_request_target:
# branches: ['master', 'release-*']
# paths: ['model/**', 'sdks/go.mod', 'sdks/go.sum', 'sdks/go/**', 'release/**', 'release/trigger_all_tests.json', '.github/trigger_files/beam_PreCommit_Go.json']
# issue_comment:
# types: [created]
# schedule:
# - cron: '0 1/6 * * *'
workflow_dispatch:

#Setting explicit permissions for the action to avoid the default permissions which are `write-all` in case of pull_request_target event
Expand Down
22 changes: 11 additions & 11 deletions .github/workflows/beam_PreCommit_GoPortable.yml
Original file line number Diff line number Diff line change
Expand Up @@ -16,17 +16,17 @@
name: PreCommit GoPortable

on:
push:
tags: ['v*']
branches: ['master', 'release-*']
paths: ['model/**', 'sdks/go.mod', 'sdks/go.sum', 'sdks/go/**', 'release/**', '.github/workflows/beam_PreCommit_GoPortable.yml']
pull_request_target:
branches: ['master', 'release-*']
paths: ['model/**', 'sdks/go.mod', 'sdks/go.sum', 'sdks/go/**', 'release/**', 'release/trigger_all_tests.json', '.github/trigger_files/beam_PreCommit_GoPortable.json']
issue_comment:
types: [created]
schedule:
- cron: '0 1/6 * * *'
# push:
# tags: ['v*']
# branches: ['master', 'release-*']
# paths: ['model/**', 'sdks/go.mod', 'sdks/go.sum', 'sdks/go/**', 'release/**', '.github/workflows/beam_PreCommit_GoPortable.yml']
# pull_request_target:
# branches: ['master', 'release-*']
# paths: ['model/**', 'sdks/go.mod', 'sdks/go.sum', 'sdks/go/**', 'release/**', 'release/trigger_all_tests.json', '.github/trigger_files/beam_PreCommit_GoPortable.json']
# issue_comment:
# types: [created]
# schedule:
# - cron: '0 1/6 * * *'
workflow_dispatch:

# This allows a subsequently queued workflow run to interrupt previous runs
Expand Down
22 changes: 11 additions & 11 deletions .github/workflows/beam_PreCommit_GoPrism.yml
Original file line number Diff line number Diff line change
Expand Up @@ -16,17 +16,17 @@
name: PreCommit GoPrism

on:
push:
tags: ['v*']
branches: ['master', 'release-*']
paths: ['model/**', 'sdks/go.mod', 'sdks/go.sum', 'sdks/go/**', 'release/**', '.github/workflows/beam_PreCommit_GoPrism.yml']
pull_request_target:
branches: ['master', 'release-*']
paths: ['model/**', 'sdks/go.mod', 'sdks/go.sum', 'sdks/go/**', 'release/**', 'release/trigger_all_tests.json', '.github/trigger_files/beam_PreCommit_GoPrism.json']
issue_comment:
types: [created]
schedule:
- cron: '0 1/6 * * *'
# push:
# tags: ['v*']
# branches: ['master', 'release-*']
# paths: ['model/**', 'sdks/go.mod', 'sdks/go.sum', 'sdks/go/**', 'release/**', '.github/workflows/beam_PreCommit_GoPrism.yml']
# pull_request_target:
# branches: ['master', 'release-*']
# paths: ['model/**', 'sdks/go.mod', 'sdks/go.sum', 'sdks/go/**', 'release/**', 'release/trigger_all_tests.json', '.github/trigger_files/beam_PreCommit_GoPrism.json']
# issue_comment:
# types: [created]
# schedule:
# - cron: '0 1/6 * * *'
workflow_dispatch:

# This allows a subsequently queued workflow run to interrupt previous runs
Expand Down
Loading