[jira] [Created] (BEAM-6015) Uber task for Portable Flink scalability

Ankur Goenka created BEAM-6015: -- Summary: Uber task for Portable Flink scalability Key: BEAM-6015 URL: https://issues.apache.org/jira/browse/BEAM-6015 Project: Beam Issue Type: Task

[jira] [Commented] (BEAM-6002) Nexmark tests timing out on all runners (crash loop due to metrics?)

[ https://issues.apache.org/jira/browse/BEAM-6002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16678925#comment-16678925 ] Chamikara Jayalath commented on BEAM-6002: -- Looks like Dataflow job (first one) succeeded but JVM

[jira] [Work logged] (BEAM-4444) Parquet IO for Python SDK

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

[jira] [Commented] (BEAM-6014) bigquery_tornadoes example does not work on Python Direct Runner

[ https://issues.apache.org/jira/browse/BEAM-6014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16678927#comment-16678927 ] Valentyn Tymofieiev commented on BEAM-6014: --- I wonder if the reason is that with DirectRunner we

[jira] [Assigned] (BEAM-6002) Nexmark tests timing out on all runners (crash loop due to metrics?)

[ https://issues.apache.org/jira/browse/BEAM-6002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Jayalath reassigned BEAM-6002: Assignee: Andrew Pilloud (was: Lukasz Gajowy) > Nexmark tests timing out on all

[jira] [Work logged] (BEAM-4444) Parquet IO for Python SDK

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

[jira] [Commented] (BEAM-6014) bigquery_tornadoes example does not work on Python Direct Runner

[ https://issues.apache.org/jira/browse/BEAM-6014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16678911#comment-16678911 ] Charles Chen commented on BEAM-6014: I can confirm that this problem occurs for me too.  For more

[jira] [Updated] (BEAM-6014) bigquery_tornadoes example does not work on Python Direct Runner

[ https://issues.apache.org/jira/browse/BEAM-6014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Valentyn Tymofieiev updated BEAM-6014: -- Description: Steps to reproduce:   {noformat}   PROJECT=$(gcloud config get-value

[jira] [Work logged] (BEAM-5798) Add support for dynamic destinations when writing to Kafka

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

[jira] [Work logged] (BEAM-5798) Add support for dynamic destinations when writing to Kafka

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

[jira] [Comment Edited] (BEAM-6014) bigquery_tornadoes example does not work on Python Direct Runner

[ https://issues.apache.org/jira/browse/BEAM-6014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16678911#comment-16678911 ] Charles Chen edited comment on BEAM-6014 at 11/7/18 10:55 PM: -- I can confirm

[jira] [Work logged] (BEAM-5931) Rollback PR/6899

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

[jira] [Commented] (BEAM-6014) bigquery_tornadoes example does not work on Python Direct Runner

[ https://issues.apache.org/jira/browse/BEAM-6014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16678895#comment-16678895 ] Valentyn Tymofieiev commented on BEAM-6014: --- Also tried to manually tried to disable FnAPI

[jira] [Work logged] (BEAM-5939) Deduplicate constants

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

[jira] [Created] (BEAM-6014) bigquery_tornadoes example does not work on Python Direct Runner

Valentyn Tymofieiev created BEAM-6014: - Summary: bigquery_tornadoes example does not work on Python Direct Runner Key: BEAM-6014 URL: https://issues.apache.org/jira/browse/BEAM-6014 Project: Beam

[jira] [Work logged] (BEAM-6013) Reduce verbose logging within SerializableCoder

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

[jira] [Commented] (BEAM-5953) Support DataflowRunner on Python 3

[ https://issues.apache.org/jira/browse/BEAM-5953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16678898#comment-16678898 ] Scott Wegner commented on BEAM-5953: I don't have much to contribute, but some additional details

[jira] [Work logged] (BEAM-4444) Parquet IO for Python SDK

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

[jira] [Work logged] (BEAM-4444) Parquet IO for Python SDK

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

[jira] [Comment Edited] (BEAM-6014) bigquery_tornadoes example does not work on Python Direct Runner

[ https://issues.apache.org/jira/browse/BEAM-6014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16678895#comment-16678895 ] Valentyn Tymofieiev edited comment on BEAM-6014 at 11/7/18 10:35 PM: -

[jira] [Work logged] (BEAM-6013) Reduce verbose logging within SerializableCoder

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

[jira] [Created] (BEAM-6013) Reduce verbose logging within SerializableCoder

Luke Cwik created BEAM-6013: --- Summary: Reduce verbose logging within SerializableCoder Key: BEAM-6013 URL: https://issues.apache.org/jira/browse/BEAM-6013 Project: Beam Issue Type: Improvement

[jira] [Work logged] (BEAM-5979) Support DATE and TIME in DML

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

[jira] [Assigned] (BEAM-3221) Model pipeline representation improvements

[ https://issues.apache.org/jira/browse/BEAM-3221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henning Rohde reassigned BEAM-3221: --- Assignee: (was: Henning Rohde) > Model pipeline representation improvements >

[jira] [Assigned] (BEAM-5679) Beam should report the account used to attempt to submit a job to Dataflow

[ https://issues.apache.org/jira/browse/BEAM-5679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henning Rohde reassigned BEAM-5679: --- Assignee: (was: Henning Rohde) > Beam should report the account used to attempt to

[jira] [Assigned] (BEAM-5791) Bound the amount of data on the data plane by time.

[ https://issues.apache.org/jira/browse/BEAM-5791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henning Rohde reassigned BEAM-5791: --- Assignee: (was: Henning Rohde) > Bound the amount of data on the data plane by time. >

[jira] [Assigned] (BEAM-5661) [beam_PostCommit_Py_ValCont] [:beam-sdks-python-container:docker] no such file or directory

[ https://issues.apache.org/jira/browse/BEAM-5661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henning Rohde reassigned BEAM-5661: --- Assignee: (was: Henning Rohde) > [beam_PostCommit_Py_ValCont]

[jira] [Assigned] (BEAM-5657) Enable CheckStyle in dataflow java worker code

[ https://issues.apache.org/jira/browse/BEAM-5657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henning Rohde reassigned BEAM-5657: --- Assignee: (was: Henning Rohde) > Enable CheckStyle in dataflow java worker code >

[jira] [Assigned] (BEAM-5689) Remove artifact naming constraint for portable Dataflow job

[ https://issues.apache.org/jira/browse/BEAM-5689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henning Rohde reassigned BEAM-5689: --- Assignee: (was: Henning Rohde) > Remove artifact naming constraint for portable Dataflow

[jira] [Assigned] (BEAM-5686) Remove DataflowRunnerHarness shim again

[ https://issues.apache.org/jira/browse/BEAM-5686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henning Rohde reassigned BEAM-5686: --- Assignee: (was: Henning Rohde) > Remove DataflowRunnerHarness shim again >

[jira] [Assigned] (BEAM-5659) Enable Javadocs check in dataflow java worker code

[ https://issues.apache.org/jira/browse/BEAM-5659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henning Rohde reassigned BEAM-5659: --- Assignee: (was: Henning Rohde) > Enable Javadocs check in dataflow java worker code >

[jira] [Assigned] (BEAM-5466) Cannot deploy job to Dataflow with RuntimeValueProvider

[ https://issues.apache.org/jira/browse/BEAM-5466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henning Rohde reassigned BEAM-5466: --- Assignee: (was: Henning Rohde) > Cannot deploy job to Dataflow with RuntimeValueProvider

[jira] [Assigned] (BEAM-3204) Coders only should have a FunctionSpec, not an SdkFunctionSpec

[ https://issues.apache.org/jira/browse/BEAM-3204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henning Rohde reassigned BEAM-3204: --- Assignee: (was: Henning Rohde) > Coders only should have a FunctionSpec, not an

[jira] [Assigned] (BEAM-2885) Local Dataflow proxy for portable job submission

[ https://issues.apache.org/jira/browse/BEAM-2885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henning Rohde reassigned BEAM-2885: --- Assignee: (was: Henning Rohde) > Local Dataflow proxy for portable job submission >

[jira] [Assigned] (BEAM-5658) Enable FindBugs in dataflow java worker code

[ https://issues.apache.org/jira/browse/BEAM-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henning Rohde reassigned BEAM-5658: --- Assignee: (was: Henning Rohde) > Enable FindBugs in dataflow java worker code >

[jira] [Assigned] (BEAM-5512) Dataflow migrates to using shared portability library for user timers

[ https://issues.apache.org/jira/browse/BEAM-5512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henning Rohde reassigned BEAM-5512: --- Assignee: (was: Henning Rohde) > Dataflow migrates to using shared portability library

[jira] [Assigned] (BEAM-3514) Use portable WindowIntoPayload in DataflowRunner

[ https://issues.apache.org/jira/browse/BEAM-3514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henning Rohde reassigned BEAM-3514: --- Assignee: (was: Henning Rohde) > Use portable WindowIntoPayload in DataflowRunner >

[jira] [Assigned] (BEAM-3223) PTransform spec should not reuse FunctionSpec

[ https://issues.apache.org/jira/browse/BEAM-3223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henning Rohde reassigned BEAM-3223: --- Assignee: (was: Henning Rohde) > PTransform spec should not reuse FunctionSpec >

[jira] [Commented] (BEAM-4821) Update Built-in I/O transforms page for Python

[ https://issues.apache.org/jira/browse/BEAM-4821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16678699#comment-16678699 ] Udi Meiri commented on BEAM-4821: - I believe both reads and writes are possible on HDFS. > Update

[jira] [Comment Edited] (BEAM-5953) Support DataflowRunner on Python 3

[ https://issues.apache.org/jira/browse/BEAM-5953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16677546#comment-16677546 ] Mark Liu edited comment on BEAM-5953 at 11/7/18 7:47 PM: - With provided Python 3

[jira] [Work logged] (BEAM-4681) Integrate support for timers using the portability APIs into Flink

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

[jira] [Work logged] (BEAM-6008) Propagate errors through portable portable runner

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

[jira] [Work logged] (BEAM-5931) Rollback PR/6899

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

[jira] [Work logged] (BEAM-4681) Integrate support for timers using the portability APIs into Flink

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

[jira] [Work logged] (BEAM-5931) Rollback PR/6899

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

[jira] [Work logged] (BEAM-6005) PCollectionCustomCoderTest passes spuriously.

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

[jira] [Work logged] (BEAM-6005) PCollectionCustomCoderTest passes spuriously.

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

[jira] [Work logged] (BEAM-5931) Rollback PR/6899

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

[jira] [Work logged] (BEAM-5931) Rollback PR/6899

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

[jira] [Work logged] (BEAM-5931) Rollback PR/6899

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

[jira] [Work logged] (BEAM-5931) Rollback PR/6899

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

[jira] [Work logged] (BEAM-5939) Deduplicate constants

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

[jira] [Assigned] (BEAM-6002) Nexmark tests timing out on all runners (crash loop due to metrics?)

[ https://issues.apache.org/jira/browse/BEAM-6002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Jayalath reassigned BEAM-6002: Assignee: Lukasz Gajowy (was: Chamikara Jayalath) > Nexmark tests timing out on

[jira] [Work logged] (BEAM-5931) Rollback PR/6899

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

[jira] [Work stopped] (BEAM-5965) RPAD

[ https://issues.apache.org/jira/browse/BEAM-5965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-5965 stopped by Rui Wang. -- > RPAD > > > Key: BEAM-5965 > URL:

[jira] [Work logged] (BEAM-6005) PCollectionCustomCoderTest passes spuriously.

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

[jira] [Work logged] (BEAM-5979) Support DATE and TIME in DML

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

[jira] [Work logged] (BEAM-6005) PCollectionCustomCoderTest passes spuriously.

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

[jira] [Closed] (BEAM-6006) Test TIME +/- Interval

[ https://issues.apache.org/jira/browse/BEAM-6006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Wang closed BEAM-6006. -- Resolution: Fixed Fix Version/s: Not applicable > Test TIME +/- Interval > -- > >

[jira] [Work logged] (BEAM-6010) Deprecate KafkaIO withTimestampFn()

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

[jira] [Work logged] (BEAM-5931) Rollback PR/6899

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

[jira] [Work logged] (BEAM-5906) Remove pipeline for publishing nexmark results to bigQuery and publish using BigQuery API only

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

[jira] [Work logged] (BEAM-5931) Rollback PR/6899

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

[jira] [Work logged] (BEAM-5979) Support DATE and TIME in DML

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

[jira] [Work logged] (BEAM-5939) Deduplicate constants

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

[jira] [Commented] (BEAM-6010) Deprecate KafkaIO withTimestampFn()

[ https://issues.apache.org/jira/browse/BEAM-6010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16678588#comment-16678588 ] Raghu Angadi commented on BEAM-6010: Thank you for filing this. > Deprecate KafkaIO withTimestampFn()

[jira] [Commented] (BEAM-5798) Add support for dynamic destinations when writing to Kafka

[ https://issues.apache.org/jira/browse/BEAM-5798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16678582#comment-16678582 ] Raghu Angadi commented on BEAM-5798: [~aromanenko], yeah, that's what I had in mind. But we should go

[jira] [Work logged] (BEAM-4863) Implement consistentWithEquals/structuralValue on FullWindowedValueCoder

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

[jira] [Work logged] (BEAM-5939) Deduplicate constants

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

[jira] [Work logged] (BEAM-6006) Test TIME +/- Interval

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

[jira] [Work logged] (BEAM-5939) Deduplicate constants

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

[jira] [Work logged] (BEAM-5939) Deduplicate constants

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

[jira] [Work logged] (BEAM-6005) PCollectionCustomCoderTest passes spuriously.

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

[jira] [Work logged] (BEAM-5906) Remove pipeline for publishing nexmark results to bigQuery and publish using BigQuery API only

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

[jira] [Commented] (BEAM-5939) Deduplicate constants

[ https://issues.apache.org/jira/browse/BEAM-5939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16678550#comment-16678550 ] Brian Martin commented on BEAM-5939: Hey [~altay], I've made a PR for this minor change. >

[jira] [Work logged] (BEAM-5939) Deduplicate constants

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

[jira] [Work logged] (BEAM-5931) Rollback PR/6899

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

[jira] [Work logged] (BEAM-5931) Rollback PR/6899

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

[jira] [Work logged] (BEAM-5931) Rollback PR/6899

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

[jira] [Work logged] (BEAM-5906) Remove pipeline for publishing nexmark results to bigQuery and publish using BigQuery API only

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

[jira] [Work logged] (BEAM-5906) Remove pipeline for publishing nexmark results to bigQuery and publish using BigQuery API only

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

[jira] [Work logged] (BEAM-6005) PCollectionCustomCoderTest passes spuriously.

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

[jira] [Work logged] (BEAM-5906) Remove pipeline for publishing nexmark results to bigQuery and publish using BigQuery API only

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

[jira] [Work logged] (BEAM-5906) Remove pipeline for publishing nexmark results to bigQuery and publish using BigQuery API only

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

[jira] [Work logged] (BEAM-5906) Remove pipeline for publishing nexmark results to bigQuery and publish using BigQuery API only

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

[jira] [Work logged] (BEAM-5906) Remove pipeline for publishing nexmark results to bigQuery and publish using BigQuery API only

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

[jira] [Work logged] (BEAM-6005) PCollectionCustomCoderTest passes spuriously.

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

[jira] [Work logged] (BEAM-6005) PCollectionCustomCoderTest passes spuriously.

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

[jira] [Work logged] (BEAM-6005) PCollectionCustomCoderTest passes spuriously.

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

[jira] [Work logged] (BEAM-6005) PCollectionCustomCoderTest passes spuriously.

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

[jira] [Commented] (BEAM-5798) Add support for dynamic destinations when writing to Kafka

[ https://issues.apache.org/jira/browse/BEAM-5798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16678500#comment-16678500 ] Alexey Romanenko commented on BEAM-5798: [~rangadi] You mean to change the internal API from using

[jira] [Work logged] (BEAM-5931) Rollback PR/6899

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

[jira] [Work logged] (BEAM-5931) Rollback PR/6899

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

[jira] [Work logged] (BEAM-5931) Rollback PR/6899

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

[jira] [Work logged] (BEAM-5931) Rollback PR/6899

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

[jira] [Work logged] (BEAM-5931) Rollback PR/6899

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

[jira] [Work logged] (BEAM-5931) Rollback PR/6899

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

[jira] [Work logged] (BEAM-5931) Rollback PR/6899

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

[jira] [Comment Edited] (BEAM-6011) Enable Phrase triggering in Nexmark jobs

[ https://issues.apache.org/jira/browse/BEAM-6011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16678445#comment-16678445 ] Lukasz Gajowy edited comment on BEAM-6011 at 11/7/18 4:18 PM: -- I made some

[jira] [Commented] (BEAM-6002) Nexmark tests timing out on all runners (crash loop due to metrics?)

[ https://issues.apache.org/jira/browse/BEAM-6002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16678450#comment-16678450 ] Lukasz Gajowy commented on BEAM-6002: - I created an issue for nexmark phrase triggering:

  1   2   >