[jira] [Created] (FLINK-20853) Add reader schema null check for AvroDeserializationSchema when recordClazz is GenericRecord

hailong wang created FLINK-20853: Summary: Add reader schema null check for AvroDeserializationSchema when recordClazz is GenericRecord Key: FLINK-20853 URL: https://issues.apache.org/jira/browse/FLINK-20853

[jira] [Created] (FLINK-20388) Supports users setting operators' metrics name

hailong wang created FLINK-20388: Summary: Supports users setting operators' metrics name Key: FLINK-20388 URL: https://issues.apache.org/jira/browse/FLINK-20388 Project: Flink Issue Type: Im

[jira] [Created] (FLINK-20375) Add a

hailong wang created FLINK-20375: Summary: Add a Key: FLINK-20375 URL: https://issues.apache.org/jira/browse/FLINK-20375 Project: Flink Issue Type: Improvement Reporter: hailong w

[jira] [Created] (FLINK-20250) NPE when invoking AsyncLookupJoinRunner#close method

hailong wang created FLINK-20250: Summary: NPE when invoking AsyncLookupJoinRunner#close method Key: FLINK-20250 URL: https://issues.apache.org/jira/browse/FLINK-20250 Project: Flink Issue Ty

[jira] [Created] (FLINK-20163) Translate page 'raw type' into Chinese

hailong wang created FLINK-20163: Summary: Translate page 'raw type' into Chinese Key: FLINK-20163 URL: https://issues.apache.org/jira/browse/FLINK-20163 Project: Flink Issue Type: Improvemen

[jira] [Created] (FLINK-20146) Update zh connector and format dependencies link

hailong wang created FLINK-20146: Summary: Update zh connector and format dependencies link Key: FLINK-20146 URL: https://issues.apache.org/jira/browse/FLINK-20146 Project: Flink Issue Type:

[jira] [Created] (FLINK-20111) Update the description of UDAF `merge` method in User-defined function document

hailong wang created FLINK-20111: Summary: Update the description of UDAF `merge` method in User-defined function document Key: FLINK-20111 URL: https://issues.apache.org/jira/browse/FLINK-20111 Proje

[jira] [Created] (FLINK-20110) Support 'merge' method for first_value and last_value UDAF

hailong wang created FLINK-20110: Summary: Support 'merge' method for first_value and last_value UDAF Key: FLINK-20110 URL: https://issues.apache.org/jira/browse/FLINK-20110 Project: Flink Is

[jira] [Created] (FLINK-20091) Introduce avro.ignore-parse-errors for AvroRowDataDeserializationSchema

hailong wang created FLINK-20091: Summary: Introduce avro.ignore-parse-errors for AvroRowDataDeserializationSchema Key: FLINK-20091 URL: https://issues.apache.org/jira/browse/FLINK-20091 Project: Fli

[jira] [Created] (FLINK-20089) Avro format fails to serialize map value with null keys

hailong wang created FLINK-20089: Summary: Avro format fails to serialize map value with null keys Key: FLINK-20089 URL: https://issues.apache.org/jira/browse/FLINK-20089 Project: Flink Issue

[jira] [Created] (FLINK-20034) Add maxwell-json format document

hailong wang created FLINK-20034: Summary: Add maxwell-json format document Key: FLINK-20034 URL: https://issues.apache.org/jira/browse/FLINK-20034 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-19912) Support ignoreParseErrors option for json serializationSchema

hailong wang created FLINK-19912: Summary: Support ignoreParseErrors option for json serializationSchema Key: FLINK-19912 URL: https://issues.apache.org/jira/browse/FLINK-19912 Project: Flink

[jira] [Created] (FLINK-19906) Incorrect result when compare two binary field

hailong wang created FLINK-19906: Summary: Incorrect result when compare two binary field Key: FLINK-19906 URL: https://issues.apache.org/jira/browse/FLINK-19906 Project: Flink Issue Type: Bu

[jira] [Created] (FLINK-19861) Improve the document of now() function

hailong wang created FLINK-19861: Summary: Improve the document of now() function Key: FLINK-19861 URL: https://issues.apache.org/jira/browse/FLINK-19861 Project: Flink Issue Type: Improvemen

[jira] [Created] (FLINK-19753) Introduce 'STRCMP' function to compare between two string fields

