(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 (27218)

Replies

Last Post

Views

[jira] [Created] (FLINK-19893) stop consuming in specific offset or timestamp by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19892) Replace __metaclass__ field with metaclass keyword by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19891) ScalarOperatorGens should generate a not-null type for IS NULL and IS NOT NULL by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19890) Introduce LimitableBulkFormat to wrap BulkFormat when limit pushed down by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19889) Supports nested projection pushdown for filesystem connector of columnar format by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19888) Migrate Hive source to FLIP-27 source interface for streaming by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19887) flink-1.11.2 - 使用包对象下的样例类，会导致table api程序编译失败 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19886) Integrate file compaction to Hive connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Question about processing a 3-level List data type in parquet by Naehee Kim

by Naehee Kim

Is there any way to change operator level parallelism dynamically? by DEEP NARAYAN Singh

by DEEP NARAYAN Singh

[jira] [Created] (FLINK-19885) Extend the JobManager's web UI in accordance to FLIP-104 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19884) Add benchmarks for batch-style execution for bounded keyed streams by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

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

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19882) E2E: SQLClientHBaseITCase crash by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19881) Optimize temporal join with upsert-Source(upsert-kafka) by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[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...

1 ... 107108109110111112113 ... 778