shuai.xu created FLINK-16140:
Summary: Translate "Event Processing (CEP)" page into Chinese
Key: FLINK-16140
URL: https://issues.apache.org/jira/browse/FLINK-16140
Project: Flink
Issue Type:
shuai.xu created FLINK-16011:
Summary: Normalize the within usage in Pattern
Key: FLINK-16011
URL: https://issues.apache.org/jira/browse/FLINK-16011
Project: Flink
Issue Type: Improvement
shuai.xu created FLINK-16010:
Summary: Support notFollowedBy with interval as the last part of a
Pattern
Key: FLINK-16010
URL: https://issues.apache.org/jira/browse/FLINK-16010
Project: Flink
shuai.xu created FLINK-15980:
Summary: The notFollowedBy in the end of GroupPattern may be
ignored
Key: FLINK-15980
URL: https://issues.apache.org/jira/browse/FLINK-15980
Project: Flink
Issue
shuai.xu created FLINK-15964:
Summary: Getting previous stage in notFollowedBy may throw
exception
Key: FLINK-15964
URL: https://issues.apache.org/jira/browse/FLINK-15964
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-15873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17029563#comment-17029563
]
shuai.xu commented on FLINK-15873:
--
hi @[~dwysakowicz], I have submit a [pull
shuai.xu created FLINK-15873:
Summary: Matched result may not be output if existing earlier
partial matches
Key: FLINK-15873
URL: https://issues.apache.org/jira/browse/FLINK-15873
Project: Flink
shuai.xu created FLINK-15627:
Summary: Correct the wrong naming of compareMaps in
NFATestUtilities
Key: FLINK-15627
URL: https://issues.apache.org/jira/browse/FLINK-15627
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-12038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16888482#comment-16888482
]
shuai.xu commented on FLINK-12038:
--
This failure can be easily re-produced in my local machine. I
[
https://issues.apache.org/jira/browse/FLINK-12038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16886925#comment-16886925
]
shuai.xu commented on FLINK-12038:
--
[~till.rohrmann], I think this is caused by
[
https://issues.apache.org/jira/browse/FLINK-12863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16865278#comment-16865278
]
shuai.xu edited comment on FLINK-12863 at 6/17/19 3:27 AM:
---
Hi
[
https://issues.apache.org/jira/browse/FLINK-12863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16865278#comment-16865278
]
shuai.xu commented on FLINK-12863:
--
Hi [~till.rohrmann], as [~xiaogang.shi] said, we found the same
shuai.xu created FLINK-12760:
Summary: Implement ExecutionGraph to InputsLocationsRetriever
Adapter
Key: FLINK-12760
URL: https://issues.apache.org/jira/browse/FLINK-12760
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-12372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16840166#comment-16840166
]
shuai.xu edited comment on FLINK-12372 at 5/16/19 2:56 AM:
---
Hi [~gjy]
For the
[
https://issues.apache.org/jira/browse/FLINK-12372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16840166#comment-16840166
]
shuai.xu commented on FLINK-12372:
--
Hi [~gjy]
For the ScheduleUnit, I think your proposal works.
For
[
https://issues.apache.org/jira/browse/FLINK-12372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16838492#comment-16838492
]
shuai.xu commented on FLINK-12372:
--
I am now working on this issue. This is the implementation plan.
1.
[
https://issues.apache.org/jira/browse/FLINK-12228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu reassigned FLINK-12228:
Assignee: shuai.xu (was: Gary Yao)
> Implement Eager Scheduling Strategy
>
[
https://issues.apache.org/jira/browse/FLINK-12227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu reassigned FLINK-12227:
Assignee: shuai.xu (was: Gary Yao)
> Introduce SchedulingStrategy interface
>
shuai.xu created FLINK-11861:
Summary: JobMasterTriggerSavepointIT case is not executed
Key: FLINK-11861
URL: https://issues.apache.org/jira/browse/FLINK-11861
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-11375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu updated FLINK-11375:
-
Description:
In SlotPool, the AvailableSlots is lock free, so all access to it should in the
main
[
https://issues.apache.org/jira/browse/FLINK-11375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu updated FLINK-11375:
-
Description:
In SlotPool, the AvailableSlots is lock free, so all access to it should in the
main
shuai.xu created FLINK-11375:
Summary: Concurrent modification to slot pool due to
SlotSharingManager releaseSlot directly
Key: FLINK-11375
URL: https://issues.apache.org/jira/browse/FLINK-11375
[
https://issues.apache.org/jira/browse/FLINK-11298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739249#comment-16739249
]
shuai.xu commented on FLINK-11298:
--
Hi [~till.rohrmann], thanks for you attention, Yes, this issue is
[
https://issues.apache.org/jira/browse/FLINK-10433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739159#comment-16739159
]
shuai.xu commented on FLINK-10433:
--
Like this proposal. Autoscaling is very useful. Further more, we
[
https://issues.apache.org/jira/browse/FLINK-11298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu reassigned FLINK-11298:
Assignee: shuai.xu
> Scheduling job in the unit of concurrent groups
>
[
https://issues.apache.org/jira/browse/FLINK-11299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu reassigned FLINK-11299:
Assignee: shuai.xu
> Decide the result partition type dynamically
>
shuai.xu created FLINK-11299:
Summary: Decide the result partition type dynamically
Key: FLINK-11299
URL: https://issues.apache.org/jira/browse/FLINK-11299
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-10432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739120#comment-16739120
]
shuai.xu commented on FLINK-10432:
--
Hi [~srichter], it's really a good idea. I think we could benefit
shuai.xu created FLINK-11298:
Summary: Scheduling job in the unit of concurrent groups
Key: FLINK-11298
URL: https://issues.apache.org/jira/browse/FLINK-11298
Project: Flink
Issue Type:
shuai.xu created FLINK-11059:
Summary: JobMaster may continue using an invalid slot if releasing
idle slot meet a timeout
Key: FLINK-11059
URL: https://issues.apache.org/jira/browse/FLINK-11059
Project:
[
https://issues.apache.org/jira/browse/FLINK-10429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16629735#comment-16629735
]
shuai.xu commented on FLINK-10429:
--
+1
This proposal goes in the same direction as our approach. We
shuai.xu created FLINK-9932:
---
Summary: If task executor offer slot to job master timeout the
first time, the slot will leak
Key: FLINK-9932
URL: https://issues.apache.org/jira/browse/FLINK-9932
Project:
shuai.xu created FLINK-9884:
---
Summary: Slot request may not be removed when it has already be
assigned in slot manager
Key: FLINK-9884
URL: https://issues.apache.org/jira/browse/FLINK-9884
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu reassigned FLINK-9828:
---
Assignee: shuai.xu
> Resource manager should recover slot resource status after failover
>
shuai.xu created FLINK-9828:
---
Summary: Resource manager should recover slot resource status
after failover
Key: FLINK-9828
URL: https://issues.apache.org/jira/browse/FLINK-9828
Project: Flink
shuai.xu created FLINK-9827:
---
Summary: ResourceManager may receive outdate report of slots
status from task manager
Key: FLINK-9827
URL: https://issues.apache.org/jira/browse/FLINK-9827
Project: Flink
shuai.xu created FLINK-9826:
---
Summary: Implement FLIP-6 YARN Resource Manager for SESSION mode
Key: FLINK-9826
URL: https://issues.apache.org/jira/browse/FLINK-9826
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-9632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu closed FLINK-9632.
---
Resolution: Invalid
> SlotPool should notify the caller when allocateSlot meet an exception
>
shuai.xu created FLINK-9632:
---
Summary: SlotPool should notify the call when allocateSlot meet an
exception
Key: FLINK-9632
URL: https://issues.apache.org/jira/browse/FLINK-9632
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu updated FLINK-9632:
Summary: SlotPool should notify the caller when allocateSlot meet an
exception (was: SlotPool should
shuai.xu created FLINK-9293:
---
Summary: SlotPool should check slot id when accepting a slot offer
with existing allocation id
Key: FLINK-9293
URL: https://issues.apache.org/jira/browse/FLINK-9293
Project:
shuai.xu created FLINK-8938:
---
Summary: Not remove job graph during job master failover
Key: FLINK-8938
URL: https://issues.apache.org/jira/browse/FLINK-8938
Project: Flink
Issue Type: Bug
shuai.xu created FLINK-8442:
---
Summary: Should recovery the input split when an execution
failover with FailoverRegion
Key: FLINK-8442
URL: https://issues.apache.org/jira/browse/FLINK-8442
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu closed FLINK-4504.
---
Resolution: Won't Fix
> Support user to decide whether the result of an operator is presistent
>
[
https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu closed FLINK-.
---
Resolution: Won't Fix
> Add a DFSInputChannel and DFSSubPartition
> -
[
https://issues.apache.org/jira/browse/FLINK-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu closed FLINK-8289.
---
Resolution: Fixed
Fix Version/s: 1.5.0
> The RestServerEndpoint should return the address with real ip
[
https://issues.apache.org/jira/browse/FLINK-8434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu updated FLINK-8434:
Description: The app master which container the job master and yarn
resource manager may failover during
shuai.xu created FLINK-8434:
---
Summary: The new yarn resource manager should take over the
running task managers after failover
Key: FLINK-8434
URL: https://issues.apache.org/jira/browse/FLINK-8434
Project:
shuai.xu created FLINK-8399:
---
Summary: Use independent configurations for the different timeouts
in slot manager
Key: FLINK-8399
URL: https://issues.apache.org/jira/browse/FLINK-8399
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-8399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu updated FLINK-8399:
Description: There are three parameter in slot manager to indicate the
timeout for slot request to task
[
https://issues.apache.org/jira/browse/FLINK-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16303117#comment-16303117
]
shuai.xu commented on FLINK-8289:
-
The RestServerEndpoint should never know whether there is a proxy, so I
[
https://issues.apache.org/jira/browse/FLINK-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16297920#comment-16297920
]
shuai.xu commented on FLINK-8289:
-
Hi [~eronwright], yes, what we need is the advertised address. But for
[
https://issues.apache.org/jira/browse/FLINK-7878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu closed FLINK-7878.
---
> Extend the resource type user can define in ResourceSpec
>
[
https://issues.apache.org/jira/browse/FLINK-6434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu closed FLINK-6434.
---
> There may be allocatedSlots leak in SlotPool
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-7928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu closed FLINK-7928.
---
> Extend the filed in ResourceProfile for precisely calculating the resource of
> a task manager
>
[
https://issues.apache.org/jira/browse/FLINK-5793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu closed FLINK-5793.
---
> Running slot may not be add to AllocatedMap in SlotPool
>
[
https://issues.apache.org/jira/browse/FLINK-5171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu closed FLINK-5171.
---
> Wrong use of Preconditions.checkState in TaskManagerRunner
>
[
https://issues.apache.org/jira/browse/FLINK-5190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu closed FLINK-5190.
---
> ZooKeeperLeaderRetrievalService should not close the zk client when stop
>
[
https://issues.apache.org/jira/browse/FLINK-5170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu closed FLINK-5170.
---
> getAkkaConfig will use localhost if hostname is specified
>
[
https://issues.apache.org/jira/browse/FLINK-8288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu updated FLINK-8288:
Affects Version/s: 1.5.0
> Register the web interface url to yarn for yarn job mode
>
[
https://issues.apache.org/jira/browse/FLINK-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu updated FLINK-8289:
Affects Version/s: 1.5.0
> The RestServerEndpoint should return the address with real ip when
>
shuai.xu created FLINK-8289:
---
Summary: The RestServerEndpoint should return the address with
real ip when getRestAdddress
Key: FLINK-8289
URL: https://issues.apache.org/jira/browse/FLINK-8289
Project:
shuai.xu created FLINK-8288:
---
Summary: Register the web interface url to yarn for yarn job mode
Key: FLINK-8288
URL: https://issues.apache.org/jira/browse/FLINK-8288
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-8266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu updated FLINK-8266:
Labels: flip-6 (was: )
> Add network memory to ResourceProfile
> -
>
>
shuai.xu created FLINK-8266:
---
Summary: Add network memory to ResourceProfile
Key: FLINK-8266
URL: https://issues.apache.org/jira/browse/FLINK-8266
Project: Flink
Issue Type: Improvement
shuai.xu created FLINK-8224:
---
Summary: Should shudownApplication when job terminated in job mode
Key: FLINK-8224
URL: https://issues.apache.org/jira/browse/FLINK-8224
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-7870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu closed FLINK-7870.
---
> SlotPool should cancel the slot request to RM if not need any more.
>
[
https://issues.apache.org/jira/browse/FLINK-7970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu updated FLINK-7970:
Description:
Now all slot allocation is one by one from execution to slot pool. If batch
allocate a number
[
https://issues.apache.org/jira/browse/FLINK-7970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu updated FLINK-7970:
Attachment: sp.jpg
> SlotPool support batch allocating slots
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-7970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu updated FLINK-7970:
Description:
Now all slot allocation is one by one from execution to slot pool. If batch
allocate a number
shuai.xu created FLINK-7970:
---
Summary: SlotPool support batch allocating slots
Key: FLINK-7970
URL: https://issues.apache.org/jira/browse/FLINK-7970
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-7969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu reassigned FLINK-7969:
---
Assignee: shuai.xu
> Resource manager support batch request slots
>
[
https://issues.apache.org/jira/browse/FLINK-7969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu updated FLINK-7969:
Labels: flip-6 (was: )
> Resource manager support batch request slots
>
shuai.xu created FLINK-7969:
---
Summary: Resource manager support batch request slots
Key: FLINK-7969
URL: https://issues.apache.org/jira/browse/FLINK-7969
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-7969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu updated FLINK-7969:
Description:
!https://issues.apache.org/jira/secure/attachment/12895559/rm.jpg! Now resource
manager only
[
https://issues.apache.org/jira/browse/FLINK-7969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu updated FLINK-7969:
Description:
!https://issues.apache.org/jira/secure/attachment/12895559/rm.jpg!Now resource
manager only
[
https://issues.apache.org/jira/browse/FLINK-7969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu updated FLINK-7969:
Description:
Now resource manager only support requesting slot one by one, it's better to
make it support
[
https://issues.apache.org/jira/browse/FLINK-7969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu updated FLINK-7969:
Attachment: (was: rm.png)
> Resource manager support batch request slots
>
[
https://issues.apache.org/jira/browse/FLINK-7969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu updated FLINK-7969:
Description:
Now resource manager only support requesting slot one by one, it's better to
make it support
[
https://issues.apache.org/jira/browse/FLINK-7969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu updated FLINK-7969:
Attachment: rm.jpg
> Resource manager support batch request slots
>
[
https://issues.apache.org/jira/browse/FLINK-7969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu updated FLINK-7969:
Attachment: rm.png
> Resource manager support batch request slots
>
[
https://issues.apache.org/jira/browse/FLINK-7969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu updated FLINK-7969:
Description:
Now resource manager only support requesting slot one by one, it's better to
make it support
[
https://issues.apache.org/jira/browse/FLINK-7871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu reassigned FLINK-7871:
---
Assignee: shuai.xu
> SlotPool should release its unused slot to RM
>
[
https://issues.apache.org/jira/browse/FLINK-7928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu updated FLINK-7928:
Labels: flip-6 (was: )
> Extend the filed in ResourceProfile for precisely calculating the resource of
>
shuai.xu created FLINK-7928:
---
Summary: Extend the filed in ResourceProfile for precisely
calculating the resource of a task manager
Key: FLINK-7928
URL: https://issues.apache.org/jira/browse/FLINK-7928
[
https://issues.apache.org/jira/browse/FLINK-7878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu updated FLINK-7878:
Labels: flip-6 (was: )
> Extend the resource type user can define in ResourceSpec
>
[
https://issues.apache.org/jira/browse/FLINK-7878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu reassigned FLINK-7878:
---
Assignee: shuai.xu
> Extend the resource type user can define in ResourceSpec
>
shuai.xu created FLINK-7878:
---
Summary: Extend the resource type user can define in ResourceSpec
Key: FLINK-7878
URL: https://issues.apache.org/jira/browse/FLINK-7878
Project: Flink
Issue Type: Bug
shuai.xu created FLINK-7871:
---
Summary: SlotPool should release its unused slot to RM
Key: FLINK-7871
URL: https://issues.apache.org/jira/browse/FLINK-7871
Project: Flink
Issue Type: Bug
shuai.xu created FLINK-7870:
---
Summary: SlotPool should cancel the slot request to RM if not need
any more.
Key: FLINK-7870
URL: https://issues.apache.org/jira/browse/FLINK-7870
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu closed FLINK-5868.
---
Resolution: Fixed
Fix Version/s: 1.3.0
> Implement a new RestartStrategy that works for the
[
https://issues.apache.org/jira/browse/FLINK-5867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu closed FLINK-5867.
---
Resolution: Fixed
Fix Version/s: 1.3.0
> The implementation of RestartPipelinedRegionStrategy
>
[
https://issues.apache.org/jira/browse/FLINK-5866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu closed FLINK-5866.
---
Resolution: Fixed
Fix Version/s: 1.3.0
> The implementation of FailoverRegion.
>
[
https://issues.apache.org/jira/browse/FLINK-5857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu closed FLINK-5857.
---
Resolution: Duplicate
> Recycle idle containers in time for yarn mode
>
[
https://issues.apache.org/jira/browse/FLINK-5857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16076347#comment-16076347
]
shuai.xu commented on FLINK-5857:
-
[~till.rohrmann] sure
> Recycle idle containers in time for yarn mode
[
https://issues.apache.org/jira/browse/FLINK-6434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16073081#comment-16073081
]
shuai.xu commented on FLINK-6434:
-
[~till.rohrmann] Sorry, I have not start working on it
> There may be
[
https://issues.apache.org/jira/browse/FLINK-6434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16000435#comment-16000435
]
shuai.xu commented on FLINK-6434:
-
Yes, add a request id can solve the problem.
> There may be
[
https://issues.apache.org/jira/browse/FLINK-6434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16000232#comment-16000232
]
shuai.xu edited comment on FLINK-6434 at 5/8/17 7:11 AM:
-
[~till.rohrmann] This
[
https://issues.apache.org/jira/browse/FLINK-6434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16000232#comment-16000232
]
shuai.xu commented on FLINK-6434:
-
[~till.rohrmann] This seems can not fix the bug totally, as between
[
https://issues.apache.org/jira/browse/FLINK-6434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu updated FLINK-6434:
Description: If the call allocateSlot() from Execution to Slotpool timeout,
the job will begin to failover,
1 - 100 of 137 matches
Mail list logo
