[jira] [Created] (FLINK-12097) Flink SQL hangs in StreamTableEnvironment.sqlUpdate, keeps executing and seems never stop, finally lead to java.lang.OutOfMemoryError: GC overhead limit exceeded

xu created FLINK-12097: -- Summary: Flink SQL hangs in StreamTableEnvironment.sqlUpdate, keeps executing and seems never stop, finally lead to java.lang.OutOfMemoryError: GC overhead limit exceeded Key: FLINK-12097 URL: https

[jira] [Created] (FLINK-12109) Flink SQL hangs in StreamTableEnvironment.sqlUpdate, finally lead to java.lang.StackOverflowError

xu created FLINK-12109: -- Summary: Flink SQL hangs in StreamTableEnvironment.sqlUpdate, finally lead to java.lang.StackOverflowError Key: FLINK-12109 URL: https://issues.apache.org/jira/browse/FLINK-12109 Project

[jira] [Created] (FLINK-30888) Flink Doc(zh version) has misspelled words

Xu created FLINK-30888: -- Summary: Flink Doc(zh version) has misspelled words Key: FLINK-30888 URL: https://issues.apache.org/jira/browse/FLINK-30888 Project: Flink Issue Type: Bug Reporter:

[jira] [Created] (FLINK-13073) BinaryRow in Blink runtime has wrong FIRST_BYTE_ZERO mask

Louis Xu created FLINK-13073: Summary: BinaryRow in Blink runtime has wrong FIRST_BYTE_ZERO mask Key: FLINK-13073 URL: https://issues.apache.org/jira/browse/FLINK-13073 Project: Flink Issue Type:

[jira] [Created] (FLINK-13096) Typo in Utils

Charles Xu created FLINK-13096: -- Summary: Typo in Utils Key: FLINK-13096 URL: https://issues.apache.org/jira/browse/FLINK-13096 Project: Flink Issue Type: Improvement Components: Deplo

[jira] [Created] (FLINK-13130) Refactor AbstractYarnClusterDescriptor to avoid code duplication

Charles Xu created FLINK-13130: -- Summary: Refactor AbstractYarnClusterDescriptor to avoid code duplication Key: FLINK-13130 URL: https://issues.apache.org/jira/browse/FLINK-13130 Project: Flink

[jira] [Created] (FLINK-13161) numBuckets calculate wrong in BinaryHashBucketArea

Louis Xu created FLINK-13161: Summary: numBuckets calculate wrong in BinaryHashBucketArea Key: FLINK-13161 URL: https://issues.apache.org/jira/browse/FLINK-13161 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-13259) Typo in PojoComparator

Charles Xu created FLINK-13259: -- Summary: Typo in PojoComparator Key: FLINK-13259 URL: https://issues.apache.org/jira/browse/FLINK-13259 Project: Flink Issue Type: Improvement Componen

[jira] [Created] (FLINK-13260) Typo in FieldAccessor

Charles Xu created FLINK-13260: -- Summary: Typo in FieldAccessor Key: FLINK-13260 URL: https://issues.apache.org/jira/browse/FLINK-13260 Project: Flink Issue Type: Improvement Component

[jira] [Created] (FLINK-13317) Merge NetUtils and ClientUtils

Charles Xu created FLINK-13317: -- Summary: Merge NetUtils and ClientUtils Key: FLINK-13317 URL: https://issues.apache.org/jira/browse/FLINK-13317 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-13351) duplicate case ROW match in FlinkTypeFactory.toLogicalType

Louis Xu created FLINK-13351: Summary: duplicate case ROW match in FlinkTypeFactory.toLogicalType Key: FLINK-13351 URL: https://issues.apache.org/jira/browse/FLINK-13351 Project: Flink Issue Type

[jira] [Created] (FLINK-13353) wrong definition of Replace planner expression

Louis Xu created FLINK-13353: Summary: wrong definition of Replace planner expression Key: FLINK-13353 URL: https://issues.apache.org/jira/browse/FLINK-13353 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-13378) Wrong comment in SingleValueAggFunction.accumulateExpressions()

