Build failed in Jenkins: beam_PerformanceTests_Python #1052

See -- [...truncated 62.08 KB...] [INFO] --- maven-resources-plugin:3.0.2:copy-resources (copy-go-pkg-source) @ beam-sdks-go --- [INFO] Using 'UTF-8' encoding to copy filter

[jira] [Work logged] (BEAM-591) Better handling of watermark in KafkaIO

[ https://issues.apache.org/jira/browse/BEAM-591?focusedWorklogId=83101&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83101 ] ASF GitHub Bot logged work on BEAM-591: --- Author: ASF GitHub Bot

Build failed in Jenkins: beam_PostRelease_NightlySnapshot #150

See -- GitHub pull request #4788 of commit 5cde206ff4941db5b182f7a98f7fa022be164026, no merge conflicts. Setting status of 5cde206ff4941db5b182f7a98f7fa022be164026 to PEN

Build failed in Jenkins: beam_PerformanceTests_Spark #1496

See -- [...truncated 84.16 KB...] 'apache-beam-testing:bqjob_r3c247e026858b310_01624c945b5b_1': Invalid schema update. Field timestamp has changed type from TIMESTAMP to F

Build failed in Jenkins: beam_PostCommit_Python_ValidatesRunner_Dataflow #1160

See -- [...truncated 773.49 KB...] "display_data": [ { "key": "fn", "label": "Transform Function",

Jenkins build is back to normal : beam_PostCommit_Python_ValidatesContainer_Dataflow #76

See

Build failed in Jenkins: beam_PostCommit_Python_Verify #4479

See -- [...truncated 1.12 MB...] "type": "STRING", "value": "apache_beam.transforms.core.CallableWrapperDoFn" } ], "non_p

[beam-site] 01/06: Update current release to 2.4.0.

This is an automated email from the ASF dual-hosted git repository. mergebot-role pushed a commit to branch mergebot in repository https://gitbox.apache.org/repos/asf/beam-site.git commit a82dc5767ae1aca9eab84a4caea4215aa82b7abf Author: Robert Bradshaw AuthorDate: Wed Mar 7 00:15:35 2018 -0800

[beam-site] 06/06: This closes #398

This is an automated email from the ASF dual-hosted git repository. mergebot-role pushed a commit to branch mergebot in repository https://gitbox.apache.org/repos/asf/beam-site.git commit 5f408eff487d31611e07e733a2e64dcc09d729ee Merge: 789d0e2 2939462 Author: Mergebot AuthorDate: Thu Mar 22 00:5

[beam-site] 05/06: Update download page (including signature and checksum).

This is an automated email from the ASF dual-hosted git repository. mergebot-role pushed a commit to branch mergebot in repository https://gitbox.apache.org/repos/asf/beam-site.git commit 29394625ce54f0c5584c3db730d3eb6bf365a80c Author: Robert Bradshaw AuthorDate: Tue Mar 20 13:34:20 2018 -0700

[jira] [Created] (BEAM-3911) Do we want to encourage release pinning?

Robert Bradshaw created BEAM-3911: - Summary: Do we want to encourage release pinning? Key: BEAM-3911 URL: https://issues.apache.org/jira/browse/BEAM-3911 Project: Beam Issue Type: Bug

Jenkins build is back to stable : beam_PostCommit_Java_MavenInstall #6266

See

[beam] branch master updated (c45a2b2 -> 7c54fb2)

This is an automated email from the ASF dual-hosted git repository. robertwb pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from c45a2b2 [BEAM-3897] Add Go wordcount example with multi output DoFns add e1c124c Add mapper microbenchmark.

[beam] 01/01: Merge pull request #4915 from robertwb/microbenchmark

This is an automated email from the ASF dual-hosted git repository. robertwb pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit 7c54fb246304d4166626791f75a4e5036148963c Merge: c45a2b2 2331d51 Author: Robert Bradshaw AuthorDate: Thu Mar 22 01:36:52

Build failed in Jenkins: beam_PostCommit_Python_ValidatesRunner_Dataflow #1161

See Changes: [robertwb] Add mapper microbenchmark. [robertwb] Remove from docs generation. -- [...truncated 774.42 KB...] "serializ

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #5198

See

[jira] [Work logged] (BEAM-2873) Detect number of shards for file sink in Flink Streaming Runner

[ https://issues.apache.org/jira/browse/BEAM-2873?focusedWorklogId=83112&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83112 ] ASF GitHub Bot logged work on BEAM-2873: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-622) Add checkpointing tests for DoFnOperator and WindowDoFnOperator

[ https://issues.apache.org/jira/browse/BEAM-622?focusedWorklogId=83115&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83115 ] ASF GitHub Bot logged work on BEAM-622: --- Author: ASF GitHub Bot

Build failed in Jenkins: beam_PostCommit_Python_Verify #4480

See Changes: [robertwb] Add mapper microbenchmark. [robertwb] Remove from docs generation. -- [...truncated 1.13 MB...] tempFiles: [] type: TypeValueValues

[jira] [Work logged] (BEAM-2831) Pipeline crashes due to Beam encoder breaking Flink memory management

[ https://issues.apache.org/jira/browse/BEAM-2831?focusedWorklogId=83119&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83119 ] ASF GitHub Bot logged work on BEAM-2831: Author: ASF GitHub Bot

Build failed in Jenkins: beam_PostCommit_Python_ValidatesRunner_Dataflow #1162

See -- [...truncated 772.05 KB...] "serialized_fn": "", "user_name": "assert_that/Match" } }, { "kind": "ParallelDo",

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #5199

See

Jenkins build is back to normal : beam_PostRelease_NightlySnapshot #151

See

[jira] [Work logged] (BEAM-3089) Issue with setting the parallelism at client level using Flink runner

[ https://issues.apache.org/jira/browse/BEAM-3089?focusedWorklogId=83148&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83148 ] ASF GitHub Bot logged work on BEAM-3089: Author: ASF GitHub Bot

Build failed in Jenkins: beam_PerformanceTests_Python #1053

See Changes: [robertwb] Add mapper microbenchmark. [robertwb] Remove from docs generation. -- [...truncated 61.09 KB...] [INFO] --- maven-resources-plugin:3.0

[jira] [Work logged] (BEAM-2831) Pipeline crashes due to Beam encoder breaking Flink memory management

[ https://issues.apache.org/jira/browse/BEAM-2831?focusedWorklogId=83150&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83150 ] ASF GitHub Bot logged work on BEAM-2831: Author: ASF GitHub Bot

Build failed in Jenkins: beam_PerformanceTests_Spark #1497

See Changes: [robertwb] Add mapper microbenchmark. [robertwb] Remove from docs generation. -- [...truncated 91.77 KB...] 'apache-beam-testing:bqjob_r52dcb896e4

[jira] [Created] (BEAM-3912) Add support of HadoopOutputFormatIO

Alexey Romanenko created BEAM-3912: -- Summary: Add support of HadoopOutputFormatIO Key: BEAM-3912 URL: https://issues.apache.org/jira/browse/BEAM-3912 Project: Beam Issue Type: Improvement

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #5200

See

[jira] [Work logged] (BEAM-3785) [SQL] Add support for arrays

[ https://issues.apache.org/jira/browse/BEAM-3785?focusedWorklogId=83182&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83182 ] ASF GitHub Bot logged work on BEAM-3785: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3785) [SQL] Add support for arrays

[ https://issues.apache.org/jira/browse/BEAM-3785?focusedWorklogId=83181&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83181 ] ASF GitHub Bot logged work on BEAM-3785: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3892) Make MetricQueryResults and related classes more json-serialization friendly

[ https://issues.apache.org/jira/browse/BEAM-3892?focusedWorklogId=83197&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83197 ] ASF GitHub Bot logged work on BEAM-3892: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3310) Push metrics to a backend in an runner agnostic way

[ https://issues.apache.org/jira/browse/BEAM-3310?focusedWorklogId=83198&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83198 ] ASF GitHub Bot logged work on BEAM-3310: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-3910) Support floating point values in Go SDK

[ https://issues.apache.org/jira/browse/BEAM-3910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16409696#comment-16409696 ] Henning Rohde commented on BEAM-3910: - LGTM. Just for my understanding: what's missing

[jira] [Commented] (BEAM-3910) Support floating point values in Go SDK

[ https://issues.apache.org/jira/browse/BEAM-3910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16409712#comment-16409712 ] Bill Neubauer commented on BEAM-3910: - That's correct. Simply adding float types to gra

Build failed in Jenkins: beam_PostCommit_Python_ValidatesRunner_Dataflow #1163

See -- [...truncated 774.26 KB...] "serialized_fn": "", "user_name": "assert_that/Match" } }, { "kind": "ParallelDo",

Build failed in Jenkins: beam_PostCommit_Python_Verify #4481

See -- [...truncated 1.12 MB...] tempFiles: [] type: TypeValueValuesEnum(JOB_TYPE_BATCH, 1)> root: INFO: Created job with id: [2018-03-22_08_27_48-4503521538329967508] roo

[jira] [Work logged] (BEAM-591) Better handling of watermark in KafkaIO

[ https://issues.apache.org/jira/browse/BEAM-591?focusedWorklogId=83205&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83205 ] ASF GitHub Bot logged work on BEAM-591: --- Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3310) Push metrics to a backend in an runner agnostic way

[ https://issues.apache.org/jira/browse/BEAM-3310?focusedWorklogId=83211&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83211 ] ASF GitHub Bot logged work on BEAM-3310: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3855) Add Go SDK support for protobuf coder

[ https://issues.apache.org/jira/browse/BEAM-3855?focusedWorklogId=83215&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83215 ] ASF GitHub Bot logged work on BEAM-3855: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-2517) Document how to build Python SDK from BEAM head in contribution guide.

[ https://issues.apache.org/jira/browse/BEAM-2517?focusedWorklogId=83217&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83217 ] ASF GitHub Bot logged work on BEAM-2517: Author: ASF GitHub Bot

[beam-site] 02/02: This closes #404

This is an automated email from the ASF dual-hosted git repository. mergebot-role pushed a commit to branch mergebot in repository https://gitbox.apache.org/repos/asf/beam-site.git commit c0ffea9d6e1af457d3ac88032c0fbdff6f5c9939 Merge: 2fee375 e462052 Author: Mergebot AuthorDate: Thu Mar 22 09:0

[beam-site] 01/02: Add instructions on how to build and use the Python tarball.

This is an automated email from the ASF dual-hosted git repository. mergebot-role pushed a commit to branch mergebot in repository https://gitbox.apache.org/repos/asf/beam-site.git commit e462052ad771f38d1ed13d1cbf3f04ab49cc32ab Author: Udi Meiri AuthorDate: Tue Mar 20 12:43:21 2018 -0700 A

[beam-site] branch asf-site updated (2fee375 -> b9082bf)

This is an automated email from the ASF dual-hosted git repository. mergebot-role pushed a change to branch asf-site in repository https://gitbox.apache.org/repos/asf/beam-site.git. from 2fee375 Prepare repository for deployment. add e462052 Add instructions on how to build and use th

[beam-site] 01/01: Prepare repository for deployment.

This is an automated email from the ASF dual-hosted git repository. mergebot-role pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/beam-site.git commit b9082bfdf71bc59bb40cb04fefcbc1f174b0b2a5 Author: Mergebot AuthorDate: Thu Mar 22 09:13:09 2018 -0700 Pr

[jira] [Work logged] (BEAM-2517) Document how to build Python SDK from BEAM head in contribution guide.

[ https://issues.apache.org/jira/browse/BEAM-2517?focusedWorklogId=83218&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83218 ] ASF GitHub Bot logged work on BEAM-2517: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3339) Create post-release testing of the nightly snapshots

[ https://issues.apache.org/jira/browse/BEAM-3339?focusedWorklogId=83225&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83225 ] ASF GitHub Bot logged work on BEAM-3339: Author: ASF GitHub Bot

[beam] 01/01: Merge pull request #4908: Add Protocol Buffer support

This is an automated email from the ASF dual-hosted git repository. tgroh pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit 1e3663b2e9781711ba45a597801eb8e11d3fd22c Merge: 7c54fb2 b539aba Author: Thomas Groh AuthorDate: Thu Mar 22 09:34:36 2018 -0

[beam] branch master updated (7c54fb2 -> 1e3663b)

This is an automated email from the ASF dual-hosted git repository. tgroh pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 7c54fb2 Merge pull request #4915 from robertwb/microbenchmark add b539aba BEAM-3894: Add Protocol Buffer support

[jira] [Work logged] (BEAM-3855) Add Go SDK support for protobuf coder

[ https://issues.apache.org/jira/browse/BEAM-3855?focusedWorklogId=83226&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83226 ] ASF GitHub Bot logged work on BEAM-3855: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3861) Build test infra for end-to-end streaming test in Python SDK

[ https://issues.apache.org/jira/browse/BEAM-3861?focusedWorklogId=83228&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83228 ] ASF GitHub Bot logged work on BEAM-3861: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3861) Build test infra for end-to-end streaming test in Python SDK

[ https://issues.apache.org/jira/browse/BEAM-3861?focusedWorklogId=83229&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83229 ] ASF GitHub Bot logged work on BEAM-3861: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3861) Build test infra for end-to-end streaming test in Python SDK

[ https://issues.apache.org/jira/browse/BEAM-3861?focusedWorklogId=83227&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83227 ] ASF GitHub Bot logged work on BEAM-3861: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3861) Build test infra for end-to-end streaming test in Python SDK

[ https://issues.apache.org/jira/browse/BEAM-3861?focusedWorklogId=83237&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83237 ] ASF GitHub Bot logged work on BEAM-3861: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3738) Enable Py3 linting in Jenkins

[ https://issues.apache.org/jira/browse/BEAM-3738?focusedWorklogId=83238&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83238 ] ASF GitHub Bot logged work on BEAM-3738: Author: ASF GitHub Bot

[beam] branch master updated (1e3663b -> e49ed3c)

This is an automated email from the ASF dual-hosted git repository. altay pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 1e3663b Merge pull request #4908: Add Protocol Buffer support add e49ed3c Improve test util for PubSub exist chec

[jira] [Work logged] (BEAM-3738) Enable Py3 linting in Jenkins

[ https://issues.apache.org/jira/browse/BEAM-3738?focusedWorklogId=83239&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83239 ] ASF GitHub Bot logged work on BEAM-3738: Author: ASF GitHub Bot

[jira] [Resolved] (BEAM-3891) There should be some way to perform a Topological Sort with a stable output

[ https://issues.apache.org/jira/browse/BEAM-3891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh resolved BEAM-3891. --- Resolution: Fixed Fix Version/s: Not applicable > There should be some way to perform a Topologi

[jira] [Work logged] (BEAM-3744) Support full PubsubMessages

[ https://issues.apache.org/jira/browse/BEAM-3744?focusedWorklogId=83240&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83240 ] ASF GitHub Bot logged work on BEAM-3744: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3339) Create post-release testing of the nightly snapshots

[ https://issues.apache.org/jira/browse/BEAM-3339?focusedWorklogId=83250&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83250 ] ASF GitHub Bot logged work on BEAM-3339: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3848) SolrIO: Improve retrying mechanism in client writes

[ https://issues.apache.org/jira/browse/BEAM-3848?focusedWorklogId=83251&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83251 ] ASF GitHub Bot logged work on BEAM-3848: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3861) Build test infra for end-to-end streaming test in Python SDK

[ https://issues.apache.org/jira/browse/BEAM-3861?focusedWorklogId=83252&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83252 ] ASF GitHub Bot logged work on BEAM-3861: Author: ASF GitHub Bot

[beam] 01/01: Remove "i == numSplits" condition, which can never be reached as i is < numSplits

This is an automated email from the ASF dual-hosted git repository. lcwik pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit 55837fde1392f7d1aa2f6e44f9436b66a62d3944 Merge: e49ed3c cabe9d0 Author: Lukasz Cwik AuthorDate: Thu Mar 22 10:24:03 2018 -0

[beam] branch master updated (e49ed3c -> 55837fd)

This is an automated email from the ASF dual-hosted git repository. lcwik pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from e49ed3c Improve test util for PubSub exist check (#4922) add cabe9d0 Remove "i == numSplits" condition, which can

[jira] [Created] (BEAM-3913) Support custom runner primitives in Fusion

Thomas Groh created BEAM-3913: - Summary: Support custom runner primitives in Fusion Key: BEAM-3913 URL: https://issues.apache.org/jira/browse/BEAM-3913 Project: Beam Issue Type: Improvement

[jira] [Work logged] (BEAM-3851) Support element timestamps while publishing to Kafka.

[ https://issues.apache.org/jira/browse/BEAM-3851?focusedWorklogId=83255&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83255 ] ASF GitHub Bot logged work on BEAM-3851: Author: ASF GitHub Bot

[jira] [Created] (BEAM-3914) 'Unzip' flattens before performing fusion

Thomas Groh created BEAM-3914: - Summary: 'Unzip' flattens before performing fusion Key: BEAM-3914 URL: https://issues.apache.org/jira/browse/BEAM-3914 Project: Beam Issue Type: Improvement

[jira] [Assigned] (BEAM-3516) SpannerWriteGroupFn does not respect mutation limits

[ https://issues.apache.org/jira/browse/BEAM-3516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh reassigned BEAM-3516: - Assignee: Chamikara Jayalath (was: Thomas Groh) > SpannerWriteGroupFn does not respect mutation l

[jira] [Assigned] (BEAM-2767) BigQueryIO result different for REPEATED field between DirectRunner and DataflowRunner

[ https://issues.apache.org/jira/browse/BEAM-2767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh reassigned BEAM-2767: - Assignee: Chamikara Jayalath (was: Thomas Groh) > BigQueryIO result different for REPEATED field

[jira] [Assigned] (BEAM-3779) Enable deserialization of a non-java Pipeline

[ https://issues.apache.org/jira/browse/BEAM-3779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh reassigned BEAM-3779: - Assignee: Ben Sidhom (was: Thomas Groh) > Enable deserialization of a non-java Pipeline > ---

[jira] [Commented] (BEAM-2767) BigQueryIO result different for REPEATED field between DirectRunner and DataflowRunner

[ https://issues.apache.org/jira/browse/BEAM-2767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16409955#comment-16409955 ] Thomas Groh commented on BEAM-2767: --- Sending this for Cham for any understanding of what'

[jira] [Work logged] (BEAM-3851) Support element timestamps while publishing to Kafka.

[ https://issues.apache.org/jira/browse/BEAM-3851?focusedWorklogId=83258&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83258 ] ASF GitHub Bot logged work on BEAM-3851: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3861) Build test infra for end-to-end streaming test in Python SDK

[ https://issues.apache.org/jira/browse/BEAM-3861?focusedWorklogId=83260&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83260 ] ASF GitHub Bot logged work on BEAM-3861: Author: ASF GitHub Bot

Build failed in Jenkins: beam_PostRelease_NightlySnapshot #152

See -- [...truncated 2.36 MB...] INFO: Will remove known temporary file /tmp/groovy-generated-5618827979173645607-tmpdir/word-count-beam/.temp-beam-2018-03-22_17-46-07-0/

Jenkins build became unstable: beam_PostCommit_Java_MavenInstall #6269

See

[beam] branch master updated: [BEAM-3851] Option to preserve element timestamp while publishing to Kafka. (#4868)

This is an automated email from the ASF dual-hosted git repository. mingmxu pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git The following commit(s) were added to refs/heads/master by this push: new 501dc4c [BEAM-3851] Option to preserve element t

[jira] [Work logged] (BEAM-3851) Support element timestamps while publishing to Kafka.

[ https://issues.apache.org/jira/browse/BEAM-3851?focusedWorklogId=83269&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83269 ] ASF GitHub Bot logged work on BEAM-3851: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3851) Support element timestamps while publishing to Kafka.

[ https://issues.apache.org/jira/browse/BEAM-3851?focusedWorklogId=83270&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83270 ] ASF GitHub Bot logged work on BEAM-3851: Author: ASF GitHub Bot

[jira] [Created] (BEAM-3915) Unclosed reader in JavaReadViaImpulse#ReadFromBoundedSourceFn

Ted Yu created BEAM-3915: Summary: Unclosed reader in JavaReadViaImpulse#ReadFromBoundedSourceFn Key: BEAM-3915 URL: https://issues.apache.org/jira/browse/BEAM-3915 Project: Beam Issue Type: Bug

[jira] [Work logged] (BEAM-3339) Create post-release testing of the nightly snapshots

[ https://issues.apache.org/jira/browse/BEAM-3339?focusedWorklogId=83278&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83278 ] ASF GitHub Bot logged work on BEAM-3339: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3861) Build test infra for end-to-end streaming test in Python SDK

[ https://issues.apache.org/jira/browse/BEAM-3861?focusedWorklogId=83283&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83283 ] ASF GitHub Bot logged work on BEAM-3861: Author: ASF GitHub Bot

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #5201

See

Jenkins build is back to stable : beam_PostCommit_Java_MavenInstall #6270

See

Build failed in Jenkins: beam_PerformanceTests_TextIOIT #299

See Changes: [coheigea] Remove "i == numSplits" condition, which can never be reached as i is [wcn] BEAM-3894: Add Protocol Buffer support [aaltay] Improve test util for PubSub exist check (#4922)

[jira] [Work logged] (BEAM-3418) Python Fnapi - Support Multiple SDK workers on a single VM

[ https://issues.apache.org/jira/browse/BEAM-3418?focusedWorklogId=83287&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83287 ] ASF GitHub Bot logged work on BEAM-3418: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3418) Python Fnapi - Support Multiple SDK workers on a single VM

[ https://issues.apache.org/jira/browse/BEAM-3418?focusedWorklogId=83286&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83286 ] ASF GitHub Bot logged work on BEAM-3418: Author: ASF GitHub Bot

Build failed in Jenkins: beam_PerformanceTests_Python #1054

See Changes: [coheigea] Remove "i == numSplits" condition, which can never be reached as i is [wcn] BEAM-3894: Add Protocol Buffer support [aaltay] Improve test util for PubSub exist check (#4922)

[jira] [Work logged] (BEAM-3913) Support custom runner primitives in Fusion

[ https://issues.apache.org/jira/browse/BEAM-3913?focusedWorklogId=83289&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83289 ] ASF GitHub Bot logged work on BEAM-3913: Author: ASF GitHub Bot

Build failed in Jenkins: beam_PerformanceTests_Spark #1498

See Changes: [coheigea] Remove "i == numSplits" condition, which can never be reached as i is [wcn] BEAM-3894: Add Protocol Buffer support [aaltay] Improve test util for PubSub exist check (#4922) [

Jenkins build became unstable: beam_PostCommit_Java_ValidatesRunner_Apex #3752

See

[jira] [Commented] (BEAM-2767) BigQueryIO result different for REPEATED field between DirectRunner and DataflowRunner

[ https://issues.apache.org/jira/browse/BEAM-2767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16410168#comment-16410168 ] Maximilian Roos commented on BEAM-2767: --- Is there any way to get around this on Pytho

[jira] [Created] (BEAM-3916) BigtableIO should use ValueProviders for KeyRange and RowFilter

Herbert R Lee created BEAM-3916: --- Summary: BigtableIO should use ValueProviders for KeyRange and RowFilter Key: BEAM-3916 URL: https://issues.apache.org/jira/browse/BEAM-3916 Project: Beam Iss

[jira] [Work logged] (BEAM-3339) Create post-release testing of the nightly snapshots

[ https://issues.apache.org/jira/browse/BEAM-3339?focusedWorklogId=83309&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83309 ] ASF GitHub Bot logged work on BEAM-3339: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-2732) State tracking in Python is inefficient and has duplicated code

[ https://issues.apache.org/jira/browse/BEAM-2732?focusedWorklogId=83310&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83310 ] ASF GitHub Bot logged work on BEAM-2732: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3744) Support full PubsubMessages

[ https://issues.apache.org/jira/browse/BEAM-3744?focusedWorklogId=83311&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83311 ] ASF GitHub Bot logged work on BEAM-3744: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3861) Build test infra for end-to-end streaming test in Python SDK

[ https://issues.apache.org/jira/browse/BEAM-3861?focusedWorklogId=83312&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83312 ] ASF GitHub Bot logged work on BEAM-3861: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3418) Python Fnapi - Support Multiple SDK workers on a single VM

[ https://issues.apache.org/jira/browse/BEAM-3418?focusedWorklogId=83313&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83313 ] ASF GitHub Bot logged work on BEAM-3418: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3418) Python Fnapi - Support Multiple SDK workers on a single VM

[ https://issues.apache.org/jira/browse/BEAM-3418?focusedWorklogId=83314&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-83314 ] ASF GitHub Bot logged work on BEAM-3418: Author: ASF GitHub Bot

Jenkins build became unstable: beam_PostCommit_Java_ValidatesRunner_Flink #5300

See

[jira] [Created] (BEAM-3917) Pipeline roots are not computed correctly for CoGBK

Henning Rohde created BEAM-3917: --- Summary: Pipeline roots are not computed correctly for CoGBK Key: BEAM-3917 URL: https://issues.apache.org/jira/browse/BEAM-3917 Project: Beam Issue Type: Bug

  1   2   3   >