[jira] [Commented] (BEAM-8298) Implement state caching for side inputs

[ https://issues.apache.org/jira/browse/BEAM-8298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969961#comment-16969961 ] Maximilian Michels commented on BEAM-8298: -- Sure. The goal is to extend the caching to side

[jira] [Updated] (BEAM-8567) Bundle execution errors during checkpointing may be swallowed

[ https://issues.apache.org/jira/browse/BEAM-8567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8567: - Fix Version/s: (was: 2.18.0) 2.17.0 > Bundle execution errors

[jira] [Updated] (BEAM-8566) Checkpoint buffer is flushed prematurely when another bundle is started during checkpointing

[ https://issues.apache.org/jira/browse/BEAM-8566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8566: - Fix Version/s: (was: 2.18.0) 2.17.0 > Checkpoint buffer is flushed

[jira] [Updated] (BEAM-8298) Implement state caching for side inputs

[ https://issues.apache.org/jira/browse/BEAM-8298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8298: - Component/s: (was: sdk-py-core) sdk-py-harness > Implement state

[jira] [Updated] (BEAM-8298) Implement state caching for side inputs

[ https://issues.apache.org/jira/browse/BEAM-8298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8298: - Component/s: runner-core > Implement state caching for side inputs >

[jira] [Updated] (BEAM-8577) FileSystems may have not be initialized during ResourceId deserialization

[ https://issues.apache.org/jira/browse/BEAM-8577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8577: - Status: Open (was: Triage Needed) > FileSystems may have not be initialized during

[jira] [Resolved] (BEAM-8788) [2.17.0 Release Validation] ParDoTest$TimerTests.testEventTimeTimerOrderingWithCreate Failed

[ https://issues.apache.org/jira/browse/BEAM-8788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-8788. -- Resolution: Fixed > [2.17.0 Release Validation] >

[jira] [Commented] (BEAM-8788) [2.17.0 Release Validation] ParDoTest$TimerTests.testEventTimeTimerOrderingWithCreate Failed

[ https://issues.apache.org/jira/browse/BEAM-8788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16979131#comment-16979131 ] Maximilian Michels commented on BEAM-8788: -- This needs to be backported:

[jira] [Updated] (BEAM-8788) [2.17.0 Release Validation] ParDoTest$TimerTests.testEventTimeTimerOrderingWithCreate Failed

[ https://issues.apache.org/jira/browse/BEAM-8788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8788: - Status: Open (was: Triage Needed) > [2.17.0 Release Validation] >

[jira] [Resolved] (BEAM-8869) MetricsPusherTest.pushesSystemMetrics is failing on non-portability FlinkRunner

[ https://issues.apache.org/jira/browse/BEAM-8869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-8869. -- Fix Version/s: Not applicable Resolution: Fixed >

[jira] [Resolved] (BEAM-8836) ExternalTransform is not providing a unique name

[ https://issues.apache.org/jira/browse/BEAM-8836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-8836. -- Fix Version/s: 2.18.0 Resolution: Fixed > ExternalTransform is not providing a

[jira] [Closed] (BEAM-8883) downgrade "Failed to remove job staging directory" log level

[ https://issues.apache.org/jira/browse/BEAM-8883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed BEAM-8883. Fix Version/s: 2.18.0 Resolution: Fixed > downgrade "Failed to remove job staging

[jira] [Resolved] (BEAM-8523) Add useful timestamp to job servicer GetJobs

[ https://issues.apache.org/jira/browse/BEAM-8523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-8523. -- Fix Version/s: 2.18.0 Resolution: Fixed > Add useful timestamp to job servicer

[jira] [Commented] (BEAM-8901) add experimental flag for reusing flink local environment

[ https://issues.apache.org/jira/browse/BEAM-8901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991691#comment-16991691 ] Maximilian Michels commented on BEAM-8901: -- {quote} Heap dump inspection shows that byte[]

[jira] [Updated] (BEAM-8929) Remove unnecessary exception handling in FnApiControlClientPoolService

[ https://issues.apache.org/jira/browse/BEAM-8929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8929: - Status: Open (was: Triage Needed) > Remove unnecessary exception handling in

[jira] [Resolved] (BEAM-8929) Remove unnecessary exception handling in FnApiControlClientPoolService

[ https://issues.apache.org/jira/browse/BEAM-8929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-8929. -- Resolution: Fixed > Remove unnecessary exception handling in

[jira] [Created] (BEAM-8962) FlinkMetricContainer causes churn in the JobManager and lets the web frontend malfunction

Maximilian Michels created BEAM-8962: Summary: FlinkMetricContainer causes churn in the JobManager and lets the web frontend malfunction Key: BEAM-8962 URL: https://issues.apache.org/jira/browse/BEAM-8962

[jira] [Updated] (BEAM-8962) FlinkMetricContainer causes churn in the JobManager and lets the web frontend malfunction

[ https://issues.apache.org/jira/browse/BEAM-8962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8962: - Status: Open (was: Triage Needed) > FlinkMetricContainer causes churn in the JobManager

[jira] [Commented] (BEAM-5495) PipelineResources algorithm is not working in most environments

[ https://issues.apache.org/jira/browse/BEAM-5495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16998381#comment-16998381 ] Maximilian Michels commented on BEAM-5495: -- {quote} Side note: I am more than happy if this

[jira] [Commented] (BEAM-5495) PipelineResources algorithm is not working in most environments

[ https://issues.apache.org/jira/browse/BEAM-5495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16998268#comment-16998268 ] Maximilian Michels commented on BEAM-5495: -- Let's assume best intentions. I don't think anyone

[jira] [Resolved] (BEAM-8835) Artifact retrieval fails with FlinkUberJarJobServer

[ https://issues.apache.org/jira/browse/BEAM-8835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-8835. -- Resolution: Fixed > Artifact retrieval fails with FlinkUberJarJobServer >

[jira] [Resolved] (BEAM-8930) External workers should receive artifact endpoint when started from python

[ https://issues.apache.org/jira/browse/BEAM-8930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-8930. -- Fix Version/s: 2.19.0 Resolution: Fixed > External workers should receive

[jira] [Resolved] (BEAM-8943) SDK harness servers don't shut down properly when SDK harness environment cleanup fails

[ https://issues.apache.org/jira/browse/BEAM-8943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-8943. -- Fix Version/s: 2.19.0 Resolution: Fixed Should we backport this to 2.18.0

[jira] [Updated] (BEAM-8959) Boolean pipeline options which default to true cannot be set to false

[ https://issues.apache.org/jira/browse/BEAM-8959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8959: - Status: Open (was: Triage Needed) > Boolean pipeline options which default to true

[jira] [Commented] (BEAM-8959) Boolean pipeline options which default to true cannot be set to false

[ https://issues.apache.org/jira/browse/BEAM-8959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16994926#comment-16994926 ] Maximilian Michels commented on BEAM-8959: -- That would be a fix for that particular option but

[jira] [Created] (BEAM-8959) Boolean pipeline options which default to true cannot be set to false

Maximilian Michels created BEAM-8959: Summary: Boolean pipeline options which default to true cannot be set to false Key: BEAM-8959 URL: https://issues.apache.org/jira/browse/BEAM-8959 Project:

[jira] [Commented] (BEAM-8901) add experimental flag for reusing flink local environment

[ https://issues.apache.org/jira/browse/BEAM-8901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16989561#comment-16989561 ] Maximilian Michels commented on BEAM-8901: -- This shouldn't be necessary. Flink itself runs

[jira] [Commented] (BEAM-8901) add experimental flag for reusing flink local environment

[ https://issues.apache.org/jira/browse/BEAM-8901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16989570#comment-16989570 ] Maximilian Michels commented on BEAM-8901: -- There was a memory issue in the past due to the job

[jira] [Resolved] (BEAM-8746) Allow the local job service to work from inside docker

[ https://issues.apache.org/jira/browse/BEAM-8746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-8746. -- Fix Version/s: 2.18.0 Resolution: Fixed > Allow the local job service to work

[jira] [Commented] (BEAM-8746) Allow the local job service to work from inside docker

[ https://issues.apache.org/jira/browse/BEAM-8746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16989583#comment-16989583 ] Maximilian Michels commented on BEAM-8746: -- Actually, the release branch is already cut, we need

[jira] [Updated] (BEAM-8746) Allow the local job service to work from inside docker

[ https://issues.apache.org/jira/browse/BEAM-8746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8746: - Fix Version/s: (was: 2.18.0) 2.19.0 > Allow the local job service

[jira] [Commented] (BEAM-8962) FlinkMetricContainer causes churn in the JobManager and lets the web frontend malfunction

[ https://issues.apache.org/jira/browse/BEAM-8962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16997437#comment-16997437 ] Maximilian Michels commented on BEAM-8962: -- I think it is worth to think about disabling the

[jira] [Resolved] (BEAM-5495) PipelineResources algorithm is not working in most environments

[ https://issues.apache.org/jira/browse/BEAM-5495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-5495. -- Fix Version/s: 2.19.0 Resolution: Fixed > PipelineResources algorithm is not

[jira] [Commented] (BEAM-8274) Remove dependency on experiments=beam_fn_api flag from PortableRunner

[ https://issues.apache.org/jira/browse/BEAM-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992725#comment-16992725 ] Maximilian Michels commented on BEAM-8274: -- I still think that adding an undocumented

[jira] [Updated] (BEAM-8483) Make beam_fn_api flag opt-out rather than opt-in for runners.

[ https://issues.apache.org/jira/browse/BEAM-8483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8483: - Status: Open (was: Triage Needed) > Make beam_fn_api flag opt-out rather than opt-in

[jira] [Closed] (BEAM-8483) Make beam_fn_api flag opt-out rather than opt-in for runners.

[ https://issues.apache.org/jira/browse/BEAM-8483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed BEAM-8483. Resolution: Fixed > Make beam_fn_api flag opt-out rather than opt-in for runners. >

[jira] [Commented] (BEAM-8483) Make beam_fn_api flag opt-out rather than opt-in for runners.

[ https://issues.apache.org/jira/browse/BEAM-8483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16959632#comment-16959632 ] Maximilian Michels commented on BEAM-8483: -- [~altay] We can use this issue to track the changes

[jira] [Commented] (BEAM-8274) Remove dependency on experiments=beam_fn_api flag from PortableRunner

[ https://issues.apache.org/jira/browse/BEAM-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16959627#comment-16959627 ] Maximilian Michels commented on BEAM-8274: -- Related: https://github.com/apache/beam/pull/9834 >

[jira] [Created] (BEAM-8483) Make beam_fn_api flag opt-out rather than opt-in for runners.

Maximilian Michels created BEAM-8483: Summary: Make beam_fn_api flag opt-out rather than opt-in for runners. Key: BEAM-8483 URL: https://issues.apache.org/jira/browse/BEAM-8483 Project: Beam

[jira] [Issue Comment Deleted] (BEAM-8274) Remove dependency on experiments=beam_fn_api flag from PortableRunner

[ https://issues.apache.org/jira/browse/BEAM-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8274: - Comment: was deleted (was: Related: https://github.com/apache/beam/pull/9834) > Remove

[jira] [Updated] (BEAM-8274) Remove dependency on experiments=beam_fn_api flag from PortableRunner

[ https://issues.apache.org/jira/browse/BEAM-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8274: - Fix Version/s: (was: 2.17.0) > Remove dependency on experiments=beam_fn_api flag from

[jira] [Closed] (BEAM-8430) sdk_worker_parallelism default is inconsistent between Py and Java SDKs

[ https://issues.apache.org/jira/browse/BEAM-8430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed BEAM-8430. Fix Version/s: 2.17.0 Resolution: Fixed > sdk_worker_parallelism default is

[jira] [Resolved] (BEAM-8403) Race condition in request id generation of GrpcStateRequestHandler

[ https://issues.apache.org/jira/browse/BEAM-8403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-8403. -- Resolution: Fixed > Race condition in request id generation of GrpcStateRequestHandler

[jira] [Created] (BEAM-8403) Race condition in request id generation of GrpcStateRequestHandler

Maximilian Michels created BEAM-8403: Summary: Race condition in request id generation of GrpcStateRequestHandler Key: BEAM-8403 URL: https://issues.apache.org/jira/browse/BEAM-8403 Project: Beam

[jira] [Commented] (BEAM-8403) Race condition in request id generation of GrpcStateRequestHandler

[ https://issues.apache.org/jira/browse/BEAM-8403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16951812#comment-16951812 ] Maximilian Michels commented on BEAM-8403: -- Also adding the error which occurs in case of the

[jira] [Updated] (BEAM-8403) Race condition in request id generation of GrpcStateRequestHandler

[ https://issues.apache.org/jira/browse/BEAM-8403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8403: - Status: Open (was: Triage Needed) > Race condition in request id generation of

[jira] [Commented] (BEAM-8403) Race condition in request id generation of GrpcStateRequestHandler

[ https://issues.apache.org/jira/browse/BEAM-8403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16951788#comment-16951788 ] Maximilian Michels commented on BEAM-8403: -- Should add that the SdkHarness itself has to be

[jira] [Resolved] (BEAM-8383) Add metrics to Python state cache

[ https://issues.apache.org/jira/browse/BEAM-8383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-8383. -- Fix Version/s: 2.18.0 Resolution: Fixed Since the release branch is cut, this

[jira] [Resolved] (BEAM-8509) TestPortableRunner should use JobServerDriver interface

[ https://issues.apache.org/jira/browse/BEAM-8509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-8509. -- Fix Version/s: 2.18.0 Resolution: Fixed > TestPortableRunner should use

[jira] [Closed] (BEAM-8442) Unfiy bundle register in Python SDK harness

[ https://issues.apache.org/jira/browse/BEAM-8442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed BEAM-8442. Fix Version/s: 2.18.0 Resolution: Fixed > Unfiy bundle register in Python SDK

[jira] [Updated] (BEAM-8442) Unfiy bundle register in Python SDK harness

[ https://issues.apache.org/jira/browse/BEAM-8442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8442: - Status: Open (was: Triage Needed) > Unfiy bundle register in Python SDK harness >

[jira] [Commented] (BEAM-8507) Unspecified flink_master fails on Python 3.6+

[ https://issues.apache.org/jira/browse/BEAM-8507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16961910#comment-16961910 ] Maximilian Michels commented on BEAM-8507: -- I believe the problem also exists for Python >= 3.6

[jira] [Updated] (BEAM-8507) Unspecified flink_master fails on Python 3.6+

[ https://issues.apache.org/jira/browse/BEAM-8507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8507: - Status: Open (was: Triage Needed) > Unspecified flink_master fails on Python 3.6+ >

[jira] [Commented] (BEAM-8507) Unspecified flink_master fails on Python 3.6+

[ https://issues.apache.org/jira/browse/BEAM-8507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16961860#comment-16961860 ] Maximilian Michels commented on BEAM-8507: -- Marking this fix version 2.17.0 since this needs to

[jira] [Updated] (BEAM-8507) Unspecified flink_master fails on Python 3.6+

[ https://issues.apache.org/jira/browse/BEAM-8507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8507: - Fix Version/s: 2.17.0 > Unspecified flink_master fails on Python 3.6+ >

[jira] [Issue Comment Deleted] (BEAM-8507) Unspecified flink_master fails on Python 3.6+

[ https://issues.apache.org/jira/browse/BEAM-8507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8507: - Comment: was deleted (was: I believe the problem also exists for Python >= 3.6 because

[jira] [Created] (BEAM-8512) Add integration tests for Python "flink_runner.py"

Maximilian Michels created BEAM-8512: Summary: Add integration tests for Python "flink_runner.py" Key: BEAM-8512 URL: https://issues.apache.org/jira/browse/BEAM-8512 Project: Beam Issue

[jira] [Closed] (BEAM-7730) Add Flink 1.9 build target and Make FlinkRunner compatible with Flink 1.9

[ https://issues.apache.org/jira/browse/BEAM-7730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed BEAM-7730. Resolution: Fixed > Add Flink 1.9 build target and Make FlinkRunner compatible with Flink

[jira] [Updated] (BEAM-7730) Add Flink 1.9 build target and Make FlinkRunner compatible with Flink 1.9

[ https://issues.apache.org/jira/browse/BEAM-7730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-7730: - Fix Version/s: 2.17.0 > Add Flink 1.9 build target and Make FlinkRunner compatible with

[jira] [Commented] (BEAM-7730) Add Flink 1.9 build target and Make FlinkRunner compatible with Flink 1.9

[ https://issues.apache.org/jira/browse/BEAM-7730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16953625#comment-16953625 ] Maximilian Michels commented on BEAM-7730: -- Marking this 2.17.0 because this was already deferred

[jira] [Closed] (BEAM-8375) Correct the command for Start a Flink job server in `environments.md`

[ https://issues.apache.org/jira/browse/BEAM-8375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed BEAM-8375. Fix Version/s: (was: 2.17.0) Not applicable Resolution: Fixed

[jira] [Closed] (BEAM-8377) Remove the flink-1.6 from the project-mappings

[ https://issues.apache.org/jira/browse/BEAM-8377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed BEAM-8377. Fix Version/s: (was: 2.17.0) Not applicable Resolution:

[jira] [Updated] (BEAM-8372) Allow submission of Flink UberJar directly to flink cluster.

[ https://issues.apache.org/jira/browse/BEAM-8372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8372: - Status: Open (was: Triage Needed) > Allow submission of Flink UberJar directly to flink

[jira] [Commented] (BEAM-8218) Implement Apache PulsarIO

[ https://issues.apache.org/jira/browse/BEAM-8218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16959909#comment-16959909 ] Maximilian Michels commented on BEAM-8218: -- Have you already started working on the connector? >

[jira] [Commented] (BEAM-8218) Implement Apache PulsarIO

[ https://issues.apache.org/jira/browse/BEAM-8218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16960316#comment-16960316 ] Maximilian Michels commented on BEAM-8218: -- Assigning this to [~taherk77] as per mailing list

[jira] [Assigned] (BEAM-8218) Implement Apache PulsarIO

[ https://issues.apache.org/jira/browse/BEAM-8218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned BEAM-8218: Assignee: (was: Alex Van Boxel) > Implement Apache PulsarIO >

[jira] [Assigned] (BEAM-8218) Implement Apache PulsarIO

[ https://issues.apache.org/jira/browse/BEAM-8218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned BEAM-8218: Assignee: Taher Koitawala > Implement Apache PulsarIO > -

[jira] [Assigned] (BEAM-8218) Implement Apache PulsarIO

[ https://issues.apache.org/jira/browse/BEAM-8218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned BEAM-8218: Assignee: Maximilian Michels > Implement Apache PulsarIO >

[jira] [Assigned] (BEAM-8218) Implement Apache PulsarIO

[ https://issues.apache.org/jira/browse/BEAM-8218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned BEAM-8218: Assignee: (was: Maximilian Michels) > Implement Apache PulsarIO >

[jira] [Resolved] (BEAM-8672) Loopback execution mode will exit before execution can begin

[ https://issues.apache.org/jira/browse/BEAM-8672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-8672. -- Resolution: Fixed > Loopback execution mode will exit before execution can begin >

[jira] [Updated] (BEAM-8746) Allow the local job service to work from inside docker

[ https://issues.apache.org/jira/browse/BEAM-8746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8746: - Status: Open (was: Triage Needed) > Allow the local job service to work from inside

[jira] [Updated] (BEAM-8672) Loopback execution mode will exit before execution can begin

[ https://issues.apache.org/jira/browse/BEAM-8672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8672: - Fix Version/s: 2.17.0 > Loopback execution mode will exit before execution can begin >

[jira] [Updated] (BEAM-8742) Add stateful processing to ParDo load test

[ https://issues.apache.org/jira/browse/BEAM-8742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8742: - Status: Open (was: Triage Needed) > Add stateful processing to ParDo load test >

[jira] [Created] (BEAM-8742) Add stateful processing to ParDo load test

Maximilian Michels created BEAM-8742: Summary: Add stateful processing to ParDo load test Key: BEAM-8742 URL: https://issues.apache.org/jira/browse/BEAM-8742 Project: Beam Issue Type:

[jira] [Resolved] (BEAM-8568) Local file system does not match relative path with wildcards

[ https://issues.apache.org/jira/browse/BEAM-8568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-8568. -- Resolution: Fixed > Local file system does not match relative path with wildcards >

[jira] [Commented] (BEAM-8512) Add integration tests for Python "flink_runner.py"

[ https://issues.apache.org/jira/browse/BEAM-8512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16982315#comment-16982315 ] Maximilian Michels commented on BEAM-8512: -- You need to add {{flink-runtime-web}} to unlock all

[jira] [Comment Edited] (BEAM-8512) Add integration tests for Python "flink_runner.py"

[ https://issues.apache.org/jira/browse/BEAM-8512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16982315#comment-16982315 ] Maximilian Michels edited comment on BEAM-8512 at 11/26/19 10:10 AM: -

[jira] [Assigned] (BEAM-8656) flink_master_url usage in flink_runner.py

[ https://issues.apache.org/jira/browse/BEAM-8656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned BEAM-8656: Assignee: Maximilian Michels (was: Kyle Weaver) > flink_master_url usage in

[jira] [Commented] (BEAM-8656) flink_master_url usage in flink_runner.py

[ https://issues.apache.org/jira/browse/BEAM-8656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16982381#comment-16982381 ] Maximilian Michels commented on BEAM-8656: -- Updating the flink runner page. We should be good

[jira] [Updated] (BEAM-8815) Portable pipeline execution without artifact staging

[ https://issues.apache.org/jira/browse/BEAM-8815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8815: - Status: Open (was: Triage Needed) > Portable pipeline execution without artifact staging

[jira] [Closed] (BEAM-8535) TextIO.read doesn't work with single wildcard with relative path

[ https://issues.apache.org/jira/browse/BEAM-8535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed BEAM-8535. Resolution: Duplicate Closing but feel free to re-open if it isn't. > TextIO.read doesn't

[jira] [Commented] (BEAM-8535) TextIO.read doesn't work with single wildcard with relative path

[ https://issues.apache.org/jira/browse/BEAM-8535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16982420#comment-16982420 ] Maximilian Michels commented on BEAM-8535: -- Is this a duplicate of BEAM-8568? > TextIO.read

[jira] [Assigned] (BEAM-8819) AvroCoder for SpecificRecords is not serialized correctly since 2.13.0

[ https://issues.apache.org/jira/browse/BEAM-8819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned BEAM-8819: Assignee: Piotr Szczepanik > AvroCoder for SpecificRecords is not serialized

[jira] [Commented] (BEAM-8819) AvroCoder for SpecificRecords is not serialized correctly since 2.13.0

[ https://issues.apache.org/jira/browse/BEAM-8819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16982424#comment-16982424 ] Maximilian Michels commented on BEAM-8819: -- Marking Fix Version 2.17.0 because this looks

[jira] [Updated] (BEAM-8819) AvroCoder for SpecificRecords is not serialized correctly since 2.13.0

[ https://issues.apache.org/jira/browse/BEAM-8819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8819: - Fix Version/s: 2.17.0 > AvroCoder for SpecificRecords is not serialized correctly since

[jira] [Updated] (BEAM-8819) AvroCoder for SpecificRecords is not serialized correctly since 2.13.0

[ https://issues.apache.org/jira/browse/BEAM-8819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8819: - Status: Open (was: Triage Needed) > AvroCoder for SpecificRecords is not serialized

[jira] [Updated] (BEAM-8535) TextIO.read doesn't work with single wildcard with relative path

[ https://issues.apache.org/jira/browse/BEAM-8535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8535: - Status: Open (was: Triage Needed) > TextIO.read doesn't work with single wildcard with

[jira] [Updated] (BEAM-8816) Load balance bundle processing w/ multiple SDK workers

[ https://issues.apache.org/jira/browse/BEAM-8816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8816: - Status: Open (was: Triage Needed) > Load balance bundle processing w/ multiple SDK

[jira] [Commented] (BEAM-8218) Implement Apache PulsarIO

[ https://issues.apache.org/jira/browse/BEAM-8218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16982622#comment-16982622 ] Maximilian Michels commented on BEAM-8218: -- [~taherk77] Could you give an update on the progress

[jira] [Commented] (BEAM-8512) Add integration tests for Python "flink_runner.py"

[ https://issues.apache.org/jira/browse/BEAM-8512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16983639#comment-16983639 ] Maximilian Michels commented on BEAM-8512: -- {quote} 1) With MiniCluster, I get error "Resource

[jira] [Updated] (BEAM-8835) Artifact retrieval fails with FlinkUberJarJobServer

[ https://issues.apache.org/jira/browse/BEAM-8835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8835: - Fix Version/s: 2.17.0 > Artifact retrieval fails with FlinkUberJarJobServer >

[jira] [Updated] (BEAM-8835) Artifact retrieval fails with FlinkUberJarJobServer

[ https://issues.apache.org/jira/browse/BEAM-8835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8835: - Status: Open (was: Triage Needed) > Artifact retrieval fails with FlinkUberJarJobServer

[jira] [Closed] (BEAM-8819) AvroCoder for SpecificRecords is not serialized correctly since 2.13.0

[ https://issues.apache.org/jira/browse/BEAM-8819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed BEAM-8819. Resolution: Fixed > AvroCoder for SpecificRecords is not serialized correctly since 2.13.0

[jira] [Resolved] (BEAM-8656) flink_master_url usage in flink_runner.py

[ https://issues.apache.org/jira/browse/BEAM-8656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-8656. -- Fix Version/s: Not applicable Resolution: Fixed > flink_master_url usage in

[jira] [Updated] (BEAM-8848) Flink: Memory efficient GBK implementation for batch runner

[ https://issues.apache.org/jira/browse/BEAM-8848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8848: - Status: Open (was: Triage Needed) > Flink: Memory efficient GBK implementation for batch

[jira] [Resolved] (BEAM-4776) Java PortableRunner should support metrics

[ https://issues.apache.org/jira/browse/BEAM-4776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-4776. -- Fix Version/s: 2.18.0 Resolution: Fixed > Java PortableRunner should support

[jira] [Commented] (BEAM-8521) beam_PostCommit_XVR_Flink failing

[ https://issues.apache.org/jira/browse/BEAM-8521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16966482#comment-16966482 ] Maximilian Michels commented on BEAM-8521: -- Yes, we had to learn it the hard way. Thanks Kyle,

[jira] [Created] (BEAM-8549) Buffered state during checkpointing may be keyed incorrectly

Maximilian Michels created BEAM-8549: Summary: Buffered state during checkpointing may be keyed incorrectly Key: BEAM-8549 URL: https://issues.apache.org/jira/browse/BEAM-8549 Project: Beam

[jira] [Commented] (BEAM-8512) Add integration tests for Python "flink_runner.py"

[ https://issues.apache.org/jira/browse/BEAM-8512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16980070#comment-16980070 ] Maximilian Michels commented on BEAM-8512: -- This can be used as the embedded testing cluster with

[jira] [Updated] (BEAM-8608) Chain DoFns in Flink batch runner when possible.

[ https://issues.apache.org/jira/browse/BEAM-8608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8608: - Status: Open (was: Triage Needed) > Chain DoFns in Flink batch runner when possible. >

<    3   4   5   6   7   8   9   10   11   >