Louis Xu created FLINK-13378: Summary: Wrong comment in SingleValueAggFunction.accumulateExpressions() Key: FLINK-13378 URL: https://issues.apache.org/jira/browse/FLINK-13378 Project: Flink Issu

[jira] [Created] (FLINK-13482) How can I cleanly shutdown streaming jobs in local mode?

Donghui Xu created FLINK-13482: -- Summary: How can I cleanly shutdown streaming jobs in local mode? Key: FLINK-13482 URL: https://issues.apache.org/jira/browse/FLINK-13482 Project: Flink Issue Ty

[jira] [Created] (FLINK-14030) Nonequivalent conversion happens in Table planner

Leonard Xu created FLINK-14030: -- Summary: Nonequivalent conversion happens in Table planner Key: FLINK-14030 URL: https://issues.apache.org/jira/browse/FLINK-14030 Project: Flink Issue Type: Bu

[jira] [Created] (FLINK-14036) function log(f0,f1) in Table API do not support decimal type

Leonard Xu created FLINK-14036: -- Summary: function log(f0,f1) in Table API do not support decimal type Key: FLINK-14036 URL: https://issues.apache.org/jira/browse/FLINK-14036 Project: Flink

[jira] [Created] (FLINK-14039) Flink Kinesis consumer: configurable per-shard consumption rate when running in adaptive mode

Ying Xu created FLINK-14039: --- Summary: Flink Kinesis consumer: configurable per-shard consumption rate when running in adaptive mode Key: FLINK-14039 URL: https://issues.apache.org/jira/browse/FLINK-14039 P

[jira] [Created] (FLINK-31994) Update copyright in NOTICE files of flink-shaded

Leonard Xu created FLINK-31994: -- Summary: Update copyright in NOTICE files of flink-shaded Key: FLINK-31994 URL: https://issues.apache.org/jira/browse/FLINK-31994 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-32219) sql client would be pending after executing plan of inserting

Shuai Xu created FLINK-32219: Summary: sql client would be pending after executing plan of inserting Key: FLINK-32219 URL: https://issues.apache.org/jira/browse/FLINK-32219 Project: Flink Issue

[jira] [Created] (FLINK-32289) The metadata column type is incorrect in Kafka table connector example

Leonard Xu created FLINK-32289: -- Summary: The metadata column type is incorrect in Kafka table connector example Key: FLINK-32289 URL: https://issues.apache.org/jira/browse/FLINK-32289 Project: Flink

[jira] [Created] (FLINK-32555) Add a page to show SIGMOD System Awards for Apache Flink

Leonard Xu created FLINK-32555: -- Summary: Add a page to show SIGMOD System Awards for Apache Flink Key: FLINK-32555 URL: https://issues.apache.org/jira/browse/FLINK-32555 Project: Flink Issue Ty

[jira] [Created] (FLINK-33689) jsonObjectAggFunction can't retract previous data which is invalid when enable local global agg

Shuai Xu created FLINK-33689: Summary: jsonObjectAggFunction can't retract previous data which is invalid when enable local global agg Key: FLINK-33689 URL: https://issues.apache.org/jira/browse/FLINK-33689

[jira] [Created] (FLINK-33765) Flink SQL to support COLLECTLIST

Zhenzhong Xu created FLINK-33765: Summary: Flink SQL to support COLLECTLIST Key: FLINK-33765 URL: https://issues.apache.org/jira/browse/FLINK-33765 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-33970) Add necessary checks for connector document

Leonard Xu created FLINK-33970: -- Summary: Add necessary checks for connector document Key: FLINK-33970 URL: https://issues.apache.org/jira/browse/FLINK-33970 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-16048) Support read avro data that serialized by KafkaAvroSerializer from Kafka in Table

Leonard Xu created FLINK-16048: -- Summary: Support read avro data that serialized by KafkaAvroSerializer from Kafka in Table Key: FLINK-16048 URL: https://issues.apache.org/jira/browse/FLINK-16048 Project

[jira] [Created] (FLINK-16070) Blink planner can not extract correct unique key for UpsertStreamTableSink

