(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 ... 106107108109110111112 ... 778

Topics (27203)

Replies

Last Post

Views

[jira] [Created] (FLINK-19910) Table API & SQL Data Types Document error by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19909) Flink application in attach mode could not terminate when the only job is canceled by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19908) FlinkLogicalTableSourceScan and CommonPhysicalTableSourceScan should respect source reuse config option by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19907) Channel state (upstream) can be restored after emission of new elements (watermarks) by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19906) Incorrect result when compare two binary field by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19905) The Jdbc-connector's 'lookup.max-retries' option initial value is 1 in JdbcLookupFunction by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

grant me the permission as a contributor by longlai li

by Yu Li

[jira] [Created] (FLINK-19904) Update documentation to address difference between -Xmx and the metric for maximum heap by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19903) Implement equivalent of Spark's f.input_file_name() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[VOTE] NEW FLIP-104: Add More Metrics to JobManager by Yadong Xie

by Yadong Xie

[jira] [Created] (FLINK-19902) Adjust JobMasterTest to be compatible by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19901) Unable to exclude metrics variables for the last metrics reporter. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19900) Wrong property name for surefire log4j configuration by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19899) [Kinesis][EFO] Optimise error handling to use a separate exception delivery mechanism by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19898) [Kinesis][EFO] Ignore ReadTimeoutException from SubcribeToShard retry policy by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19897) Improve UI related to FLIP-102 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19896) Support first-n-rows deduplication in the Deduplicate operator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19895) Unify life cycle management of ResultPartitionType Pipelined Family by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] 1.12 feature freeze date += one week ? by Stephan Ewen

by Stephan Ewen

[jira] [Created] (FLINK-19894) Use iloc for positional slicing instead of direct slicing in from_pandas by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

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

1 ... 106107108109110111112 ... 778