(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 ... 305306307308309310311 ... 780

Topics (27279)

Replies

Last Post

Views

[jira] [Created] (FLINK-14049) Update error message for failed partition updates to include task name by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14048) Flink client hangs after trying to kill Yarn Job during deployment by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Support notifyOnMaster for notifyCheckpointComplete by JingsongLee-2

by JingsongLee-2

[DISCUSS] modular built-in functions by bowen.li

by Xuefu Z

[jira] [Created] (FLINK-14047) Hide secret values when displaying user configuration/global job parameters in web UI by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

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

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14045) Rewrite DefaultExecutionSlotAllocator to use SlotProviderStrategy by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14044) Reducing synchronization in AsyncWaitOperator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14043) SavepointMigrationTestBase is super slow by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14042) Different RelDataTypes generated for same TemporalTableFunction by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Retrieval services in non-high-availability scenario by tison

by tison

[jira] [Created] (FLINK-14041) Refactor LeaderRetrievalServiceHostnameResolutionTest and remove StandaloneUtils by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14040) Enable a cron job to run MiniCluster tests for schedulerNG by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

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

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14038) ExecutionGraph deploy failed due to akka timeout by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14037) Deserializing the input/output formats failed: unread block data by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

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

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14035) Introduce/Change some log for snapshot to better analysis checkpoint problem by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14034) In FlinkKafkaProducer, KafkaTransactionState should be made public or invoke should be made final by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14033) Distributed caches are not registered in Yarn Per Job Cluster Mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14032) Make the cache size of RocksDBPriorityQueueSetFactory configurable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14031) flink-examples should add blink dependency on flink-examples-table by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14030) Nonequivalent conversion happens in Table planner by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[ANNOUNCE] Kostas Kloudas joins the Flink PMC by Fabian Hueske-2

by Biao Liu

[jira] [Created] (FLINK-14029) Update Flink's Mesos scheduling behavior to reject all expired offers by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14028) Support logging aggregation in Python user-defined functions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14027) Add documentation for Python user-defined functions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14026) Manage the resource of Python worker properly by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14025) Support to run the Python worker in docker mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14024) Support use-defined metrics in Python user-defined functions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14023) Support accessing job parameters in Python user-defined functions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14022) Add validation check for places where Python ScalarFunction cannot be used by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14021) Add rules to push down the Python ScalarFunctions contained in the join condition of Correlate node by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14020) User Apache Arrow as the serializer for data transmission between Java operator and Python harness by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14019) Python environment and dependency management by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 305306307308309310311 ... 780