[jira] [Commented] (FLINK-2391) Storm-compatibility:method FlinkTopologyBuilder.createTopology() throws java.lang.NullPointerException

[ 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

[jira] [Commented] (FLINK-2391) Storm-compatibility:method FlinkTopologyBuilder.createTopology() throws java.lang.NullPointerException

[ 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

[jira] [Commented] (FLINK-2391) Storm-compatibility:method FlinkTopologyBuilder.createTopology() throws java.lang.NullPointerException

[ 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

[jira] [Commented] (FLINK-2391) Storm-compatibility:method FlinkTopologyBuilder.createTopology() throws java.lang.NullPointerException

[ 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

[jira] [Issue Comment Deleted] (FLINK-2391) Storm-compatibility:method FlinkTopologyBuilder.createTopology() throws java.lang.NullPointerException

[ 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

[jira] [Issue Comment Deleted] (FLINK-2391) Storm-compatibility:method FlinkTopologyBuilder.createTopology() throws java.lang.NullPointerException

[ 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

[jira] [Issue Comment Deleted] (FLINK-2391) Storm-compatibility:method FlinkTopologyBuilder.createTopology() throws java.lang.NullPointerException

[ 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

[jira] [Created] (FLINK-2446) SocketTextStreamFunction has memory leak when reconnect server

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

[jira] [Created] (FLINK-2465) SocketClientSink closeConnection function has memory leak

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

[jira] [Created] (FLINK-2471) FileSinkFunction invoke performance optimize

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

[jira] [Created] (FLINK-2476) Remove unwanted check null of input1 in ConnectedDataStream

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

[jira] [Created] (FLINK-2483) Add default branch of switch(scheduleMode) in scheduleForExecution function

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

[jira] [Created] (FLINK-2486) Remove unwanted null check in removeInstance function

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

[jira] [Created] (FLINK-2494) Fix StreamGraph getJobGraph bug

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

[jira] [Created] (FLINK-2507) Rename the function tansformAndEmit in org.apache.flink.stormcompatibility.wrappers.AbstractStormCollector

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

[jira] [Created] (FLINK-2512) Add client.close() before throw RuntimeException

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

[jira] [Created] (FLINK-2516) Remove unwanted log.isInfoEnabled check

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

[jira] [Created] (FLINK-2525) Add configuration support in Storm-compatibility

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

[jira] [Created] (FLINK-2526) Add catch{} for task when it stop running

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

[jira] [Created] (FLINK-2530) optimize equal() of AcknowledgeCheckpoint

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

[jira] [Closed] (FLINK-2526) Add catch{} for task when it stop running

[ 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 > ---

[jira] [Created] (FLINK-2571) Add task hooks support in Storm-compatibility

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