[jira] [Assigned] (BEAM-5396) Flink portable runner savepoint / upgrade support

2018-12-27 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned BEAM-5396: Assignee: Maximilian Michels (was: Thomas Weise) > Flink portable runner savepoint

[jira] [Created] (BEAM-6315) CountingSource returns CheckpointMark with null date

2018-12-27 Thread Maximilian Michels (JIRA)
Maximilian Michels created BEAM-6315: Summary: CountingSource returns CheckpointMark with null date Key: BEAM-6315 URL: https://issues.apache.org/jira/browse/BEAM-6315 Project: Beam Issue

[jira] [Commented] (BEAM-6315) CountingSource returns CheckpointMark with null date

2018-12-27 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16729763#comment-16729763 ] Maximilian Michels commented on BEAM-6315: -- >From UnboundedSource: {quote}May n

[jira] [Updated] (BEAM-6315) CountingSource returns CheckpointMark with null date

2018-12-27 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-6315: - Component/s: runner-flink > CountingSource returns CheckpointMark with null date > ---

[jira] [Commented] (BEAM-5467) Python Flink ValidatesRunner job issues

2018-12-28 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16730318#comment-16730318 ] Maximilian Michels commented on BEAM-5467: -- Thanks for the build logs [~apilloud]

[jira] [Commented] (BEAM-6289) Running a join on two Cassandra tables using FlinkRunner fails

2018-12-28 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16730390#comment-16730390 ] Maximilian Michels commented on BEAM-6289: -- Thanks for the logs and for the great

[jira] [Commented] (BEAM-5467) Python Flink ValidatesRunner job issues

2018-12-28 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16730417#comment-16730417 ] Maximilian Michels commented on BEAM-5467: -- The culprit is now {{test_pardo_unfus

[jira] [Resolved] (BEAM-5936) [beam_PreCommit_Java_Cron] Flake due to flink.PortableStateExecutionTest

2018-12-28 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-5936. -- Resolution: Fixed Assignee: Maximilian Michels Fix Version/s: 2.10.0 I b

[jira] [Created] (BEAM-6326) Fix test failures in streaming mode of PortableValidatesRunner

2018-12-28 Thread Maximilian Michels (JIRA)
Maximilian Michels created BEAM-6326: Summary: Fix test failures in streaming mode of PortableValidatesRunner Key: BEAM-6326 URL: https://issues.apache.org/jira/browse/BEAM-6326 Project: Beam

[jira] [Commented] (BEAM-6289) Running a join on two Cassandra tables using FlinkRunner fails

2018-12-28 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16730441#comment-16730441 ] Maximilian Michels commented on BEAM-6289: -- {quote} The issue was first detected

[jira] [Created] (BEAM-6328) Provide environment option for JobServer container URL

2018-12-28 Thread Maximilian Michels (JIRA)
Maximilian Michels created BEAM-6328: Summary: Provide environment option for JobServer container URL Key: BEAM-6328 URL: https://issues.apache.org/jira/browse/BEAM-6328 Project: Beam Iss

[jira] [Resolved] (BEAM-6316) beam-sdks-python:portableWordCountBatch flaky: could not load docker image

2018-12-28 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-6316. -- Resolution: Fixed Fix Version/s: Not applicable Thanks for reporting this. > bea

[jira] [Created] (BEAM-6329) State for portable timers can interfere with user state

2018-12-29 Thread Maximilian Michels (JIRA)
Maximilian Michels created BEAM-6329: Summary: State for portable timers can interfere with user state Key: BEAM-6329 URL: https://issues.apache.org/jira/browse/BEAM-6329 Project: Beam Is

[jira] [Closed] (BEAM-6329) State for portable timers can interfere with user state

2018-12-29 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed BEAM-6329. Resolution: Fixed > State for portable timers can interfere with user state > --

[jira] [Resolved] (BEAM-5467) Python Flink ValidatesRunner job issues

2018-12-30 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-5467. -- Resolution: Fixed Fix Version/s: Not applicable Closing because tests are back to

[jira] [Resolved] (BEAM-5386) Flink Runner gets progressively stuck when Pubsub subscription is nearly empty

2018-12-30 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-5386. -- Resolution: Fixed Assignee: Maximilian Michels (was: Chamikara Jayalath)

