[jira] [Created] (FLINK-35502) compress the checkpoint metadata ZK/ETCD HA Services

Ying Z created FLINK-35502: -- Summary: compress the checkpoint metadata ZK/ETCD HA Services Key: FLINK-35502 URL: https://issues.apache.org/jira/browse/FLINK-35502 Project: Flink Issue Type: Improvem

[jira] [Updated] (FLINK-35502) compress the checkpoint metadata generated by ZK/ETCD HA Services

[ https://issues.apache.org/jira/browse/FLINK-35502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ying Z updated FLINK-35502: --- Summary: compress the checkpoint metadata generated by ZK/ETCD HA Services (was: compress the checkpoint me

[jira] [Updated] (FLINK-35502) compress the checkpoint metadata generated by ZK/ETCD HA Services

[ https://issues.apache.org/jira/browse/FLINK-35502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ying Z updated FLINK-35502: --- Description: In the implementation of Flink HA, the metadata of checkpoints is stored in either Zookeeper (

[jira] [Updated] (FLINK-35502) compress the checkpoint metadata generated by ZK/ETCD HA Services

[ https://issues.apache.org/jira/browse/FLINK-35502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ying Z updated FLINK-35502: --- Description: In the implementation of Flink HA, the metadata of checkpoints is stored in either Zookeeper (

[jira] [Commented] (FLINK-35502) compress the checkpoint metadata generated by ZK/ETCD HA Services

[ https://issues.apache.org/jira/browse/FLINK-35502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17851346#comment-17851346 ] Ying Z commented on FLINK-35502: [~roman]  My usage scenario is as follows: The checkpoi

[jira] [Commented] (FLINK-35502) compress the checkpoint metadata generated by ZK/ETCD HA Services

[ https://issues.apache.org/jira/browse/FLINK-35502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17851859#comment-17851859 ] Ying Z commented on FLINK-35502: Yes, I understand that using cron + savepoint can parti

[jira] [Created] (FLINK-19244) CsvRowDataDeserializationSchema throws cast exception : Row length mismatch.

Ying Z created FLINK-19244: -- Summary: CsvRowDataDeserializationSchema throws cast exception : Row length mismatch. Key: FLINK-19244 URL: https://issues.apache.org/jira/browse/FLINK-19244 Project: Flink

[jira] [Comment Edited] (FLINK-19244) CsvRowDataDeserializationSchema throws cast exception : Row length mismatch.

[ https://issues.apache.org/jira/browse/FLINK-19244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17196636#comment-17196636 ] Ying Z edited comment on FLINK-19244 at 9/16/20, 2:59 AM: -- [~ja

[jira] [Commented] (FLINK-19244) CsvRowDataDeserializationSchema throws cast exception : Row length mismatch.

[ https://issues.apache.org/jira/browse/FLINK-19244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17196636#comment-17196636 ] Ying Z commented on FLINK-19244: [~jark] ignoreParseErrors=true will skip this record x

[jira] [Commented] (FLINK-19244) CsvRowDataDeserializationSchema throws cast exception : Row length mismatch.

[ https://issues.apache.org/jira/browse/FLINK-19244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17196668#comment-17196668 ] Ying Z commented on FLINK-19244: [~jark] Thanks for your advice, this will lead the use

[jira] [Commented] (FLINK-19244) CsvRowDataDeserializationSchema throws cast exception : Row length mismatch.

[ https://issues.apache.org/jira/browse/FLINK-19244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17198768#comment-17198768 ] Ying Z commented on FLINK-19244: [~jark] I try to pull a request, and cloud you help to

[jira] [Commented] (FLINK-19298) Maven enforce goal dependency-convergence failed on flink-json

[ https://issues.apache.org/jira/browse/FLINK-19298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17200745#comment-17200745 ] Ying Z commented on FLINK-19298: For com.google.guava:guava:19.0 and 16.0.1, I think we

[jira] [Created] (FLINK-15719) Exceptions when using scala types directly with the State Process API

Ying Z created FLINK-15719: -- Summary: Exceptions when using scala types directly with the State Process API Key: FLINK-15719 URL: https://issues.apache.org/jira/browse/FLINK-15719 Project: Flink Is

[jira] [Commented] (FLINK-15719) Exceptions when using scala types directly with the State Process API

[ https://issues.apache.org/jira/browse/FLINK-15719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17186212#comment-17186212 ] Ying Z commented on FLINK-15719: I pull a request here, [https://github.com/apache/flink

[jira] [Created] (FLINK-18782) How to retain the column'name when convert a Table to DataStream

Ying Z created FLINK-18782: -- Summary: How to retain the column'name when convert a Table to DataStream Key: FLINK-18782 URL: https://issues.apache.org/jira/browse/FLINK-18782 Project: Flink Issue T

[jira] [Commented] (FLINK-18782) Retain the column name when converting a Table to a DataStream

[ https://issues.apache.org/jira/browse/FLINK-18782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168996#comment-17168996 ] Ying Z commented on FLINK-18782: [~jark] Thanks for your advice ^_^ I have already trie

[jira] [Commented] (FLINK-15719) Exceptions when using scala types directly with the State Process API

[ https://issues.apache.org/jira/browse/FLINK-15719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17173617#comment-17173617 ] Ying Z commented on FLINK-15719: Hi, [~tzulitai] , I want to help to modify the doc [1]