iindyk commented on a change in pull request #12420:
URL: https://github.com/apache/beam/pull/12420#discussion_r468937788
##
File path: sdks/python/apache_beam/transforms/stats.py
##
@@ -398,8 +424,8 @@ class ApproximateQuantilesCombineFn(CombineFn):
iindyk commented on a change in pull request #12420:
URL: https://github.com/apache/beam/pull/12420#discussion_r468937924
##
File path: sdks/python/apache_beam/transforms/stats.py
##
@@ -576,17 +633,34 @@ def _interpolate(self, i_buffers, count, step, offset):
iindyk commented on a change in pull request #12420:
URL: https://github.com/apache/beam/pull/12420#discussion_r468937732
##
File path: sdks/python/apache_beam/transforms/stats.py
##
@@ -263,30 +265,38 @@ class Globally(PTransform):
Args:
num_quantiles: number of
udim commented on a change in pull request #12257:
URL: https://github.com/apache/beam/pull/12257#discussion_r468946744
##
File path: sdks/python/tox.ini
##
@@ -172,6 +172,17 @@ extras = test,gcp,interactive,aws
commands =
{toxinidir}/scripts/run_pytest.sh {envname}
KevinGG commented on a change in pull request #12444:
URL: https://github.com/apache/beam/pull/12444#discussion_r468885295
##
File path: .test-infra/jenkins/job_PreCommit_Whitespace.groovy
##
@@ -0,0 +1,30 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+
tvalentyn commented on a change in pull request #12513:
URL: https://github.com/apache/beam/pull/12513#discussion_r468884894
##
File path: CI.md
##
@@ -89,7 +89,9 @@ Those jobs often have matrix run strategy which runs several
different variation
Some of the jobs require
TobKed commented on a change in pull request #12513:
URL: https://github.com/apache/beam/pull/12513#discussion_r468897533
##
File path: CI.md
##
@@ -89,7 +89,9 @@ Those jobs often have matrix run strategy which runs several
different variation
Some of the jobs require
tvalentyn commented on a change in pull request #12263:
URL: https://github.com/apache/beam/pull/12263#discussion_r468935806
##
File path:
sdks/java/extensions/ml/src/main/java/org/apache/beam/sdk/extensions/ml/DLPDeidentifyText.java
##
@@ -177,19 +177,24 @@ public
udim commented on pull request #12257:
URL: https://github.com/apache/beam/pull/12257#issuecomment-672414494
We can give this a try by adding this to `CommonJobProperties.groovy`:
```
credentialsBinding {
// other values
string("CODECOV_TOKEN",
udim commented on a change in pull request #12257:
URL: https://github.com/apache/beam/pull/12257#discussion_r468943368
##
File path: sdks/python/tox.ini
##
@@ -172,6 +172,17 @@ extras = test,gcp,interactive,aws
commands =
{toxinidir}/scripts/run_pytest.sh {envname}
pabloem commented on pull request #12489:
URL: https://github.com/apache/beam/pull/12489#issuecomment-672302553
Run Python PreCommit
This is an automated message from the Apache Git Service.
To respond to the message, please
TobKed commented on a change in pull request #12452:
URL: https://github.com/apache/beam/pull/12452#discussion_r468884891
##
File path: sdks/python/apache_beam/testing/util.py
##
@@ -334,3 +335,19 @@ def open_shards(glob_pattern, mode='rt', encoding='utf-8'):
lukecwik commented on pull request #12519:
URL: https://github.com/apache/beam/pull/12519#issuecomment-672327320
Thanks for taking a look, I'm going to break this up into a few PRs to
separate it from what was needed for the DirectRunner.
tvalentyn merged pull request #12525:
URL: https://github.com/apache/beam/pull/12525
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
pabloem commented on pull request #12489:
URL: https://github.com/apache/beam/pull/12489#issuecomment-672395931
Run Portable_Python PreCommit
This is an automated message from the Apache Git Service.
To respond to the
TheNeuralBit commented on pull request #12481:
URL: https://github.com/apache/beam/pull/12481#issuecomment-672308417
PreCommit seems to have passed, just no update here:
https://ci-beam.apache.org/job/beam_PreCommit_Java_Phrase/2603/
I've also validated this with some internal test
TheNeuralBit merged pull request #12481:
URL: https://github.com/apache/beam/pull/12481
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
ibzib commented on pull request #12538:
URL: https://github.com/apache/beam/pull/12538#issuecomment-672390647
Run Java Spark PortableValidatesRunner Batch
This is an automated message from the Apache Git Service.
To respond
ibzib opened a new pull request #12538:
URL: https://github.com/apache/beam/pull/12538
**Please** add a meaningful description for your change here
Thank you for your contribution! Follow this checklist to help us
incorporate your contribution quickly
y1chi opened a new pull request #12537:
URL: https://github.com/apache/beam/pull/12537
…status api for portable runners.
**Please** add a meaningful description for your change here
Thank you for your contribution! Follow this checklist to help
y1chi commented on pull request #12537:
URL: https://github.com/apache/beam/pull/12537#issuecomment-672338978
R: @angoenka
This is an automated message from the Apache Git Service.
To respond to the message, please log on
y1chi commented on a change in pull request #12537:
URL: https://github.com/apache/beam/pull/12537#discussion_r468939630
##
File path: sdks/python/apache_beam/runners/worker/worker_status.py
##
@@ -152,7 +170,11 @@ def generate_status_response(self):
all_status_sections =
angoenka commented on a change in pull request #12537:
URL: https://github.com/apache/beam/pull/12537#discussion_r468938985
##
File path: sdks/python/apache_beam/runners/worker/worker_status.py
##
@@ -152,7 +170,11 @@ def generate_status_response(self):
piotr-szuberski commented on pull request #12526:
URL: https://github.com/apache/beam/pull/12526#issuecomment-671776638
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
piotr-szuberski commented on pull request #12518:
URL: https://github.com/apache/beam/pull/12518#issuecomment-671776295
I've created a PR that disables kafka test
https://github.com/apache/beam/pull/12526
This is an
piotr-szuberski commented on a change in pull request #12297:
URL: https://github.com/apache/beam/pull/12297#discussion_r468391276
##
File path: sdks/python/apache_beam/io/kinesis.py
##
@@ -0,0 +1,317 @@
+#
+# Licensed to the Apache Software Foundation (ASF) under one or more
kkucharc commented on pull request #12527:
URL: https://github.com/apache/beam/pull/12527#issuecomment-671802138
run seed job
This is an automated message from the Apache Git Service.
To respond to the message, please log on
piotr-szuberski opened a new pull request #12526:
URL: https://github.com/apache/beam/pull/12526
Enable again when BEAM-10633 is merged
R: @TheNeuralBit @boyuanzz
**Please** add a meaningful description for your change here
Thank you
piotr-szuberski commented on a change in pull request #12297:
URL: https://github.com/apache/beam/pull/12297#discussion_r468394074
##
File path: sdks/python/apache_beam/io/external/xlang_kinesisio_it_test.py
##
@@ -0,0 +1,304 @@
+#
+# Licensed to the Apache Software Foundation
kkucharc opened a new pull request #12527:
URL: https://github.com/apache/beam/pull/12527
Thank you for your contribution! Follow this checklist to help us
incorporate your contribution quickly and easily:
- [ ] [**Choose
kkucharc commented on pull request #12527:
URL: https://github.com/apache/beam/pull/12527#issuecomment-671808653
Run Python Load Tests Combine Dataflow Streaming
This is an automated message from the Apache Git Service.
To
piotr-szuberski commented on a change in pull request #12297:
URL: https://github.com/apache/beam/pull/12297#discussion_r468391526
##
File path: sdks/python/apache_beam/io/kinesis.py
##
@@ -0,0 +1,317 @@
+#
+# Licensed to the Apache Software Foundation (ASF) under one or more
piotr-szuberski commented on a change in pull request #12297:
URL: https://github.com/apache/beam/pull/12297#discussion_r468391828
##
File path: sdks/python/apache_beam/io/kinesis.py
##
@@ -0,0 +1,317 @@
+#
+# Licensed to the Apache Software Foundation (ASF) under one or more
kkucharc commented on pull request #12527:
URL: https://github.com/apache/beam/pull/12527#issuecomment-671797660
run seed job
This is an automated message from the Apache Git Service.
To respond to the message, please log on
kkucharc commented on a change in pull request #12435:
URL: https://github.com/apache/beam/pull/12435#discussion_r468464708
##
File path: sdks/python/apache_beam/testing/load_tests/pardo_test.py
##
@@ -125,7 +125,9 @@ def process(self, element, state=state_param):
aromanenko-dev commented on pull request #12422:
URL: https://github.com/apache/beam/pull/12422#issuecomment-671841184
@TheNeuralBit Ok, thanks. I think it LGTM
This is an automated message from the Apache Git Service.
To
kkucharc commented on pull request #12527:
URL: https://github.com/apache/beam/pull/12527#issuecomment-671844911
Run Python Load Tests Combine Dataflow Batch
This is an automated message from the Apache Git Service.
To
abhiy13 commented on a change in pull request #12490:
URL: https://github.com/apache/beam/pull/12490#discussion_r468465389
##
File path:
sdks/java/io/contextual-text-io/src/main/java/org/apache/beam/sdk/io/ContextualTextIO/ContextualTextIO.java
##
@@ -0,0 +1,554 @@
+/*
+ *
aromanenko-dev merged pull request #12422:
URL: https://github.com/apache/beam/pull/12422
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
damgad opened a new pull request #12529:
URL: https://github.com/apache/beam/pull/12529
This PR deletes the `beam_Clean_tmp_directory` job and integrates its
functionality into `beam_Inventory_apache-beam-jenkins-XX` jobs.
Thank you for your
damgad commented on pull request #12529:
URL: https://github.com/apache/beam/pull/12529#issuecomment-672001509
run seed job
This is an automated message from the Apache Git Service.
To respond to the message, please log on
kamilwu commented on a change in pull request #12527:
URL: https://github.com/apache/beam/pull/12527#discussion_r468671360
##
File path: .test-infra/jenkins/job_LoadTests_Combine_Python.groovy
##
@@ -93,15 +93,23 @@ def loadTestConfigurations = { datasetName ->
kamilwu commented on a change in pull request #12527:
URL: https://github.com/apache/beam/pull/12527#discussion_r468672022
##
File path: .test-infra/jenkins/job_LoadTests_Combine_Python.groovy
##
@@ -113,13 +121,31 @@ PhraseTriggeringPostCommitBuilder.postCommitJob(
this
TheNeuralBit opened a new pull request #12530:
URL: https://github.com/apache/beam/pull/12530
Post-Commit Tests Status (on master branch)
Lang | SDK | Dataflow | Flink | Samza | Spark
davidak09 commented on a change in pull request #12050:
URL: https://github.com/apache/beam/pull/12050#discussion_r468538993
##
File path:
sdks/java/core/src/main/java/org/apache/beam/sdk/io/DefaultFilenamePolicy.java
##
@@ -182,19 +184,26 @@ public void encode(Params value,
damgad opened a new pull request #12528:
URL: https://github.com/apache/beam/pull/12528
There is a new plugin installed in our Jenkins instance - Test stability
history. To use it we have to enable it while archiving Junit test results.
That PR enables it everywhere in the DSL job
damgad commented on pull request #12528:
URL: https://github.com/apache/beam/pull/12528#issuecomment-671934387
run seed job
This is an automated message from the Apache Git Service.
To respond to the message, please log on
damgad removed a comment on pull request #12528:
URL: https://github.com/apache/beam/pull/12528#issuecomment-671933592
run seed job
This is an automated message from the Apache Git Service.
To respond to the message, please
damgad commented on pull request #12528:
URL: https://github.com/apache/beam/pull/12528#issuecomment-671944905
R: @aaltay
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
damgad commented on pull request #12528:
URL: https://github.com/apache/beam/pull/12528#issuecomment-671933592
run seed job
This is an automated message from the Apache Git Service.
To respond to the message, please log on
damgad removed a comment on pull request #12528:
URL: https://github.com/apache/beam/pull/12528#issuecomment-671933076
run seed job
This is an automated message from the Apache Git Service.
To respond to the message, please
damgad commented on pull request #12528:
URL: https://github.com/apache/beam/pull/12528#issuecomment-671933076
run seed job
This is an automated message from the Apache Git Service.
To respond to the message, please log on
mxm opened a new pull request #12531:
URL: https://github.com/apache/beam/pull/12531
By default, the Python SDK adds a timer output timestamp equal to the current
timestamp of an element. This is problematic because:
1. We hold back the output watermark on the current element's
Mark-Zeng opened a new pull request #12532:
URL: https://github.com/apache/beam/pull/12532
- Added a basic NFA class.
- Removed redundant code.
Thank you for your contribution! Follow this checklist to help us
incorporate your contribution quickly
Mark-Zeng commented on pull request #12532:
URL: https://github.com/apache/beam/pull/12532#issuecomment-672046274
R: @amaliujia
cc: @jhnmora000
This is an automated message from the Apache Git Service.
To respond to the
TheNeuralBit commented on pull request #12530:
URL: https://github.com/apache/beam/pull/12530#issuecomment-672054462
Run XVR_Direct PostCommit
This is an automated message from the Apache Git Service.
To respond to the
TheNeuralBit commented on pull request #12520:
URL: https://github.com/apache/beam/pull/12520#issuecomment-672062422
Run Python 3.8 PostCommit
This is an automated message from the Apache Git Service.
To respond to the
TheNeuralBit commented on pull request #12526:
URL: https://github.com/apache/beam/pull/12526#issuecomment-672066405
Run Python 3.8 PostCommit
This is an automated message from the Apache Git Service.
To respond to the
sclukas77 commented on a change in pull request #12498:
URL: https://github.com/apache/beam/pull/12498#discussion_r468718529
##
File path:
sdks/java/extensions/schemaio-expansion-service/src/main/java/org/apache/beam/sdk/extensions/schemaio/expansion/package-info.java
##
@@
sclukas77 commented on a change in pull request #12498:
URL: https://github.com/apache/beam/pull/12498#discussion_r468718319
##
File path: sdks/python/apache_beam/io/jdbc.py
##
@@ -168,41 +182,33 @@ def __init__(
:param expansion_service: The address (host:port) of the
sclukas77 commented on a change in pull request #12498:
URL: https://github.com/apache/beam/pull/12498#discussion_r468719581
##
File path: settings.gradle
##
@@ -181,3 +181,4 @@ include "beam-test-tools"
project(":beam-test-tools").dir = file(".test-infra/tools")
include
sclukas77 commented on a change in pull request #12498:
URL: https://github.com/apache/beam/pull/12498#discussion_r468718975
##
File path:
sclukas77 commented on a change in pull request #12498:
URL: https://github.com/apache/beam/pull/12498#discussion_r468719290
##
File path:
101 - 163 of 163 matches
Mail list logo
