dev@flink.apache.org, 2022-11

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

- Re: [ANNOUNCE] Apache Flink 1.16.0 released - posted by liu ron <ro...@gmail.com> on 2022/11/01 00:12:52 UTC, 0 replies.
- [jira] [Created] (FLINK-29820) Support to read data from table store with specify snapshot id - posted by "Shammon (Jira)" <ji...@apache.org> on 2022/11/01 00:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29821) Schema.Builder how to set not null column? - posted by "Alvin Ge (Jira)" <ji...@apache.org> on 2022/11/01 01:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29822) Fix wrong description in comments of StreamExecutionEnvironment#setMaxParallelism() - posted by "Feifan Wang (Jira)" <ji...@apache.org> on 2022/11/01 01:51:00 UTC, 0 replies.
- Re: [jira] [Created] (FLINK-29807) Drop TypeSerializerConfigSnapshot and savepoint support from Flink versions < 1.8.0 - posted by Leonard Xu <xb...@gmail.com> on 2022/11/01 02:15:42 UTC, 0 replies.
- [jira] [Created] (FLINK-29823) Support create schema for table snapshot - posted by "Shammon (Jira)" <ji...@apache.org> on 2022/11/01 02:31:00 UTC, 0 replies.
- Re: [DISCUSS] Delete useless branches from Flink repository - posted by Yun Tang <my...@live.com> on 2022/11/01 03:26:53 UTC, 1 replies.
- Re: [VOTE] FLIP-263: Improve resolving schema compatibility - posted by Yun Tang <my...@live.com> on 2022/11/01 03:27:51 UTC, 0 replies.
- [jira] [Created] (FLINK-29824) AgglomerativeClustering fails when the distanceThreshold is very large - posted by "Zhipeng Zhang (Jira)" <ji...@apache.org> on 2022/11/01 04:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29825) Improve benchmark stablility - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2022/11/01 04:36:00 UTC, 0 replies.
- Re: [ANNOUNCE] New Apache Flink PMC Member - Danny Cranmer - posted by weijie guo <gu...@gmail.com> on 2022/11/01 06:19:23 UTC, 4 replies.
- Re: [DISCUSS] Remove FlinkKafkaConsumer and FlinkKafkaProducer in the master for 1.17 release - posted by David Anderson <da...@apache.org> on 2022/11/01 06:21:04 UTC, 10 replies.
- [jira] [Created] (FLINK-29826) flink-sql-connector-hbase-1.4 netty class not found, because of shade not work - posted by "xuyong (Jira)" <ji...@apache.org> on 2022/11/01 07:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29827) [Connector][AsyncSinkWriter] Checkpointed states block writer from sending records - posted by "Hoang Tri Tam (Jira)" <ji...@apache.org> on 2022/11/01 07:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29828) Support to read data from table with given snapshot id - posted by "Shammon (Jira)" <ji...@apache.org> on 2022/11/01 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29829) align explain results in different platforms - posted by "Yubin Li (Jira)" <ji...@apache.org> on 2022/11/01 08:14:00 UTC, 0 replies.
- Re: SQL Gateway and SQL Client - posted by Alexey Leonov-Vendrovskiy <ve...@gmail.com> on 2022/11/01 08:15:43 UTC, 16 replies.
- [jira] [Created] (FLINK-29830) PulsarSinkITCase$DeliveryGuaranteeTest.writeRecordsToPulsar failed - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/11/01 08:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29831) Multiple Hive tests are failing - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/11/01 08:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29832) Refactor default database name in flink table store - posted by "Shammon (Jira)" <ji...@apache.org> on 2022/11/01 08:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29833) Improve PyFlink support in Windows - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/11/01 08:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29834) Clear static Jackson TypeFactory cache on CL release - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/11/01 09:27:00 UTC, 0 replies.
- [SUMMARY] Flink 1.17 Release Sync 11/1/2022 - posted by Qingsheng Ren <re...@apache.org> on 2022/11/01 09:29:30 UTC, 0 replies.
- [jira] [Created] (FLINK-29835) BlobServer fails to provide artifacts - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/11/01 09:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29836) PulsarUnorderedSourceITCase failed due to an expected job restart not happening - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/11/01 09:46:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-264 Extract BaseCoordinatorContext - posted by Maximilian Michels <mx...@apache.org> on 2022/11/01 12:28:55 UTC, 5 replies.
- Re: Stateful Functions with Flink 1.15 and onwards - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2022/11/01 17:07:05 UTC, 6 replies.
- [GitHub] [flink-connector-shared-utils] MartijnVisser commented on a diff in pull request #1: [FLINK-29472] Add first version of release scripts - posted by GitBox <gi...@apache.org> on 2022/11/01 18:16:58 UTC, 0 replies.
- [jira] [Created] (FLINK-29837) SQL API does not expose the RowKind of the Row for processing Changelogs - posted by "Eric Xiao (Jira)" <ji...@apache.org> on 2022/11/01 23:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29838) Hive streaming sink for partitioned table should contain metastore by default - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/11/02 01:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29839) SQL Gateway with hiveserver2 throw exception - posted by "chenqizhu (Jira)" <ji...@apache.org> on 2022/11/02 02:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29840) Old record may overwrite new record in Table Store when snapshot committing is slow - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/11/02 03:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29841) docs/content/docs/deployment/config.md has error - posted by "hcj (Jira)" <ji...@apache.org> on 2022/11/02 03:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29842) Change commitIdentifier in Table Store snapshot to long value - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/11/02 03:23:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-263: Improve resolving schema compatibility - posted by Hangxiang Yu <ma...@gmail.com> on 2022/11/02 04:05:36 UTC, 0 replies.
- [jira] [Created] (FLINK-29843) Euclidean Distance Measure generates NAN distance values - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2022/11/02 04:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29844) FLIP-263: Improve resolving schema compatibility - posted by "Hangxiang Yu (Jira)" <ji...@apache.org> on 2022/11/02 04:48:00 UTC, 0 replies.
- [GitHub] [flink-connector-shared-utils] zentol commented on a diff in pull request #1: [FLINK-29472] Add first version of release scripts - posted by GitBox <gi...@apache.org> on 2022/11/02 07:17:09 UTC, 9 replies.
- [jira] [Created] (FLINK-29845) ThroughputCalculator throws java.lang.IllegalArgumentException: Time should be non negative under very low throughput cluster - posted by "Jingxiao GU (Jira)" <ji...@apache.org> on 2022/11/02 07:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29846) Upgrade Archunit to 1.0.0 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/11/02 07:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29847) Store/cache JarUploadResponseBody - posted by "Daren Wong (Jira)" <ji...@apache.org> on 2022/11/02 08:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29848) Port BinaryRowDataUtil to Flink Table Store - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/11/02 08:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29849) Event time temporal join on an upsert source may produce incorrect execution plan - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2022/11/02 08:28:00 UTC, 0 replies.
- Re: [DISCUSS] Flink release retro - posted by Qingsheng Ren <re...@apache.org> on 2022/11/02 08:42:08 UTC, 6 replies.
- [GitHub] [flink-connector-shared-utils] leonardBang commented on pull request #1: [FLINK-29472] Add first version of release scripts - posted by GitBox <gi...@apache.org> on 2022/11/02 10:11:02 UTC, 1 replies.
- [GitHub] [flink-connector-shared-utils] MartijnVisser commented on pull request #1: [FLINK-29472] Add first version of release scripts - posted by GitBox <gi...@apache.org> on 2022/11/02 10:16:36 UTC, 0 replies.
- [DISCUSS] FLIP-269: Properly Handling the Processing Timers on Job Termination - posted by Yun Gao <yu...@aliyun.com.INVALID> on 2022/11/02 10:19:36 UTC, 22 replies.
- [VOTE] Release Apache Flink Elasticsearch connector 3.0.0, rc1 - posted by Chesnay Schepler <ch...@apache.org> on 2022/11/02 11:01:17 UTC, 3 replies.
- Re: [DISCUSS] Release Flink 1.15.3 - posted by Fabian Paul <fp...@apache.org> on 2022/11/02 13:07:47 UTC, 6 replies.
- Re: [DISCUSS] Issue tracking workflow - posted by Chesnay Schepler <ch...@apache.org> on 2022/11/02 13:14:42 UTC, 7 replies.
- [jira] [Created] (FLINK-29850) Flink Table Store quick start guide does not work - posted by "Alex Sorokoumov (Jira)" <ji...@apache.org> on 2022/11/02 14:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29851) Upgrade to Fabric8 6.x.x and JOSDK 4.x.x - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/11/02 14:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29852) The operator is repeatedly displayed on the Flink Web UI - posted by "JasonLee (Jira)" <ji...@apache.org> on 2022/11/02 15:59:00 UTC, 0 replies.
- Re: [VOTE] Drop TypeSerializerConfigSnapshot and savepoint support from Flink versions < 1.8.0 - posted by Piotr Nowojski <pn...@apache.org> on 2022/11/02 17:04:02 UTC, 0 replies.
- [RESULT][VOTE] Drop TypeSerializerConfigSnapshot and savepoint support from Flink versions < 1.8.0 - posted by Piotr Nowojski <pn...@apache.org> on 2022/11/02 17:06:39 UTC, 0 replies.
- [jira] [Created] (FLINK-29853) Older jackson-databind found in flink-kubernetes-operator-1.2.0-shaded.jar - posted by "James Busche (Jira)" <ji...@apache.org> on 2022/11/02 17:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29854) Make Record Size Flush Strategy Optional for Async Sink - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2022/11/02 19:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29855) UDF randomly processed input data twice - posted by "Xinyi Yan (Jira)" <ji...@apache.org> on 2022/11/02 21:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29856) Triggering savepoint does not trigger source operator checkpoint - posted by "Mason Chen (Jira)" <ji...@apache.org> on 2022/11/03 02:50:00 UTC, 1 replies.
- [jira] [Created] (FLINK-29857) Fix HiveServer2Endpoint crush when using Hive3 Beeline - posted by "yuzelin (Jira)" <ji...@apache.org> on 2022/11/03 03:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29858) Jdbc reading supports setting multiple queryTemplates - posted by "waywtdcc (Jira)" <ji...@apache.org> on 2022/11/03 05:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29859) TPC-DS end-to-end test with adaptive batch scheduler failed due to oo non-empty .out files. - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2022/11/03 06:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29860) Pulsar connector bug when using Hybrid.Builder - posted by "Noel O'Connor (Jira)" <ji...@apache.org> on 2022/11/03 07:16:00 UTC, 0 replies.
- [CANCELED][VOTE] Release Apache Flink Elasticsearch connector 3.0.0, rc1 - posted by Chesnay Schepler <ch...@apache.org> on 2022/11/03 07:55:56 UTC, 0 replies.
- [jira] [Created] (FLINK-29861) Optimize logic of enumerateSplits in HiveSource - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/11/03 07:57:00 UTC, 0 replies.
- [VOTE] Release Apache Flink Elasticsearch connector 3.0.0, rc2 - posted by Chesnay Schepler <ch...@apache.org> on 2022/11/03 08:22:13 UTC, 11 replies.
- [jira] [Created] (FLINK-29862) Upgrade to flink-shaded 16.0 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/11/03 08:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29863) Properly handle NaN/Infinity in OpenAPI spec - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/11/03 09:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29864) AvroDeserializationSchema.forSpecific still generates genericdata.record - posted by "christofe lintermans (Jira)" <ji...@apache.org> on 2022/11/03 10:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29865) Allow configuring the JDK in build-nightly-dist.yml - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2022/11/03 10:51:00 UTC, 0 replies.
- Re: [ANNOUNCE] Performance Daily Monitoring Moved from Ververica to Apache Flink Slack Channel - posted by Jing Ge <ji...@ververica.com> on 2022/11/03 11:21:52 UTC, 2 replies.
- [jira] [Created] (FLINK-29866) Split flink-dist - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/11/03 11:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29867) Update maven-enforcer-plugin to 3.1.0 - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2022/11/03 12:03:00 UTC, 0 replies.
- ASF Slack - posted by Maximilian Michels <mx...@apache.org> on 2022/11/03 12:13:27 UTC, 15 replies.
- [jira] [Created] (FLINK-29868) Dependency convergence error for org.osgi:org.osgi.core:jar - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2022/11/03 12:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29870) Split ResourceActions to ResourceAllocator and ResourceAllocationNotifier - posted by "Weihua Hu (Jira)" <ji...@apache.org> on 2022/11/03 12:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29869) make ResourceActions declarative - posted by "Weihua Hu (Jira)" <ji...@apache.org> on 2022/11/03 12:34:00 UTC, 0 replies.
- Re: [DISCUSS] FLINK-20578 Cannot create empty array using ARRAY[] - posted by eric xiao <xi...@gmail.com> on 2022/11/03 14:53:45 UTC, 0 replies.
- [jira] [Created] (FLINK-29871) Upgrade operator Flink version and examples to 1.16 - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/11/03 15:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29872) JobDetailsInfo Rest endpoint breaking change in 1.16 - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/11/03 16:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29873) CannotPlanException raised after "CROSS JOIN UNNEST" - posted by "Daeyeon Bae (Jira)" <ji...@apache.org> on 2022/11/03 23:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29874) Streaming File Sink end-to-end test failed on azure - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2022/11/04 01:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29875) Can not find JobConf when using Hive Connector - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/11/04 02:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29876) Explicitly throw exception from Table Store sink when unaligned checkpoint is enabled - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/11/04 02:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29877) Failed to fetch next result - posted by "penney (Jira)" <ji...@apache.org> on 2022/11/04 03:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29878) Fail to use flink-sql-connector-hive-3.1.3 - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/11/04 04:20:00 UTC, 0 replies.
- 回复：[jira] [Commented] (FLINK-29877) Failed to fetch next result - posted by 浦、懂 <27...@qq.com.INVALID> on 2022/11/04 05:29:13 UTC, 1 replies.
- [jira] [Created] (FLINK-29879) Introduce operators for files merging - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/11/04 06:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29880) Hive sink supports merge files in batch mode - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/11/04 06:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29881) when Fetch results in sql gateway, the result using open api is different from using restful api - posted by "yiwei93 (Jira)" <ji...@apache.org> on 2022/11/04 06:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29882) LargeDataITCase is not stable - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/11/04 07:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29883) Benchmarks are failing - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/11/04 08:08:00 UTC, 0 replies.
- [DISCUSS]Introduce a time-segment based restart strategy - posted by Weihua Hu <hu...@gmail.com> on 2022/11/04 08:45:35 UTC, 7 replies.
- [jira] [Created] (FLINK-29884) Flaky test failure in finegrained_resource_management/SortMergeResultPartitionTest.testRelease - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2022/11/04 09:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29885) SqlValidatorException :Column 'currency' is ambiguous - posted by "ZuoYan (Jira)" <ji...@apache.org> on 2022/11/04 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29886) networkThroughput 1000,100ms,OpenSSL Benchmark is failing - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2022/11/04 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29887) Lookup cache in JDBC table connector is not each process (i.e. TaskManager) will hold a cache - posted by "linweijiang (Jira)" <ji...@apache.org> on 2022/11/04 09:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29888) Improve MutatedConfigurationException for disallowed changes in CheckpointConfig and ExecutionConfig - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2022/11/04 12:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29889) netty-tcnative-static does not bundle tcnative-classes - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/11/04 14:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29890) UDFs classloading from JARs in 1.16 is broken - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2022/11/04 14:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29891) The RetryRule tests print some excessive stacktraces that might confuse people investigating actual issues - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/11/04 15:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29892) flink-conf.yaml does not accept hash (#) in the env.java.opts property - posted by "Sergio Sainz (Jira)" <ji...@apache.org> on 2022/11/04 15:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29893) k8s python e2e test failed due to permission error when pulling the Docker image - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/11/04 16:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29894) Rename flink-connector-dynamodb to flink-connector-aws - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2022/11/04 16:42:00 UTC, 0 replies.
- [DISCUSS] FLIP-271: Autoscaling - posted by Maximilian Michels <mx...@apache.org> on 2022/11/04 18:37:28 UTC, 48 replies.
- [jira] [Created] (FLINK-29895) Improve code coverage and integration tests for DynamoDB implementation of Async Sink - posted by "Yuri Gusev (Jira)" <ji...@apache.org> on 2022/11/04 19:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29896) DynamoDB CI Failing to run checks - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2022/11/04 20:22:00 UTC, 0 replies.
- Re: [jira] [Created] (FLINK-28372) Investigate Akka Artery - posted by Razin Bouzar <rb...@salesforce.com.INVALID> on 2022/11/04 22:10:19 UTC, 1 replies.
- [jira] [Created] (FLINK-29897) PyFlinkStreamUserDefinedFunctionTests.test_table_function fails on CI - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2022/11/05 05:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29898) ClusterEntrypointTest.testCloseAsyncShouldBeExecutedInShutdownHook fails on CI - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2022/11/05 05:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29899) flink-runtime tests fail with exit code 137 returned from Docker - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2022/11/05 06:10:00 UTC, 0 replies.
- Re: Re: [DISCUSS] FLIP-213: TaskManager's Flame Graphs - posted by Yun Tang <my...@live.com> on 2022/11/05 07:51:13 UTC, 0 replies.
- [jira] [Created] (FLINK-29900) Implement Table API for DynamoDB Sink - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2022/11/05 08:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29901) Support “NOT IN” built-in function in Table API - posted by "zhangjingcun (Jira)" <ji...@apache.org> on 2022/11/05 08:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29902) Support “value1.notIn(TABLE)” built-in function in Table API - posted by "zhangjingcun (Jira)" <ji...@apache.org> on 2022/11/05 08:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29903) Support “string1.notSimilar(string2)” built-in function in Table API - posted by "zhangjingcun (Jira)" <ji...@apache.org> on 2022/11/05 08:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29904) Support “string1.notLike(string2)” built-in function in Table API - posted by "zhangjingcun (Jira)" <ji...@apache.org> on 2022/11/05 09:00:00 UTC, 0 replies.
- Re: [flink] branch master updated: [hotfix][docs] Set proper watermark and description for event-time temporal table join example - posted by Michael Stollery <mi...@gmail.com> on 2022/11/05 14:04:45 UTC, 1 replies.
- [jira] [Created] (FLINK-29905) Migrate flink-connector-dynamodb-parent to flink-connector-aws-parent - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2022/11/05 15:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29906) Address tabs/spaces in checkstyle/spotless - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2022/11/05 15:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29907) Externalize AWS connectors from Flink core - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2022/11/05 15:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29908) Externalize and configure E2E tests - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2022/11/05 15:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29909) Standardise connector package names - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2022/11/05 16:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29910) JdbcNumericBetweenParametersProvider(Variables within the method are extracted) - posted by "zhilinli (Jira)" <ji...@apache.org> on 2022/11/06 07:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29911) Improve performance of AgglomerativeClustering - posted by "Zhipeng Zhang (Jira)" <ji...@apache.org> on 2022/11/06 08:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29912) scan.partition. column can specify any type of field - posted by "waywtdcc (Jira)" <ji...@apache.org> on 2022/11/07 02:01:00 UTC, 0 replies.
- Re: [DISCUSS] Repeatable cleanup of checkpoint data - posted by Yang Wang <da...@gmail.com> on 2022/11/07 02:09:30 UTC, 3 replies.
- [jira] [Created] (FLINK-29913) Shared state would be discarded by mistake when maxConcurrentCheckpoint>1 - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2022/11/07 06:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29914) KafkaTableITCase.testKafkaSourceSink fails - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/11/07 08:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29915) -netty-tcnative-static not built on CI - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/11/07 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29916) Levels in Table Store may mistakenly ignore level 0 files when two files have the same sequence number - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/11/07 09:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29917) In standalone mode can't view flink dashboard page in default - posted by "Hang HOU (Jira)" <ji...@apache.org> on 2022/11/07 09:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29918) Generalized delegation token support - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/11/07 11:29:00 UTC, 0 replies.
- [DISCUSS] FLIP-272: Generalized delegation token support - posted by Gabor Somogyi <ga...@gmail.com> on 2022/11/07 13:09:09 UTC, 10 replies.
- [blog article] Howto migrate a real-life batch pipeline from the DataSet API to the DataStream API - posted by Etienne Chauchot <ec...@apache.org> on 2022/11/07 14:29:54 UTC, 8 replies.
- Questions about Flink Table Store - posted by Alexander Sorokoumov <as...@confluent.io.INVALID> on 2022/11/07 14:59:01 UTC, 2 replies.
- [jira] [Created] (FLINK-29919) Support operator leader election - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/11/07 16:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29920) Minor reformat Kafka connector documentation - posted by "Mingliang Liu (Jira)" <ji...@apache.org> on 2022/11/07 23:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29921) Can't deserialize Avro type if schema contains a field with name `schema`. - posted by "Bill G (Jira)" <ji...@apache.org> on 2022/11/07 23:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29922) Table store hive catalog support create external table - posted by "konwu (Jira)" <ji...@apache.org> on 2022/11/08 03:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29923) Hybrid Shuffle may face deadlock when running a task need to execute big size data - posted by "AlexHu (Jira)" <ji...@apache.org> on 2022/11/08 04:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29924) Update official document - posted by "Hang HOU (Jira)" <ji...@apache.org> on 2022/11/08 04:21:00 UTC, 0 replies.
- FeatHub - A feature store that uses Apache Flink for real-time feature ETL - posted by Dong Lin <li...@gmail.com> on 2022/11/08 05:42:29 UTC, 0 replies.
- [jira] [Created] (FLINK-29925) table ui of configure value is strange - posted by "jiadong.lu (Jira)" <ji...@apache.org> on 2022/11/08 07:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29926) File source continuous monitoring mode ignoring files during savepoint upgrade mode - posted by "Avinash (Jira)" <ji...@apache.org> on 2022/11/08 08:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29927) AkkaUtils#getAddress may cause memory leak - posted by "Gen Luo (Jira)" <ji...@apache.org> on 2022/11/08 09:21:00 UTC, 0 replies.
- [VOTE] Release flink-shaded 16.1, release candidate #1 - posted by Chesnay Schepler <ch...@apache.org> on 2022/11/08 10:47:35 UTC, 4 replies.
- [jira] [Created] (FLINK-29928) Allow sharing (RocksDB) memory between slots - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/11/08 10:55:03 UTC, 0 replies.
- [jira] [Created] (FLINK-29929) Correct conversions from ResolvedSchema to TableSchema - posted by "Yubin Li (Jira)" <ji...@apache.org> on 2022/11/08 11:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29930) ParquetFileStatsExtractorTest is unstable - posted by "Shammon (Jira)" <ji...@apache.org> on 2022/11/08 11:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29931) Pin Flink binary URL and cache binary - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/11/08 11:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29932) Upgrade Calcite version to 1.29.0 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/11/08 11:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29933) Bump Flink version to 1.16.0 - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/11/08 11:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29934) maven-assembly-plugin 2.4 make assemble plugin could find xml in flink clients module - posted by "jackylau (Jira)" <ji...@apache.org> on 2022/11/08 12:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29935) Setup CI runs against 1.16/1.17-SNAPSHOT - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/11/08 12:44:00 UTC, 0 replies.
- Re: support escaping `#` in flink job spec in Flink-operator - posted by Maximilian Michels <mx...@apache.org> on 2022/11/08 13:36:43 UTC, 0 replies.
- Re: [Discuss]- Donate Iceberg Flink Connector - posted by OpenInx <op...@gmail.com> on 2022/11/08 13:43:36 UTC, 0 replies.
- [jira] [Created] (FLINK-29936) Make operator more robust to namespaces access errors - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/11/08 15:19:00 UTC, 0 replies.
- [DISCUSS] Allow sharing (RocksDB) memory between slots - posted by Roman Khachatryan <ro...@apache.org> on 2022/11/08 15:21:23 UTC, 12 replies.
- [jira] [Created] (FLINK-29937) Enhanced DynamoDB Element Converter - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2022/11/08 21:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29938) Add open() Method to AsyncSink ElementConverter - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2022/11/08 22:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29939) Add metrics for Kubernetes Client Response 5xx count and rate - posted by "Zhou Jiang (Jira)" <ji...@apache.org> on 2022/11/09 00:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29940) ExecutionGraph logs job state change at ERROR level when job fails - posted by "Mingliang Liu (Jira)" <ji...@apache.org> on 2022/11/09 00:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29941) Support SQL Client connects to SQL Gateway - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2022/11/09 02:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29942) Improve average performance for TPC-DS - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2022/11/09 03:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29943) Bump Table Store 0.2 Flink version to 1.15.2 - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/11/09 03:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29944) Support accumaltor in source reader - posted by "hk__lrzy (Jira)" <ji...@apache.org> on 2022/11/09 03:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29945) Refactor ‘Executor’ interface to work with Gateway API - posted by "yuzelin (Jira)" <ji...@apache.org> on 2022/11/09 04:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29946) Introduce ‘ErrorDetail’ in SQL Gateway Rest Endpoint for error handling - posted by "yuzelin (Jira)" <ji...@apache.org> on 2022/11/09 04:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29947) Support configuring session API in Gateway RestEndpoint - posted by "yuzelin (Jira)" <ji...@apache.org> on 2022/11/09 04:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29948) Introduce ErrorResponse in Gateway RestEndpoint. - posted by "yuzelin (Jira)" <ji...@apache.org> on 2022/11/09 06:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29949) Implement 'RemoteExecutor' to perform the communication with Gateway - posted by "yuzelin (Jira)" <ji...@apache.org> on 2022/11/09 06:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29950) Add 'contentType' and 'FieldFormat' to 'ResultSet' for improvement - posted by "yuzelin (Jira)" <ji...@apache.org> on 2022/11/09 06:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29951) Kafka SQL connector supports setting end offset/timestamp - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2022/11/09 06:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29952) Using DROP TABLE XXX to drop a temporary table （or view） in sql-client can get an exception with incomplete explaination. - posted by "Hang HOU (Jira)" <ji...@apache.org> on 2022/11/09 07:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29953) Get rid of flink-connector-hive dependency in flink-table-store-hive - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/11/09 07:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29954) Improve DynamoDB Connector Sample Code - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2022/11/09 07:57:00 UTC, 0 replies.
- [RESULT][VOTE] Release Apache Flink Elasticsearch connector 3.0.0, rc2 - posted by Chesnay Schepler <ch...@apache.org> on 2022/11/09 09:13:23 UTC, 0 replies.
- [jira] [Created] (FLINK-29955) Upgrade hogo version to v0.104.0 - posted by "Jeff Yang (Jira)" <ji...@apache.org> on 2022/11/09 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29956) Kafka-related test infrastructure code is scattered over multiple classes/environments - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/11/09 10:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29957) Rework connector docs integration - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/11/09 13:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29958) Add new connector_artifact shortcode - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/11/09 13:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29959) Use optimistic locking when patching resource status - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/11/09 15:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29960) Update README to Reflect AWS Connectors Single Repo - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2022/11/09 15:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29961) Make referencing custom image clearer for Docker - posted by "Mingliang Liu (Jira)" <ji...@apache.org> on 2022/11/09 17:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29962) Exclude Jamon 2.3.1 - posted by "John Roesler (Jira)" <ji...@apache.org> on 2022/11/09 18:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29963) Flink Table Store supports pluggable filesystem - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/11/09 18:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29964) Support Spark/Hive with OSS - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/11/09 18:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29965) Support Spark/Hive with S3 - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/11/09 19:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29966) Replace and redesign the Python api documentation base - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/11/10 02:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29967) Optimize determinism requirements from sink node with considering that SinkUpsertMaterializer already supports upsertKey - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2022/11/10 02:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29968) Update streaming query document for Table Store to include full compaction changelog producer - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/11/10 02:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29969) Show the root cause when exceeded checkpoint tolerable failure threshold - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2022/11/10 02:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29970) Prometheus cannot collect flink metrics - posted by "钟洋洋 (Jira)" <ji...@apache.org> on 2022/11/10 03:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29971) Hbase sink will lose data at extreme case - posted by "wenchao.wu (Jira)" <ji...@apache.org> on 2022/11/10 08:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29972) Pin Flink docs to Elasticsearch Connector 3.0.0 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/11/10 08:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29973) connector_artifact should append Flink minor version - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/11/10 08:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29974) Session jobs in FINISHED/FAILED state cannot be upgraded - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/11/10 08:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29975) Let hybrid full spilling strategy supports partition reuse - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2022/11/10 08:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29976) The cron connectors test run out of given timeout in Azure - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2022/11/10 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29977) Kafka connector not compatible with kafka-clients 3.3x - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/11/10 09:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29978) FlinkKafkaInternalProducer not compatible with kafka-client-3.3.x - posted by "Owen Lee (Jira)" <ji...@apache.org> on 2022/11/10 09:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29979) connector_artifact should only work for stable releases - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/11/10 11:05:00 UTC, 0 replies.
- [ACCOUNCE] Apache Flink Elasticsearch Connector 3.0.0 released - posted by Chesnay Schepler <ch...@apache.org> on 2022/11/10 11:50:51 UTC, 3 replies.
- [GitHub] [flink-connector-shared-utils] zentol merged pull request #1: [FLINK-29472] Add first version of release scripts - posted by GitBox <gi...@apache.org> on 2022/11/10 12:22:56 UTC, 0 replies.
- [jira] [Created] (FLINK-29980) Wrap the HiveSource's bulkFormat to handle the partition keys - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/11/10 12:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29981) Improve WatermarkAssignerChangelogNormalizeTransposeRule - posted by "godfrey he (Jira)" <ji...@apache.org> on 2022/11/10 12:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29982) Move cassandra connector to dedicated repo - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2022/11/10 15:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29983) Table Store with Hive3 profile lacks hive-standalone-metastore dependency - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/11/10 16:06:00 UTC, 0 replies.
- [VOTE] Release 1.15.3, release candidate #1 - posted by Fabian Paul <fp...@apache.org> on 2022/11/10 16:18:42 UTC, 11 replies.
- [jira] [Created] (FLINK-29984) Flink Histogram not emitting min and max when using Prometheus Reporter - posted by "Lim Qing Wei (Jira)" <ji...@apache.org> on 2022/11/10 17:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29985) SlotTable not close on TM termination - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/11/10 18:01:00 UTC, 0 replies.
- [DISCUSS] FLIP-268: Rack Awareness for Kafka Sources - posted by Jeremy DeGroot <je...@gmail.com> on 2022/11/10 21:35:34 UTC, 5 replies.
- [jira] [Created] (FLINK-29986) How to persist flink catalogs configuration? - posted by "Alvin Ge (Jira)" <ji...@apache.org> on 2022/11/11 01:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29987) PartialUpdateITCase.testForeignKeyJo is unstable - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/11/11 03:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29988) Improve upper case fields for hive metastore - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/11/11 03:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29989) Enable FlameGraph for arbitrary thread on TaskManager - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2022/11/11 06:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29990) Unparsed SQL for SqlTableLike cannot be parsed correctly - posted by "Shuo Cheng (Jira)" <ji...@apache.org> on 2022/11/11 07:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29991) KinesisFirehoseSinkTest#firehoseSinkFailsWhenUnableToConnectToRemoteService failed - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/11/11 09:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29992) Join execution plan parsing error - posted by "HunterXHunter (Jira)" <ji...@apache.org> on 2022/11/11 09:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29993) Provide more convenient way to programmatically configure reporters - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/11/11 09:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29994) Update official document about Lookup Join. - posted by "Hang HOU (Jira)" <ji...@apache.org> on 2022/11/11 10:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29995) Improve the usability of job analysis for backpressure, expired checkpoints and exceptions - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2022/11/11 11:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29996) Link to the task manager's thread dump page in the backpressure tab - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2022/11/11 11:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29997) Link to the taskmanager page in the expired sub-task of checkpoint tab - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2022/11/11 11:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29998) Make the backpressure tab could be sort by the busy percent - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2022/11/11 11:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29999) Improve documentation on how a user should migrate from FlinkKafkaConsumer to KafkaSource - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/11/11 12:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30000) Introduce FileSystemFactory to create FileSystem from custom configuration - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/11/11 13:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30001) sql-client.sh start failed - posted by "xiaohang.li (Jira)" <ji...@apache.org> on 2022/11/12 03:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30002) Change the alignmentTimeout to alignedCheckpointTimeout - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2022/11/12 04:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30003) The ConcurrentModificationException occurred at ContextClassLoadingSettingTest - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2022/11/12 11:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30004) Cannot resume deployment after suspend with savepoint due to leftover confgmaps - posted by "Thomas Weise (Jira)" <ji...@apache.org> on 2022/11/12 17:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30005) Translate "Schema Migration Limitations for State Schema Evolution" into Chinese - posted by "hao wang (Jira)" <ji...@apache.org> on 2022/11/13 07:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30006) Cannot remove columns that are incorrectly considered constants from an Aggregate In Streaming - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2022/11/13 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30007) Document how users can request a Jira account / file a bug - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/11/13 08:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30008) Add Flink 1.16.0 Support - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2022/11/13 10:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30009) OperatorCoordinator.start()'s JavaDoc mismatches its behavior - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2022/11/14 03:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30010) flink-quickstart-test failed due to could not resolve dependencies - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2022/11/14 03:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30011) HiveCatalogGenericMetadataTest azure CI failed due to catalog does not exist - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2022/11/14 04:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30012) A typo in official Table Store document. - posted by "Hang HOU (Jira)" <ji...@apache.org> on 2022/11/14 07:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30013) Add data type compatibility check in SchemaChange.updateColumnType - posted by "Shammon (Jira)" <ji...@apache.org> on 2022/11/14 07:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30014) Fix the NPE from aggregate util - posted by "Jiang Xin (Jira)" <ji...@apache.org> on 2022/11/14 07:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30015) Benchmarks are failing - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/11/14 07:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30016) Update Flink 1.16 release notes about updated oshi-core - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/11/14 08:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30017) Remove aggregate-scaladoc profile - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/11/14 08:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30018) NPE error in generated StreamExecCalc - posted by "jackwangcs (Jira)" <ji...@apache.org> on 2022/11/14 08:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30019) Remove the unused HiveTableFileInputFormat in hive connector - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/11/14 09:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30020) Use separate Prometheus CollectorRegistries - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/11/14 09:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30021) Table store Hive catalog getTableLocation by hms client - posted by "konwu (Jira)" <ji...@apache.org> on 2022/11/14 09:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30022) ChangelogStorageMetricsTest#testTotalAttemptsPerUpload failed - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2022/11/14 11:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30023) ChangelogStorageMetricsTest#testTotalAttemptsPerUpload failed - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2022/11/14 11:57:00 UTC, 0 replies.
- Understanding the Internals of Watermark Generation | Actual Implementation - posted by Tawfek Yasser Tawfek <TY...@nu.edu.eg> on 2022/11/14 12:00:57 UTC, 0 replies.
- [jira] [Created] (FLINK-30024) Secure e2e tests are using a super old kerberos docker image - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/11/14 13:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30025) table.execute().print() can only use the default max column width - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/11/14 19:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30026) Support database table include option in debezium-json - posted by "Zhiwen Sun (Jira)" <ji...@apache.org> on 2022/11/15 07:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30027) Fields min and max in BinaryTableStats support lazy deserialization - posted by "Shammon (Jira)" <ji...@apache.org> on 2022/11/15 07:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30028) A little fix with document about period in log.changelog-mode description. - posted by "Hang HOU (Jira)" <ji...@apache.org> on 2022/11/15 08:46:00 UTC, 0 replies.
- [SUMMARY] Flink 1.17 Release Sync 11/15/2022 - posted by Leonard Xu <xb...@gmail.com> on 2022/11/15 09:50:24 UTC, 0 replies.
- [jira] [Created] (FLINK-30029) Notice/ShadeParser parse version/classifier separately - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/11/15 09:53:00 UTC, 0 replies.
- Env Vars in the Flink Web UI - posted by Konstantin Knauf <kn...@apache.org> on 2022/11/15 10:26:14 UTC, 8 replies.
- [jira] [Created] (FLINK-30030) Unexpected behavior for overwrite in Hive dialect - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/11/15 13:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30031) flink table store run abnormally when shade flink - posted by "zhenzhenhua (Jira)" <ji...@apache.org> on 2022/11/15 15:44:00 UTC, 0 replies.
- [Vote] Remove FlinkKafkaConsumer and graduate related Source APIs - posted by Jing Ge <ji...@ververica.com.INVALID> on 2022/11/15 16:36:57 UTC, 2 replies.
- [jira] [Created] (FLINK-30032) IOException during MAX_WATERMARK emission causes message missing - posted by "Haoze Wu (Jira)" <ji...@apache.org> on 2022/11/15 18:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30033) Add primary key data type validation - posted by "Shammon (Jira)" <ji...@apache.org> on 2022/11/16 02:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30034) class not found exception when using Hive 3.1.3 connector - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/11/16 03:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30035) ./bin/sql-client.sh won't import external jar into the session - posted by "Steven Zhen Wu (Jira)" <ji...@apache.org> on 2022/11/16 03:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30036) Force delete pod when k8s node is not ready - posted by "Peng Yuan (Jira)" <ji...@apache.org> on 2022/11/16 04:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30037) Improve the efficiency of Flink ML Python CI - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2022/11/16 06:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30038) HiveE2E test is not stable - posted by "Shammon (Jira)" <ji...@apache.org> on 2022/11/16 06:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30039) Insert overwrite show excetion that query and insert schema do not match - posted by "Hang HOU (Jira)" <ji...@apache.org> on 2022/11/16 09:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30040) Add more PyFlink API examples - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/11/16 10:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30041) Setup conjars https mirror - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/11/16 10:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30042) Create/Use new CI image with Maven 3.8.6 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/11/16 10:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30043) Some example sqls in flink table store rescale-bucket doucument are incorrect. - posted by "Hang HOU (Jira)" <ji...@apache.org> on 2022/11/16 11:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30044) Deduplicate plugin parser loops - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/11/16 11:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30045) FromClasspathEntryClassInformationProvider too eager to verify MainClass - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2022/11/16 11:25:00 UTC, 0 replies.
- Argo CD health check for FlinkDeployment - posted by Xingcan Cui <xi...@gmail.com> on 2022/11/16 15:19:08 UTC, 2 replies.
- [jira] [Created] (FLINK-30046) Cannot use digest in Helm chart to reference image - posted by "Tobias Hofer (Jira)" <ji...@apache.org> on 2022/11/16 15:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30047) getLastSavepointStatus should return null when there is never savepoint completed or pending - posted by "Clara Xiong (Jira)" <ji...@apache.org> on 2022/11/16 20:40:00 UTC, 0 replies.
- Stack Overflow Question re compressing broadcast state - posted by Ken Krugler <kk...@transpac.com> on 2022/11/16 22:27:55 UTC, 5 replies.
- [jira] [Created] (FLINK-30048) MapState.remove(UK key) is better to return the old value. - posted by "xljtswf (Jira)" <ji...@apache.org> on 2022/11/17 02:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30049) CsvBulkWriter is unsupported for S3 FileSystem - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/11/17 02:50:00 UTC, 0 replies.
- Can we make flink operator using golang? - posted by Mark Lee <li...@126.com> on 2022/11/17 04:47:24 UTC, 1 replies.
- [VOTE] FLIP-272: Generalized delegation token support - posted by Gabor Somogyi <ga...@gmail.com> on 2022/11/17 08:05:01 UTC, 4 replies.
- Re: [DISCUSS] Updating Flink HBase Connectors - posted by Martijn Visser <ma...@apache.org> on 2022/11/17 08:29:23 UTC, 3 replies.
- [jira] [Created] (FLINK-30050) [Umbrella] Externalize Flink connectors - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/11/17 08:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30051) Create repository for Kafka connector - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/11/17 08:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30052) Move existing Kafka connector code from Flink repo to dedicated Kafka repo - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/11/17 08:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30054) Move existing Pulsar connector code from Flink repo to dedicated Pulsar repo - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/11/17 08:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30053) Create and initialize repository for Pulsar connector - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/11/17 08:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30056) Make polling for metadata no more than specified timeout by using new Consumer#poll(Duration) - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/11/17 08:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30055) Move existing Cassandra connector code from Flink repo to dedicated Cassandra repo - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/11/17 08:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30057) Create and initialize repository for Google Cloud PubSub connector - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/11/17 08:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30058) Move existing Google PubSub connector code from Flink repo to dedicated Google PubSub repo - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/11/17 08:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30059) Create and initialize repository for JDBC connector - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/11/17 08:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30061) Create and initialize repository for HBase connector - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/11/17 08:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30060) Move existing JDBC connector code from Flink repo to dedicated JDBC repo - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/11/17 08:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30063) Create and initialize repository for Hive connector - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/11/17 08:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30062) Move existing HBase connector code from Flink repo to dedicated HBase repo - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/11/17 08:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30064) Move existing Hive connector code from Flink repo to dedicated Hive repo - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/11/17 08:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30065) Move Firehose connector code from Flink repo to dedicated AWS repo - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/11/17 08:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30066) Move Kinesis connector code from Flink repo to dedicated AWS repo - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/11/17 08:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30067) DelegatingConfiguration#set should return itself - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/11/17 08:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30068) Allow users to configure what to do with errors while committing transactions during recovery in KafkaSink - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2022/11/17 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30069) Expected prune behavior for matches with same priority - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2022/11/17 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30070) Create savepoints without side effects - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2022/11/17 09:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30071) Throw exception at compile time when sequence field does not exist - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/11/17 10:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30072) Cannot assign instance of SerializedLambda to field KeyGroupStreamPartitioner.keySelector - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2022/11/17 10:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30073) Managed memory can be wasted if rocksdb memory is fixed-per-slot - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/11/17 10:31:00 UTC, 0 replies.
- "Introduction to Apache Flink" presentation - posted by Johannes Moser <jo...@moser.wtf> on 2022/11/17 10:56:52 UTC, 0 replies.
- [jira] [Created] (FLINK-30074) ES e2e tests are never run - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/11/17 12:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30075) Failed to load data to the cache after the hive lookup join task is restarted - posted by "zhanglu153 (Jira)" <ji...@apache.org> on 2022/11/18 02:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30076) hive join mysql error - posted by "zck (Jira)" <ji...@apache.org> on 2022/11/18 03:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30077) k8s jobmanager pod repeated restart - posted by "hanjie (Jira)" <ji...@apache.org> on 2022/11/18 03:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30078) Temporal join should finish when the left table is bounded and finished - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2022/11/18 03:28:00 UTC, 0 replies.
- [DISCUSS] FLIP-273: Improve Catalog API to Support ALTER TABLE syntax - posted by Shengkai Fang <fs...@gmail.com> on 2022/11/18 03:55:01 UTC, 4 replies.
- [jira] [Created] (FLINK-30079) Stop using deprecated TM options in doc - posted by "Mingliang Liu (Jira)" <ji...@apache.org> on 2022/11/18 06:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30080) Introduce public programming api and dependency jar for table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/11/18 06:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30081) Local executor can not accept different jvm-overhead.min/max values - posted by "Mingliang Liu (Jira)" <ji...@apache.org> on 2022/11/18 06:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30082) Enable write-buffer-spillable by default only for object storage - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/11/18 06:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30083) Bump maven-shade-plugin to 3.4.0 - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2022/11/18 08:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30084) Remove unused ResourceActions.notifyAllocationFailure - posted by "Weihua Hu (Jira)" <ji...@apache.org> on 2022/11/18 08:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30085) JVM hanging after executing YARNSessionCapacitySchedulerITCase.testNonexistingQueueWARNmessage - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/11/18 08:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30086) Include classifier in DependencyTree tree - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/11/18 10:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30087) sql-gateway-api is bundled twice in the distribution - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/11/18 12:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30088) Excessive state updates for TtlMapState and TtlListState - posted by "Roman Boyko (Jira)" <ji...@apache.org> on 2022/11/18 13:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30089) Remove dependency promotion from kinesis connector - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/11/18 13:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30090) Support timespan for TimerGauges - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/11/18 15:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30091) mvn package verify fails with "Error creating shaded jar: duplicate entry" - posted by "Alex Sorokoumov (Jira)" <ji...@apache.org> on 2022/11/18 16:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30092) Improve Table API experience for Flink DOUBLE type - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2022/11/18 16:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30093) [Flink SQL][Protobuf] CompileException when querying Kafka topic using google.protobuf.Timestamp - posted by "James Mcguire (Jira)" <ji...@apache.org> on 2022/11/18 18:37:00 UTC, 0 replies.
- Could not connect Amazon S3 file system with different creds at runtime. - posted by "kursat kursatkurt.com" <ku...@kursatkurt.com> on 2022/11/18 19:13:09 UTC, 2 replies.
- [jira] [Created] (FLINK-30094) Flink Table Sotre's Lookup Join document may needs left table DDL example. - posted by "Hang HOU (Jira)" <ji...@apache.org> on 2022/11/19 05:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30095) Flink's JobCluster ResourceManager should throw an exception when the failure number of starting worker reaches the maximum failure rate - posted by "zhanglu153 (Jira)" <ji...@apache.org> on 2022/11/19 09:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30096) Rename DynamoDB config destinationTableName to tableName - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2022/11/19 12:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30097) CachedDataStream java example in the document is not correct - posted by "Prabhu Joseph (Jira)" <ji...@apache.org> on 2022/11/19 13:45:00 UTC, 0 replies.
- [DISCUSS] OLM Bundles for Flink Kubernetes Operator - posted by Hao t Chang <ht...@us.ibm.com> on 2022/11/19 19:39:45 UTC, 10 replies.
- [jira] [Created] (FLINK-30098) Update DynamoDb Sink unit tests to JUnit 5 - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2022/11/19 23:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30099) Add tests to cover model data APIs for all existing algorithms - posted by "Dong Lin (Jira)" <ji...@apache.org> on 2022/11/20 02:44:00 UTC, 0 replies.
- 答复: [DISCUSS] OLM Bundles for Flink Kubernetes Operator - posted by Mark Lee <li...@126.com> on 2022/11/20 10:48:28 UTC, 1 replies.
- [jira] [Created] (FLINK-30100) Remove the unused CheckpointFailureReason - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2022/11/20 13:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30101) YARN client should - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2022/11/21 03:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30102) Unstable test EventTimeWindowCheckpointingITCase.testPreAggregatedSlidingTimeWindow failed runs on azure - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2022/11/21 03:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30103) Test InputFormatCacheLoaderTest.checkCounter failed due to unexpected value on azure - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2022/11/21 03:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30104) Snapshot deployment failed due to Could not transfer artifact org.apache.flink:flink-runtime-web:jar:1.15-20221119.010836-325 from/to apache.snapshots - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2022/11/21 03:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30105) SubtaskExecutionAttemptAccumulatorsInfoTest failed with JVM exit code 239 - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2022/11/21 03:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30106) Build python wheels on macs failed due to install for crcmod error - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2022/11/21 04:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30107) ChangelogRecoveryITCase#testMaterialization - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2022/11/21 04:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30108) flink-core module tests exited with code 143 - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2022/11/21 04:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30109) Checked exceptions are sneakingly transformed into unchecked exceptions in the Pulsar - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/11/21 05:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30110) Enable from-timestamp log scan when timestamp-millis is configured - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/11/21 07:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30111) CacheRead fails with Intermediate data set with ID not found - posted by "Prabhu Joseph (Jira)" <ji...@apache.org> on 2022/11/21 08:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30112) Improve docs re state compression - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2022/11/21 08:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30113) Compression for operator state - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2022/11/21 09:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30114) Introduce PyFlink example for table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/11/21 11:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30115) Include log4j-layout-template-json jar in the default operator image - posted by "Alexis Sarda-Espinosa (Jira)" <ji...@apache.org> on 2022/11/21 12:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30116) Don't Show Env Vars in Web UI - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2022/11/21 14:03:00 UTC, 0 replies.
- [ANNOUNCE] New Apache Flink Committer - Matyas Orhidi - posted by Márton Balassi <mb...@apache.org> on 2022/11/21 14:17:54 UTC, 33 replies.
- [jira] [Created] (FLINK-30117) Evaluate error whitelist entries added in FLINK-29475 - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/11/21 16:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30118) Move DDB connector Integration Tests/ITCase to E2E test - posted by "Daren Wong (Jira)" <ji...@apache.org> on 2022/11/21 16:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30119) (Flink Kubernetes Operator should store last savepoint in the SavepointInfo.lastSavepoint field whether it is completed or pending - posted by "Clara Xiong (Jira)" <ji...@apache.org> on 2022/11/21 17:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30120) Flink Statefun Task Failure causes restart of all tasks - posted by "Stephan Weinwurm (Jira)" <ji...@apache.org> on 2022/11/21 23:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30121) Support Stored procedures - posted by "melin (Jira)" <ji...@apache.org> on 2022/11/22 01:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30122) Flink ML KMeans getting model data throws TypeError - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2022/11/22 01:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30123) Optimize ApplicationDeployer API design - posted by "melin (Jira)" <ji...@apache.org> on 2022/11/22 01:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30124) GenericType is not supported in PyFlink currently - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2022/11/22 01:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30125) Projection pushdown is not work for partial update - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/11/22 02:56:00 UTC, 0 replies.
- FRocksDB Some Question - posted by Zheng Yu Chen <ja...@gmail.com> on 2022/11/22 03:39:50 UTC, 3 replies.
- [jira] [Created] (FLINK-30126) Delay registration of the catalog, register the catalog as needed - posted by "melin (Jira)" <ji...@apache.org> on 2022/11/22 03:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30127) Correct the packaging of HadoopRecoverableWriter and related issues - posted by "ramkrishna.s.vasudevan (Jira)" <ji...@apache.org> on 2022/11/22 04:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30128) Introduce Azure Data Lake Gen2 APIs in the Hadoop Recoverable path - posted by "ramkrishna.s.vasudevan (Jira)" <ji...@apache.org> on 2022/11/22 04:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30129) Push projection through ChangelogNormalize - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2022/11/22 06:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30130) Table.select lose watermark - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2022/11/22 07:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30131) flink iterate will suspend when record is a bit large - posted by "Lu (Jira)" <ji...@apache.org> on 2022/11/22 07:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30132) Test LocalRecoveryITCase#testRecoverLocallyFromProcessCrashWithWorkingDirectory failed on azure due to File not exists - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2022/11/22 07:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30133) HadoopModuleFactory creates error if the security module cannot be loaded - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/11/22 07:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30134) Annotate all the public classes for the delegation token framework - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/11/22 07:37:00 UTC, 1 replies.
- [jira] [Created] (FLINK-30135) RMQSourceITCase failed on azure with exit code 143 - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2022/11/22 07:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30136) ElasticsearchSinkITCase.testElasticsearchSink failed on azure due to ES service unavailable - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2022/11/22 07:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30137) LocalRecoveryITCase.testRecoverLocallyFromProcessCrashWithWorkingDirectory failed due to NoSuchFileException - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/11/22 07:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30138) BlobServerCleanupTest utilizes failsWithin with a quite low timeout which might result in test instabilities - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/11/22 08:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30139) CodeGenLoader fails when temporary directory is a symlink - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/11/22 08:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30140) flink-runtime intergration tests fail due to Process Exit Code: 239 - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/11/22 08:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30141) MinioTestContainerTest failed due to IllegalStateException in container startup - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/11/22 08:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30142) Flink ML operators lose table watermark after transform() - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2022/11/22 09:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30143) Table Store fails when temporary directory is a symlink - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/11/22 09:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30144) Guarantee Flink ML operators function correctly with object-reuse enabled - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2022/11/22 09:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30145) Evaluate operator error log entry: JmDeploymentStatus.ERROR.Count - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/11/22 10:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30147) Evaluate operator error log entry: Failed to submit a listener notification task - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/11/22 10:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30146) Evaluate operator error log entry: Exception while listing jobs - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/11/22 10:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30148) Evaluate operator error log entry: Failed to submit job to session cluster - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/11/22 10:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30150) Evaluate operator error log entry: REST service in session cluster is bad now - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/11/22 10:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30151) Evaluate operator error log entry: AuditUtils - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/11/22 10:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30149) Evaluate operator error log entry: Error during event processing - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/11/22 10:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30152) Failure in setting up the CI agent - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/11/22 10:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30153) YARNSessionCapacitySchedulerITCase fails with NoClassDefFoundError - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/11/22 10:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30154) flinkConfiguration in SessionJob is not accepted - posted by "Emmanuel Leroy (Jira)" <ji...@apache.org> on 2022/11/22 13:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30155) Pretty print MutatedConfigurationException - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2022/11/22 16:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30156) [FLIP-242] Blogpost about the customisable RateLimitingStrategy in the AsyncSinkBase - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2022/11/22 17:24:00 UTC, 0 replies.
- Re: Table API thrift support - posted by Chen Qin <qi...@gmail.com> on 2022/11/22 17:43:51 UTC, 5 replies.
- [jira] [Created] (FLINK-30157) Trigger Events Before JM Recovery and Unhealthy Job Restarts - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/11/22 22:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30158) [Flink SQL][Protobuf] NullPointerException when querying Kafka topic using repeated or map attributes - posted by "James Mcguire (Jira)" <ji...@apache.org> on 2022/11/22 23:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30159) Add Transformer for ANOVATest - posted by "Jiang Xin (Jira)" <ji...@apache.org> on 2022/11/23 02:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30160) Add Transformer for FValueTest - posted by "Jiang Xin (Jira)" <ji...@apache.org> on 2022/11/23 02:48:00 UTC, 0 replies.
- [ANNOUNCE] New Apache Flink PMC Members - Godfrey He, Xingbo Huang - posted by Dian Fu <di...@gmail.com> on 2022/11/23 04:18:01 UTC, 27 replies.
- [jira] [Created] (FLINK-30161) Add TableSchema validation before it is commited - posted by "Shammon (Jira)" <ji...@apache.org> on 2022/11/23 06:27:00 UTC, 0 replies.
- [DISCUSS] Releasing Amazon DynamoDB Connector v2.0.0 - posted by Danny Cranmer <da...@apache.org> on 2022/11/23 08:06:34 UTC, 2 replies.
- [jira] [Created] (FLINK-30162) Remove unused arguments/methods/classes - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/11/23 08:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30163) StreamPandasUDFITTests.test_basic_functionality failed - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/11/23 09:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30164) Expose BucketComputer from SupportsWrite - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/11/23 09:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30165) [JUnit5 Migration] Migrate unaligned checkpoint related tests under flink-runtime module to junit5 - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2022/11/23 09:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30166) Refactor tests that use the deprecated StreamingFileSink instead of FileSink - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/11/23 10:53:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-272: Generalized delegation token support - posted by Gabor Somogyi <ga...@gmail.com> on 2022/11/23 10:59:42 UTC, 0 replies.
- [jira] [Created] (FLINK-30167) Upgrade japicmp to 1.17.1 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/11/23 11:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30168) PyFlink Deserialization Error with Object Array - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2022/11/23 11:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30169) Adds version switcher in PyFlink API doc - posted by "Xingbo Huang (Jira)" <ji...@apache.org> on 2022/11/23 12:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30170) Update Parquet version to 1.12.3 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/11/23 13:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30171) Bump socket.io-parser from 4.0.4 to 4.0.5 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/11/23 13:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30172) Bump loader-utils from 2.0.2 to 2.0.4 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/11/23 13:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30173) Upgrade @angular-devkit/build-angular from 14.2.6 to 15.0.0 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/11/23 13:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30174) Bump engine.io from 6.2.0 to 6.2.1 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/11/23 13:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30175) Bump snakeyaml from 1.31 to 1.32 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/11/23 13:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30176) assert_available_slots is passing even if curl is timing out - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/11/23 13:53:00 UTC, 0 replies.
- [VOTE] FLIP-271: Autoscaling - posted by Maximilian Michels <mx...@apache.org> on 2022/11/23 16:25:05 UTC, 14 replies.
- [jira] [Created] (FLINK-30177) Update pgjdbc to fix CVE-2022-41946 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/11/23 22:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30178) Kubernetes test failed with "crictl: command not found" - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/11/23 22:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30179) Stop stringifying exception for logging - posted by "Mingliang Liu (Jira)" <ji...@apache.org> on 2022/11/24 01:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30180) Remove the description of Filesystem supporting for the lookup in the Supported Connectors section - posted by "Xianxun Ye (Jira)" <ji...@apache.org> on 2022/11/24 02:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30181) MultiInputCheckpointingTimeBenchmark.checkpointMultiInput benchmark failed - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2022/11/24 02:17:00 UTC, 0 replies.
- Fwd: Physical memory and Auto Memory settings in TM - posted by ramkrishna vasudevan <ra...@gmail.com> on 2022/11/24 02:26:43 UTC, 0 replies.
- [jira] [Created] (FLINK-30182) Create template for release announcement - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/11/24 03:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30183) We should add a proper error message in case the deprecated reflection-based instantiation of a reporter is triggered - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/11/24 05:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30184) Save TM/JM thread stack periodically - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2022/11/24 06:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30185) Provide the flame graph to the subtask level - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2022/11/24 06:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30186) Bump Flink version to 1.15.3 - posted by "Jeff Yang (Jira)" <ji...@apache.org> on 2022/11/24 07:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30187) Multi session job test is silently not checking the operator log for errors - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/11/24 08:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30188) Partition finished state in ConsumedPartitionGroup is not updated correctly in dynamic graph - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2022/11/24 08:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30189) HsSubpartitionFileReader may load data that has been consumed from memory - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2022/11/24 09:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30190) Update Cython from 0.29.24 to 0.29.32 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/11/24 09:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30192) Update python-dateutil from 2.8.0 to 2.8.2 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/11/24 09:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30191) Update py4j from 0.10.9.3 to 0.10.9.7 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/11/24 09:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30193) could flink has dynamic rebalance according to the load of downstream operators - posted by "Lu (Jira)" <ji...@apache.org> on 2022/11/24 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30194) Rename DelegationTokenProvider to HadoopDelegationTokenProvider - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/11/24 12:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30195) LeaderElectionService should avoid potential deadlock with leaderContender - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2022/11/24 14:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30196) Replace usage of deprecated Mockito's methods with advised by Mockito - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/11/24 14:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30197) Update slf4j from 1.7.32 to 1.7.36 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/11/24 14:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30198) Support AdaptiveBatchScheduler to set per-task size for reducer task - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/11/24 15:16:00 UTC, 0 replies.
- [RESULT][VOTE] Release 1.15.3, release candidate #1 - posted by Fabian Paul <fp...@apache.org> on 2022/11/24 15:42:44 UTC, 0 replies.
- [jira] [Created] (FLINK-30199) Add a script to run Kubernetes Operator e2e tests manually - posted by "Peter Vary (Jira)" <ji...@apache.org> on 2022/11/24 18:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30200) TimestampOffsetsInitializer allows configurable OffsetResetStrategy - posted by "Mason Chen (Jira)" <ji...@apache.org> on 2022/11/24 20:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30201) Function "unnest" can't process nesting JSON properly - posted by "zhangyue (Jira)" <ji...@apache.org> on 2022/11/25 02:07:00 UTC, 0 replies.
- [DISCUSS] FLIP-275: Support Remote SQL Client Based on SQL Gateway - posted by yu zelin <yu...@gmail.com> on 2022/11/25 03:48:46 UTC, 2 replies.
- [jira] [Created] (FLINK-30202) DataGeneratorSourceITCase.testGatedRateLimiter failed - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/11/25 04:45:00 UTC, 0 replies.
- subscribe to dev mailing list - posted by 王汛洪 <wa...@hworld.com> on 2022/11/25 07:44:10 UTC, 1 replies.
- [jira] [Created] (FLINK-30203) BatchPandasConversionTests.test_empty_to_pandas failed - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/11/25 08:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30204) Table Store support separated compact jobs - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/11/25 08:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30205) Modify compact interface for TableWrite and FileStoreWrite to support normal compaction in Table Store - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/11/25 08:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30206) Allow FileStoreScan to read incremental changes from OVERWRITE snapshot in Table Store - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/11/25 08:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30207) Move split initialization and discovery logic fully into SnapshotEnumerator in Table Store - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/11/25 08:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30208) avoid unconditional state update in CountTrigger#onElement - posted by "xljtswf (Jira)" <ji...@apache.org> on 2022/11/25 08:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30209) Introduce CompactFileStoreSource for compact jobs of Table Store - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/11/25 08:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30210) Refactor StoreCompactOperator to accept records containing partitions and buckets in Table Store - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/11/25 08:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30211) Introduce CompactStoreSink for compact jobs in Table Store - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/11/25 08:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30212) Introduce a TableStoreCompactJob class for users to submit compact jobs in Table Store - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/11/25 08:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30213) The edge is wrong when the vertex parallelism is changed - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2022/11/25 09:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30214) The resource is not enough - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2022/11/25 09:24:00 UTC, 0 replies.
- [VOTE] Release flink-connector-cassandra, release candidate #1 - posted by Chesnay Schepler <ch...@apache.org> on 2022/11/25 09:31:16 UTC, 7 replies.
- [jira] [Created] (FLINK-30215) Deprecated Cassandra explicit Scala support - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/11/25 13:12:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.15.3 released - posted by Fabian Paul <fp...@apache.org> on 2022/11/25 13:22:08 UTC, 0 replies.
- [jira] [Created] (FLINK-30216) Address tabs/spaces in checkstyle/spotless - posted by "Daren Wong (Jira)" <ji...@apache.org> on 2022/11/25 13:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30217) Use ListState#update() to replace clear + add mode. - posted by "xljtswf (Jira)" <ji...@apache.org> on 2022/11/25 14:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30218) [Kafka Connector] java.lang.OutOfMemoryError: Metaspace - posted by "Lukas Mahl (Jira)" <ji...@apache.org> on 2022/11/25 14:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30219) Fetch results api in sql gateway return error result. - posted by "Aiden Gong (Jira)" <ji...@apache.org> on 2022/11/26 02:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30220) Hide user credentials in Flink SQL JDBC connector - posted by "Jun Qin (Jira)" <ji...@apache.org> on 2022/11/26 08:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30221) Fix the bug of sum(try_cast(string as bigint)) return null when partial elements can't convert to bigint - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/11/26 09:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30222) Suspended a job in last-state mode bug - posted by "tanjialiang (Jira)" <ji...@apache.org> on 2022/11/27 08:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30223) Refactor Lock to provide Lock.Factory - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/11/28 02:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30224) NullPointerException in FlinkKinesisConsumer's close() method during too early stop-with-savepoint - posted by "Astamur Kirillin (Jira)" <ji...@apache.org> on 2022/11/28 09:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30225) Convergence test failed once after reference version upgrade to 1.15.3 - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/11/28 09:35:00 UTC, 0 replies.
- How to make flink operator as a cluster operator? - posted by Mark Lee <li...@126.com> on 2022/11/28 10:02:44 UTC, 0 replies.
- [jira] [Created] (FLINK-30226) Offer a Identity(De)SerializationSchema - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2022/11/28 10:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30227) Add LeafEmptyFunction for predicate without fields - posted by "Shammon (Jira)" <ji...@apache.org> on 2022/11/28 10:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30228) RateLimitedSourceReaderITCase.testRateLimitingParallelExecution failed - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/11/28 13:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30229) SQL IT case for DynamoDB Sink - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2022/11/28 14:11:00 UTC, 0 replies.
- [NOTICE] Connector release guide - posted by Chesnay Schepler <ch...@apache.org> on 2022/11/28 16:07:12 UTC, 1 replies.
- [VOTE] Release flink-connector-dynamodb v3.0.0, release candidate #0 - posted by Danny Cranmer <da...@apache.org> on 2022/11/28 16:42:42 UTC, 4 replies.
- [jira] [Created] (FLINK-30230) Drop Support for Flink 1.15 - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2022/11/28 16:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30231) Update to Fabric8 Kubernetes Client to a version that has automatic renewal of service account tokens - posted by "Chris Thomson (Jira)" <ji...@apache.org> on 2022/11/28 21:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30232) shading of netty epoll shared library does not account for ARM64 platform - posted by "Chris Thomson (Jira)" <ji...@apache.org> on 2022/11/28 22:06:00 UTC, 0 replies.
- How's JobManager bring up TaskManager in Application Mode or Session Mode? - posted by 李 <li...@126.com> on 2022/11/29 04:22:30 UTC, 1 replies.
- [jira] [Created] (FLINK-30233) Hybrid full result partition should also work with speculative execution - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2022/11/29 04:27:00 UTC, 0 replies.
- Kubernetes Operator 1.3.0 release - posted by Őrhidi Mátyás <ma...@gmail.com> on 2022/11/29 05:43:34 UTC, 3 replies.
- [jira] [Created] (FLINK-30234) SourceReaderBase should provide an option to disable numRecordsIn metric registration - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2022/11/29 06:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30235) Comprehensive benchmarks on changelog checkpointing - posted by "Rui Xia (Jira)" <ji...@apache.org> on 2022/11/29 07:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30236) UpsertKafkaTableITCase failed due to timeout when creating a topic - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/11/29 07:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30237) Only bundle a single Zookeeper version - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/11/29 09:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30238) Unified Sink committer does not clean up state on final savepoint - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2022/11/29 11:02:00 UTC, 4 replies.
- [SUMMARY] Flink 1.17 Release Sync 11/29/2022 - posted by Qingsheng Ren <re...@apache.org> on 2022/11/29 12:12:08 UTC, 0 replies.
- [jira] [Created] (FLINK-30239) The flame graph doesn't work due to groupExecutionsByLocation has bug - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2022/11/29 16:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30240) Fix Doc error pointing to TableKind#MANAGED - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2022/11/29 18:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30241) Flink ML Iteration ConcurrentModificationException - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2022/11/30 01:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30242) Push localHashAggregate pass the union node - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/11/30 06:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30243) Remove duplicate commas - posted by "Shilun Fan (Jira)" <ji...@apache.org> on 2022/11/30 06:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30244) When task using udf/udtf with jni, flink on k8s session the old - posted by "AlexHu (Jira)" <ji...@apache.org> on 2022/11/30 06:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30245) NPE thrown when filtering decimal(18, 4) values after calling DecimalDataUtils.subtract method - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2022/11/30 07:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30246) Registering the same metric object with different name and group will conflict in metric reporter - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2022/11/30 07:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30247) Introduce Time Travel reading for table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/11/30 08:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30248) Spark writer supports insert overwrite - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/11/30 09:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30249) TableUtils.getRowTypeInfo() creating wrong TypeInformation - posted by "Zhipeng Zhang (Jira)" <ji...@apache.org> on 2022/11/30 09:55:00 UTC, 0 replies.
- [VOTE] Release flink-connector-pulsar v3.0.0, release candidate #1 - posted by Martijn Visser <ma...@apache.org> on 2022/11/30 10:59:23 UTC, 0 replies.
- [jira] [Created] (FLINK-30250) The flame graph type is wrong - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2022/11/30 11:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30251) Move the IO with DFS during abort checkpoint to an asynchronous thread. - posted by "ming li (Jira)" <ji...@apache.org> on 2022/11/30 11:13:00 UTC, 0 replies.
- [VOTE] Release flink-connector-jdbc v3.0.0, release candidate #1 - posted by Martijn Visser <ma...@apache.org> on 2022/11/30 11:40:56 UTC, 0 replies.
- [jira] [Created] (FLINK-30252) Publish flink-shaded pom - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/11/30 11:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30253) Introduce io executor for standalone checkpoint store - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2022/11/30 13:11:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-271: Autoscaling - posted by Maximilian Michels <mx...@apache.org> on 2022/11/30 14:39:22 UTC, 0 replies.
- [jira] [Created] (FLINK-30254) Sync Pulsar updates to external Pulsar connector repository - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/11/30 19:04:00 UTC, 0 replies.