hailong wang created FLINK-19753: Summary: Introduce 'STRCMP' function to compare between two string fields Key: FLINK-19753 URL: https://issues.apache.org/jira/browse/FLINK-19753 Project: Flink

[jira] [Created] (FLINK-19691) Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

hailong wang created FLINK-19691: Summary: Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector Key: FLINK-19691 URL: https://issues.apache.org/jira/browse/FLINK-19691

[jira] [Created] (FLINK-19660) Translate page 'table_environment.zh.md' into Chinese

hailong wang created FLINK-19660: Summary: Translate page 'table_environment.zh.md' into Chinese Key: FLINK-19660 URL: https://issues.apache.org/jira/browse/FLINK-19660 Project: Flink Issue T

[jira] [Created] (FLINK-19659) Array type supports equals and not_equals operator when element types are different but castable

hailong wang created FLINK-19659: Summary: Array type supports equals and not_equals operator when element types are different but castable Key: FLINK-19659 URL: https://issues.apache.org/jira/browse/FLINK-19659

[jira] [Created] (FLINK-19619) Test failed in Azure For EmulatedPubSubSourceTest

hailong wang created FLINK-19619: Summary: Test failed in Azure For EmulatedPubSubSourceTest Key: FLINK-19619 URL: https://issues.apache.org/jira/browse/FLINK-19619 Project: Flink Issue Type:

[jira] [Created] (FLINK-19618) Boken link in docs

hailong wang created FLINK-19618: Summary: Boken link in docs Key: FLINK-19618 URL: https://issues.apache.org/jira/browse/FLINK-19618 Project: Flink Issue Type: Bug Components: Docu

[jira] [Created] (FLINK-19587) Error result when casting binary type as varchar

hailong wang created FLINK-19587: Summary: Error result when casting binary type as varchar Key: FLINK-19587 URL: https://issues.apache.org/jira/browse/FLINK-19587 Project: Flink Issue Type:

[jira] [Created] (FLINK-19584) HBaseSinkFunction no needs to create thread to flush when bufferFlushMaxMutations = 1

hailong wang created FLINK-19584: Summary: HBaseSinkFunction no needs to create thread to flush when bufferFlushMaxMutations = 1 Key: FLINK-19584 URL: https://issues.apache.org/jira/browse/FLINK-19584

[jira] [Created] (FLINK-19509) ClassCastException for MULTISET type of JsonRowDataDeserializationSchema and JsonRowDataSerializationSchema

hailong wang created FLINK-19509: Summary: ClassCastException for MULTISET type of JsonRowDataDeserializationSchema and JsonRowDataSerializationSchema Key: FLINK-19509 URL: https://issues.apache.org/jira/browse/FL

[jira] [Created] (FLINK-19482) OrcRowInputFormat does not define serialVersionUID

hailong wang created FLINK-19482: Summary: OrcRowInputFormat does not define serialVersionUID Key: FLINK-19482 URL: https://issues.apache.org/jira/browse/FLINK-19482 Project: Flink Issue Type

[jira] [Created] (FLINK-19478) Translate page 'intro_to_table_api' into Chinese

hailong wang created FLINK-19478: Summary: Translate page 'intro_to_table_api' into Chinese Key: FLINK-19478 URL: https://issues.apache.org/jira/browse/FLINK-19478 Project: Flink Issue Type:

[jira] [Created] (FLINK-19477) Translate page 'python_table_api_connectors' into Chinese

hailong wang created FLINK-19477: Summary: Translate page 'python_table_api_connectors' into Chinese Key: FLINK-19477 URL: https://issues.apache.org/jira/browse/FLINK-19477 Project: Flink Iss

[jira] [Created] (FLINK-19455) Module 'flink-sql-connector-hive-2.3.6' build fail by maven-enforcer-plugin

hailong wang created FLINK-19455: Summary: Module 'flink-sql-connector-hive-2.3.6' build fail by maven-enforcer-plugin Key: FLINK-19455 URL: https://issues.apache.org/jira/browse/FLINK-19455 Project:

[jira] [Created] (FLINK-19430) Translate page 'datastream_tutorial' into Chinese

hailong wang created FLINK-19430: Summary: Translate page 'datastream_tutorial' into Chinese Key: FLINK-19430 URL: https://issues.apache.org/jira/browse/FLINK-19430 Project: Flink Issue Type:

