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

---

- [jira] [Created] (FLINK-25500) ZooKeeperLeaderElectionITCase.testJobExecutionOnClusterWithLeaderChange failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/01/02 03:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25501) npm ci hangs on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/01/02 03:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25502) eval method of Flink ScalerFunction only run one time - posted by "Spongebob (Jira)" <ji...@apache.org> on 2022/01/02 10:35:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-203: Incremental savepoints - posted by David Morávek <dm...@apache.org> on 2022/01/03 08:04:22 UTC, 11 replies.
- Re: [DISCUSS] FLIP-205: Support cache in DataStream for Batch Processing - posted by David Morávek <dm...@apache.org> on 2022/01/03 08:17:05 UTC, 14 replies.
- Re: [DISCUSS] Changing the minimal supported version of Hadoop - posted by David Morávek <dm...@apache.org> on 2022/01/03 08:24:19 UTC, 2 replies.
- Re: Re: [DISCUSS] FLIP-191: Extend unified Sink interface to support small file compaction - posted by Fabian Paul <fp...@apache.org> on 2022/01/03 08:45:06 UTC, 1 replies.
- [jira] [Created] (FLINK-25503) KafkaDynamicSource: can't use group-offsets startup mode directly - posted by "Zongwen Li (Jira)" <ji...@apache.org> on 2022/01/03 08:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25504) Update and synchronise used versions of Kafka Client and Confluent Platform - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/01/03 10:18:00 UTC, 0 replies.
- Re: Re: [DISCUSS] Introduce Hash Lookup Join - posted by Francesco Guardiani <fr...@ververica.com> on 2022/01/03 10:38:08 UTC, 9 replies.
- Re: [DISCUSS] FLIP-206: Support PyFlink Runtime Execution in Thread Mode - posted by Till Rohrmann <tr...@apache.org> on 2022/01/03 10:45:37 UTC, 8 replies.
- [jira] [Created] (FLINK-25505) Fix NetworkBufferPoolTest, SystemResourcesCounterTest on Apple M1 - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2022/01/03 12:45:00 UTC, 0 replies.
- [DISCUSS] Drop Gelly - posted by Martijn Visser <ma...@ververica.com> on 2022/01/03 13:20:07 UTC, 9 replies.
- Re: [VOTE] Apache Flink ML Release 2.0.0, release candidate #3 - posted by Till Rohrmann <tr...@apache.org> on 2022/01/03 14:10:11 UTC, 4 replies.
- [DISCUSS] Looking for maintainers for Google PubSub connector or discuss next step - posted by Martijn Visser <ma...@ververica.com> on 2022/01/03 14:40:58 UTC, 3 replies.
- [jira] [Created] (FLINK-25506) Generate HBase Connector Options doc from HBaseConnectorOptions - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/01/03 16:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25507) ElasticsearchWriterITCase#testWriteOnBulkFlush test failed - posted by "ranqiqiang (Jira)" <ji...@apache.org> on 2022/01/04 02:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25508) Flink Batch mode, cluster shutdown early. - posted by "todd (Jira)" <ji...@apache.org> on 2022/01/04 03:23:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-200: Support Multiple Rule and Dynamic Rule Changing (Flink CEP) - posted by Becket Qin <be...@gmail.com> on 2022/01/04 05:40:35 UTC, 8 replies.
- [jira] [Created] (FLINK-25509) FLIP-208: Update KafkaSource to detect EOF based on de-serialized records - posted by "Dong Lin (Jira)" <ji...@apache.org> on 2022/01/04 07:03:00 UTC, 0 replies.
- [DISCUSS] FLIP-208: Update KafkaSource to detect EOF based on de-serialized record - posted by Dong Lin <li...@gmail.com> on 2022/01/04 07:04:01 UTC, 16 replies.
- [jira] [Created] (FLINK-25510) Add test cases for KafkaPartitionSplitReader - posted by "Zongwen Li (Jira)" <ji...@apache.org> on 2022/01/04 07:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25511) Leftovers after truncation are not be cleaned up if pre-uploading is enabled - posted by "Yuan Mei (Jira)" <ji...@apache.org> on 2022/01/04 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25512) Materialization Files are not cleaned up if no checkpoint is using it - posted by "Yuan Mei (Jira)" <ji...@apache.org> on 2022/01/04 08:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25513) CoFlatMapFunction requires both two flat_maps to yield something - posted by "chendan (Jira)" <ji...@apache.org> on 2022/01/04 08:37:00 UTC, 0 replies.
- Re: [NOTICE] Table API is now Scala-free by introducing a flink-table-planner-loader - posted by Jingsong Li <ji...@gmail.com> on 2022/01/04 08:50:25 UTC, 0 replies.
- [VOTE] FLIP-191: Extend unified Sink interface to support small file compaction - posted by Fabian Paul <fp...@apache.org> on 2022/01/04 09:20:41 UTC, 5 replies.
- Re: [DISCUSS] Change some default config values of blocking shuffle - posted by Yingjie Cao <ke...@gmail.com> on 2022/01/04 09:34:27 UTC, 3 replies.
- [jira] [Created] (FLINK-25514) YARN session tests scan unrelated logs for bugs - posted by "Niklas Semmler (Jira)" <ji...@apache.org> on 2022/01/04 09:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25515) flink-kafka-consumer - posted by "宇宙先生 (Jira)" <ji...@apache.org> on 2022/01/04 10:00:04 UTC, 0 replies.
- [jira] [Created] (FLINK-25516) Add catalog object compile/restore options - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2022/01/04 10:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25517) Extract duplicate code in JarFileChecker - posted by "Wenjun Ruan (Jira)" <ji...@apache.org> on 2022/01/04 11:05:00 UTC, 0 replies.
- [DISCUSS] Disabling JNDI by default - posted by Till Rohrmann <tr...@apache.org> on 2022/01/04 12:12:20 UTC, 1 replies.
- [jira] [Created] (FLINK-25518) Harden JSON Serialization utilities - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/01/04 14:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25519) Promote StreamExecutionEnvironment#fromSource() from @Experimental to next phase - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/01/04 18:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25520) Implement "ALTER TABLE ... COMPACT" SQL - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/01/05 01:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25521) The composition description of 'INTERVAL DAY TO SECOND' in the Data Type is incorrect - posted by "Zongwen Li (Jira)" <ji...@apache.org> on 2022/01/05 03:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25522) KafkaShuffleExactlyOnceITCase.testAssignedToPartitionFailureRecoveryProcessingTime - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/01/05 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25523) KafkaSourceITCase$KafkaSpecificTests.testTimestamp fails on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/01/05 08:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25524) If enabled changelog, RocksDB incremental checkpoint would always be full - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2022/01/05 08:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25525) flink-examples-table is not runnable in the IDE - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2022/01/05 08:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25526) Deprecate TableSinkFactory, TableSourceFactory and TableFormatFactory - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/01/05 08:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25527) Add StringIndexer in FlinkML - posted by "Zhipeng Zhang (Jira)" <ji...@apache.org> on 2022/01/05 08:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25528) state processor api do not support increment checkpoint - posted by "刘方奇 (Jira)" <ji...@apache.org> on 2022/01/05 09:06:00 UTC, 0 replies.
- Re: [DISCUSS] Deprecate MapR FS - posted by Martijn Visser <ma...@ververica.com> on 2022/01/05 09:11:24 UTC, 5 replies.
- [jira] [Created] (FLINK-25529) java.lang.ClassNotFoundException: org.apache.orc.PhysicalWriter when write bulkly into hive-2.1.1 orc table - posted by "Yuan Zhu (Jira)" <ji...@apache.org> on 2022/01/05 09:25:00 UTC, 0 replies.
- Re: [DISCUSS] JUnit 5 Migration - posted by Ryan Skraba <ry...@aiven.io.INVALID> on 2022/01/05 10:39:25 UTC, 1 replies.
- Re: [DISCUSS] Creating an external connector repository - posted by Martijn Visser <ma...@ververica.com> on 2022/01/05 10:48:11 UTC, 3 replies.
- Re: [DISCUSS] FLIP-201: Persist local state in working directory - posted by Till Rohrmann <tr...@apache.org> on 2022/01/05 10:50:06 UTC, 3 replies.
- [jira] [Created] (FLINK-25530) Support Pulsar source connector in Python DataStream API. - posted by "Ada Wong (Jira)" <ji...@apache.org> on 2022/01/05 12:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25531) The test testRetryCommittableOnRetriableError takes one hour before completing succesfully - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/01/05 12:50:00 UTC, 0 replies.
- Re: [VOTE] Release flink-shaded 15.0, release candidate #1 - posted by Matthias Pohl <ma...@ververica.com> on 2022/01/05 13:57:24 UTC, 1 replies.
- [DISCUSS] Moving connectors from Flink to external connector repositories - posted by Martijn Visser <ma...@ververica.com> on 2022/01/05 13:59:57 UTC, 2 replies.
- [jira] [Created] (FLINK-25532) Provide Flink SQL CLI as Docker image - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/01/05 14:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25533) Preferred AllocationIDs are not respected when fulfilling pending slot requests - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/01/05 16:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25534) execute pre-job throws org.apache.flink.table.api.TableException: Failed to execute sql - posted by "jychen (Jira)" <ji...@apache.org> on 2022/01/06 01:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25535) The JVM parameter does not take effect - posted by "Bo Cui (Jira)" <ji...@apache.org> on 2022/01/06 02:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25536) Minor Fix: Adjust the order of variable declaration and comment in StateAssignmentOperation - posted by "Junfan Zhang (Jira)" <ji...@apache.org> on 2022/01/06 02:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25537) Migrate flink-core to JUnit 5 - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2022/01/06 02:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25538) Migrate flink-connector-kafka to JUnit 5 - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2022/01/06 02:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25539) 用flink的BatchTableEnvironment创建连接器去读取oss文件，并行度设为16，读数时有时会出现线程报错：Null IO stream - posted by "王康 (Jira)" <ji...@apache.org> on 2022/01/06 02:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25540) [JUnit5 Migration] Module: flink-runtime - posted by "Hang Ruan (Jira)" <ji...@apache.org> on 2022/01/06 03:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25541) [JUnit5 Migration] Module: flink-test-utils - posted by "Hang Ruan (Jira)" <ji...@apache.org> on 2022/01/06 03:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25542) [JUnit5 Migration] Module: flink-runtime-web - posted by "Hang Ruan (Jira)" <ji...@apache.org> on 2022/01/06 03:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25543) [JUnit5 Migration] Module: flink-yarn - posted by "Hang Ruan (Jira)" <ji...@apache.org> on 2022/01/06 03:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25545) [JUnit5 Migration] Module: flink-clients - posted by "Hang Ruan (Jira)" <ji...@apache.org> on 2022/01/06 03:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25544) [JUnit5 Migration] Module: flink-streaming-java - posted by "Hang Ruan (Jira)" <ji...@apache.org> on 2022/01/06 03:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25546) [JUnit5 Migration] Module: flink-connector-base - posted by "Hang Ruan (Jira)" <ji...@apache.org> on 2022/01/06 03:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25547) [JUnit5 Migration] Module: flink-optimizer - posted by "Hang Ruan (Jira)" <ji...@apache.org> on 2022/01/06 03:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25549) [JUnit5 Migration] Module: flink-dstl - posted by "Hang Ruan (Jira)" <ji...@apache.org> on 2022/01/06 03:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25548) [JUnit5 Migration] Module: flink-sql-parser - posted by "Hang Ruan (Jira)" <ji...@apache.org> on 2022/01/06 03:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25550) [JUnit5 Migration] Module: flink-kuberbetes - posted by "Hang Ruan (Jira)" <ji...@apache.org> on 2022/01/06 03:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25551) Add example and documentation on the usage of Row in Python UDTF - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/01/06 03:46:00 UTC, 0 replies.
- [RESULT] [VOTE] Apache Flink ML Release 2.0.0, release candidate #3 - posted by Yun Gao <yu...@aliyun.com.INVALID> on 2022/01/06 06:07:37 UTC, 0 replies.
- [jira] [Created] (FLINK-25552) Support MinMaxScaler in FlinkML - posted by "weibo zhao (Jira)" <ji...@apache.org> on 2022/01/06 07:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25553) Remove MapR filesystem - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/01/06 07:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25554) DistributedCacheDfsTest.testSubmittingJobViaRestClusterClient fails on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/01/06 08:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25555) FLIP-191: Extend unified Sink interface to support small file compaction - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2022/01/06 09:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25556) Extra waiting of final checkpoint in benchmarks - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2022/01/06 11:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25557) Introduce incremental/full checkpoint size stats - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2022/01/06 12:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25558) TableResult OK may be empty if returned by multiple queries - posted by "Paul Lin (Jira)" <ji...@apache.org> on 2022/01/06 16:42:00 UTC, 0 replies.
- Re: [DISCUSS] Releasing Flink 1.14.3 - posted by Thomas Weise <th...@apache.org> on 2022/01/07 00:54:09 UTC, 7 replies.
- [jira] [Created] (FLINK-25559) SQL JOIN causes data loss - posted by "Zongwen Li (Jira)" <ji...@apache.org> on 2022/01/07 02:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25560) Add - posted by "Bruce Wong (Jira)" <ji...@apache.org> on 2022/01/07 02:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25561) Execution mode of batch mode job web ui shows pipeline - posted by "Echo Lee (Jira)" <ji...@apache.org> on 2022/01/07 06:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25562) hive sql connector 依赖冲突 - posted by "ziqiang.wang (Jira)" <ji...@apache.org> on 2022/01/07 06:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25563) Support sink parallelism configuration to Elasticsearch connector - posted by "Yubin Li (Jira)" <ji...@apache.org> on 2022/01/07 07:19:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-188: Introduce Built-in Dynamic Table Storage - posted by Jingsong Li <ji...@gmail.com> on 2022/01/07 07:30:11 UTC, 2 replies.
- [VOTE] Create a separate sub project for FLIP-188: flink-store - posted by Jingsong Li <ji...@gmail.com> on 2022/01/07 07:37:36 UTC, 18 replies.
- [NOTICE] Introduction of flink-table-test-utils - posted by Timo Walther <tw...@apache.org> on 2022/01/07 08:24:20 UTC, 0 replies.
- [jira] [Created] (FLINK-25564) TaskManagerProcessFailureStreamingRecoveryITCase>AbstractTaskManagerProcessFailureRecoveryTest.testTaskManagerProcessFailure fails on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/01/07 08:32:00 UTC, 0 replies.
- [DISCUSS] FLIP-209: Support to run multiple shuffle plugins in one session cluster - posted by Yingjie Cao <ke...@gmail.com> on 2022/01/07 08:47:06 UTC, 0 replies.
- [jira] [Created] (FLINK-25565) Write and Read Parquet INT64 Timestamp - posted by "Bo Cui (Jira)" <ji...@apache.org> on 2022/01/07 10:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25566) Fail to cancel task if disk is bad for java.lang.NoClassDefFoundError - posted by "Liu (Jira)" <ji...@apache.org> on 2022/01/07 11:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25567) Casting of Multisets to Multisets - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/01/07 11:39:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-191: Extend unified Sink interface to support small file compaction - posted by Fabian Paul <fp...@apache.org> on 2022/01/07 11:55:09 UTC, 0 replies.
- [jira] [Created] (FLINK-25568) Add Elasticsearch 7 Source Connector - posted by "Alexander Preuss (Jira)" <ji...@apache.org> on 2022/01/07 12:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25569) Introduce decomposed Sink V2 interfaces - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2022/01/07 12:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25570) Introduce Sink V2 extension APIs - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2022/01/07 12:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25572) Update File Sink to use decomposed interfaces - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2022/01/07 12:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25571) Update Elasticsearch Sink to use decomposed interfaces - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2022/01/07 12:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25573) Update Kafka Sink to use decomposed interfaces - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2022/01/07 12:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25574) Update Async Sink to use decomposed interfaces - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2022/01/07 12:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25575) Implement StreamGraph translation for Sink V2 interfaces - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2022/01/07 12:36:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink ML 2.0.0 released - posted by Yun Gao <yu...@aliyun.com.INVALID> on 2022/01/07 13:26:19 UTC, 2 replies.
- [jira] [Created] (FLINK-25576) Update com.h2database:h2 to 2.0.206 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/01/07 13:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25577) Update GCS documentation not to use no longer supported flink-shaded-hadoop artifacts - posted by "David Morávek (Jira)" <ji...@apache.org> on 2022/01/07 14:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25578) Graduate Sink V1 interfaces to PublicEvolving and deprecate them - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2022/01/07 15:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25579) Py4JException: window([class org.apache.flink.table.api.SlideWithSizeAndSlide]) does not exist - posted by "Darron Fuller (Jira)" <ji...@apache.org> on 2022/01/09 03:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25580) Minor improvements for RocksDBIncrementalCheckpointUtils - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/01/09 03:32:00 UTC, 0 replies.
- [Ask for review] - posted by Aitozi <gj...@gmail.com> on 2022/01/09 08:53:27 UTC, 2 replies.
- [DISCUSS] Add the ability of evolution RowData in sql/table job - posted by Aitozi <gj...@gmail.com> on 2022/01/09 09:38:28 UTC, 2 replies.
- [jira] [Created] (FLINK-25581) Jobmanager does not archive completed jobs - posted by "Leonid Ilyevsky (Jira)" <ji...@apache.org> on 2022/01/09 23:25:00 UTC, 0 replies.
- Flink SQL Kafka connector - posted by 聂荧屏 <sm...@gmail.com> on 2022/01/10 02:06:05 UTC, 1 replies.
- [jira] [Created] (FLINK-25582) flink sql kafka source cannot special custom parallelism - posted by "venn wu (Jira)" <ji...@apache.org> on 2022/01/10 02:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25583) [FLIP-191] Support compacting small files for FileSink - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/01/10 06:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25584) Azure failed on install node and npm for Flink : Runtime web - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/01/10 06:33:00 UTC, 0 replies.
- is task reassignment possible - posted by Chen Qin <qi...@gmail.com> on 2022/01/10 06:43:50 UTC, 1 replies.
- [jira] [Created] (FLINK-25585) JobManagerHAProcessFailureRecoveryITCase.testDispatcherProcessFailure failed on the azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/01/10 06:45:00 UTC, 0 replies.
- Re: Unable to update logback configuration in Flink Native Kubernetes - posted by Yang Wang <da...@gmail.com> on 2022/01/10 07:07:58 UTC, 0 replies.
- [jira] [Created] (FLINK-25586) ExecutionGraphInfoStore in session cluster should split failed and successful jobs - posted by "Shammon (Jira)" <ji...@apache.org> on 2022/01/10 07:15:00 UTC, 0 replies.
- Regarding Connector Options - value.deserializer - posted by "Ronak Beejawat (rbeejawa)" <rb...@cisco.com.INVALID> on 2022/01/10 07:50:37 UTC, 3 replies.
- [jira] [Created] (FLINK-25587) HiveCatalogITCase crashed on Azure with exit code 239 - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/01/10 08:27:00 UTC, 0 replies.
- [VOTE] FLIP-201: Persist local state in working directory - posted by Till Rohrmann <tr...@apache.org> on 2022/01/10 09:22:32 UTC, 7 replies.
- [jira] [Created] (FLINK-25588) Add jdk8 and datetime module to jackson shaded - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/01/10 10:15:00 UTC, 0 replies.
- Re: [DISCUSS] Slimmed down docker images. - posted by Chesnay Schepler <ch...@apache.org> on 2022/01/10 10:50:05 UTC, 0 replies.
- [jira] [Created] (FLINK-25589) Update Chinese version of Elasticsearch connector docs - posted by "Alexander Preuss (Jira)" <ji...@apache.org> on 2022/01/10 10:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25590) Logging warning of insufficient memory for all configured buffers - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2022/01/10 11:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25591) Use FileSource for StreamExecutionEnvironment.readFiles - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2022/01/10 12:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25592) Improvement of parser, optimizer and execution for Flink Batch SQL - posted by "Jing Zhang (Jira)" <ji...@apache.org> on 2022/01/10 13:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25593) A redundant scan could be skipped if it is an input of join and the other input is empty after partition prune - posted by "Jing Zhang (Jira)" <ji...@apache.org> on 2022/01/10 13:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25594) Take parquet metadata into consideration when source is parquet files - posted by "Jing Zhang (Jira)" <ji...@apache.org> on 2022/01/10 13:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25595) Specify hash/sort aggregate strategy in SQL hint - posted by "Jing Zhang (Jira)" <ji...@apache.org> on 2022/01/10 13:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25596) Specify hash/sortmerge join in SQL hint - posted by "Jing Zhang (Jira)" <ji...@apache.org> on 2022/01/10 14:00:00 UTC, 0 replies.
- what is efficient way to write Left join in flink - posted by "Ronak Beejawat (rbeejawa)" <rb...@cisco.com.INVALID> on 2022/01/10 14:09:56 UTC, 4 replies.
- [DISCUSS] FLIP-210: Change logging level dynamically at runtime - posted by Wenhao Ji <pr...@gmail.com> on 2022/01/10 16:10:19 UTC, 10 replies.
- [jira] [Created] (FLINK-25597) Document which URI based config options works with local / general filesystem - posted by "David Morávek (Jira)" <ji...@apache.org> on 2022/01/10 16:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25598) Changelog materialized state discarded on failure - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/01/10 20:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25599) The description of taskmanager.memory.task.heap.size in the official document is incorrect - posted by "Zhuang Liu (Jira)" <ji...@apache.org> on 2022/01/11 02:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25600) Support new statement set syntax in sql client and update docs - posted by "Wenlong Lyu (Jira)" <ji...@apache.org> on 2022/01/11 02:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25601) Update 'state.backend' in flink-conf.yaml - posted by "Ada Wong (Jira)" <ji...@apache.org> on 2022/01/11 03:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25603) make the BlobServer use aws s3 - posted by "lupan (Jira)" <ji...@apache.org> on 2022/01/11 06:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25602) make the BlobServer use aws s3 - posted by "lupan (Jira)" <ji...@apache.org> on 2022/01/11 06:28:00 UTC, 0 replies.
- [VOTE] FLIP-199: Change some default config values of blocking shuffle for better usability - posted by Yingjie Cao <ke...@gmail.com> on 2022/01/11 07:14:37 UTC, 4 replies.
- [jira] [Created] (FLINK-25604) Remove useless aggregate function - posted by "Jing Zhang (Jira)" <ji...@apache.org> on 2022/01/11 07:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25605) Batch get statistics of multiple partitions instead of get one by one - posted by "Jing Zhang (Jira)" <ji...@apache.org> on 2022/01/11 08:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25606) Requesting exclusive buffers timeout when recovering from unaligned checkpoint under fine-grained resource mode - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2022/01/11 08:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25607) Sorting by duration on Flink Web UI does not work correctly - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2022/01/11 08:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25608) Mark metrics as Public(Evolving) - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2022/01/11 09:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25609) Avoid creating temporary tables for inline tables - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2022/01/11 10:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25610) [FLIP-171] Kinesis Firehose implementation of Async Sink Table API - posted by "Ahmed Hamdy (Jira)" <ji...@apache.org> on 2022/01/11 11:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25611) Remove CoordinatorExecutorThreadFactory thread creation guards - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/01/11 11:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25612) Update the outdated illustration of ExecutionState in the documentation - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2022/01/11 12:00:00 UTC, 0 replies.
- Re: [VOTE][CANCELED] Release flink-shaded 15.0, release candidate #1 - posted by Chesnay Schepler <ch...@apache.org> on 2022/01/11 12:14:56 UTC, 0 replies.
- [jira] [Created] (FLINK-25613) Remove excessive surefire-plugin versions - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/01/11 13:14:00 UTC, 0 replies.
- Could not find any factory for identifier 'jdbc' - posted by "Ronak Beejawat (rbeejawa)" <rb...@cisco.com.INVALID> on 2022/01/11 13:14:00 UTC, 5 replies.
- [DISCUSS] FLIP-211: Kerberos delegation token framework - posted by Gabor Somogyi <ga...@gmail.com> on 2022/01/11 13:58:41 UTC, 33 replies.
- [jira] [Created] (FLINK-25614) Let LocalWindowAggregate be chained with upstream - posted by "Q Kang (Jira)" <ji...@apache.org> on 2022/01/11 15:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25615) FlinkKafkaProducer fail to correctly migrate pre Flink 1.9 state - posted by "Matthias Schwalbe (Jira)" <ji...@apache.org> on 2022/01/11 16:21:00 UTC, 0 replies.
- [VOTE] Release 1.14.3, release candidate #1 - posted by Martijn Visser <ma...@ververica.com> on 2022/01/11 16:34:53 UTC, 10 replies.
- Need help with finding inner workings of watermark stream idleness - posted by Jeff Carter <jp...@gmail.com> on 2022/01/11 17:04:44 UTC, 1 replies.
- Use of JIRA fixVersion - posted by Thomas Weise <th...@apache.org> on 2022/01/11 19:44:01 UTC, 2 replies.
- [RESULT][VOTE] Create a separate sub project for FLIP-188 - posted by Jingsong Li <ji...@gmail.com> on 2022/01/12 02:23:05 UTC, 0 replies.
- [jira] [Created] (FLINK-25616) Support VectorAssembler in FlinkML - posted by "weibo zhao (Jira)" <ji...@apache.org> on 2022/01/12 02:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25617) Support VectorAssembler in FlinkML - posted by "weibo zhao (Jira)" <ji...@apache.org> on 2022/01/12 02:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25618) Data quality by apache flink - posted by "tanjialiang (Jira)" <ji...@apache.org> on 2022/01/12 03:32:00 UTC, 0 replies.
- [DISCUSS] Seek help for making JIRA links clickable in github - posted by Jingsong Li <ji...@gmail.com> on 2022/01/12 05:53:05 UTC, 4 replies.
- [jira] [Created] (FLINK-25619) Init flink-table-store repository - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/01/12 06:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25620) Upload artifacts to S3 failed on azure pipeline - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/01/12 06:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25621) LegacyStatefulJobSavepointMigrationITCase failed on azure with exit code 127 - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/01/12 07:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25622) Throws NPE in Python UDTF - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/01/12 07:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25623) TPC-DS end-to-end test (Blink planner) failed on azure due to download file tpcds.idx failed. - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/01/12 07:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25624) KafkaSinkITCase.testRecoveryWithExactlyOnceGuarantee blocked on azure pipeline - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/01/12 07:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25625) Introduce FileFormat for table-store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/01/12 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25626) Azure failed due to "Error occurred in starting fork" - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/01/12 08:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25627) Add basic structures of file store in table-store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/01/12 09:56:00 UTC, 0 replies.
- [VOTE] FLIP-206: Support PyFlink Runtime Execution in Thread Mode - posted by Xingbo Huang <hx...@gmail.com> on 2022/01/12 09:58:58 UTC, 4 replies.
- OutOfMemoryError: Java heap space while implmentating flink sql api - posted by "Ronak Beejawat (rbeejawa)" <rb...@cisco.com.INVALID> on 2022/01/12 09:59:33 UTC, 3 replies.
- [DISCUSS] Data quality by apache flink - posted by tanjialiang <ta...@126.com> on 2022/01/12 10:43:17 UTC, 0 replies.
- Re: Flink native k8s integration vs. operator - posted by Konstantin Knauf <kn...@apache.org> on 2022/01/12 11:20:51 UTC, 10 replies.
- [jira] [Created] (FLINK-25628) Introduce RecordReader and related classes for table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/01/12 12:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25629) Introduce CompactStrategy and CompactManager for table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/01/12 12:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25630) Introduce MergeTree writer and reader for table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/01/12 12:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25631) Support enhanced `show tables` statement - posted by "Yubin Li (Jira)" <ji...@apache.org> on 2022/01/12 12:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25632) Makes Job name available in cleanup stage - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/01/12 15:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25633) CPUResourceTest does not work with German Locale - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/01/12 16:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25634) flink-read-onyarn-configuration - posted by "宇宙先生 (Jira)" <ji...@apache.org> on 2022/01/13 02:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25635) Using sql client create hive catalog throw exception - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/01/13 04:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25636) FLIP-199: Change some default config values of blocking shuffle for better usability - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2022/01/13 06:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25637) Make sort-shuffle the default shuffle implementation for batch jobs - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2022/01/13 07:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25638) Increase the default write buffer size of sort-shuffle to 16M - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2022/01/13 07:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25639) Increase the default read buffer size of sort-shuffle to 64M - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2022/01/13 07:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25640) Enhance the document for blocking shuffle - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2022/01/13 07:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25641) Unexpected aggregate plan after load hive module - posted by "Jing Zhang (Jira)" <ji...@apache.org> on 2022/01/13 08:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25642) The standalone deployment mode should also support the parameter pipeline.jars - posted by "john (Jira)" <ji...@apache.org> on 2022/01/13 08:04:00 UTC, 0 replies.
- [DISCUSS] Future of Per-Job Mode - posted by Konstantin Knauf <kn...@apache.org> on 2022/01/13 08:30:48 UTC, 9 replies.
- [DISCUSS] Merge flink-connector-testing into flink-connector-test-utils - posted by Qingsheng Ren <re...@gmail.com> on 2022/01/13 08:37:28 UTC, 5 replies.
- [jira] [Created] (FLINK-25643) Introduce Predicate to table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/01/13 09:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25644) Introduce interfaces between file-table-store and flink connector sink - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/01/13 10:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25645) UnsupportedOperationException would thrown out when hash shuffle by a field with array type - posted by "Jing Zhang (Jira)" <ji...@apache.org> on 2022/01/13 11:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25646) Document buffer debloating issues with high parallelism - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2022/01/13 12:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25647) Improve JSON format handling and support - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/01/13 12:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25648) Redundant to querying deployment when creating task manager pod - posted by "Yuan Huang (Jira)" <ji...@apache.org> on 2022/01/13 13:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25649) Scheduling jobs fails with org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException - posted by "Gil De Grove (Jira)" <ji...@apache.org> on 2022/01/13 13:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25650) Document unaligned checkpoints performance limitations (larger records/flat map/timers/...) - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2022/01/13 14:01:00 UTC, 0 replies.
- [FEEDBACK] Metadata Platforms / Catalogs / Lineage integration - posted by Martijn Visser <ma...@ververica.com> on 2022/01/13 15:27:23 UTC, 5 replies.
- [jira] [Created] (FLINK-25651) Flink1.14.2 DataStream Connectors Kafka Deserializer example method uses the wrong parameter - posted by "shouzuo meng (Jira)" <ji...@apache.org> on 2022/01/14 03:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25652) Can "duration“ and ”received records" be updated at the same time in WebUI's task detail ? - posted by "jeff-zou (Jira)" <ji...@apache.org> on 2022/01/14 06:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25653) Move buffer recycle in SortMergeSubpartitionReader out of lock to avoid deadlock - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2022/01/14 07:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25654) Remove the redundant lock in SortMergeResultPartition - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2022/01/14 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25655) FlinkKafkaInternalProducerITCase.testInitTransactionId failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/01/14 09:19:00 UTC, 0 replies.
- [DISCUSS] Move Flink website to privacy friendly Analytics solution - posted by Martijn Visser <ma...@ververica.com> on 2022/01/14 10:20:43 UTC, 4 replies.
- [jira] [Created] (FLINK-25656) Upgrade software.amazon.glue:schema-registry-common and software.amazon.glue:schema-registry-serde dependency from 1.1.5 to 1.1.8 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/01/14 14:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25657) Upgrade com.amazonaws:amazon-kinesis-client dependency from 1.14.1 to 1.14.7 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/01/14 14:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25658) Setup Nexus npm cache - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/01/14 14:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25659) LogicalRelDataTypeConverterTest is flaky on Azure - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2022/01/14 15:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25660) Failed to build flink-runtime-web - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/01/15 11:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25661) Add Custom Fatal Exception handler in AsyncSinkWriter - posted by "Nir Tsruya (Jira)" <ji...@apache.org> on 2022/01/16 10:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25662) Access KeyedStateStore in WindowAssigner - posted by "Sun Sheng (Jira)" <ji...@apache.org> on 2022/01/17 03:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25663) SqlParse - posted by "Xiang Yang (Jira)" <ji...@apache.org> on 2022/01/17 04:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25664) Notify will be not triggered for PipelinedSubpartition if more than one buffer is added during isBlocked == true - posted by "Cai Liuyang (Jira)" <ji...@apache.org> on 2022/01/17 05:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25665) DistinctITCase.testCorrectnessOfDistinctOnCustomTypeWithTypeExtractor timeout on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/01/17 07:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25666) Remove LegacyTypeInfoDataTypeConverter - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2022/01/17 07:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25667) AdaptiveSchedulerTest.testStatusMetrics is not stable - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/01/17 07:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25668) Support calcuate network memory for dynamic graph. - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2022/01/17 08:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25669) Support register operator coordinators for newly initialized ExecutionJobVertex. - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2022/01/17 08:05:00 UTC, 0 replies.
- How to use TableEnvironment in multiple thread environments - posted by Chang Chen <ba...@gmail.com> on 2022/01/17 08:13:13 UTC, 3 replies.
- [jira] [Created] (FLINK-25670) StateFun: Unable to handle oversize HTTP message if state size is large - posted by "Kyle (Jira)" <ji...@apache.org> on 2022/01/17 08:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25671) npm ci failed with code EPROTO when downloading stylelint-config-prettier-8.0.2.tgz - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/01/17 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25672) FileSource enumerator remembers paths of all already processed files which can result in large state - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/01/17 08:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25673) AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstSavepointSucceedOnSecond hangs on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/01/17 08:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25674) CassandraConnectorITCase.testCassandraPojoNoAnnotatedKeyspaceAtLeastOnceSink fails on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/01/17 09:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25675) UnalignedCheckpointCompatibilityITCase.test hangs on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/01/17 09:15:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-206: Support PyFlink Runtime Execution in Thread Mode - posted by Xingbo Huang <hx...@gmail.com> on 2022/01/17 09:57:03 UTC, 0 replies.
- [jira] [Created] (FLINK-25676) Add set_description in Python API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2022/01/17 09:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25677) Update ReplicateRows to the new type system - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2022/01/17 10:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25678) TaskExecutorStateChangelogStoragesManager.shutdown is not thread-safe - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/01/17 10:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25679) Build arm64 Linux images for Apache Flink - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2022/01/17 12:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25680) Introduce Table Store Flink Sink - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/01/17 12:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25681) CodeSplitITCase produces large stacktraces and potentially out of memory errors - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/01/17 12:49:00 UTC, 0 replies.
- I want to contribute to Apache Flink - posted by chengyunzhang6 <ch...@163.com> on 2022/01/17 13:59:42 UTC, 2 replies.
- [jira] [Created] (FLINK-25682) Check in script to verify cheksums and signatures for Apache Flink Releases - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2022/01/17 15:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25683) wrong result if table transfrom to DataStream then window process grouped to mini batch in batch mode - posted by "zhangzh (Jira)" <ji...@apache.org> on 2022/01/18 04:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25684) Support enhanced show databases syntax - posted by "Moses (Jira)" <ji...@apache.org> on 2022/01/18 05:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25685) RestClusterClient gets stuck on submitting job with local user artifact - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2022/01/18 05:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25686) Support Pulsar Schema evolution in Pulsar Connector - posted by "Yufei Zhang (Jira)" <ji...@apache.org> on 2022/01/18 06:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25687) DropDelete is incorrect in CompactManager when outputLevel is zero - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/01/18 07:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25688) Resolve performance degradation with high parallelism when using buffer debloating - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2022/01/18 08:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25689) Introduce atomic commit - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/01/18 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25690) RetryRule should allow a callback to be called on exception and failure cases - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2022/01/18 09:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25691) ElasticsearchSinkITCase.testElasticsearchSink fails on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/01/18 09:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25692) Documentation for Kinesis Firehose Sink - posted by "Zichen Liu (Jira)" <ji...@apache.org> on 2022/01/18 10:27:00 UTC, 0 replies.
- [VOTE] Release flink-shaded 15.0, release candidate #2 - posted by Chesnay Schepler <ch...@apache.org> on 2022/01/18 13:37:19 UTC, 4 replies.
- [jira] [Created] (FLINK-25693) User property 'auto.offset.reset' doesn't take precedence in case of scan.startup.mode= group-offsets - posted by "Gaurav Miglani (Jira)" <ji...@apache.org> on 2022/01/18 15:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25694) GSON/Alluxio Vulnerability - posted by "David Perkins (Jira)" <ji...@apache.org> on 2022/01/18 18:50:00 UTC, 0 replies.
- Flink 1.13.6 with log4j 2.17.1 - posted by Razin Bouzar <rb...@salesforce.com.INVALID> on 2022/01/18 19:24:06 UTC, 0 replies.
- [jira] [Created] (FLINK-25695) TemporalJoin cause state leak in some case - posted by "Lyn Zhang (Jira)" <ji...@apache.org> on 2022/01/19 02:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25696) Introduce MetadataPublisher interface to SinkWriter - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/01/19 05:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25697) Support HTTPS for Prometheus Push Gateway - posted by "Mason Chen (Jira)" <ji...@apache.org> on 2022/01/19 06:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25698) Elasticsearch7DynamicSinkITCase.testWritingDocuments fails on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/01/19 09:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25699) Use HashMap for MAP value constructors - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2022/01/19 09:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25700) flinksql Cascading Window TVF Aggregation exception - posted by "simenliuxing (Jira)" <ji...@apache.org> on 2022/01/19 09:45:00 UTC, 0 replies.
- Request for Flink 1.12.8 release - posted by "V N, Suchithra (Nokia - IN/Bangalore)" <su...@nokia.com> on 2022/01/19 11:10:57 UTC, 3 replies.
- [jira] [Created] (FLINK-25701) Add API annotation to some Kafka connector core classes and interface - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/01/19 11:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25702) Remove the usage of Configurable - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/01/19 12:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25703) In Batch, I think .stagingPath should be created when the task is running to prevent permission issues caused by inconsistency of hadoop usernames - posted by "shizhengchao (Jira)" <ji...@apache.org> on 2022/01/19 12:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25704) Performance regression on 18.01.2022 in batch network benchmarks - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2022/01/19 12:30:00 UTC, 0 replies.
- [VOTE] Creating external connector repositories - posted by Martijn Visser <ma...@ververica.com> on 2022/01/19 13:47:35 UTC, 11 replies.
- [VOTE] Moving connectors from Flink to external connector repositories - posted by Martijn Visser <ma...@ververica.com> on 2022/01/19 13:47:37 UTC, 6 replies.
- [jira] [Created] (FLINK-25705) Translate "Metric Reporters" page of "Deployment" in to Chinese - posted by "ChengKai Yang (Jira)" <ji...@apache.org> on 2022/01/19 14:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25706) Add idleness to Kafka Source documentation - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/01/19 14:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25707) AdaptiveScheduler never transitions executions into SCHEDULED state - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/01/19 16:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25708) Upgrade Flink dependency to 1.14.3 - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/01/19 17:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25709) GlueSchemaRegistryAvroKinesisITCase fails on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/01/19 18:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25710) Multiple Kafka IT cases fail with "ContainerLaunch Container startup failed" - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/01/19 20:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25711) OOM / buffer-overflow on KafkaIO SpecificRecord - posted by "Jordan Moore (Jira)" <ji...@apache.org> on 2022/01/19 23:28:00 UTC, 0 replies.
- [VOTE] FLIP-204: Introduce Hash Lookup Join - posted by Jing Zhang <be...@gmail.com> on 2022/01/20 02:15:12 UTC, 9 replies.
- [jira] [Created] (FLINK-25712) Merge flink-connector-testing into flink-connector-test-utils - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2022/01/20 02:17:00 UTC, 0 replies.
- [VOTE] FLIP-205: Support cache in DataStream for Batch Processing - posted by Xuannan Su <su...@gmail.com> on 2022/01/20 03:09:00 UTC, 6 replies.
- [ANNOUNCE] Apache Flink 1.14.3 released - posted by Thomas Weise <th...@apache.org> on 2022/01/20 04:29:20 UTC, 4 replies.
- [jira] [Created] (FLINK-25713) Support VectorNormalize in FlinkML - posted by "weibo zhao (Jira)" <ji...@apache.org> on 2022/01/20 04:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25714) Remove @ant-design/icons-angular dependency once NG-ZORRO supports node v16.X - posted by "Junhan Yang (Jira)" <ji...@apache.org> on 2022/01/20 08:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25715) Application Mode: Add option to submit a failed job on application error - posted by "David Morávek (Jira)" <ji...@apache.org> on 2022/01/20 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25716) Translate "Streaming Concepts" page of "Application Development > Table API & SQL" to Chinese - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/01/20 08:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25717) Chinese version document Penging word misspelling - posted by "aresyhzhang (Jira)" <ji...@apache.org> on 2022/01/20 08:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25718) FLIP-206: Support PyFlink Runtime Execution in Thread Mode - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/01/20 09:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25719) Support General Python UDF in Thread Mode - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/01/20 09:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25720) Support Python UDTF in Thread Mode - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/01/20 09:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25721) Support Pandas UDF in Thread Mode - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/01/20 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25722) Support Python UDAF in Thread Mode - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/01/20 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25724) Support Python DataStream API in Thread Mode - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/01/20 09:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25723) Support Pandas UDAF in Thread Mode - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/01/20 09:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25725) Refactor web-dashboard's folder structure and use Angular DI injection token for better reusability - posted by "Junhan Yang (Jira)" <ji...@apache.org> on 2022/01/20 09:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25726) Implement GlobalCommitter as custom post commit topology - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2022/01/20 09:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25727) Flink SQL convert constant string to char type which cause hive udtf json_tuple not work - posted by "syntomic (Jira)" <ji...@apache.org> on 2022/01/20 09:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25728) StreamMultipleInputProcessor holds mass CompletableFuture instances under certain scenario - posted by "pc wang (Jira)" <ji...@apache.org> on 2022/01/20 10:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25729) Replace the deprecated FlinkKinesisConsumer with a Kinesis Consumer based on the AWS SDK for Java 2.x - posted by "Zichen Liu (Jira)" <ji...@apache.org> on 2022/01/20 10:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25730) Fix chaining strategy (and typo?) in RowTimeMiniBatchAssginerOperator - posted by "Q Kang (Jira)" <ji...@apache.org> on 2022/01/20 11:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25731) Mark FlinkKinesisProducer/FlinkKinesisConsumer as deprecated - posted by "Zichen Liu (Jira)" <ji...@apache.org> on 2022/01/20 11:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25732) Dispatcher#requestMultipleJobDetails returns non-serialiable collection - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/01/20 12:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25733) [FLIP-171] Create A migration guide for Kinesis Table API connector - posted by "Ahmed Hamdy (Jira)" <ji...@apache.org> on 2022/01/20 12:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25734) Chinese Translation - Update documentation for Kinesis Table Api - posted by "Ahmed Hamdy (Jira)" <ji...@apache.org> on 2022/01/20 15:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25735) Chinese Translation - Add documentation for KDS Async Sink - posted by "Zichen Liu (Jira)" <ji...@apache.org> on 2022/01/20 15:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25736) Chinese Translation - Update documentation for Kinesis Table Api - posted by "Zichen Liu (Jira)" <ji...@apache.org> on 2022/01/20 15:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25737) Chinese Translation - Add documentation for Firehose Async Sink - posted by "Zichen Liu (Jira)" <ji...@apache.org> on 2022/01/20 16:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25738) Translate/fix translations for "FileSystem" connector page of "Connectors > DataStream Connectors" - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/01/20 20:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25739) Include dstl-dfs into distribution (opt/) - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/01/20 21:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25740) PulsarSourceOrderedE2ECase fails on azure - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/01/20 22:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25741) Ignore buffer pools which have no floating buffer in buffer redistributing - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2022/01/21 01:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25742) Remove the redundant serialization of RPC invocation at Flink side. - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2022/01/21 01:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25743) Parameter flink.yarn. has no effect in yarn-session mode with flink-shade-hadoop-2-uber.jar - posted by "HunterHunter (Jira)" <ji...@apache.org> on 2022/01/21 04:50:00 UTC, 0 replies.
- Developing multiple Flink Pieplines - posted by Hussein El Ghoul <hu...@quiqup.com> on 2022/01/21 08:01:12 UTC, 1 replies.
- [DISCUSS] Looking for maintainers for Cassandra connector or decide to remove connector - posted by Martijn Visser <ma...@ververica.com> on 2022/01/21 08:22:42 UTC, 1 replies.
- [jira] [Created] (FLINK-25744) Support native savepoints (w/o modifying the statebackend specific snapshot strategies) - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2022/01/21 08:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25745) Support RocksDB incremental native savepoints - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2022/01/21 08:25:00 UTC, 0 replies.
- [DISCUSS] Looking for maintainers for NiFi connector or decide to remove connector - posted by Martijn Visser <ma...@ververica.com> on 2022/01/21 08:27:25 UTC, 0 replies.
- [DISCUSS] Deprecate/remove Twitter connector - posted by Martijn Visser <ma...@ververica.com> on 2022/01/21 08:34:07 UTC, 8 replies.
- [jira] [Created] (FLINK-25746) Failed to run ITCase locally with IDEA under flink-orc and flink-parquet module - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/01/21 08:54:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-201: Persist local state in working directory - posted by Till Rohrmann <tr...@apache.org> on 2022/01/21 08:56:30 UTC, 0 replies.
- [jira] [Created] (FLINK-25747) UdfStreamOperatorCheckpointingITCase hangs on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/01/21 09:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25748) Website misses some Repositories - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2022/01/21 09:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25749) YARNSessionFIFOSecuredITCase.testDetachedMode fails on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/01/21 09:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25750) Performance regression on 20.01.2021 in globalWindow and stateBackend benchmarks - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/01/21 09:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25751) flink-table tests exit with code 137 - posted by "Niklas Semmler (Jira)" <ji...@apache.org> on 2022/01/21 11:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25752) Create a migration e2e test - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2022/01/21 12:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25753) KafkaTableITCase.testStartFromGroupOffsetsLatest fails on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/01/21 12:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25754) Drop unused private class org.apache.flink.connector.elasticsearch.table.KeyExtractor.ColumnWithIndex - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/01/21 13:27:00 UTC, 0 replies.
- [VOTE] FLIP-211: Kerberos delegation token framework - posted by Gabor Somogyi <ga...@gmail.com> on 2022/01/21 14:57:41 UTC, 5 replies.
- [jira] [Created] (FLINK-25755) Introduce shared interface for adaptive scheduler state transitions - posted by "David Morávek (Jira)" <ji...@apache.org> on 2022/01/21 15:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25756) Dedicated Opensearch connectors - posted by "Andriy Redko (Jira)" <ji...@apache.org> on 2022/01/21 18:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25757) Fix this security issue related to this exploit: https://www.exploit-db.com/exploits/48978 - posted by "Michael Bailey (Jira)" <ji...@apache.org> on 2022/01/21 19:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25758) GCS Filesystem implementation fails on Java 11 tests due to licensing issues - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/01/22 08:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25759) Upgrade to flink-shaded 15.0 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/01/22 10:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25760) Support for extended SQL syntax - posted by "melin (Jira)" <ji...@apache.org> on 2022/01/22 13:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25761) Translate Avro format page into Chinese. - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2022/01/22 14:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25762) Native k8s- User defined system properties get overriden when cluster is created - posted by "Tamir Sagi (Jira)" <ji...@apache.org> on 2022/01/22 14:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25763) Match Recognize Logical Offsets function table shows backticks - posted by "Mans Singh (Jira)" <ji...@apache.org> on 2022/01/22 23:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25764) Docker sets JobManager's rpc address to same host by default - posted by "Niklas Semmler (Jira)" <ji...@apache.org> on 2022/01/23 15:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25765) Kubernetes: flink's configmap and flink's actual config are out of sync - posted by "Niklas Semmler (Jira)" <ji...@apache.org> on 2022/01/23 17:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25766) Chinese translation - posted by "Yao Zhang (Jira)" <ji...@apache.org> on 2022/01/24 02:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25767) Translation of page 'Working with State' is incomplete - posted by "Yao Zhang (Jira)" <ji...@apache.org> on 2022/01/24 02:57:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-205: Support cache in DataStream for Batch Processing - posted by Xuannan Su <su...@gmail.com> on 2022/01/24 03:14:00 UTC, 0 replies.
- [DISCUSS] FLIP-213: TaskManager's Flame Graphs - posted by Jacky Lau <28...@qq.com.INVALID> on 2022/01/24 07:18:45 UTC, 6 replies.
- [jira] [Created] (FLINK-25768) Python test BlinkBatchTableEnvironmentTests.test_explain_with_multi_sinks failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/01/24 07:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25769) Add internal functions and basic function versioning - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2022/01/24 07:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25770) Delete file is not correct in MergeTreeWriter - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/01/24 07:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25771) CassandraConnectorITCase.testRetrialAndDropTables fails on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/01/24 08:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25772) GCS filessystem fails license checker - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/01/24 08:45:00 UTC, 0 replies.
- [VOTE] FLIP-203: Incremental savepoints - posted by Piotr Nowojski <pn...@apache.org> on 2022/01/24 08:56:46 UTC, 8 replies.
- [ANNOUNCE] flink-shaded 15.0 released - posted by Chesnay Schepler <ch...@apache.org> on 2022/01/24 09:58:22 UTC, 3 replies.
- [jira] [Created] (FLINK-25773) Upgrade to flink-shaded 15.0 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/01/24 10:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25774) Restrict the maximum number of buffers can be used per result partition for blocking shuffle - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2022/01/24 10:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25775) Document JavaScript SDK - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/01/24 10:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25776) Sync netty bugfix version across the project - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/01/24 10:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25777) Generate documentation for Table factories (formats and connectors) - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/01/24 10:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25779) Define ConfigOption for properties map in Kinesis - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/01/24 10:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25778) Define ConfigOption for properties map in Kafka - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/01/24 10:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25780) Reduce the maximum number of data output buffers for sort-shuffle - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2022/01/24 11:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25781) Adjust the maximum number of buffers can be used per result partition for shuffle data read - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2022/01/24 11:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25782) Translate datastream filesystem.md page into Chinese. - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2022/01/24 12:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25783) Translate azure_table_storage.md page into Chinese. - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2022/01/24 12:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25784) SerializedThrowable(De)Serializer out of sync - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/01/24 12:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25785) Update com.h2database:h2 to 2.0.206 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/01/24 12:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25786) Adjust the generation of subpartition data storage order for sort-shuffle from random shuffle to random shift - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2022/01/24 13:07:00 UTC, 0 replies.
- [DISCUSS] Releasing Flink 1.13.6 - posted by Martijn Visser <ma...@ververica.com> on 2022/01/24 13:52:23 UTC, 4 replies.
- [jira] [Created] (FLINK-25787) Adding endpoint support in Pubsub Source / Sink - posted by "Md Mehrab Alam (Jira)" <ji...@apache.org> on 2022/01/24 14:03:00 UTC, 0 replies.
- [RESULT][VOTE] Creating external connector repositories - posted by Martijn Visser <ma...@ververica.com> on 2022/01/24 14:05:19 UTC, 0 replies.
- [RESULT][VOTE] Moving connectors from Flink to external connector repositories - posted by Martijn Visser <ma...@ververica.com> on 2022/01/24 14:05:21 UTC, 0 replies.
- [DISCUSS] Host StatefulFunction JavaScript SDK on npm - posted by Till Rohrmann <tr...@apache.org> on 2022/01/24 14:37:48 UTC, 9 replies.
- [jira] [Created] (FLINK-25788) Add show connectors command - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/01/24 14:40:00 UTC, 0 replies.
- [DISCUSS] Stateful Functions 3.2.0 release? - posted by Till Rohrmann <tr...@apache.org> on 2022/01/24 14:45:22 UTC, 5 replies.
- [jira] [Created] (FLINK-25789) Translate the formats/hadoop page into Chinese. - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2022/01/24 15:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25790) Support authentication via core-site.xml in GCS FileSystem plugin - posted by "Galen Warren (Jira)" <ji...@apache.org> on 2022/01/24 16:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25791) Make ObjectIdentifier json representation simpler - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/01/24 16:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25792) Async Sink Base is too being flushed too frequently resulting in backpressure even when buffer is near empty - posted by "Zichen Liu (Jira)" <ji...@apache.org> on 2022/01/24 19:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25793) Kinesis Data Streams sink is not limiting throughput to the destination and therefore exceeding rate limits - posted by "Zichen Liu (Jira)" <ji...@apache.org> on 2022/01/24 19:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25794) Memory pages in LazyMemorySegmentPool should be clear after they are released to MemoryManager - posted by "Shammon (Jira)" <ji...@apache.org> on 2022/01/25 02:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25795) Support Pulsar sink connector in Python DataStream API. - posted by "Ada Wong (Jira)" <ji...@apache.org> on 2022/01/25 02:16:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-204: Introduce Hash Lookup Join - posted by Jing Zhang <be...@gmail.com> on 2022/01/25 02:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25796) Avoid record copy for result partition of sort-shuffle if there are enough buffers for better performance - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2022/01/25 03:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25797) Translate datastream/formats/parquet.md page into Chinese. - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2022/01/25 04:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25798) Translate datastream/formats/text_files.md page into Chinese. - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2022/01/25 04:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25799) Translate table/filesystem.md page into Chinese. - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2022/01/25 04:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25800) Update wrong links in the datastream/execution_mode.md page. - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2022/01/25 04:57:00 UTC, 0 replies.
- [DISCUSS] FLIP-212: Introduce Flink Kubernetes Operator - posted by Thomas Weise <th...@apache.org> on 2022/01/25 05:08:01 UTC, 7 replies.
- [jira] [Created] (FLINK-25801) add cpu processor metric of taskmanager - posted by "王俊博 (Jira)" <ji...@apache.org> on 2022/01/25 06:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25802) OverWindow in batch mode failed - posted by "Zoyo Pei (Jira)" <ji...@apache.org> on 2022/01/25 07:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25803) Implement partition and bucket filter of FileStoreScanImpl - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/01/25 08:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25804) Loading and running connector code use separated ClassLoader. - posted by "Ada Wong (Jira)" <ji...@apache.org> on 2022/01/25 09:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25805) Use compact DataType serialization for default classes instead of internal ones - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2022/01/25 10:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25806) Remove legacy high availability services - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/01/25 14:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25807) Generated SubtaskExecutionAttemptDetailsInfo contains duplicate property - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/01/25 14:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25808) JsonTypeInfo property should be valid java identifier - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/01/25 15:05:00 UTC, 0 replies.
- Flink 1.15. Bi-weekly 2022-01-25 - posted by Johannes Moser <jo...@ververica.com> on 2022/01/25 15:36:25 UTC, 0 replies.
- [DISCUSS] Pushing Apache Flink 1.15 Feature Freeze - posted by Johannes Moser <jo...@ververica.com> on 2022/01/25 15:38:19 UTC, 7 replies.
- [jira] [Created] (FLINK-25809) Introduce test infra for building FLIP-190 tests - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/01/25 15:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25810) [FLIP-171] Add Uber-jar for sql connector for KinesisDataStreams. - posted by "Ahmed Hamdy (Jira)" <ji...@apache.org> on 2022/01/25 16:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25811) Fix generic AsyncSinkWriter retrying requests in reverse order - posted by "Ahmed Hamdy (Jira)" <ji...@apache.org> on 2022/01/25 17:24:00 UTC, 0 replies.
- [VOTE] Apache Flink Stateful Functions 3.2.0, release candidate #1 - posted by Till Rohrmann <tr...@apache.org> on 2022/01/25 21:49:45 UTC, 7 replies.
- [jira] [Created] (FLINK-25812) Show Plan in Ui doesn't show. - posted by "None none (Jira)" <ji...@apache.org> on 2022/01/25 22:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25813) TableITCase.testCollectWithClose failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/01/26 02:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25814) AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstSavepointSucceedOnSecond failed due to stop-with-savepoint failed - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/01/26 03:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25815) PulsarSourceITCase.testTaskManagerFailure failed on azure due to timeout - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/01/26 03:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25816) Changelog keyed state backend would come across NPE during notification - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2022/01/26 03:34:00 UTC, 0 replies.
- PR Review Request - posted by Jing Zhang <be...@gmail.com> on 2022/01/26 06:55:31 UTC, 1 replies.
- Re: Looking for Maintainers for Flink on YARN - posted by Konstantin Knauf <ko...@ververica.com> on 2022/01/26 09:17:03 UTC, 6 replies.
- [jira] [Created] (FLINK-25817) FLIP-201: Persist local state in working directory - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/01/26 09:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25818) Add explanation how Kafka Source deals with idleness when parallelism is higher then the number of partitions - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/01/26 09:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25819) NetworkBufferPoolTest.testIsAvailableOrNotAfterRequestAndRecycleMultiSegments fails on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/01/26 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25820) Introduce Table Store Flink Source - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/01/26 10:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25821) Add the doc of execution mode in PyFlink - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/01/26 11:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25822) Migrate away from using Source- and SinkFunctions for internal tests - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2022/01/26 12:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25823) Remove Mesos from Flink Landing page - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/01/26 13:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25824) E2e test phase fails on AZP after "Unable to locate package moreutils" - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/01/26 13:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25825) MySqlCatalogITCase fails on azure - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/01/26 13:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25826) Handle symbols at a central place with serializable format - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2022/01/26 13:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25828) build_stateful_functions.sh can fail if target contains source or javadoc jar - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/01/26 14:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25829) Do not deploy empty statefun-sdk-js jar - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/01/26 14:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25830) Typo mistake in "Metric Report page" of the documentation - posted by "ChengKai Yang (Jira)" <ji...@apache.org> on 2022/01/26 14:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25831) ExecutionVertex.getLatestPriorAllocation fails if there is an unsuccessful restart attempt - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/01/26 15:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25832) When the TaskManager is closed, its associated slot is not set to the released state. - posted by "john (Jira)" <ji...@apache.org> on 2022/01/27 02:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25833) FlinkUserCodeClassLoader is not registered as parallel capable - posted by "nicolasyang (Jira)" <ji...@apache.org> on 2022/01/27 03:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25834) 'flink run' command can not use 'pipeline.classpaths' in flink-conf.yaml - posted by "Ada Wong (Jira)" <ji...@apache.org> on 2022/01/27 03:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25835) The task initialization duration is recorded in logs - posted by "Bo Cui (Jira)" <ji...@apache.org> on 2022/01/27 04:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25836) test_keyed_process_function_with_state of BatchModeDataStreamTests faild in PyFlink - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/01/27 04:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25837) RPC Serialization failure when multiple job managers - posted by "Matthew McMahon (Jira)" <ji...@apache.org> on 2022/01/27 05:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25838) BatchArrowPythonOverWindowAggregateFunctionOperatorTest. testFinishBundleTriggeredByTime failed in Azure - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/01/27 06:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25839) 'Run kubernetes application HA test' failed on azure due to could not get 3 completed checkpoints in 120 sec - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/01/27 07:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25840) Add semantic test support in the connector testframe - posted by "Hang Ruan (Jira)" <ji...@apache.org> on 2022/01/27 08:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25841) Expose plan via TableEnvironment.compilePlanSql/executePlan - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2022/01/27 08:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25842) [v2] FLIP-158: Generalized incremental checkpoints - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/01/27 08:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25843) Expose plan via Table.compilePlan/TableEnvironment.fromPlan - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2022/01/27 09:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25844) Expose plan via StatementSet.compilePlan - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2022/01/27 09:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25845) Expose plan via SQL COMPILE / EXECUTE PLAN - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2022/01/27 09:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25846) Async Sink does not gracefully shutdown on Cancel - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2022/01/27 09:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25847) KubernetesHighAvailabilityRecoverFromSavepointITCase. testRecoverFromSavepoint failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/01/27 09:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25848) [FLIP-171] KDS Sink does not fast fail when invalid configuration supplied - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2022/01/27 09:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25849) Differentiate TaskManager sessions - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/01/27 10:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25850) Consider notifying nested state backend about checkpoint abortion - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/01/27 10:29:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-203: Incremental savepoints - posted by Piotr Nowojski <pn...@apache.org> on 2022/01/27 10:32:45 UTC, 0 replies.
- [jira] [Created] (FLINK-25851) CassandraConnectorITCase.testRetrialAndDropTables shows table already exists errors on AZP - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2022/01/27 10:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25852) Annotate SourceFunction and SinkFunction as deprecated - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/01/27 12:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25853) Annotate current JDBC connector as deprecated to prepare for new JDBC connector - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/01/27 12:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25854) Annotate legacy FileSource as deprecated - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/01/27 12:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25855) DefaultDeclarativeSlotPool rejects offered slots when the job is restarting - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/01/27 12:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25856) Fix use of UserDefinedType in from_elements - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/01/27 12:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25857) Add committer metrics to track the status of committables - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2022/01/27 13:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25858) Remove ArchUnit rules for JUnit 4 in ITCaseRules the JUnit 4->5 migration is closed - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/01/27 17:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25859) Add documentation for DynamoDB Async Sink - posted by "Yuri Gusev (Jira)" <ji...@apache.org> on 2022/01/27 18:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25860) Move read buffer allocation and output file creation to setup method for sort-shuffle result partition to avoid blocking main thread - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2022/01/28 03:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25861) Move states of AbstractAvroBulkFormat into its reader - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/01/28 03:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25862) Refactor SharedStateRegistry to limit StreamStateHandle to register/unregister - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2022/01/28 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25863) Implement Matomo - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/01/28 09:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25864) Implement Matomo on Flink project website - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/01/28 09:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25865) Support to set restart policy of TaskManager pod for native K8s integration - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/01/28 10:58:00 UTC, 0 replies.
- Stack Overflow Question - Deserialization schema for multiple topics - posted by Hussein El Ghoul <hu...@quiqup.com> on 2022/01/28 11:00:03 UTC, 1 replies.
- [jira] [Created] (FLINK-25866) Support additional TLS configuration. - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2022/01/28 11:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25867) [ZH] Add ChangelogBackend documentation - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/01/28 13:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25868) Enable japicmp for all modules - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/01/28 13:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25869) Create a stress test cron build - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2022/01/28 14:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25870) Introduce ContextResolvedFunction similar to ContextResolvedTable - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2022/01/28 14:46:00 UTC, 0 replies.
- [VOTE] Deprecate Per-Job Mode in Flink 1.15 - posted by Konstantin Knauf <kn...@apache.org> on 2022/01/28 15:30:31 UTC, 8 replies.
- [jira] [Created] (FLINK-25871) "License Check failed" on AZP - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/01/28 16:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25872) Restoring from incremental checkpoint with changelog state-backend cannot work well with snapshot CLAIM mode - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2022/01/28 17:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25873) Using RocksDB state backend causes java.lang.ClassNotFoundException: org.apache.flink.runtime.state.CheckpointStreamFactory$CheckpointStateOutputStream - posted by "Galen Warren (Jira)" <ji...@apache.org> on 2022/01/28 18:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25874) PyFlink package dependencies conflict - posted by "Martin Liu (Jira)" <ji...@apache.org> on 2022/01/29 01:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25875) "StatsDReporter. FilterCharacters" for special processing of the characters are comprehensive enough - posted by "赵富午 (Jira)" <ji...@apache.org> on 2022/01/29 04:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25876) Implement overwrite in FileStoreScanImpl - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/01/29 07:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25877) Update the copyright year in NOTICE files - posted by "nyingping (Jira)" <ji...@apache.org> on 2022/01/29 09:58:00 UTC, 0 replies.
- [Consulting] Should a Flink class loader be a singleton? - posted by Zhiping Wu <st...@gmail.com> on 2022/01/30 03:21:02 UTC, 1 replies.
- [jira] [Created] (FLINK-25878) Update privacy policy to reflect change from Google Analytics to Matomo - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/01/30 13:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25879) Track used search terms in Matomo - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/01/30 13:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25880) Implement Matomo in Flink documentation - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/01/30 13:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25881) Measure visits on flink.apache.org and nightlies.apache.org/flink as the same visit - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/01/30 13:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25882) Translate updated privacy policy to Chinese - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/01/30 13:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25883) The value of DEFAULT_BUNDLE_PROCESSOR_CACHE_SHUTDOWN_THRESHOLD_S is too large - posted by "Mikhail (Jira)" <ji...@apache.org> on 2022/01/30 23:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25884) PulsarSourceITCase.testTaskManagerFailure failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/01/31 06:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25885) ClusterEntrypointTest.testWorkingDirectoryIsDeletedIfApplicationCompletes failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/01/31 06:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25886) Hard-coded ZK version in FlinkContainersBuilder#buildZookeeperContainer - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/01/31 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25887) FLIP-193: Snapshots ownership follow ups - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2022/01/31 08:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25888) Capture time that the job spends on deploying tasks - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/01/31 09:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25890) Implement scroll tracking on Flink documentation - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/01/31 09:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25889) Implement scroll tracking on Flink project website - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/01/31 09:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25891) NoClassDefFoundError AsyncSSLPrivateKeyMethod in benchmark - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2022/01/31 10:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25892) Develop ArchUnit test for connectors - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/01/31 10:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25893) ResourceManagerServiceImpl's lifecycle can lead to exceptions - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/01/31 10:23:00 UTC, 0 replies.
- [VOTE] Deprecate NiFi connector - posted by Martijn Visser <ma...@ververica.com> on 2022/01/31 10:46:30 UTC, 0 replies.
- [VOTE] Remove Twitter connector - posted by Martijn Visser <ma...@ververica.com> on 2022/01/31 10:46:37 UTC, 0 replies.
- [VOTE] Deprecate Cassandra connector - posted by Martijn Visser <ma...@ververica.com> on 2022/01/31 10:46:45 UTC, 1 replies.
- JDBC: Support connection pooling - posted by Dario Heinisch <da...@gmail.com> on 2022/01/31 12:45:57 UTC, 0 replies.
- [RESULT][VOTE] Apache Flink Stateful Functions 3.2.0, release candidate #1 - posted by Till Rohrmann <tr...@apache.org> on 2022/01/31 13:54:56 UTC, 0 replies.
- [jira] [Created] (FLINK-25894) Explicitly configure japicmp oldVersion for flink-streaming-java - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/01/31 14:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25895) Add ExecNodeGraph ser/de - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/01/31 14:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25896) Buffer debloating issues with high parallelism - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2022/01/31 15:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25897) Update project configuration gradle doc to 7.x version - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/01/31 15:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25898) Add README.md to flink-statefun/statefun-sdk-js - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/01/31 16:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25899) Add Java connected components example to flink-statefun-playground - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/01/31 18:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25900) Create view example does not assign alias to functions resulting in generated names like EXPR$5 - posted by "Mans Singh (Jira)" <ji...@apache.org> on 2022/01/31 23:55:00 UTC, 0 replies.