Nico Kruber created FLINK-6008:
--
Summary: collection of BlobServer improvements
Key: FLINK-6008
URL: https://issues.apache.org/jira/browse/FLINK-6008
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-6008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-6008:
---
Description:
The following things should be improved around the BlobServer/BlobCache:
* update config
Nico Kruber created FLINK-6046:
--
Summary: Add support for oversized messages during deployment
Key: FLINK-6046
URL: https://issues.apache.org/jira/browse/FLINK-6046
Project: Flink
Issue Type: Ne
[
https://issues.apache.org/jira/browse/FLINK-6046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-6046:
---
Description:
This is the non-FLIP6 version of FLINK-4346, restricted to deployment messages:
Currentl
[
https://issues.apache.org/jira/browse/FLINK-4545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15924535#comment-15924535
]
Nico Kruber commented on FLINK-4545:
We did some thinking and would probably add the f
Nico Kruber created FLINK-6064:
--
Summary: wrong BlobServer hostname in TaskExecutor
Key: FLINK-6064
URL: https://issues.apache.org/jira/browse/FLINK-6064
Project: Flink
Issue Type: Bug
Nico Kruber created FLINK-5059:
--
Summary: only serialise events once in RecordWriter#broadcastEvent
Key: FLINK-5059
URL: https://issues.apache.org/jira/browse/FLINK-5059
Project: Flink
Issue Typ
Nico Kruber created FLINK-5060:
--
Summary: only serialise records once in RecordWriter#emit and
RecordWriter#broadcastEmit
Key: FLINK-5060
URL: https://issues.apache.org/jira/browse/FLINK-5060
Project: Fl
Nico Kruber created FLINK-5066:
--
Summary: prevent LocalInputChannel#getNextBuffer from
de-serialising all events when looking for EndOfPartitionEvent only
Key: FLINK-5066
URL: https://issues.apache.org/jira/browse/FL
Nico Kruber created FLINK-5081:
--
Summary: unable to set yarn.maximum-failed-containers with flink
one-time YARN setup
Key: FLINK-5081
URL: https://issues.apache.org/jira/browse/FLINK-5081
Project: Flink
Nico Kruber created FLINK-5129:
--
Summary: make the BlobServer use a distributed file system
Key: FLINK-5129
URL: https://issues.apache.org/jira/browse/FLINK-5129
Project: Flink
Issue Type: Impro
[
https://issues.apache.org/jira/browse/FLINK-5129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-5129:
---
Priority: Major (was: Minor)
> make the BlobServer use a distributed file system
> --
Nico Kruber created FLINK-5178:
--
Summary: allow BLOB_STORAGE_DIRECTORY_KEY to point to a
distributed file system
Key: FLINK-5178
URL: https://issues.apache.org/jira/browse/FLINK-5178
Project: Flink
Nico Kruber created FLINK-5202:
--
Summary: test timeout (no output for 300s) in
YARNHighAvailabilityITCase
Key: FLINK-5202
URL: https://issues.apache.org/jira/browse/FLINK-5202
Project: Flink
Is
[
https://issues.apache.org/jira/browse/FLINK-5202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15705518#comment-15705518
]
Nico Kruber commented on FLINK-5202:
one more:
https://api.travis-ci.org/jobs/1797339
Nico Kruber created FLINK-5203:
--
Summary: YARNHighAvailabilityITCase fails to deploy YARN cluster
Key: FLINK-5203
URL: https://issues.apache.org/jira/browse/FLINK-5203
Project: Flink
Issue Type:
Nico Kruber created FLINK-5204:
--
Summary: Flakey YARNSessionCapacitySchedulerITCase
(NullPointerException)
Key: FLINK-5204
URL: https://issues.apache.org/jira/browse/FLINK-5204
Project: Flink
I
Nico Kruber created FLINK-5206:
--
Summary: Flakey PythonPlanBinderTest
Key: FLINK-5206
URL: https://issues.apache.org/jira/browse/FLINK-5206
Project: Flink
Issue Type: Bug
Environment: i
Nico Kruber created FLINK-5212:
--
Summary: Flakey ScalaShellITCase#testPreventRecreationBatch (out
of Java heap space)
Key: FLINK-5212
URL: https://issues.apache.org/jira/browse/FLINK-5212
Project: Flink
Nico Kruber created FLINK-5277:
--
Summary: missing unit test for ensuring ResultPartition#add always
recycles buffers
Key: FLINK-5277
URL: https://issues.apache.org/jira/browse/FLINK-5277
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber reassigned FLINK-5277:
--
Assignee: Nico Kruber
> missing unit test for ensuring ResultPartition#add always recycles buff
Nico Kruber created FLINK-5288:
--
Summary: Flakey
ConnectedComponentsITCase#testConnectedComponentsExample unit test
Key: FLINK-5288
URL: https://issues.apache.org/jira/browse/FLINK-5288
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-3053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15732160#comment-15732160
]
Nico Kruber commented on FLINK-3053:
one more:
https://api.travis-ci.org/jobs/18197645
[
https://issues.apache.org/jira/browse/FLINK-5066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-5066:
---
Summary: add more efficient isEvent check to EventSerializer (was: prevent
LocalInputChannel#getNextB
[
https://issues.apache.org/jira/browse/FLINK-5066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-5066:
---
Description:
-LocalInputChannel#getNextBuffer de-serialises all incoming events on the
lookout for an
Nico Kruber created FLINK-5308:
--
Summary: download links to previous releases are incomplete
Key: FLINK-5308
URL: https://issues.apache.org/jira/browse/FLINK-5308
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-5308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15735659#comment-15735659
]
Nico Kruber commented on FLINK-5308:
I was thinking about this, too: to only link them
Nico Kruber created FLINK-5309:
--
Summary: documentation links on the home page point to 1.2-SNAPSHOT
Key: FLINK-5309
URL: https://issues.apache.org/jira/browse/FLINK-5309
Project: Flink
Issue Ty
Nico Kruber created FLINK-5334:
--
Summary: outdated scala SBT quickstart example
Key: FLINK-5334
URL: https://issues.apache.org/jira/browse/FLINK-5334
Project: Flink
Issue Type: Bug
Com
[
https://issues.apache.org/jira/browse/FLINK-3952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-3952:
---
Component/s: Network
> Bump Netty to 4.1
> -
>
> Key: FLINK-3952
>
[
https://issues.apache.org/jira/browse/FLINK-3952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-3952:
---
Component/s: (was: DataSet API)
> Bump Netty to 4.1
> -
>
> Key: F
Nico Kruber created FLINK-6270:
--
Summary: Port several network config parameters to ConfigOption
Key: FLINK-6270
URL: https://issues.apache.org/jira/browse/FLINK-6270
Project: Flink
Issue Type:
Nico Kruber created FLINK-6287:
--
Summary: Flakey JobManagerRegistrationTest
Key: FLINK-6287
URL: https://issues.apache.org/jira/browse/FLINK-6287
Project: Flink
Issue Type: Bug
Compone
[
https://issues.apache.org/jira/browse/FLINK-6287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-6287:
---
Component/s: Tests
> Flakey JobManagerRegistrationTest
> -
>
>
Nico Kruber created FLINK-6292:
--
Summary: Travis: transfer.sh not accepting uploads via http://
anymore
Key: FLINK-6292
URL: https://issues.apache.org/jira/browse/FLINK-6292
Project: Flink
Issu
Nico Kruber created FLINK-6293:
--
Summary: Flakey JobManagerITCase
Key: FLINK-6293
URL: https://issues.apache.org/jira/browse/FLINK-6293
Project: Flink
Issue Type: Bug
Components: Job-S
[
https://issues.apache.org/jira/browse/FLINK-6293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15964138#comment-15964138
]
Nico Kruber commented on FLINK-6293:
Same here (with only the {{transfer.sh}} upload c
[
https://issues.apache.org/jira/browse/FLINK-6293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-6293:
---
Component/s: (was: Job-Submission)
JobManager
> Flakey JobManagerITCase
> ---
Nico Kruber created FLINK-6299:
--
Summary: make all IT cases extend from TestLogger
Key: FLINK-6299
URL: https://issues.apache.org/jira/browse/FLINK-6299
Project: Flink
Issue Type: Improvement
Nico Kruber created FLINK-6305:
--
Summary: flink-ml tests are executed in all flink-fast-test
profiles
Key: FLINK-6305
URL: https://issues.apache.org/jira/browse/FLINK-6305
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-6292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15971637#comment-15971637
]
Nico Kruber commented on FLINK-6292:
does it make sense to cherry-pick this commit int
[
https://issues.apache.org/jira/browse/FLINK-6292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15972446#comment-15972446
]
Nico Kruber commented on FLINK-6292:
oh, sorry, I'll double check next time before set
[
https://issues.apache.org/jira/browse/FLINK-6287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-6287:
---
Labels: test-stability (was: )
> Flakey JobManagerRegistrationTest
>
Nico Kruber created FLINK-6320:
--
Summary: Flakey JobManagerHAJobGraphRecoveryITCase
Key: FLINK-6320
URL: https://issues.apache.org/jira/browse/FLINK-6320
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-6293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-6293:
---
Labels: test-stability (was: )
> Flakey JobManagerITCase
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-6064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber closed FLINK-6064.
--
> wrong BlobServer hostname in TaskExecutor
> -
>
>
Nico Kruber created FLINK-6329:
--
Summary: refactor name-addressable accessors in BlobService
classes from returning a URL to a File or InputStream
Key: FLINK-6329
URL: https://issues.apache.org/jira/browse/FLINK-6329
Nico Kruber created FLINK-6380:
--
Summary: BlobService concurrency issues between delete and put/get
methods
Key: FLINK-6380
URL: https://issues.apache.org/jira/browse/FLINK-6380
Project: Flink
Nico Kruber created FLINK-5008:
--
Summary: Update IDE setup documentation
Key: FLINK-5008
URL: https://issues.apache.org/jira/browse/FLINK-5008
Project: Flink
Issue Type: Improvement
Co
[
https://issues.apache.org/jira/browse/FLINK-5008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber reassigned FLINK-5008:
--
Assignee: Nico Kruber
> Update IDE setup documentation
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-5008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-5008:
---
Description:
* The IDE setup documentation of Flink is outdated in both parts: IntelliJ IDEA
was base
[
https://issues.apache.org/jira/browse/FLINK-5618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-5618:
---
Issue Type: Sub-task (was: Improvement)
Parent: FLINK-5430
> Add queryable state documentatio
[
https://issues.apache.org/jira/browse/FLINK-5277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-5277:
---
Issue Type: Improvement (was: Bug)
> missing unit test for ensuring ResultPartition#add always recycl
[
https://issues.apache.org/jira/browse/FLINK-5672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15863683#comment-15863683
]
Nico Kruber commented on FLINK-5672:
a local cluster does not quite work out of the bo
[
https://issues.apache.org/jira/browse/FLINK-5672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15863683#comment-15863683
]
Nico Kruber edited comment on FLINK-5672 at 2/13/17 1:43 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-5553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber reassigned FLINK-5553:
--
Assignee: Nico Kruber
> Job fails during deployment with IllegalStateException from subpartitio
[
https://issues.apache.org/jira/browse/FLINK-5553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15863863#comment-15863863
]
Nico Kruber commented on FLINK-5553:
If you try again with the PR above, there should
Nico Kruber created FLINK-5796:
--
Summary: broken links in the docs
Key: FLINK-5796
URL: https://issues.apache.org/jira/browse/FLINK-5796
Project: Flink
Issue Type: Bug
Components: Docu
[
https://issues.apache.org/jira/browse/FLINK-5796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15865902#comment-15865902
]
Nico Kruber commented on FLINK-5796:
{{/api/java/org/apache/flink/table/api/Table.html
[
https://issues.apache.org/jira/browse/FLINK-4813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15866135#comment-15866135
]
Nico Kruber commented on FLINK-4813:
for documentation: until the minikdc dependency i
[
https://issues.apache.org/jira/browse/FLINK-5070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-5070:
---
Component/s: Type Serialization System
Scala API
> Unable to use Scala's BeanProperty
[
https://issues.apache.org/jira/browse/FLINK-4813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber reassigned FLINK-4813:
--
Assignee: Nico Kruber
> Having flink-test-utils as a dependency outside Flink fails the build
>
Nico Kruber created FLINK-5814:
--
Summary: flink-dist creates wrong symlink when not used with
cleaned before
Key: FLINK-5814
URL: https://issues.apache.org/jira/browse/FLINK-5814
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber closed FLINK-5099.
--
Resolution: Cannot Reproduce
the stack trace seems incomplete and the actual OutOfMemory error may even
[
https://issues.apache.org/jira/browse/FLINK-5923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15886298#comment-15886298
]
Nico Kruber commented on FLINK-5923:
I guess the following error may also originate fr
Nico Kruber created FLINK-5973:
--
Summary: check whether the direct memory size is always correctly
calculated
Key: FLINK-5973
URL: https://issues.apache.org/jira/browse/FLINK-5973
Project: Flink
Nico Kruber created FLINK-6005:
--
Summary: unit test ArrayList initializations without default size
Key: FLINK-6005
URL: https://issues.apache.org/jira/browse/FLINK-6005
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-6005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-6005:
---
Summary: unit test ArrayList initializations without initial size (was:
unit test ArrayList initializ
[
https://issues.apache.org/jira/browse/FLINK-6005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-6005:
---
Description: I found some ArrayList initializations without a sensible
initial size although it is pos
[
https://issues.apache.org/jira/browse/FLINK-3150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber reassigned FLINK-3150:
--
Assignee: Nico Kruber (was: Robert Metzger)
> Make YARN container invocation configurable
> --
[
https://issues.apache.org/jira/browse/FLINK-5178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-5178:
---
Description: After FLINK-5129, high availability (HA) mode adds the ability
for the BlobCache instance
[
https://issues.apache.org/jira/browse/FLINK-5178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-5178:
---
Summary: allow BlobCache to use a distributed file system irrespective of
the HA mode (was: allow Blo
Nico Kruber created FLINK-5482:
--
Summary: QueryableStateClient does not recover from a failed
lookup due to a non-running job
Key: FLINK-5482
URL: https://issues.apache.org/jira/browse/FLINK-5482
Project
[
https://issues.apache.org/jira/browse/FLINK-5456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823766#comment-15823766
]
Nico Kruber commented on FLINK-5456:
Looks like some of the existing documentation got
Nico Kruber created FLINK-5507:
--
Summary: remove queryable list state sink
Key: FLINK-5507
URL: https://issues.apache.org/jira/browse/FLINK-5507
Project: Flink
Issue Type: Improvement
Nico Kruber created FLINK-5515:
--
Summary: fix unused kvState.getSerializedValue call in
KvStateServerHandler
Key: FLINK-5515
URL: https://issues.apache.org/jira/browse/FLINK-5515
Project: Flink
Nico Kruber created FLINK-5521:
--
Summary: remove unused KvStateRequestSerializer#serializeList
Key: FLINK-5521
URL: https://issues.apache.org/jira/browse/FLINK-5521
Project: Flink
Issue Type: Im
Nico Kruber created FLINK-5526:
--
Summary: QueryableState: notify upon receiving a query but having
queryable state disabled
Key: FLINK-5526
URL: https://issues.apache.org/jira/browse/FLINK-5526
Project:
Nico Kruber created FLINK-5527:
--
Summary: QueryableState: requesting a non-existing key in
MemoryStateBackend or FsStateBackend does not return the default value
Key: FLINK-5527
URL: https://issues.apache.org/jira/br
Nico Kruber created FLINK-5528:
--
Summary: tests: reduce the retry delay in QueryableStateITCase
Key: FLINK-5528
URL: https://issues.apache.org/jira/browse/FLINK-5528
Project: Flink
Issue Type: I
[
https://issues.apache.org/jira/browse/FLINK-5528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15826088#comment-15826088
]
Nico Kruber commented on FLINK-5528:
Using 100ms instead does not impose too much addi
Nico Kruber created FLINK-5530:
--
Summary: race condition in AbstractRocksDBState#getSerializedValue
Key: FLINK-5530
URL: https://issues.apache.org/jira/browse/FLINK-5530
Project: Flink
Issue Typ
Nico Kruber created FLINK-5559:
--
Summary: queryable state:
KvStateRequestSerializer#deserializeKeyAndNamespace() throws an IOException
without own failure message if deserialisation fails
Key: FLINK-5559
URL: https:
Nico Kruber created FLINK-5561:
--
Summary: DataInputDeserializer#available returns one too few
Key: FLINK-5561
URL: https://issues.apache.org/jira/browse/FLINK-5561
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-5559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15828460#comment-15828460
]
Nico Kruber commented on FLINK-5559:
or even better, migrate the IllegalArgumentExcept
Nico Kruber created FLINK-5576:
--
Summary: extend deserialization functions of
KvStateRequestSerializer to detect unconsumed bytes
Key: FLINK-5576
URL: https://issues.apache.org/jira/browse/FLINK-5576
Pro
[
https://issues.apache.org/jira/browse/FLINK-5576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-5576:
---
Description: KvStateRequestSerializer#deserializeValue and
KvStateRequestSerializer#deserializeList bo
[
https://issues.apache.org/jira/browse/FLINK-5576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-5576:
---
Description: KvStateRequestSerializer#deserializeValue and
KvStateRequestSerializer#deserializeList bo
Nico Kruber created FLINK-5591:
--
Summary: queryable state: request failures failing on the server
side do not contain client stack trace
Key: FLINK-5591
URL: https://issues.apache.org/jira/browse/FLINK-5591
Nico Kruber created FLINK-5613:
--
Summary: QueryableState: requesting a non-existing key in
RocksDBStateBackend is not consistent with the MemoryStateBackend and
FsStateBackend
Key: FLINK-5613
URL: https://issues.apa
[
https://issues.apache.org/jira/browse/FLINK-5613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-5613:
---
Description:
Querying for a non-existing key for a state that has a default value set
currently resul
[
https://issues.apache.org/jira/browse/FLINK-5527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber closed FLINK-5527.
--
Resolution: Won't Fix
let's go with FLINK-5613 instead
> QueryableState: requesting a non-existing key
[
https://issues.apache.org/jira/browse/FLINK-5614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15834282#comment-15834282
]
Nico Kruber commented on FLINK-5614:
having snapshots (at least) until the release wou
Nico Kruber created FLINK-5615:
--
Summary: queryable state: execute the QueryableStateITCase for all
three state back-ends
Key: FLINK-5615
URL: https://issues.apache.org/jira/browse/FLINK-5615
Project: Fl
[
https://issues.apache.org/jira/browse/FLINK-4719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-4719:
---
Assignee: (was: Nico Kruber)
> KryoSerializer random exception
> ---
>
Nico Kruber created FLINK-5642:
--
Summary: queryable state: race condition with HeadListState
Key: FLINK-5642
URL: https://issues.apache.org/jira/browse/FLINK-5642
Project: Flink
Issue Type: Bug
Nico Kruber created FLINK-5651:
--
Summary: state backends: forbid Iterator#remove() from the
Iterable returned by HeapListState#get()
Key: FLINK-5651
URL: https://issues.apache.org/jira/browse/FLINK-5651
[
https://issues.apache.org/jira/browse/FLINK-5651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15839482#comment-15839482
]
Nico Kruber commented on FLINK-5651:
Actually, it can be fine to use Iterator#remove()
[
https://issues.apache.org/jira/browse/FLINK-5651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber closed FLINK-5651.
--
Resolution: Won't Fix
> state backends: forbid Iterator#remove() from the Iterable returned by
> HeapLi
[
https://issues.apache.org/jira/browse/FLINK-5666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15840187#comment-15840187
]
Nico Kruber commented on FLINK-5666:
hmm - do you see a warning like "Failed to delete
1 - 100 of 1422 matches
Mail list logo
