Stefan Richter created FLINK-4492:
-
Summary: Cleanup files from canceled snapshots
Key: FLINK-4492
URL: https://issues.apache.org/jira/browse/FLINK-4492
Project: Flink
Issue Type: Bug
Stefan Richter created FLINK-4493:
-
Summary: Unify the snapshot output format for keyed-state backends
Key: FLINK-4493
URL: https://issues.apache.org/jira/browse/FLINK-4493
Project: Flink
Iss
Stefan Richter created FLINK-4508:
-
Summary: Consolidate DummyEnvironment and MockEnvironment for Tests
Key: FLINK-4508
URL: https://issues.apache.org/jira/browse/FLINK-4508
Project: Flink
Is
[
https://issues.apache.org/jira/browse/FLINK-4556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter reassigned FLINK-4556:
-
Assignee: Stefan Richter
> Make Queryable State Key-Group Aware
> ---
[
https://issues.apache.org/jira/browse/FLINK-4603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15512553#comment-15512553
]
Stefan Richter commented on FLINK-4603:
---
Currently, we should still keep the UserCod
[
https://issues.apache.org/jira/browse/FLINK-5985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904895#comment-15904895
]
Stefan Richter commented on FLINK-5985:
---
I think the proper solution is based on pre
[
https://issues.apache.org/jira/browse/FLINK-6044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter reassigned FLINK-6044:
-
Assignee: Stefan Richter
> TypeSerializerSerializationProxy.read() doesn't verify the rea
[
https://issues.apache.org/jira/browse/FLINK-6044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15924201#comment-15924201
]
Stefan Richter commented on FLINK-6044:
---
Thanks for reporting this. The {{read(...)}
Stefan Richter created FLINK-6048:
-
Summary: Asynchronous snapshots for heap-based operator state
backends
Key: FLINK-6048
URL: https://issues.apache.org/jira/browse/FLINK-6048
Project: Flink
Stefan Richter created FLINK-6049:
-
Summary: Parallelize execution of (async) snapshots in
AsyncCheckpointRunnable
Key: FLINK-6049
URL: https://issues.apache.org/jira/browse/FLINK-6049
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-6061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925929#comment-15925929
]
Stefan Richter commented on FLINK-6061:
---
Thanks for reporting this. I agree that the
[
https://issues.apache.org/jira/browse/FLINK-6061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter reassigned FLINK-6061:
-
Assignee: Stefan Richter
> NPE on TypeSerializer.serialize with a RocksDBStateBackend cal
[
https://issues.apache.org/jira/browse/FLINK-6061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925929#comment-15925929
]
Stefan Richter edited comment on FLINK-6061 at 3/15/17 11:19 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-6061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15926192#comment-15926192
]
Stefan Richter commented on FLINK-6061:
---
[~vpernin] afaik, there is not yet a native
[
https://issues.apache.org/jira/browse/FLINK-6061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-6061.
-
Resolution: Fixed
Fix Version/s: 1.3.0
Fixed in 0bdc8bf (master)
> NPE on TypeSerializer.s
[
https://issues.apache.org/jira/browse/FLINK-6044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-6044.
-
Resolution: Fixed
Fix Version/s: 1.3.0
Fixed in cbaf4e5 (master)
> TypeSerializerSerializa
[
https://issues.apache.org/jira/browse/FLINK-5979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-5979.
-
Resolution: Fixed
fixed in ab014ef
> Backwards compatibility for HeapKeyedStateBackend serializat
[
https://issues.apache.org/jira/browse/FLINK-5715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-5715.
-
Resolution: Fixed
Fix Version/s: 1.3.0
fixed in ab014ef
> Asynchronous snapshotting for He
[
https://issues.apache.org/jira/browse/FLINK-5985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-5985.
-
Resolution: Fixed
Fix Version/s: 1.2.1
1.3.0
fixed in 20fff32.
> Flink
[
https://issues.apache.org/jira/browse/FLINK-5985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter reassigned FLINK-5985:
-
Assignee: Stefan Richter
> Flink treats every task as stateful (making topology changes i
[
https://issues.apache.org/jira/browse/FLINK-4760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-4760.
-
Resolution: Not A Problem
> Kafka 09 Consumer failed to initialize state because of corrupted oper
[
https://issues.apache.org/jira/browse/FLINK-5217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15942790#comment-15942790
]
Stefan Richter commented on FLINK-5217:
---
[~shijinkui] the JavaDocs for {{Checkpointe
Stefan Richter created FLINK-6207:
-
Summary: Duplicate type serializers for async snapshots of
CopyOnWriteStateTable
Key: FLINK-6207
URL: https://issues.apache.org/jira/browse/FLINK-6207
Project: Flin
[
https://issues.apache.org/jira/browse/FLINK-6207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-6207.
-
Resolution: Fixed
Fix Version/s: 1.2.1
fixed in 89866a5
backported to 1.2 in bb3e26f
> Du
[
https://issues.apache.org/jira/browse/FLINK-6034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-6034.
-
Resolution: Fixed
Fix Version/s: 1.3.0
Implemented in cd5527417a1cae57073a8855c6c3b88c88c78
Stefan Richter created FLINK-6220:
-
Summary: Fine-grained copy-on-write for Heap(Map/List)States in
CopyOnWriteStateTable
Key: FLINK-6220
URL: https://issues.apache.org/jira/browse/FLINK-6220
Project:
[
https://issues.apache.org/jira/browse/FLINK-5037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-5037.
-
Resolution: Fixed
Fix Version/s: 1.2.0
> Instability in AbstractUdfStreamOperatorLifecycleT
Stefan Richter created FLINK-5041:
-
Summary: Implement savepoint backwards compatibility 1.1 -> 1.2
Key: FLINK-5041
URL: https://issues.apache.org/jira/browse/FLINK-5041
Project: Flink
Issue
Stefan Richter created FLINK-5042:
-
Summary: Convert old savepoints to new savepoints
Key: FLINK-5042
URL: https://issues.apache.org/jira/browse/FLINK-5042
Project: Flink
Issue Type: Sub-task
Stefan Richter created FLINK-5043:
-
Summary: Converting keyed state from Flink 1.1 backend
implementations to their new counterparts in 1.2
Key: FLINK-5043
URL: https://issues.apache.org/jira/browse/FLINK-5043
Stefan Richter created FLINK-5044:
-
Summary: Converting operator and function state from Flink 1.1 for
all changed operators in 1.2
Key: FLINK-5044
URL: https://issues.apache.org/jira/browse/FLINK-5044
Stefan Richter created FLINK-5051:
-
Summary: Backwards compatibility for serializers in backend state
Key: FLINK-5051
URL: https://issues.apache.org/jira/browse/FLINK-5051
Project: Flink
Issu
Stefan Richter created FLINK-5052:
-
Summary: Changing the maximum parallelism (number of key groups)
of a job
Key: FLINK-5052
URL: https://issues.apache.org/jira/browse/FLINK-5052
Project: Flink
Stefan Richter created FLINK-5053:
-
Summary: Incremental / lightweight snapshots for checkpoints
Key: FLINK-5053
URL: https://issues.apache.org/jira/browse/FLINK-5053
Project: Flink
Issue Typ
[
https://issues.apache.org/jira/browse/FLINK-5053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15663198#comment-15663198
]
Stefan Richter commented on FLINK-5053:
---
That might very well be, I am still plannin
[
https://issues.apache.org/jira/browse/FLINK-5051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-5051:
--
Description:
When a new state is register, e.g. in a keyed backend via
`getPartitionedState`, t
[
https://issues.apache.org/jira/browse/FLINK-5051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-5051:
--
Description:
When a new state is register, e.g. in a keyed backend via
`getPartitionedState`, t
Stefan Richter created FLINK-5099:
-
Summary: Test testCancelPartitionRequest is instable
Key: FLINK-5099
URL: https://issues.apache.org/jira/browse/FLINK-5099
Project: Flink
Issue Type: Bug
Stefan Richter created FLINK-5100:
-
Summary: Test testZooKeeperReelection is instable
Key: FLINK-5100
URL: https://issues.apache.org/jira/browse/FLINK-5100
Project: Flink
Issue Type: Bug
Stefan Richter created FLINK-5101:
-
Summary: Test CassandraConnectorITCase instable
Key: FLINK-5101
URL: https://issues.apache.org/jira/browse/FLINK-5101
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-5053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-5053:
--
Description:
There is currently basically no difference between savepoints and checkpoints
in F
Stefan Richter created FLINK-5107:
-
Summary: Job Manager goes out of memory from long history of prior
execution attempts
Key: FLINK-5107
URL: https://issues.apache.org/jira/browse/FLINK-5107
Project:
[
https://issues.apache.org/jira/browse/FLINK-5107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15683096#comment-15683096
]
Stefan Richter commented on FLINK-5107:
---
agreed, it could be a next step to provide
[
https://issues.apache.org/jira/browse/FLINK-5111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15683737#comment-15683737
]
Stefan Richter commented on FLINK-5111:
---
I think this is not an issue, because the d
Stefan Richter created FLINK-5146:
-
Summary: Improved resource cleanup in RocksDB keyed state backend
Key: FLINK-5146
URL: https://issues.apache.org/jira/browse/FLINK-5146
Project: Flink
Issu
[
https://issues.apache.org/jira/browse/FLINK-5146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-5146:
--
Priority: Blocker (was: Major)
> Improved resource cleanup in RocksDB keyed state backend
> ---
[
https://issues.apache.org/jira/browse/FLINK-5024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15692874#comment-15692874
]
Stefan Richter commented on FLINK-5024:
---
Independently of this, I also talked with A
[
https://issues.apache.org/jira/browse/FLINK-4100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-4100.
-
Resolution: Fixed
Fix Version/s: 1.1.3
1.2.0
> RocksDBStateBackend#close
[
https://issues.apache.org/jira/browse/FLINK-4100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15701566#comment-15701566
]
Stefan Richter commented on FLINK-4100:
---
Yes, this looks very outdated.
> RocksDBSt
[
https://issues.apache.org/jira/browse/FLINK-4492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715225#comment-15715225
]
Stefan Richter commented on FLINK-4492:
---
Should be ok to close this.
> Cleanup file
Stefan Richter created FLINK-5265:
-
Summary: Introduce state handle replication mode for
CheckpointCoordinator
Key: FLINK-5265
URL: https://issues.apache.org/jira/browse/FLINK-5265
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter reassigned FLINK-5265:
-
Assignee: Stefan Richter
> Introduce state handle replication mode for CheckpointCoordina
[
https://issues.apache.org/jira/browse/FLINK-5052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter reassigned FLINK-5052:
-
Assignee: Stefan Richter
> Changing the maximum parallelism (number of key groups) of a j
[
https://issues.apache.org/jira/browse/FLINK-5052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-5052:
--
Assignee: (was: Stefan Richter)
> Changing the maximum parallelism (number of key groups) of
[
https://issues.apache.org/jira/browse/FLINK-5051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter reassigned FLINK-5051:
-
Assignee: Stefan Richter
> Backwards compatibility for serializers in backend state
> ---
[
https://issues.apache.org/jira/browse/FLINK-5035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15728267#comment-15728267
]
Stefan Richter commented on FLINK-5035:
---
That is correct. I think we actually need t
[
https://issues.apache.org/jira/browse/FLINK-5283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter reassigned FLINK-5283:
-
Assignee: Stefan Richter
> InputStream should be closed in
> RocksDBKeyedStateBackend#re
[
https://issues.apache.org/jira/browse/FLINK-5286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15731933#comment-15731933
]
Stefan Richter commented on FLINK-5286:
---
I think that FLINK-4910 uncovers subtle pro
[
https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-5041:
--
Description:
This issue tracks the implementation of backwards compatibility between Flink
1.1
Stefan Richter created FLINK-5290:
-
Summary: Ensure backwards compatibility of the hashes used to
generate JobVertexIds
Key: FLINK-5290
URL: https://issues.apache.org/jira/browse/FLINK-5290
Project: F
Stefan Richter created FLINK-5291:
-
Summary: Ensure backwards compatibility of the hashes used to
generate JobVertexIds
Key: FLINK-5291
URL: https://issues.apache.org/jira/browse/FLINK-5291
Project: F
[
https://issues.apache.org/jira/browse/FLINK-5291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-5291.
-
Resolution: Duplicate
> Ensure backwards compatibility of the hashes used to generate JobVertexIds
[
https://issues.apache.org/jira/browse/FLINK-5289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter reassigned FLINK-5289:
-
Assignee: Stefan Richter
> NPE when using value state on non-keyed stream
> -
[
https://issues.apache.org/jira/browse/FLINK-4858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15742624#comment-15742624
]
Stefan Richter commented on FLINK-4858:
---
Agreed. We can not remove it in 1.2, becaus
Stefan Richter created FLINK-5325:
-
Summary: Introduce interface for CloseableRegistry to separate
user from system-facing functionality
Key: FLINK-5325
URL: https://issues.apache.org/jira/browse/FLINK-5325
Stefan Richter created FLINK-5327:
-
Summary: Remove IOException from StateObject::getStateSize
Key: FLINK-5327
URL: https://issues.apache.org/jira/browse/FLINK-5327
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-5327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-5327:
--
Description: The signature of {{StateObject::getStateSize}} declares
throwing of an {{IOExceptio
[
https://issues.apache.org/jira/browse/FLINK-5034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15744733#comment-15744733
]
Stefan Richter commented on FLINK-5034:
---
Yes
> Don't Write StateDescriptor to Rocks
Stefan Richter created FLINK-5335:
-
Summary: Allow ListCheckpointed user functions to return null
Key: FLINK-5335
URL: https://issues.apache.org/jira/browse/FLINK-5335
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-5290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-5290.
-
Resolution: Fixed
Fix Version/s: 1.2.0
> Ensure backwards compatibility of the hashes used
Stefan Richter created FLINK-5337:
-
Summary: Introduce backwards compatible state to task assignment
Key: FLINK-5337
URL: https://issues.apache.org/jira/browse/FLINK-5337
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-5335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-5335.
-
Resolution: Implemented
Fix Version/s: 1.2.0
> Allow ListCheckpointed user functions to ret
[
https://issues.apache.org/jira/browse/FLINK-5347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-5347:
--
Comment: was deleted
(was: The stream is not opened in the method and therefore should also not
[
https://issues.apache.org/jira/browse/FLINK-5347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15752754#comment-15752754
]
Stefan Richter commented on FLINK-5347:
---
The stream is not opened in the method and
[
https://issues.apache.org/jira/browse/FLINK-5347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15752765#comment-15752765
]
Stefan Richter commented on FLINK-5347:
---
{{dos}} is just a wrapper around {{out}}. {
Stefan Richter created FLINK-4134:
-
Summary: EventTimeSessionWindows trigger for empty windows when
dropping late events
Key: FLINK-4134
URL: https://issues.apache.org/jira/browse/FLINK-4134
Project:
[
https://issues.apache.org/jira/browse/FLINK-4134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter reassigned FLINK-4134:
-
Assignee: Stefan Richter
> EventTimeSessionWindows trigger for empty windows when droppin
Stefan Richter created FLINK-4140:
-
Summary: CheckpointCoordinator fails to discard completed
checkpoint
Key: FLINK-4140
URL: https://issues.apache.org/jira/browse/FLINK-4140
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter reassigned FLINK-4140:
-
Assignee: Stefan Richter
> CheckpointCoordinator fails to discard completed checkpoint
>
[
https://issues.apache.org/jira/browse/FLINK-4140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-4140:
--
Assignee: Ufuk Celebi (was: Stefan Richter)
> CheckpointCoordinator fails to discard completed
Stefan Richter created FLINK-4141:
-
Summary: TaskManager failures not always recover when killed
during an ApplicationMaster failure in HA mode on Yarn
Key: FLINK-4141
URL: https://issues.apache.org/jira/browse/FL
Stefan Richter created FLINK-4142:
-
Summary: Recovery problem in HA on Hadoop Yarn 2.5.0
Key: FLINK-4142
URL: https://issues.apache.org/jira/browse/FLINK-4142
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-4142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-4142:
--
Summary: Recovery problem in HA on Hadoop Yarn 2.4.1 (was: Recovery
problem in HA on Hadoop Yar
[
https://issues.apache.org/jira/browse/FLINK-4142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-4142:
--
Description:
On Hadoop Yarn 2.4.1, recovery in HA fails in the following scenario:
1) Kill appl
[
https://issues.apache.org/jira/browse/FLINK-4142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15359073#comment-15359073
]
Stefan Richter commented on FLINK-4142:
---
I have a log for the problem here:
https:/
Stefan Richter created FLINK-4150:
-
Summary: Problem with Blobstore in Yarn HA setting on recovery
after cluster shutdown
Key: FLINK-4150
URL: https://issues.apache.org/jira/browse/FLINK-4150
Project:
Stefan Richter created FLINK-4156:
-
Summary: Job with -m yarn-cluster registers TaskManagers to
another running Yarn session
Key: FLINK-4156
URL: https://issues.apache.org/jira/browse/FLINK-4156
Proje
Stefan Richter created FLINK-4166:
-
Summary: Generate automatic different namespaces in Zookeeper for
Flink applications
Key: FLINK-4166
URL: https://issues.apache.org/jira/browse/FLINK-4166
Project:
Stefan Richter created FLINK-4182:
-
Summary: HA recovery not working properly under ApplicationMaster
failures.
Key: FLINK-4182
URL: https://issues.apache.org/jira/browse/FLINK-4182
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-4182:
--
Description:
When randomly killing TaskManager and ApplicationMaster, a job sometimes does
not
Stefan Richter created FLINK-4200:
-
Summary: Kafka consumers should log the offset from which they
restore
Key: FLINK-4200
URL: https://issues.apache.org/jira/browse/FLINK-4200
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-4150:
--
Description:
Submitting a job in Yarn with HA can lead to the following exception:
{code}
org.a
Stefan Richter created FLINK-4201:
-
Summary: Checkpoints for jobs in non-terminal state (e.g.
suspended) get deleted
Key: FLINK-4201
URL: https://issues.apache.org/jira/browse/FLINK-4201
Project: Flin
Stefan Richter created FLINK-4211:
-
Summary: Dynamic Properties not working for jobs submitted to Yarn
session
Key: FLINK-4211
URL: https://issues.apache.org/jira/browse/FLINK-4211
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15378999#comment-15378999
]
Stefan Richter commented on FLINK-4211:
---
I see. I think unfortunately this is not re
Stefan Richter created FLINK-4230:
-
Summary: Session Windowing IT Case
Key: FLINK-4230
URL: https://issues.apache.org/jira/browse/FLINK-4230
Project: Flink
Issue Type: Test
Componen
[
https://issues.apache.org/jira/browse/FLINK-3623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15414110#comment-15414110
]
Stefan Richter commented on FLINK-3623:
---
In my opinion, our implementation of Murmur
Stefan Richter created FLINK-4374:
-
Summary: GroupReduce Broken for null Date
Key: FLINK-4374
URL: https://issues.apache.org/jira/browse/FLINK-4374
Project: Flink
Issue Type: Bug
Co
[
https://issues.apache.org/jira/browse/FLINK-4374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter reassigned FLINK-4374:
-
Assignee: Timo Walther
> GroupReduce Broken for null Date
> -
[
https://issues.apache.org/jira/browse/FLINK-4374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-4374:
--
Description:
The GroupReduceITCase has an error that allows a problem with {{null}} Dates to
go
1 - 100 of 975 matches
Mail list logo
