[jira] [Commented] (FLINK-5309) documentation links on the home page point to 1.2-SNAPSHOT

2017-02-07 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855687#comment-15855687 ] Nico Kruber commented on FLINK-5309: Quickstart seems to point to 1.2 (which is stable now) but it

[jira] [Commented] (FLINK-5614) Enable snapshot builds for release branches

2017-01-23 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15834282#comment-15834282 ] Nico Kruber commented on FLINK-5614: having snapshots (at least) until the release would make release

[jira] [Created] (FLINK-5615) queryable state: execute the QueryableStateITCase for all three state back-ends

2017-01-23 Thread Nico Kruber (JIRA)
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:

[jira] [Closed] (FLINK-5527) QueryableState: requesting a non-existing key in MemoryStateBackend or FsStateBackend does not return the default value

2017-01-23 Thread Nico Kruber (JIRA)
[ 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

[jira] [Updated] (FLINK-5613) QueryableState: requesting a non-existing key in RocksDBStateBackend is not consistent with the MemoryStateBackend and FsStateBackend

2017-01-23 Thread Nico Kruber (JIRA)
[ 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

[jira] [Created] (FLINK-5613) QueryableState: requesting a non-existing key in RocksDBStateBackend is not consistent with the MemoryStateBackend and FsStateBackend

2017-01-23 Thread Nico Kruber (JIRA)
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:

[jira] [Commented] (FLINK-5666) Blob files are not cleaned up from ZK storage directory

2017-01-26 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15840235#comment-15840235 ] Nico Kruber commented on FLINK-5666: Alternatively, the BlobLibraryCacheManager's cleanup task may

[jira] [Commented] (FLINK-5666) Blob files are not cleaned up from ZK storage directory

2017-01-26 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15840187#comment-15840187 ] Nico Kruber commented on FLINK-5666: hmm - do you see a warning like "Failed to delete blob at..."?

[jira] [Created] (FLINK-5642) queryable state: race condition with HeadListState

2017-01-25 Thread Nico Kruber (JIRA)
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

[jira] [Updated] (FLINK-4719) KryoSerializer random exception

2017-01-25 Thread Nico Kruber (JIRA)
[ 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 > ---

[jira] [Created] (FLINK-5651) state backends: forbid Iterator#remove() from the Iterable returned by HeapListState#get()

2017-01-26 Thread Nico Kruber (JIRA)
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

[jira] [Commented] (FLINK-5651) state backends: forbid Iterator#remove() from the Iterable returned by HeapListState#get()

2017-01-26 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15839482#comment-15839482 ] Nico Kruber commented on FLINK-5651: Actually, it can be fine to use Iterator#remove() as long as the

[jira] [Closed] (FLINK-5651) state backends: forbid Iterator#remove() from the Iterable returned by HeapListState#get()

2017-01-26 Thread Nico Kruber (JIRA)
[ 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 >

[jira] [Created] (FLINK-5591) queryable state: request failures failing on the server side do not contain client stack trace

2017-01-20 Thread Nico Kruber (JIRA)
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

[jira] [Commented] (FLINK-5796) broken links in the docs

2017-02-14 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865902#comment-15865902 ] Nico Kruber commented on FLINK-5796: {{/api/java/org/apache/flink/table/api/Table.html}} is actually

[jira] [Updated] (FLINK-5618) Add queryable state documentation

2017-02-10 Thread Nico Kruber (JIRA)
[ 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

[jira] [Updated] (FLINK-5070) Unable to use Scala's BeanProperty with classes

2017-02-14 Thread Nico Kruber (JIRA)
[ 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

[jira] [Commented] (FLINK-4813) Having flink-test-utils as a dependency outside Flink fails the build

2017-02-14 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866135#comment-15866135 ] Nico Kruber commented on FLINK-4813: for documentation: until the minikdc dependency is made optional,

[jira] [Assigned] (FLINK-4813) Having flink-test-utils as a dependency outside Flink fails the build

2017-02-15 Thread Nico Kruber (JIRA)
[ 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

[jira] [Created] (FLINK-5796) broken links in the docs

2017-02-14 Thread Nico Kruber (JIRA)
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:

[jira] [Commented] (FLINK-5553) Job fails during deployment with IllegalStateException from subpartition request

2017-02-13 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15863863#comment-15863863 ] Nico Kruber commented on FLINK-5553: If you try again with the PR above, there should now be a more

[jira] [Assigned] (FLINK-5553) Job fails during deployment with IllegalStateException from subpartition request

2017-02-13 Thread Nico Kruber (JIRA)
[ 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

[jira] [Updated] (FLINK-5277) missing unit test for ensuring ResultPartition#add always recycles buffers

2017-02-13 Thread Nico Kruber (JIRA)
[ 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

[jira] [Created] (FLINK-5814) flink-dist creates wrong symlink when not used with cleaned before

2017-02-16 Thread Nico Kruber (JIRA)
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

[jira] [Commented] (FLINK-5672) Job fails with java.lang.IllegalArgumentException: port out of range:-1

2017-02-13 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15863683#comment-15863683 ] Nico Kruber commented on FLINK-5672: a local cluster does not quite work out of the box via

[jira] [Comment Edited] (FLINK-5672) Job fails with java.lang.IllegalArgumentException: port out of range:-1

2017-02-13 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15863683#comment-15863683 ] Nico Kruber edited comment on FLINK-5672 at 2/13/17 1:43 PM: - a local cluster

[jira] [Closed] (FLINK-5099) Test testCancelPartitionRequest is instable

2017-02-17 Thread Nico Kruber (JIRA)
[ 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

[jira] [Created] (FLINK-5576) extend deserialization functions of KvStateRequestSerializer to detect unconsumed bytes

2017-01-19 Thread Nico Kruber (JIRA)
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

[jira] [Created] (FLINK-5530) race condition in AbstractRocksDBState#getSerializedValue

2017-01-17 Thread Nico Kruber (JIRA)
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

[jira] [Commented] (FLINK-5456) Add docs about new state and checkpointing interfaces

2017-01-16 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15823766#comment-15823766 ] Nico Kruber commented on FLINK-5456: Looks like some of the existing documentation got lost with

[jira] [Created] (FLINK-5507) remove queryable list state sink

2017-01-16 Thread Nico Kruber (JIRA)
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

[jira] [Created] (FLINK-5515) fix unused kvState.getSerializedValue call in KvStateServerHandler

2017-01-16 Thread Nico Kruber (JIRA)
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

[jira] [Created] (FLINK-5521) remove unused KvStateRequestSerializer#serializeList

2017-01-17 Thread Nico Kruber (JIRA)
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:

[jira] [Created] (FLINK-5527) QueryableState: requesting a non-existing key in MemoryStateBackend or FsStateBackend does not return the default value

2017-01-17 Thread Nico Kruber (JIRA)
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:

[jira] [Created] (FLINK-5526) QueryableState: notify upon receiving a query but having queryable state disabled

2017-01-17 Thread Nico Kruber (JIRA)
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:

[jira] [Commented] (FLINK-5528) tests: reduce the retry delay in QueryableStateITCase

2017-01-17 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15826088#comment-15826088 ] Nico Kruber commented on FLINK-5528: Using 100ms instead does not impose too much additional query

[jira] [Created] (FLINK-5528) tests: reduce the retry delay in QueryableStateITCase

2017-01-17 Thread Nico Kruber (JIRA)
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:

[jira] [Created] (FLINK-5559) queryable state: KvStateRequestSerializer#deserializeKeyAndNamespace() throws an IOException without own failure message if deserialisation fails

2017-01-18 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-5559: -- Summary: queryable state: KvStateRequestSerializer#deserializeKeyAndNamespace() throws an IOException without own failure message if deserialisation fails Key: FLINK-5559 URL:

[jira] [Created] (FLINK-5561) DataInputDeserializer#available returns one too few

2017-01-18 Thread Nico Kruber (JIRA)
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:

[jira] [Commented] (FLINK-5559) queryable state: KvStateRequestSerializer#deserializeKeyAndNamespace() throws an IOException without own failure message if deserialisation fails

2017-01-18 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828460#comment-15828460 ] Nico Kruber commented on FLINK-5559: or even better, migrate the IllegalArgumentException to

[jira] [Updated] (FLINK-5576) extend deserialization functions of KvStateRequestSerializer to detect unconsumed bytes

2017-01-19 Thread Nico Kruber (JIRA)
[ 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

[jira] [Updated] (FLINK-5576) extend deserialization functions of KvStateRequestSerializer to detect unconsumed bytes

2017-01-19 Thread Nico Kruber (JIRA)
[ 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

[jira] [Commented] (FLINK-5923) Test instability in SavepointITCase testTriggerSavepointAndResume

2017-02-27 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886298#comment-15886298 ] Nico Kruber commented on FLINK-5923: I guess the following error may also originate from that race

[jira] [Created] (FLINK-5059) only serialise events once in RecordWriter#broadcastEvent

2016-11-14 Thread Nico Kruber (JIRA)
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

[jira] [Created] (FLINK-5060) only serialise records once in RecordWriter#emit and RecordWriter#broadcastEmit

2016-11-14 Thread Nico Kruber (JIRA)
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:

[jira] [Created] (FLINK-5066) prevent LocalInputChannel#getNextBuffer from de-serialising all events when looking for EndOfPartitionEvent only

2016-11-14 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-5066: -- Summary: prevent LocalInputChannel#getNextBuffer from de-serialising all events when looking for EndOfPartitionEvent only Key: FLINK-5066 URL:

[jira] [Created] (FLINK-5129) make the BlobServer use a distributed file system

2016-11-22 Thread Nico Kruber (JIRA)
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:

[jira] [Created] (FLINK-5178) allow BLOB_STORAGE_DIRECTORY_KEY to point to a distributed file system

2016-11-28 Thread Nico Kruber (JIRA)
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

[jira] [Updated] (FLINK-5129) make the BlobServer use a distributed file system

2016-11-28 Thread Nico Kruber (JIRA)
[ 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 >

[jira] [Created] (FLINK-5081) unable to set yarn.maximum-failed-containers with flink one-time YARN setup

2016-11-16 Thread Nico Kruber (JIRA)
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

[jira] [Created] (FLINK-5008) Update IDE setup documentation

2016-11-03 Thread Nico Kruber (JIRA)
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

[jira] [Assigned] (FLINK-5008) Update IDE setup documentation

2016-11-03 Thread Nico Kruber (JIRA)
[ 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 > -- > >

[jira] [Updated] (FLINK-5008) Update quickstart documentation

2016-11-04 Thread Nico Kruber (JIRA)
[ 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

[jira] [Created] (FLINK-5288) Flakey ConnectedComponentsITCase#testConnectedComponentsExample unit test

2016-12-08 Thread Nico Kruber (JIRA)
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

[jira] [Commented] (FLINK-3053) SuccessAfterNetworkBuffersFailureITCase.testSuccessfulProgramAfterFailure

2016-12-08 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15732160#comment-15732160 ] Nico Kruber commented on FLINK-3053: one more:

[jira] [Updated] (FLINK-5066) add more efficient isEvent check to EventSerializer

2016-12-08 Thread Nico Kruber (JIRA)
[ 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

[jira] [Updated] (FLINK-5066) add more efficient isEvent check to EventSerializer

2016-12-08 Thread Nico Kruber (JIRA)
[ 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

[jira] [Created] (FLINK-5308) download links to previous releases are incomplete

2016-12-09 Thread Nico Kruber (JIRA)
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

[jira] [Commented] (FLINK-5308) download links to previous releases are incomplete

2016-12-09 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15735659#comment-15735659 ] Nico Kruber commented on FLINK-5308: I was thinking about this, too: to only link them in the newest

[jira] [Created] (FLINK-5309) documentation links on the home page point to 1.2-SNAPSHOT

2016-12-09 Thread Nico Kruber (JIRA)
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

[jira] [Created] (FLINK-5334) outdated scala SBT quickstart example

2016-12-14 Thread Nico Kruber (JIRA)
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

[jira] [Created] (FLINK-5482) QueryableStateClient does not recover from a failed lookup due to a non-running job

2017-01-13 Thread Nico Kruber (JIRA)
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

[jira] [Created] (FLINK-5202) test timeout (no output for 300s) in YARNHighAvailabilityITCase

2016-11-29 Thread Nico Kruber (JIRA)
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

[jira] [Commented] (FLINK-5202) test timeout (no output for 300s) in YARNHighAvailabilityITCase

2016-11-29 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15705518#comment-15705518 ] Nico Kruber commented on FLINK-5202: one more:

[jira] [Created] (FLINK-5203) YARNHighAvailabilityITCase fails to deploy YARN cluster

2016-11-29 Thread Nico Kruber (JIRA)
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

[jira] [Created] (FLINK-5206) Flakey PythonPlanBinderTest

2016-11-29 Thread Nico Kruber (JIRA)
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:

[jira] [Created] (FLINK-5204) Flakey YARNSessionCapacitySchedulerITCase (NullPointerException)

2016-11-29 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-5204: -- Summary: Flakey YARNSessionCapacitySchedulerITCase (NullPointerException) Key: FLINK-5204 URL: https://issues.apache.org/jira/browse/FLINK-5204 Project: Flink

[jira] [Created] (FLINK-5212) Flakey ScalaShellITCase#testPreventRecreationBatch (out of Java heap space)

2016-11-30 Thread Nico Kruber (JIRA)
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

[jira] [Updated] (FLINK-5178) allow BlobCache touse a distributed file system irrespective of the HA mode

2017-01-06 Thread Nico Kruber (JIRA)
[ 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

[jira] [Updated] (FLINK-5178) allow BlobCache to use a distributed file system irrespective of the HA mode

2017-01-06 Thread Nico Kruber (JIRA)
[ 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

[jira] [Created] (FLINK-5277) missing unit test for ensuring ResultPartition#add always recycles buffers

2016-12-07 Thread Nico Kruber (JIRA)
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

[jira] [Assigned] (FLINK-5277) missing unit test for ensuring ResultPartition#add always recycles buffers

2016-12-07 Thread Nico Kruber (JIRA)
[ 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

[jira] [Assigned] (FLINK-3150) Make YARN container invocation configurable

2016-12-21 Thread Nico Kruber (JIRA)
[ 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 >

[jira] [Created] (FLINK-6064) wrong BlobServer hostname in TaskExecutor

2017-03-15 Thread Nico Kruber (JIRA)
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

[jira] [Created] (FLINK-6299) make all IT cases extend from TestLogger

2017-04-12 Thread Nico Kruber (JIRA)
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

[jira] [Updated] (FLINK-3952) Bump Netty to 4.1

2017-04-06 Thread Nico Kruber (JIRA)
[ 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 >

[jira] [Updated] (FLINK-3952) Bump Netty to 4.1

2017-04-06 Thread Nico Kruber (JIRA)
[ 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:

[jira] [Created] (FLINK-6287) Flakey JobManagerRegistrationTest

2017-04-10 Thread Nico Kruber (JIRA)
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

[jira] [Updated] (FLINK-6287) Flakey JobManagerRegistrationTest

2017-04-10 Thread Nico Kruber (JIRA)
[ 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 > - > >

[jira] [Created] (FLINK-6292) Travis: transfer.sh not accepting uploads via http:// anymore

2017-04-11 Thread Nico Kruber (JIRA)
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

[jira] [Commented] (FLINK-6293) Flakey JobManagerITCase

2017-04-11 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15964138#comment-15964138 ] Nico Kruber commented on FLINK-6293: Same here (with only the {{transfer.sh}} upload changed compared

[jira] [Updated] (FLINK-6293) Flakey JobManagerITCase

2017-04-11 Thread Nico Kruber (JIRA)
[ 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 >

[jira] [Created] (FLINK-6293) Flakey JobManagerITCase

2017-04-11 Thread Nico Kruber (JIRA)
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:

[jira] [Created] (FLINK-6329) refactor name-addressable accessors in BlobService classes from returning a URL to a File or InputStream

2017-04-19 Thread Nico Kruber (JIRA)
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:

[jira] [Created] (FLINK-6305) flink-ml tests are executed in all flink-fast-test profiles

2017-04-13 Thread Nico Kruber (JIRA)
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

[jira] [Updated] (FLINK-6287) Flakey JobManagerRegistrationTest

2017-04-18 Thread Nico Kruber (JIRA)
[ 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 >

[jira] [Created] (FLINK-6320) Flakey JobManagerHAJobGraphRecoveryITCase

2017-04-18 Thread Nico Kruber (JIRA)
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

[jira] [Updated] (FLINK-6293) Flakey JobManagerITCase

2017-04-18 Thread Nico Kruber (JIRA)
[ 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 > --- > >

[jira] [Created] (FLINK-6008) collection of BlobServer improvements

2017-03-09 Thread Nico Kruber (JIRA)
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

[jira] [Created] (FLINK-6005) unit test ArrayList initializations without default size

2017-03-09 Thread Nico Kruber (JIRA)
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

[jira] [Updated] (FLINK-6005) unit test ArrayList initializations without initial size

2017-03-09 Thread Nico Kruber (JIRA)
[ 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

[jira] [Updated] (FLINK-6005) unit test ArrayList initializations without initial size

2017-03-09 Thread Nico Kruber (JIRA)
[ 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

[jira] [Created] (FLINK-6046) Add support for oversized messages during deployment

2017-03-14 Thread Nico Kruber (JIRA)
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:

[jira] [Updated] (FLINK-6046) Add support for oversized messages during deployment

2017-03-14 Thread Nico Kruber (JIRA)
[ 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:

[jira] [Updated] (FLINK-6008) collection of BlobServer improvements

2017-03-10 Thread Nico Kruber (JIRA)
[ 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

[jira] [Commented] (FLINK-4545) Flink automatically manages TM network buffer

2017-03-14 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15924535#comment-15924535 ] Nico Kruber commented on FLINK-4545: We did some thinking and would probably add the following three

[jira] [Created] (FLINK-5973) check whether the direct memory size is always correctly calculated

2017-03-06 Thread Nico Kruber (JIRA)
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

[jira] [Created] (FLINK-6270) Port several network config parameters to ConfigOption

2017-04-06 Thread Nico Kruber (JIRA)
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:

[jira] [Commented] (FLINK-6292) Travis: transfer.sh not accepting uploads via http:// anymore

2017-04-17 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15971637#comment-15971637 ] Nico Kruber commented on FLINK-6292: does it make sense to cherry-pick this commit into the previous

[jira] [Commented] (FLINK-6292) Travis: transfer.sh not accepting uploads via http:// anymore

2017-04-18 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15972446#comment-15972446 ] Nico Kruber commented on FLINK-6292: oh, sorry, I'll double check next time before setting the

  1   2   3   4   >