Leonard Xu created FLINK-16070: -- Summary: Blink planner can not extract correct unique key for UpsertStreamTableSink Key: FLINK-16070 URL: https://issues.apache.org/jira/browse/FLINK-16070 Project: Flin

[jira] [Created] (FLINK-16175) Add configOption to set CaseSensitive for SQL

Leonard Xu created FLINK-16175: -- Summary: Add configOption to set CaseSensitive for SQL Key: FLINK-16175 URL: https://issues.apache.org/jira/browse/FLINK-16175 Project: Flink Issue Type: Improve

[jira] [Created] (FLINK-16281) parameters 'maxRetryTimes' can not work in JDBCUpsertTableSink

Leonard Xu created FLINK-16281: -- Summary: parameters 'maxRetryTimes' can not work in JDBCUpsertTableSink Key: FLINK-16281 URL: https://issues.apache.org/jira/browse/FLINK-16281 Project: Flink I

[jira] [Created] (FLINK-16294) JDBC connector support create database table automatically

Leonard Xu created FLINK-16294: -- Summary: JDBC connector support create database table automatically Key: FLINK-16294 URL: https://issues.apache.org/jira/browse/FLINK-16294 Project: Flink Issue

[jira] [Created] (FLINK-16345) Computed column can not refer time attribute column

Leonard Xu created FLINK-16345: -- Summary: Computed column can not refer time attribute column Key: FLINK-16345 URL: https://issues.apache.org/jira/browse/FLINK-16345 Project: Flink Issue Type:

[jira] [Created] (FLINK-16405) Add hive-metastore dependency in connecting to hive docs

Leonard Xu created FLINK-16405: -- Summary: Add hive-metastore dependency in connecting to hive docs Key: FLINK-16405 URL: https://issues.apache.org/jira/browse/FLINK-16405 Project: Flink Issue Ty

[jira] [Created] (FLINK-16464) result-mode tableau may shift when content contains Chinese String in SQL CLI

Leonard Xu created FLINK-16464: -- Summary: result-mode tableau may shift when content contains Chinese String in SQL CLI Key: FLINK-16464 URL: https://issues.apache.org/jira/browse/FLINK-16464 Project:

[jira] [Created] (FLINK-16701) Elasticsearch sink support alias for indices.

Leonard Xu created FLINK-16701: -- Summary: Elasticsearch sink support alias for indices. Key: FLINK-16701 URL: https://issues.apache.org/jira/browse/FLINK-16701 Project: Flink Issue Type: Improve

[jira] [Created] (FLINK-16975) Add docs for FileSystem connector and hive connector

Leonard Xu created FLINK-16975: -- Summary: Add docs for FileSystem connector and hive connector Key: FLINK-16975 URL: https://issues.apache.org/jira/browse/FLINK-16975 Project: Flink Issue Type:

[jira] [Created] (FLINK-14423) Import teradat.tpcds as test data generator (refer to hive)

Leonard Xu created FLINK-14423: -- Summary: Import teradat.tpcds as test data generator (refer to hive) Key: FLINK-14423 URL: https://issues.apache.org/jira/browse/FLINK-14423 Project: Flink Issu

[jira] [Created] (FLINK-14424) Create tpc-ds end to end test

Leonard Xu created FLINK-14424: -- Summary: Create tpc-ds end to end test Key: FLINK-14424 URL: https://issues.apache.org/jira/browse/FLINK-14424 Project: Flink Issue Type: Sub-task Com

[jira] [Created] (FLINK-14425) Pick necessary commits gently that tpc-ds tests need from flink-tpc-ds project

Leonard Xu created FLINK-14425: -- Summary: Pick necessary commits gently that tpc-ds tests need from flink-tpc-ds project Key: FLINK-14425 URL: https://issues.apache.org/jira/browse/FLINK-14425 Project: F

[jira] [Created] (FLINK-14426) Test and pass 103 tpcds tests

Leonard Xu created FLINK-14426: -- Summary: Test and pass 103 tpcds tests Key: FLINK-14426 URL: https://issues.apache.org/jira/browse/FLINK-14426 Project: Flink Issue Type: Sub-task Comp

