[jira] [Created] (FLINK-3706) YARNSessionCapacitySchedulerITCase.testNonexistingQueue unstable

Aljoscha Krettek created FLINK-3706: --- Summary: YARNSessionCapacitySchedulerITCase.testNonexistingQueue unstable Key: FLINK-3706 URL: https://issues.apache.org/jira/browse/FLINK-3706 Project: Flink

[jira] [Updated] (FLINK-3706) YARNSessionCapacitySchedulerITCase.testNonexistingQueue unstable

[ https://issues.apache.org/jira/browse/FLINK-3706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-3706: Attachment: log.txt > YARNSessionCapacitySchedulerITCase.testNonexistingQueue unstable > ---

[jira] [Resolved] (FLINK-3637) Change RollingSink Writer interface to allow wider range of outputs

[ https://issues.apache.org/jira/browse/FLINK-3637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-3637. - Resolution: Fixed Fix Version/s: 1.1.0 Implemented in https://github.com/apache/fl

[jira] [Resolved] (FLINK-3711) Scala fold() example syntax incorrect

[ https://issues.apache.org/jira/browse/FLINK-3711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-3711. - Resolution: Fixed Fixed in https://github.com/apache/flink/commit/e5b93da0eda610e163a5d4a

[jira] [Updated] (FLINK-3713) DisposeSavepoint message uses system classloader to discard state

[ https://issues.apache.org/jira/browse/FLINK-3713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-3713: Description: The {{DisposeSavepoint}} message in the JobManager is using the system classlo

[jira] [Resolved] (FLINK-3654) Disable Write-Ahead-Log in RocksDB State

[ https://issues.apache.org/jira/browse/FLINK-3654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-3654. - Resolution: Fixed Fix Version/s: 1.1.0 Changed in https://github.com/apache/flink/

[jira] [Updated] (FLINK-3643) Improve Windowing

[ https://issues.apache.org/jira/browse/FLINK-3643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-3643: Summary: Improve Windowing (was: Improve Window Triggers) > Improve Windowing > ---

[jira] [Updated] (FLINK-3643) Improve Windowing

[ https://issues.apache.org/jira/browse/FLINK-3643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-3643: Description: I think there are several shortcomings in the current window system and I star

[jira] [Created] (FLINK-3714) Add Support for "Allowed Lateness"

Aljoscha Krettek created FLINK-3714: --- Summary: Add Support for "Allowed Lateness" Key: FLINK-3714 URL: https://issues.apache.org/jira/browse/FLINK-3714 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-3715) Move Accumulating/Discarding from Trigger to WindowOperator

Aljoscha Krettek created FLINK-3715: --- Summary: Move Accumulating/Discarding from Trigger to WindowOperator Key: FLINK-3715 URL: https://issues.apache.org/jira/browse/FLINK-3715 Project: Flink

[jira] [Created] (FLINK-3718) Add Option For Completely Async Backup in RocksDB State Backend

Aljoscha Krettek created FLINK-3718: --- Summary: Add Option For Completely Async Backup in RocksDB State Backend Key: FLINK-3718 URL: https://issues.apache.org/jira/browse/FLINK-3718 Project: Flink

[jira] [Resolved] (FLINK-3688) ClassCastException in StreamRecordSerializer when WindowOperator.trigger() is called and TimeCharacteristic = ProcessingTime

[ https://issues.apache.org/jira/browse/FLINK-3688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-3688. - Resolution: Fixed Fix Version/s: 1.0.2 Fixed in https://github.com/apache/flink/co

[jira] [Commented] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask

[ https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15234552#comment-15234552 ] Aljoscha Krettek commented on FLINK-3669: - Hi, I'll be looking at your code today.

[jira] [Created] (FLINK-3730) Fix RocksDB Local Directory Initialization

Aljoscha Krettek created FLINK-3730: --- Summary: Fix RocksDB Local Directory Initialization Key: FLINK-3730 URL: https://issues.apache.org/jira/browse/FLINK-3730 Project: Flink Issue Type: Bu

[jira] [Commented] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask

[ https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15236970#comment-15236970 ] Aljoscha Krettek commented on FLINK-3669: - Hi, I finally had a look at your code.

[jira] [Updated] (FLINK-3581) Add Special Aligned Event-Time WindowOperator

[ https://issues.apache.org/jira/browse/FLINK-3581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-3581: Summary: Add Special Aligned Event-Time WindowOperator (was: Add Non-Keyed Window Trigger )

[jira] [Commented] (FLINK-3581) Add Special Aligned Event-Time WindowOperator

[ https://issues.apache.org/jira/browse/FLINK-3581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15236977#comment-15236977 ] Aljoscha Krettek commented on FLINK-3581: - I decided to change the scope of this i

[jira] [Created] (FLINK-3740) Session Window State is Not Checkpointed

Aljoscha Krettek created FLINK-3740: --- Summary: Session Window State is Not Checkpointed Key: FLINK-3740 URL: https://issues.apache.org/jira/browse/FLINK-3740 Project: Flink Issue Type: Bug

[jira] [Resolved] (FLINK-3730) Fix RocksDB Local Directory Initialization

[ https://issues.apache.org/jira/browse/FLINK-3730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-3730. - Resolution: Fixed Fix Version/s: 1.0.2 1.1.0 Fixed in https://g

[jira] [Commented] (FLINK-3738) Refactor TableEnvironment and TranslationContext

[ https://issues.apache.org/jira/browse/FLINK-3738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15238864#comment-15238864 ] Aljoscha Krettek commented on FLINK-3738: - What do you mean by this? "DataSet and

[jira] [Created] (FLINK-3747) Consolidate TimestampAssigner Methods in Kafka Consumer

Aljoscha Krettek created FLINK-3747: --- Summary: Consolidate TimestampAssigner Methods in Kafka Consumer Key: FLINK-3747 URL: https://issues.apache.org/jira/browse/FLINK-3747 Project: Flink I

[jira] [Assigned] (FLINK-3747) Consolidate TimestampAssigner Methods in Kafka Consumer

[ https://issues.apache.org/jira/browse/FLINK-3747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-3747: --- Assignee: Aljoscha Krettek > Consolidate TimestampAssigner Methods in Kafka Consumer

[jira] [Commented] (FLINK-3747) Consolidate TimestampAssigner Methods in Kafka Consumer

[ https://issues.apache.org/jira/browse/FLINK-3747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15238947#comment-15238947 ] Aljoscha Krettek commented on FLINK-3747: - will do > Consolidate TimestampAssign

[jira] [Commented] (FLINK-3738) Refactor TableEnvironment and TranslationContext

[ https://issues.apache.org/jira/browse/FLINK-3738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15238995#comment-15238995 ] Aljoscha Krettek commented on FLINK-3738: - Why not {{tEnv.fromDataSet(DataSet)}} t

[jira] [Commented] (FLINK-3738) Refactor TableEnvironment and TranslationContext

[ https://issues.apache.org/jira/browse/FLINK-3738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15239000#comment-15239000 ] Aljoscha Krettek commented on FLINK-3738: - The reason I'm saying this is that the

[jira] [Commented] (FLINK-3738) Refactor TableEnvironment and TranslationContext

[ https://issues.apache.org/jira/browse/FLINK-3738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15239011#comment-15239011 ] Aljoscha Krettek commented on FLINK-3738: - Ah ok, I see. > Refactor TableEnvironm

[jira] [Commented] (FLINK-3750) Make JDBCInputFormat a parallel source

[ https://issues.apache.org/jira/browse/FLINK-3750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15239331#comment-15239331 ] Aljoscha Krettek commented on FLINK-3750: - +1, this would be a good addition. > M

[jira] [Commented] (FLINK-3751) default Operator names are inconsistent

[ https://issues.apache.org/jira/browse/FLINK-3751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15239333#comment-15239333 ] Aljoscha Krettek commented on FLINK-3751: - +1 > default Operator names are incons

[jira] [Commented] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask

[ https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15241151#comment-15241151 ] Aljoscha Krettek commented on FLINK-3669: - No worries, we all have plenty to do. :

[jira] [Created] (FLINK-3760) Fix StateDescriptor.readObject

Aljoscha Krettek created FLINK-3760: --- Summary: Fix StateDescriptor.readObject Key: FLINK-3760 URL: https://issues.apache.org/jira/browse/FLINK-3760 Project: Flink Issue Type: Bug

[jira] [Resolved] (FLINK-3760) Fix StateDescriptor.readObject

[ https://issues.apache.org/jira/browse/FLINK-3760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-3760. - Resolution: Fixed Fixed in https://github.com/apache/flink/commit/494212b37b64b45cd777cc0

[jira] [Commented] (FLINK-3708) Scala API for CEP

[ https://issues.apache.org/jira/browse/FLINK-3708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15249561#comment-15249561 ] Aljoscha Krettek commented on FLINK-3708: - I think it was required because we cann

[jira] [Commented] (FLINK-3785) Add REST resource to query information about checkpointing

[ https://issues.apache.org/jira/browse/FLINK-3785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15249565#comment-15249565 ] Aljoscha Krettek commented on FLINK-3785: - [~uce] should this already be there, or

[jira] [Commented] (FLINK-3758) Add possibility to register accumulators in custom triggers

[ https://issues.apache.org/jira/browse/FLINK-3758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15249718#comment-15249718 ] Aljoscha Krettek commented on FLINK-3758: - Yes, I think it should work but we woul

[jira] [Commented] (FLINK-3790) Rolling File sink does not pick up hadoop configuration

[ https://issues.apache.org/jira/browse/FLINK-3790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15249908#comment-15249908 ] Aljoscha Krettek commented on FLINK-3790: - You're right, this should probably use

[jira] [Resolved] (FLINK-3718) Add Option For Completely Async Backup in RocksDB State Backend

[ https://issues.apache.org/jira/browse/FLINK-3718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-3718. - Resolution: Fixed Fix Version/s: 1.1.0 Implemented in https://github.com/apache/fl

[jira] [Commented] (FLINK-3792) RowTypeInfo equality should not depend on field names

[ https://issues.apache.org/jira/browse/FLINK-3792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15250012#comment-15250012 ] Aljoscha Krettek commented on FLINK-3792: - What would be the field names (and type

[jira] [Commented] (FLINK-3796) FileSourceFunction doesn't respect InputFormat's life cycle methods

[ https://issues.apache.org/jira/browse/FLINK-3796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15251550#comment-15251550 ] Aljoscha Krettek commented on FLINK-3796: - I think [~kkl0u] is currently working o

[jira] [Commented] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask

[ https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15253601#comment-15253601 ] Aljoscha Krettek commented on FLINK-3669: - I'm checking it out. > WindowOperator

[jira] [Commented] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask

[ https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15253604#comment-15253604 ] Aljoscha Krettek commented on FLINK-3669: - Btw, in the future if you reference me

[jira] [Commented] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask

[ https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15253666#comment-15253666 ] Aljoscha Krettek commented on FLINK-3669: - Hi, it's almost done but I think we nee

[jira] [Created] (FLINK-3803) Checkpoint Stats Tracker Reads from Wrong Configuration

Aljoscha Krettek created FLINK-3803: --- Summary: Checkpoint Stats Tracker Reads from Wrong Configuration Key: FLINK-3803 URL: https://issues.apache.org/jira/browse/FLINK-3803 Project: Flink I

[jira] [Resolved] (FLINK-3740) Session Window State is Not Checkpointed

[ https://issues.apache.org/jira/browse/FLINK-3740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-3740. - Resolution: Fixed Fixed in https://github.com/apache/flink/commit/f2f5bd5bed2f737b8418be0

[jira] [Commented] (FLINK-3803) Checkpoint Stats Tracker Reads from Wrong Configuration

[ https://issues.apache.org/jira/browse/FLINK-3803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15256195#comment-15256195 ] Aljoscha Krettek commented on FLINK-3803: - I talked to [~trohrm...@apache.org] abo

[jira] [Commented] (FLINK-3806) Revert use of DataSet.count() in Gelly

[ https://issues.apache.org/jira/browse/FLINK-3806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15256433#comment-15256433 ] Aljoscha Krettek commented on FLINK-3806: - Correct, I think the {{count()}}/{{coll

[jira] [Commented] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask

[ https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15260086#comment-15260086 ] Aljoscha Krettek commented on FLINK-3669: - Thanks! I'll have a look at your branch

[jira] [Commented] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask

[ https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15260171#comment-15260171 ] Aljoscha Krettek commented on FLINK-3669: - I think we have a winner now :-) Could

[jira] [Assigned] (FLINK-3840) RocksDB local parent dir is polluted with empty folders with random names

[ https://issues.apache.org/jira/browse/FLINK-3840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-3840: --- Assignee: Aljoscha Krettek > RocksDB local parent dir is polluted with empty folders

[jira] [Commented] (FLINK-3841) RocksDB statebackend creates empty dbs for stateless operators

[ https://issues.apache.org/jira/browse/FLINK-3841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15261719#comment-15261719 ] Aljoscha Krettek commented on FLINK-3841: - You're absolutely right. Should probabl

[jira] [Updated] (FLINK-3841) RocksDB statebackend creates empty dbs for stateless operators

[ https://issues.apache.org/jira/browse/FLINK-3841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-3841: Affects Version/s: 1.1.0 > RocksDB statebackend creates empty dbs for stateless operators >

[jira] [Updated] (FLINK-3840) RocksDB local parent dir is polluted with empty folders with random names

[ https://issues.apache.org/jira/browse/FLINK-3840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-3840: Affects Version/s: 1.1.0 1.0.0 1.0.1

[jira] [Commented] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask

[ https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15261744#comment-15261744 ] Aljoscha Krettek commented on FLINK-3669: - Thanks! Once you open the PR I will wri

[jira] [Commented] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask

[ https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15262013#comment-15262013 ] Aljoscha Krettek commented on FLINK-3669: - Thanks :-) Quick remark: if you include

[jira] [Resolved] (FLINK-3840) RocksDB local parent dir is polluted with empty folders with random names

[ https://issues.apache.org/jira/browse/FLINK-3840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-3840. - Resolution: Fixed Fix Version/s: 1.0.3 1.1.0 Fixed in https://g

[jira] [Commented] (FLINK-3841) RocksDB statebackend creates empty dbs for stateless operators

[ https://issues.apache.org/jira/browse/FLINK-3841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263942#comment-15263942 ] Aljoscha Krettek commented on FLINK-3841: - I would do it next week... ;-) > Rocks

[jira] [Commented] (FLINK-3844) Checkpoint failures should not always lead to job failures

[ https://issues.apache.org/jira/browse/FLINK-3844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263946#comment-15263946 ] Aljoscha Krettek commented on FLINK-3844: - +1, we could have something similar to

[jira] [Commented] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask

[ https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263974#comment-15263974 ] Aljoscha Krettek commented on FLINK-3669: - Ah, in the custom trigger the {{oldTime

[jira] [Commented] (FLINK-3404) Extend Kafka consumers with interface StoppableFunction

[ https://issues.apache.org/jira/browse/FLINK-3404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15265376#comment-15265376 ] Aljoscha Krettek commented on FLINK-3404: - I think implementing atomic checkpoint-

[jira] [Commented] (FLINK-3855) Upgrade Jackson version

[ https://issues.apache.org/jira/browse/FLINK-3855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15266149#comment-15266149 ] Aljoscha Krettek commented on FLINK-3855: - I think this is good. Your PR link seem

[jira] [Commented] (FLINK-3855) Upgrade Jackson version

[ https://issues.apache.org/jira/browse/FLINK-3855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15266265#comment-15266265 ] Aljoscha Krettek commented on FLINK-3855: - Never mind, the link seems to be workin

[jira] [Commented] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask

[ https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15266509#comment-15266509 ] Aljoscha Krettek commented on FLINK-3669: - Is the problem gone with changing this?

[jira] [Commented] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask

[ https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15268419#comment-15268419 ] Aljoscha Krettek commented on FLINK-3669: - Ok, I think it's good to merge then. :-

[jira] [Commented] (FLINK-3860) WikipediaEditsSourceTest.testWikipediaEditsSource times out

[ https://issues.apache.org/jira/browse/FLINK-3860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15268555#comment-15268555 ] Aljoscha Krettek commented on FLINK-3860: - +1 > WikipediaEditsSourceTest.testWiki

[jira] [Commented] (FLINK-3404) Extend Kafka consumers with interface StoppableFunction

[ https://issues.apache.org/jira/browse/FLINK-3404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15268558#comment-15268558 ] Aljoscha Krettek commented on FLINK-3404: - In some way, yes. > Extend Kafka consu

[jira] [Resolved] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask

[ https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-3669. - Resolution: Fixed Fix Version/s: 1.1.0 Fixed in https://github.com/apache/flink/co

[jira] [Assigned] (FLINK-3860) WikipediaEditsSourceTest.testWikipediaEditsSource times out

[ https://issues.apache.org/jira/browse/FLINK-3860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-3860: --- Assignee: Aljoscha Krettek (was: Ufuk Celebi) > WikipediaEditsSourceTest.testWikiped

[jira] [Created] (FLINK-3869) WindowedStream.apply with FoldFunction is too restrictive

Aljoscha Krettek created FLINK-3869: --- Summary: WindowedStream.apply with FoldFunction is too restrictive Key: FLINK-3869 URL: https://issues.apache.org/jira/browse/FLINK-3869 Project: Flink

[jira] [Commented] (FLINK-3883) Rename flink clients for inclusion on system path

[ https://issues.apache.org/jira/browse/FLINK-3883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276130#comment-15276130 ] Aljoscha Krettek commented on FLINK-3883: - +1 The symlink thing should be fixed qu

[jira] [Commented] (FLINK-3758) Add possibility to register accumulators in custom triggers

[ https://issues.apache.org/jira/browse/FLINK-3758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276351#comment-15276351 ] Aljoscha Krettek commented on FLINK-3758: - I'm looking at it. :-) > Add possibili

[jira] [Commented] (FLINK-3758) Add possibility to register accumulators in custom triggers

[ https://issues.apache.org/jira/browse/FLINK-3758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276356#comment-15276356 ] Aljoscha Krettek commented on FLINK-3758: - Please open a PR. The changes look good

[jira] [Comment Edited] (FLINK-3758) Add possibility to register accumulators in custom triggers

[ https://issues.apache.org/jira/browse/FLINK-3758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276356#comment-15276356 ] Aljoscha Krettek edited comment on FLINK-3758 at 5/9/16 1:29 PM: ---

[jira] [Commented] (FLINK-3889) Make File Monitoring Function checkpointable.

[ https://issues.apache.org/jira/browse/FLINK-3889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15281342#comment-15281342 ] Aljoscha Krettek commented on FLINK-3889: - Isn't this a duplicate of FLINK-2314, w

[jira] [Commented] (FLINK-3897) why does jobmanager process has too many ForkJoinTask object

[ https://issues.apache.org/jira/browse/FLINK-3897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15281352#comment-15281352 ] Aljoscha Krettek commented on FLINK-3897: - What are the {{ForkJoinTasks}} used for

[jira] [Commented] (FLINK-3889) Make File Monitoring Function checkpointable.

[ https://issues.apache.org/jira/browse/FLINK-3889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15281358#comment-15281358 ] Aljoscha Krettek commented on FLINK-3889: - Ok, I see. Maybe FLINK-3808 is redundan

[jira] [Commented] (FLINK-3889) Make File Monitoring Function checkpointable.

[ https://issues.apache.org/jira/browse/FLINK-3889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15281380#comment-15281380 ] Aljoscha Krettek commented on FLINK-3889: - Thanks, trying to keep a tight ship in

[jira] [Commented] (FLINK-3918) Not configuring any time characteristic leads to a ClassCastException

[ https://issues.apache.org/jira/browse/FLINK-3918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15286624#comment-15286624 ] Aljoscha Krettek commented on FLINK-3918: - What we could also do is get rid of the

[jira] [Commented] (FLINK-2144) Incremental count, average, and variance for windows

[ https://issues.apache.org/jira/browse/FLINK-2144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15293562#comment-15293562 ] Aljoscha Krettek commented on FLINK-2144: - I think this can easily be done by user

[jira] [Commented] (FLINK-2144) Incremental count, average, and variance for windows

[ https://issues.apache.org/jira/browse/FLINK-2144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15293609#comment-15293609 ] Aljoscha Krettek commented on FLINK-2144: - Right now we don't really have place in

[jira] [Assigned] (FLINK-3344) EventTimeWindowCheckpointingITCase.testPreAggregatedTumblingTimeWindow

[ https://issues.apache.org/jira/browse/FLINK-3344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-3344: --- Assignee: Aljoscha Krettek > EventTimeWindowCheckpointingITCase.testPreAggregatedTumb

[jira] [Created] (FLINK-3948) EventTimeWindowCheckpointingITCase Fails with Core Dump

Aljoscha Krettek created FLINK-3948: --- Summary: EventTimeWindowCheckpointingITCase Fails with Core Dump Key: FLINK-3948 URL: https://issues.apache.org/jira/browse/FLINK-3948 Project: Flink I

[jira] [Commented] (FLINK-3948) EventTimeWindowCheckpointingITCase Fails with Core Dump

[ https://issues.apache.org/jira/browse/FLINK-3948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15294781#comment-15294781 ] Aljoscha Krettek commented on FLINK-3948: - RocksDB seems to be somewhat sensitive

[jira] [Commented] (FLINK-2144) Incremental count, average, and variance for windows

[ https://issues.apache.org/jira/browse/FLINK-2144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15294791#comment-15294791 ] Aljoscha Krettek commented on FLINK-2144: - We could provide pre-made FoldFunctions

[jira] [Commented] (FLINK-3946) State API Should Support Data Expiration

[ https://issues.apache.org/jira/browse/FLINK-3946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15294795#comment-15294795 ] Aljoscha Krettek commented on FLINK-3946: - I thought about this when adding the {{

[jira] [Commented] (FLINK-3582) Add Iterator over State for All Keys in Partitioned State

[ https://issues.apache.org/jira/browse/FLINK-3582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15294806#comment-15294806 ] Aljoscha Krettek commented on FLINK-3582: - This is addressed in this PR: https://g

[jira] [Comment Edited] (FLINK-3582) Add Iterator over State for All Keys in Partitioned State

[ https://issues.apache.org/jira/browse/FLINK-3582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15294806#comment-15294806 ] Aljoscha Krettek edited comment on FLINK-3582 at 5/21/16 7:03 AM: --

[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=15294810#comment-15294810 ] Aljoscha Krettek commented on FLINK-3947: - There is already this: FLINK-3582 which

[jira] [Updated] (FLINK-3956) Make FileInputFormats independent from Configuration

[ https://issues.apache.org/jira/browse/FLINK-3956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-3956: Summary: Make FileInputFormats independent from Configuration (was: Make FileInputFormats i

[jira] [Commented] (FLINK-3956) Make FileInputFormats independent from Configuration

[ https://issues.apache.org/jira/browse/FLINK-3956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15296471#comment-15296471 ] Aljoscha Krettek commented on FLINK-3956: - The title very exactly specified what w

[jira] [Commented] (FLINK-3959) Remove implicit sinks

[ https://issues.apache.org/jira/browse/FLINK-3959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15296475#comment-15296475 ] Aljoscha Krettek commented on FLINK-3959: - We should think about this. Most other

[jira] [Commented] (FLINK-3758) Add possibility to register accumulators in custom triggers

[ https://issues.apache.org/jira/browse/FLINK-3758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15298074#comment-15298074 ] Aljoscha Krettek commented on FLINK-3758: - [~knaufk], we might have to reconsider

[jira] [Commented] (FLINK-3758) Add possibility to register accumulators in custom triggers

[ https://issues.apache.org/jira/browse/FLINK-3758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15298079#comment-15298079 ] Aljoscha Krettek commented on FLINK-3758: - The issue for the monitoring is this on

[jira] [Closed] (FLINK-3968) Cancel button on a running job not available on smaller screens

[ https://issues.apache.org/jira/browse/FLINK-3968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-3968. --- Resolution: Duplicate > Cancel button on a running job not available on smaller screens >

[jira] [Created] (FLINK-3969) Log Exceptions Thrown by Invokable

Aljoscha Krettek created FLINK-3969: --- Summary: Log Exceptions Thrown by Invokable Key: FLINK-3969 URL: https://issues.apache.org/jira/browse/FLINK-3969 Project: Flink Issue Type: Improvemen

[jira] [Commented] (FLINK-3969) Log Exceptions Thrown by Invokable

[ https://issues.apache.org/jira/browse/FLINK-3969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15299766#comment-15299766 ] Aljoscha Krettek commented on FLINK-3969: - ML archive of the thread: http://apach

[jira] [Commented] (FLINK-1673) Colocate Flink Kafka consumer

[ https://issues.apache.org/jira/browse/FLINK-1673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1535#comment-1535 ] Aljoscha Krettek commented on FLINK-1673: - [~rmetzger] is this still relevant or c

[jira] [Closed] (FLINK-1673) Colocate Flink Kafka consumer

[ https://issues.apache.org/jira/browse/FLINK-1673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-1673. --- Resolution: Won't Fix > Colocate Flink Kafka consumer > - > >

[jira] [Created] (FLINK-3977) Subclasses of InternalWindowFunction must support OutputTypeConfigurable

Aljoscha Krettek created FLINK-3977: --- Summary: Subclasses of InternalWindowFunction must support OutputTypeConfigurable Key: FLINK-3977 URL: https://issues.apache.org/jira/browse/FLINK-3977 Project:

[jira] [Commented] (FLINK-3978) Add contains methods to RuntimeContext

[ https://issues.apache.org/jira/browse/FLINK-3978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15302101#comment-15302101 ] Aljoscha Krettek commented on FLINK-3978: - For the accumulators, I think the way t

[jira] [Commented] (FLINK-3758) Add possibility to register accumulators in custom triggers

[ https://issues.apache.org/jira/browse/FLINK-3758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15302624#comment-15302624 ] Aljoscha Krettek commented on FLINK-3758: - There might be one, I don't know too mu

[jira] [Updated] (FLINK-3948) EventTimeWindowCheckpointingITCase Fails with Core Dump

[ https://issues.apache.org/jira/browse/FLINK-3948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-3948: Affects Version/s: 1.1.0 > EventTimeWindowCheckpointingITCase Fails with Core Dump > ---

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