[jira] [Commented] (FLINK-6115) Need more helpful error message when trying to serialize a tuple with a null field

2017-03-29 Thread fang yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15948396#comment-15948396 ] fang yong commented on FLINK-6115: -- OMG, null value not be supported in tuple really suprised me, and my

[jira] [Assigned] (FLINK-6210) RocksDB instance should be closed in ListViaMergeSpeedMiniBenchmark

2017-03-29 Thread fang yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] fang yong reassigned FLINK-6210: Assignee: fang yong > RocksDB instance should be closed in ListViaMergeSpeedMiniBenchmark >

[jira] [Commented] (FLINK-6058) Don't read DEFAULT_PARALLELISM from GlobalConfiguration

2017-03-16 Thread fang yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15927578#comment-15927578 ] fang yong commented on FLINK-6058: -- Read default parallelism from ContextEnviroment sounds good. But what

[jira] [Commented] (FLINK-5978) JM WebFrontend address ConfigOption is defined in ConfigConstants

2017-03-15 Thread fang yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15927411#comment-15927411 ] fang yong commented on FLINK-5978: -- Hi Chesnay Schepler, glad to see an easy issue while I'm new, could

[jira] [Commented] (FLINK-6288) FlinkKafkaProducer's custom Partitioner is always invoked with number of partitions of default topic

2017-04-21 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15978304#comment-15978304 ] Fang Yong commented on FLINK-6288: -- Hi [~tzulitai], I'll pick this issue if nobody follows it, thanks. >

[jira] [Assigned] (FLINK-6288) FlinkKafkaProducer's custom Partitioner is always invoked with number of partitions of default topic

2017-04-21 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-6288: Assignee: Fang Yong > FlinkKafkaProducer's custom Partitioner is always invoked with number of >

[jira] [Created] (FLINK-6352) FlinkKafkaConsumer should support to use timestamp to set up start offset

2017-04-21 Thread Fang Yong (JIRA)
Fang Yong created FLINK-6352: Summary: FlinkKafkaConsumer should support to use timestamp to set up start offset Key: FLINK-6352 URL: https://issues.apache.org/jira/browse/FLINK-6352 Project: Flink

[jira] [Updated] (FLINK-6352) FlinkKafkaConsumer should support to use timestamp to set up start offset

2017-04-21 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong updated FLINK-6352: - Description: Currently "auto.offset.reset" is used to initialize the start offset of

[jira] [Commented] (FLINK-6352) FlinkKafkaConsumer should support to use timestamp to set up start offset

2017-04-21 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15978177#comment-15978177 ] Fang Yong commented on FLINK-6352: -- Hi [~tzulitai], [~rmetzger], what do you think about this? Or anyone

[jira] [Commented] (FLINK-6333) Utilize Bloomfilters in RocksDb

2017-04-19 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15976008#comment-15976008 ] Fang Yong commented on FLINK-6333: -- Now flink uses RocksDb jni 4.11.2, and already support setFilter(new

[jira] [Commented] (FLINK-6288) FlinkKafkaProducer's custom Partitioner is always invoked with number of partitions of default topic

2017-04-23 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15980636#comment-15980636 ] Fang Yong commented on FLINK-6288: -- Thanks for providing the mailing list for this issue, I think this is

[jira] [Comment Edited] (FLINK-6288) FlinkKafkaProducer's custom Partitioner is always invoked with number of partitions of default topic

2017-04-23 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15980636#comment-15980636 ] Fang Yong edited comment on FLINK-6288 at 4/24/17 2:18 AM: --- Thanks for

[jira] [Assigned] (FLINK-6352) FlinkKafkaConsumer should support to use timestamp to set up start offset

2017-04-23 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-6352: Assignee: Fang Yong > FlinkKafkaConsumer should support to use timestamp to set up start offset >

[jira] [Created] (FLINK-6366) KafkaConsumer is not closed in FlinkKafkaConsumer09

2017-04-24 Thread Fang Yong (JIRA)
Fang Yong created FLINK-6366: Summary: KafkaConsumer is not closed in FlinkKafkaConsumer09 Key: FLINK-6366 URL: https://issues.apache.org/jira/browse/FLINK-6366 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-6366) KafkaConsumer is not closed in FlinkKafkaConsumer09