[jira] [Created] (FLINK-14455) Improve join reorder feature without table statistics

Leonard Xu created FLINK-14455: -- Summary: Improve join reorder feature without table statistics Key: FLINK-14455 URL: https://issues.apache.org/jira/browse/FLINK-14455 Project: Flink Issue Type:

[jira] [Created] (FLINK-14549) Bring more detail by using logicalType rather than conversionClass in exception msg

Leonard Xu created FLINK-14549: -- Summary: Bring more detail by using logicalType rather than conversionClass in exception msg Key: FLINK-14549 URL: https://issues.apache.org/jira/browse/FLINK-14549 Proj

[jira] [Created] (FLINK-14625) Eliminate cross join in multi join to reduce cost

Leonard Xu created FLINK-14625: -- Summary: Eliminate cross join in multi join to reduce cost Key: FLINK-14625 URL: https://issues.apache.org/jira/browse/FLINK-14625 Project: Flink Issue Type: Im

[jira] [Created] (FLINK-14674) some tpc-ds query hang in scheduled stage for long time

Leonard Xu created FLINK-14674: -- Summary: some tpc-ds query hang in scheduled stage for long time Key: FLINK-14674 URL: https://issues.apache.org/jira/browse/FLINK-14674 Project: Flink Issue Typ

[jira] [Created] (FLINK-14675) output directory settings of tpc-ds dataGenerator have length limitation

Leonard Xu created FLINK-14675: -- Summary: output directory settings of tpc-ds dataGenerator have length limitation Key: FLINK-14675 URL: https://issues.apache.org/jira/browse/FLINK-14675 Project: Flink

[jira] [Created] (FLINK-14677) validate all tpc-ds query result with TPC Official reference answer set

Leonard Xu created FLINK-14677: -- Summary: validate all tpc-ds query result with TPC Official reference answer set Key: FLINK-14677 URL: https://issues.apache.org/jira/browse/FLINK-14677 Project: Flink

[jira] [Created] (FLINK-14784) CsvTableSink miss delimiter when row start with null member

Leonard Xu created FLINK-14784: -- Summary: CsvTableSink miss delimiter when row start with null member Key: FLINK-14784 URL: https://issues.apache.org/jira/browse/FLINK-14784 Project: Flink Issu

[jira] [Created] (FLINK-14861) parallelism.default in flink-conf.yaml do not work which is a bug imported by[FLINK-14745]

Leonard Xu created FLINK-14861: -- Summary: parallelism.default in flink-conf.yaml do not work which is a bug imported by[FLINK-14745] Key: FLINK-14861 URL: https://issues.apache.org/jira/browse/FLINK-14861

[jira] [Created] (FLINK-14882) Wrong null order when change flink default null order from NullCollation.LOW to NullCollation.FIRST

Leonard Xu created FLINK-14882: -- Summary: Wrong null order when change flink default null order from NullCollation.LOW to NullCollation.FIRST Key: FLINK-14882 URL: https://issues.apache.org/jira/browse/FLINK-14882

[jira] [Created] (FLINK-14886) Wrong result in scalar query using blink planner

Leonard Xu created FLINK-14886: -- Summary: Wrong result in scalar query using blink planner Key: FLINK-14886 URL: https://issues.apache.org/jira/browse/FLINK-14886 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-14895) same rank in rollup row with group row that all group key are null

Leonard Xu created FLINK-14895: -- Summary: same rank in rollup row with group row that all group key are null Key: FLINK-14895 URL: https://issues.apache.org/jira/browse/FLINK-14895 Project: Flink

[jira] [Created] (FLINK-14900) output contains null value when a is null where a <> 'String'

Leonard Xu created FLINK-14900: -- Summary: output contains null value when a is null where a <> 'String' Key: FLINK-14900 URL: https://issues.apache.org/jira/browse/FLINK-14900 Project: Flink

[jira] [Created] (FLINK-14924) CsvTableSource can not config empty column as null

