[jira] [Commented] (FLINK-2917) Make non-copying behaviour default for stream operator

[ https://issues.apache.org/jira/browse/FLINK-2917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14973308#comment-14973308 ] Aljoscha Krettek commented on FLINK-2917: - We already have the switch: {{enableObj

[jira] [Updated] (FLINK-2870) Add support for accumulating/discarding for Event-Time Windows

[ https://issues.apache.org/jira/browse/FLINK-2870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-2870: Fix Version/s: (was: 0.10) > Add support for accumulating/discarding for Event-Time Wind

[jira] [Closed] (FLINK-2891) Key for Keyed State is not set upon Window Evaluation

[ https://issues.apache.org/jira/browse/FLINK-2891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-2891. --- Resolution: Fixed Fixed for both types of window operations now. > Key for Keyed State is not

[jira] [Created] (FLINK-2922) Add Queryable Window Operator

Aljoscha Krettek created FLINK-2922: --- Summary: Add Queryable Window Operator Key: FLINK-2922 URL: https://issues.apache.org/jira/browse/FLINK-2922 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-2922) Add Queryable Window Operator

[ https://issues.apache.org/jira/browse/FLINK-2922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14974474#comment-14974474 ] Aljoscha Krettek commented on FLINK-2922: - The idea is, for example, that the regu

[jira] [Commented] (FLINK-2922) Add Queryable Window Operator

[ https://issues.apache.org/jira/browse/FLINK-2922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14974914#comment-14974914 ] Aljoscha Krettek commented on FLINK-2922: - I don't exactly know what you mean by t

[jira] [Updated] (FLINK-2922) Add Queryable Window Operator

[ https://issues.apache.org/jira/browse/FLINK-2922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-2922: Attachment: FLINK-2922.pdf Design Doc > Add Queryable Window Operator > ---

[jira] [Comment Edited] (FLINK-2922) Add Queryable Window Operator

[ https://issues.apache.org/jira/browse/FLINK-2922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14976143#comment-14976143 ] Aljoscha Krettek edited comment on FLINK-2922 at 10/27/15 10:13 AM:

[jira] [Commented] (FLINK-2929) Recovery of jobs on cluster restarts

[ https://issues.apache.org/jira/browse/FLINK-2929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14976712#comment-14976712 ] Aljoscha Krettek commented on FLINK-2929: - I think we have to fix it, yes. I'm not

[jira] [Commented] (FLINK-2932) Flink quickstart docs should ask users to download from https, not http

[ https://issues.apache.org/jira/browse/FLINK-2932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14977870#comment-14977870 ] Aljoscha Krettek commented on FLINK-2932: - I think we should change it, yes. > Fl

[jira] [Commented] (FLINK-2932) Flink quickstart docs should ask users to download from https, not http

[ https://issues.apache.org/jira/browse/FLINK-2932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14977872#comment-14977872 ] Aljoscha Krettek commented on FLINK-2932: - [~fkautz] Would you be interested in co

[jira] [Commented] (FLINK-2934) Remove placehoder pages in Web dashboard

[ https://issues.apache.org/jira/browse/FLINK-2934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14978385#comment-14978385 ] Aljoscha Krettek commented on FLINK-2934: - Did you add a Jira for adding them agai

[jira] [Commented] (FLINK-2934) Remove placehoder pages in Web dashboard

[ https://issues.apache.org/jira/browse/FLINK-2934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14978402#comment-14978402 ] Aljoscha Krettek commented on FLINK-2934: - Maybe, I'm not sure what is supposed to

[jira] [Commented] (FLINK-2932) Flink quickstart docs should ask users to download from https, not http

[ https://issues.apache.org/jira/browse/FLINK-2932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14979048#comment-14979048 ] Aljoscha Krettek commented on FLINK-2932: - No, as far as I know a CLA is only requ

[jira] [Commented] (FLINK-2959) Remove number of execution retries configuration from Environment

[ https://issues.apache.org/jira/browse/FLINK-2959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14989234#comment-14989234 ] Aljoscha Krettek commented on FLINK-2959: - But this is not the only method on {{St

[jira] [Commented] (FLINK-2236) RowSerializer and CaseClassComparator are not in sync regarding Null-Values

[ https://issues.apache.org/jira/browse/FLINK-2236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14991375#comment-14991375 ] Aljoscha Krettek commented on FLINK-2236: - The {{RowSerializer}} is already indepe

[jira] [Comment Edited] (FLINK-2236) RowSerializer and CaseClassComparator are not in sync regarding Null-Values

[ https://issues.apache.org/jira/browse/FLINK-2236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14991375#comment-14991375 ] Aljoscha Krettek edited comment on FLINK-2236 at 11/5/15 9:15 AM: --

[jira] [Commented] (FLINK-2976) Save and load checkpoints manually

[ https://issues.apache.org/jira/browse/FLINK-2976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14991613#comment-14991613 ] Aljoscha Krettek commented on FLINK-2976: - Yes, it is definitely required. Althoug

[jira] [Assigned] (FLINK-2979) RollingSink does not work with Hadoop 2.7.1

[ https://issues.apache.org/jira/browse/FLINK-2979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-2979: --- Assignee: Aljoscha Krettek > RollingSink does not work with Hadoop 2.7.1 > --

[jira] [Assigned] (FLINK-2963) Dependence on SerializationUtils#deserialize() should be avoided

[ https://issues.apache.org/jira/browse/FLINK-2963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-2963: --- Assignee: Aljoscha Krettek > Dependence on SerializationUtils#deserialize() should be

[jira] [Updated] (FLINK-2963) Dependence on SerializationUtils#deserialize() should be avoided

[ https://issues.apache.org/jira/browse/FLINK-2963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-2963: Assignee: (was: Aljoscha Krettek) > Dependence on SerializationUtils#deserialize() shoul

[jira] [Resolved] (FLINK-2979) RollingSink does not work with Hadoop 2.7.1

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

[jira] [Created] (FLINK-2991) Extend Window Operators to Allow Efficient Fold Operation

Aljoscha Krettek created FLINK-2991: --- Summary: Extend Window Operators to Allow Efficient Fold Operation Key: FLINK-2991 URL: https://issues.apache.org/jira/browse/FLINK-2991 Project: Flink

[jira] [Commented] (FLINK-3004) ForkableMiniCluster does not call RichFunction#open

[ https://issues.apache.org/jira/browse/FLINK-3004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15001944#comment-15001944 ] Aljoscha Krettek commented on FLINK-3004: - Could you please post example code wher

[jira] [Created] (FLINK-3024) TimestampExtractor Does not Work When returning Long.MIN_VALUE

Aljoscha Krettek created FLINK-3024: --- Summary: TimestampExtractor Does not Work When returning Long.MIN_VALUE Key: FLINK-3024 URL: https://issues.apache.org/jira/browse/FLINK-3024 Project: Flink

[jira] [Resolved] (FLINK-3022) Broken link 'Working With State' in Fault Tolerance Section of Stream Programming Guide

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

[jira] [Commented] (FLINK-3024) TimestampExtractor Does not Work When returning Long.MIN_VALUE

[ https://issues.apache.org/jira/browse/FLINK-3024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15008446#comment-15008446 ] Aljoscha Krettek commented on FLINK-3024: - Ok, the problem is actually more subtle

[jira] [Closed] (FLINK-3024) TimestampExtractor Does not Work When returning Long.MIN_VALUE

[ https://issues.apache.org/jira/browse/FLINK-3024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-3024. --- Resolution: Fixed Fix Version/s: 0.10.1 1.0.0 Fixed in https://gith

[jira] [Commented] (FLINK-3002) Add an EitherType to the Java API

[ https://issues.apache.org/jira/browse/FLINK-3002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15008836#comment-15008836 ] Aljoscha Krettek commented on FLINK-3002: - Hi, you can remove the {{isLeft}}/{{isR

[jira] [Resolved] (FLINK-2955) Add operations introduction in Table API page.

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

[jira] [Commented] (FLINK-3044) In YARN mode, configure FsStateBackend by default.

[ https://issues.apache.org/jira/browse/FLINK-3044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15013259#comment-15013259 ] Aljoscha Krettek commented on FLINK-3044: - Also, I think when starting with yarn t

[jira] [Commented] (FLINK-3044) In YARN mode, configure FsStateBackend by default.

[ https://issues.apache.org/jira/browse/FLINK-3044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15013381#comment-15013381 ] Aljoscha Krettek commented on FLINK-3044: - I recently ran a Job on GCE to test the

[jira] [Commented] (FLINK-3054) Remove R (return) type variable from SerializationSchema

[ https://issues.apache.org/jira/browse/FLINK-3054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15024130#comment-15024130 ] Aljoscha Krettek commented on FLINK-3054: - What do we gain by removing the return

[jira] [Resolved] (FLINK-3070) Create an asynchronous state handle interface

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

[jira] [Commented] (FLINK-2988) Cannot load DataSet[Row] from CSV file

[ https://issues.apache.org/jira/browse/FLINK-2988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15029767#comment-15029767 ] Aljoscha Krettek commented on FLINK-2988: - I think adding support to {{TableEnviro

[jira] [Commented] (FLINK-3073) Activate streaming mode by default

[ https://issues.apache.org/jira/browse/FLINK-3073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15029808#comment-15029808 ] Aljoscha Krettek commented on FLINK-3073: - +1 > Activate streaming mode by defaul

[jira] [Commented] (FLINK-3085) Move State Backend Initialization from "registerInputOutput()" to "invoke()"

[ https://issues.apache.org/jira/browse/FLINK-3085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15029819#comment-15029819 ] Aljoscha Krettek commented on FLINK-3085: - I also have some work in progress here:

[jira] [Assigned] (FLINK-3071) Add asynchronous materialization thread

[ https://issues.apache.org/jira/browse/FLINK-3071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-3071: --- Assignee: Aljoscha Krettek (was: Stephan Ewen) > Add asynchronous materialization th

[jira] [Assigned] (FLINK-3073) Activate streaming mode by default

[ https://issues.apache.org/jira/browse/FLINK-3073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-3073: --- Assignee: Aljoscha Krettek > Activate streaming mode by default > ---

[jira] [Assigned] (FLINK-3080) Cannot union a data stream with a product of itself

[ https://issues.apache.org/jira/browse/FLINK-3080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-3080: --- Assignee: Aljoscha Krettek > Cannot union a data stream with a product of itself > --

[jira] [Commented] (FLINK-3073) Activate streaming mode by default

[ https://issues.apache.org/jira/browse/FLINK-3073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15033528#comment-15033528 ] Aljoscha Krettek commented on FLINK-3073: - Should we keep the distinction between

[jira] [Resolved] (FLINK-3080) Cannot union a data stream with a product of itself

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

[jira] [Comment Edited] (FLINK-3080) Cannot union a data stream with a product of itself

[ https://issues.apache.org/jira/browse/FLINK-3080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15035660#comment-15035660 ] Aljoscha Krettek edited comment on FLINK-3080 at 12/2/15 11:21 AM: -

[jira] [Resolved] (FLINK-2115) TableAPI throws ExpressionException for "Dangling GroupBy operation"

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

[jira] [Resolved] (FLINK-3071) Add asynchronous materialization thread

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

[jira] [Resolved] (FLINK-3069) Make state materialization asynchronous

[ https://issues.apache.org/jira/browse/FLINK-3069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-3069. - Resolution: Fixed Assignee: Aljoscha Krettek (was: Stephan Ewen) Both sub-items of

[jira] [Commented] (FLINK-3096) ChaosMonkeyITCase fails in checkCleanRecoveryState with Unclean checkpoints

[ https://issues.apache.org/jira/browse/FLINK-3096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15037748#comment-15037748 ] Aljoscha Krettek commented on FLINK-3096: - Yes, if FLINK-3094 is the reason for th

[jira] [Commented] (FLINK-3132) Restructure streaming guide

[ https://issues.apache.org/jira/browse/FLINK-3132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15045240#comment-15045240 ] Aljoscha Krettek commented on FLINK-3132: - We can add sub issues for individual pa

[jira] [Commented] (FLINK-3138) Method References are not supported as lambda expressions

[ https://issues.apache.org/jira/browse/FLINK-3138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15046828#comment-15046828 ] Aljoscha Krettek commented on FLINK-3138: - How does this manifest? I changed the

[jira] [Commented] (FLINK-3140) NULL value data layout in Row Serializer/Comparator

[ https://issues.apache.org/jira/browse/FLINK-3140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15046834#comment-15046834 ] Aljoscha Krettek commented on FLINK-3140: - I think in the end the best way is to a

[jira] [Assigned] (FLINK-3136) Scala Closure Cleaner uses wrong ASM import

[ https://issues.apache.org/jira/browse/FLINK-3136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-3136: --- Assignee: Aljoscha Krettek (was: Stephan Ewen) > Scala Closure Cleaner uses wrong AS

[jira] [Resolved] (FLINK-3136) Scala Closure Cleaner uses wrong ASM import

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

[jira] [Assigned] (FLINK-2936) ClassCastException when using EventTimeSourceFunction in non-EventTime program

[ https://issues.apache.org/jira/browse/FLINK-2936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-2936: --- Assignee: Aljoscha Krettek > ClassCastException when using EventTimeSourceFunction in

[jira] [Assigned] (FLINK-3121) Watermark forwarding does not work for sources not producing any data

[ https://issues.apache.org/jira/browse/FLINK-3121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-3121: --- Assignee: Aljoscha Krettek > Watermark forwarding does not work for sources not produ

[jira] [Resolved] (FLINK-3073) Activate streaming mode by default

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

[jira] [Resolved] (FLINK-3583) Configuration not visible in gui when job is running

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

[jira] [Created] (FLINK-3614) Remove Non-Keyed Window Operator

Aljoscha Krettek created FLINK-3614: --- Summary: Remove Non-Keyed Window Operator Key: FLINK-3614 URL: https://issues.apache.org/jira/browse/FLINK-3614 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-3614) Remove Non-Keyed Window Operator

[ https://issues.apache.org/jira/browse/FLINK-3614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15197171#comment-15197171 ] Aljoscha Krettek commented on FLINK-3614: - Yes, the parallel pre-aggregation will

[jira] [Commented] (FLINK-3629) In wikiedits Quick Start example, "The first call, .window()" should be "The first call, .timeWindow()"

[ https://issues.apache.org/jira/browse/FLINK-3629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15199478#comment-15199478 ] Aljoscha Krettek commented on FLINK-3629: - Nope, you did everything correctly. I j

[jira] [Updated] (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 updated FLINK-3637: Assignee: Lasse Dalegaard > Change RollingSink Writer interface to allow wider range of outp

[jira] [Resolved] (FLINK-3629) In wikiedits Quick Start example, "The first call, .window()" should be "The first call, .timeWindow()"

[ https://issues.apache.org/jira/browse/FLINK-3629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-3629. - Resolution: Fixed Fix Version/s: 1.0.0 1.0.1 Fixed inhttps://gi

[jira] [Commented] (FLINK-3624) Use camelCase naming of JSON attributes generated by the REST API instead of dash

[ https://issues.apache.org/jira/browse/FLINK-3624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15199277#comment-15199277 ] Aljoscha Krettek commented on FLINK-3624: - That's certainly a valid concern. I don

[jira] [Commented] (FLINK-3629) In wikiedits Quick Start example, "The first call, .window()" should be "The first call, .timeWindow()"

[ https://issues.apache.org/jira/browse/FLINK-3629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15199252#comment-15199252 ] Aljoscha Krettek commented on FLINK-3629: - Good catch, would you like to prepare a

[jira] [Assigned] (FLINK-3628) ChainingOutput and CopyingChainingOutput setKeyContextElement1 is no use

[ https://issues.apache.org/jira/browse/FLINK-3628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-3628: --- Assignee: Aljoscha Krettek > ChainingOutput and CopyingChainingOutput setKeyContextEl

[jira] [Updated] (FLINK-3628) ChainingOutput and CopyingChainingOutput setKeyContextElement1 is no use

[ https://issues.apache.org/jira/browse/FLINK-3628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-3628: Assignee: MaGuowei (was: Aljoscha Krettek) > ChainingOutput and CopyingChainingOutput setKe

[jira] [Commented] (FLINK-3624) Use camelCase naming of JSON attributes generated by the REST API instead of dash

[ https://issues.apache.org/jira/browse/FLINK-3624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15204226#comment-15204226 ] Aljoscha Krettek commented on FLINK-3624: - That might be an option, yes. Any other

[jira] [Created] (FLINK-3643) Improve Window Triggers

Aljoscha Krettek created FLINK-3643: --- Summary: Improve Window Triggers Key: FLINK-3643 URL: https://issues.apache.org/jira/browse/FLINK-3643 Project: Flink Issue Type: Improvement

[jira] [Resolved] (FLINK-3399) Count with timeout trigger

[ https://issues.apache.org/jira/browse/FLINK-3399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-3399. - Resolution: Fixed This will be subsumed by the work in FLINK-3643 > Count with timeout tr

[jira] [Commented] (FLINK-3399) Count with timeout trigger

[ https://issues.apache.org/jira/browse/FLINK-3399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15204560#comment-15204560 ] Aljoscha Krettek commented on FLINK-3399: - Hi [~shikhar] I opened FLINK-3643 as an

[jira] [Created] (FLINK-3646) Use Processing-Time Clock in Window Assigners/Triggers

Aljoscha Krettek created FLINK-3646: --- Summary: Use Processing-Time Clock in Window Assigners/Triggers Key: FLINK-3646 URL: https://issues.apache.org/jira/browse/FLINK-3646 Project: Flink Is

[jira] [Created] (FLINK-3647) Change StreamSource to use Processing-Time Clock Service

Aljoscha Krettek created FLINK-3647: --- Summary: Change StreamSource to use Processing-Time Clock Service Key: FLINK-3647 URL: https://issues.apache.org/jira/browse/FLINK-3647 Project: Flink

[jira] [Updated] (FLINK-3647) Change StreamSource to use Processing-Time Clock Service

[ https://issues.apache.org/jira/browse/FLINK-3647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-3647: Description: Currently, the {{StreamSource.AutomaticWatermarkContext}} has it's own timer se

[jira] [Created] (FLINK-3648) Introduce Trigger Test Harness

Aljoscha Krettek created FLINK-3648: --- Summary: Introduce Trigger Test Harness Key: FLINK-3648 URL: https://issues.apache.org/jira/browse/FLINK-3648 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-3651) Fix faulty RollingSink Restore

Aljoscha Krettek created FLINK-3651: --- Summary: Fix faulty RollingSink Restore Key: FLINK-3651 URL: https://issues.apache.org/jira/browse/FLINK-3651 Project: Flink Issue Type: Bug

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

Aljoscha Krettek created FLINK-3654: --- Summary: Disable Write-Ahead-Log in RocksDB State Key: FLINK-3654 URL: https://issues.apache.org/jira/browse/FLINK-3654 Project: Flink Issue Type: Impr

[jira] [Updated] (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 updated FLINK-3654: Component/s: (was: Sure) Streaming > Disable Write-Ahead-Log in RocksDB

[jira] [Commented] (FLINK-3658) Allow the FlinkKafkaProducer to send data to multiple topics

[ https://issues.apache.org/jira/browse/FLINK-3658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15208132#comment-15208132 ] Aljoscha Krettek commented on FLINK-3658: - Seems legit, this would actually allow

[jira] [Created] (FLINK-3659) Allow ConnectedStreams to Be Keyed on Only One Side

Aljoscha Krettek created FLINK-3659: --- Summary: Allow ConnectedStreams to Be Keyed on Only One Side Key: FLINK-3659 URL: https://issues.apache.org/jira/browse/FLINK-3659 Project: Flink Issue

[jira] [Created] (FLINK-3669) WindowOperator registers a log of timers at StreamTask

Aljoscha Krettek created FLINK-3669: --- Summary: WindowOperator registers a log of timers at StreamTask Key: FLINK-3669 URL: https://issues.apache.org/jira/browse/FLINK-3669 Project: Flink Is

[jira] [Assigned] (FLINK-3643) Improve Window Triggers

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

[jira] [Commented] (FLINK-3643) Improve Window Triggers

[ https://issues.apache.org/jira/browse/FLINK-3643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15214204#comment-15214204 ] Aljoscha Krettek commented on FLINK-3643: - I added a link to the overall design do

[jira] [Updated] (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 updated FLINK-3669: Summary: WindowOperator registers a lot of timers at StreamTask (was: WindowOperator regist

[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=15219845#comment-15219845 ] Aljoscha Krettek commented on FLINK-3669: - Yes, you're right that's still a proble

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=15221486#comment-15221486 ] Aljoscha Krettek commented on FLINK-3688: - Yes, this is indeed a bug. I have a fou

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=15221496#comment-15221496 ] Aljoscha Krettek commented on FLINK-3688: - And, as [~StephanEwen] suggested, we co

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=15221597#comment-15221597 ] Aljoscha Krettek commented on FLINK-3688: - Exactly, that's the reason. If we did t

[jira] [Updated] (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 updated FLINK-3688: Assignee: Konstantin Knauf > ClassCastException in StreamRecordSerializer when WindowOperato

[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=15221600#comment-15221600 ] Aljoscha Krettek commented on FLINK-3669: - Yes, the 3rd option would require addit

[jira] [Comment Edited] (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=15221600#comment-15221600 ] Aljoscha Krettek edited comment on FLINK-3669 at 4/1/16 12:05 PM: --

[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=15221682#comment-15221682 ] Aljoscha Krettek commented on FLINK-3669: - Sure, no pressure! > WindowOperator re

[jira] [Commented] (FLINK-3691) Extend AvroInputFormat to support Avro GenericRecord

[ https://issues.apache.org/jira/browse/FLINK-3691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15223807#comment-15223807 ] Aljoscha Krettek commented on FLINK-3691: - I think this would be good yes. [~rmetz

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=15223808#comment-15223808 ] Aljoscha Krettek commented on FLINK-3688: - [~StephanEwen] you touched the StreamRe

[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=15223811#comment-15223811 ] Aljoscha Krettek commented on FLINK-3669: - Yes, you are right about that one. I th

[jira] [Commented] (FLINK-3035) Redis as State Backend

[ https://issues.apache.org/jira/browse/FLINK-3035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15223815#comment-15223815 ] Aljoscha Krettek commented on FLINK-3035: - Hi, Redis would not be used for snapsho

[jira] [Commented] (FLINK-3692) Develop a Kafka state backend

[ https://issues.apache.org/jira/browse/FLINK-3692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15223817#comment-15223817 ] Aljoscha Krettek commented on FLINK-3692: - This is definitely interesting. How wou

[jira] [Closed] (FLINK-2870) Add support for accumulating/discarding for Event-Time Windows

[ https://issues.apache.org/jira/browse/FLINK-2870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-2870. --- Resolution: Duplicate This will be subsumed by the work in FLINK-3643 > Add support for accum

[jira] [Resolved] (FLINK-2674) Rework windowing logic

[ https://issues.apache.org/jira/browse/FLINK-2674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-2674. - Resolution: Fixed All sub-issues are done. > Rework windowing logic > ---

[jira] [Commented] (FLINK-3700) Replace Guava Preconditions class with Flink Preconditions

[ https://issues.apache.org/jira/browse/FLINK-3700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15226119#comment-15226119 ] Aljoscha Krettek commented on FLINK-3700: - Could we not just copy the portion of G

[jira] [Resolved] (FLINK-3614) Remove Non-Keyed Window Operator

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

[jira] [Resolved] (FLINK-3174) Add merging WindowAssigner

[ https://issues.apache.org/jira/browse/FLINK-3174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-3174. - Resolution: Fixed Fix Version/s: (was: 1.0.0) 1.1.0 Done in

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