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

2019-09-05 Thread Yu Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Yang resolved FLINK-12389. - Resolution: Fixed > flink codegen set String type for ByteBuffer fields > --

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

2019-09-05 Thread Yu Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16923694#comment-16923694 ] Yu Yang commented on FLINK-12389: - Resolving this issue as `not a bug`  as we had been a

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

2019-05-01 Thread Yu Yang (JIRA)
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] [Comment Edited] (FLINK-12389) flink codegen set String type for ByteBuffer fields

2019-05-01 Thread Yu Yang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16831429#comment-16831429 ] Yu Yang edited comment on FLINK-12389 at 5/2/19 6:30 AM: - [~fhue

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

2019-05-01 Thread Yu Yang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16831429#comment-16831429 ] Yu Yang commented on FLINK-12389: - [~fhue...@gmail.com] could you share any pointers on

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

2019-05-02 Thread Yu Yang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16831745#comment-16831745 ] Yu Yang commented on FLINK-12389: - [~twalthr], [~fhueske] thanks for the reply! given t

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

2019-05-02 Thread Yu Yang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16831745#comment-16831745 ] Yu Yang edited comment on FLINK-12389 at 5/2/19 4:42 PM: - [~twal

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

2019-10-03 Thread Yu Yang (Jira)
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 Type

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

2019-03-27 Thread Yu Yang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16803603#comment-16803603 ] Yu Yang commented on FLINK-11746: - [~tiwalter]  Could you help to review this PR?  > Ad

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

2019-04-15 Thread Yu Yang (JIRA)
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 Co

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

2019-04-15 Thread Yu Yang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Yang updated FLINK-12206: Description: We feed list of events with the following RowTypeInfo  to flink, {code:java} Row( timestamp

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

2019-04-15 Thread Yu Yang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Yang updated FLINK-12206: Description: We feed list of events with the following RowTypeInfo  to flink, {code:java} Row( timestamp

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

2020-03-04 Thread Yu Yang (Jira)
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-11746) Add thrift format support in Flink

2019-02-25 Thread Yu Yang (JIRA)
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 Co

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

2021-01-01 Thread Yu Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17257252#comment-17257252 ] Yu Yang commented on FLINK-19402: - [~chesnay]  Could you tell how we can get `timestamp(

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

2021-01-01 Thread Yu Yang (Jira)
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 Issue

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

2020-09-24 Thread Yu Yang (Jira)
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 Iss

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

2020-09-25 Thread Yu Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17202087#comment-17202087 ] Yu Yang commented on FLINK-19402: - [~chesnay]  That seems sufficient. Has the change bee

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

2020-05-28 Thread Yu Yang (Jira)
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 P

[jira] [Updated] (FLINK-18017) have Kafka connector report metrics on null records

2020-05-29 Thread Yu Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Yang updated FLINK-18017: Summary: have Kafka connector report metrics on null records (was: improve Kafka connector to handle rec

[jira] [Updated] (FLINK-18017) have Kafka connector report metrics on null records

2020-05-29 Thread Yu Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Yang updated FLINK-18017: Description: Corrupted messages can get into the message pipeline for various reasons.  When a Flink dese

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

2020-07-21 Thread Yu Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17162176#comment-17162176 ] Yu Yang commented on FLINK-11746: -   [~f.pompermaier]  we did not get time to work on t

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

2020-07-21 Thread Yu Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17162176#comment-17162176 ] Yu Yang edited comment on FLINK-11746 at 7/21/20, 5:03 PM: --- [~

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

2020-12-11 Thread Yu Yang (Jira)
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] [Updated] (FLINK-20575) flink application failed to restore from check-point

2020-12-11 Thread Yu Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Yang updated FLINK-20575: Description: Our flink application failed to restore from a check-point due to  com.amazonaws.AbortedExcep

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

2020-12-11 Thread Yu Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Yang resolved FLINK-20575. - Release Note: i think that the issue is due to task cancelling that was caused by other exception. res