[jira] [Commented] (FLINK-16573) Kinesis consumer does not properly shutdown RecordFetcher threads

[ https://issues.apache.org/jira/browse/FLINK-16573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060149#comment-17060149 ] Maximilian Michels commented on FLINK-16573: Backported also to {{release-1.

[jira] [Closed] (FLINK-16573) Kinesis consumer does not properly shutdown RecordFetcher threads

[ https://issues.apache.org/jira/browse/FLINK-16573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-16573. -- Fix Version/s: 1.10.1 1.9.3 Resolution: Fixed > Kinesis cons

[jira] [Comment Edited] (FLINK-16573) Kinesis consumer does not properly shutdown RecordFetcher threads

[ https://issues.apache.org/jira/browse/FLINK-16573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17057889#comment-17057889 ] Maximilian Michels edited comment on FLINK-16573 at 3/12/20, 3:44 PM:

[jira] [Commented] (FLINK-16510) Task manager safeguard shutdown may not be reliable

[ https://issues.apache.org/jira/browse/FLINK-16510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17058026#comment-17058026 ] Maximilian Michels commented on FLINK-16510: I'm constrained by what Lyft's

[jira] [Commented] (FLINK-16573) Kinesis consumer does not properly shutdown RecordFetcher threads

[ https://issues.apache.org/jira/browse/FLINK-16573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17057889#comment-17057889 ] Maximilian Michels commented on FLINK-16573: Should add that this eventually

[jira] [Commented] (FLINK-16510) Task manager safeguard shutdown may not be reliable

[ https://issues.apache.org/jira/browse/FLINK-16510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17057885#comment-17057885 ] Maximilian Michels commented on FLINK-16510: We haven't seen this particular

[jira] [Created] (FLINK-16573) Kinesis consumer does not properly shutdown RecordFetcher threads

Maximilian Michels created FLINK-16573: -- Summary: Kinesis consumer does not properly shutdown RecordFetcher threads Key: FLINK-16573 URL: https://issues.apache.org/jira/browse/FLINK-16573 Project

[jira] [Commented] (FLINK-16511) Task cancellation timeout is not effective on OOM errors

[ https://issues.apache.org/jira/browse/FLINK-16511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17056181#comment-17056181 ] Maximilian Michels commented on FLINK-16511: Awesome. Thanks for pointing me

[jira] [Commented] (FLINK-16510) Task manager safeguard shutdown may not be reliable

[ https://issues.apache.org/jira/browse/FLINK-16510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17055832#comment-17055832 ] Maximilian Michels commented on FLINK-16510: Yes, indeed no deadlock. The th

[jira] [Assigned] (FLINK-16510) Task manager safeguard shutdown may not be reliable

[ https://issues.apache.org/jira/browse/FLINK-16510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-16510: -- Assignee: Maximilian Michels > Task manager safeguard shutdown may not be rel

[jira] [Assigned] (FLINK-16511) Task cancellation timeout is not effective on OOM errors

[ https://issues.apache.org/jira/browse/FLINK-16511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-16511: -- Assignee: Maximilian Michels > Task cancellation timeout is not effective on

[jira] [Created] (FLINK-16511) Task cancellation timeout is not effective on OOM errors

Maximilian Michels created FLINK-16511: -- Summary: Task cancellation timeout is not effective on OOM errors Key: FLINK-16511 URL: https://issues.apache.org/jira/browse/FLINK-16511 Project: Flink

[jira] [Created] (FLINK-16510) Task manager safeguard shutdown may not be reliable

Maximilian Michels created FLINK-16510: -- Summary: Task manager safeguard shutdown may not be reliable Key: FLINK-16510 URL: https://issues.apache.org/jira/browse/FLINK-16510 Project: Flink

[jira] [Commented] (FLINK-10850) Job may hang on FAILING state if taskmanager updateTaskExecutionState failed

[ https://issues.apache.org/jira/browse/FLINK-10850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17053971#comment-17053971 ] Maximilian Michels commented on FLINK-10850: Just to update this here, if th

[jira] [Commented] (FLINK-10850) Job may hang on FAILING state if taskmanager updateTaskExecutionState failed

[ https://issues.apache.org/jira/browse/FLINK-10850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17051259#comment-17051259 ] Maximilian Michels commented on FLINK-10850: [~trohrmann] We're seeing this

[jira] [Updated] (FLINK-10850) Job may hang on FAILING state if taskmanager updateTaskExecutionState failed

[ https://issues.apache.org/jira/browse/FLINK-10850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-10850: --- Description: I encountered a job which is oom but hung on FAILING state. It left 3 s

[jira] [Assigned] (FLINK-16260) Add docker images based on Java 11

[ https://issues.apache.org/jira/browse/FLINK-16260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-16260: -- Assignee: Ismaël Mejía > Add docker images based on Java 11 > ---

[jira] [Commented] (FLINK-15504) Flink suppresses stdout/stderr during JobGraph generation from JAR

[ https://issues.apache.org/jira/browse/FLINK-15504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17025701#comment-17025701 ] Maximilian Michels commented on FLINK-15504: I think it is worth including a

[jira] [Commented] (FLINK-15504) Flink suppresses stdout/stderr during JobGraph generation from JAR

[ https://issues.apache.org/jira/browse/FLINK-15504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17020268#comment-17020268 ] Maximilian Michels commented on FLINK-15504: I think it is not a bad idea to

[jira] [Updated] (FLINK-15253) Accumulators are not checkpointed

[ https://issues.apache.org/jira/browse/FLINK-15253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-15253: --- Component/s: Runtime / Checkpointing > Accumulators are not checkpointed > -

[jira] [Commented] (FLINK-15504) Flink suppresses stdout/stderr during JobGraph generation from JAR

[ https://issues.apache.org/jira/browse/FLINK-15504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17013491#comment-17013491 ] Maximilian Michels commented on FLINK-15504: master: 4bb4a50c4ed6c909dc98788

[jira] [Updated] (FLINK-15504) Flink suppresses stdout/stderr during JobGraph generation from JAR

[ https://issues.apache.org/jira/browse/FLINK-15504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-15504: --- Fix Version/s: (was: 1.11.0) > Flink suppresses stdout/stderr during JobGraph ge

[jira] [Updated] (FLINK-15504) Flink suppresses stdout/stderr during JobGraph generation from JAR

[ https://issues.apache.org/jira/browse/FLINK-15504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-15504: --- Fix Version/s: 1.10.0 > Flink suppresses stdout/stderr during JobGraph generation fr

[jira] [Commented] (FLINK-15504) Flink suppresses stdout/stderr during JobGraph generation from JAR

[ https://issues.apache.org/jira/browse/FLINK-15504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17013068#comment-17013068 ] Maximilian Michels commented on FLINK-15504: Backporting this also to {{rele

[jira] [Updated] (FLINK-15504) Flink suppresses stdout/stderr during JobGraph generation from JAR

[ https://issues.apache.org/jira/browse/FLINK-15504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-15504: --- Fix Version/s: (was: 1.10.0) 1.11.0 > Flink suppresses stdout

[jira] [Closed] (FLINK-15504) Flink suppresses stdout/stderr during JobGraph generation from JAR

[ https://issues.apache.org/jira/browse/FLINK-15504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-15504. -- Fix Version/s: 1.10.0 Release Note: Allow outputting to stdout/stderr during JobGr

[jira] [Updated] (FLINK-15504) Flink suppresses stdout/stderr during JobGraph generation from JAR

[ https://issues.apache.org/jira/browse/FLINK-15504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-15504: --- Description: Flink uses the org.apache.flink.client.program.OptimizerPlanEnvironment

[jira] [Updated] (FLINK-15504) Flink suppresses stdout/stderr during JobGraph generation from JAR

[ https://issues.apache.org/jira/browse/FLINK-15504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-15504: --- Description: Flink uses the {{OptimizerPlanEnvironment}} which replaces stdout/stder

[jira] [Created] (FLINK-15504) Flink suppresses stdout/stderr during JobGraph generation from JAR

Maximilian Michels created FLINK-15504: -- Summary: Flink suppresses stdout/stderr during JobGraph generation from JAR Key: FLINK-15504 URL: https://issues.apache.org/jira/browse/FLINK-15504 Projec

[jira] [Commented] (FLINK-15253) Accumulators are not checkpointed

[ https://issues.apache.org/jira/browse/FLINK-15253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17008805#comment-17008805 ] Maximilian Michels commented on FLINK-15253: It is fine with me to make them

[jira] [Commented] (FLINK-14653) Job-related errors in snapshotState do not result in job failure

[ https://issues.apache.org/jira/browse/FLINK-14653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16996296#comment-16996296 ] Maximilian Michels commented on FLINK-14653: Good suggestion. Treating excep

[jira] [Created] (FLINK-15253) Accumulators are not checkpointed

Maximilian Michels created FLINK-15253: -- Summary: Accumulators are not checkpointed Key: FLINK-15253 URL: https://issues.apache.org/jira/browse/FLINK-15253 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-15252) Heartbeat with large accumulator payload may cause instable clusters

Maximilian Michels created FLINK-15252: -- Summary: Heartbeat with large accumulator payload may cause instable clusters Key: FLINK-15252 URL: https://issues.apache.org/jira/browse/FLINK-15252 Proj

[jira] [Closed] (FLINK-14470) Watermark display not working with high parallelism job

[ https://issues.apache.org/jira/browse/FLINK-14470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-14470. -- Fix Version/s: 1.10.0 Resolution: Duplicate > Watermark display not working wit

[jira] [Resolved] (FLINK-8949) Rest API failure with long URL

[ https://issues.apache.org/jira/browse/FLINK-8949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-8949. --- Fix Version/s: 1.10.0 Release Note: Watermarks for tasks with a high parallelism

[jira] [Commented] (FLINK-14653) Job-related errors in snapshotState do not result in job failure

[ https://issues.apache.org/jira/browse/FLINK-14653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16982685#comment-16982685 ] Maximilian Michels commented on FLINK-14653: I'm not sure this will work bec

[jira] [Commented] (FLINK-8949) Rest API failure with long URL

[ https://issues.apache.org/jira/browse/FLINK-8949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16978634#comment-16978634 ] Maximilian Michels commented on FLINK-8949: --- I've updated the PR to add the new

[jira] [Commented] (FLINK-8949) Rest API failure with long URL

[ https://issues.apache.org/jira/browse/FLINK-8949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16978388#comment-16978388 ] Maximilian Michels commented on FLINK-8949: --- Just saw the discussion here. We a

[jira] [Assigned] (FLINK-8949) Rest API failure with long URL

[ https://issues.apache.org/jira/browse/FLINK-8949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-8949: - Assignee: Maximilian Michels > Rest API failure with long URL >

[jira] [Commented] (FLINK-8949) Rest API failure with long URL

[ https://issues.apache.org/jira/browse/FLINK-8949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16976595#comment-16976595 ] Maximilian Michels commented on FLINK-8949: --- Also just debugged this. Running i

[jira] [Updated] (FLINK-8949) Rest API failure with long URL

[ https://issues.apache.org/jira/browse/FLINK-8949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-8949: -- Affects Version/s: 1.7.2 > Rest API failure with long URL > ---

[jira] [Updated] (FLINK-8949) Rest API failure with long URL

[ https://issues.apache.org/jira/browse/FLINK-8949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-8949: -- Affects Version/s: 1.8.2 > Rest API failure with long URL > ---

[jira] [Updated] (FLINK-8949) Rest API failure with long URL

[ https://issues.apache.org/jira/browse/FLINK-8949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-8949: -- Affects Version/s: 1.6.4 > Rest API failure with long URL > ---

[jira] [Commented] (FLINK-14653) Job-related errors in snapshotState do not result in job failure

[ https://issues.apache.org/jira/browse/FLINK-14653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16970003#comment-16970003 ] Maximilian Michels commented on FLINK-14653: Imagine I have set my Flink job

[jira] [Comment Edited] (FLINK-14653) Job-related errors in snapshotState do not result in job failure

[ https://issues.apache.org/jira/browse/FLINK-14653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16969962#comment-16969962 ] Maximilian Michels edited comment on FLINK-14653 at 11/8/19 9:16 AM: -

[jira] [Comment Edited] (FLINK-14653) Job-related errors in snapshotState do not result in job failure

[ https://issues.apache.org/jira/browse/FLINK-14653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16969962#comment-16969962 ] Maximilian Michels edited comment on FLINK-14653 at 11/8/19 9:15 AM: -

[jira] [Commented] (FLINK-14653) Job-related errors in snapshotState do not result in job failure

[ https://issues.apache.org/jira/browse/FLINK-14653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16969962#comment-16969962 ] Maximilian Michels commented on FLINK-14653: I'm aware of that. However, the

[jira] [Commented] (FLINK-14653) Job-related errors in snapshotState do not result in job failure

[ https://issues.apache.org/jira/browse/FLINK-14653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16969180#comment-16969180 ] Maximilian Michels commented on FLINK-14653: We might still want to differen

[jira] [Created] (FLINK-14653) Job-related errors in snapshotState do not result in job failure

Maximilian Michels created FLINK-14653: -- Summary: Job-related errors in snapshotState do not result in job failure Key: FLINK-14653 URL: https://issues.apache.org/jira/browse/FLINK-14653 Project:

[jira] [Commented] (FLINK-10317) Configure Metaspace size by default

[ https://issues.apache.org/jira/browse/FLINK-10317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16959971#comment-16959971 ] Maximilian Michels commented on FLINK-10317: {{MaxmetaspaceSize}} has someth

[jira] [Commented] (FLINK-10672) Task stuck while writing output to flink

[ https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16941796#comment-16941796 ] Maximilian Michels commented on FLINK-10672: [~angoenka] Do you think you co

[jira] [Commented] (FLINK-10672) Task stuck while writing output to flink

[ https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16939220#comment-16939220 ] Maximilian Michels commented on FLINK-10672: Yes, it is one possible explana

[jira] [Commented] (FLINK-14168) Remove unused BootstrapTools#generateTaskManagerConfiguration

[ https://issues.apache.org/jira/browse/FLINK-14168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936655#comment-16936655 ] Maximilian Michels commented on FLINK-14168: The code was indeed not used at

[jira] [Commented] (FLINK-12653) Keyed state backend fails to restore during rescaling

[ https://issues.apache.org/jira/browse/FLINK-12653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16921366#comment-16921366 ] Maximilian Michels commented on FLINK-12653: Thanks [~tzulitai]! > Keyed st

[jira] [Resolved] (FLINK-13794) Remove unused field printStatusDuringExecution in ClusterClient

[ https://issues.apache.org/jira/browse/FLINK-13794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-13794. Resolution: Fixed > Remove unused field printStatusDuringExecution in ClusterClien

[jira] [Commented] (FLINK-13794) Remove unused field printStatusDuringExecution in ClusterClient

[ https://issues.apache.org/jira/browse/FLINK-13794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16912020#comment-16912020 ] Maximilian Michels commented on FLINK-13794: Sure [~Tison]. Here you go. >

[jira] [Assigned] (FLINK-13794) Remove unused field printStatusDuringExecution in ClusterClient

[ https://issues.apache.org/jira/browse/FLINK-13794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-13794: -- Assignee: TisonKun > Remove unused field printStatusDuringExecution in Cluste

[jira] [Commented] (FLINK-10672) Task stuck while writing output to flink

[ https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16897101#comment-16897101 ] Maximilian Michels commented on FLINK-10672: [~zjwang] From the testing that

[jira] [Resolved] (FLINK-13367) Make ClosureCleaner detect writeReplace serialization override

[ https://issues.apache.org/jira/browse/FLINK-13367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-13367. Resolution: Fixed Assignee: David Moravek Fix Version/s: 1.9.0

[jira] [Commented] (FLINK-12653) Keyed state backend fails to restore during rescaling

[ https://issues.apache.org/jira/browse/FLINK-12653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16878533#comment-16878533 ] Maximilian Michels commented on FLINK-12653: Thanks for taking a look [~tzul

[jira] [Assigned] (FLINK-12653) Keyed state backend fails to restore during rescaling

[ https://issues.apache.org/jira/browse/FLINK-12653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-12653: -- Assignee: (was: Maximilian Michels) > Keyed state backend fails to restor

[jira] [Commented] (FLINK-12653) Keyed state backend fails to restore during rescaling

[ https://issues.apache.org/jira/browse/FLINK-12653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16864652#comment-16864652 ] Maximilian Michels commented on FLINK-12653: We have worked around this issu

[jira] [Commented] (FLINK-12653) Keyed state backend fails to restore during rescaling

[ https://issues.apache.org/jira/browse/FLINK-12653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16862787#comment-16862787 ] Maximilian Michels commented on FLINK-12653: After a decent amount of debugg

[jira] [Assigned] (FLINK-12653) Keyed state backend fails to restore during rescaling

[ https://issues.apache.org/jira/browse/FLINK-12653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-12653: -- Assignee: Maximilian Michels > Keyed state backend fails to restore during re

[jira] [Commented] (FLINK-12653) Keyed state backend fails to restore during rescaling

[ https://issues.apache.org/jira/browse/FLINK-12653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16861958#comment-16861958 ] Maximilian Michels commented on FLINK-12653: On the other hand, if state wri

[jira] [Commented] (FLINK-12653) Keyed state backend fails to restore during rescaling

[ https://issues.apache.org/jira/browse/FLINK-12653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16861950#comment-16861950 ] Maximilian Michels commented on FLINK-12653: Some more context, this does no

[jira] [Commented] (FLINK-12653) Keyed state backend fails to restore during rescaling

[ https://issues.apache.org/jira/browse/FLINK-12653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849943#comment-16849943 ] Maximilian Michels commented on FLINK-12653: Some more information, these ar

[jira] [Comment Edited] (FLINK-12653) Keyed state backend fails to restore during rescaling

[ https://issues.apache.org/jira/browse/FLINK-12653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849943#comment-16849943 ] Maximilian Michels edited comment on FLINK-12653 at 5/28/19 5:15 PM: -

[jira] [Updated] (FLINK-12653) Keyed state backend fails to restore during rescaling

[ https://issues.apache.org/jira/browse/FLINK-12653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-12653: --- Environment: Beam 2.12.0 or any other Beam version Flink >= 1.6 Heap/Filesystem stat

[jira] [Updated] (FLINK-12653) Keyed state backend fails to restore during rescaling

[ https://issues.apache.org/jira/browse/FLINK-12653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-12653: --- Environment: Beam 2.12.0 or any other Beam version Flink >= 1.6 Filesystem state bac

[jira] [Commented] (FLINK-12653) Keyed state backend fails to restore during rescaling

[ https://issues.apache.org/jira/browse/FLINK-12653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849917#comment-16849917 ] Maximilian Michels commented on FLINK-12653: The above stack trace was with

[jira] [Created] (FLINK-12653) Keyed state backend fails to restore during rescaling

Maximilian Michels created FLINK-12653: -- Summary: Keyed state backend fails to restore during rescaling Key: FLINK-12653 URL: https://issues.apache.org/jira/browse/FLINK-12653 Project: Flink

[jira] [Commented] (FLINK-12101) Race condition when concurrently running uploaded jars via REST

[ https://issues.apache.org/jira/browse/FLINK-12101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812467#comment-16812467 ] Maximilian Michels commented on FLINK-12101: Thanks for taking the time to l

[jira] [Commented] (FLINK-3273) Remove Scala dependency from flink-streaming-java

[ https://issues.apache.org/jira/browse/FLINK-3273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16809634#comment-16809634 ] Maximilian Michels commented on FLINK-3273: --- The idea was to have a Scala-free

[jira] [Updated] (FLINK-12101) Race condition when concurrently running uploaded jars via REST

[ https://issues.apache.org/jira/browse/FLINK-12101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-12101: --- Summary: Race condition when concurrently running uploaded jars via REST (was: Race

[jira] [Created] (FLINK-12101) Race condition when concurrenty running uploaded jars via REST

Maximilian Michels created FLINK-12101: -- Summary: Race condition when concurrenty running uploaded jars via REST Key: FLINK-12101 URL: https://issues.apache.org/jira/browse/FLINK-12101 Project: F

[jira] [Assigned] (FLINK-2491) Checkpointing only works if all operators/tasks are still running

[ https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-2491: - Assignee: (was: Márton Balassi) > Checkpointing only works if all operators/

[jira] [Commented] (FLINK-2491) Checkpointing only works if all operators/tasks are still running

[ https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16792126#comment-16792126 ] Maximilian Michels commented on FLINK-2491: --- I think we should take the time to

[jira] [Created] (FLINK-11373) CliFrontend cuts off reason for error messages

Maximilian Michels created FLINK-11373: -- Summary: CliFrontend cuts off reason for error messages Key: FLINK-11373 URL: https://issues.apache.org/jira/browse/FLINK-11373 Project: Flink Is

[jira] [Commented] (FLINK-10672) Task stuck while writing output to flink

[ https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16724901#comment-16724901 ] Maximilian Michels commented on FLINK-10672: No, [~thw] just set the Fix Ver

[jira] [Commented] (FLINK-11168) LargePlanTest times out on Travis

[ https://issues.apache.org/jira/browse/FLINK-11168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16722910#comment-16722910 ] Maximilian Michels commented on FLINK-11168: It seems a bit odd but I suppos

[jira] [Commented] (FLINK-11146) Get rid of legacy codes from ClusterClient

[ https://issues.apache.org/jira/browse/FLINK-11146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16722894#comment-16722894 ] Maximilian Michels commented on FLINK-11146: I agree that the client classes

[jira] [Commented] (FLINK-11168) LargePlanTest times out on Travis

[ https://issues.apache.org/jira/browse/FLINK-11168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16722146#comment-16722146 ] Maximilian Michels commented on FLINK-11168: How slow is Travis? On my machi

[jira] [Assigned] (FLINK-11168) LargePlanTest times out on Travis

[ https://issues.apache.org/jira/browse/FLINK-11168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-11168: -- Assignee: Maximilian Michels > LargePlanTest times out on Travis > --

[jira] [Commented] (FLINK-11168) LargePlanTest times out on Travis

[ https://issues.apache.org/jira/browse/FLINK-11168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16722142#comment-16722142 ] Maximilian Michels commented on FLINK-11168: Thanks for reporting. I'll look

[jira] [Updated] (FLINK-10566) Flink Planning is exponential in the number of stages

[ https://issues.apache.org/jira/browse/FLINK-10566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-10566: --- Affects Version/s: 1.8.0 > Flink Planning is exponential in the number of stages > -

[jira] [Resolved] (FLINK-10566) Flink Planning is exponential in the number of stages

[ https://issues.apache.org/jira/browse/FLINK-10566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-10566. Resolution: Fixed Fix Version/s: 1.8.0 1.7.1

[jira] [Assigned] (FLINK-10566) Flink Planning is exponential in the number of stages

[ https://issues.apache.org/jira/browse/FLINK-10566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-10566: -- Assignee: Maximilian Michels > Flink Planning is exponential in the number of

[jira] [Commented] (FLINK-10566) Flink Planning is exponential in the number of stages

[ https://issues.apache.org/jira/browse/FLINK-10566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16716864#comment-16716864 ] Maximilian Michels commented on FLINK-10566: Indeed. It seems to be the Kryo

[jira] [Commented] (FLINK-10566) Flink Planning is exponential in the number of stages

[ https://issues.apache.org/jira/browse/FLINK-10566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16714970#comment-16714970 ] Maximilian Michels commented on FLINK-10566: Thanks for the explanation [~fh

[jira] [Commented] (FLINK-10860) java.lang.ArrayIndexOutOfBoundsException Error reading state

[ https://issues.apache.org/jira/browse/FLINK-10860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16693274#comment-16693274 ] Maximilian Michels commented on FLINK-10860: It does not look like it's rela

[jira] [Commented] (FLINK-10732) force-shading 1.5.5 maven artifact was not released

[ https://issues.apache.org/jira/browse/FLINK-10732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16674878#comment-16674878 ] Maximilian Michels commented on FLINK-10732: Thanks! > force-shading 1.5.5

[jira] [Commented] (FLINK-10732) force-shading 1.5.5 maven artifact was not released

[ https://issues.apache.org/jira/browse/FLINK-10732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16673474#comment-16673474 ] Maximilian Michels commented on FLINK-10732: Possibles fixes: 1) Release a

[jira] [Updated] (FLINK-10672) Task stuck while writing output to flink

[ https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-10672: --- Labels: beam (was: ) > Task stuck while writing output to flink > -

[jira] [Updated] (FLINK-10672) Task stuck while writing output to flink

[ https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-10672: --- Fix Version/s: 1.5.6 > Task stuck while writing output to flink > --

[jira] [Commented] (FLINK-10672) Task stuck while writing output to flink

[ https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16671319#comment-16671319 ] Maximilian Michels commented on FLINK-10672: Thanks for investigating the ma

[jira] [Commented] (FLINK-10732) force-shading 1.5.5 maven artifact was not released

[ https://issues.apache.org/jira/browse/FLINK-10732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16669852#comment-16669852 ] Maximilian Michels commented on FLINK-10732: I've also ran into this and wor

[jira] [Commented] (FLINK-10566) Flink Planning is exponential in the number of stages

[ https://issues.apache.org/jira/browse/FLINK-10566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16655683#comment-16655683 ] Maximilian Michels commented on FLINK-10566: Just to clarify, this happens d

[jira] [Commented] (FLINK-10566) Flink Planning is exponential in the number of stages

[ https://issues.apache.org/jira/browse/FLINK-10566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16655681#comment-16655681 ] Maximilian Michels commented on FLINK-10566: Here's a thread dump: {noform

[jira] [Resolved] (FLINK-10279) Make jython limitations more obvious in documentation

[ https://issues.apache.org/jira/browse/FLINK-10279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-10279. Resolution: Fixed Fixed via 982fa402a0a9c65356c5e89b25569ed7a8ca89a5 > Make jytho

<    1   2   3   4   5   6   7   8   9   10   >