[
https://issues.apache.org/jira/browse/FLINK-4424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15434777#comment-15434777
]
Till Rohrmann commented on FLINK-4424:
--
Yes that is the idea. It might actually make sense to create
[
https://issues.apache.org/jira/browse/FLINK-4478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15436496#comment-15436496
]
Till Rohrmann commented on FLINK-4478:
--
Hi [~jinyu.zj], I think we have to give the others a little
[
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-4478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15436913#comment-15436913
]
Till Rohrmann commented on FLINK-4478:
--
I've created a design document which outlines the heartbeat
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15436919#comment-15436919
]
Till Rohrmann commented on FLINK-4354:
--
I think this can be done quite easily once FLINK-4478 has
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15436938#comment-15436938
]
Till Rohrmann commented on FLINK-4364:
--
Here as well, I think the implementation is simply
[
https://issues.apache.org/jira/browse/FLINK-4357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15436953#comment-15436953
]
Till Rohrmann commented on FLINK-4357:
--
I think we also need some kind of {{SlotManager}} on the
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=15436974#comment-15436974
]
Till Rohrmann commented on FLINK-4358:
--
In order to deploy tasks to slots, we first have to solve
[
https://issues.apache.org/jira/browse/FLINK-4343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15436982#comment-15436982
]
Till Rohrmann commented on FLINK-4343:
--
I've tried to outline the interaction of the new
[
https://issues.apache.org/jira/browse/FLINK-4343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15436982#comment-15436982
]
Till Rohrmann edited comment on FLINK-4343 at 8/25/16 2:35 PM:
---
I've tried
[
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
[
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-4455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-4455.
Resolution: Fixed
Fixed via 78f2a15867734055a9712ea3a27f54d9bed3e43b
> Replace ActorGateways in
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
[
https://issues.apache.org/jira/browse/FLINK-4451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15464545#comment-15464545
]
Till Rohrmann commented on FLINK-4451:
--
Fixed via 0cf2a822b6872ee4f3f0c99f0fcee71affaeaee5
> Throw
[
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
>
[
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
[
https://issues.apache.org/jira/browse/FLINK-3704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15454849#comment-15454849
]
Till Rohrmann commented on FLINK-3704:
--
I think I might have found a problem. The two tests in
[
https://issues.apache.org/jira/browse/FLINK-3704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15454898#comment-15454898
]
Till Rohrmann commented on FLINK-3704:
--
I suspect that the `ZooKeeperTestEnvironment.deleteAll`
[
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)
>
[
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,
[
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
>
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:
[
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-4456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-4456.
Resolution: Fixed
Fixed via 0735b5b935b0c0757943e2d58047afcfb9949560
> Replace ActorGateway in
[
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
[
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
[
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-2312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15458190#comment-15458190
]
Till Rohrmann commented on FLINK-2312:
--
We've merged FLINK-2259 which might already fulfil your needs
[
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-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
[
https://issues.apache.org/jira/browse/FLINK-4603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15476941#comment-15476941
]
Till Rohrmann commented on FLINK-4603:
--
Wouldn't we even then need the user code class loader to load
[
https://issues.apache.org/jira/browse/FLINK-4603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15483601#comment-15483601
]
Till Rohrmann commented on FLINK-4603:
--
That makes sense.
> KeyedStateBackend cannot restore user
[
https://issues.apache.org/jira/browse/FLINK-2014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15489775#comment-15489775
]
Till Rohrmann commented on FLINK-2014:
--
Hi [~vlchen91],
I'm not sure what's the exact status of the
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:
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:
Till Rohrmann created FLINK-4687:
Summary: Add getAddress method to RpcService
Key: FLINK-4687
URL: https://issues.apache.org/jira/browse/FLINK-4687
Project: Flink
Issue Type: Sub-task
Till Rohrmann created FLINK-4711:
Summary: TaskManager can crash due to failing
onPartitionStateUpdate call
Key: FLINK-4711
URL: https://issues.apache.org/jira/browse/FLINK-4711
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-4711.
Resolution: Fixed
Fixed via 477d1c5d4ca6f469b3c87bc1f7962ece805cae1d
> TaskManager can crash due
Till Rohrmann created FLINK-4714:
Summary: Set task state to RUNNING after state has been restored
Key: FLINK-4714
URL: https://issues.apache.org/jira/browse/FLINK-4714
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-4650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-4650:
-
Affects Version/s: 1.2.0
> Frequent task manager disconnects from JobManager
>
Till Rohrmann created FLINK-4717:
Summary: Naive version of atomic stop signal with savepoint
Key: FLINK-4717
URL: https://issues.apache.org/jira/browse/FLINK-4717
Project: Flink
Issue Type:
Till Rohrmann created FLINK-4715:
Summary: TaskManager should commit suicide after cancellation
failure
Key: FLINK-4715
URL: https://issues.apache.org/jira/browse/FLINK-4715
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-4650:
-
Fix Version/s: 1.2.0
> Frequent task manager disconnects from JobManager
>
Till Rohrmann created FLINK-4716:
Summary: Add trigger full recovery button to web UI
Key: FLINK-4716
URL: https://issues.apache.org/jira/browse/FLINK-4716
Project: Flink
Issue Type:
Till Rohrmann created FLINK-4752:
Summary: Improve session window documentation
Key: FLINK-4752
URL: https://issues.apache.org/jira/browse/FLINK-4752
Project: Flink
Issue Type: Improvement
Till Rohrmann created FLINK-4746:
Summary: Replace TaskManagerRuntimeInfo by TaskManagerConfiguration
Key: FLINK-4746
URL: https://issues.apache.org/jira/browse/FLINK-4746
Project: Flink
Till Rohrmann created FLINK-4751:
Summary: Extend Flink's futures to support combining two futures
Key: FLINK-4751
URL: https://issues.apache.org/jira/browse/FLINK-4751
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-4751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-4751.
Resolution: Fixed
Added via 98710ead59305fc067cb8fdfab2c47d3bdc2e3fc
> Extend Flink's futures to
Till Rohrmann created FLINK-4738:
Summary: Port TaskManager logic to TaskExecutor
Key: FLINK-4738
URL: https://issues.apache.org/jira/browse/FLINK-4738
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-4760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15554466#comment-15554466
]
Till Rohrmann commented on FLINK-4760:
--
Which version of Flink are you using? If it's the current
Till Rohrmann created FLINK-4755:
Summary: Create ContainerID; Rename ResourceID into ProcessID and
InstanceID into RegistrationID
Key: FLINK-4755
URL: https://issues.apache.org/jira/browse/FLINK-4755
[
https://issues.apache.org/jira/browse/FLINK-4580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15509897#comment-15509897
]
Till Rohrmann commented on FLINK-4580:
--
Adding this check lazily when executing the rpc call.
>
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
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
[
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-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-4361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-4361.
--
Resolution: Fixed
Added via 11cc6b95bab5c3d17dd1182f3ad87df4184aaa4a
> Introduce Flink's own
[
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}
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}
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
[
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)
>
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=15433305#comment-15433305
]
Till Rohrmann commented on FLINK-4449:
--
Can we create a generic {{HeartbeatManager}} which can be
[
https://issues.apache.org/jira/browse/FLINK-4489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15445372#comment-15445372
]
Till Rohrmann commented on FLINK-4489:
--
No this refers to the {{TaskManager's}} {{SlotManager}}. This
[
https://issues.apache.org/jira/browse/FLINK-4486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15445414#comment-15445414
]
Till Rohrmann commented on FLINK-4486:
--
I think that's the right way to fix the problem right now.
[
https://issues.apache.org/jira/browse/FLINK-4419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15445435#comment-15445435
]
Till Rohrmann commented on FLINK-4419:
--
At the moment, the blocking results are kept in managed
[
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-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=15446226#comment-15446226
]
Till Rohrmann commented on FLINK-4055:
--
It happened again:
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
[
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
[
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
>
[
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
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
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:
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
[
https://issues.apache.org/jira/browse/FLINK-4361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15446392#comment-15446392
]
Till Rohrmann commented on FLINK-4361:
--
I'm not sure whether it's worth the effort to actually
[
https://issues.apache.org/jira/browse/FLINK-4687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-4687.
Resolution: Fixed
Added via 93775cef67b1903a8f462da924f97df5ae6819c4
> Add getAddress method to
Till Rohrmann created FLINK-4695:
Summary: Separate configuration parsing from MetricRegistry
Key: FLINK-4695
URL: https://issues.apache.org/jira/browse/FLINK-4695
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-4505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-4505.
--
Resolution: Fixed
Added via 5513fe61dc8699a617c163ee2a555e43dc6422e4
> Implement
[
https://issues.apache.org/jira/browse/FLINK-4361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15526671#comment-15526671
]
Till Rohrmann commented on FLINK-4361:
--
Added to the master via
[
https://issues.apache.org/jira/browse/FLINK-4690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-4690.
--
Resolution: Fixed
Added via 84672c22f8088a70caf35b54d74eee458bf600dd
> Replace
[
https://issues.apache.org/jira/browse/FLINK-4406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-4406.
--
Resolution: Fixed
Added via ba2b59096022b480a70f6410d9b1643da5158608
> Implement job master
[
https://issues.apache.org/jira/browse/FLINK-4478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-4478.
Resolution: Fixed
Added via d5c0092f3db37956a3cebea9d4a782978d08f8be
> Implement heartbeat logic
>
[
https://issues.apache.org/jira/browse/FLINK-4596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-4596:
-
Affects Version/s: 1.2.0
> RESTART_STRATEGY is not really pluggable
>
[
https://issues.apache.org/jira/browse/FLINK-4596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-4596:
-
Issue Type: Wish (was: Bug)
> RESTART_STRATEGY is not really pluggable
>
[
https://issues.apache.org/jira/browse/FLINK-4596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15522615#comment-15522615
]
Till Rohrmann commented on FLINK-4596:
--
Hi [~nguraja], you're right that the class loading will fail
[
https://issues.apache.org/jira/browse/FLINK-4580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-4580.
Resolution: Fixed
Fixed via 2a61e74b9108835ffb5f8ab89d67cb7105801594
> Check that the RpcEndpoint
[
https://issues.apache.org/jira/browse/FLINK-4596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-4596:
-
Component/s: Distributed Coordination
> RESTART_STRATEGY is not really pluggable
>
[
https://issues.apache.org/jira/browse/FLINK-4695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-4695.
Resolution: Fixed
Added via f1b5b35f595e7ae53001a4c46edbf0c9b78ee376
> Separate configuration
[
https://issues.apache.org/jira/browse/FLINK-4630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15525483#comment-15525483
]
Till Rohrmann commented on FLINK-4630:
--
Hi Shijinkui, what do you wanna use this source for? Is it
Till Rohrmann created FLINK-4694:
Summary: Add wait for termination function to RpcEndpoints
Key: FLINK-4694
URL: https://issues.apache.org/jira/browse/FLINK-4694
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15644835#comment-15644835
]
Till Rohrmann commented on FLINK-4354:
--
Hi [~wangzj],
I agree with points 2-6.
But I'm not so sure
1001 - 1100 of 12713 matches
Mail list logo