2017-04-24 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-6366: Assignee: Fang Yong > KafkaConsumer is not closed in FlinkKafkaConsumer09 >

[jira] [Commented] (FLINK-6219) Add a state backend which supports sorting

2017-04-19 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15974314#comment-15974314 ] Fang Yong commented on FLINK-6219: -- Hi [~fhueske], the SortedQueueState sounds good. In addtion to use of

[jira] [Assigned] (FLINK-7307) Add proper command line parsing tool to ClusterEntrypoint

2017-08-04 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-7307: Assignee: Fang Yong > Add proper command line parsing tool to ClusterEntrypoint >

[jira] [Commented] (FLINK-7307) Add proper command line parsing tool to ClusterEntrypoint

2017-08-04 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16114122#comment-16114122 ] Fang Yong commented on FLINK-7307: -- Sorry to see this late, I will use {{CommandLine}} to parse configDir

[jira] [Assigned] (FLINK-7417) Create flink-shaded-jackson

2017-08-10 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-7417: Assignee: (was: Fang Yong) > Create flink-shaded-jackson > --- > >

[jira] [Assigned] (FLINK-7396) Don't put multiple directories in HADOOP_CONF_DIR in config.sh

2017-08-10 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-7396: Assignee: Fang Yong > Don't put multiple directories in HADOOP_CONF_DIR in config.sh >

[jira] [Assigned] (FLINK-7419) Shade jackson dependency in flink-avro

2017-08-10 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-7419: Assignee: Fang Yong > Shade jackson dependency in flink-avro >

[jira] [Assigned] (FLINK-7417) Create flink-shaded-jackson

2017-08-10 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-7417: Assignee: Fang Yong > Create flink-shaded-jackson > --- > >

[jira] [Assigned] (FLINK-7100) TaskManager metrics are registered twice

2017-07-12 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-7100: Assignee: Fang Yong > TaskManager metrics are registered twice >

[jira] [Assigned] (FLINK-6588) Rename NumberOfFullRestarts metric

2017-07-10 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-6588: Assignee: Fang Yong > Rename NumberOfFullRestarts metric > -- > >

[jira] [Assigned] (FLINK-6521) Add per job cleanup methods to HighAvailabilityServices

2017-07-20 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-6521: Assignee: Fang Yong > Add per job cleanup methods to HighAvailabilityServices >

[jira] [Created] (FLINK-7222) Kafka010ITCase fails on windows

2017-07-18 Thread Fang Yong (JIRA)
Fang Yong created FLINK-7222: Summary: Kafka010ITCase fails on windows Key: FLINK-7222 URL: https://issues.apache.org/jira/browse/FLINK-7222 Project: Flink Issue Type: Bug Components:

[jira] [Assigned] (FLINK-7222) Kafka010ITCase fails on windows

2017-07-18 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-7222: Assignee: Fang Yong > Kafka010ITCase fails on windows > --- > >

[jira] [Updated] (FLINK-7222) Kafka010ITCase fails on windows

2017-07-18 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong updated FLINK-7222: - Description: Kafka010ITCase fails on windows for the following resions {code} java.lang.AssertionError:

[jira] [Assigned] (FLINK-7269) Refactor passing of dynamic properties

2017-07-28 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-7269: Assignee: Fang Yong > Refactor passing of dynamic properties >

[jira] [Assigned] (FLINK-7251) Merge the flink-java8 project into flink-core

2017-07-25 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-7251: Assignee: Fang Yong > Merge the flink-java8 project into flink-core >

[jira] [Assigned] (FLINK-6667) Pass a callback type to the RestartStrategy, rather than the full ExecutionGraph

2017-07-06 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-6667: Assignee: Fang Yong > Pass a callback type to the RestartStrategy, rather than the full >

[jira] [Assigned] (FLINK-7099) Replace usages of deprecated JOB_MANAGER_IPC_PORT_KEY

2017-07-06 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-7099: Assignee: Fang Yong > Replace usages of deprecated JOB_MANAGER_IPC_PORT_KEY >

[jira] [Closed] (FLINK-6366) KafkaConsumer is not closed in FlinkKafkaConsumer09

2017-04-24 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong closed FLINK-6366. Resolution: Invalid As [~tzulitai] said, this change isn't necessary, as the previous implementation was a