Leonard Xu created FLINK-14924: -- Summary: CsvTableSource can not config empty column as null Key: FLINK-14924 URL: https://issues.apache.org/jira/browse/FLINK-14924 Project: Flink Issue Type: Bu

[jira] [Created] (FLINK-15200) legacy planner cannot deal Type with precision like DataTypes.TIMESTAMP(3) in TableSourceUtil

Leonard Xu created FLINK-15200: -- Summary: legacy planner cannot deal Type with precision like DataTypes.TIMESTAMP(3) in TableSourceUtil Key: FLINK-15200 URL: https://issues.apache.org/jira/browse/FLINK-15200

[jira] [Created] (FLINK-15250) Docs of Table Connect to External Systems is outdate and need to fix

Leonard Xu created FLINK-15250: -- Summary: Docs of Table Connect to External Systems is outdate and need to fix Key: FLINK-15250 URL: https://issues.apache.org/jira/browse/FLINK-15250 Project: Flink

[jira] [Created] (FLINK-15301) Flink Kinesis AsyncRecordEmitter needs to handle unchecked exception gracefully

Ying Xu created FLINK-15301: --- Summary: Flink Kinesis AsyncRecordEmitter needs to handle unchecked exception gracefully Key: FLINK-15301 URL: https://issues.apache.org/jira/browse/FLINK-15301 Project: Flink

[jira] [Created] (FLINK-15333) Using FlinkCostFactory rather than RelOptCostImpl in blink planner

Leonard Xu created FLINK-15333: -- Summary: Using FlinkCostFactory rather than RelOptCostImpl in blink planner Key: FLINK-15333 URL: https://issues.apache.org/jira/browse/FLINK-15333 Project: Flink

[jira] [Created] (FLINK-15334) Fix schemaValidator because properties mapping may change if user defined generated columns before custom columns

Leonard Xu created FLINK-15334: -- Summary: Fix schemaValidator because properties mapping may change if user defined generated columns before custom columns Key: FLINK-15334 URL: https://issues.apache.org/jira/brows

[jira] [Created] (FLINK-15356) Add applicationId to existing flink metrics running on yarn

Forward Xu created FLINK-15356: -- Summary: Add applicationId to existing flink metrics running on yarn Key: FLINK-15356 URL: https://issues.apache.org/jira/browse/FLINK-15356 Project: Flink Issu

[jira] [Created] (FLINK-15363) Hbase connector do not support datatypes with precision like TIMESTAMP(9) and DECIMAL(10,4)

Leonard Xu created FLINK-15363: -- Summary: Hbase connector do not support datatypes with precision like TIMESTAMP(9) and DECIMAL(10,4) Key: FLINK-15363 URL: https://issues.apache.org/jira/browse/FLINK-15363

[jira] [Created] (FLINK-15366) Dimension table do not support computed column

Leonard Xu created FLINK-15366: -- Summary: Dimension table do not support computed column Key: FLINK-15366 URL: https://issues.apache.org/jira/browse/FLINK-15366 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-15379) JDBC connector return wrong value if defined dataType contains precision

Leonard Xu created FLINK-15379: -- Summary: JDBC connector return wrong value if defined dataType contains precision Key: FLINK-15379 URL: https://issues.apache.org/jira/browse/FLINK-15379 Project: Flink

[jira] [Created] (FLINK-15383) StreamExecSink should use sink Schema field name rather than query Schema field name

Leonard Xu created FLINK-15383: -- Summary: StreamExecSink should use sink Schema field name rather than query Schema field name Key: FLINK-15383 URL: https://issues.apache.org/jira/browse/FLINK-15383 Proj

[jira] [Created] (FLINK-15425) update outdated document of Connect to External Systems

Leonard Xu created FLINK-15425: -- Summary: update outdated document of Connect to External Systems Key: FLINK-15425 URL: https://issues.apache.org/jira/browse/FLINK-15425 Project: Flink Issue Typ

[jira] [Created] (FLINK-15461) Add Stream SQL end2end test to cover connecting to external systems

