[jira] [Created] (FLINK-4544) TaskManager metrics are vulnerable to custom JMX bean installation

Stephan Ewen created FLINK-4544: --- Summary: TaskManager metrics are vulnerable to custom JMX bean installation Key: FLINK-4544 URL: https://issues.apache.org/jira/browse/FLINK-4544 Project: Flink

[jira] [Resolved] (FLINK-4539) Duplicate/inconsistent logic for physical memory size in classes "Hardware" and "EnvironmentInformation"

[ https://issues.apache.org/jira/browse/FLINK-4539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4539. - Resolution: Fixed Fixed via 97a83a1fa62c06db19b09104d85c5e2bb850df0f > Duplicate/inconsistent log

[jira] [Closed] (FLINK-4539) Duplicate/inconsistent logic for physical memory size in classes "Hardware" and "EnvironmentInformation"

[ https://issues.apache.org/jira/browse/FLINK-4539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4539. --- > Duplicate/inconsistent logic for physical memory size in classes "Hardware" > and "EnvironmentInformati

[jira] [Commented] (FLINK-4536) Possible thread leak in Task Manager

[ https://issues.apache.org/jira/browse/FLINK-4536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15454916#comment-15454916 ] Stephan Ewen commented on FLINK-4536: - Okay, I looked through the thread dump - here i

[jira] [Commented] (FLINK-4536) Possible thread leak in Task Manager

[ https://issues.apache.org/jira/browse/FLINK-4536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15455016#comment-15455016 ] Stephan Ewen commented on FLINK-4536: - The number of threads suggests the InfluxDB sin

[jira] [Created] (FLINK-4566) ProducerFailedException does not properly preserve Exception causes

Stephan Ewen created FLINK-4566: --- Summary: ProducerFailedException does not properly preserve Exception causes Key: FLINK-4566 URL: https://issues.apache.org/jira/browse/FLINK-4566 Project: Flink

[jira] [Created] (FLINK-4567) Enhance SerializedThrowable to properly preserver cause chains

Stephan Ewen created FLINK-4567: --- Summary: Enhance SerializedThrowable to properly preserver cause chains Key: FLINK-4567 URL: https://issues.apache.org/jira/browse/FLINK-4567 Project: Flink I

[jira] [Resolved] (FLINK-4567) Enhance SerializedThrowable to properly preserver cause chains

[ https://issues.apache.org/jira/browse/FLINK-4567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4567. - Resolution: Fixed Fixed via 761d0a02505c7eaef7a566f978145b187c89cbf8 > Enhance SerializedThrowabl

[jira] [Closed] (FLINK-4567) Enhance SerializedThrowable to properly preserver cause chains

[ https://issues.apache.org/jira/browse/FLINK-4567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4567. --- > Enhance SerializedThrowable to properly preserver cause chains > ---

[jira] [Resolved] (FLINK-4490) Decouple Slot and Instance

[ https://issues.apache.org/jira/browse/FLINK-4490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4490. - Resolution: Fixed Assignee: Stephan Ewen Fixed as of eac6088a75e813a015b778f4cfc4cce0cf2a53c

[jira] [Closed] (FLINK-4490) Decouple Slot and Instance

[ https://issues.apache.org/jira/browse/FLINK-4490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4490. --- > Decouple Slot and Instance > -- > > Key: FLINK-4490 >

[jira] [Commented] (FLINK-4525) Drop the "eager split pre-assignment" code paths

[ https://issues.apache.org/jira/browse/FLINK-4525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15458851#comment-15458851 ] Stephan Ewen commented on FLINK-4525: - Addendum in fb8f2c935e96c9300a7584e310eb96e8a1f

[jira] [Closed] (FLINK-4566) ProducerFailedException does not properly preserve Exception causes

[ https://issues.apache.org/jira/browse/FLINK-4566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4566. --- > ProducerFailedException does not properly preserve Exception causes > --

[jira] [Resolved] (FLINK-4566) ProducerFailedException does not properly preserve Exception causes

[ https://issues.apache.org/jira/browse/FLINK-4566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4566. - Resolution: Fixed Fixed in - 1.2.0 via e227b10134e387f3c49804dc0cc4c223c30702e3 - 1.1.3 via f2

[jira] [Commented] (FLINK-3947) Provide low level access to RocksDB state backend

[ https://issues.apache.org/jira/browse/FLINK-3947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15459017#comment-15459017 ] Stephan Ewen commented on FLINK-3947: - [~elevy] I think we can approach this two ways

[jira] [Resolved] (FLINK-4459) Introduce SlotProvider for Scheduler

[ https://issues.apache.org/jira/browse/FLINK-4459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4459. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed via 6e40f59015dcdb8529691318e8f5a33e831252b8

[jira] [Closed] (FLINK-4459) Introduce SlotProvider for Scheduler

[ https://issues.apache.org/jira/browse/FLINK-4459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4459. --- > Introduce SlotProvider for Scheduler > > > Key: FLI

[jira] [Commented] (FLINK-4620) Automatically creating savepoints

[ https://issues.apache.org/jira/browse/FLINK-4620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15493397#comment-15493397 ] Stephan Ewen commented on FLINK-4620: - Adding [~uce] to this thread. There is a FLIP

[jira] [Created] (FLINK-4625) Guard Flink processes against blocking shutdown hooks

Stephan Ewen created FLINK-4625: --- Summary: Guard Flink processes against blocking shutdown hooks Key: FLINK-4625 URL: https://issues.apache.org/jira/browse/FLINK-4625 Project: Flink Issue Type:

[jira] [Commented] (FLINK-4632) when yarn nodemanager lost, flink hung

[ https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15502924#comment-15502924 ] Stephan Ewen commented on FLINK-4632: - It may happen that a TaskManager is lost / kill

[jira] [Commented] (FLINK-4513) Kafka connector documentation refers to Flink 1.1-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-4513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15504208#comment-15504208 ] Stephan Ewen commented on FLINK-4513: - The fix is to actually edit the Kafka section o

[jira] [Resolved] (FLINK-4625) Guard Flink processes against blocking shutdown hooks

[ https://issues.apache.org/jira/browse/FLINK-4625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4625. - Resolution: Fixed Fixed via 5066125f9a377d232f77f6fbcac3c22ebea66b39 > Guard Flink processes agai

[jira] [Created] (FLINK-4642) Remove unnecessary Guava dependency from flink-streaming-java

Stephan Ewen created FLINK-4642: --- Summary: Remove unnecessary Guava dependency from flink-streaming-java Key: FLINK-4642 URL: https://issues.apache.org/jira/browse/FLINK-4642 Project: Flink Is

[jira] [Commented] (FLINK-4640) Serialization of the initialValue of a Fold on WindowedStream fails

[ https://issues.apache.org/jira/browse/FLINK-4640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15507104#comment-15507104 ] Stephan Ewen commented on FLINK-4640: - I actually reproduced the error BOTH on the {{K

[jira] [Created] (FLINK-4645) Hard to register Kryo Serializers due to generics

Stephan Ewen created FLINK-4645: --- Summary: Hard to register Kryo Serializers due to generics Key: FLINK-4645 URL: https://issues.apache.org/jira/browse/FLINK-4645 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-4640) Serialization of the initialValue of a Fold on WindowedStream fails

[ https://issues.apache.org/jira/browse/FLINK-4640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15507323#comment-15507323 ] Stephan Ewen commented on FLINK-4640: - Okay, so the {{keyBy(1).fold(...)}} case can be

[jira] [Commented] (FLINK-4640) Serialization of the initialValue of a Fold on WindowedStream fails

[ https://issues.apache.org/jira/browse/FLINK-4640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15507442#comment-15507442 ] Stephan Ewen commented on FLINK-4640: - Have a fix and nice tests. Waiting for the CI t

[jira] [Commented] (FLINK-4645) Hard to register Kryo Serializers due to generics

[ https://issues.apache.org/jira/browse/FLINK-4645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15507572#comment-15507572 ] Stephan Ewen commented on FLINK-4645: - I think both methods have the same erasure (bin

[jira] [Commented] (FLINK-4644) Deprecate "flink.base.dir.path" from ConfigConstants

[ https://issues.apache.org/jira/browse/FLINK-4644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15507579#comment-15507579 ] Stephan Ewen commented on FLINK-4644: - It was initially used by the web frontend, IIRC

[jira] [Commented] (FLINK-4650) Frequent task manager disconnects from JobManager

[ https://issues.apache.org/jira/browse/FLINK-4650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15509268#comment-15509268 ] Stephan Ewen commented on FLINK-4650: - Can you describe what message you get? Do the A

[jira] [Commented] (FLINK-4632) when yarn nodemanager lost, flink hung

[ https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15509469#comment-15509469 ] Stephan Ewen commented on FLINK-4632: - Do you know which of the following two situatio

[jira] [Assigned] (FLINK-4640) Serialization of the initialValue of a Fold on WindowedStream fails

[ https://issues.apache.org/jira/browse/FLINK-4640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-4640: --- Assignee: Stephan Ewen > Serialization of the initialValue of a Fold on WindowedStream fails

[jira] [Updated] (FLINK-4651) Re-register processing time timers at the WindowOperator upon recovery.

[ https://issues.apache.org/jira/browse/FLINK-4651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-4651: Fix Version/s: 1.2.0 > Re-register processing time timers at the WindowOperator upon recovery. > ---

[jira] [Resolved] (FLINK-4640) Serialization of the initialValue of a Fold on WindowedStream fails

[ https://issues.apache.org/jira/browse/FLINK-4640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4640. - Resolution: Fixed Fixed in - 1.1.3 via 52a4440d916fb450c4999f6e1f42f392e247b426 - 1.2.0 via 4d

[jira] [Closed] (FLINK-4640) Serialization of the initialValue of a Fold on WindowedStream fails

[ https://issues.apache.org/jira/browse/FLINK-4640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4640. --- > Serialization of the initialValue of a Fold on WindowedStream fails > --

[jira] [Closed] (FLINK-4645) Hard to register Kryo Serializers due to generics

[ https://issues.apache.org/jira/browse/FLINK-4645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4645. --- > Hard to register Kryo Serializers due to generics > - >

[jira] [Resolved] (FLINK-4645) Hard to register Kryo Serializers due to generics

[ https://issues.apache.org/jira/browse/FLINK-4645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4645. - Resolution: Fixed Fixed via 82ef021cb8f77635bcec61d49eedce1ddefd1e48 > Hard to register Kryo Seri

[jira] [Commented] (FLINK-4650) Frequent task manager disconnects from JobManager

[ https://issues.apache.org/jira/browse/FLINK-4650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15512786#comment-15512786 ] Stephan Ewen commented on FLINK-4650: - Am I right in assuming that the TaskManager is

[jira] [Commented] (FLINK-4646) Add BipartiteGraph class

[ https://issues.apache.org/jira/browse/FLINK-4646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15512828#comment-15512828 ] Stephan Ewen commented on FLINK-4646: - [~greghogan] [~vkalavri] Copying you here. Are

[jira] [Commented] (FLINK-4661) Failure to find org.apache.flink:flink-runtime_2.10:jar:tests:1.2-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-4661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15512844#comment-15512844 ] Stephan Ewen commented on FLINK-4661: - What project is throwing that error? The test j

[jira] [Commented] (FLINK-4646) Add BipartiteGraph class

[ https://issues.apache.org/jira/browse/FLINK-4646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15512893#comment-15512893 ] Stephan Ewen commented on FLINK-4646: - Ah, I did not see that. Just thought that it wo

[jira] [Commented] (FLINK-3370) Add an aligned version of the window operator

[ https://issues.apache.org/jira/browse/FLINK-3370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15512900#comment-15512900 ] Stephan Ewen commented on FLINK-3370: - Think of a "pane" as the unit of slide, sou add

[jira] [Commented] (FLINK-4660) HadoopFileSystem (with S3A) may leak connections, which cause job to stuck in a restarting loop

[ https://issues.apache.org/jira/browse/FLINK-4660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15513227#comment-15513227 ] Stephan Ewen commented on FLINK-4660: - We looked through this a bit, and the problem m

[jira] [Commented] (FLINK-4218) Sporadic "java.lang.RuntimeException: Error triggering a checkpoint..." causes task restarting

[ https://issues.apache.org/jira/browse/FLINK-4218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15513234#comment-15513234 ] Stephan Ewen commented on FLINK-4218: - [~zhenzhongxu] Adding you to this conversation.

[jira] [Commented] (FLINK-4587) Yet another java.lang.NoSuchFieldError: INSTANCE

[ https://issues.apache.org/jira/browse/FLINK-4587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15513337#comment-15513337 ] Stephan Ewen commented on FLINK-4587: - It depends on which maven version you are using

[jira] [Closed] (FLINK-4603) KeyedStateBackend cannot restore user code classes

[ https://issues.apache.org/jira/browse/FLINK-4603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4603. --- > KeyedStateBackend cannot restore user code classes > --

[jira] [Resolved] (FLINK-4603) KeyedStateBackend cannot restore user code classes

[ https://issues.apache.org/jira/browse/FLINK-4603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4603. - Resolution: Fixed Fixed via 3b8fe95ec728d59e3ffba2901450c56d7cca2b24 > KeyedStateBackend cannot r

[jira] [Closed] (FLINK-4628) User class loader unavailable during input split assignment

[ https://issues.apache.org/jira/browse/FLINK-4628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4628. --- > User class loader unavailable during input split assignment > --

[jira] [Resolved] (FLINK-4628) User class loader unavailable during input split assignment

[ https://issues.apache.org/jira/browse/FLINK-4628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4628. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed via 345b2529a8acdd59d67e89ea930ec69ad69a55d3

[jira] [Commented] (FLINK-4596) RESTART_STRATEGY is not really pluggable

[ https://issues.apache.org/jira/browse/FLINK-4596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15515992#comment-15515992 ] Stephan Ewen commented on FLINK-4596: - Adding [~till.rohrmann] to this - he created th

[jira] [Commented] (FLINK-4660) HadoopFileSystem (with S3A) may leak connections, which cause job to stuck in a restarting loop

[ https://issues.apache.org/jira/browse/FLINK-4660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15515997#comment-15515997 ] Stephan Ewen commented on FLINK-4660: - It should have been fixed as of 2 days ago: ht

[jira] [Commented] (FLINK-4218) Sporadic "java.lang.RuntimeException: Error triggering a checkpoint..." causes task restarting

[ https://issues.apache.org/jira/browse/FLINK-4218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15516084#comment-15516084 ] Stephan Ewen commented on FLINK-4218: - Okay, I will take a stab at this... > Sporadic

[jira] [Resolved] (FLINK-4666) Make constants to be final in ParameterTool

[ https://issues.apache.org/jira/browse/FLINK-4666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4666. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed via 568845a3cfea1f6fe71a99f1f546cbd4d947fb33

[jira] [Closed] (FLINK-4666) Make constants to be final in ParameterTool

[ https://issues.apache.org/jira/browse/FLINK-4666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4666. --- > Make constants to be final in ParameterTool > --- > >

[jira] [Closed] (FLINK-4665) Remove boxing/unboxing to parse a primitive

[ https://issues.apache.org/jira/browse/FLINK-4665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4665. --- > Remove boxing/unboxing to parse a primitive > --- > >

[jira] [Resolved] (FLINK-4665) Remove boxing/unboxing to parse a primitive

[ https://issues.apache.org/jira/browse/FLINK-4665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4665. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in 37c9512fadb2b2ad6d3167b97d25fd00a2fa7620 T

[jira] [Resolved] (FLINK-4663) Flink JDBCOutputFormat logs wrong WARN message

[ https://issues.apache.org/jira/browse/FLINK-4663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4663. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in - 1.2.0 via 335a2826481725aabc86de8068909

[jira] [Closed] (FLINK-4663) Flink JDBCOutputFormat logs wrong WARN message

[ https://issues.apache.org/jira/browse/FLINK-4663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4663. --- > Flink JDBCOutputFormat logs wrong WARN message > -- > >

[jira] [Closed] (FLINK-4556) Make Queryable State Key-Group Aware

[ https://issues.apache.org/jira/browse/FLINK-4556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4556. --- > Make Queryable State Key-Group Aware > > > Key: FLI

[jira] [Resolved] (FLINK-4556) Make Queryable State Key-Group Aware

[ https://issues.apache.org/jira/browse/FLINK-4556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4556. - Resolution: Fixed Fix Version/s: 1.2.0 fixed in 181b54515ed2701a25d4a71fa7ed52394b2aeb66 >

[jira] [Commented] (FLINK-4218) Sporadic "java.lang.RuntimeException: Error triggering a checkpoint..." causes task restarting

[ https://issues.apache.org/jira/browse/FLINK-4218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15516309#comment-15516309 ] Stephan Ewen commented on FLINK-4218: - >From the Amazon docs, the issue that we run in

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

[ https://issues.apache.org/jira/browse/FLINK-4545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15905091#comment-15905091 ] Stephan Ewen commented on FLINK-4545: - Part two fixed in 11e2aa6dcdbf42992cda57a5b50d5

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

[ https://issues.apache.org/jira/browse/FLINK-4545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15905101#comment-15905101 ] Stephan Ewen commented on FLINK-4545: - [~greghogan] Sorry, just saw I never answered t

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

[ https://issues.apache.org/jira/browse/FLINK-4545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15905101#comment-15905101 ] Stephan Ewen edited comment on FLINK-4545 at 3/10/17 1:54 PM: --

[jira] [Resolved] (FLINK-5976) Refactoring duplicate Tokenizer in flink-test

[ https://issues.apache.org/jira/browse/FLINK-5976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5976. - Resolution: Fixed Fix Version/s: (was: 1.2.0) 1.3.0 Fixed in e5e6da0

[jira] [Closed] (FLINK-5980) Expose max-parallelism value in RuntimeContext

[ https://issues.apache.org/jira/browse/FLINK-5980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5980. --- > Expose max-parallelism value in RuntimeContext > -- > >

[jira] [Closed] (FLINK-5976) Refactoring duplicate Tokenizer in flink-test

[ https://issues.apache.org/jira/browse/FLINK-5976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5976. --- > Refactoring duplicate Tokenizer in flink-test > - > >

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

[ https://issues.apache.org/jira/browse/FLINK-6005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-6005. - Resolution: Fixed Fix Version/s: 1.3.0 Fixed via bb1197d9162a630c87d47defc5d0c42de6726feb

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

[ https://issues.apache.org/jira/browse/FLINK-6005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-6005. --- > unit test ArrayList initializations without initial size > -

[jira] [Updated] (FLINK-5756) When there are many values under the same key in ListState, RocksDBStateBackend performances poor

[ https://issues.apache.org/jira/browse/FLINK-5756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-5756: Description: When using RocksDB as the StateBackend, if there are many values under the same key in

[jira] [Commented] (FLINK-5756) When there are many values under the same key in ListState, RocksDBStateBackend performances poor

[ https://issues.apache.org/jira/browse/FLINK-5756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15922909#comment-15922909 ] Stephan Ewen commented on FLINK-5756: - Thanks for opening this and sharing the test re

[jira] [Comment Edited] (FLINK-5756) When there are many values under the same key in ListState, RocksDBStateBackend performances poor

[ https://issues.apache.org/jira/browse/FLINK-5756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15922909#comment-15922909 ] Stephan Ewen edited comment on FLINK-5756 at 3/13/17 8:52 PM: --

[jira] [Comment Edited] (FLINK-5756) When there are many values under the same key in ListState, RocksDBStateBackend performances poor

[ https://issues.apache.org/jira/browse/FLINK-5756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15922909#comment-15922909 ] Stephan Ewen edited comment on FLINK-5756 at 3/13/17 8:52 PM: --

[jira] [Commented] (FLINK-5756) When there are many values under the same key in ListState, RocksDBStateBackend performances poor

[ https://issues.apache.org/jira/browse/FLINK-5756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15924109#comment-15924109 ] Stephan Ewen commented on FLINK-5756: - I raised the issue at RocksDB: https://github.c

[jira] [Commented] (FLINK-2263) ExecutionGraph uses Thread.sleep to delay execution retries

[ https://issues.apache.org/jira/browse/FLINK-2263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15924112#comment-15924112 ] Stephan Ewen commented on FLINK-2263: - I think this is not super critical any more, be

[jira] [Commented] (FLINK-5756) When there are many values under the same key in ListState, RocksDBStateBackend performances poor

[ https://issues.apache.org/jira/browse/FLINK-5756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15924537#comment-15924537 ] Stephan Ewen commented on FLINK-5756: - I would suggest to see if we get a response fro

[jira] [Resolved] (FLINK-6010) Documentation: correct IntelliJ IDEA Plugins path in 'Installing the Scala plugin' section

[ https://issues.apache.org/jira/browse/FLINK-6010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-6010. - Resolution: Fixed Fix Version/s: (was: 1.2.1) 1.3.0 Fixed via a87b52

[jira] [Closed] (FLINK-6010) Documentation: correct IntelliJ IDEA Plugins path in 'Installing the Scala plugin' section

[ https://issues.apache.org/jira/browse/FLINK-6010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-6010. --- > Documentation: correct IntelliJ IDEA Plugins path in 'Installing the Scala > plugin' section >

[jira] [Assigned] (FLINK-5962) Cancel checkpoint canceller tasks in CheckpointCoordinator

[ https://issues.apache.org/jira/browse/FLINK-5962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-5962: --- Assignee: Stephan Ewen > Cancel checkpoint canceller tasks in CheckpointCoordinator > ---

[jira] [Commented] (FLINK-5756) When there are many values under the same key in ListState, RocksDBStateBackend performances poor

[ https://issues.apache.org/jira/browse/FLINK-5756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15926599#comment-15926599 ] Stephan Ewen commented on FLINK-5756: - [~SyinchwunLeo] I tried the variant of manual g

[jira] [Commented] (FLINK-5756) When there are many values under the same key in ListState, RocksDBStateBackend performances poor

[ https://issues.apache.org/jira/browse/FLINK-5756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15926662#comment-15926662 ] Stephan Ewen commented on FLINK-5756: - Just validated that compactions actually help,

[jira] [Commented] (FLINK-6044) TypeSerializerSerializationProxy.read() doesn't verify the read buffer length

[ https://issues.apache.org/jira/browse/FLINK-6044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15926779#comment-15926779 ] Stephan Ewen commented on FLINK-6044: - [~srichter] I think we should try and safeguard

[jira] [Commented] (FLINK-6044) TypeSerializerSerializationProxy.read() doesn't verify the read buffer length

[ https://issues.apache.org/jira/browse/FLINK-6044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15926785#comment-15926785 ] Stephan Ewen commented on FLINK-6044: - The {{read()}} / {{readFully()}} issue has occu

[jira] [Commented] (FLINK-5962) Cancel checkpoint canceller tasks in CheckpointCoordinator

[ https://issues.apache.org/jira/browse/FLINK-5962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15926812#comment-15926812 ] Stephan Ewen commented on FLINK-5962: - Fixed in 1.2 via 9d59e008d8849cdfe2daf302e25145

[jira] [Created] (FLINK-6071) Savepoints should not count in the number of retained checkpoints

Stephan Ewen created FLINK-6071: --- Summary: Savepoints should not count in the number of retained checkpoints Key: FLINK-6071 URL: https://issues.apache.org/jira/browse/FLINK-6071 Project: Flink

[jira] [Commented] (FLINK-5668) passing taskmanager configuration through taskManagerEnv instead of file

[ https://issues.apache.org/jira/browse/FLINK-5668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927823#comment-15927823 ] Stephan Ewen commented on FLINK-5668: - [~bill.liu8904] Okay, I see. This is a bigger c

[jira] [Commented] (FLINK-5048) Kafka Consumer (0.9/0.10) threading model leads problematic cancellation behavior

[ https://issues.apache.org/jira/browse/FLINK-5048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927941#comment-15927941 ] Stephan Ewen commented on FLINK-5048: - Sorry to come late here. The fix did not change

[jira] [Commented] (FLINK-6074) Fix processFunction with watermark not work well in tableAPI

[ https://issues.apache.org/jira/browse/FLINK-6074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15928046#comment-15928046 ] Stephan Ewen commented on FLINK-6074: - Some more details would help here ;-) > Fix pr

[jira] [Commented] (FLINK-5756) When there are many values under the same key in ListState, RocksDBStateBackend performances poor

[ https://issues.apache.org/jira/browse/FLINK-5756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15928115#comment-15928115 ] Stephan Ewen commented on FLINK-5756: - We have found an approach in RocksDB that may i

[jira] [Commented] (FLINK-5756) When there are many values under the same key in ListState, RocksDBStateBackend performances poor

[ https://issues.apache.org/jira/browse/FLINK-5756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15928117#comment-15928117 ] Stephan Ewen commented on FLINK-5756: - Added a mini-benchmark for 'list operations' on

[jira] [Closed] (FLINK-5692) Add an Option to Deactivate Kryo Fallback for Serializers

[ https://issues.apache.org/jira/browse/FLINK-5692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5692. --- > Add an Option to Deactivate Kryo Fallback for Serializers >

[jira] [Closed] (FLINK-5962) Cancel checkpoint canceller tasks in CheckpointCoordinator

[ https://issues.apache.org/jira/browse/FLINK-5962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5962. --- > Cancel checkpoint canceller tasks in CheckpointCoordinator > ---

[jira] [Resolved] (FLINK-5962) Cancel checkpoint canceller tasks in CheckpointCoordinator

[ https://issues.apache.org/jira/browse/FLINK-5962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5962. - Resolution: Fixed Fix Version/s: 1.2.1 1.3.0 Fixed in - 1.3.0 via 7025

[jira] [Commented] (FLINK-4421) Make clocks and time measurements monotonous

[ https://issues.apache.org/jira/browse/FLINK-4421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15928125#comment-15928125 ] Stephan Ewen commented on FLINK-4421: - Fixed in {{flink-clients}} in 6b5e1f68a9b78901f

[jira] [Resolved] (FLINK-4754) Make number of retained checkpoints user configurable

[ https://issues.apache.org/jira/browse/FLINK-4754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4754. - Resolution: Fixed Fix Version/s: 1.3.0 Fixed via b46f5e050bdd77fe6e501bad20466d8777218131

[jira] [Resolved] (FLINK-5692) Add an Option to Deactivate Kryo Fallback for Serializers

[ https://issues.apache.org/jira/browse/FLINK-5692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5692. - Resolution: Fixed Fix Version/s: 1.3.0 Fixed in 0f99aae1e1f8b693c2ba79a061046bc042113f0b wi

[jira] [Closed] (FLINK-4754) Make number of retained checkpoints user configurable

[ https://issues.apache.org/jira/browse/FLINK-4754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4754. --- > Make number of retained checkpoints user configurable >

[jira] [Closed] (FLINK-6041) Move StreamingFunctionUtils to 'org.apache.flink.streaming.util'

[ https://issues.apache.org/jira/browse/FLINK-6041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-6041. --- > Move StreamingFunctionUtils to 'org.apache.flink.streaming.util' > -

[jira] [Resolved] (FLINK-6041) Move StreamingFunctionUtils to 'org.apache.flink.streaming.util'

[ https://issues.apache.org/jira/browse/FLINK-6041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-6041. - Resolution: Fixed Fix Version/s: (was: 2.0.0) 1.3.0 Fixed via 03889a

[jira] [Resolved] (FLINK-6009) Deprecate DataSetUtils#checksumHashCode

[ https://issues.apache.org/jira/browse/FLINK-6009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-6009. - Resolution: Fixed Fixed via 40a156e4974c942b021d20edb78b95c8bf261972 > Deprecate DataSetUtils#che

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