[jira] [Commented] (BEAM-10079) Samza tests failing [Java 11]

[ https://issues.apache.org/jira/browse/BEAM-10079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17125416#comment-17125416 ] Xinyu Liu commented on BEAM-10079: -- [~kenn]: hmm, this doesn't happen in our local folk at LinkedIn so

[jira] [Assigned] (BEAM-8459) Samza runner fails UsesStrictTimerOrdering category tests

[ https://issues.apache.org/jira/browse/BEAM-8459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinyu Liu reassigned BEAM-8459: --- Assignee: Xinyu Liu > Samza runner fails UsesStrictTimerOrdering category tests >

[jira] [Updated] (BEAM-7059) SamzaRunner: fix the job.id inconsistency in the new Samza version

[ https://issues.apache.org/jira/browse/BEAM-7059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinyu Liu updated BEAM-7059: Description: The new Samza 1.1.0 version introduces a backward incompatible change which requires setting

[jira] [Created] (BEAM-7059) SamzaRunner: fix the job.id inconsistency in the new Samza version

Xinyu Liu created BEAM-7059: --- Summary: SamzaRunner: fix the job.id inconsistency in the new Samza version Key: BEAM-7059 URL: https://issues.apache.org/jira/browse/BEAM-7059 Project: Beam Issue

[jira] [Created] (BEAM-6994) SamzaRunner: further improvements for upgrading Samza

Xinyu Liu created BEAM-6994: --- Summary: SamzaRunner: further improvements for upgrading Samza Key: BEAM-6994 URL: https://issues.apache.org/jira/browse/BEAM-6994 Project: Beam Issue Type:

[jira] [Created] (BEAM-6932) SamzaRunner: migrate to use new Samza 1.1.0 liraries

Xinyu Liu created BEAM-6932: --- Summary: SamzaRunner: migrate to use new Samza 1.1.0 liraries Key: BEAM-6932 URL: https://issues.apache.org/jira/browse/BEAM-6932 Project: Beam Issue Type:

[jira] [Created] (BEAM-6866) SamzaRunner: support timers in ParDo

Xinyu Liu created BEAM-6866: --- Summary: SamzaRunner: support timers in ParDo Key: BEAM-6866 URL: https://issues.apache.org/jira/browse/BEAM-6866 Project: Beam Issue Type: Improvement

[jira] [Created] (BEAM-6767) SamzaRunner: Add more parameters to SamzaPipelineOptions

Xinyu Liu created BEAM-6767: --- Summary: SamzaRunner: Add more parameters to SamzaPipelineOptions Key: BEAM-6767 URL: https://issues.apache.org/jira/browse/BEAM-6767 Project: Beam Issue Type:

[jira] [Assigned] (BEAM-6550) ParDo Async Java API

[ https://issues.apache.org/jira/browse/BEAM-6550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinyu Liu reassigned BEAM-6550: --- Assignee: Bharath Kumarasubramanian (was: Xinyu Liu) > ParDo Async Java API >

[jira] [Commented] (BEAM-6550) ParDo Async Java API

[ https://issues.apache.org/jira/browse/BEAM-6550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16756377#comment-16756377 ] Xinyu Liu commented on BEAM-6550: - Summary from email thread: >From [~kenn]: If the input is a

[jira] [Created] (BEAM-6550) ParDo Async Java API

Xinyu Liu created BEAM-6550: --- Summary: ParDo Async Java API Key: BEAM-6550 URL: https://issues.apache.org/jira/browse/BEAM-6550 Project: Beam Issue Type: Improvement Components:

[jira] [Assigned] (BEAM-6550) ParDo Async Java API

[ https://issues.apache.org/jira/browse/BEAM-6550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinyu Liu reassigned BEAM-6550: --- Assignee: Xinyu Liu (was: Kenneth Knowles) > ParDo Async Java API > > >

[jira] [Assigned] (BEAM-5732) expose runner mode to user through samza pipeline option

[ https://issues.apache.org/jira/browse/BEAM-5732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinyu Liu reassigned BEAM-5732: --- Assignee: Daniel Chen (was: Xinyu Liu) > expose runner mode to user through samza pipeline option

[jira] [Created] (BEAM-6382) SamzaRunner: add an option to read configs using a user-defined factory

Xinyu Liu created BEAM-6382: --- Summary: SamzaRunner: add an option to read configs using a user-defined factory Key: BEAM-6382 URL: https://issues.apache.org/jira/browse/BEAM-6382 Project: Beam

[jira] [Created] (BEAM-6286) Add SamzaRunner profile to mvn archetype

Xinyu Liu created BEAM-6286: --- Summary: Add SamzaRunner profile to mvn archetype Key: BEAM-6286 URL: https://issues.apache.org/jira/browse/BEAM-6286 Project: Beam Issue Type: Improvement

[jira] [Created] (BEAM-6264) SamzaRunner: support metrics enable/disable and set state durable in SamzaPipelineOptions

Xinyu Liu created BEAM-6264: --- Summary: SamzaRunner: support metrics enable/disable and set state durable in SamzaPipelineOptions Key: BEAM-6264 URL: https://issues.apache.org/jira/browse/BEAM-6264

[jira] [Created] (BEAM-6253) SamzaRunner: Add a few customized transforms for runner use cases

Xinyu Liu created BEAM-6253: --- Summary: SamzaRunner: Add a few customized transforms for runner use cases Key: BEAM-6253 URL: https://issues.apache.org/jira/browse/BEAM-6253 Project: Beam Issue

[jira] [Created] (BEAM-6252) SamzaRunner: Add a registrar to allow customized DoFnInvoker

Xinyu Liu created BEAM-6252: --- Summary: SamzaRunner: Add a registrar to allow customized DoFnInvoker Key: BEAM-6252 URL: https://issues.apache.org/jira/browse/BEAM-6252 Project: Beam Issue Type:

[jira] [Commented] (BEAM-4763) Add postCommit scripts and perfkit dashboards for nexmark on Samza runner

[ https://issues.apache.org/jira/browse/BEAM-4763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16687147#comment-16687147 ] Xinyu Liu commented on BEAM-4763: - [~kenn]: Of course it's interesting to Samza runner! I will try to