Leonard Xu created FLINK-15461: -- Summary: Add Stream SQL end2end test to cover connecting to external systems Key: FLINK-15461 URL: https://issues.apache.org/jira/browse/FLINK-15461 Project: Flink

[jira] [Created] (FLINK-15476) Update StreamingFileSink documentation -- bulk encoded writer now supports customized checkpoint policy

Ying Xu created FLINK-15476: --- Summary: Update StreamingFileSink documentation -- bulk encoded writer now supports customized checkpoint policy Key: FLINK-15476 URL: https://issues.apache.org/jira/browse/FLINK-15476

[jira] [Created] (FLINK-15485) Reopen tests like 'ignore TODO/when FLINK-xx is closed/when FLINK-xx is merged' has been finished

Leonard Xu created FLINK-15485: -- Summary: Reopen tests like 'ignore TODO/when FLINK-xx is closed/when FLINK-xx is merged' has been finished Key: FLINK-15485 URL: https://issues.apache.org/jira/browse/FLINK-15485

[jira] [Created] (FLINK-15508) support DataType with precision in ExpressionParser

Leonard Xu created FLINK-15508: -- Summary: support DataType with precision in ExpressionParser Key: FLINK-15508 URL: https://issues.apache.org/jira/browse/FLINK-15508 Project: Flink Issue Type: I

[jira] [Created] (FLINK-15551) Streaming File Sink s3 end-to-end test FAIL

Leonard Xu created FLINK-15551: -- Summary: Streaming File Sink s3 end-to-end test FAIL Key: FLINK-15551 URL: https://issues.apache.org/jira/browse/FLINK-15551 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-10358) Flink kinesis connector could throw NPE during getRecords() call

Ying Xu created FLINK-10358: --- Summary: Flink kinesis connector could throw NPE during getRecords() call Key: FLINK-10358 URL: https://issues.apache.org/jira/browse/FLINK-10358 Project: Flink Issu

[jira] [Created] (FLINK-13027) StreamingFileSink bulk-encoded writer supports file rolling upon customized events

Ying Xu created FLINK-13027: --- Summary: StreamingFileSink bulk-encoded writer supports file rolling upon customized events Key: FLINK-13027 URL: https://issues.apache.org/jira/browse/FLINK-13027 Project: Fli

[jira] [Created] (FLINK-4308) Allow uploaded jar directory to be configurable

Zhenzhong Xu created FLINK-4308: --- Summary: Allow uploaded jar directory to be configurable Key: FLINK-4308 URL: https://issues.apache.org/jira/browse/FLINK-4308 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-4335) Add jar id, and job parameters information to job status rest call

Zhenzhong Xu created FLINK-4335: --- Summary: Add jar id, and job parameters information to job status rest call Key: FLINK-4335 URL: https://issues.apache.org/jira/browse/FLINK-4335 Project: Flink

[jira] [Created] (FLINK-4336) Expose ability to take a savepoint from job manager rest api

Zhenzhong Xu created FLINK-4336: --- Summary: Expose ability to take a savepoint from job manager rest api Key: FLINK-4336 URL: https://issues.apache.org/jira/browse/FLINK-4336 Project: Flink Iss

[jira] [Created] (FLINK-4371) Add ability to take savepoints from job manager RESTful API

Zhenzhong Xu created FLINK-4371: --- Summary: Add ability to take savepoints from job manager RESTful API Key: FLINK-4371 URL: https://issues.apache.org/jira/browse/FLINK-4371 Project: Flink Issu

[jira] [Created] (FLINK-4372) Add ability to take savepoints from job manager web UI

Zhenzhong Xu created FLINK-4372: --- Summary: Add ability to take savepoints from job manager web UI Key: FLINK-4372 URL: https://issues.apache.org/jira/browse/FLINK-4372 Project: Flink Issue Type

[jira] [Created] (FLINK-4545) Flink automatically manages TM network buffer

Zhenzhong Xu created FLINK-4545: --- Summary: Flink automatically manages TM network buffer Key: FLINK-4545 URL: https://issues.apache.org/jira/browse/FLINK-4545 Project: Flink Issue Type: Wish

