Aljoscha Krettek created FLINK-3706:
---
Summary: YARNSessionCapacitySchedulerITCase.testNonexistingQueue
unstable
Key: FLINK-3706
URL: https://issues.apache.org/jira/browse/FLINK-3706
Project: Flink
[
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
> ---
[
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
[
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
[
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
[
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/
[
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
> ---
[
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
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
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
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
[
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
[
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.
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
[
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.
[
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 )
[
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
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
[
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
[
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
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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. :
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
>
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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-
[
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
[
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
[
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?
[
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. :-
[
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
[
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
[
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
[
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
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
[
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
[
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
[
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
[
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:
---
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
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
[
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
[
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
[
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 {{
[
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
[
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:
--
[
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
[
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
[
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
[
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
[
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
[
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
[
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
>
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
[
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
[
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
[
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
> -
>
>
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:
[
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
[
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
[
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
> ---
301 - 400 of 1845 matches
Mail list logo