[jira] [Closed] (BEAM-6294) Use Flink's redistribute for reshuffle.

2018-12-30 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed BEAM-6294. Resolution: Fixed Fix Version/s: 2.10.0 Closing because the issue is fixed in the lin

[jira] [Commented] (BEAM-593) Support unblocking run() in FlinkRunner and cancel() and waitUntilFinish() in FlinkRunnerResult

2019-01-03 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16733185#comment-16733185 ] Maximilian Michels commented on BEAM-593: - I'll have a look in the next days. Async

[jira] [Commented] (BEAM-5442) PortableRunner swallows custom options for Runner

2019-01-03 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16733237#comment-16733237 ] Maximilian Michels commented on BEAM-5442: -- As per mailing list discussion, not a

[jira] [Commented] (BEAM-6248) Add Flink 1.7.x build target to Flink Runner

2019-01-03 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16733281#comment-16733281 ] Maximilian Michels commented on BEAM-6248: -- I'd like to include this in the upcom

[jira] [Updated] (BEAM-6315) CountingSource returns CheckpointMark with null date

2019-01-03 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-6315: - Fix Version/s: (was: 2.10.0) > CountingSource returns CheckpointMark with null date >

[jira] [Commented] (BEAM-6315) CountingSource returns CheckpointMark with null date

2019-01-03 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16733681#comment-16733681 ] Maximilian Michels commented on BEAM-6315: -- [~kenn] Not resolved, but not severe

[jira] [Commented] (BEAM-6315) CountingSource returns CheckpointMark with null date

2019-01-03 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16733682#comment-16733682 ] Maximilian Michels commented on BEAM-6315: -- This needs to be fixed in the Unbound

[jira] [Commented] (BEAM-5467) Python Flink ValidatesRunner job issues

2019-01-03 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16733683#comment-16733683 ] Maximilian Michels commented on BEAM-5467: -- [~swegner] Already done in the last P

[jira] [Commented] (BEAM-6289) Running a join on two Cassandra tables using FlinkRunner fails

2019-01-03 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16733688#comment-16733688 ] Maximilian Michels commented on BEAM-6289: -- {quote} Is there any example of how t

[jira] [Resolved] (BEAM-6289) Running a join on two Cassandra tables using FlinkRunner fails

2019-01-03 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-6289. -- Resolution: Workaround Fix Version/s: Not applicable > Running a join on two Cass

[jira] [Commented] (BEAM-6009) PortableValidatesRunner runs only in batch mode

2019-01-07 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16735907#comment-16735907 ] Maximilian Michels commented on BEAM-6009: -- I'd keep this closed because this iss

[jira] [Assigned] (BEAM-6326) Fix test failures in streaming mode of PortableValidatesRunner

2019-01-07 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned BEAM-6326: Assignee: Maximilian Michels > Fix test failures in streaming mode of PortableValid

[jira] [Updated] (BEAM-6326) Fix test failures in streaming mode of PortableValidatesRunner

2019-01-07 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-6326: - Description: As of BEAM-6009, the tests are run separately for batch and streaming. This h

[jira] [Commented] (BEAM-5865) Auto sharding of streaming sinks in FlinkRunner

2019-01-08 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16737241#comment-16737241 ] Maximilian Michels commented on BEAM-5865: -- You're right that we need a shuffle/k

[jira] [Closed] (BEAM-6097) Add NemoRunner

2019-01-09 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed BEAM-6097. Resolution: Fixed Fix Version/s: 2.11.0 > Add NemoRunner > -- > >

[jira] [Commented] (BEAM-6294) Use Flink's redistribute for reshuffle.

2019-01-09 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16738354#comment-16738354 ] Maximilian Michels commented on BEAM-6294: -- [~thw] I think we should revert this

[jira] [Closed] (BEAM-6346) Portable Flink Job hangs if the sdk harness fails to start

2019-01-09 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed BEAM-6346. Resolution: Fixed Fix Version/s: 2.11.0 > Portable Flink Job hangs if the sdk harness

[jira] [Commented] (BEAM-6315) CountingSource returns CheckpointMark with null date

2019-01-09 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16738446#comment-16738446 ] Maximilian Michels commented on BEAM-6315: -- [~smarthi] Do you want to have a look