[jira] [Assigned] (FLINK-7270) Add support for dynamic properties to cluster entry point

2017-07-30 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-7270: Assignee: Fang Yong > Add support for dynamic properties to cluster entry point >

[jira] [Assigned] (FLINK-6787) Job-/StoppableException should extend FlinkException

2017-08-09 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-6787: Assignee: Fang Yong > Job-/StoppableException should extend FlinkException >

[jira] [Assigned] (FLINK-6864) Remove confusing "invalid POJO type" messages from TypeExtractor

2017-08-22 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-6864: Assignee: Fang Yong > Remove confusing "invalid POJO type" messages from TypeExtractor >

[jira] [Assigned] (FLINK-6346) Migrate from Java serialization for GenericWriteAheadSink's state

2017-05-03 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-6346: Assignee: Fang Yong > Migrate from Java serialization for GenericWriteAheadSink's state >

[jira] [Commented] (FLINK-6564) Build fails on file systems that do not distinguish between upper and lower case

2017-05-11 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007656#comment-16007656 ] Fang Yong commented on FLINK-6564: -- Thank you for your report, and also I meet this problem in windows. I

[jira] [Assigned] (FLINK-6495) Migrate Akka configuration options

2017-05-10 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-6495: Assignee: Fang Yong > Migrate Akka configuration options > -- > >

[jira] [Commented] (FLINK-6495) Migrate Akka configuration options

2017-05-10 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16004313#comment-16004313 ] Fang Yong commented on FLINK-6495: -- [~Zentol], I'd like to pick this issue and create a PR to fix it

[jira] [Created] (FLINK-7010) Lamdba expression in flatMap throws InvalidTypesException in DataSet

2017-06-26 Thread Fang Yong (JIRA)
Fang Yong created FLINK-7010: Summary: Lamdba expression in flatMap throws InvalidTypesException in DataSet Key: FLINK-7010 URL: https://issues.apache.org/jira/browse/FLINK-7010 Project: Flink

[jira] [Updated] (FLINK-7010) Lamdba expression in flatMap throws InvalidTypesException in DataSet

2017-06-26 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong updated FLINK-7010: - Description: When I create an example and use lambda in flatMap as follows {noformat}

[jira] [Updated] (FLINK-7010) Lamdba expression in flatMap throws InvalidTypesException in DataSet

2017-06-26 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong updated FLINK-7010: - Description: When I create an example and use lambda in flatMap as follows {noformat}

[jira] [Updated] (FLINK-7010) Lamdba expression in flatMap throws InvalidTypesException in DataSet

2017-06-26 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong updated FLINK-7010: - Description: When I create an example and use lambda in flatMap as follows {noformat}

[jira] [Assigned] (FLINK-6310) LocalExecutor#endSession() uses wrong lock for synchronization

2017-06-26 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-6310: Assignee: Fang Yong > LocalExecutor#endSession() uses wrong lock for synchronization >

[jira] [Commented] (FLINK-6522) Add ZooKeeper cleanup logic to ZooKeeperHaServices

2017-06-26 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062864#comment-16062864 ] Fang Yong commented on FLINK-6522: -- Hi [~till.rohrmann], I want to pick this issue. If I understand

[jira] [Assigned] (FLINK-6522) Add ZooKeeper cleanup logic to ZooKeeperHaServices

2017-06-27 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-6522: Assignee: Fang Yong > Add ZooKeeper cleanup logic to ZooKeeperHaServices >

[jira] [Commented] (FLINK-7010) Lamdba expression in flatMap throws InvalidTypesException in DataSet

2017-06-27 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16064507#comment-16064507 ] Fang Yong commented on FLINK-7010: -- [~dawidwys] Thank you for your reply. I found some operators such as

[jira] [Assigned] (FLINK-6494) Migrate ResourceManager configuration options

2017-05-22 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-6494: Assignee: Fang Yong > Migrate ResourceManager configuration options >

[jira] [Commented] (FLINK-6494) Migrate ResourceManager configuration options

2017-05-22 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16020675#comment-16020675 ] Fang Yong commented on FLINK-6494: -- Should configurations of yarn and mesos be moved to

[jira] [Commented] (FLINK-6494) Migrate ResourceManager configuration options

