[jira] [Created] (FLINK-26123) The data of the upsert-kafka source cannot be written to HBase under sql where conditions

Carl created FLINK-26123: Summary: The data of the upsert-kafka source cannot be written to HBase under sql where conditions Key: FLINK-26123 URL: https://issues.apache.org/jira/browse/FLINK-26123 Project:

[jira] [Created] (FLINK-24836) Over window in month time calculated an incorrect aggregation result.

Carl created FLINK-24836: Summary: Over window in month time calculated an incorrect aggregation result. Key: FLINK-24836 URL: https://issues.apache.org/jira/browse/FLINK-24836 Project: Flink Issue

[jira] [Created] (FLINK-23939) The result of validation and parsing failure does not match the document description

Carl created FLINK-23939: Summary: The result of validation and parsing failure does not match the document description Key: FLINK-23939 URL: https://issues.apache.org/jira/browse/FLINK-23939 Project: Flink

[jira] [Created] (FLINK-23730) Source from hive sink hbase lost data

Carl created FLINK-23730: Summary: Source from hive sink hbase lost data Key: FLINK-23730 URL: https://issues.apache.org/jira/browse/FLINK-23730 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-23719) Support switch WAL in Flink SQL DDL options

Carl created FLINK-23719: Summary: Support switch WAL in Flink SQL DDL options Key: FLINK-23719 URL: https://issues.apache.org/jira/browse/FLINK-23719 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-23211) An old interface method is used in this section of [Passing Options Factory to RocksDB].

Carl created FLINK-23211: Summary: An old interface method is used in this section of [Passing Options Factory to RocksDB]. Key: FLINK-23211 URL: https://issues.apache.org/jira/browse/FLINK-23211 Project:

[jira] [Created] (FLINK-23198) An old interface method is used in this section of [Passing Options Factory to RocksDB].

Carl created FLINK-23198: Summary: An old interface method is used in this section of [Passing Options Factory to RocksDB]. Key: FLINK-23198 URL: https://issues.apache.org/jira/browse/FLINK-23198 Project:

[jira] [Created] (FLINK-23176) my flink application has failed when i executed an savepoint

Carl created FLINK-23176: Summary: my flink application has failed when i executed an savepoint Key: FLINK-23176 URL: https://issues.apache.org/jira/browse/FLINK-23176 Project: Flink Issue Type:

[jira] [Created] (FLINK-23051) Savepoint an application for source of cdc-kafka, then restart the application from the savepoint, offset not be recovered.

Carl created FLINK-23051: Summary: Savepoint an application for source of cdc-kafka, then restart the application from the savepoint, offset not be recovered. Key: FLINK-23051 URL:

[jira] [Created] (FLINK-22498) cast the primary key for source table that has a decimal primary key as string, and then insert into a kudu table that has a string primary key throw the exception : Ups

Carl created FLINK-22498: Summary: cast the primary key for source table that has a decimal primary key as string, and then insert into a kudu table that has a string primary key throw the exception : UpsertStreamTableSink requires that Table has a

[jira] [Created] (FLINK-22267) Savepoint an application for source of upsert-kafka, then restart the application from the savepoint, state not be recovered.

Carl created FLINK-22267: Summary: Savepoint an application for source of upsert-kafka, then restart the application from the savepoint, state not be recovered. Key: FLINK-22267 URL:

[jira] [Created] (FLINK-21889) source:canal-cdc , sink:upsert-kafka, print "select * from sinkTable", throw NullException

Carl created FLINK-21889: Summary: source:canal-cdc , sink:upsert-kafka, print "select * from sinkTable", throw NullException Key: FLINK-21889 URL: https://issues.apache.org/jira/browse/FLINK-21889 Project: