[jira] [Created] (FLINK-20829) flink.jm.downtime metric is inaccurate in flink 1.9.1 and 1.11.1

Yu Yang created FLINK-20829: --- Summary: flink.jm.downtime metric is inaccurate in flink 1.9.1 and 1.11.1 Key: FLINK-20829 URL: https://issues.apache.org/jira/browse/FLINK-20829 Project: Flink

[jira] [Created] (FLINK-20575) flink application failed to restore from check-point

Yu Yang created FLINK-20575: --- Summary: flink application failed to restore from check-point Key: FLINK-20575 URL: https://issues.apache.org/jira/browse/FLINK-20575 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-19402) Metrics for measuring Flink application deployment latency in Yarn

Yu Yang created FLINK-19402: --- Summary: Metrics for measuring Flink application deployment latency in Yarn Key: FLINK-19402 URL: https://issues.apache.org/jira/browse/FLINK-19402 Project: Flink

Re: thrift support

Thanks for the discussion. In https://github.com/apache/flink/pull/8067 we made an initial version on adding thrift-format support in flink, and haven't got time to finish it. Feel free to take it over and make changes. I've also linked this discussion thread in https://issues.apache.org/jira/brows

[jira] [Created] (FLINK-18017) improve Kafka connector to handle record deserialization exception and report related metrics

Yu Yang created FLINK-18017: --- Summary: improve Kafka connector to handle record deserialization exception and report related metrics Key: FLINK-18017 URL: https://issues.apache.org/jira/browse/FLINK-18017

[jira] [Created] (FLINK-16429) failed to restore flink job from checkpoints due to unhandled exceptions

Yu Yang created FLINK-16429: --- Summary: failed to restore flink job from checkpoints due to unhandled exceptions Key: FLINK-16429 URL: https://issues.apache.org/jira/browse/FLINK-16429 Project: Flink

[jira] [Created] (FLINK-14317) make hadoop history server logs accessible through flink ui

Yu Yang created FLINK-14317: --- Summary: make hadoop history server logs accessible through flink ui Key: FLINK-14317 URL: https://issues.apache.org/jira/browse/FLINK-14317 Project: Flink Issue

[jira] [Created] (FLINK-12389) flink codegen set String type for ByteBuffer fields

Yu Yang created FLINK-12389: --- Summary: flink codegen set String type for ByteBuffer fields Key: FLINK-12389 URL: https://issues.apache.org/jira/browse/FLINK-12389 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-12206) cannot query nested fields using Flink SQL

Yu Yang created FLINK-12206: --- Summary: cannot query nested fields using Flink SQL Key: FLINK-12206 URL: https://issues.apache.org/jira/browse/FLINK-12206 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-11746) Add thrift format support in Flink

Yu Yang created FLINK-11746: --- Summary: Add thrift format support in Flink Key: FLINK-11746 URL: https://issues.apache.org/jira/browse/FLINK-11746 Project: Flink Issue Type: New Feature