github-actions[bot] commented on PR #34313:
URL: https://github.com/apache/beam/pull/34313#issuecomment-2727167652
Assigning reviewers. If you would like to opt out of this review, comment
`assign to next reviewer`:
R: @damccorm for label python.
Available commands:
- `stop
github-actions[bot] commented on PR #34307:
URL: https://github.com/apache/beam/pull/34307#issuecomment-2727153606
Stopping reviewer notifications for this pull request: review requested by
someone other than the bot, ceding control. If you'd like to restart, comment
`assign set of reviewer
Suvrat1629 commented on PR #34307:
URL: https://github.com/apache/beam/pull/34307#issuecomment-2727153118
R: @rohitsinha54
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
liferoad opened a new pull request, #34313:
URL: https://github.com/apache/beam/pull/34313
Fix #21006
Thank you for your contribution! Follow this checklist to help us
incorporate your contribution quickly and easily:
- [ ] Mention the appropria
liferoad commented on issue #18029:
URL: https://github.com/apache/beam/issues/18029#issuecomment-2727116909
https://github.com/apache/beam/blob/master/sdks/python/apache_beam/examples/cookbook/multiple_output_pardo_test.py
Probably keeping the current code is good for now. We can alw
liferoad closed issue #18029: Update Python SDK example tests to use assert_that
URL: https://github.com/apache/beam/issues/18029
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
github-actions[bot] commented on PR #34310:
URL: https://github.com/apache/beam/pull/34310#issuecomment-2727114339
Stopping reviewer notifications for this pull request: review requested by
someone other than the bot, ceding control. If you'd like to restart, comment
`assign set of reviewer
shunping commented on PR #34310:
URL: https://github.com/apache/beam/pull/34310#issuecomment-2727113869
r: @damccorm
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To uns
github-actions[bot] commented on PR #34312:
URL: https://github.com/apache/beam/pull/34312#issuecomment-2727107827
Stopping reviewer notifications for this pull request: review requested by
someone other than the bot, ceding control. If you'd like to restart, comment
`assign set of reviewer
rohitsinha54 commented on PR #34312:
URL: https://github.com/apache/beam/pull/34312#issuecomment-2727107364
R: @robertwb
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To
rohitsinha54 opened a new pull request, #34312:
URL: https://github.com/apache/beam/pull/34312
… SDK will make it report Lineage as BoundedTrie
**Please** add a meaningful description for your change here
Thank you for your contribution! Follow th
shunping commented on PR #34310:
URL: https://github.com/apache/beam/pull/34310#issuecomment-2727042999
Run Python_Dataframes PreCommit 3.12
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the sp
shunping opened a new pull request, #34311:
URL: https://github.com/apache/beam/pull/34311
(no comment)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-ma
shunping opened a new pull request, #34310:
URL: https://github.com/apache/beam/pull/34310
**Please** add a meaningful description for your change here
Thank you for your contribution! Follow this checklist to help us
incorporate your contribution quick
liferoad closed issue #19899: GCS IO fails with uninformative 'Broken pipe'
errors while attempting to write to a GCS bucket without proper permissions.
URL: https://github.com/apache/beam/issues/19899
--
This is an automated message from the Apache Git Service.
To respond to the message, ple
liferoad commented on issue #19899:
URL: https://github.com/apache/beam/issues/19899#issuecomment-2727019145
Tested this with this using `gs://test`, which I do not have the access:
```
cd sdks/python
pip install build && python -m build --sdist
scripts/run_integration_test.sh --t
shunping opened a new pull request, #34309:
URL: https://github.com/apache/beam/pull/34309
Support offline detectors that are based on ModelHandler.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go t
liferoad commented on issue #21577:
URL: https://github.com/apache/beam/issues/21577#issuecomment-2726983578
https://github.com/apache/beam/issues/25676 switched to the gcs library.
This probably logs this inside the library. Close this for now.
--
This is an automated message from the A
liferoad closed issue #21577: Log GCS upload ID for Python GCS connector
URL: https://github.com/apache/beam/issues/21577
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To uns
Amar3tto commented on issue #31968:
URL: https://github.com/apache/beam/issues/31968#issuecomment-2726929272
Fixed by https://github.com/apache/beam/pull/34078
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
Amar3tto closed issue #31968: The StressTests Java BigQueryIO job is flaky
URL: https://github.com/apache/beam/issues/31968
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To u
lostluck commented on PR #34307:
URL: https://github.com/apache/beam/pull/34307#issuecomment-2726906977
assign to next reviewer
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific commen
github-actions[bot] commented on PR #34307:
URL: https://github.com/apache/beam/pull/34307#issuecomment-2726900386
Assigning reviewers. If you would like to opt out of this review, comment
`assign to next reviewer`:
R: @lostluck added as fallback since no labels match configuration
liferoad commented on PR #34196:
URL: https://github.com/apache/beam/pull/34196#issuecomment-2726864670
https://github.com/apache/beam/actions/runs/13814130500/job/38824779287 also
keeps failing.
--
This is an automated message from the Apache Git Service.
To respond to the message, p
tvalentyn closed pull request #34199: Remove a note about cloudpickle support
being experimental
URL: https://github.com/apache/beam/pull/34199
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the sp
damccorm commented on code in PR #34078:
URL: https://github.com/apache/beam/pull/34078#discussion_r1993611275
##
it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/bigquery/BigQueryIOST.java:
##
@@ -255,7 +257,9 @@ private void runTest() throws IOException {
github-actions[bot] commented on PR #34238:
URL: https://github.com/apache/beam/pull/34238#issuecomment-2712044243
Assigning reviewers. If you would like to opt out of this review, comment
`assign to next reviewer`:
R: @damccorm for label python.
Available commands:
- `stop
shunping commented on code in PR #34232:
URL: https://github.com/apache/beam/pull/34232#discussion_r1987842803
##
sdks/python/apache_beam/ml/anomaly/detectors/robust_zscore.py:
##
@@ -0,0 +1,119 @@
+#
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contr
ahmedabu98 commented on code in PR #33504:
URL: https://github.com/apache/beam/pull/33504#discussion_r1987873614
##
sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/IcebergIO.java:
##
@@ -310,7 +409,155 @@
*
*
*
- * For internal use only; no backwards
github-actions[bot] commented on PR #34305:
URL: https://github.com/apache/beam/pull/34305#issuecomment-2726046159
Stopping reviewer notifications for this pull request: review requested by
someone other than the bot, ceding control. If you'd like to restart, comment
`assign set of reviewer
liferoad opened a new issue, #34287:
URL: https://github.com/apache/beam/issues/34287
### What happened?
https://beam.apache.org/releases/pydoc/current/apache_beam.transforms.core.html
https://github.com/user-attachments/assets/c9c613c7-9cb3-4b68-9174-7762cad3cb50";
/>
svetakvsundhar commented on PR #34299:
URL: https://github.com/apache/beam/pull/34299#issuecomment-2725578973
R: @liferoad
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
shunping commented on PR #34273:
URL: https://github.com/apache/beam/pull/34273#issuecomment-2723099684
> > Oh, please fix linting though
>
> Fixed. Waiting for the tests to finish.
@damccorm, the tests are fine now. PTAL. Thanks!
--
This is an automated message from the Apac
Naireen commented on code in PR #34275:
URL: https://github.com/apache/beam/pull/34275#discussion_r1996399018
##
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/ReadFromKafkaDoFn.java:
##
@@ -454,7 +454,9 @@ public ProcessContinuation processElement(
final S
Suvrat1629 opened a new pull request, #34307:
URL: https://github.com/apache/beam/pull/34307
**Please** add a meaningful description for your change here
This PR addresses issue #33448, where gauge metrics were not being extracted
into the metrics results i
liferoad commented on PR #34196:
URL: https://github.com/apache/beam/pull/34196#issuecomment-2726779979
`grpcio==1.71.0` seems not working well. many tests keep failing:
https://github.com/apache/beam/actions/runs/13873590601/job/38823181322?pr=34196
--
This is an automated message from t
robertwb commented on code in PR #34193:
URL: https://github.com/apache/beam/pull/34193#discussion_r1985471758
##
sdks/python/apache_beam/runners/worker/operations.py:
##
@@ -1280,33 +1280,37 @@ def process(self, wkv):
# pylint: disable=unidiomatic-typecheck
# Opti
liferoad commented on PR #34227:
URL: https://github.com/apache/beam/pull/34227#issuecomment-2711343539
which python are you using?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific c
github-actions[bot] commented on PR #34222:
URL: https://github.com/apache/beam/pull/34222#issuecomment-2708788645
Checks are failing. Will not request review until checks are succeeding. If
you'd like to override that behavior, comment `assign set of reviewers`
--
This is an automated me
twosom commented on PR #34272:
URL: https://github.com/apache/beam/pull/34272#issuecomment-2719745586
Run Java Spark v3 PortableValidatesRunner Streaming
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to
liferoad commented on issue #30145:
URL: https://github.com/apache/beam/issues/30145#issuecomment-2724858384
Good idea.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To u
shunping opened a new pull request, #34273:
URL: https://github.com/apache/beam/pull/34273
With this PR, we will now support generating Spec for a specifiable
initialized with classes or functions as init arguments.
--
This is an automated message from the Apache Git Service.
To respond t
kennknowles commented on code in PR #33037:
URL: https://github.com/apache/beam/pull/33037#discussion_r1987545549
##
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/SimpleParDoFn.java:
##
@@ -516,10 +520,14 @@ private void
regist
Naireen commented on PR #34244:
URL: https://github.com/apache/beam/pull/34244#issuecomment-2720101993
Run Java PreCommit
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To
ahmedabu98 commented on code in PR #33504:
URL: https://github.com/apache/beam/pull/33504#discussion_r1987743929
##
sdks/java/managed/src/main/java/org/apache/beam/sdk/managed/Managed.java:
##
@@ -108,6 +110,7 @@ public class Managed {
*
*
* {@link Managed#ICEBERG
claudevdm commented on PR #34162:
URL: https://github.com/apache/beam/pull/34162#issuecomment-2703816929
Looks like the tests are all green @damccorm .
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to g
github-actions[bot] commented on PR #34237:
URL: https://github.com/apache/beam/pull/34237#issuecomment-2711500128
Assigning reviewers. If you would like to opt out of this review, comment
`assign to next reviewer`:
R: @damondouglas for label java.
Available commands:
- `sto
Abacn commented on PR #34230:
URL: https://github.com/apache/beam/pull/34230#issuecomment-2711082480
Thank you for the contribution! Would you mind find a team member (for
example, another contributor in ClickHouse) for first pass of review and I can
help merging the change
--
This is an
scwhittle commented on code in PR #34275:
URL: https://github.com/apache/beam/pull/34275#discussion_r1995479936
##
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/ReadFromKafkaDoFn.java:
##
@@ -558,8 +560,8 @@ public ProcessContinuation processElement(
Amar3tto commented on issue #30513:
URL: https://github.com/apache/beam/issues/30513#issuecomment-2724822414
Job has been stable for 1 day. Closing as resolved.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL a
robertwb opened a new pull request, #34305:
URL: https://github.com/apache/beam/pull/34305
Handle numeric promotion, sequence multiplication, and fix division for
Python 3.11+.
Thank you for your contribution! Follow this checklist to help us
incorpora
ahmedabu98 commented on code in PR #33504:
URL: https://github.com/apache/beam/pull/33504#discussion_r1985714490
##
sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/IncrementalScanSource.java:
##
@@ -0,0 +1,163 @@
+/*
+ * Licensed to the Apache Software Foundati
robertwb merged PR #34290:
URL: https://github.com/apache/beam/pull/34290
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscr...@beam.apache
github-actions[bot] commented on PR #34180:
URL: https://github.com/apache/beam/pull/34180#issuecomment-2703543445
Stopping reviewer notifications for this pull request: review requested by
someone other than the bot, ceding control. If you'd like to restart, comment
`assign set of reviewer
mataralhawiti commented on issue #34224:
URL: https://github.com/apache/beam/issues/34224#issuecomment-2710580358
thanks @liferoad for the update, that's what I thought.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
svetakvsundhar opened a new pull request, #34299:
URL: https://github.com/apache/beam/pull/34299
Remove `svetakvsundhar` as a healthcare reviewer assigned by the bot.
Thank you for your contribution! Follow this checklist to help us
incorporate you
damccorm merged PR #34298:
URL: https://github.com/apache/beam/pull/34298
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscr...@beam.apache
akashorabek closed pull request #34229: Precommit flink container 2 (PR for
testing purposes)
URL: https://github.com/apache/beam/pull/34229
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the speci
Brijeshthummar02 commented on PR #34227:
URL: https://github.com/apache/beam/pull/34227#issuecomment-2711229200
@mataralhawiti just to mention i have used this to check
```
yapf --diff --parallel --recursive sdks/python/apache_beam
```
and this to automatically fix the formattin
github-actions[bot] commented on PR #34140:
URL: https://github.com/apache/beam/pull/34140#issuecomment-2703671496
Assigning reviewers. If you would like to opt out of this review, comment
`assign to next reviewer`:
R: @damondouglas for label java.
R: @chamikaramj for label io.
github-actions[bot] commented on PR #34001:
URL: https://github.com/apache/beam/pull/34001#issuecomment-2703679389
Reminder, please take a look at this pr: @liferoad
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
shunping opened a new pull request, #34234:
URL: https://github.com/apache/beam/pull/34234
(no comment)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-ma
damccorm merged PR #34231:
URL: https://github.com/apache/beam/pull/34231
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscr...@beam.apache
Abacn opened a new pull request, #34237:
URL: https://github.com/apache/beam/pull/34237
We don't need this after avro is fully moved out of sdks/java/core
Resolve a TODO added in #25611
**Please** add a meaningful description for your change here
charlespnh commented on PR #34142:
URL: https://github.com/apache/beam/pull/34142#issuecomment-2712506768
Here it is https://github.com/apache/beam/issues/34242
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL a
Brijeshthummar02 commented on PR #34227:
URL: https://github.com/apache/beam/pull/34227#issuecomment-2711287638
@liferoad your point makes sense, but what i think using
```
yapf --in-place --parallel --recursive sdks/python/apache_beam
```
will like format our whole repo that sho
rohitsinha54 commented on PR #34294:
URL: https://github.com/apache/beam/pull/34294#issuecomment-2724132667
This PR submission will start making the post submit Dataflow worker tests
which exercises Dataflow runner test fails since the backend can accept
BoundedTrie but cannot persist and s
dependabot[bot] commented on PR #34157:
URL: https://github.com/apache/beam/pull/34157#issuecomment-2705519186
Superseded by #34203.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific c
Abacn commented on PR #34237:
URL: https://github.com/apache/beam/pull/34237#issuecomment-2711784404
R: @claudevdm
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsub
Abacn opened a new pull request, #34214:
URL: https://github.com/apache/beam/pull/34214
in an attempt to fix "data race ExecutionStateTracker.java:261 in
org.apache.beam.runners.core.metrics.ExecutionStateTracker.deactivate()V"
reported by internal test (internal bug: 401543527)
The
liferoad merged PR #34297:
URL: https://github.com/apache/beam/pull/34297
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscr...@beam.apache
scwhittle commented on code in PR #34283:
URL: https://github.com/apache/beam/pull/34283#discussion_r1995469504
##
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/AbstractWindmillStream.java:
##
@@ -236,14 +236,20 @
liferoad merged PR #34306:
URL: https://github.com/apache/beam/pull/34306
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscr...@beam.apache
liferoad commented on issue #32743:
URL: https://github.com/apache/beam/issues/32743#issuecomment-2726579160
`ARTIFACTS_DIR` should accept the gs bucket. This is what we do with the
Dataproc Flink
cluster:https://github.com/apache/beam/blob/bef5238b76b6fe6c3c55be0926148f6b8dc5eb95/.test-inf
liferoad closed issue #34287: [Bug]: Python doc misses Copyright
URL: https://github.com/apache/beam/issues/34287
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe
github-actions[bot] commented on PR #34306:
URL: https://github.com/apache/beam/pull/34306#issuecomment-2726719249
Assigning reviewers. If you would like to opt out of this review, comment
`assign to next reviewer`:
R: @jrmccluskey for label python.
Available commands:
- `st
liferoad commented on PR #34306:
URL: https://github.com/apache/beam/pull/34306#issuecomment-2726573979
Thanks for contributing.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comme
liferoad commented on issue #28342:
URL: https://github.com/apache/beam/issues/28342#issuecomment-2726576341
I think we can at least update these:
Python 3 support: we already support Python 3.12 and sunset Python 3.8.
Supporting 3.13 is on the roadmap.
Java 17 support: this is
github-actions[bot] commented on PR #33543:
URL: https://github.com/apache/beam/pull/33543#issuecomment-2726498849
This pull request has been marked as stale due to 60 days of inactivity. It
will be closed in 1 week if no further activity occurs. If you think that’s
incorrect or this pull r
github-actions[bot] commented on PR #33532:
URL: https://github.com/apache/beam/pull/33532#issuecomment-2726498855
This pull request has been marked as stale due to 60 days of inactivity. It
will be closed in 1 week if no further activity occurs. If you think that’s
incorrect or this pull r
github-actions[bot] commented on PR #32360:
URL: https://github.com/apache/beam/pull/32360#issuecomment-2726482256
Reminder, please take a look at this pr: @robertwb @chamikaramj
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHu
github-actions[bot] commented on PR #33072:
URL: https://github.com/apache/beam/pull/33072#issuecomment-2726482252
Reminder, please take a look at this pr: @damondouglas @Abacn
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
github-actions[bot] commented on PR #34063:
URL: https://github.com/apache/beam/pull/34063#issuecomment-2726482239
Reminder, please take a look at this pr: @kennknowles @johnjcasey
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
github-actions[bot] commented on PR #31608:
URL: https://github.com/apache/beam/pull/31608#issuecomment-2726482264
Reminder, please take a look at this pr: @kennknowles @johnjcasey
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
liferoad merged PR #34299:
URL: https://github.com/apache/beam/pull/34299
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscr...@beam.apache
85 matches
Mail list logo
