github-actions[bot] commented on PR #36042:
URL: https://github.com/apache/beam/pull/36042#issuecomment-3250885020
Assigning reviewers:
R: @jrmccluskey for label go.
Note: If you would like to opt out of this review, comment `assign to next
reviewer`.
Available comma
dependabot[bot] opened a new pull request, #36042:
URL: https://github.com/apache/beam/pull/36042
Bumps
[github.com/aws/aws-sdk-go-v2/service/s3](https://github.com/aws/aws-sdk-go-v2)
from 1.87.2 to 1.87.3.
Commits
https://github.com/aws/aws-sdk-go-v2/commit/640b80872b2c49ad52
shunping commented on code in PR #36014:
URL: https://github.com/apache/beam/pull/36014#discussion_r2319915328
##
sdks/python/apache_beam/io/jdbc.py:
##
@@ -96,10 +95,11 @@
from apache_beam.transforms.external import BeamJarExpansionService
from apache_beam.transforms.external
liferoad commented on PR #36036:
URL: https://github.com/apache/beam/pull/36036#issuecomment-3250653558
/gemini review
--
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 un
gemini-code-assist[bot] commented on code in PR #36036:
URL: https://github.com/apache/beam/pull/36036#discussion_r2320095874
##
sdks/python/apache_beam/yaml/examples/transforms/blueprint/iceberg_to_alloydb.yaml:
##
@@ -0,0 +1,51 @@
+# coding=utf-8
+#
+# Licensed to the Apache S
liferoad commented on code in PR #36036:
URL: https://github.com/apache/beam/pull/36036#discussion_r2320093761
##
sdks/python/apache_beam/yaml/examples/transforms/blueprint/iceberg_to_alloydb.yaml:
##
@@ -0,0 +1,55 @@
+# coding=utf-8
+#
+# Licensed to the Apache Software Foundat
derrickaw commented on code in PR #36036:
URL: https://github.com/apache/beam/pull/36036#discussion_r2320023053
##
sdks/python/apache_beam/yaml/examples/transforms/blueprint/iceberg_to_alloydb.yaml:
##
@@ -0,0 +1,55 @@
+# coding=utf-8
+#
+# Licensed to the Apache Software Founda
tarun-google commented on code in PR #36036:
URL: https://github.com/apache/beam/pull/36036#discussion_r2320011622
##
sdks/python/apache_beam/yaml/examples/transforms/blueprint/iceberg_to_alloydb.yaml:
##
@@ -0,0 +1,55 @@
+# coding=utf-8
+#
+# Licensed to the Apache Software Fou
shunping closed issue #36013: [Bug]: JDBC logical type not found when running a
Python pipeline in docker env
URL: https://github.com/apache/beam/issues/36013
--
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
shunping commented on code in PR #36014:
URL: https://github.com/apache/beam/pull/36014#discussion_r2319951676
##
sdks/python/apache_beam/io/jdbc.py:
##
@@ -96,10 +95,11 @@
from apache_beam.transforms.external import BeamJarExpansionService
from apache_beam.transforms.external
shunping merged PR #36014:
URL: https://github.com/apache/beam/pull/36014
--
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
derrickaw commented on code in PR #36036:
URL: https://github.com/apache/beam/pull/36036#discussion_r2319948717
##
sdks/python/apache_beam/yaml/examples/transforms/blueprint/iceberg_to_alloydb.yaml:
##
@@ -0,0 +1,55 @@
+# coding=utf-8
+#
+# Licensed to the Apache Software Founda
Abacn commented on code in PR #36014:
URL: https://github.com/apache/beam/pull/36014#discussion_r2319939241
##
sdks/python/apache_beam/io/jdbc.py:
##
@@ -96,10 +95,11 @@
from apache_beam.transforms.external import BeamJarExpansionService
from apache_beam.transforms.external im
Abacn commented on code in PR #36014:
URL: https://github.com/apache/beam/pull/36014#discussion_r2319910050
##
sdks/python/apache_beam/io/jdbc.py:
##
@@ -96,10 +95,11 @@
from apache_beam.transforms.external import BeamJarExpansionService
from apache_beam.transforms.external im
claudevdm commented on code in PR #36014:
URL: https://github.com/apache/beam/pull/36014#discussion_r2319903383
##
sdks/python/apache_beam/io/jdbc.py:
##
@@ -96,10 +95,11 @@
from apache_beam.transforms.external import BeamJarExpansionService
from apache_beam.transforms.externa
shunping commented on PR #36034:
URL: https://github.com/apache/beam/pull/36034#issuecomment-3250373545
> > where is this translation called
>
> when converting the transform to its proto representation:
>
>
https://github.com/apache/beam/blob/d28fd643096d6bdb9db164684f58388a04
shunping commented on PR #36034:
URL: https://github.com/apache/beam/pull/36034#issuecomment-3250343555
> > Will take a look later, but from a quick skim, it looks like we're
missing translation logic in this PR
>
> Thanks for taking a look. I've been able to call both the managed and
ahmedabu98 commented on PR #36034:
URL: https://github.com/apache/beam/pull/36034#issuecomment-3250362173
> where is this translation called
when converting the transform to its proto representation:
https://github.com/apache/beam/blob/d28fd643096d6bdb9db164684f58388a04a5b9b5/sdks/jav
ahmedabu98 commented on code in PR #36034:
URL: https://github.com/apache/beam/pull/36034#discussion_r2319873888
##
model/pipeline/src/main/proto/org/apache/beam/model/pipeline/v1/external_transforms.proto:
##
@@ -76,6 +76,10 @@ message ManagedTransforms {
"beam:schematra
damccorm commented on code in PR #36041:
URL: https://github.com/apache/beam/pull/36041#discussion_r2319798344
##
build.gradle.kts:
##
@@ -637,6 +637,127 @@ tasks.register("formatChanges") {
}
}
+tasks.register("validateChanges") {
Review Comment:
Ok, that works
--
damccorm commented on issue #34768:
URL: https://github.com/apache/beam/issues/34768#issuecomment-3250270023
This has been fixed as part of making prism the default.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
damccorm closed issue #34768: [Bug]: Prism isn't correctly used as the default
for streaming pipelines.
URL: https://github.com/apache/beam/issues/34768
--
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
damccorm commented on issue #34553:
URL: https://github.com/apache/beam/issues/34553#issuecomment-3250268790
I think we can call this done. We've added anomaly detection and RAG
primitives. We will probably add more, but we've hit a reasonable level of
completeness.
--
This is an automat
damccorm closed issue #34553: [Task]: Enrich ML features such as RAG, Anomaly
Detection
URL: https://github.com/apache/beam/issues/34553
--
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
damccorm commented on issue #34549:
URL: https://github.com/apache/beam/issues/34549#issuecomment-3250259135
I think we can call this done. There are corner cases we can burn down, but
the core work is complete
--
This is an automated message from the Apache Git Service.
To respond to the
damccorm closed issue #34549: [Task]: Make Prism default
URL: https://github.com/apache/beam/issues/34549
--
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-actions[bot] commented on PR #36027:
URL: https://github.com/apache/beam/pull/36027#issuecomment-3250255571
Assigning reviewers:
R: @jrmccluskey for label python.
Note: If you would like to opt out of this review, comment `assign to next
reviewer`.
Available c
damccorm closed issue #21510: [Beam I/O Standards] Avoid partially-built
PTransform objects
URL: https://github.com/apache/beam/issues/21510
--
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
damccorm commented on issue #21510:
URL: https://github.com/apache/beam/issues/21510#issuecomment-3250252645
I think we probably will not pick this up, it doesn't seem super high value
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
liferoad merged PR #36041:
URL: https://github.com/apache/beam/pull/36041
--
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 code in PR #36041:
URL: https://github.com/apache/beam/pull/36041#discussion_r2319789019
##
build.gradle.kts:
##
@@ -637,6 +637,127 @@ tasks.register("formatChanges") {
}
}
+tasks.register("validateChanges") {
Review Comment:
sounds good. I will d
Abacn commented on PR #32977:
URL: https://github.com/apache/beam/pull/32977#issuecomment-3250237374
related to #34672 (acutally this PR is the one referred in Beam 3 milestone
doc https://s.apache.org/beam3-milestones:
https://docs.google.com/document/d/1KfTMok67-bZBUcCCYeHkdktyQZ6arWQJEP
damccorm commented on code in PR #36041:
URL: https://github.com/apache/beam/pull/36041#discussion_r2319774407
##
build.gradle.kts:
##
@@ -637,6 +637,127 @@ tasks.register("formatChanges") {
}
}
+tasks.register("validateChanges") {
Review Comment:
Could we make this a
github-actions[bot] commented on PR #36036:
URL: https://github.com/apache/beam/pull/36036#issuecomment-3250172906
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
tarun-google commented on PR #36036:
URL: https://github.com/apache/beam/pull/36036#issuecomment-3250169853
R: @claudevdm @derrickaw @chamikaramj
--
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
liferoad opened a new pull request, #36041:
URL: https://github.com/apache/beam/pull/36041
Add a new gradle task 'validateChanges' that checks CHANGES.md follows
required formatting rules including:
- Language references must use parentheses
- Each entry must have a proper issue link
shunping commented on code in PR #36014:
URL: https://github.com/apache/beam/pull/36014#discussion_r2319658873
##
sdks/python/apache_beam/typehints/schemas.py:
##
@@ -690,7 +690,16 @@ def add(self, urn, logical_type):
self.by_language_type[logical_type.language_type()] = lo
Abacn commented on code in PR #36014:
URL: https://github.com/apache/beam/pull/36014#discussion_r2319643908
##
sdks/python/apache_beam/typehints/schemas.py:
##
@@ -690,7 +690,16 @@ def add(self, urn, logical_type):
self.by_language_type[logical_type.language_type()] = logic
Abacn closed issue #19707: Get rid of jackson to avoid the continuous flow of
CVEs in Jackson
URL: https://github.com/apache/beam/issues/19707
--
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 spe
Abacn commented on issue #19707:
URL: https://github.com/apache/beam/issues/19707#issuecomment-3250035334
I think this is now obsolete. Beam and some of its popular dependencies
(calcite, iceberg, hadoop) still use jackson databind. Even Beam itself moved
out of jackson-databind user pipeli
Abacn commented on issue #34553:
URL: https://github.com/apache/beam/issues/34553#issuecomment-3249996976
This Issue is marked as Beam 3 - Milestone 1: No Code and ML focus. Please
help us burning down the open blocker tasks.
* If this issue is solved, close it. If it is obsolete, clo
Abacn commented on issue #34554:
URL: https://github.com/apache/beam/issues/34554#issuecomment-3249997636
This Issue is marked as Beam 3 - Milestone 1: No Code and ML focus. Please
help us burning down the open blocker tasks.
* If this issue is solved, close it. If it is obsolete, clo
Abacn commented on issue #29650:
URL: https://github.com/apache/beam/issues/29650#issuecomment-3249994607
This Issue is marked as Beam 3 - Milestone 1: No Code and ML focus. Please
help us burning down the open blocker tasks.
* If this issue is solved, close it. If it is obsolete, clo
Abacn commented on issue #31827:
URL: https://github.com/apache/beam/issues/31827#issuecomment-3249998869
This Issue is marked as Beam 3 - Milestone 1: No Code and ML focus. Please
help us burning down the open blocker tasks.
* If this issue is solved, close it. If it is obsolete, clo
Abacn commented on issue #31678:
URL: https://github.com/apache/beam/issues/31678#issuecomment-3250012234
Move to milestone 3 as Java 8 has been deprecated in Beam 2.x
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
Abacn commented on issue #34768:
URL: https://github.com/apache/beam/issues/34768#issuecomment-3250010462
This Issue is marked as Beam 3 - Milestone 1: No Code and ML focus. Please
help us burning down the open blocker tasks.
* If this issue is solved, close it. If it is obsolete, clo
Abacn commented on issue #35448:
URL: https://github.com/apache/beam/issues/35448#issuecomment-3250009464
Move to milestone 3 as Samza runner has been deprecated for Beam 2.x
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
Abacn commented on issue #34993:
URL: https://github.com/apache/beam/issues/34993#issuecomment-3250006131
moved to Milestone 3
--
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
Abacn commented on issue #34993:
URL: https://github.com/apache/beam/issues/34993#issuecomment-3250005776
This Issue is marked as Beam 3 - Milestone 1: No Code and ML focus. Please
help us burning down the open blocker tasks.
* If this issue is solved, close it. If it is obsolete, clo
Abacn commented on issue #34671:
URL: https://github.com/apache/beam/issues/34671#issuecomment-3250003746
This Issue is marked as Beam 3 - Milestone 1: No Code and ML focus. Please
help us burning down the open blocker tasks.
* If this issue is solved, close it. If it is obsolete, clo
Abacn commented on issue #34350:
URL: https://github.com/apache/beam/issues/34350#issuecomment-3250005020
This Issue is marked as Beam 3 - Milestone 1: No Code and ML focus. Please
help us burning down the open blocker tasks.
* If this issue is solved, close it. If it is obsolete, clo
Abacn commented on issue #34672:
URL: https://github.com/apache/beam/issues/34672#issuecomment-3250004328
This Issue is marked as Beam 3 - Milestone 1: No Code and ML focus. Please
help us burning down the open blocker tasks.
* If this issue is solved, close it. If it is obsolete, clo
Abacn commented on issue #34637:
URL: https://github.com/apache/beam/issues/34637#issuecomment-325408
This is essentially same FR as #18645
--
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
Abacn commented on issue #34637:
URL: https://github.com/apache/beam/issues/34637#issuecomment-324597
This Issue is marked as Beam 3 - Milestone 1: No Code and ML focus. Please
help us burning down the open blocker tasks.
* If this issue is solved, close it. If it is obsolete, clo
Abacn commented on issue #34550:
URL: https://github.com/apache/beam/issues/34550#issuecomment-3249996647
This Issue is marked as Beam 3 - Milestone 1: No Code and ML focus. Please
help us burning down the open blocker tasks.
* If this issue is solved, close it. If it is obsolete, clo
Abacn commented on issue #34552:
URL: https://github.com/apache/beam/issues/34552#issuecomment-3249995996
This Issue is marked as Beam 3 - Milestone 1: No Code and ML focus. Please
help us burning down the open blocker tasks.
* If this issue is solved, close it. If it is obsolete, clo
Abacn commented on issue #34419:
URL: https://github.com/apache/beam/issues/34419#issuecomment-3249993561
This Issue is marked as Beam 3 - Milestone 1: No Code and ML focus. Please
help us burning down the open blocker tasks.
* If this issue is solved, close it. If it is obsolete, clo
Abacn commented on issue #34549:
URL: https://github.com/apache/beam/issues/34549#issuecomment-3249994052
This Issue is marked as Beam 3 - Milestone 1: No Code and ML focus. Please
help us burning down the open blocker tasks.
* If this issue is solved, close it. If it is obsolete, clo
Abacn commented on issue #21551:
URL: https://github.com/apache/beam/issues/21551#issuecomment-3249992103
This Issue is marked as Beam 3 - Milestone 1: No Code and ML focus. Please
help us burning down the open blocker tasks.
* If this issue is solved, close it. If it is obsolete, clo
Abacn commented on issue #19389:
URL: https://github.com/apache/beam/issues/19389#issuecomment-3249989420
This Issue is marked as Beam 3 - Milestone 1: No Code and ML focus. Please
help us burning down the open blocker tasks.
* If this issue is solved, close it. If it is obsolete, clo
Abacn commented on issue #19278:
URL: https://github.com/apache/beam/issues/19278#issuecomment-3249988408
This Issue is marked as Beam 3 - Milestone 1: No Code and ML focus. Please
help us burning down the open blocker tasks.
* If this issue is solved, close it. If it is obsolete, clo
Abacn commented on issue #19388:
URL: https://github.com/apache/beam/issues/19388#issuecomment-3249989160
This Issue is marked as Beam 3 - Milestone 1: No Code and ML focus. Please
help us burning down the open blocker tasks.
* If this issue is solved, close it. If it is obsolete, clo
Abacn commented on issue #21510:
URL: https://github.com/apache/beam/issues/21510#issuecomment-3249990633
This Issue is marked as Beam 3 - Milestone 1: No Code and ML focus. Please
help us burning down the open blocker tasks.
* If this issue is solved, close it. If it is obsolete, clo
Abacn commented on issue #19707:
URL: https://github.com/apache/beam/issues/19707#issuecomment-3249990104
This Issue is marked as Beam 3 - Milestone 1: No Code and ML focus. Please
help us burning down the open blocker tasks.
* If this issue is solved, close it. If it is obsolete, clo
Abacn commented on issue #19331:
URL: https://github.com/apache/beam/issues/19331#issuecomment-3249988820
This Issue is marked as Beam 3 - Milestone 1: No Code and ML focus. Please
help us burning down the open blocker tasks.
* If this issue is solved, close it. If it is obsolete, clo
Abacn commented on issue #19215:
URL: https://github.com/apache/beam/issues/19215#issuecomment-3249987975
This Issue is marked as Beam 3 - Milestone 1: No Code and ML focus. Please
help us burning down the open blocker tasks.
* If this issue is solved, close it. If it is obsolete, clo
Abacn commented on issue #18868:
URL: https://github.com/apache/beam/issues/18868#issuecomment-3249987148
This Issue is marked as Beam 3 - Milestone 1: No Code and ML focus. Please
help us burning down the open blocker tasks.
* If this issue is solved, close it. If it is obsolete, clo
Abacn commented on issue #18645:
URL: https://github.com/apache/beam/issues/18645#issuecomment-3249986022
This Issue is marked as Beam 3 - Milestone 1: No Code and ML focus. Please
help us burning down the open blocker tasks.
* If this issue is solved, close it. If it is obsolete, clo
github-actions[bot] commented on PR #36027:
URL: https://github.com/apache/beam/pull/36027#issuecomment-3249980492
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
Abacn merged PR #36028:
URL: https://github.com/apache/beam/pull/36028
--
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.or
github-actions[bot] commented on PR #36036:
URL: https://github.com/apache/beam/pull/36036#issuecomment-3249880306
Assigning reviewers:
R: @shunping for label python.
Note: If you would like to opt out of this review, comment `assign to next
reviewer`.
Available comm
damccorm closed issue #35432: [Feature Request]: Support Protobuf 6.x in Python
SDK
URL: https://github.com/apache/beam/issues/35432
--
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 comm
damccorm commented on PR #35477:
URL: https://github.com/apache/beam/pull/35477#issuecomment-3249862824
Merging since the cut has passed
--
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 specif
damccorm merged PR #35477:
URL: https://github.com/apache/beam/pull/35477
--
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
damccorm merged PR #36037:
URL: https://github.com/apache/beam/pull/36037
--
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
shunping commented on code in PR #36014:
URL: https://github.com/apache/beam/pull/36014#discussion_r2319345662
##
sdks/python/apache_beam/typehints/schemas.py:
##
@@ -690,7 +690,16 @@ def add(self, urn, logical_type):
self.by_language_type[logical_type.language_type()] = lo
liferoad commented on code in PR #36027:
URL: https://github.com/apache/beam/pull/36027#discussion_r2319087592
##
sdks/python/apache_beam/io/gcp/pubsub.py:
##
@@ -541,11 +546,67 @@ def is_bounded(self):
return False
-# TODO(BEAM-27443): Remove in favor of a proper Write
tarun-google commented on PR #36036:
URL: https://github.com/apache/beam/pull/36036#issuecomment-3249695723
Run Python_Transforms PreCommit 3.10
--
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 th
liferoad commented on issue #34081:
URL: https://github.com/apache/beam/issues/34081#issuecomment-3249661919
This can be moved to 2.69 since we need the fix from grpcio.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
VIKTORVAV99 commented on issue #25946:
URL: https://github.com/apache/beam/issues/25946#issuecomment-3249616428
> > It's possible to work around in several ways but it just adds more code
that should not be needed.
>
> @VIKTORVAV99 curious to know what approach you're taking! Are you
ahmedabu98 commented on issue #25946:
URL: https://github.com/apache/beam/issues/25946#issuecomment-3249608107
> It's possible to work around in several ways but it just adds more code
that should not be needed.
@VIKTORVAV99 curious to know what approach you're taking! Are you working
ahmedabu98 commented on issue #25946:
URL: https://github.com/apache/beam/issues/25946#issuecomment-3249604963
I've created a doc to outline new logical types for Timestamp and DateTime,
with configurable precision levels: https://s.apache.org/beam-timestamp-strategy
--
This is an automat
claudevdm commented on code in PR #36014:
URL: https://github.com/apache/beam/pull/36014#discussion_r2319216933
##
sdks/python/apache_beam/typehints/schemas.py:
##
@@ -690,7 +690,16 @@ def add(self, urn, logical_type):
self.by_language_type[logical_type.language_type()] = l
shunping commented on code in PR #36034:
URL: https://github.com/apache/beam/pull/36034#discussion_r2319173650
##
model/pipeline/src/main/proto/org/apache/beam/model/pipeline/v1/external_transforms.proto:
##
@@ -76,6 +76,10 @@ message ManagedTransforms {
"beam:schematrans
shunping commented on code in PR #36034:
URL: https://github.com/apache/beam/pull/36034#discussion_r2319173650
##
model/pipeline/src/main/proto/org/apache/beam/model/pipeline/v1/external_transforms.proto:
##
@@ -76,6 +76,10 @@ message ManagedTransforms {
"beam:schematrans
shunping commented on code in PR #36034:
URL: https://github.com/apache/beam/pull/36034#discussion_r2319173650
##
model/pipeline/src/main/proto/org/apache/beam/model/pipeline/v1/external_transforms.proto:
##
@@ -76,6 +76,10 @@ message ManagedTransforms {
"beam:schematrans
shunping commented on code in PR #36014:
URL: https://github.com/apache/beam/pull/36014#discussion_r2319163872
##
sdks/python/apache_beam/typehints/schemas.py:
##
@@ -690,7 +690,16 @@ def add(self, urn, logical_type):
self.by_language_type[logical_type.language_type()] = lo
shunping commented on code in PR #36014:
URL: https://github.com/apache/beam/pull/36014#discussion_r2319163872
##
sdks/python/apache_beam/typehints/schemas.py:
##
@@ -690,7 +690,16 @@ def add(self, urn, logical_type):
self.by_language_type[logical_type.language_type()] = lo
shunping commented on code in PR #36014:
URL: https://github.com/apache/beam/pull/36014#discussion_r2319163872
##
sdks/python/apache_beam/typehints/schemas.py:
##
@@ -690,7 +690,16 @@ def add(self, urn, logical_type):
self.by_language_type[logical_type.language_type()] = lo
jrmccluskey merged PR #36005:
URL: https://github.com/apache/beam/pull/36005
--
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.apa
claudevdm commented on code in PR #36014:
URL: https://github.com/apache/beam/pull/36014#discussion_r2319125732
##
sdks/python/apache_beam/typehints/schemas.py:
##
@@ -690,7 +690,16 @@ def add(self, urn, logical_type):
self.by_language_type[logical_type.language_type()] = l
liferoad closed issue #36011: [Feature Request]: PrismRunner should support
transform overrides
URL: https://github.com/apache/beam/issues/36011
--
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 s
liferoad commented on issue #36011:
URL: https://github.com/apache/beam/issues/36011#issuecomment-3249415149
After talking to @damccorm, we do not need overrides for PrismRunner for now
since it will fall back to DirectRunner.
--
This is an automated message from the Apache Git Service.
github-actions[bot] commented on PR #36014:
URL: https://github.com/apache/beam/pull/36014#issuecomment-3249413450
Assigning reviewers:
R: @claudevdm for label python.
Note: If you would like to opt out of this review, comment `assign to next
reviewer`.
Available com
liferoad commented on code in PR #36027:
URL: https://github.com/apache/beam/pull/36027#discussion_r2319087592
##
sdks/python/apache_beam/io/gcp/pubsub.py:
##
@@ -541,11 +546,67 @@ def is_bounded(self):
return False
-# TODO(BEAM-27443): Remove in favor of a proper Write
shunping commented on PR #36034:
URL: https://github.com/apache/beam/pull/36034#issuecomment-3249381526
> Will take a look later, but from a quick skim, it looks like we're missing
translation logic in this PR
Thanks for taking a look. I've been able to call both the managed and
unma
liferoad commented on PR #36001:
URL: https://github.com/apache/beam/pull/36001#issuecomment-3249379381
close this. https://github.com/apache/beam/pull/36027 is the recommended way.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
liferoad closed pull request #36001: feat(pubsub): add batch mode support for
WriteToPubSub in DataflowRunner
URL: https://github.com/apache/beam/pull/36001
--
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
github-actions[bot] commented on PR #36034:
URL: https://github.com/apache/beam/pull/36034#issuecomment-3249303335
Assigning reviewers:
R: @liferoad for label python.
R: @Abacn for label java.
Note: If you would like to opt out of this review, comment `assign to next
rev
liferoad commented on issue #35957:
URL: https://github.com/apache/beam/issues/35957#issuecomment-3249244730
https://beam.apache.org/blog/beam-2.66.0/
Python: Argument abbreviation is no longer enabled within Beam. If you
previously abbreviated arguments (e.g. --r for --runner), you w
1 - 100 of 34541 matches
Mail list logo