[jira] [Created] (FLINK-19429) Translate page 'Data Types' into Chinese

hailong wang created FLINK-19429: Summary: Translate page 'Data Types' into Chinese Key: FLINK-19429 URL: https://issues.apache.org/jira/browse/FLINK-19429 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-19425) Correct the usage of BulkWriter#flush and BulkWriter#finish

hailong wang created FLINK-19425: Summary: Correct the usage of BulkWriter#flush and BulkWriter#finish Key: FLINK-19425 URL: https://issues.apache.org/jira/browse/FLINK-19425 Project: Flink

[jira] [Created] (FLINK-19424) Translate page 'Query Configuration' into Chinese

hailong wang created FLINK-19424: Summary: Translate page 'Query Configuration' into Chinese Key: FLINK-19424 URL: https://issues.apache.org/jira/browse/FLINK-19424 Project: Flink Issue Type:

[jira] [Created] (FLINK-19386) Remove legacy table planner dependecy from connectors and formats

hailong wang created FLINK-19386: Summary: Remove legacy table planner dependecy from connectors and formats Key: FLINK-19386 URL: https://issues.apache.org/jira/browse/FLINK-19386 Project: Flink

[jira] [Created] (FLINK-19363) Code of split method grows beyond 64 KB

hailong wang created FLINK-19363: Summary: Code of split method grows beyond 64 KB Key: FLINK-19363 URL: https://issues.apache.org/jira/browse/FLINK-19363 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-19362) Remove confusing comment for `DOT` operator codegen

hailong wang created FLINK-19362: Summary: Remove confusing comment for `DOT` operator codegen Key: FLINK-19362 URL: https://issues.apache.org/jira/browse/FLINK-19362 Project: Flink Issue Typ

[jira] [Created] (FLINK-19334) Translate page 'Streaming File Sink' into Chinese

hailong wang created FLINK-19334: Summary: Translate page 'Streaming File Sink' into Chinese Key: FLINK-19334 URL: https://issues.apache.org/jira/browse/FLINK-19334 Project: Flink Issue Type:

[jira] [Created] (FLINK-19266) Test fail when run azure in AbstractCloseableRegistryTest#testClose

hailong wang created FLINK-19266: Summary: Test fail when run azure in AbstractCloseableRegistryTest#testClose Key: FLINK-19266 URL: https://issues.apache.org/jira/browse/FLINK-19266 Project: Flink

[jira] [Created] (FLINK-18714) Support consuming multiple topics for KafkaTableSource

hailong wang created FLINK-18714: Summary: Support consuming multiple topics for KafkaTableSource Key: FLINK-18714 URL: https://issues.apache.org/jira/browse/FLINK-18714 Project: Flink Issue

[jira] [Created] (FLINK-18713) Allow default ms unit for table.exec.mini-batch.allow-latency etc.

hailong wang created FLINK-18713: Summary: Allow default ms unit for table.exec.mini-batch.allow-latency etc. Key: FLINK-18713 URL: https://issues.apache.org/jira/browse/FLINK-18713 Project: Flink

[jira] [Created] (FLINK-18711) Trim the blank space for TableOptions

hailong wang created FLINK-18711: Summary: Trim the blank space for TableOptions Key: FLINK-18711 URL: https://issues.apache.org/jira/browse/FLINK-18711 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-18686) Getting the emit time when `table.exec.emit.early-fire.enabled` is true

hailong wang created FLINK-18686: Summary: Getting the emit time when `table.exec.emit.early-fire.enabled` is true Key: FLINK-18686 URL: https://issues.apache.org/jira/browse/FLINK-18686 Project: Flin

[jira] [Created] (FLINK-18003) Table hints support multi Options

hailong wang created FLINK-18003: Summary: Table hints support multi Options Key: FLINK-18003 URL: https://issues.apache.org/jira/browse/FLINK-18003 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-17892) Dynamic option may not be a part of the table digest

hailong wang created FLINK-17892: Summary: Dynamic option may not be a part of the table digest Key: FLINK-17892 URL: https://issues.apache.org/jira/browse/FLINK-17892 Project: Flink Issue Ty

[jira] [Created] (FLINK-17767) Tumble and Hop window support offset