[jira] [Created] (FLINK-4660) HadoopFileSystem (with S3A) may leak connections, which cause job to stuck in a restarting loop

Zhenzhong Xu created FLINK-4660: --- Summary: HadoopFileSystem (with S3A) may leak connections, which cause job to stuck in a restarting loop Key: FLINK-4660 URL: https://issues.apache.org/jira/browse/FLINK-4660

[jira] [Created] (FLINK-4760) Kafka 09 Consumer failed to initialize state causing job to restart

Zhenzhong Xu created FLINK-4760: --- Summary: Kafka 09 Consumer failed to initialize state causing job to restart Key: FLINK-4760 URL: https://issues.apache.org/jira/browse/FLINK-4760 Project: Flink

[jira] [Created] (FLINK-4819) Checkpoint metadata+data inspection tool (view / update)

Zhenzhong Xu created FLINK-4819: --- Summary: Checkpoint metadata+data inspection tool (view / update) Key: FLINK-4819 URL: https://issues.apache.org/jira/browse/FLINK-4819 Project: Flink Issue Ty

[jira] [Created] (FLINK-4820) Slf4j / log4j version upgrade to support dynamic change of log levels.

Zhenzhong Xu created FLINK-4820: --- Summary: Slf4j / log4j version upgrade to support dynamic change of log levels. Key: FLINK-4820 URL: https://issues.apache.org/jira/browse/FLINK-4820 Project: Flink

[jira] [Created] (FLINK-19148) Table crashed in Flink Table API & SQL Docs

Leonard Xu created FLINK-19148: -- Summary: Table crashed in Flink Table API & SQL Docs Key: FLINK-19148 URL: https://issues.apache.org/jira/browse/FLINK-19148 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-19271) wrong HOP_PROCTIME output when materialize proctime

Leonard Xu created FLINK-19271: -- Summary: wrong HOP_PROCTIME output when materialize proctime Key: FLINK-19271 URL: https://issues.apache.org/jira/browse/FLINK-19271 Project: Flink Issue Type: B

[jira] [Created] (FLINK-19342) stop overriding convertFrom() in FlinkPlannerImpl after upgrade calcite to 1.23

Leonard Xu created FLINK-19342: -- Summary: stop overriding convertFrom() in FlinkPlannerImpl after upgrade calcite to 1.23 Key: FLINK-19342 URL: https://issues.apache.org/jira/browse/FLINK-19342 Project:

[jira] [Created] (FLINK-19389) Error determining python major version to start fileserver during e-2-e tests

Di Xu created FLINK-19389: - Summary: Error determining python major version to start fileserver during e-2-e tests Key: FLINK-19389 URL: https://issues.apache.org/jira/browse/FLINK-19389 Project: Flink

[jira] [Created] (FLINK-19523) Secrets should be filtered out from logs

Qinghui Xu created FLINK-19523: -- Summary: Secrets should be filtered out from logs Key: FLINK-19523 URL: https://issues.apache.org/jira/browse/FLINK-19523 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-19549) [CI] ##[error]The job running on agent Azure Pipelines 5 ran longer than the maximum time of 260 minutes.

Di Xu created FLINK-19549: - Summary: [CI] ##[error]The job running on agent Azure Pipelines 5 ran longer than the maximum time of 260 minutes. Key: FLINK-19549 URL: https://issues.apache.org/jira/browse/FLINK-19549

[jira] [Created] (FLINK-19644) Support read specific partition of Hive table in temporal join

Leonard Xu created FLINK-19644: -- Summary: Support read specific partition of Hive table in temporal join Key: FLINK-19644 URL: https://issues.apache.org/jira/browse/FLINK-19644 Project: Flink I

[jira] [Created] (FLINK-19734) Add scan-only TableSoure tests

Leonard Xu created FLINK-19734: -- Summary: Add scan-only TableSoure tests Key: FLINK-19734 URL: https://issues.apache.org/jira/browse/FLINK-19734 Project: Flink Issue Type: Sub-task R

[jira] [Created] (FLINK-19830) Properly implements processing-time temporal table join

