look for help about task hooks of storm-compatibility

Hi @mjsax @StephanEwen @rmetzger Can you give me some suggestion about my idea of how to transfer user-defined class code to task? Thank you very much! Regards Fengbin Fang # Dear all, I am work on task hooks of storm-compatibility. Storm support add hook through the Storm

look for help about task hooks of storm-compatibility

Dear all, I am work on task hooks of storm-compatibility. Storm support add hook through the Storm configuration using the "topology.auto.task.hooks" config. Users can use user-defined hooks class names as value of "topology.auto.task.hooks" of Configuration Map. These hooks are automatically r

[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

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

[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

Test about Improve performance of call system.currentTimeMillis()

Hello! I have a test about cost of System.currentTimeMillis() and my CLOCK.currentTimeMillis() .( My clock will be a JVM singleton) Call currentTimeMillis function 1 times, System.currentTimeMillis() need about 1902ms and my CLOCK.currentTimeMillis() only need 119ms. The function perfor

Improve performance of call system.currentTimeMillis()

Hello Some operators call system.currentTimeMillis() frequently and it is cost performance. I want to use a thread to call System.currentTimeMillis and update a long variable millTime. All other module do not need call System.currentTimeMillis() and can get millTime directly. I want to know

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

[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

[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

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

[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

[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