hailong wang created FLINK-17767: Summary: Tumble and Hop window support offset Key: FLINK-17767 URL: https://issues.apache.org/jira/browse/FLINK-17767 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-16158) SqlClient showdown when executing update if not start cluster

hailong wang created FLINK-16158: Summary: SqlClient showdown when executing update if not start cluster Key: FLINK-16158 URL: https://issues.apache.org/jira/browse/FLINK-16158 Project: Flink

[jira] [Created] (FLINK-16147) Add watermarkExprOutputType in WatermarkSpec#toString method

hailong wang created FLINK-16147: Summary: Add watermarkExprOutputType in WatermarkSpec#toString method Key: FLINK-16147 URL: https://issues.apache.org/jira/browse/FLINK-16147 Project: Flink

[jira] [Created] (FLINK-15995) TO_BASE64 sql operator change operandTypeChecker from OperandTypes.ANY to OperandTypes.family(SqlTypeFamily.STRING)

hailong wang created FLINK-15995: Summary: TO_BASE64 sql operator change operandTypeChecker from OperandTypes.ANY to OperandTypes.family(SqlTypeFamily.STRING) Key: FLINK-15995 URL: https://issues.apache.org/jira/

[jira] [Created] (FLINK-15994) Support byte array arguments for FROM_BASE64 function

hailong wang created FLINK-15994: Summary: Support byte array arguments for FROM_BASE64 function Key: FLINK-15994 URL: https://issues.apache.org/jira/browse/FLINK-15994 Project: Flink Issue T

[jira] [Created] (FLINK-15677) TableSource#explainSource should return the field names from getProducedDataType instead of getTableSchema

hailong wang created FLINK-15677: Summary: TableSource#explainSource should return the field names from getProducedDataType instead of getTableSchema Key: FLINK-15677 URL: https://issues.apache.org/jira/browse/FLI

[jira] [Created] (FLINK-15676) Improve test code of JDBCUpsertTableSinkITCase and JDBCLookupFunctionITCase

hailong wang created FLINK-15676: Summary: Improve test code of JDBCUpsertTableSinkITCase and JDBCLookupFunctionITCase Key: FLINK-15676 URL: https://issues.apache.org/jira/browse/FLINK-15676 Project:

[jira] [Created] (FLINK-15556) Add a switch for PushProjectIntoTableSourceScanRule

hailong wang created FLINK-15556: Summary: Add a switch for PushProjectIntoTableSourceScanRule Key: FLINK-15556 URL: https://issues.apache.org/jira/browse/FLINK-15556 Project: Flink Issue Typ

[jira] [Created] (FLINK-15555) Delete TABLE_OPTIMIZER_REUSE_SOURCE_ENABLED option for subplaner reuse

hailong wang created FLINK-1: Summary: Delete TABLE_OPTIMIZER_REUSE_SOURCE_ENABLED option for subplaner reuse Key: FLINK-1 URL: https://issues.apache.org/jira/browse/FLINK-1 Project: Flin

[jira] [Created] (FLINK-15553) Create table ddl support comment after computed column

hailong wang created FLINK-15553: Summary: Create table ddl support comment after computed column Key: FLINK-15553 URL: https://issues.apache.org/jira/browse/FLINK-15553 Project: Flink Issue

[jira] [Created] (FLINK-15479) Override explainSource method in JDBCTableSource

hailong wang created FLINK-15479: Summary: Override explainSource method in JDBCTableSource Key: FLINK-15479 URL: https://issues.apache.org/jira/browse/FLINK-15479 Project: Flink Issue Type:

[jira] [Created] (FLINK-15434) testResourceManagerConnectionAfterRegainingLeadership test fail when run azure

hailong wang created FLINK-15434: Summary: testResourceManagerConnectionAfterRegainingLeadership test fail when run azure Key: FLINK-15434 URL: https://issues.apache.org/jira/browse/FLINK-15434 Proje

[jira] [Created] (FLINK-15409) Add semicolon to WindowJoinUtil#generateJoinFunction '$collectorTerm.collect($joinedRow)' statement

hailong wang created FLINK-15409: Summary: Add semicolon to WindowJoinUtil#generateJoinFunction '$collectorTerm.collect($joinedRow)' statement Key: FLINK-15409 URL: https://issues.apache.org/jira/browse/FLINK-1540

[jira] [Created] (FLINK-15408) Interval join support no equi-condition