Leonard Xu created FLINK-19830: -- Summary: Properly implements processing-time temporal table join Key: FLINK-19830 URL: https://issues.apache.org/jira/browse/FLINK-19830 Project: Flink Issue Typ

[jira] [Created] (FLINK-19878) Improve watermark ChangelogNormalize for upsertSource

Leonard Xu created FLINK-19878: -- Summary: Improve watermark ChangelogNormalize for upsertSource Key: FLINK-19878 URL: https://issues.apache.org/jira/browse/FLINK-19878 Project: Flink Issue Type:

[jira] [Created] (FLINK-19881) Optimize temporal join with upsert-Source(upsert-kafka)

Leonard Xu created FLINK-19881: -- Summary: Optimize temporal join with upsert-Source(upsert-kafka) Key: FLINK-19881 URL: https://issues.apache.org/jira/browse/FLINK-19881 Project: Flink Issue Typ

[jira] [Created] (FLINK-20184) update hive streaming read and temporal table documents

Leonard Xu created FLINK-20184: -- Summary: update hive streaming read and temporal table documents Key: FLINK-20184 URL: https://issues.apache.org/jira/browse/FLINK-20184 Project: Flink Issue Typ

[jira] [Created] (FLINK-20279) Elasticsearch6DynamicSinkITCase failed caused by pulling docker image error

Leonard Xu created FLINK-20279: -- Summary: Elasticsearch6DynamicSinkITCase failed caused by pulling docker image error Key: FLINK-20279 URL: https://issues.apache.org/jira/browse/FLINK-20279 Project: Flin

[jira] [Created] (FLINK-20316) update the deduplication section of query page

Leonard Xu created FLINK-20316: -- Summary: update the deduplication section of query page Key: FLINK-20316 URL: https://issues.apache.org/jira/browse/FLINK-20316 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-20385) Allow to read metadata for Canal-json format

Leonard Xu created FLINK-20385: -- Summary: Allow to read metadata for Canal-json format Key: FLINK-20385 URL: https://issues.apache.org/jira/browse/FLINK-20385 Project: Flink Issue Type: New Feat

[jira] [Created] (FLINK-20405) The LAG function in over window is not implements correctly

Leonard Xu created FLINK-20405: -- Summary: The LAG function in over window is not implements correctly Key: FLINK-20405 URL: https://issues.apache.org/jira/browse/FLINK-20405 Project: Flink Issu

[jira] [Created] (FLINK-20484) Improve hive temporal table exception

Leonard Xu created FLINK-20484: -- Summary: Improve hive temporal table exception Key: FLINK-20484 URL: https://issues.apache.org/jira/browse/FLINK-20484 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-20502) Reduce the uploading time of hadoop jars in hbase e2e test

Leonard Xu created FLINK-20502: -- Summary: Reduce the uploading time of hadoop jars in hbase e2e test Key: FLINK-20502 URL: https://issues.apache.org/jira/browse/FLINK-20502 Project: Flink Iss

[jira] [Created] (FLINK-20587) INSERT INTO TIMESTAMP WITH LOCAL TIME ZONE VALUES, THROW Unsupported type

Forward Xu created FLINK-20587: -- Summary: INSERT INTO TIMESTAMP WITH LOCAL TIME ZONE VALUES, THROW Unsupported type Key: FLINK-20587 URL: https://issues.apache.org/jira/browse/FLINK-20587 Project: Flink

[jira] [Created] (FLINK-20746) Support ignore-first-line option for CSV format

Leonard Xu created FLINK-20746: -- Summary: Support ignore-first-line option for CSV format Key: FLINK-20746 URL: https://issues.apache.org/jira/browse/FLINK-20746 Project: Flink Issue Type: Impro

[jira] [Created] (FLINK-20840) Projection pushdown doesn't work in temporal(lookup) join

Leonard Xu created FLINK-20840: -- Summary: Projection pushdown doesn't work in temporal(lookup) join Key: FLINK-20840 URL: https://issues.apache.org/jira/browse/FLINK-20840 Project: Flink Issue

  1   2   3   >