2017-05-23 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16022231#comment-16022231 ] Fang Yong commented on FLINK-6494: -- If so, I think another two subtasks should be created to migrate

[jira] [Assigned] (FLINK-6511) JobClient does not properly clean up BlobCache resources

2017-06-06 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-6511: Assignee: Fang Yong > JobClient does not properly clean up BlobCache resources >

[jira] [Assigned] (FLINK-6498) Migrate Zookeeper configuration options

2017-06-06 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-6498: Assignee: Fang Yong > Migrate Zookeeper configuration options >

[jira] [Commented] (FLINK-6511) JobClient does not properly clean up BlobCache resources

2017-06-06 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16038469#comment-16038469 ] Fang Yong commented on FLINK-6511: -- [~till.rohrmann] In the {{retrieveClassLoader}} of {{JobClient}}, I

[jira] [Commented] (FLINK-6511) JobClient does not properly clean up BlobCache resources

2017-06-06 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16040017#comment-16040017 ] Fang Yong commented on FLINK-6511: -- Thank you for your reply [~till.rohrmann], It's sound good! I noted

[jira] [Assigned] (FLINK-6499) Migrate state configuration options

2017-06-14 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-6499: Assignee: Fang Yong > Migrate state configuration options > --- >

[jira] [Assigned] (FLINK-5488) yarnClient should be closed in AbstractYarnClusterDescriptor for error conditions

2017-05-02 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-5488: Assignee: Fang Yong > yarnClient should be closed in AbstractYarnClusterDescriptor for error >

[jira] [Commented] (FLINK-5488) yarnClient should be closed in AbstractYarnClusterDescriptor for error conditions

2017-05-02 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15992576#comment-15992576 ] Fang Yong commented on FLINK-5488: -- It's good to release resources before exception is thown, I'd create

[jira] [Assigned] (FLINK-6439) Unclosed InputStream in OperatorSnapshotUtil#readStateHandle()

2017-05-03 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-6439: Assignee: Fang Yong > Unclosed InputStream in OperatorSnapshotUtil#readStateHandle() >

[jira] [Commented] (FLINK-6343) Migrate from discouraged Java serialization for all sources / sinks

2017-05-08 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16001922#comment-16001922 ] Fang Yong commented on FLINK-6343: -- [~tzulitai] I aggree with you that register two state for compatible

[jira] [Commented] (FLINK-6498) Migrate Zookeeper configuration options

2017-06-06 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16038509#comment-16038509 ] Fang Yong commented on FLINK-6498: -- Hi [~Zentol], I noted that some of Zookeeper configurations is

[jira] [Assigned] (FLINK-6665) Pass a ScheduledExecutorService to the RestartStrategy

2017-06-28 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-6665: Assignee: Fang Yong > Pass a ScheduledExecutorService to the RestartStrategy >

[jira] [Created] (FLINK-7856) Port JobVertexBackPressureHandler to REST endpoint

2017-10-16 Thread Fang Yong (JIRA)
Fang Yong created FLINK-7856: Summary: Port JobVertexBackPressureHandler to REST endpoint Key: FLINK-7856 URL: https://issues.apache.org/jira/browse/FLINK-7856 Project: Flink Issue Type:

[jira] [Created] (FLINK-7855) Port JobVertexAccumulatorsHandler to REST endpoint

2017-10-16 Thread Fang Yong (JIRA)
Fang Yong created FLINK-7855: Summary: Port JobVertexAccumulatorsHandler to REST endpoint Key: FLINK-7855 URL: https://issues.apache.org/jira/browse/FLINK-7855 Project: Flink Issue Type:

[jira] [Created] (FLINK-7858) Port JobVertexTaskManagersHandler to REST endpoint

2017-10-16 Thread Fang Yong (JIRA)
Fang Yong created FLINK-7858: Summary: Port JobVertexTaskManagersHandler to REST endpoint Key: FLINK-7858 URL: https://issues.apache.org/jira/browse/FLINK-7858 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-7858) Port JobVertexTaskManagersHandler to REST endpoint

2017-10-16 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-7858: Assignee: Fang Yong > Port JobVertexTaskManagersHandler to REST endpoint >

[jira] [Created] (FLINK-7857) Port JobVertexDetails to REST endpoint

