[
https://issues.apache.org/jira/browse/FLINK-2391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14642675#comment-14642675
]
fangfengbin commented on FLINK-2391:
Thank you very much!
> Storm-compatibility:metho
[
https://issues.apache.org/jira/browse/FLINK-2391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14642673#comment-14642673
]
fangfengbin commented on FLINK-2391:
Thank you very much!
> Storm-compatibility:metho
[
https://issues.apache.org/jira/browse/FLINK-2391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14642674#comment-14642674
]
fangfengbin commented on FLINK-2391:
Thank you very much!
> Storm-compatibility:metho
[
https://issues.apache.org/jira/browse/FLINK-2391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14642672#comment-14642672
]
fangfengbin commented on FLINK-2391:
Thank you very much!
> Storm-compatibility:metho
[
https://issues.apache.org/jira/browse/FLINK-2391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
fangfengbin updated FLINK-2391:
---
Comment: was deleted
(was: Thank you very much!)
> Storm-compatibility:method FlinkTopologyBuilder.cr
[
https://issues.apache.org/jira/browse/FLINK-2391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
fangfengbin updated FLINK-2391:
---
Comment: was deleted
(was: Thank you very much!)
> Storm-compatibility:method FlinkTopologyBuilder.cr
[
https://issues.apache.org/jira/browse/FLINK-2391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
fangfengbin updated FLINK-2391:
---
Comment: was deleted
(was: Thank you very much!)
> Storm-compatibility:method FlinkTopologyBuilder.cr
fangfengbin created FLINK-2446:
--
Summary: SocketTextStreamFunction has memory leak when reconnect
server
Key: FLINK-2446
URL: https://issues.apache.org/jira/browse/FLINK-2446
Project: Flink
Iss
fangfengbin created FLINK-2465:
--
Summary: SocketClientSink closeConnection function has memory leak
Key: FLINK-2465
URL: https://issues.apache.org/jira/browse/FLINK-2465
Project: Flink
Issue Typ
fangfengbin created FLINK-2471:
--
Summary: FileSinkFunction invoke performance optimize
Key: FLINK-2471
URL: https://issues.apache.org/jira/browse/FLINK-2471
Project: Flink
Issue Type: Improvemen
fangfengbin created FLINK-2476:
--
Summary: Remove unwanted check null of input1 in
ConnectedDataStream
Key: FLINK-2476
URL: https://issues.apache.org/jira/browse/FLINK-2476
Project: Flink
Issue
fangfengbin created FLINK-2483:
--
Summary: Add default branch of switch(scheduleMode) in
scheduleForExecution function
Key: FLINK-2483
URL: https://issues.apache.org/jira/browse/FLINK-2483
Project: Flink
fangfengbin created FLINK-2486:
--
Summary: Remove unwanted null check in removeInstance function
Key: FLINK-2486
URL: https://issues.apache.org/jira/browse/FLINK-2486
Project: Flink
Issue Type: B
fangfengbin created FLINK-2494:
--
Summary: Fix StreamGraph getJobGraph bug
Key: FLINK-2494
URL: https://issues.apache.org/jira/browse/FLINK-2494
Project: Flink
Issue Type: Bug
Component
fangfengbin created FLINK-2507:
--
Summary: Rename the function tansformAndEmit in
org.apache.flink.stormcompatibility.wrappers.AbstractStormCollector
Key: FLINK-2507
URL: https://issues.apache.org/jira/browse/FLINK-25
fangfengbin created FLINK-2512:
--
Summary: Add client.close() before throw RuntimeException
Key: FLINK-2512
URL: https://issues.apache.org/jira/browse/FLINK-2512
Project: Flink
Issue Type: Bug
fangfengbin created FLINK-2516:
--
Summary: Remove unwanted log.isInfoEnabled check
Key: FLINK-2516
URL: https://issues.apache.org/jira/browse/FLINK-2516
Project: Flink
Issue Type: Bug
C
fangfengbin created FLINK-2525:
--
Summary: Add configuration support in Storm-compatibility
Key: FLINK-2525
URL: https://issues.apache.org/jira/browse/FLINK-2525
Project: Flink
Issue Type: New Fe
fangfengbin created FLINK-2526:
--
Summary: Add catch{} for task when it stop running
Key: FLINK-2526
URL: https://issues.apache.org/jira/browse/FLINK-2526
Project: Flink
Issue Type: Bug
fangfengbin created FLINK-2530:
--
Summary: optimize equal() of AcknowledgeCheckpoint
Key: FLINK-2530
URL: https://issues.apache.org/jira/browse/FLINK-2530
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-2526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
fangfengbin closed FLINK-2526.
--
Resolution: Fixed
> Add catch{} for task when it stop running
> ---
fangfengbin created FLINK-2571:
--
Summary: Add task hooks support in Storm-compatibility
Key: FLINK-2571
URL: https://issues.apache.org/jira/browse/FLINK-2571
Project: Flink
Issue Type: New Feat
22 matches
Mail list logo