github-actions[bot] commented on PR #30699:
URL: https://github.com/apache/beam/pull/30699#issuecomment-2011254129
Assigning reviewers. If you would like to opt out of this review, comment
`assign to next reviewer`:
R: @lostluck for label go.
Available commands:
- `stop
github-actions[bot] commented on PR #30698:
URL: https://github.com/apache/beam/pull/30698#issuecomment-2011254194
Assigning reviewers. If you would like to opt out of this review, comment
`assign to next reviewer`:
R: @riteshghorse for label go.
Available commands:
- `stop
liferoad commented on code in PR #30696:
URL: https://github.com/apache/beam/pull/30696#discussion_r1532926148
##
sdks/python/apache_beam/runners/worker/sdk_worker.py:
##
@@ -1272,14 +1277,40 @@ def _lazy_iterator(
:return A generator which returns the next element if
kennknowles merged PR #30691:
URL: https://github.com/apache/beam/pull/30691
--
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:
kennknowles commented on PR #30545:
URL: https://github.com/apache/beam/pull/30545#issuecomment-2010761636
Rebased passed the failure at HEAD just to get a fully green signal on this
PR.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
Abacn commented on PR #30696:
URL: https://github.com/apache/beam/pull/30696#issuecomment-2010690599
example:
--
This is an automated message from the Apache Git Service.
To respond to
kennknowles commented on code in PR #30545:
URL: https://github.com/apache/beam/pull/30545#discussion_r1532980254
##
sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/RedistributeTest.java:
##
@@ -0,0 +1,396 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
Abacn opened a new pull request, #30696:
URL: https://github.com/apache/beam/pull/30696
**Please** add a meaningful description for your change here
Thank you for your contribution! Follow this checklist to help us
incorporate your contribution quickly
github-actions[bot] commented on PR #30690:
URL: https://github.com/apache/beam/pull/30690#issuecomment-2010864181
Assigning reviewers. If you would like to opt out of this review, comment
`assign to next reviewer`:
R: @Abacn for label build.
Available commands:
- `stop
github-actions[bot] commented on PR #30695:
URL: https://github.com/apache/beam/pull/30695#issuecomment-2010726451
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
Abacn merged PR #30630:
URL: https://github.com/apache/beam/pull/30630
--
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:
m-trieu commented on PR #30425:
URL: https://github.com/apache/beam/pull/30425#issuecomment-2011033112
@Abacn @kennknowles It looks like it cannot find a dependency i added
i only added it this gradle file
akashorabek commented on PR #30630:
URL: https://github.com/apache/beam/pull/30630#issuecomment-2010893498
Run Java_Examples_Dataflow 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
codecov[bot] commented on PR #30698:
URL: https://github.com/apache/beam/pull/30698#issuecomment-2011223695
##
[Codecov](https://app.codecov.io/gh/apache/beam/pull/30698?dropdown=coverage=pr=h1_medium=referral_source=github_content=comment_campaign=pr+comments_term=apache)
Report
All
codecov[bot] commented on PR #30699:
URL: https://github.com/apache/beam/pull/30699#issuecomment-2011223569
##
[Codecov](https://app.codecov.io/gh/apache/beam/pull/30699?dropdown=coverage=pr=h1_medium=referral_source=github_content=comment_campaign=pr+comments_term=apache)
Report
All
dependabot[bot] opened a new pull request, #30699:
URL: https://github.com/apache/beam/pull/30699
Bumps
[google.golang.org/api](https://github.com/googleapis/google-api-go-client)
from 0.166.0 to 0.170.0.
Release notes
Sourced from
damondouglas merged PR #30690:
URL: https://github.com/apache/beam/pull/30690
--
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:
dependabot[bot] opened a new pull request, #30698:
URL: https://github.com/apache/beam/pull/30698
Bumps [github.com/golang/protobuf](https://github.com/golang/protobuf) from
1.5.3 to 1.5.4.
Release notes
Sourced from
github-actions[bot] commented on PR #30696:
URL: https://github.com/apache/beam/pull/30696#issuecomment-2010905176
Assigning reviewers. If you would like to opt out of this review, comment
`assign to next reviewer`:
R: @riteshghorse for label python.
Available commands:
-
akashorabek commented on PR #30630:
URL: https://github.com/apache/beam/pull/30630#issuecomment-2008707627
Run Kotlin_Examples 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
akashorabek commented on PR #30630:
URL: https://github.com/apache/beam/pull/30630#issuecomment-2008707523
Run Java_Examples_Dataflow 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
potiuk commented on issue #29149:
URL: https://github.com/apache/beam/issues/29149#issuecomment-2008716900
Hey. Friendly question here.
After Datastax fixed their libev support for cassandra-driver (testing it in
https://github.com/apache/airflow/pull/38314) , Papermill and Apache
scwhittle commented on code in PR #30545:
URL: https://github.com/apache/beam/pull/30545#discussion_r1531976044
##
runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowPipelineTranslator.java:
##
@@ -917,6 +919,41 @@ private void
akashorabek commented on PR #30630:
URL: https://github.com/apache/beam/pull/30630#issuecomment-2009164781
Run Java_Examples_Dataflow 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
yuwtennis commented on issue #21577:
URL: https://github.com/apache/beam/issues/21577#issuecomment-2009405325
Hello. Is this issue already implemented ? I see `upload_id` when I increase
the log level.
```
DEBUG:urllib3.connectionpool:https://storage.googleapis.com:443 "PUT
scwhittle commented on code in PR #30679:
URL: https://github.com/apache/beam/pull/30679#discussion_r1531797806
##
sdks/python/apache_beam/runners/worker/sdk_worker.py:
##
@@ -607,12 +607,16 @@ def _schedule_periodic_shutdown(self):
# type: () -> None
def
akashorabek commented on PR #30630:
URL: https://github.com/apache/beam/pull/30630#issuecomment-2009407880
Run Java_Examples_Dataflow 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
akashorabek commented on PR #30630:
URL: https://github.com/apache/beam/pull/30630#issuecomment-2009165137
Run Kotlin_Examples 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
Amar3tto opened a new pull request, #30687:
URL: https://github.com/apache/beam/pull/30687
Thank you for your contribution! Follow this checklist to help us
incorporate your contribution quickly and easily:
- [ ] Mention the appropriate issue
scwhittle commented on code in PR #30681:
URL: https://github.com/apache/beam/pull/30681#discussion_r1531597620
##
sdks/python/apache_beam/runners/common.py:
##
@@ -1941,3 +1945,64 @@ def validate_transform(transform_id):
for t in pipeline_proto.root_transform_ids:
akashorabek commented on PR #30630:
URL: https://github.com/apache/beam/pull/30630#issuecomment-2009051676
Run Kotlin_Examples 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
je-ik commented on code in PR #30545:
URL: https://github.com/apache/beam/pull/30545#discussion_r1531638179
##
runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkStreamingTransformTranslators.java:
##
@@ -921,6 +926,38 @@ public void translateNode(
}
}
+
je-ik commented on code in PR #30545:
URL: https://github.com/apache/beam/pull/30545#discussion_r1531641777
##
sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/RedistributeTest.java:
##
@@ -0,0 +1,396 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
je-ik commented on code in PR #30545:
URL: https://github.com/apache/beam/pull/30545#discussion_r1531642528
##
runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkBatchPortablePipelineTranslator.java:
##
@@ -290,6 +296,26 @@ public
akashorabek commented on PR #30630:
URL: https://github.com/apache/beam/pull/30630#issuecomment-2009061574
Run Kotlin_Examples 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
olehborysevych opened a new pull request, #30686:
URL: https://github.com/apache/beam/pull/30686
Duet AI prompts for:
CSV
JSON
Parquet
Avro
Thank you for your contribution! Follow this checklist to help us
incorporate your contribution quickly
akashorabek commented on PR #30630:
URL: https://github.com/apache/beam/pull/30630#issuecomment-2008998407
Run Java_Examples_Dataflow 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
akashorabek commented on PR #30630:
URL: https://github.com/apache/beam/pull/30630#issuecomment-2008998653
Run Kotlin_Examples 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
riteshghorse opened a new pull request, #30689:
URL: https://github.com/apache/beam/pull/30689
[Notebook
link](https://colab.research.google.com/drive/1p9jRi3Q9UWMiRysZ3hKdeMr734tstWNw?usp=sharing)
Add an example notebook to demonstrate enrichment transform with Vertex AI
Feature
kennknowles commented on PR #30545:
URL: https://github.com/apache/beam/pull/30545#issuecomment-2009846203
Seems that streaming wordcount is timing out at 900 seconds pretty reliably
:-/
I'll keep kicking that test perhaps. Presumably it has about 1 second of
compute and 15 minutes
damccorm commented on code in PR #30679:
URL: https://github.com/apache/beam/pull/30679#discussion_r1532121334
##
sdks/python/apache_beam/runners/worker/sdk_worker.py:
##
@@ -607,12 +607,16 @@ def _schedule_periodic_shutdown(self):
# type: () -> None
def
kennknowles commented on code in PR #30545:
URL: https://github.com/apache/beam/pull/30545#discussion_r1532287597
##
runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowPipelineTranslator.java:
##
@@ -917,6 +919,41 @@ private void
Polber commented on issue #28686:
URL: https://github.com/apache/beam/issues/28686#issuecomment-2009833954
.take-issue
--
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
Polber commented on issue #28699:
URL: https://github.com/apache/beam/issues/28699#issuecomment-2009834175
.take-issue
--
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
rthneha opened a new issue, #30688:
URL: https://github.com/apache/beam/issues/30688
### What happened?
I have configured PulsarIO plugin via Beam to read messages from Pulsar as
below:
```
PCollection pCollectionAll = p.apply("ReadPulsarMessage",
PulsarIO
riteshghorse commented on PR #30689:
URL: https://github.com/apache/beam/pull/30689#issuecomment-2009657862
R: @rszper
--
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
gdiazdelrio commented on issue #21060:
URL: https://github.com/apache/beam/issues/21060#issuecomment-2009703761
Hi. Is there any intention on following up with this idea? Or is it stale?
We could definitely make use of an MQTT connector for Python or, in its defect,
an External Transform
tvalentyn commented on code in PR #30679:
URL: https://github.com/apache/beam/pull/30679#discussion_r1532292874
##
sdks/python/apache_beam/runners/worker/sdk_worker.py:
##
@@ -607,12 +607,18 @@ def _schedule_periodic_shutdown(self):
# type: () -> None
def
github-actions[bot] commented on PR #30689:
URL: https://github.com/apache/beam/pull/30689#issuecomment-2009660598
Stopping reviewer notifications for this pull request: review requested by
someone other than the bot, ceding control
--
This is an automated message from the Apache Git
riteshghorse merged PR #30685:
URL: https://github.com/apache/beam/pull/30685
--
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:
scwhittle commented on code in PR #30679:
URL: https://github.com/apache/beam/pull/30679#discussion_r1532144088
##
sdks/python/apache_beam/runners/worker/sdk_worker.py:
##
@@ -607,12 +607,18 @@ def _schedule_periodic_shutdown(self):
# type: () -> None
def
kennknowles commented on PR #30545:
URL: https://github.com/apache/beam/pull/30545#issuecomment-2009853881
Hmm actually seeing
```
java.lang.BootstrapMethodError: java.lang.NoClassDefFoundError:
com/github/benmanes/caffeine/cache/RemovalCause
2024-03-20 10:54:38.890 EDT
kennknowles commented on PR #30425:
URL: https://github.com/apache/beam/pull/30425#issuecomment-2009858870
On #30545 I'm seeing this failure crashlooping the streaming wordcount
integration tests:
```
java.lang.BootstrapMethodError: java.lang.NoClassDefFoundError:
andreydevyatkin closed issue #30657: The PostCommit Python ValidatesRunner
Samza job is flaky
URL: https://github.com/apache/beam/issues/30657
--
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
volatilemolotov commented on PR #30673:
URL: https://github.com/apache/beam/pull/30673#issuecomment-2010201646
Run Python_Coverage 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
damondouglas opened a new pull request, #30690:
URL: https://github.com/apache/beam/pull/30690
This PR addresses #30447 assigning a unique Google Cloud storage path to
mobile gaming tests' output.
Thank you for your contribution! Follow this checklist
damccorm merged PR #32:
URL: https://github.com/apache/beam-starter-go/pull/32
--
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:
damccorm commented on code in PR #30679:
URL: https://github.com/apache/beam/pull/30679#discussion_r1532352373
##
sdks/python/apache_beam/runners/worker/sdk_worker.py:
##
@@ -607,12 +607,18 @@ def _schedule_periodic_shutdown(self):
# type: () -> None
def
lostluck merged PR #30684:
URL: https://github.com/apache/beam/pull/30684
--
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:
dependabot[bot] opened a new pull request, #32:
URL: https://github.com/apache/beam-starter-go/pull/32
Bumps [github.com/docker/docker](https://github.com/docker/docker) from
24.0.7+incompatible to 24.0.9+incompatible.
Release notes
Sourced from
github-actions[bot] commented on PR #30693:
URL: https://github.com/apache/beam/pull/30693#issuecomment-2010529055
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
damccorm merged PR #30694:
URL: https://github.com/apache/beam/pull/30694
--
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:
Abacn commented on PR #30425:
URL: https://github.com/apache/beam/pull/30425#issuecomment-2010317923
It is related: The push trigger for this PR is the first failed one:
https://github.com/apache/beam/actions/runs/8345017925
Abacn commented on PR #30425:
URL: https://github.com/apache/beam/pull/30425#issuecomment-2010319013
This now blocks Java open PRs, we should revert it then investigate
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
Abacn commented on PR #30691:
URL: https://github.com/apache/beam/pull/30691#issuecomment-2010320793
R: @damondouglas @kennknowles
breaks Java Example Dataflow PreCommit
--
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 issue #30657:
URL: https://github.com/apache/beam/issues/30657#issuecomment-2010329675
Reopening since the workflow is still flaky
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
damccorm opened a new pull request, #30694:
URL: https://github.com/apache/beam/pull/30694
This should be actioned on immediately, so we'll send an email to do so.
Thank you for your contribution! Follow this checklist to help us
incorporate your
damccorm commented on PR #30694:
URL: https://github.com/apache/beam/pull/30694#issuecomment-2010459941
R: @liferoad @ahmedabu98
--
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
riteshghorse opened a new pull request, #30692:
URL: https://github.com/apache/beam/pull/30692
Adds beam webpage for vertex ai enrichment handler and update the transform
catalog.
Part of #30386
Thank you for your contribution! Follow this
github-actions[bot] commented on PR #30691:
URL: https://github.com/apache/beam/pull/30691#issuecomment-2010325798
Stopping reviewer notifications for this pull request: review requested by
someone other than the bot, ceding control
--
This is an automated message from the Apache Git
arvindram03 opened a new pull request, #30693:
URL: https://github.com/apache/beam/pull/30693
Reverts apache/beam#30648
--
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
github-actions[bot] commented on PR #30694:
URL: https://github.com/apache/beam/pull/30694#issuecomment-2010461812
Stopping reviewer notifications for this pull request: review requested by
someone other than the bot, ceding control
--
This is an automated message from the Apache Git
damccorm merged PR #30679:
URL: https://github.com/apache/beam/pull/30679
--
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:
m-trieu opened a new pull request, #30695:
URL: https://github.com/apache/beam/pull/30695
**Please** add a meaningful description for your change here
Thank you for your contribution! Follow this checklist to help us
incorporate your contribution
74 matches
Mail list logo