2017-10-16 Thread Fang Yong (JIRA)
Fang Yong created FLINK-7857: Summary: Port JobVertexDetails to REST endpoint Key: FLINK-7857 URL: https://issues.apache.org/jira/browse/FLINK-7857 Project: Flink Issue Type: Sub-task

[jira] [Assigned] (FLINK-7857) Port JobVertexDetails to REST endpoint

2017-10-16 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-7857: Assignee: Fang Yong > Port JobVertexDetails to REST endpoint >

[jira] [Assigned] (FLINK-7856) Port JobVertexBackPressureHandler to REST endpoint

2017-10-16 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-7856: Assignee: Fang Yong > Port JobVertexBackPressureHandler to REST endpoint >

[jira] [Assigned] (FLINK-7855) Port JobVertexAccumulatorsHandler to REST endpoint

2017-10-16 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-7855: Assignee: Fang Yong > Port JobVertexAccumulatorsHandler to REST endpoint >

[jira] [Assigned] (FLINK-7386) Flink Elasticsearch 5 connector is not compatible with Elasticsearch 5.2+ client

2017-08-30 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-7386: Assignee: Fang Yong > Flink Elasticsearch 5 connector is not compatible with Elasticsearch 5.2+ >

[jira] [Assigned] (FLINK-7495) AbstractUdfStreamOperator#initializeState() should be called in AsyncWaitOperator#initializeState()

2017-08-30 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-7495: Assignee: Fang Yong > AbstractUdfStreamOperator#initializeState() should be called in >

[jira] [Commented] (FLINK-7521) Remove the 10MB limit from the current REST implementation.

2017-09-06 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16156352#comment-16156352 ] Fang Yong commented on FLINK-7521: -- It might be better to add a config option to set this value instead

[jira] [Assigned] (FLINK-7521) Remove the 10MB limit from the current REST implementation.

2017-09-06 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-7521: Assignee: Fang Yong > Remove the 10MB limit from the current REST implementation. >

[jira] [Assigned] (FLINK-7703) Port JobExceptionsHandler to new REST endpoint

2017-09-29 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-7703: Assignee: Fang Yong > Port JobExceptionsHandler to new REST endpoint >

[jira] [Created] (FLINK-7941) Port SubtasksTimesHandler to new REST endpoint

2017-10-29 Thread Fang Yong (JIRA)
Fang Yong created FLINK-7941: Summary: Port SubtasksTimesHandler to new REST endpoint Key: FLINK-7941 URL: https://issues.apache.org/jira/browse/FLINK-7941 Project: Flink Issue Type: Sub-task

[jira] [Assigned] (FLINK-7941) Port SubtasksTimesHandler to new REST endpoint

2017-10-29 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-7941: Assignee: Fang Yong > Port SubtasksTimesHandler to new REST endpoint >

[jira] [Commented] (FLINK-7100) TaskManager metrics are registered twice

2017-10-26 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16221567#comment-16221567 ] Fang Yong commented on FLINK-7100: -- [~Zentol] [~till.rohrmann], thank you for your suggestions. If I

[jira] [Assigned] (FLINK-7712) Port JarDeleteHandler to new REST endpoint

2017-12-21 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-7712: Assignee: Fang Yong > Port JarDeleteHandler to new REST endpoint >

[jira] [Assigned] (FLINK-7711) Port JarListHandler to new REST endpoint

2017-12-21 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-7711: Assignee: Fang Yong > Port JarListHandler to new REST endpoint >

[jira] [Assigned] (FLINK-7714) Port JarPlanHandler to new REST endpoint

2017-12-21 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-7714: Assignee: Fang Yong > Port JarPlanHandler to new REST endpoint >

[jira] [Assigned] (FLINK-7715) Port JarRunHandler to new REST endpoint

2017-12-21 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-7715: Assignee: Fang Yong > Port JarRunHandler to new REST endpoint >

[jira] [Assigned] (FLINK-7713) Port JarUploadHandler to new REST endpoint

2017-12-21 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-7713: Assignee: Fang Yong > Port JarUploadHandler to new REST endpoint >

[jira] [Closed] (FLINK-32755) Add quick start guide for Flink OLAP

2023-09-03 Thread Fang Yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong closed FLINK-32755. - Resolution: Fixed Fixed by fbef3c22757a2352145599487beb84e02aaeb389 > Add quick start guide for Flink

