Till Rohrmann created FLINK-4395:
Summary: Eager processing of late arrivals in CEP operator
Key: FLINK-4395
URL: https://issues.apache.org/jira/browse/FLINK-4395
Project: Flink
Issue Type: I
[
https://issues.apache.org/jira/browse/FLINK-4055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421000#comment-15421000
]
Till Rohrmann commented on FLINK-4055:
--
Another instance:
https://s3.amazonaws.com/a
[
https://issues.apache.org/jira/browse/FLINK-4383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-4383.
Resolution: Fixed
Fixed via e8a434647bac8009b11779a3943c5d63871fcb14
> Check parameters for seriali
[
https://issues.apache.org/jira/browse/FLINK-4373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-4373.
--
Resolution: Done
Added via 08cf860169948c93c6c92ab1e2c70cf1a4266c6f
> Introduce SlotID, Allocat
[
https://issues.apache.org/jira/browse/FLINK-4399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15422667#comment-15422667
]
Till Rohrmann commented on FLINK-4399:
--
Hi Felix,
both issues have the same idea. Ho
[
https://issues.apache.org/jira/browse/FLINK-4382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-4382.
Resolution: Fixed
Fixed via 5df27ebd73f5218a792fb53385887968c0e4ca36
> Buffer rpc calls until RpcEn
[
https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424236#comment-15424236
]
Till Rohrmann commented on FLINK-4363:
--
I think you can already start with implementi
Till Rohrmann created FLINK-4424:
Summary: Make network environment start-up/shutdown independent of
JobManager association
Key: FLINK-4424
URL: https://issues.apache.org/jira/browse/FLINK-4424
Projec
[
https://issues.apache.org/jira/browse/FLINK-4348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-4348:
-
Summary: Implement communication from ResourceManager to TaskManager (was:
implement communicatio
[
https://issues.apache.org/jira/browse/FLINK-4414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-4414:
Assignee: Till Rohrmann (was: Wenlong Lyu)
> Remove restriction on RpcService.getAddress
>
[
https://issues.apache.org/jira/browse/FLINK-4414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-4414.
--
Resolution: Fixed
Fixed via 682ebdb5744b01a4d126ce4a66846c12588a1714
> Remove restriction on Rp
[
https://issues.apache.org/jira/browse/FLINK-4390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-4390.
Resolution: Won't Fix
I think we cannot check for the throw clause consistency because the exception
[
https://issues.apache.org/jira/browse/FLINK-3319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-3319.
Resolution: Fixed
Added via 266c76b55e410965d7a5332acd3b2a0dfd3b24bb
> Add or operator to CEP's pat
[
https://issues.apache.org/jira/browse/FLINK-4352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-4352:
-
Description:
The {{JobClient}} has to adapted to the new Flip-6 architecture.
1. for yarn mode, j
[
https://issues.apache.org/jira/browse/FLINK-4352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-4352:
-
Summary: Implement new JobClient (was: interaction between new JobManager
and JobClient)
> Imple
[
https://issues.apache.org/jira/browse/FLINK-4355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-4355.
--
Resolution: Fixed
Test cases added via be80f400fbe24389a8d7a1fa9159f6bd80e3a2d9
> Implement Tas
[
https://issues.apache.org/jira/browse/FLINK-4434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-4434.
--
Resolution: Fixed
Added via eee149765db992a7b787ed0a535c4fd2f5c78ce1
> Add a testing RPC servic
[
https://issues.apache.org/jira/browse/FLINK-4400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-4400.
--
Resolution: Fixed
Added via e4f5aec22a1d86ac3667e3d79ccd9f91e934086a
> Leadership Election amon
Till Rohrmann created FLINK-4451:
Summary: Throw exception when remote connection cannot be resolved
Key: FLINK-4451
URL: https://issues.apache.org/jira/browse/FLINK-4451
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-4443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-4443.
--
Resolution: Fixed
Added via 113e22b4f9be88f6baef391f55de1f547cfaecca
> Add support in RpcComple
[
https://issues.apache.org/jira/browse/FLINK-4424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-4424:
-
Issue Type: Improvement (was: Sub-task)
Parent: (was: FLINK-4343)
> Make network envi
Till Rohrmann created FLINK-4455:
Summary: Replace ActorGateways in NetworkEnvironment by interfaces
Key: FLINK-4455
URL: https://issues.apache.org/jira/browse/FLINK-4455
Project: Flink
Issue
Till Rohrmann created FLINK-4456:
Summary: Replace ActorGateway in RuntimeEnvironment by interface
Key: FLINK-4456
URL: https://issues.apache.org/jira/browse/FLINK-4456
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-4456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-4456:
-
Summary: Replace ActorGateway in Task by interface (was: Replace
ActorGateway in RuntimeEnvironme
[
https://issues.apache.org/jira/browse/FLINK-4456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-4456:
-
Description:
The {{Task}} communicates with the outside world ({{JobManager}} and
{{TaskManager}}
Till Rohrmann created FLINK-4457:
Summary: Make the ExecutionGraph independent of Akka
Key: FLINK-4457
URL: https://issues.apache.org/jira/browse/FLINK-4457
Project: Flink
Issue Type: Improve
Till Rohrmann created FLINK-4458:
Summary: Remove ForkableFlinkMiniCluster
Key: FLINK-4458
URL: https://issues.apache.org/jira/browse/FLINK-4458
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-4459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-4459:
-
Summary: Introduce SlotProvider for Scheduler (was: Introduce SlotProvider
to Scheduler)
> Intro
Till Rohrmann created FLINK-4459:
Summary: Introduce SlotProvider to Scheduler
Key: FLINK-4459
URL: https://issues.apache.org/jira/browse/FLINK-4459
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-4449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433305#comment-15433305
]
Till Rohrmann commented on FLINK-4449:
--
Can we create a generic {{HeartbeatManager}}
[
https://issues.apache.org/jira/browse/FLINK-4424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15434777#comment-15434777
]
Till Rohrmann commented on FLINK-4424:
--
Yes that is the idea. It might actually make
Till Rohrmann created FLINK-4478:
Summary: Implement heartbeat logic
Key: FLINK-4478
URL: https://issues.apache.org/jira/browse/FLINK-4478
Project: Flink
Issue Type: Improvement
Com
[
https://issues.apache.org/jira/browse/FLINK-3823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reopened FLINK-3823:
--
It happened again... :-(
https://s3.amazonaws.com/archive.travis-ci.org/jobs/154498433/log.txt
> K
[
https://issues.apache.org/jira/browse/FLINK-4451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-4451.
Resolution: Fixed
Fixed via affa548cada5d9c25c32eb1f39986bbbd3e55f21
> Throw exception when remote
[
https://issues.apache.org/jira/browse/FLINK-4478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15436496#comment-15436496
]
Till Rohrmann commented on FLINK-4478:
--
Hi [~jinyu.zj], I think we have to give the o
[
https://issues.apache.org/jira/browse/FLINK-4478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-4478:
-
Description:
With the Flip-6 refactoring, we'll have the need for a dedicated heartbeat
component
[
https://issues.apache.org/jira/browse/FLINK-4478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-4478:
-
Description:
With the Flip-6 refactoring, we'll have the need for a dedicated heartbeat
component
[
https://issues.apache.org/jira/browse/FLINK-4478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15436913#comment-15436913
]
Till Rohrmann commented on FLINK-4478:
--
I've created a design document which outlines
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15436919#comment-15436919
]
Till Rohrmann commented on FLINK-4354:
--
I think this can be done quite easily once FL
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15436938#comment-15436938
]
Till Rohrmann commented on FLINK-4364:
--
Here as well, I think the implementation is s
[
https://issues.apache.org/jira/browse/FLINK-4357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15436953#comment-15436953
]
Till Rohrmann commented on FLINK-4357:
--
I think we also need some kind of {{SlotManag
Till Rohrmann created FLINK-4489:
Summary: Implement TaskManager's SlotManager
Key: FLINK-4489
URL: https://issues.apache.org/jira/browse/FLINK-4489
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-4358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15436974#comment-15436974
]
Till Rohrmann commented on FLINK-4358:
--
In order to deploy tasks to slots, we first h
[
https://issues.apache.org/jira/browse/FLINK-4343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15436982#comment-15436982
]
Till Rohrmann commented on FLINK-4343:
--
I've tried to outline the interaction of the
[
https://issues.apache.org/jira/browse/FLINK-4343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15436982#comment-15436982
]
Till Rohrmann edited comment on FLINK-4343 at 8/25/16 2:35 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-4489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445372#comment-15445372
]
Till Rohrmann commented on FLINK-4489:
--
No this refers to the {{TaskManager's}} {{Slo
[
https://issues.apache.org/jira/browse/FLINK-4486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445414#comment-15445414
]
Till Rohrmann commented on FLINK-4486:
--
I think that's the right way to fix the probl
[
https://issues.apache.org/jira/browse/FLINK-4419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445435#comment-15445435
]
Till Rohrmann commented on FLINK-4419:
--
At the moment, the blocking results are kept
[
https://issues.apache.org/jira/browse/FLINK-4478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-4478:
Assignee: Till Rohrmann
> Implement heartbeat logic
> -
>
>
Till Rohrmann created FLINK-4528:
Summary: Mark runAsync and scheduleAsync methods protected
Key: FLINK-4528
URL: https://issues.apache.org/jira/browse/FLINK-4528
Project: Flink
Issue Type: S
Till Rohrmann created FLINK-4529:
Summary: Move JobMaster, TaskExecutor and ResourceManager out of
the rpc package
Key: FLINK-4529
URL: https://issues.apache.org/jira/browse/FLINK-4529
Project: Flink
Till Rohrmann created FLINK-4530:
Summary: Generalize TaskExecutorToResourceManagerConnection to be
reusable
Key: FLINK-4530
URL: https://issues.apache.org/jira/browse/FLINK-4530
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15446226#comment-15446226
]
Till Rohrmann commented on FLINK-4055:
--
It happened again:
https://s3.amazonaws.com/
[
https://issues.apache.org/jira/browse/FLINK-4361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15446392#comment-15446392
]
Till Rohrmann commented on FLINK-4361:
--
I'm not sure whether it's worth the effort to
[
https://issues.apache.org/jira/browse/FLINK-4455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-4455:
Assignee: Till Rohrmann
> Replace ActorGateways in NetworkEnvironment by interfaces
> -
[
https://issues.apache.org/jira/browse/FLINK-4424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-4424:
Assignee: Till Rohrmann
> Make network environment start-up/shutdown independent of JobMana
[
https://issues.apache.org/jira/browse/FLINK-4456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-4456:
Assignee: Till Rohrmann
> Replace ActorGateway in Task by interface
> -
[
https://issues.apache.org/jira/browse/FLINK-4458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-4458:
Assignee: Till Rohrmann
> Remove ForkableFlinkMiniCluster
> ---
[
https://issues.apache.org/jira/browse/FLINK-3704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-3704:
Assignee: Till Rohrmann
> JobManagerHAProcessFailureBatchRecoveryITCase.testJobManagerProce
[
https://issues.apache.org/jira/browse/FLINK-3704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15454849#comment-15454849
]
Till Rohrmann commented on FLINK-3704:
--
I think I might have found a problem. The two
[
https://issues.apache.org/jira/browse/FLINK-3704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15454898#comment-15454898
]
Till Rohrmann commented on FLINK-3704:
--
I suspect that the `ZooKeeperTestEnvironment.
[
https://issues.apache.org/jira/browse/FLINK-3704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-3704:
-
Assignee: (was: Till Rohrmann)
> JobManagerHAProcessFailureBatchRecoveryITCase.testJobManagerP
[
https://issues.apache.org/jira/browse/FLINK-4529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-4529.
Resolution: Fixed
Fixed via 11a92d1da958cfd2c079a550bcac62c0e6eeb6b3
> Move JobMaster, TaskExecutor
[
https://issues.apache.org/jira/browse/FLINK-4528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-4528.
Resolution: Fixed
Fixed via 074f214e0cf67b86d0d879a93a18f6cc86acfa9f
> Mark runAsync and scheduleAs
Till Rohrmann created FLINK-4568:
Summary: Replace ActorGateway in WebRuntimeMonitor
Key: FLINK-4568
URL: https://issues.apache.org/jira/browse/FLINK-4568
Project: Flink
Issue Type: Improveme
[
https://issues.apache.org/jira/browse/FLINK-2312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15458190#comment-15458190
]
Till Rohrmann commented on FLINK-2312:
--
We've merged FLINK-2259 which might already f
[
https://issues.apache.org/jira/browse/FLINK-4455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-4455.
Resolution: Fixed
Fixed via 78f2a15867734055a9712ea3a27f54d9bed3e43b
> Replace ActorGateways in Net
[
https://issues.apache.org/jira/browse/FLINK-4424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-4424.
Resolution: Fixed
Fixed via 78f2a15867734055a9712ea3a27f54d9bed3e43b
> Make network environment sta
[
https://issues.apache.org/jira/browse/FLINK-4489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-4489:
-
Summary: Implement TaskManager's SlotAllocationTable (was: Implement
TaskManager's SlotManager)
[
https://issues.apache.org/jira/browse/FLINK-4361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-4361:
Assignee: Till Rohrmann
> Introduce Flink's own future abstraction
> --
[
https://issues.apache.org/jira/browse/FLINK-4361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-4361:
-
Summary: Introduce Flink's own future abstraction (was: Replace Scala
Futures)
> Introduce Flink
Till Rohrmann created FLINK-4580:
Summary: Check that the RpcEndpoint supports the specified
RpcGateway
Key: FLINK-4580
URL: https://issues.apache.org/jira/browse/FLINK-4580
Project: Flink
I
[
https://issues.apache.org/jira/browse/FLINK-4451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15464545#comment-15464545
]
Till Rohrmann commented on FLINK-4451:
--
Fixed via 0cf2a822b6872ee4f3f0c99f0fcee71affa
[
https://issues.apache.org/jira/browse/FLINK-4579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-4579:
-
Issue Type: Improvement (was: Bug)
> Add StateBackendFactory for RocksDB Backend
> --
[
https://issues.apache.org/jira/browse/FLINK-4458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-4458.
Resolution: Fixed
Fixed via 02b852e3571e46f25fdfc79f43ceb726ddff9ba7
> Remove ForkableFlinkMiniClus
[
https://issues.apache.org/jira/browse/FLINK-4456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-4456.
Resolution: Fixed
Fixed via 0735b5b935b0c0757943e2d58047afcfb9949560
> Replace ActorGateway in Task
Till Rohrmann created FLINK-4603:
Summary: KeyedStateBackend cannot restore user code classes
Key: FLINK-4603
URL: https://issues.apache.org/jira/browse/FLINK-4603
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-4603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15476941#comment-15476941
]
Till Rohrmann commented on FLINK-4603:
--
Wouldn't we even then need the user code clas
[
https://issues.apache.org/jira/browse/FLINK-4603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15483601#comment-15483601
]
Till Rohrmann commented on FLINK-4603:
--
That makes sense.
> KeyedStateBackend canno
[
https://issues.apache.org/jira/browse/FLINK-2014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15489775#comment-15489775
]
Till Rohrmann commented on FLINK-2014:
--
Hi [~vlchen91],
I'm not sure what's the exac
Till Rohrmann created FLINK-4624:
Summary: Gelly's summarization algorithm cannot deal with null
vertex group values
Key: FLINK-4624
URL: https://issues.apache.org/jira/browse/FLINK-4624
Project: Flin
[
https://issues.apache.org/jira/browse/FLINK-4520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-4520:
-
Assignee: Hao Chen
> Integrate Siddhi as a lightweight CEP Library
> -
[
https://issues.apache.org/jira/browse/FLINK-4641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-4641:
-
Description:
We should add support for branching CEP patterns to the Pattern API.
{code}
|-
Till Rohrmann created FLINK-4641:
Summary: Support branching CEP patterns
Key: FLINK-4641
URL: https://issues.apache.org/jira/browse/FLINK-4641
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-4641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-4641:
-
Description:
We should add support for branching CEP patterns to the Pattern API.
{code}
|--
[
https://issues.apache.org/jira/browse/FLINK-4641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-4641:
-
Description:
We should add support for branching CEP patterns to the Pattern API.
{code}
|-
[
https://issues.apache.org/jira/browse/FLINK-4361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-4361.
--
Resolution: Fixed
Added via 11cc6b95bab5c3d17dd1182f3ad87df4184aaa4a
> Introduce Flink's own fu
[
https://issues.apache.org/jira/browse/FLINK-4580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15509897#comment-15509897
]
Till Rohrmann commented on FLINK-4580:
--
Adding this check lazily when executing the r
Till Rohrmann created FLINK-4656:
Summary: Port existing code to use Flink's future abstraction
Key: FLINK-4656
URL: https://issues.apache.org/jira/browse/FLINK-4656
Project: Flink
Issue Type
Till Rohrmann created FLINK-4658:
Summary: Allow RpcService to execute Callables in the RpcService
executor
Key: FLINK-4658
URL: https://issues.apache.org/jira/browse/FLINK-4658
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-4656.
Resolution: Fixed
Fixed via 31a091b930178bf2aec2881ee273fe0e5e17464d
> Port existing code to use Fl
[
https://issues.apache.org/jira/browse/FLINK-4658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-4658.
Resolution: Fixed
Fixed via b5f6a06b01436a8b0e7243e3f8af7444f8058868
> Allow RpcService to execute
[
https://issues.apache.org/jira/browse/FLINK-5999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-5999:
-
Priority: Critical (was: Major)
> MiniClusterITCase.runJobWithMultipleRpcServices fails
> ---
[
https://issues.apache.org/jira/browse/FLINK-5999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-5999:
Assignee: Till Rohrmann
> MiniClusterITCase.runJobWithMultipleRpcServices fails
> -
[
https://issues.apache.org/jira/browse/FLINK-5936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15905191#comment-15905191
]
Till Rohrmann commented on FLINK-5936:
--
The {{PredictDataSetOperation}} is used in th
[
https://issues.apache.org/jira/browse/FLINK-5971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-5971.
Resolution: Fixed
Fix Version/s: 1.3.0
Fixed via fcd264a707d3dd8ef4247825752c8639732c943c
>
[
https://issues.apache.org/jira/browse/FLINK-5942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-5942.
Resolution: Fixed
Fix Version/s: 1.2.1
1.1.5
1.3.0
1.3.
[
https://issues.apache.org/jira/browse/FLINK-5940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-5940.
Resolution: Fixed
Fix Version/s: 1.2.1
1.1.5
1.3.0
1.3.
Till Rohrmann created FLINK-6042:
Summary: Display last n exceptions/causes for job restarts in Web
UI
Key: FLINK-6042
URL: https://issues.apache.org/jira/browse/FLINK-6042
Project: Flink
Is
Till Rohrmann created FLINK-6043:
Summary: Display time when exceptions/root cause of failure
happened
Key: FLINK-6043
URL: https://issues.apache.org/jira/browse/FLINK-6043
Project: Flink
Is
1 - 100 of 12848 matches
Mail list logo