[jira] [Assigned] (BEAM-6315) CountingSource returns CheckpointMark with null date

2019-01-09 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned BEAM-6315: Assignee: (was: Maximilian Michels) > CountingSource returns CheckpointMark wit

[jira] [Updated] (BEAM-6315) UnboundedSourceWrapper checkpoints before starting Readers

2019-01-09 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-6315: - Summary: UnboundedSourceWrapper checkpoints before starting Readers (was: CountingSource

[jira] [Updated] (BEAM-6315) UnboundedSourceWrapper checkpoints before starting Readers

2019-01-09 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-6315: - Description: When start has not been called on the Readers of CountingSource, the checkpoi

[jira] [Commented] (BEAM-6315) UnboundedSourceWrapper checkpoints before starting Readers

2019-01-09 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16738449#comment-16738449 ] Maximilian Michels commented on BEAM-6315: -- Updated the description and title to

[jira] [Updated] (BEAM-6315) UnboundedSourceWrapper checkpoints before starting Readers

2019-01-09 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-6315: - Description: When start has not been called on the Readers of CountingSource, the checkpoi

[jira] [Updated] (BEAM-6315) UnboundedSourceWrapper checkpoints before starting Readers

2019-01-09 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-6315: - Description: When start has not been called on the Readers of CountingSource, the checkpoi

[jira] [Updated] (BEAM-6315) UnboundedSourceWrapper checkpoints before starting Readers

2019-01-09 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-6315: - Description: When start has not been called on the Readers of CountingSource, the checkpoi

[jira] [Created] (BEAM-6405) Improve PortableValidatesRunner test reliability on Jenkins

2019-01-10 Thread Maximilian Michels (JIRA)
Maximilian Michels created BEAM-6405: Summary: Improve PortableValidatesRunner test reliability on Jenkins Key: BEAM-6405 URL: https://issues.apache.org/jira/browse/BEAM-6405 Project: Beam

[jira] [Commented] (BEAM-6405) Improve PortableValidatesRunner test reliability on Jenkins

2019-01-10 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16739478#comment-16739478 ] Maximilian Michels commented on BEAM-6405: -- CC [~thw] > Improve PortableValidate

[jira] [Commented] (BEAM-68) Support for limiting parallelism of a step

2019-01-10 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-68?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16739539#comment-16739539 ] Maximilian Michels commented on BEAM-68: [~franz] I think we need to discuss the det

[jira] [Resolved] (BEAM-3494) Snapshot state of aggregated data of apache beam project is not maintained in flink's checkpointing

2019-01-10 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-3494. -- Resolution: Incomplete Fix Version/s: Not applicable This is missing important in

[jira] [Commented] (BEAM-4520) No messages delivered after a while with PubsubIO

2019-01-10 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16739581#comment-16739581 ] Maximilian Michels commented on BEAM-4520: -- I suppose this is more of a Runner pr

[jira] [Closed] (BEAM-6248) Add Flink 1.7.x build target to Flink Runner

2019-01-10 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed BEAM-6248. Resolution: Fixed Fix Version/s: 2.11.0 > Add Flink 1.7.x build target to Flink Runne

[jira] [Closed] (BEAM-6326) Fix test failures in streaming mode of PortableValidatesRunner

2019-01-10 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed BEAM-6326. Resolution: Fixed Fix Version/s: 2.11.0 2.10.0 > Fix test failures

[jira] [Commented] (BEAM-6289) Running a join on two Cassandra tables using FlinkRunner fails

2019-01-11 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16740646#comment-16740646 ] Maximilian Michels commented on BEAM-6289: -- [~srfrnk] Just mentioning you in case

[jira] [Commented] (BEAM-6418) beam_PreCommit_Java_Cron failing

2019-01-12 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16741334#comment-16741334 ] Maximilian Michels commented on BEAM-6418: -- Thanks for reporting this. Should be

[jira] [Commented] (BEAM-6418) beam_PreCommit_Java_Cron failing

2019-01-13 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16741720#comment-16741720 ] Maximilian Michels commented on BEAM-6418: -- The Jenkins test environment is very

[jira] [Resolved] (BEAM-6321) flinkCompatibilityMatrixBatchDOCKER out of memory

2019-01-14 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-6321. -- Resolution: Fixed Fix Version/s: Not applicable Should be fixed by https://github

[jira] [Closed] (BEAM-6234) [Flink Runner] Make failOnCheckpointingErrors setting available in FlinkPipelineOptions

2019-01-14 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed BEAM-6234. Resolution: Fixed Fix Version/s: (was: 2.8.0) 2.10.0 > [Flink

[jira] [Commented] (BEAM-4176) Java: Portable batch runner passes all ValidatesRunner tests that non-portable runner passes

2019-01-15 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16743166#comment-16743166 ] Maximilian Michels commented on BEAM-4176: -- Small update on this, these are the c

[jira] [Assigned] (BEAM-6435) beam_PostCommit_Java_PVR_Flink_Batch regularly failing

2019-01-15 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned BEAM-6435: Assignee: Maximilian Michels > beam_PostCommit_Java_PVR_Flink_Batch regularly faili

[jira] [Commented] (BEAM-6435) beam_PostCommit_Java_PVR_Flink_Batch regularly failing

2019-01-15 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16743181#comment-16743181 ] Maximilian Michels commented on BEAM-6435: -- This is the same symptom we were seei

[jira] [Commented] (BEAM-6440) FlinkTimerInternals memory leak

2019-01-15 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16743288#comment-16743288 ] Maximilian Michels commented on BEAM-6440: -- Thank you for the profiling. This was

[jira] [Resolved] (BEAM-6418) beam_PreCommit_Java_Cron failing

2019-01-15 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-6418. -- Resolution: Fixed Fix Version/s: Not applicable Looks like the issue is resolved.

[jira] [Closed] (BEAM-6439) Move Python Flink VR tests to PreCommit

2019-01-15 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed BEAM-6439. Resolution: Fixed Assignee: Robert Bradshaw (was: Jason Kuster) Fix Version/

[jira] [Commented] (BEAM-4176) Java: Portable batch runner passes all ValidatesRunner tests that non-portable runner passes

2019-01-15 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16743486#comment-16743486 ] Maximilian Michels commented on BEAM-4176: -- Awesome, thanks for the info. > J

[jira] [Closed] (BEAM-6440) FlinkTimerInternals memory leak

2019-01-16 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed BEAM-6440. Resolution: Fixed > FlinkTimerInternals memory leak > --- > >

[jira] [Commented] (BEAM-6440) FlinkTimerInternals memory leak

2019-01-16 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16744189#comment-16744189 ] Maximilian Michels commented on BEAM-6440: -- We should consider backporting this t

[jira] [Assigned] (BEAM-6230) Document Flink version support policy

2019-01-16 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned BEAM-6230: Assignee: Maximilian Michels > Document Flink version support policy >

[jira] [Commented] (BEAM-6405) Improve PortableValidatesRunner test reliability on Jenkins

2019-01-16 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16744608#comment-16744608 ] Maximilian Michels commented on BEAM-6405: -- Streaming execution looks very good:

[jira] [Created] (BEAM-6460) PipelineOptionsFactory may hold on to Classloader after pipeline restart

2019-01-17 Thread Maximilian Michels (JIRA)
Maximilian Michels created BEAM-6460: Summary: PipelineOptionsFactory may hold on to Classloader after pipeline restart Key: BEAM-6460 URL: https://issues.apache.org/jira/browse/BEAM-6460 Project:

[jira] [Updated] (BEAM-6465) Flink: State accumulation during restoring from a savepoint

2019-01-18 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-6465: - Issue Type: Bug (was: Test) > Flink: State accumulation during restoring from a savepoint

[jira] [Created] (BEAM-6469) Python ValidatesRunner tests fail due to missing module

2019-01-18 Thread Maximilian Michels (JIRA)
Maximilian Michels created BEAM-6469: Summary: Python ValidatesRunner tests fail due to missing module Key: BEAM-6469 URL: https://issues.apache.org/jira/browse/BEAM-6469 Project: Beam Is

[jira] [Updated] (BEAM-6460) Jackson Cache may hold on to Classloader after pipeline restart

2019-01-18 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-6460: - Summary: Jackson Cache may hold on to Classloader after pipeline restart (was: PipelineOp

[jira] [Commented] (BEAM-6469) Python Flink ValidatesRunner tests fail due to missing module

2019-01-18 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16746860#comment-16746860 ] Maximilian Michels commented on BEAM-6469: -- Thanks for investigating! > Python F

[jira] [Commented] (BEAM-6470) python tenacity is breaks the Python validates runner flink tests

2019-01-19 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16747142#comment-16747142 ] Maximilian Michels commented on BEAM-6470: -- This is a duplicate of BEAM-6469, but

[jira] [Closed] (BEAM-6469) Python Flink ValidatesRunner tests fail due to missing module

2019-01-19 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed BEAM-6469. Resolution: Fixed Thanks for the fix. Creating a new issue for the now visible failing test.

[jira] [Updated] (BEAM-6469) Python Flink ValidatesRunner tests fail due to missing module

2019-01-19 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-6469: - Fix Version/s: 2.11.0 > Python Flink ValidatesRunner tests fail due to missing module > --

[jira] [Commented] (BEAM-6469) Python Flink ValidatesRunner tests fail due to missing module

2019-01-19 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16747159#comment-16747159 ] Maximilian Michels commented on BEAM-6469: -- Also backported this to the {{release

[jira] [Commented] (BEAM-6465) Flink: State accumulation during restoring from a savepoint

2019-01-19 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16747168#comment-16747168 ] Maximilian Michels commented on BEAM-6465: -- Thank you for the detailed bug report

[jira] [Commented] (BEAM-6469) Python Flink ValidatesRunner tests fail due to missing module

2019-01-19 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16747170#comment-16747170 ] Maximilian Michels commented on BEAM-6469: -- Follow-up: https://issues.apache.org/

[jira] [Created] (BEAM-6473) Python Flink ValidatesRunner test_flattened_side_input fails

2019-01-19 Thread Maximilian Michels (JIRA)
Maximilian Michels created BEAM-6473: Summary: Python Flink ValidatesRunner test_flattened_side_input fails Key: BEAM-6473 URL: https://issues.apache.org/jira/browse/BEAM-6473 Project: Beam

[jira] [Resolved] (BEAM-5396) Flink portable runner savepoint / upgrade support

2019-01-20 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-5396. -- Resolution: Fixed Fix Version/s: 2.11.0 Resolving. The initial scope of this issu

[jira] [Updated] (BEAM-5396) Flink portable runner savepoint / upgrade support

2019-01-21 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-5396: - Fix Version/s: 2.10.0 > Flink portable runner savepoint / upgrade support > --

[jira] [Commented] (BEAM-6460) Jackson Cache may hold on to Classloader after pipeline restart

2019-01-21 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16748279#comment-16748279 ] Maximilian Michels commented on BEAM-6460: -- Update on this: Not a Beam issue. Fli

[jira] [Resolved] (BEAM-6460) Jackson Cache may hold on to Classloader after pipeline restart

2019-01-21 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-6460. -- Resolution: Workaround Fix Version/s: 2.11.0 > Jackson Cache may hold on to Class

[jira] [Commented] (BEAM-6470) python tenacity is breaks the Python validates runner flink tests

2019-01-22 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16749274#comment-16749274 ] Maximilian Michels commented on BEAM-6470: -- We can, though it doesn't seem to be

[jira] [Resolved] (BEAM-6405) Improve PortableValidatesRunner test reliability on Jenkins

2019-01-23 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-6405. -- Resolution: Fixed Fix Version/s: 2.11.0 > Improve PortableValidatesRunner test re

[jira] [Commented] (BEAM-6488) Portable Flink runner support for running cross-language transforms

2019-01-23 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16750507#comment-16750507 ] Maximilian Michels commented on BEAM-6488: -- Thanks for picking this up [~heejong]

[jira] [Updated] (BEAM-6473) Python Flink ValidatesRunner test_flattened_side_input fails

2019-01-23 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-6473: - Priority: Major (was: Critical) > Python Flink ValidatesRunner test_flattened_side_input

[jira] [Commented] (BEAM-6473) Python Flink ValidatesRunner test_flattened_side_input fails

2019-01-23 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16750702#comment-16750702 ] Maximilian Michels commented on BEAM-6473: -- This looks like an issue with the Pyt

[jira] [Assigned] (BEAM-6473) Python Flink ValidatesRunner test_flattened_side_input fails

2019-01-24 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned BEAM-6473: Assignee: Maximilian Michels > Python Flink ValidatesRunner test_flattened_side_inp

[jira] [Created] (BEAM-6523) Support transcoding for Flatten in Flink Runner

2019-01-28 Thread Maximilian Michels (JIRA)
Maximilian Michels created BEAM-6523: Summary: Support transcoding for Flatten in Flink Runner Key: BEAM-6523 URL: https://issues.apache.org/jira/browse/BEAM-6523 Project: Beam Issue Type

[jira] [Created] (BEAM-6533) UnboundedSourceWrapper

2019-01-29 Thread Maximilian Michels (JIRA)
Maximilian Michels created BEAM-6533: Summary: UnboundedSourceWrapper Key: BEAM-6533 URL: https://issues.apache.org/jira/browse/BEAM-6533 Project: Beam Issue Type: Improvement

[jira] [Updated] (BEAM-6533) UnboundedSourceWrapper source log output should not be zero-based

2019-01-29 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-6533: - Summary: UnboundedSourceWrapper source log output should not be zero-based (was: Unbounde

[jira] [Commented] (BEAM-6510) [beam_PostCommit_Java_Nexmark_Flink] Consistently timing out

2019-01-29 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16754825#comment-16754825 ] Maximilian Michels commented on BEAM-6510: -- {quote} I do notice that the lines 18

[jira] [Closed] (BEAM-6518) Substring-matching bug in Python metrics filtering

2019-01-29 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed BEAM-6518. Resolution: Fixed Fix Version/s: 2.11.0 > Substring-matching bug in Python metrics fi

[jira] [Updated] (BEAM-6510) [beam_PostCommit_Java_Nexmark_Flink] Consistently timing out

2019-01-29 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-6510: - Labels: SQL (was: SQL currently-failing) > [beam_PostCommit_Java_Nexmark_Flink] Consisten

[jira] [Closed] (BEAM-6510) [beam_PostCommit_Java_Nexmark_Flink] Consistently timing out

2019-01-29 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed BEAM-6510. Resolution: Fixed Fix Version/s: 2.11.0 > [beam_PostCommit_Java_Nexmark_Flink] Consis

[jira] [Closed] (BEAM-6533) UnboundedSourceWrapper source log output should not be zero-based

2019-01-29 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed BEAM-6533. Resolution: Fixed Fixed with {{beb7abf09dc80406848dfc81e242ec25b7e6780e}}. > UnboundedSourc

[jira] [Updated] (BEAM-6510) [beam_PostCommit_Java_Nexmark_Flink] Consistently timing out

2019-01-29 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-6510: - Affects Version/s: 2.11.0 2.10.0 > [beam_PostCommit_Java_Nexmark_Fl

[jira] [Commented] (BEAM-6543) Multiple PostCommit_Java_ValidatesRunner_Flink tests are failing due to AssertionError

2019-01-30 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16755968#comment-16755968 ] Maximilian Michels commented on BEAM-6543: -- Thank you for reporting [~chamikara].

[jira] [Commented] (BEAM-5442) PortableRunner swallows custom options for Runner

2019-01-30 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16755967#comment-16755967 ] Maximilian Michels commented on BEAM-5442: -- This is great. Thank you for the foll

[jira] [Created] (BEAM-6549) Make use of DescribePipelineOptionsRequest in Go SDK

2019-01-30 Thread Maximilian Michels (JIRA)
Maximilian Michels created BEAM-6549: Summary: Make use of DescribePipelineOptionsRequest in Go SDK Key: BEAM-6549 URL: https://issues.apache.org/jira/browse/BEAM-6549 Project: Beam Issue

[jira] [Closed] (BEAM-6543) Multiple PostCommit_Java_ValidatesRunner_Flink tests are failing due to AssertionError

2019-01-30 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed BEAM-6543. Resolution: Fixed Fix Version/s: Not applicable > Multiple PostCommit_Java_ValidatesR

[jira] [Updated] (BEAM-5386) Flink Runner gets progressively stuck when Pubsub subscription is nearly empty

2019-01-30 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-5386: - Affects Version/s: 2.7.0 2.8.0 2.9.0 > Flink

<    3   4   5   6   7   8   9   10   11   12   >