[jira] [Updated] (FLINK-32755) Add quick start guide for Flink OLAP

2023-09-03 Thread Fang Yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong updated FLINK-32755: -- Fix Version/s: 1.19.0 > Add quick start guide for Flink OLAP > >

[jira] [Closed] (FLINK-32396) Support timestamp for jdbc driver and gateway

2023-09-11 Thread Fang Yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong closed FLINK-32396. - Fix Version/s: 1.19.0 Resolution: Fixed Fixed by c33a6527d8383dc571e0b648b8a29322416ab9d6 >

[jira] [Assigned] (FLINK-33051) GlobalFailureHandler interface should be retired in favor of LabeledGlobalFailureHandler

2023-09-13 Thread Fang Yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-33051: - Assignee: Matt Wang > GlobalFailureHandler interface should be retired in favor of >

[jira] [Closed] (FLINK-32968) Fix doc for customized catalog listener

2023-08-31 Thread Fang Yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong closed FLINK-32968. - Fix Version/s: 1.18.0 1.19.0 Resolution: Fixed Fixed by

[jira] [Updated] (FLINK-32755) Add quick start guide for Flink OLAP

2023-08-31 Thread Fang Yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong updated FLINK-32755: -- Parent: FLINK-32898 Issue Type: Sub-task (was: Improvement) > Add quick start guide for

[jira] [Assigned] (FLINK-32396) Support timestamp for jdbc driver and gateway

2023-08-31 Thread Fang Yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-32396: - Assignee: Fang Yong > Support timestamp for jdbc driver and gateway >

[jira] [Updated] (FLINK-32755) Add quick start guide for Flink OLAP

2023-08-31 Thread Fang Yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong updated FLINK-32755: -- Parent: (was: FLINK-32898) Issue Type: Improvement (was: Sub-task) > Add quick start

[jira] [Updated] (FLINK-32755) Add quick start guide for Flink OLAP

2023-08-31 Thread Fang Yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong updated FLINK-32755: -- Parent: FLINK-32898 Issue Type: Sub-task (was: Improvement) > Add quick start guide for

[jira] [Updated] (FLINK-32755) Add quick start guide for Flink OLAP

2023-08-31 Thread Fang Yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong updated FLINK-32755: -- Parent: (was: FLINK-25318) Issue Type: Improvement (was: Sub-task) > Add quick start

[jira] [Closed] (FLINK-32749) Sql gateway supports default catalog loaded by CatalogStore

2023-09-01 Thread Fang Yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong closed FLINK-32749. - Fix Version/s: 1.19.0 Resolution: Fixed Fixed by 1797a70c0074b9e0cbfd20abc2c33050a7906578 > Sql

[jira] [Commented] (FLINK-32667) Use standalone store and embedding writer for jobs with no-restart-strategy in session cluster

2023-09-04 Thread Fang Yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761807#comment-17761807 ] Fang Yong commented on FLINK-32667: --- [~mapohl] As we discussed in the threads

[jira] [Updated] (FLINK-25356) Add benchmarks for performance in OLAP scenarios

2023-09-04 Thread Fang Yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong updated FLINK-25356: -- Parent: (was: FLINK-25318) Issue Type: Technical Debt (was: Sub-task) > Add benchmarks

[jira] [Created] (FLINK-33033) Add haservice micro benchmark for olap

2023-09-04 Thread Fang Yong (Jira)
Fang Yong created FLINK-33033: - Summary: Add haservice micro benchmark for olap Key: FLINK-33033 URL: https://issues.apache.org/jira/browse/FLINK-33033 Project: Flink Issue Type: Sub-task

[jira] [Assigned] (FLINK-33210) Introduce lineage graph relevant interfaces

2023-10-17 Thread Fang Yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-33210: - Assignee: Fang Yong > Introduce lineage graph relevant interfaces >

[jira] [Commented] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship

2023-11-01 Thread Fang Yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17781613#comment-17781613 ] Fang Yong commented on FLINK-31275: --- Hi [~mobuchowski], thanks for your comments. In the currently

[jira] [Comment Edited] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship

2023-11-01 Thread Fang Yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17781613#comment-17781613 ] Fang Yong edited comment on FLINK-31275 at 11/1/23 9:04 AM: Hi

  1   2   3   >