[jira] [Created] (FLINK-27708) Add background compaction task for append-only table when ingesting.

Zheng Hu created FLINK-27708: Summary: Add background compaction task for append-only table when ingesting. Key: FLINK-27708 URL: https://issues.apache.org/jira/browse/FLINK-27708 Project: Flink

[jira] [Created] (FLINK-27706) Refactor all subclasses of FileStoreTableITCase to use the batchSql.

Zheng Hu created FLINK-27706: Summary: Refactor all subclasses of FileStoreTableITCase to use the batchSql. Key: FLINK-27706 URL: https://issues.apache.org/jira/browse/FLINK-27706 Project: Flink

[jira] [Created] (FLINK-27696) Add bin-pack strategy to split the whole bucket data files into several small splits for append-only table.

Zheng Hu created FLINK-27696: Summary: Add bin-pack strategy to split the whole bucket data files into several small splits for append-only table. Key: FLINK-27696 URL: https://issues.apache.org/jira/browse/FLINK-2769

[jira] [Created] (FLINK-27679) Support append-only table for log store.

Zheng Hu created FLINK-27679: Summary: Support append-only table for log store. Key: FLINK-27679 URL: https://issues.apache.org/jira/browse/FLINK-27679 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27678) Support append-only table for file store.

Zheng Hu created FLINK-27678: Summary: Support append-only table for file store. Key: FLINK-27678 URL: https://issues.apache.org/jira/browse/FLINK-27678 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27656) Add parquet file format

Zheng Hu created FLINK-27656: Summary: Add parquet file format Key: FLINK-27656 URL: https://issues.apache.org/jira/browse/FLINK-27656 Project: Flink Issue Type: Sub-task Reporter: Z

[jira] [Created] (FLINK-27655) Implement Avro File statistic collector

Zheng Hu created FLINK-27655: Summary: Implement Avro File statistic collector Key: FLINK-27655 URL: https://issues.apache.org/jira/browse/FLINK-27655 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27553) Clarify the semantic of RecordWriter interface.

Zheng Hu created FLINK-27553: Summary: Clarify the semantic of RecordWriter interface. Key: FLINK-27553 URL: https://issues.apache.org/jira/browse/FLINK-27553 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27546) Add append only writer which implements the RecordWriter interface.

Zheng Hu created FLINK-27546: Summary: Add append only writer which implements the RecordWriter interface. Key: FLINK-27546 URL: https://issues.apache.org/jira/browse/FLINK-27546 Project: Flink

[jira] [Created] (FLINK-27517) Introduce rolling file writer to write one record each time for append-only table.

Zheng Hu created FLINK-27517: Summary: Introduce rolling file writer to write one record each time for append-only table. Key: FLINK-27517 URL: https://issues.apache.org/jira/browse/FLINK-27517 Project: F

[jira] [Created] (FLINK-27307) Flink table store support append-only ingestion without primary keys.

Zheng Hu created FLINK-27307: Summary: Flink table store support append-only ingestion without primary keys. Key: FLINK-27307 URL: https://issues.apache.org/jira/browse/FLINK-27307 Project: Flink

[jira] [Created] (FLINK-21494) Could not execute statement 'USE `default`' in Flink SQL client

Zheng Hu created FLINK-21494: Summary: Could not execute statement 'USE `default`' in Flink SQL client Key: FLINK-21494 URL: https://issues.apache.org/jira/browse/FLINK-21494 Project: Flink Issu

[jira] [Created] (FLINK-18049) The Flink kafka consumer job will be interrupted if the upstream kafka producer change the AVRO schema

Zheng Hu created FLINK-18049: Summary: The Flink kafka consumer job will be interrupted if the upstream kafka producer change the AVRO schema Key: FLINK-18049 URL: https://issues.apache.org/jira/browse/FLINK-18049

[jira] [Created] (FLINK-14941) The AbstractTableInputFormat#nextRecord in hbase connector will handle the same rowkey twice once encountered any exception

Zheng Hu created FLINK-14941: Summary: The AbstractTableInputFormat#nextRecord in hbase connector will handle the same rowkey twice once encountered any exception Key: FLINK-14941 URL: https://issues.apache.org/jira/b

[jira] [Created] (FLINK-14703) Port the Kafka SQL related tests.

Zheng Hu created FLINK-14703: Summary: Port the Kafka SQL related tests. Key: FLINK-14703 URL: https://issues.apache.org/jira/browse/FLINK-14703 Project: Flink Issue Type: Sub-task Re

[jira] [Created] (FLINK-14702) Rewrite the tpch ( test_tpch.sh ) e2e tests by using the newly introduced java framework

Zheng Hu created FLINK-14702: Summary: Rewrite the tpch ( test_tpch.sh ) e2e tests by using the newly introduced java framework Key: FLINK-14702 URL: https://issues.apache.org/jira/browse/FLINK-14702 Proj

[jira] [Created] (FLINK-14700) Consider to set the random listen port in e2e flink cluster.

Zheng Hu created FLINK-14700: Summary: Consider to set the random listen port in e2e flink cluster. Key: FLINK-14700 URL: https://issues.apache.org/jira/browse/FLINK-14700 Project: Flink Issue T

[jira] [Created] (FLINK-14620) Rewrite the elasticsearch related end-to-end tests by using the newly introduce e2e java framework

Zheng Hu created FLINK-14620: Summary: Rewrite the elasticsearch related end-to-end tests by using the newly introduce e2e java framework Key: FLINK-14620 URL: https://issues.apache.org/jira/browse/FLINK-14620

[jira] [Created] (FLINK-14446) Design a Java end to end test framework for supporting more external system

Zheng Hu created FLINK-14446: Summary: Design a Java end to end test framework for supporting more external system Key: FLINK-14446 URL: https://issues.apache.org/jira/browse/FLINK-14446 Project: Flink

[jira] [Created] (FLINK-14349) Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect

Zheng Hu created FLINK-14349: Summary: Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect Key: FLINK-14349 URL: https://issues.apache.org/jira/browse/FLINK-14349