hailong wang created FLINK-15408: Summary: Interval join support no equi-condition Key: FLINK-15408 URL: https://issues.apache.org/jira/browse/FLINK-15408 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-15393) Change 'ReturnExpiredIfNotCleanedUp' to 'NeverReturnExpired' in JoinRecordStateViews#createTtlConfig

hailong wang created FLINK-15393: Summary: Change 'ReturnExpiredIfNotCleanedUp' to 'NeverReturnExpired' in JoinRecordStateViews#createTtlConfig Key: FLINK-15393 URL: https://issues.apache.org/jira/browse/FLINK-1

[jira] [Created] (FLINK-14990) Add bit functions to Blink planner

hailong wang created FLINK-14990: Summary: Add bit functions to Blink planner Key: FLINK-14990 URL: https://issues.apache.org/jira/browse/FLINK-14990 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-14902) JDBCTableSource support AsyncLookupFunction

hailong wang created FLINK-14902: Summary: JDBCTableSource support AsyncLookupFunction Key: FLINK-14902 URL: https://issues.apache.org/jira/browse/FLINK-14902 Project: Flink Issue Type: Impro

[jira] [Created] (FLINK-14893) Using Child ClassLoader to load class when Parent ClassLoader couldn't load in ParentFirstPatterns

hailong wang created FLINK-14893: Summary: Using Child ClassLoader to load class when Parent ClassLoader couldn't load in ParentFirstPatterns Key: FLINK-14893 URL: https://issues.apache.org/jira/browse/FLINK-148

[jira] [Created] (FLINK-14613) Add validation check when applying UDF to tempral table key in Temporal Table Join condition

hailong wang created FLINK-14613: Summary: Add validation check when applying UDF to tempral table key in Temporal Table Join condition Key: FLINK-14613 URL: https://issues.apache.org/jira/browse/FLINK-14613

[jira] [Created] (FLINK-14441) Fix ValueLiteralExpression#getValueAs when valueClass is Period.class

hailong wang created FLINK-14441: Summary: Fix ValueLiteralExpression#getValueAs when valueClass is Period.class Key: FLINK-14441 URL: https://issues.apache.org/jira/browse/FLINK-14441 Project: Flink

[jira] [Created] (FLINK-14421) Add 'L' when define a long value

hailong wang created FLINK-14421: Summary: Add 'L' when define a long value Key: FLINK-14421 URL: https://issues.apache.org/jira/browse/FLINK-14421 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-14408) In OldPlanner, UDF open method can not be invoke when SQL is optimized

hailong wang created FLINK-14408: Summary: In OldPlanner, UDF open method can not be invoke when SQL is optimized Key: FLINK-14408 URL: https://issues.apache.org/jira/browse/FLINK-14408 Project: Flink

[jira] [Created] (FLINK-14275) Window Aggregate function support a RichFunction

hailong wang created FLINK-14275: Summary: Window Aggregate function support a RichFunction Key: FLINK-14275 URL: https://issues.apache.org/jira/browse/FLINK-14275 Project: Flink Issue Type:

[jira] [Created] (FLINK-14274) RuntimeContext can be get from FunctionContext

hailong wang created FLINK-14274: Summary: RuntimeContext can be get from FunctionContext Key: FLINK-14274 URL: https://issues.apache.org/jira/browse/FLINK-14274 Project: Flink Issue Type: I

[jira] [Created] (FLINK-14273) when User-Defined Aggregate Functions(UDAF) parameters are inconsistent with the definition, the error reporting is confusing

hailong wang created FLINK-14273: Summary: when User-Defined Aggregate Functions(UDAF) parameters are inconsistent with the definition, the error reporting is confusing Key: FLINK-14273 URL: https://issues.apache.

[jira] [Created] (FLINK-14064) Support Project Push down to LookupableTableSource

hailong wang created FLINK-14064: Summary: Support Project Push down to LookupableTableSource Key: FLINK-14064 URL: https://issues.apache.org/jira/browse/FLINK-14064 Project: Flink Issue Type

[jira] [Created] (FLINK-14046) DDL property 'format.fields.#.type' should ignore case

hailong wang created FLINK-14046: Summary: DDL property 'format.fields.#.type' should ignore case Key: FLINK-14046 URL: https://issues.apache.org/jira/browse/FLINK-14046 Project: Flink Issue