dev@flink.apache.org, 2023-04

You are viewing a plain text version of this content. The canonical link for it is here.

- [jira] [Created] (FLINK-31686) All of connector should replace the shallow copy with a deep copy - posted by "tanjialiang (Jira)" <ji...@apache.org> on 2023/04/01 08:19:00 UTC, 0 replies.
- Re: [DISCUSS] Planning Flink 1.18 - posted by Jark Wu <im...@gmail.com> on 2023/04/01 15:54:28 UTC, 1 replies.
- [jira] [Created] (FLINK-31687) Flink jdbc driver get rid of flink core - posted by "Fang Yong (Jira)" <ji...@apache.org> on 2023/04/02 03:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31688) Broken links in docs for Azure Table Storage - posted by "Yuxin Tan (Jira)" <ji...@apache.org> on 2023/04/02 13:41:00 UTC, 0 replies.
- Re: [DISCUSS] Add support for Apache Arrow format - posted by Aitozi <gj...@gmail.com> on 2023/04/02 14:21:12 UTC, 3 replies.
- Re: [DISCUSS] FLIP 295: Support persistence of Catalog configuration and asynchronous registration - posted by Xianxun Ye <ye...@gmail.com> on 2023/04/02 14:58:12 UTC, 12 replies.
- [jira] [Created] (FLINK-31689) Filesystem sink fails when parallelism of compactor operator changed - posted by "jirawech.s (Jira)" <ji...@apache.org> on 2023/04/02 16:10:00 UTC, 0 replies.
- Re: [blog article] Howto create a batch source with the new Source framework - posted by yuxia <lu...@alumni.sjtu.edu.cn> on 2023/04/03 01:37:42 UTC, 1 replies.
- [jira] [Created] (FLINK-31690) The current key is not set for KeyedCoProcessOperator - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2023/04/03 02:33:00 UTC, 2 replies.
- [jira] [Created] (FLINK-31691) Add MAP_FROM_ENTRIES supported in SQL & Table API - posted by "jackylau (Jira)" <ji...@apache.org> on 2023/04/03 04:09:00 UTC, 0 replies.
- Re: [VOTE] Release flink-connector-kafka, release candidate #1 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2023/04/03 04:36:18 UTC, 6 replies.
- Re: [External] [DISCUSS] FLIP-292: Support configuring state TTL at operator level for Table API & SQL programs - posted by godfrey he <go...@gmail.com> on 2023/04/03 07:15:49 UTC, 7 replies.
- [ANNOUNCE] Apache flink-connector-mongodb v1.0.0 released - posted by Danny Cranmer <da...@apache.org> on 2023/04/03 07:56:45 UTC, 1 replies.
- [ANNOUNCE] Apache flink-connector-aws v4.1.0 released - posted by Danny Cranmer <da...@apache.org> on 2023/04/03 07:56:57 UTC, 0 replies.
- [jira] [Created] (FLINK-31692) Integrate MongoDB connector docs into Flink website - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2023/04/03 08:00:00 UTC, 0 replies.
- [DISCUSS] FLINK-31553 - posted by Marios Trivyzas <ma...@gmail.com> on 2023/04/03 08:04:22 UTC, 0 replies.
- [jira] [Created] (FLINK-31693) Bump http-cache-semantics from 4.1.0 to 4.1.1 in - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2023/04/03 08:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31694) Bump ua-parser-js from 0.7.31 to 0.7.33 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2023/04/03 08:21:00 UTC, 0 replies.
- [DISCUSS] Status of Statefun Project - posted by Martijn Visser <ma...@apache.org> on 2023/04/03 09:02:06 UTC, 5 replies.
- [jira] [Created] (FLINK-31695) Calling `bin/flink stop` when flink-shaded-hadoop-2-uber-2.8.3-10.0.jar is in lib directory thwos NoSuchMethodError - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2023/04/03 09:08:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-287: Extend Sink#InitContext to expose ExecutionConfig and JobID - posted by Zhu Zhu <re...@gmail.com> on 2023/04/03 09:42:28 UTC, 6 replies.
- [jira] [Created] (FLINK-31696) ElasticSearch nightly CI failure - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2023/04/03 09:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31697) OpenSearch nightly CI failure - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2023/04/03 09:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31698) Cassandra nightly CI failure - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2023/04/03 09:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31699) JDBC nightly CI failure - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2023/04/03 09:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31700) MongoDB nightly CI failure - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2023/04/03 09:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31701) RabbitMQ nightly CI failure - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2023/04/03 09:53:00 UTC, 0 replies.
- Re: [DISCUSS] Releasing connectors for Flink 1.17 - posted by Danny Cranmer <da...@apache.org> on 2023/04/03 09:56:52 UTC, 3 replies.
- [jira] [Created] (FLINK-31702) Integrate Opensearch connector docs into Flink docs v1.17/master - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2023/04/03 10:32:00 UTC, 0 replies.
- [DISCUSS] FLIP-306: Unified File Merging Mechanism for Checkpoints - posted by Zakelly Lan <za...@gmail.com> on 2023/04/03 10:35:45 UTC, 20 replies.
- [jira] [Created] (FLINK-31703) Update Flink docs for AWS v4.1.0 - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2023/04/03 10:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31704) Pulsar docs should be pulled from dedicated branch - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2023/04/03 10:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31705) Remove Conjars - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2023/04/03 11:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31706) The default source parallelism should be the same as execution's default parallelism under adaptive batch scheduler - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2023/04/03 11:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31707) Constant string cannot be used as input arguments of Pandas UDAF - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2023/04/03 11:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31708) RuntimeException/KryoException thrown when deserializing an empty protobuf record - posted by "shen (Jira)" <ji...@apache.org> on 2023/04/03 11:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31709) JobResultStore and ExecutionGraphInfoStore could be merged - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/04/03 12:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31710) Remove and rely on the curator dependency that's provided by flink - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/04/03 12:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31711) OpenAPI spec omits complete-statement request body - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2023/04/03 13:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31712) Allow skipping of archunit tests for nightly connector builds - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2023/04/03 13:06:00 UTC, 0 replies.
- [ANNOUNCE] Starting with Flink 1.18 Release Sync - posted by Qingsheng Ren <re...@apache.org> on 2023/04/03 13:35:58 UTC, 0 replies.
- [jira] [Created] (FLINK-31713) k8s operator should gather job version metrics - posted by "Márton Balassi (Jira)" <ji...@apache.org> on 2023/04/03 14:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31714) Conjars.org has died - posted by "Niels Basjes (Jira)" <ji...@apache.org> on 2023/04/03 15:06:00 UTC, 0 replies.
- [VOTE] Release flink-connector-aws, 4.1.0 for Flink 1.17 - posted by Danny Cranmer <da...@apache.org> on 2023/04/03 16:19:00 UTC, 6 replies.
- [jira] [Created] (FLINK-31715) Warning - 'An illegal reflective access operation has occurred' - posted by "Feroze Daud (Jira)" <ji...@apache.org> on 2023/04/03 17:01:00 UTC, 0 replies.
- TaskManager OutOfMemoryError. Metaspace out of memory with python udf - posted by tom yang <en...@gmail.com> on 2023/04/03 17:46:53 UTC, 0 replies.
- [jira] [Created] (FLINK-31716) Event UID field is missing the first time that an event is consumed - posted by "Rodrigo Meneses (Jira)" <ji...@apache.org> on 2023/04/03 18:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31717) Unit tests running with local kube config - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2023/04/03 20:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31718) pulsar connector v3.0 branch's CI is not working properly - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2023/04/04 04:44:00 UTC, 0 replies.
- Re: [DISCUSS] Releasing Flink ML 2.2.0 - posted by Dong Lin <li...@gmail.com> on 2023/04/04 05:44:38 UTC, 0 replies.
- [jira] [Created] (FLINK-31719) Update Netty to 4.1.91-Final - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2023/04/04 06:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31720) Pulsar connector v3.0 branch's docs are empty - posted by "Yuxin Tan (Jira)" <ji...@apache.org> on 2023/04/04 07:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31721) Move JobStatusHook to flink-core module - posted by "tartarus (Jira)" <ji...@apache.org> on 2023/04/04 08:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31722) Remove dependency on flink-shaded - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2023/04/04 08:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31723) DispatcherTest#testCancellationDuringInitialization is unstable - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2023/04/04 08:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31724) SqlClientITCase.testMatchRecognize fails with "bash -c rm -rf /opt/flink/checkpoint/*" returned non-zero exit code 1 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2023/04/04 09:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31725) Synchronize dependency version between Flink and flink-connector-pulsar - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2023/04/04 09:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31726) PyFlink module java.base does not "opens java.lang" to unnamed module - posted by "padavan (Jira)" <ji...@apache.org> on 2023/04/04 12:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31727) Source parallelism should match number of Kafka partitions - posted by "Yordan Pavlov (Jira)" <ji...@apache.org> on 2023/04/04 13:08:00 UTC, 0 replies.
- [SUMMARY] Flink 1.18 Release Sync 4/4/2023 - posted by Jing Ge <ji...@ververica.com.INVALID> on 2023/04/04 13:10:53 UTC, 0 replies.
- [jira] [Created] (FLINK-31728) Remove Scala API dependencies from batch/streaming examples - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2023/04/04 13:42:00 UTC, 0 replies.
- what happened to the images in FLIP-24: SQL Client? - posted by David Anderson <da...@apache.org> on 2023/04/04 15:24:32 UTC, 4 replies.
- [jira] [Created] (FLINK-31729) Unexpected UPDATE_BEFORE output record in LEFT OUTER JOIN - posted by "Alexander Smirnov (Jira)" <ji...@apache.org> on 2023/04/04 17:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31730) Support Ephemeral Storage in KubernetesConfigOptions - posted by "Zhenqiu Huang (Jira)" <ji...@apache.org> on 2023/04/04 17:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31731) No suitable constructor found for DebeziumAvroSerializationSchema - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2023/04/04 19:22:00 UTC, 0 replies.
- [DISCUSS] EXACTLY_ONCE delivery semantics for upsert-kafka connector - posted by Alexander Sorokoumov <as...@confluent.io.INVALID> on 2023/04/05 01:39:01 UTC, 6 replies.
- [jira] [Created] (FLINK-31732) flink-ml-uber module should include statefun as a dependency - posted by "Zhipeng Zhang (Jira)" <ji...@apache.org> on 2023/04/05 02:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31733) Model name clashes in OpenAPI spec - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2023/04/05 10:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31734) Align behaviour of REST API / WEB UI feature flags - posted by "David Morávek (Jira)" <ji...@apache.org> on 2023/04/05 12:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31735) JobDetailsInfo plan incorrectly documented as string - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2023/04/05 13:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31736) Expose per-job capabilities via REST API - posted by "David Morávek (Jira)" <ji...@apache.org> on 2023/04/05 13:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31737) Hide the rescaling buttons for batch jobs in the WEB UI - posted by "David Morávek (Jira)" <ji...@apache.org> on 2023/04/05 13:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31738) FlameGraphTypeQueryParameter#Type clashes with java.reflect.Type in generated clients - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2023/04/05 14:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31739) ElasticSearch and Cassandra connector v3.0 branch's CI is not working properly - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2023/04/05 15:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31740) Allow setting boundedness for upsert-kafka SQL connector - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2023/04/05 21:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31741) Supports data conversion according to type for executor - posted by "Fang Yong (Jira)" <ji...@apache.org> on 2023/04/06 02:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31742) Remove deprecated TableSchema in flink-table-planner test - posted by "Ran Tao (Jira)" <ji...@apache.org> on 2023/04/06 03:29:00 UTC, 0 replies.
- Re: [ANNOUNCE] Kafka Connector Code Removal from apache/flink:main branch and code freezing - posted by Mason Chen <ma...@gmail.com> on 2023/04/06 04:29:15 UTC, 1 replies.
- Re: [DISCUSS] FLIP-302: Support TRUNCATE TABLE statement - posted by yuxia <lu...@alumni.sjtu.edu.cn> on 2023/04/06 08:44:45 UTC, 19 replies.
- [jira] [Created] (FLINK-31743) Avoid relocating the RocksDB's log failure when filename exceeds 255 characters - posted by "jinghaihang (Jira)" <ji...@apache.org> on 2023/04/06 08:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31744) Extend Adaptive Scheduler sparse EG to contain maxParallelism - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2023/04/06 13:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31745) Performance regression on serializerHeavyString since April 3rd - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2023/04/06 13:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31746) Batch workload output completes while the job client fails - posted by "Haoze Wu (Jira)" <ji...@apache.org> on 2023/04/06 18:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31747) Externalize debezium from flink-json - posted by "Mason Chen (Jira)" <ji...@apache.org> on 2023/04/06 22:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31748) Adapt SplitFetcherManager#removeSplit for flink-connector-pulsar - posted by "Zili Chen (Jira)" <ji...@apache.org> on 2023/04/07 02:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31749) The Using Hadoop OutputFormats example is not avaliable for DataStream - posted by "junzhong qin (Jira)" <ji...@apache.org> on 2023/04/07 02:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31750) Hash Keys are duplicate when join reorder happens in stream mode - posted by "ZhengYi Weng (Jira)" <ji...@apache.org> on 2023/04/07 02:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31751) array return type SpecificTypeStrategies.ARRAY and ifThenElse return type is not correct - posted by "jackylau (Jira)" <ji...@apache.org> on 2023/04/07 07:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31752) SourceOperatorStreamTask increments numRecordsOut twice - posted by "Weihua Hu (Jira)" <ji...@apache.org> on 2023/04/07 08:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31753) Support DataStream CoGroup in stream Mode with similar performance as DataSet CoGroup - posted by "Dong Lin (Jira)" <ji...@apache.org> on 2023/04/07 09:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31754) Build flink master error with Error in ASM processing class org/apache/calcite/sql/validate/SqlValidatorImpl$NavigationExpander.class: 19 - posted by "zhenlong dong (Jira)" <ji...@apache.org> on 2023/04/07 11:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31755) ROW function can not work with RewriteIntersectAllRule - posted by "Aitozi (Jira)" <ji...@apache.org> on 2023/04/07 13:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31756) KafkaTableITCase.testStartFromGroupOffsetsNone fails due to UnknownTopicOrPartitionException - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2023/04/09 05:37:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-304: Pluggable failure handling for Apache Flink - posted by Panagiotis Garefalakis <pg...@apache.org> on 2023/04/09 19:46:56 UTC, 4 replies.
- [jira] [Created] (FLINK-31757) Optimize Flink tasks un-balanced scheduling - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2023/04/10 02:57:00 UTC, 0 replies.
- [DISCUSS] FLIP-305: Support atomic for CREATE TABLE AS SELECT(CTAS) statement - posted by Mang Zhang <zh...@163.com> on 2023/04/10 03:02:46 UTC, 12 replies.
- Re: [DISCUSS] FLIP-278: Hybrid Source Connector - posted by Ran Tao <ch...@gmail.com> on 2023/04/10 07:33:48 UTC, 0 replies.
- [VOTE] FLIP-292: Enhance COMPILED PLAN to support operator-level state TTL configuration - posted by Jane Chan <qi...@gmail.com> on 2023/04/10 10:05:58 UTC, 7 replies.
- [jira] [Created] (FLINK-31758) Some external connectors sql client jar has a wrong download url in document - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2023/04/10 15:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31759) Update some external connectors to use modified sql_connector_download_table shortcode - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2023/04/10 15:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31760) COALESCE() with NULL arguments throws error - posted by "Mohsen Rezaei (Jira)" <ji...@apache.org> on 2023/04/10 18:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31761) Fix Some Typo And Improve lambda expressions. - posted by "Shilun Fan (Jira)" <ji...@apache.org> on 2023/04/10 22:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31762) Subscribe multiple Kafka topics may cause partition assignment skew - posted by "Liam (Jira)" <ji...@apache.org> on 2023/04/11 00:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31763) Ensure that the total number of requested buffers does not exceed poolSize + maxOverdraftBuffersPerGate - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2023/04/11 05:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31764) Get rid of numberOfRequestedOverdraftMemorySegments in LocalBufferPool - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2023/04/11 05:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31765) Disable changelog backend for the StatefulJobSavepointMigrationITCase and StatefulJobWBroadcastStateMigrationITCase with RocksDB and checkpoints - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/04/11 06:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31766) Restoring from a retained checkpoint that was generated with changelog backend enabled might fail due to missing files - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/04/11 06:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31767) Improve the implementation for "analyze table" execution - posted by "Godfrey He (Jira)" <ji...@apache.org> on 2023/04/11 06:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31768) Create FLIP-285 interfaces without changing the behavior - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/04/11 07:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31769) Add percentiles to aggregated metrics - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2023/04/11 08:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31770) OracleExactlyOnceSinkE2eTest.testInsert fails for JDBC connector - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2023/04/11 08:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31771) Improve select available slot from SlotPool - posted by "Weihua Hu (Jira)" <ji...@apache.org> on 2023/04/11 11:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31772) AsyncSinkWriter Performance regression due to AIMD rate limiting strategy - posted by "Ahmed Hamdy (Jira)" <ji...@apache.org> on 2023/04/11 12:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31773) Introduces LeaderElection sub-interface - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/04/11 12:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31774) Add document for delete and update statement - posted by "Aitozi (Jira)" <ji...@apache.org> on 2023/04/11 15:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31775) High-Availability not supported in kubernetes when istio enabled - posted by "Sergio Sainz (Jira)" <ji...@apache.org> on 2023/04/11 19:17:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-288:Enable Dynamic Partition Discovery by Default in Kafka Source - posted by Hongshun Wang <lo...@gmail.com> on 2023/04/12 06:27:18 UTC, 8 replies.
- [jira] [Created] (FLINK-31776) Introducing sub-interface LeaderElectionService.LeaderElection - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/04/12 11:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31777) Upsert Kafka use Avro Confluent, key is ok, but all values are null. - posted by "Alvin Ge (Jira)" <ji...@apache.org> on 2023/04/12 11:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31778) Casting array of rows produces incorrect result - posted by "Ilya Soin (Jira)" <ji...@apache.org> on 2023/04/12 12:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31779) Track stable branch of externalized connector instead of specific release tag - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2023/04/12 12:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31780) Allow users to enable Ensemble tracking for ZooKeeper - posted by "Oleksandr Nitavskyi (Jira)" <ji...@apache.org> on 2023/04/12 13:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31782) Make DefaultLeaderElectionService implement MultipleComponentLeaderElectionService.Listener - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/04/12 14:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31781) Introduce contender ID into LeaderElectionService interface - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/04/12 14:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31783) Replace LeaderElectionDriver in DefaultLeaderElectionService with MultipleComponentLeaderElectionService - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/04/12 14:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31784) Add multiple-component support to DefaultLeaderElectionService - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/04/12 14:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31785) Move LeaderElectionService out of LeaderContender - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/04/12 14:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31786) Removing unused HighAvailabilityServices implementations - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/04/12 14:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31787) Add the explicit ROW constructor to the system function doc - posted by "Aitozi (Jira)" <ji...@apache.org> on 2023/04/12 14:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31788) Add back Support emitValueWithRetract for TableAggregateFunction - posted by "Feng Jin (Jira)" <ji...@apache.org> on 2023/04/12 15:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31789) Update axel to current - posted by "Morey Straus (Jira)" <ji...@apache.org> on 2023/04/12 17:58:00 UTC, 0 replies.
- [mongodb connector] which flink version(s) is the mongodb connector compatible with? - posted by Saketh Kurnool <sa...@decodable.co> on 2023/04/12 21:27:06 UTC, 3 replies.
- [VOTE] Release flink-connector-kafka 3.0.0 for Flink 1.17, release candidate #2 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2023/04/12 23:55:57 UTC, 9 replies.
- [DISCUSS] EncodingFormat and DecondingFormat provide copy API - posted by tanjialiang <ta...@126.com> on 2023/04/13 02:05:39 UTC, 4 replies.
- [jira] [Created] (FLINK-31790) Filesystem batch sink should also respect to the PartitionCommitPolicy - posted by "Aitozi (Jira)" <ji...@apache.org> on 2023/04/13 02:27:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-292: Enhance COMPILED PLAN to support operator-level state TTL configuration - posted by Jane Chan <qi...@gmail.com> on 2023/04/13 02:32:51 UTC, 0 replies.
- [DISCUSS] Release Paimon 0.4 - posted by Jingsong Li <ji...@gmail.com> on 2023/04/13 02:56:30 UTC, 1 replies.
- [jira] [Created] (FLINK-31791) FLIP-292: Enhance COMPILED PLAN to support operator-level state TTL configuration - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2023/04/13 03:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31792) Errors are not reported in the Web UI - posted by "David Morávek (Jira)" <ji...@apache.org> on 2023/04/13 06:00:00 UTC, 0 replies.
- [VOTE] Release flink-connector-pulsar, release candidate #1 - posted by Martijn Visser <ma...@apache.org> on 2023/04/13 08:58:23 UTC, 3 replies.
- [VOTE] Release flink-connector-elasticsearch, release candidate #1 - posted by Martijn Visser <ma...@apache.org> on 2023/04/13 09:21:18 UTC, 4 replies.
- [jira] [Created] (FLINK-31793) Remove dependency on flink-shaded for flink-connector-jdbc - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2023/04/13 10:20:00 UTC, 0 replies.
- [VOTE] Apache Flink ML Release 2.2.0, release candidate #2 - posted by Dong Lin <li...@gmail.com> on 2023/04/13 10:28:11 UTC, 3 replies.
- [VOTE] Release flink-connector-cassandra v3.0.1, release candidate #1 - posted by Danny Cranmer <da...@apache.org> on 2023/04/13 11:31:43 UTC, 3 replies.
- [VOTE] Release flink-connector-opensearch, release candidate #1 - posted by Martijn Visser <ma...@apache.org> on 2023/04/13 12:53:57 UTC, 4 replies.
- [jira] [Created] (FLINK-31794) Ignore unknown CRD fields - posted by "Daren Wong (Jira)" <ji...@apache.org> on 2023/04/13 13:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31795) Add Config to enable/disable savepoint cleanup - posted by "Daren Wong (Jira)" <ji...@apache.org> on 2023/04/13 13:49:00 UTC, 0 replies.
- [VOTE] Release flink-connector-gcp-pubsub v3.0.1, release candidate #1 - posted by Martijn Visser <ma...@apache.org> on 2023/04/13 14:05:59 UTC, 2 replies.
- [jira] [Created] (FLINK-31796) Support service mesh istio with Flink kubernetes (both native and operator) for secure communications - posted by "Sergio Sainz (Jira)" <ji...@apache.org> on 2023/04/13 14:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31797) Move LeaderElectionService out of LeaderContender - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/04/13 14:13:00 UTC, 0 replies.
- [DISCUSS] Release of Pulsar Connector v4.0.0 - posted by Yufan Sheng <sy...@gmail.com> on 2023/04/13 14:22:36 UTC, 2 replies.
- [jira] [Created] (FLINK-31798) Add config to enable/disable Kubernetes Events - posted by "Daren Wong (Jira)" <ji...@apache.org> on 2023/04/13 14:40:00 UTC, 1 replies.
- [VOTE] Release flink-connector-jdbc v3.1.0, release candidate #1 - posted by Danny Cranmer <da...@apache.org> on 2023/04/13 14:41:06 UTC, 7 replies.
- [VOTE] Release flink-connector-rabbitmq v3.0.1, release candidate #1 - posted by Martijn Visser <ma...@apache.org> on 2023/04/13 14:45:34 UTC, 2 replies.
- [jira] [Created] (FLINK-31799) Python connector download link should refer to the url defined in externalized repository - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2023/04/13 15:18:00 UTC, 0 replies.
- [VOTE] Release flink-connector-mongodb v1.0.1, release candidate #1 - posted by Danny Cranmer <da...@apache.org> on 2023/04/13 15:20:11 UTC, 9 replies.
- [jira] [Created] (FLINK-31800) Update tika to current - posted by "Morey Straus (Jira)" <ji...@apache.org> on 2023/04/13 15:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31801) Missing elasticsearch connector on maven central repository - posted by "Fang Yong (Jira)" <ji...@apache.org> on 2023/04/14 01:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31802) Python py37-cython: commands failed - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2023/04/14 07:39:00 UTC, 0 replies.
- [DISCUSS FLINKSQL PARALLELISM] - posted by GREEN <12...@qq.com.INVALID> on 2023/04/14 07:55:45 UTC, 6 replies.
- [jira] [Created] (FLINK-31803) UpdateJobResourceRequirementsRecoveryITCase.testRescaledJobGraphsWillBeRecoveredCorrectly(Path) is unstable on azure - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2023/04/14 07:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31804) ITCase MiniCluster test architecture rule should accept MiniClusterTestEnvironment - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2023/04/14 08:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31805) Cassandra Source shouldn't use IOUtils - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2023/04/14 08:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31806) Prod architecture tests didn't detect non-public API usage - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2023/04/14 08:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31807) Test architecture tests don't cover all tests - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2023/04/14 08:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31808) wrong examples of how to set operator name in documents - posted by "Weihua Hu (Jira)" <ji...@apache.org> on 2023/04/14 09:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31809) Improve efficiency of ListStateWithCache#snapshotState - posted by "Fan Hong (Jira)" <ji...@apache.org> on 2023/04/14 09:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31810) RocksDBException: Bad table magic number on checkpoint rescale - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2023/04/14 10:57:00 UTC, 0 replies.
- [VOTE] Release flink-connector-cassandra v3.1.0, release candidate #1 - posted by Danny Cranmer <da...@apache.org> on 2023/04/14 12:13:43 UTC, 3 replies.
- [jira] [Created] (FLINK-31811) Unsupported complex data type for Flink SQL - posted by "jirawech.s (Jira)" <ji...@apache.org> on 2023/04/14 12:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31812) SavePoint from /jars/:jarid:/run api on body is not anymore emptyToNull if empty - posted by "Nicolas Fraison (Jira)" <ji...@apache.org> on 2023/04/14 13:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31813) Initial implementation of Kinesis Source using FLIP-27 - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2023/04/14 13:31:00 UTC, 0 replies.
- Need Help with Slack Invite Link - posted by Madhur Pyasi <md...@gmail.com> on 2023/04/15 21:03:07 UTC, 5 replies.
- [jira] [Created] (FLINK-31814) Enable Precondition in DefaultLeaderElectionService.close after the MultipleComponentLeaderElectionDriverAdapter is removed - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/04/16 07:55:00 UTC, 0 replies.
- Re: [Discussion] - Take findify/flink-scala-api under Flink umbrella - posted by David Morávek <dm...@apache.org> on 2023/04/16 09:45:46 UTC, 5 replies.
- [jira] [Created] (FLINK-31815) Fixing the container vulnerability by upgrade the SnakeYaml Maven dependency - posted by "Jeff Yang (Jira)" <ji...@apache.org> on 2023/04/16 12:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31816) Refactor EmbeddedLeaderElectionService - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/04/16 14:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31817) Skip meaningless testForUnsplittable in FileInputFormat - posted by "zouxxyy (Jira)" <ji...@apache.org> on 2023/04/17 03:18:00 UTC, 0 replies.
- [VOTE] FLIP-302: Support TRUNCATE TABLE statement in batch mode - posted by yuxia <lu...@alumni.sjtu.edu.cn> on 2023/04/17 03:30:42 UTC, 9 replies.
- [jira] [Created] (FLINK-31818) parsing error of 'security.kerberos.access.hadoopFileSystems' in flink-conf.yaml - posted by "Seung-Min (Jira)" <ji...@apache.org> on 2023/04/17 05:58:00 UTC, 0 replies.
- [VOTE] FLIP-304: Pluggable Failure Enrichers - posted by Panagiotis Garefalakis <pg...@apache.org> on 2023/04/17 07:23:56 UTC, 11 replies.
- [jira] [Created] (FLINK-31819) Add document for using watermark advanced functions in sql - posted by "Yuan Kui (Jira)" <ji...@apache.org> on 2023/04/17 08:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31820) Support data source sub-database and sub-table - posted by "xingyuan cheng (Jira)" <ji...@apache.org> on 2023/04/17 09:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31821) FlinkSQL set parallelism for each operator. - posted by "hanqing (Jira)" <ji...@apache.org> on 2023/04/17 09:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31822) Support configure maxRows when fetch result - posted by "Feng Jin (Jira)" <ji...@apache.org> on 2023/04/17 09:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31823) RestHandlerConfigurationTest.testWebRescaleFeatureFlagWithReactiveMode is unstable - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2023/04/17 11:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31824) flink sql TO_TIMESTAMP error - posted by "leishuiyu (Jira)" <ji...@apache.org> on 2023/04/17 12:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31825) Stopping minikube fails with timeout - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2023/04/17 13:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31826) Incorrect estimation of the target data rate of a vertex when only a subset of its upstream vertex's output is consumed - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2023/04/17 15:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31827) Incorrect estimation of the target data rate of a vertex when only a subset of its upstream vertex's output is consumed - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2023/04/17 15:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31828) List field in a POJO data stream results in table program compilation failure - posted by "Vladimir Matveev (Jira)" <ji...@apache.org> on 2023/04/17 22:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31829) Conversion to relational algebra failed to preserve datatypes' nullabilities - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2023/04/18 01:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31830) Coalesce on nested fields with different nullabilities will get wrong plan - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2023/04/18 02:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31831) TaskManagerDisconnectOnShutdownITCase.testTaskManagerProcessFailure is unstable - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2023/04/18 05:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31832) Add benchmarks for end to end restarting tasks - posted by "Weihua Hu (Jira)" <ji...@apache.org> on 2023/04/18 06:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31833) Support code-gen fusion for multiple operators - posted by "Godfrey He (Jira)" <ji...@apache.org> on 2023/04/18 08:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31834) Azure Warning: no space left on device - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2023/04/18 08:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31835) DataTypeHint don't support Row> - posted by "jeff-zou (Jira)" <ji...@apache.org> on 2023/04/18 09:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31836) Upgrade to Calcite version to 1.34.0 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2023/04/18 09:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31837) Move LeaderElectionDriver instantiated into DefaultLeaderElectionService's constructor - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/04/18 09:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31838) Move thread handling from DefaultMultipleComponentLeaderElectionService into DefaultLeaderElectionService - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/04/18 11:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31839) It's not possible to add flink-s3-fs-hadoop and flink-s3-fs-presto plugins at the same time - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2023/04/18 11:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31840) NullPointerException in operators.window.slicing.SliceAssigners$AbstractSliceAssigner.assignSliceEnd - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2023/04/18 11:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31841) Redundant local variables in AllWindowedStream#reduce - posted by "Wencong Liu (Jira)" <ji...@apache.org> on 2023/04/18 12:00:04 UTC, 0 replies.
- [jira] [Created] (FLINK-31842) calculate task executor's utilization only when used - posted by "Weihua Hu (Jira)" <ji...@apache.org> on 2023/04/18 12:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31843) Select slots from SlotPool#freeSlots in bulk - posted by "Weihua Hu (Jira)" <ji...@apache.org> on 2023/04/18 12:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31844) DefaultPackagedProgramRetriever#getClasspathsFromUserLibDir supports loading profile - posted by "Bo Cui (Jira)" <ji...@apache.org> on 2023/04/18 13:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31845) Make KubernetesStepDecorator Pluggable - posted by "Daren Wong (Jira)" <ji...@apache.org> on 2023/04/18 15:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31846) Support cancel final checkpoint when all tasks are finished - posted by "Fan Hong (Jira)" <ji...@apache.org> on 2023/04/19 02:16:00 UTC, 0 replies.
- [discuss] FLINK-25132: KafkaSource cannot work with object-reusing DeserializationSchema result in a performance regression - posted by 何军 <xu...@gmail.com> on 2023/04/19 03:30:01 UTC, 1 replies.
- [RESULT] [VOTE] Apache Flink ML Release 2.2.0, release candidate #2 - posted by Dong Lin <li...@gmail.com> on 2023/04/19 03:32:33 UTC, 0 replies.
- [jira] [Created] (FLINK-31847) Flink Connector JDBC CI Failing - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2023/04/19 07:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31848) And Operator has side effect when operands have udf - posted by "zju_zsx (Jira)" <ji...@apache.org> on 2023/04/19 08:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31849) Enforce some some simple validation directly through the CRD - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2023/04/19 08:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31850) Fix args in JobSpec not being passed through to Flink in Standalone mode - 1.4.0 - posted by "Gil Shmaya (Jira)" <ji...@apache.org> on 2023/04/19 09:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31851) Remove unused KubernetesMultipleComponentLeaderElectionHaServicesFactory - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2023/04/19 09:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31852) NumRecordsOut metrics broken - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2023/04/19 10:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31853) Remove use of ExecutionAttemptMappingProvider - posted by "Junrui Li (Jira)" <ji...@apache.org> on 2023/04/19 11:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31854) Flink connector redshift - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2023/04/19 12:01:00 UTC, 0 replies.
- DefaultInputSplitAssigner question - posted by Péter Váry <pe...@gmail.com> on 2023/04/19 12:26:34 UTC, 4 replies.
- [jira] [Created] (FLINK-31855) Canceling a job through the UI isn't possible in standalone - posted by "Gil Shmaya (Jira)" <ji...@apache.org> on 2023/04/19 13:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31856) Add support for Opensearch Connector REST client customization - posted by "Michael Hempel-Jørgensen (Jira)" <ji...@apache.org> on 2023/04/19 14:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31857) Support pluginable observers mechanism - posted by "Daren Wong (Jira)" <ji...@apache.org> on 2023/04/19 15:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31858) Add Autoscaler support for Session Job - posted by "phoebe chen (Jira)" <ji...@apache.org> on 2023/04/19 15:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31859) Update maven cyclonedx plugin to 2.7.7 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2023/04/19 16:11:00 UTC, 0 replies.
- ValueState losing event randomly onTimer trigger - posted by Kireet Agrawal <ki...@gantry.io.INVALID> on 2023/04/19 16:44:30 UTC, 0 replies.
- [jira] [Created] (FLINK-31860) FlinkDeployments never finalize when namespace is deleted - posted by "Jayme Howard (Jira)" <ji...@apache.org> on 2023/04/19 20:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31861) Introduce ByteArraySchema which serialize/deserialize data of type byte array - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2023/04/20 05:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31862) KafkaSinkITCase.testStartFromSavepoint is unstable - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2023/04/20 07:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31863) Add 'Hostname' enum val to k8s NodeAddress type. - posted by "Vince.Feng (Jira)" <ji...@apache.org> on 2023/04/20 10:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31864) Generate unaligned checkpoint type based on persisted data - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2023/04/20 10:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31865) Flink hive parser support order by non select column - posted by "yunfan (Jira)" <ji...@apache.org> on 2023/04/20 10:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31866) Autoscaler metric trimming reduces the numbet of metric observations - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2023/04/20 11:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31867) Enforce a minimum number of observations within a metric window - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2023/04/20 11:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31868) Fix DefaultInputSplitAssigner javadoc for class - posted by "Peter Vary (Jira)" <ji...@apache.org> on 2023/04/20 11:41:00 UTC, 0 replies.
- [VOTE] Release flink-shaded 17.0, release candidate #1 - posted by Martijn Visser <ma...@apache.org> on 2023/04/20 12:25:39 UTC, 1 replies.
- [jira] [Created] (FLINK-31869) test_multi_sessionjob.sh gets stuck very frequently - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2023/04/20 14:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31870) Cassandra input/output formats documentation is missing - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2023/04/20 14:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31871) Interpret Flink MemoryUnits according to the actual user input - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2023/04/20 15:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31872) CLONE - AsyncSinkWriter Performance regression due to AIMD rate limiting strategy - posted by "Ahmed Hamdy (Jira)" <ji...@apache.org> on 2023/04/20 17:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31873) Add setMaxParallelism to the DataStreamSink Class - posted by "Eric Xiao (Jira)" <ji...@apache.org> on 2023/04/20 20:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31874) Support truncate table statement in batch mode - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2023/04/21 01:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31875) OSS throwns NoClassDefFoundError due to old hadoop-common version - posted by "Hangxiang Yu (Jira)" <ji...@apache.org> on 2023/04/21 02:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31876) [JUnit5 Migration] Module: flink-queryable-state - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2023/04/21 04:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31877) StreamExecutionEnvironmentTests.test_from_collection_with_data_types is unstable - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2023/04/21 05:47:00 UTC, 0 replies.
- [VOTE] FLIP-288: Enable Dynamic Partition Discovery by Default in Kafka Source - posted by Hongshun Wang <lo...@gmail.com> on 2023/04/21 06:50:45 UTC, 12 replies.
- [jira] [Created] (FLINK-31878) Fix the wrong name of PauseOrResumeSplitsTask#toString in connector fetcher - posted by "Yuxin Tan (Jira)" <ji...@apache.org> on 2023/04/21 07:52:00 UTC, 0 replies.
- Off for a week - posted by Etienne Chauchot <ec...@apache.org> on 2023/04/21 08:53:45 UTC, 0 replies.
- [ANNOUNCE] New Apache Flink PMC Member - Leonard Xu - posted by Jark Wu <im...@gmail.com> on 2023/04/21 11:47:52 UTC, 34 replies.
- [ANNOUNCE] New Apache Flink PMC Member - Qingsheng Ren - posted by Jark Wu <im...@gmail.com> on 2023/04/21 11:50:02 UTC, 33 replies.
- [jira] [Created] (FLINK-31879) org.apache.avro.util.Utf8 cannot be serialized with avro when used in state - posted by "Feroze Daud (Jira)" <ji...@apache.org> on 2023/04/21 18:11:00 UTC, 0 replies.
- [DISCUSS] FLINK-31873: Add setMaxParallelism to the DataStreamSink Class - posted by eric xiao <xi...@gmail.com> on 2023/04/21 19:20:12 UTC, 4 replies.
- [jira] [Created] (FLINK-31880) Bad Test in OrcColumnarRowSplitReaderTest - posted by "Kurt Ostfeld (Jira)" <ji...@apache.org> on 2023/04/21 21:52:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-304: Pluggable Failure Enrichers - posted by Panagiotis Garefalakis <pg...@apache.org> on 2023/04/22 00:06:35 UTC, 0 replies.
- [ANNOUNCE] Apache Flink Kafka Connectors 3.0.0 released - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2023/04/22 03:12:15 UTC, 0 replies.
- [jira] [Created] (FLINK-31881) The Chinese documentation page of Flink official CEP is experiencing confusion. - posted by "zhaoshuo (Jira)" <ji...@apache.org> on 2023/04/22 13:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31882) SqlGateway will throw exception when executing DeleteFromFilterOperation - posted by "yuzelin (Jira)" <ji...@apache.org> on 2023/04/23 02:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31883) StreamSQLExample.Order has nullability issues - posted by "chenyu (Jira)" <ji...@apache.org> on 2023/04/23 03:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31884) Upgrade ExecNode to new version causes the old serialized plan failed to pass Json SerDe round trip - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2023/04/23 06:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31885) Trigger events on autoscaler errors - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2023/04/23 06:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31886) Upgrade to fabric8 6.5.1 and JOSDK 4.3.0 - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2023/04/23 06:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31887) Upgrade Flink version of Flink ML to 1.17.0 - posted by "Jiang Xin (Jira)" <ji...@apache.org> on 2023/04/23 11:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31888) Introduce interfaces and utils for loading and executing enrichers - posted by "Panagiotis Garefalakis (Jira)" <ji...@apache.org> on 2023/04/23 21:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31889) Add documentation for implementing/loading enrichers - posted by "Panagiotis Garefalakis (Jira)" <ji...@apache.org> on 2023/04/23 21:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31890) JobMaster per-task failure labeling - posted by "Panagiotis Garefalakis (Jira)" <ji...@apache.org> on 2023/04/23 22:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31891) JobMaster TM disconnect failure labeling - posted by "Panagiotis Garefalakis (Jira)" <ji...@apache.org> on 2023/04/23 22:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31893) AdaptiveScheduler global failure handling - posted by "Panagiotis Garefalakis (Jira)" <ji...@apache.org> on 2023/04/23 22:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31892) DefaultScheduler global failure handling - posted by "Panagiotis Garefalakis (Jira)" <ji...@apache.org> on 2023/04/23 22:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31894) ExceptionHistory and REST API failure label integration - posted by "Panagiotis Garefalakis (Jira)" <ji...@apache.org> on 2023/04/23 22:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31896) Extend web interface to support failure labels - posted by "Panagiotis Garefalakis (Jira)" <ji...@apache.org> on 2023/04/23 22:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31895) End-to-end integration tests for failure labels - posted by "Panagiotis Garefalakis (Jira)" <ji...@apache.org> on 2023/04/23 22:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31897) Failing Unit Test: org.apache.flink.queryablestate.network.ClientTest.testRequestUnavailableHost - posted by "Kurt Ostfeld (Jira)" <ji...@apache.org> on 2023/04/23 23:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31898) Flink k8s autoscaler does not work as expected - posted by "Kyungmin Kim (Jira)" <ji...@apache.org> on 2023/04/24 02:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31899) Upgrade Flink version of Flink ML to 1.17.0 - posted by "Jiang Xin (Jira)" <ji...@apache.org> on 2023/04/24 03:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31900) Fix some typo in java doc, comments and assertion message - posted by "Feifan Wang (Jira)" <ji...@apache.org> on 2023/04/24 03:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31901) AbstractBroadcastWrapperOperator should not block checkpoint barriers when processing cached records - posted by "Zhipeng Zhang (Jira)" <ji...@apache.org> on 2023/04/24 06:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31902) cast expr to type with not null should throw exception like calcite - posted by "jackylau (Jira)" <ji...@apache.org> on 2023/04/24 06:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31903) Caching records fails in BroadcastUtils#withBroadcastStream - posted by "Zhipeng Zhang (Jira)" <ji...@apache.org> on 2023/04/24 07:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31904) fix current serveral flink nullable type handle - posted by "jackylau (Jira)" <ji...@apache.org> on 2023/04/24 07:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31905) Exception thrown when accessing nested field of the result of Python UDF with complex type - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2023/04/24 07:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31906) typeof should only return type exclude nullable - posted by "jackylau (Jira)" <ji...@apache.org> on 2023/04/24 07:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31907) Remove unused fields inside of ExecutionSlotSharingGroupBuilder - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2023/04/24 07:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31909) Using BroadcastUtils#withBroadcast in iteration perround mode got stuck - posted by "Zhipeng Zhang (Jira)" <ji...@apache.org> on 2023/04/24 07:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31908) cast expr to type with not null should not change nullable of expr - posted by "jackylau (Jira)" <ji...@apache.org> on 2023/04/24 07:44:00 UTC, 0 replies.
- [RESULT] [VOTE] flink-connector-aws 4.1.0 for Flink 1.17 - posted by Danny Cranmer <da...@apache.org> on 2023/04/24 07:47:43 UTC, 0 replies.
- [jira] [Created] (FLINK-31910) Using BroadcastUtils#withBroadcast in iteration perround mode got stuck - posted by "Zhipeng Zhang (Jira)" <ji...@apache.org> on 2023/04/24 07:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31911) Bad address construction in SqlClientTest - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2023/04/24 08:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31912) Upgrade bytebuddy - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2023/04/24 08:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31913) sql-client.sh does not respect env.java.opts.all/client - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2023/04/24 08:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31914) Failing to close FlinkKafkaInternalProducer created in KafkaWriter with exactly-once semantic results in memory leak - posted by "datariver (Jira)" <ji...@apache.org> on 2023/04/24 08:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31915) Python API incorrectly passes env.java.opts as single argument - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2023/04/24 08:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31916) Python API only respects deprecated env.java.opts key - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2023/04/24 08:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31917) Loss of Idempotence in JsonSerDe Round Trip for AggregateCall and RexNode - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2023/04/24 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31918) Pulsar Source does not failing build against Flink 1.18 on nightly CI - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2023/04/24 09:06:00 UTC, 0 replies.
- [RESULT] [VOTE] flink-connector-mongodb 1.0.1, release candidate #1 - posted by Danny Cranmer <da...@apache.org> on 2023/04/24 09:25:10 UTC, 0 replies.
- [jira] [Created] (FLINK-31919) Skip ClosureCleaner if object can be serialized - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2023/04/24 09:35:00 UTC, 0 replies.
- Re: [Discussion] - Release major Flink version to support JDK 17 (LTS) - posted by Chesnay Schepler <ch...@apache.org> on 2023/04/24 09:39:20 UTC, 7 replies.
- [ANNOUNCE] Apache flink-connector-mongodb 1.0.1 released - posted by Danny Cranmer <da...@apache.org> on 2023/04/24 09:48:34 UTC, 0 replies.
- [ANNOUNCE] Apache flink-connector-aws 4.1.0 for Flink 1.17 released - posted by Danny Cranmer <da...@apache.org> on 2023/04/24 09:55:28 UTC, 0 replies.
- [jira] [Created] (FLINK-31920) Flaky tests - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2023/04/24 10:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31921) Create a mini cluster based metric collection test - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2023/04/24 10:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31922) Port over Kinesis Client configurations for retry and backoff - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2023/04/24 11:12:00 UTC, 0 replies.
- Kubernetes Operator 1.5.0 release planning - posted by Gyula Fóra <gy...@apache.org> on 2023/04/24 11:26:27 UTC, 1 replies.
- [jira] [Created] (FLINK-31923) Connector weekly runs are only testing main branches instead of all supported branches - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2023/04/24 11:48:00 UTC, 0 replies.
- [SUMMARY] Flink 1.18 Release Sync 04/18/2023 - posted by Qingsheng Ren <re...@apache.org> on 2023/04/24 11:49:52 UTC, 2 replies.
- [jira] [Created] (FLINK-31924) [Flink operator] Flink Autoscale - Limit the max number of scale ups - posted by "Sriram Ganesh (Jira)" <ji...@apache.org> on 2023/04/24 12:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31925) Sync benchmark dependency versions with the version used in Flink - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2023/04/24 14:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31926) Implement rename Table in GlueCatalog - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2023/04/24 17:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31927) Cassandra source raises an exception on Flink 1.16.0 on a real Cassandra cluster - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2023/04/24 18:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31928) flink-kubernetes works not properly in IPv6 environment in k8s - posted by "caiyi (Jira)" <ji...@apache.org> on 2023/04/25 01:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31929) HighAvailabilityServicesUtils.getWebMonitorAddress works not properly in IPv6 stack of k8s - posted by "caiyi (Jira)" <ji...@apache.org> on 2023/04/25 01:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31930) MetricQueryService works not properly in k8s with IPv6 stack - posted by "caiyi (Jira)" <ji...@apache.org> on 2023/04/25 02:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31931) Exception history page should not link to a non-existent TM log page. - posted by "Junrui Li (Jira)" <ji...@apache.org> on 2023/04/25 04:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31932) Allow to configure HA on k8s without using service account - posted by "Arkadiusz Gasinski (Jira)" <ji...@apache.org> on 2023/04/25 06:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31933) Remove Whitebox usage in ExpressionKeysTest - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2023/04/25 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31934) Remove mocking in RocksDB tests - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2023/04/25 08:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31935) The new resource requirements REST API is only available for session clusters - posted by "David Morávek (Jira)" <ji...@apache.org> on 2023/04/25 09:46:00 UTC, 0 replies.
- Inconsistent Display Formats of TIMESTAMP_LTZ - posted by Paul Lam <pa...@gmail.com> on 2023/04/25 10:16:02 UTC, 0 replies.
- [DISCUSS] Planning Flink 2.0 - posted by Xintong Song <to...@gmail.com> on 2023/04/25 11:09:56 UTC, 19 replies.
- [DISCUSS] Preventing Mockito usage for the new code with Checkstyle - posted by David Morávek <dm...@apache.org> on 2023/04/25 11:15:58 UTC, 13 replies.
- [jira] [Created] (FLINK-31936) Support setting scale up max factor - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2023/04/25 11:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31937) Failing Unit Test: ClientTest.testClientServerIntegration "Connection leak" - posted by "Kurt Ostfeld (Jira)" <ji...@apache.org> on 2023/04/25 14:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31938) Failing Unit Test: FlinkConnectionTest.testCatalogSchema "Failed to get response for the operation" - posted by "Kurt Ostfeld (Jira)" <ji...@apache.org> on 2023/04/25 15:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31939) ClassNotFoundException on org.apache.beam.runners.flink.translation.wrappers.SourceInputFormat when running Flink 1.14 and up with Beam 2.46.0 - posted by "AmitK (Jira)" <ji...@apache.org> on 2023/04/25 16:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31940) DataStreamCsvITCase#CityPojo should be public - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2023/04/25 17:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31941) Not backwards compatible naming for some kubernetes resources - posted by "Eric Xiao (Jira)" <ji...@apache.org> on 2023/04/25 20:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31942) Support Conditional Writes in DynamoDB connector - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2023/04/25 21:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31943) Multiple t_env cause class loading problem - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2023/04/26 02:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31944) Protobuf format throw com.google.protobuf.InvalidProtocolBufferException - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2023/04/26 07:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31945) Table of contents in the blogs of the project website is missing some titles - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2023/04/26 09:09:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-288: Enable Dynamic Partition Discovery by Default in Kafka Source - posted by Hongshun Wang <lo...@gmail.com> on 2023/04/26 11:24:26 UTC, 0 replies.
- [jira] [Created] (FLINK-31946) DynamoDB Sink Allow Multiple Item Writes - posted by "Curtis Jensen (Jira)" <ji...@apache.org> on 2023/04/26 16:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31947) Enable stdout redirect in flink-console.sh - posted by "Zhenqiu Huang (Jira)" <ji...@apache.org> on 2023/04/26 17:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31948) Supports triggering CI manually - posted by "Jiang Xin (Jira)" <ji...@apache.org> on 2023/04/27 02:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31949) The state of CountTumblingWindowAssigner of Python DataStream API were never purged - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2023/04/27 03:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31950) Introduce StateMetadata and support operator-level state TTL configuration via Compiled Plan - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2023/04/27 04:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31951) Mix schema record source creates corrupt record - posted by "Kevin Tseng (Jira)" <ji...@apache.org> on 2023/04/27 04:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31952) Support 'EXPLAIN' statement for CompiledPlan - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2023/04/27 07:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31953) FLIP-288: Enable Dynamic Partition Discovery by Default in Kafka Source - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2023/04/27 08:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31954) Prevent Mockito for the new code with Checkstyle - posted by "David Morávek (Jira)" <ji...@apache.org> on 2023/04/27 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31955) Prevent JUnit 4 usage for the new code with Checkstyle - posted by "David Morávek (Jira)" <ji...@apache.org> on 2023/04/27 08:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31956) Extend the CompiledPlan to read from/write to Flink's FileSystem - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2023/04/27 09:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31957) Add documentation for the user story - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2023/04/27 09:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31958) Table to DataStream allow partial fields - posted by "padavan (Jira)" <ji...@apache.org> on 2023/04/27 10:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31959) Correct the unaligned checkpoint type at checkpoint level - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2023/04/27 10:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31960) SQL OverBy. Error on a code that does not exist - posted by "padavan (Jira)" <ji...@apache.org> on 2023/04/27 16:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31961) Implement ExpandedQuery and OriginalQuery methods for glue in catalog - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2023/04/27 16:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31962) libssl not found when running CI - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2023/04/27 19:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31963) java.lang.ArrayIndexOutOfBoundsException when scale down via autoscaler - posted by "Tan Kim (Jira)" <ji...@apache.org> on 2023/04/28 02:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31964) Improve the document of Autoscaler as 1.17.0 is released - posted by "Biao Geng (Jira)" <ji...@apache.org> on 2023/04/28 02:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31965) Fix ClassNotFoundException in benchmarks - posted by "Paul Lin (Jira)" <ji...@apache.org> on 2023/04/28 06:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31966) Flink Kubernetes operator lacks TLS support - posted by "Adrian Vasiliu (Jira)" <ji...@apache.org> on 2023/04/28 07:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31967) SQL with LAG function NullPointerException - posted by "padavan (Jira)" <ji...@apache.org> on 2023/04/28 08:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31968) [PyFlink] 1.17.0 version on M1 processor - posted by "Yury Smirnov (Jira)" <ji...@apache.org> on 2023/04/28 08:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31969) Remove all local recovery files immediately when local recovery fail - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2023/04/28 10:44:00 UTC, 0 replies.
- [DISCUSS] SqlClient gateway mode: support for URLs - posted by Alexander Fedulov <al...@gmail.com> on 2023/04/28 12:41:28 UTC, 0 replies.
- [jira] [Created] (FLINK-31971) Drop HadoopRecoverableWriterOldHadoopWithNoTruncateSupportTest - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2023/04/28 15:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31972) Remove powermock whitebox usages - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2023/04/28 16:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31973) Introduce Managed table support in glue catalog - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2023/04/28 17:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31974) JobManager crashes after KubernetesClientException exception with FatalExitExceptionHandler - posted by "Sergio Sainz (Jira)" <ji...@apache.org> on 2023/04/28 22:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31975) default catalog failed to retrieve partition Spec - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2023/04/29 09:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31976) Once marked as an inefficient scale-up, further scaling may not happen forever - posted by "Tan Kim (Jira)" <ji...@apache.org> on 2023/04/30 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31977) If scaling.effectiveness.detection.enabled is false, the call to the detectIneffectiveScaleUp() function is unnecessary - posted by "Tan Kim (Jira)" <ji...@apache.org> on 2023/04/30 09:22:00 UTC, 0 replies.