(DEPRECATED) Apache Flink Mailing List archive.

This used to be a public archive of the Flink mailing mailing list.

We recommend using the official Apache Mailing List Archive: https://lists.apache.org/list.html?dev@flink.apache.org

New Topic

People

1 ... 107108109110111112113 ... 778

Topics (27203)

Replies

Last Post

Views

[jira] [Created] (FLINK-19880) flink-json The validation and incoming parameters do not match by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19879) Support "IF NOT EXISTS" in DDL for CREATE TABLE by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19878) Improve watermark ChangelogNormalize for upsertSource by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19877) AlterDatabaseOperation is missing ignoreIfNotExists by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19876) Latency metrics can merge chain task latency metrics to reduce the number of latency metrics by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19875) Integrate file compaction to connectors by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19874) Apply JoinDeriveNullFilterRule after join reorder by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19873) Skip DDL change events for Canal data by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19872) Support to parse millisecond for TIME type in CSV format by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19871) add hash(primary key） to kafka partition sink mapping by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19870) Fix special case when the reuse of exchange causes the deadlock by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19869) Support java.util.UUID as RAW type in PostgresCatalog and handle it in PostgresRowConverter by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19868) Csv Serialization schema contains line delimiter by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19867) Validation fails for UDF that accepts var-args by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19866) FunctionsStateBootstrapOperator.createStateAccessor fails due to uninitialized runtimeContext by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Remove flink-connector-filesystem module. by Kostas Kloudas-5

by Jingsong Li

[jira] [Created] (FLINK-19865) YARN tests failed with "java.lang.NumberFormatException: For input string: "${env:MAX_LOG_FILE_NUMBER}" java.lang.NumberFormatException: For input string: "${env:MAX_LOG_FILE_NUMBER}"" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19864) TwoInputStreamTaskTest.testWatermarkMetrics failed with "expected:<1> but was:<-9223372036854775808>" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19863) SQLClientHBaseITCase.testHBase failed with "java.io.IOException: Process failed due to timeout" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19862) DeclarativeSlotManager#suspend can fail with NPE by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19861) Improve the document of now() function by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19860) Consider skipping restart and traverse regions which are already being restarted in RestartPipelinedRegionFailoverStrategy by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19859) Add documentation for the upsert-kafka connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19858) Add the new table factory for upsert-kafka connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19857) FLIP-149: Introduce the upsert-kafka Connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[VOTE]FLIP-149: Introduce the upsert-kafka connector by Shengkai Fang

by Shengkai Fang

[jira] [Created] (FLINK-19856) Add EndOfChannelRecovery rescaling epoch by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19855) Incompatible semantics of channelIndex in UnionInputGate.resumeConsumption and its clients by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19854) TableScanTest.testTemporalJoinOnUpsertSource fails by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19853) BulkSlotProviderImplTest.testFailedBulkSlotAllocationReleasesAllocatedSlot failed in azure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19852) Managed memory released check can block IterativeTask by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19851) flink sql client connector type jdbc exception by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19850) Add E2E tests for the new streaming case of the new FileSink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19849) Check NOTICE files for 1.12 release by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19848) flink docs of Building Flink from Source bug by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 107108109110111112113 ... 778