asf-ci commented on PR #17764:
URL: https://github.com/apache/beam/pull/17764#issuecomment-1138160968
Can one of the admins verify this patch?
--
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
asf-ci commented on PR #17764:
URL: https://github.com/apache/beam/pull/17764#issuecomment-1138160975
Can one of the admins verify this patch?
--
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
nbali opened a new pull request, #17764:
URL: https://github.com/apache/beam/pull/17764
We create a schema with NOT NULL fields even if the proto field is optional.
IMO the code was at the wrong place in the switch-case instead of after it
Thank you for
asf-ci commented on PR #17764:
URL: https://github.com/apache/beam/pull/17764#issuecomment-1138160967
Can one of the admins verify this patch?
--
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
nbali commented on PR #16773:
URL: https://github.com/apache/beam/pull/16773#issuecomment-1138130175
ping?
--
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
nbali commented on PR #16888:
URL: https://github.com/apache/beam/pull/16888#issuecomment-1138130150
ping?
--
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
lostluck commented on code in PR #17755:
URL: https://github.com/apache/beam/pull/17755#discussion_r882286246
##
sdks/go/pkg/beam/core/runtime/exec/sdf.go:
##
@@ -308,7 +308,12 @@ func (n *TruncateSizedRestriction) StartBundle(ctx
context.Context, id string, d
// Timestamp
riteshghorse commented on code in PR #17755:
URL: https://github.com/apache/beam/pull/17755#discussion_r882263387
##
sdks/go/pkg/beam/core/runtime/exec/sdf.go:
##
@@ -308,7 +308,12 @@ func (n *TruncateSizedRestriction) StartBundle(ctx
context.Context, id string, d
// Times
riteshghorse commented on code in PR #17755:
URL: https://github.com/apache/beam/pull/17755#discussion_r882260463
##
sdks/go/pkg/beam/core/runtime/exec/sdf.go:
##
@@ -308,7 +308,12 @@ func (n *TruncateSizedRestriction) StartBundle(ctx
context.Context, id string, d
// Times
codecov[bot] commented on PR #17763:
URL: https://github.com/apache/beam/pull/17763#issuecomment-1138048537
#
[Codecov](https://codecov.io/gh/apache/beam/pull/17763?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Fo
ihji opened a new pull request, #17763:
URL: https://github.com/apache/beam/pull/17763
Adding context support for Python callable.
We could remove unnecessary workaround like:
```
PythonCallableSource.of(
"lambda: __import__('apache_beam.ml.inference.sklearn_inference')"
robertwb commented on code in PR #17761:
URL: https://github.com/apache/beam/pull/17761#discussion_r88407
##
sdks/python/apache_beam/runners/worker/operations.py:
##
@@ -1214,9 +1213,9 @@ def __init__(
def setup(self):
# type: () -> None
+_LOGGER.debug('Setup c
robertwb commented on PR #17762:
URL: https://github.com/apache/beam/pull/17762#issuecomment-1138012527
R: @yeandy
--
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 unsubs
robertwb opened a new pull request, #17762:
URL: https://github.com/apache/beam/pull/17762
Thank you for your contribution! Follow this checklist to help us
incorporate your contribution quickly and easily:
- [ ] [**Choose
reviewer(s)**](https://b
youngoli commented on code in PR #17748:
URL: https://github.com/apache/beam/pull/17748#discussion_r882199263
##
sdks/go/pkg/beam/io/healthcare/fhirio/read.go:
##
@@ -0,0 +1,87 @@
+// Licensed to the Apache Software Foundation (ASF) under one or more
+// contributor license agre
lostluck commented on code in PR #17755:
URL: https://github.com/apache/beam/pull/17755#discussion_r882204700
##
sdks/go/pkg/beam/core/runtime/exec/sdf.go:
##
@@ -308,7 +308,12 @@ func (n *TruncateSizedRestriction) StartBundle(ctx
context.Context, id string, d
// Timestamp
github-actions[bot] commented on PR #17751:
URL: https://github.com/apache/beam/pull/17751#issuecomment-1137961582
Assigning reviewers. If you would like to opt out of this review, comment
`assign to next reviewer`:
R: @jrmccluskey for label go.
Available commands:
- `stop r
chamikaramj commented on PR #17696:
URL: https://github.com/apache/beam/pull/17696#issuecomment-1137939966
Run XVR_JavaUsingPython_Dataflow PostCommit
--
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
TheNeuralBit commented on PR #17761:
URL: https://github.com/apache/beam/pull/17761#issuecomment-1137937121
Run Python 3.9 PostCommit
--
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
TheNeuralBit commented on PR #17758:
URL: https://github.com/apache/beam/pull/17758#issuecomment-1137936789
Run Python 3.9 PostCommit
--
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
codecov[bot] commented on PR #17761:
URL: https://github.com/apache/beam/pull/17761#issuecomment-1137936956
#
[Codecov](https://codecov.io/gh/apache/beam/pull/17761?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Fo
youngoli merged PR #17720:
URL: https://github.com/apache/beam/pull/17720
--
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
youngoli merged PR #17759:
URL: https://github.com/apache/beam/pull/17759
--
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
codecov[bot] commented on PR #17751:
URL: https://github.com/apache/beam/pull/17751#issuecomment-1137932677
#
[Codecov](https://codecov.io/gh/apache/beam/pull/17751?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Fo
TheNeuralBit commented on PR #17758:
URL: https://github.com/apache/beam/pull/17758#issuecomment-1137930008
Run Python_PVR_Flink 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 spec
alejandrorm commented on PR #17717:
URL: https://github.com/apache/beam/pull/17717#issuecomment-1137924822
retest this please
--
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.
TheNeuralBit commented on PR #17761:
URL: https://github.com/apache/beam/pull/17761#issuecomment-1137920391
Note that a9b5da8 fixes several locations where we re-entering `ScopedState`
instances.
--
This is an automated message from the Apache Git Service.
To respond to the message, pleas
chamikaramj commented on PR #17696:
URL: https://github.com/apache/beam/pull/17696#issuecomment-1137902071
Run XVR_JavaUsingPython_Dataflow PostCommit
--
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
TheNeuralBit opened a new pull request, #17761:
URL: https://github.com/apache/beam/pull/17761
This PR makes both `ScopedState` implementations raise an `AssertionError`
if re-entered. This is necessary because the "fast" implementation ends up with
an inconsistent state when re-entered. In
robertwb commented on code in PR #16818:
URL: https://github.com/apache/beam/pull/16818#discussion_r882152259
##
sdks/go/test/integration/io/xlang/bigquery/bigquery.go:
##
@@ -0,0 +1,114 @@
+// Licensed to the Apache Software Foundation (ASF) under one or more
+// contributor li
kileys commented on PR #17760:
URL: https://github.com/apache/beam/pull/17760#issuecomment-1137866164
R: @ihji
--
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 unsubscri
kileys opened a new pull request, #17760:
URL: https://github.com/apache/beam/pull/17760
New images:
https://gcr.io/cloud-dataflow/v1beta3/beam-java8-latest-batch:beam-master05252022
https://gcr.io/cloud-dataflow/v1beta3/beam-java8-latest-streaming:beam-master05252022
robertwb commented on PR #17327:
URL: https://github.com/apache/beam/pull/17327#issuecomment-1137863948
I should note that before either change I was getting on the order of 15k
ops/sec.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
robertwb merged PR #17568:
URL: https://github.com/apache/beam/pull/17568
--
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
KevinGG commented on PR #17736:
URL: https://github.com/apache/beam/pull/17736#issuecomment-1137852735
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
robertwb commented on code in PR #17696:
URL: https://github.com/apache/beam/pull/17696#discussion_r882117830
##
sdks/java/extensions/python/src/main/java/org/apache/beam/sdk/extensions/python/transforms/PythonMap.java:
##
@@ -0,0 +1,69 @@
+/*
+ * Licensed to the Apache Software
robertwb commented on code in PR #17696:
URL: https://github.com/apache/beam/pull/17696#discussion_r882116881
##
sdks/java/extensions/python/src/main/java/org/apache/beam/sdk/extensions/python/transforms/PythonMap.java:
##
@@ -0,0 +1,69 @@
+/*
+ * Licensed to the Apache Software
kileys commented on PR #17739:
URL: https://github.com/apache/beam/pull/17739#issuecomment-1137843884
Thanks Kyle! Filed https://issues.apache.org/jira/browse/INFRA-23301
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
chamikaramj commented on PR #17696:
URL: https://github.com/apache/beam/pull/17696#issuecomment-1137839650
Run XVR_JavaUsingPython_Dataflow PostCommit
--
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
chamikaramj commented on code in PR #17696:
URL: https://github.com/apache/beam/pull/17696#discussion_r881987405
##
sdks/java/extensions/python/src/main/java/org/apache/beam/sdk/extensions/python/transforms/PythonMap.java:
##
@@ -0,0 +1,69 @@
+/*
+ * Licensed to the Apache Softw
damccorm commented on code in PR #17755:
URL: https://github.com/apache/beam/pull/17755#discussion_r882106313
##
sdks/go/pkg/beam/core/runtime/exec/sdf.go:
##
@@ -308,7 +308,12 @@ func (n *TruncateSizedRestriction) StartBundle(ctx
context.Context, id string, d
// Timestamp
reuvenlax commented on PR #17423:
URL: https://github.com/apache/beam/pull/17423#issuecomment-1137834110
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.
reuvenlax commented on PR #17423:
URL: https://github.com/apache/beam/pull/17423#issuecomment-1137833613
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.
y1chi merged PR #17756:
URL: https://github.com/apache/beam/pull/17756
--
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
jrmccluskey commented on code in PR #17747:
URL: https://github.com/apache/beam/pull/17747#discussion_r882097746
##
sdks/go/pkg/beam/runners/dataflow/dataflowlib/job.go:
##
@@ -83,6 +87,8 @@ type JobOptions struct {
TeardownPolicy string
}
+const replaceIdPlaceholder
jrmccluskey commented on code in PR #17747:
URL: https://github.com/apache/beam/pull/17747#discussion_r882097610
##
sdks/go/pkg/beam/runners/dataflow/dataflow_test.go:
##
@@ -197,3 +197,50 @@ func TestGetJobOptions_DockerNoImage(t *testing.T) {
t.Fatalf("getConta
y1chi opened a new pull request, #17759:
URL: https://github.com/apache/beam/pull/17759
**Please** add a meaningful description for your change here
Thank you for your contribution! Follow this checklist to help us
incorporate your contribution quickly
youngoli commented on code in PR #17690:
URL: https://github.com/apache/beam/pull/17690#discussion_r882088511
##
website/www/site/content/en/get-started/downloads.md:
##
@@ -88,6 +88,14 @@ versions denoted `0.x.y`.
## Releases
+### 2.39.0 (2022-05-25)
+Official [source code
riteshghorse commented on code in PR #17755:
URL: https://github.com/apache/beam/pull/17755#discussion_r882066312
##
sdks/go/pkg/beam/core/runtime/exec/sdf.go:
##
@@ -308,7 +308,12 @@ func (n *TruncateSizedRestriction) StartBundle(ctx
context.Context, id string, d
// Times
damccorm commented on code in PR #17747:
URL: https://github.com/apache/beam/pull/17747#discussion_r882061858
##
sdks/go/pkg/beam/runners/dataflow/dataflowlib/job.go:
##
@@ -239,6 +252,13 @@ func Translate(ctx context.Context, p *pipepb.Pipeline,
opts *JobOptions, worker
//
damccorm commented on code in PR #17755:
URL: https://github.com/apache/beam/pull/17755#discussion_r882052841
##
sdks/go/pkg/beam/core/runtime/exec/sdf.go:
##
@@ -308,7 +308,12 @@ func (n *TruncateSizedRestriction) StartBundle(ctx
context.Context, id string, d
// Timestamp
robertwb commented on PR #17568:
URL: https://github.com/apache/beam/pull/17568#issuecomment-1137784761
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.
T
robertwb commented on PR #17568:
URL: https://github.com/apache/beam/pull/17568#issuecomment-1137783668
sdks:java:io:hcatalog:compileJava is failing again.
--
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
fernando-wizeline commented on code in PR #17471:
URL: https://github.com/apache/beam/pull/17471#discussion_r882047968
##
runners/direct-java/build.gradle:
##
@@ -178,6 +192,26 @@ task validatesRunner(type: Test) {
}
}
+tasks.register("validatesRunnerSickbay", Test) {
Rev
KevinGG commented on PR #17736:
URL: https://github.com/apache/beam/pull/17736#issuecomment-1137763456
R: @rohdesamuel
PTAL, thx!
--
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
KevinGG commented on PR #17736:
URL: https://github.com/apache/beam/pull/17736#issuecomment-1137762995
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
lostluck merged PR #17752:
URL: https://github.com/apache/beam/pull/17752
--
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
riteshghorse commented on PR #17755:
URL: https://github.com/apache/beam/pull/17755#issuecomment-1137760512
R: @lostluck
--
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
riteshghorse commented on PR #17754:
URL: https://github.com/apache/beam/pull/17754#issuecomment-1137760444
R: @lostluck
--
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
y1chi commented on PR #17756:
URL: https://github.com/apache/beam/pull/17756#issuecomment-1137733522
Run Java_Examples_Dataflow_Java17 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 th
yeandy commented on code in PR #17758:
URL: https://github.com/apache/beam/pull/17758#discussion_r882020082
##
sdks/python/apache_beam/examples/dataframe/flight_delays_it_test.py:
##
@@ -35,59 +35,58 @@
from apache_beam.testing.test_pipeline import TestPipeline
-@unittest.s
msbukal commented on code in PR #17741:
URL: https://github.com/apache/beam/pull/17741#discussion_r881954049
##
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/FhirBundleWithMetadata.java:
##
@@ -0,0 +1,73 @@
+/*
+ * Licensed to the Apache
riteshghorse commented on code in PR #17754:
URL: https://github.com/apache/beam/pull/17754#discussion_r881994891
##
sdks/go/pkg/beam/io/rtrackers/offsetrange/offsetrange_test.go:
##
@@ -299,3 +301,225 @@ func TestTracker_TrySplit(t *testing.T) {
})
}
}
reuvenlax commented on PR #17423:
URL: https://github.com/apache/beam/pull/17423#issuecomment-1137702810
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.
codecov[bot] commented on PR #17758:
URL: https://github.com/apache/beam/pull/17758#issuecomment-1137700263
#
[Codecov](https://codecov.io/gh/apache/beam/pull/17758?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Fo
y1chi merged PR #17690:
URL: https://github.com/apache/beam/pull/17690
--
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
Abacn commented on code in PR #17604:
URL: https://github.com/apache/beam/pull/17604#discussion_r881978749
##
sdks/python/apache_beam/io/filebasedsource.py:
##
@@ -449,3 +458,102 @@ def expand(self, pvalue):
| 'ReadRange' >> ParDo(
_ReadRange(
Abacn commented on code in PR #17604:
URL: https://github.com/apache/beam/pull/17604#discussion_r881976544
##
sdks/python/apache_beam/io/filebasedsource.py:
##
@@ -338,15 +338,25 @@ def default_output_coder(self):
class _ExpandIntoRanges(DoFn):
def __init__(
- self, s
alejandrorm commented on PR #17717:
URL: https://github.com/apache/beam/pull/17717#issuecomment-1137666766
retest this please
--
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.
riteshghorse commented on code in PR #17754:
URL: https://github.com/apache/beam/pull/17754#discussion_r881972483
##
sdks/go/pkg/beam/io/rtrackers/offsetrange/offsetrange.go:
##
@@ -223,3 +229,119 @@ func (tracker *Tracker) GetRestriction() interface{} {
func (tracker *Tracker)
TheNeuralBit commented on PR #17758:
URL: https://github.com/apache/beam/pull/17758#issuecomment-1137661255
R: @yeandy
--
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
TheNeuralBit commented on PR #17758:
URL: https://github.com/apache/beam/pull/17758#issuecomment-1137661104
Run Python 3.9 PostCommit
--
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
TheNeuralBit opened a new pull request, #17758:
URL: https://github.com/apache/beam/pull/17758
The `bigquery-samples.airline_ontime_data.flights` dataset, which this
integration test relied on, was deleted. I was able to find a dataset with
largely equivalent data and copy it into `apache-b
github-actions[bot] commented on PR #17755:
URL: https://github.com/apache/beam/pull/17755#issuecomment-1137658562
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 Serv
riteshghorse commented on PR #17755:
URL: https://github.com/apache/beam/pull/17755#issuecomment-1137657668
R: @damccorm @youngoli
--
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 co
github-actions[bot] commented on PR #17755:
URL: https://github.com/apache/beam/pull/17755#issuecomment-1137656665
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 revi
riteshghorse commented on code in PR #17754:
URL: https://github.com/apache/beam/pull/17754#discussion_r881966575
##
sdks/go/pkg/beam/io/rtrackers/offsetrange/offsetrange.go:
##
@@ -223,3 +229,119 @@ func (tracker *Tracker) GetRestriction() interface{} {
func (tracker *Tracker)
codecov[bot] commented on PR #17757:
URL: https://github.com/apache/beam/pull/17757#issuecomment-1137652718
#
[Codecov](https://codecov.io/gh/apache/beam/pull/17757?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Fo
riteshghorse commented on code in PR #17754:
URL: https://github.com/apache/beam/pull/17754#discussion_r881963324
##
sdks/go/pkg/beam/io/rtrackers/offsetrange/offsetrange.go:
##
@@ -223,3 +229,119 @@ func (tracker *Tracker) GetRestriction() interface{} {
func (tracker *Tracker)
ibzib merged PR #17739:
URL: https://github.com/apache/beam/pull/17739
--
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
riteshghorse commented on code in PR #17754:
URL: https://github.com/apache/beam/pull/17754#discussion_r881962204
##
sdks/go/pkg/beam/io/rtrackers/offsetrange/offsetrange.go:
##
@@ -223,3 +229,119 @@ func (tracker *Tracker) GetRestriction() interface{} {
func (tracker *Tracker)
y1chi commented on code in PR #17690:
URL: https://github.com/apache/beam/pull/17690#discussion_r881961746
##
website/www/site/data/authors.yml:
##
@@ -231,3 +231,6 @@ hermannb:
iht:
name: Israel Herraiz
email: i...@google.com
+yichi:
+ name: Yichi Zhang
+ email: zyi...
riteshghorse commented on code in PR #17754:
URL: https://github.com/apache/beam/pull/17754#discussion_r881960322
##
sdks/go/pkg/beam/io/rtrackers/offsetrange/offsetrange.go:
##
@@ -223,3 +229,119 @@ func (tracker *Tracker) GetRestriction() interface{} {
func (tracker *Tracker)
Abacn commented on code in PR #17604:
URL: https://github.com/apache/beam/pull/17604#discussion_r881959947
##
sdks/python/apache_beam/io/avroio.py:
##
@@ -176,20 +181,70 @@ def __init__(
name and the value being the actual data. If False, it only returns
the da
riteshghorse commented on code in PR #17754:
URL: https://github.com/apache/beam/pull/17754#discussion_r881956686
##
sdks/go/pkg/beam/io/rtrackers/offsetrange/offsetrange.go:
##
@@ -223,3 +229,119 @@ func (tracker *Tracker) GetRestriction() interface{} {
func (tracker *Tracker)
riteshghorse commented on code in PR #17754:
URL: https://github.com/apache/beam/pull/17754#discussion_r881955914
##
sdks/go/pkg/beam/io/rtrackers/offsetrange/offsetrange.go:
##
@@ -223,3 +229,119 @@ func (tracker *Tracker) GetRestriction() interface{} {
func (tracker *Tracker)
riteshghorse commented on code in PR #17754:
URL: https://github.com/apache/beam/pull/17754#discussion_r881954256
##
sdks/go/pkg/beam/io/rtrackers/offsetrange/offsetrange.go:
##
@@ -223,3 +229,119 @@ func (tracker *Tracker) GetRestriction() interface{} {
func (tracker *Tracker)
jrmccluskey commented on code in PR #17754:
URL: https://github.com/apache/beam/pull/17754#discussion_r881944088
##
sdks/go/pkg/beam/io/rtrackers/offsetrange/offsetrange_test.go:
##
@@ -299,3 +301,225 @@ func TestTracker_TrySplit(t *testing.T) {
})
}
}
+
codecov[bot] commented on PR #17756:
URL: https://github.com/apache/beam/pull/17756#issuecomment-1137637094
#
[Codecov](https://codecov.io/gh/apache/beam/pull/17756?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Fo
ihji commented on code in PR #17696:
URL: https://github.com/apache/beam/pull/17696#discussion_r881952432
##
sdks/java/extensions/python/src/main/java/org/apache/beam/sdk/extensions/python/transforms/PythonMap.java:
##
@@ -0,0 +1,69 @@
+/*
+ * Licensed to the Apache Software Fou
TheNeuralBit merged PR #17728:
URL: https://github.com/apache/beam/pull/17728
--
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.ap
codecov[bot] commented on PR #17755:
URL: https://github.com/apache/beam/pull/17755#issuecomment-1137633134
#
[Codecov](https://codecov.io/gh/apache/beam/pull/17755?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Fo
zwestrick commented on PR #17757:
URL: https://github.com/apache/beam/pull/17757#issuecomment-1137624024
R: TheNeuralBit
--
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 #17747:
URL: https://github.com/apache/beam/pull/17747#issuecomment-1137623456
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
asf-ci commented on PR #17757:
URL: https://github.com/apache/beam/pull/17757#issuecomment-1137622810
Can one of the admins verify this patch?
--
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
zwestrick opened a new pull request, #17757:
URL: https://github.com/apache/beam/pull/17757
This will make it easier to see what underlying coder is in use, and matches
several other coders in this file.
--
This is an automated message from the Apache Git Service.
To respond to th
asf-ci commented on PR #17757:
URL: https://github.com/apache/beam/pull/17757#issuecomment-1137622798
Can one of the admins verify this patch?
--
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
asf-ci commented on PR #17757:
URL: https://github.com/apache/beam/pull/17757#issuecomment-1137622797
Can one of the admins verify this patch?
--
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
damccorm commented on code in PR #17754:
URL: https://github.com/apache/beam/pull/17754#discussion_r881913985
##
sdks/go/pkg/beam/io/rtrackers/offsetrange/offsetrange.go:
##
@@ -223,3 +229,119 @@ func (tracker *Tracker) GetRestriction() interface{} {
func (tracker *Tracker) IsB
lnogueir commented on PR #17748:
URL: https://github.com/apache/beam/pull/17748#issuecomment-1137590300
R: @youngoli
--
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
1 - 100 of 159 matches
Mail list logo
