You are viewing a plain text version of this content. The canonical link for it is here.
- Re: [DISCUSS] FLIP-274 : Introduce metric group for OperatorCoordinator - posted by Dong Lin <li...@gmail.com> on 2023/01/01 01:44:03 UTC, 18 replies.
- [jira] [Created] (FLINK-30537) Add support for OpenSearch 2.3 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2023/01/01 11:54:00 UTC, 0 replies.
- [VOTE] Apache Flink Kubernetes Operator Release 1.3.1, release candidate #1 - posted by Gyula Fóra <gy...@apache.org> on 2023/01/01 18:42:30 UTC, 9 replies.
- [jira] [Created] (FLINK-30538) Improve error handling of stop job operation - posted by "Paul Lin (Jira)" <ji...@apache.org> on 2023/01/02 07:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30539) YARNSessionCapacitySchedulerITCase.testDetachedPerJobYarnCluster and testDetachedPerJobYarnClusterWithStreamingJob timing out - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/02 10:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30540) DataSinkTaskTest failed with a 143 exit code - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/02 10:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30541) Add Transformer and Estimator for OnlineStandardScaler - posted by "Zhipeng Zhang (Jira)" <ji...@apache.org> on 2023/01/02 16:29:00 UTC, 0 replies.
- Re: Flink Forward Session Question - posted by Márton Balassi <ba...@gmail.com> on 2023/01/02 17:34:31 UTC, 0 replies.
- [jira] [Created] (FLINK-30542) Support adaptive hash aggregate in runtime - posted by "Yunhong Zheng (Jira)" <ji...@apache.org> on 2023/01/03 01:48:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-283: Use adaptive batch scheduler as default scheduler for batch jobs - posted by Lijie Wang <wa...@gmail.com> on 2023/01/03 03:03:01 UTC, 3 replies.
- Re: [DISCUSS] FLIP-266: Simplify network memory configurations for TaskManager - posted by Yuxin Tan <ta...@gmail.com> on 2023/01/03 03:18:26 UTC, 0 replies.
- Re: [DISCUSS] Extending the feature freezing date of Flink 1.17 - posted by David Anderson <da...@apache.org> on 2023/01/03 03:41:05 UTC, 6 replies.
- Re: [EXTERNAL] Re: [DISCUSS] Add Flink Web3 Connector - posted by Junyao Huang <Ju...@microsoft.com.INVALID> on 2023/01/03 03:46:08 UTC, 0 replies.
- [DISCUSS] Allow source readers extending SourceReaderBase to override numRecordsIn report logic - posted by Wencong Liu <li...@163.com> on 2023/01/03 03:49:35 UTC, 17 replies.
- Re: [DISCUSS] FLIP-282: Introduce Delete & Update API - posted by Jingsong Li <ji...@gmail.com> on 2023/01/03 04:12:12 UTC, 4 replies.
- [jira] [Created] (FLINK-30543) Adding more examples for setting up jobs via operator. - posted by "Sriram Ganesh (Jira)" <ji...@apache.org> on 2023/01/03 04:17:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-280: Introduce a new explain mode to provide SQL advice - posted by Shengkai Fang <fs...@gmail.com> on 2023/01/03 04:26:25 UTC, 7 replies.
- [jira] [Created] (FLINK-30544) Speed up finding minimum watermark across all channels by introducing heap-based algorithm - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2023/01/03 04:33:00 UTC, 0 replies.
- Re: [DISCUSS] Adding a option for planner to decide which join reorder rule to choose - posted by Benchao Li <li...@apache.org> on 2023/01/03 04:53:38 UTC, 8 replies.
- [jira] [Created] (FLINK-30545) The SchemaManager doesn't check 'NOT NULL' specification when committing AddColumn change - posted by "yuzelin (Jira)" <ji...@apache.org> on 2023/01/03 07:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30546) WindowDeduplicate didn't write result to sink timely - posted by "kevinshin (Jira)" <ji...@apache.org> on 2023/01/03 08:39:00 UTC, 0 replies.
- Fw:WindowDeduplicate didn't write result to sink effectiveness as expected - posted by lk_hadoop <lk...@163.com> on 2023/01/03 08:49:04 UTC, 0 replies.
- [jira] [Created] (FLINK-30547) Flink-table-runtime free for flink-table-store-common - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/01/03 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30548) In some cases AvroDeserializationSchema buffer is not reset - posted by "heyu dou (Jira)" <ji...@apache.org> on 2023/01/03 09:44:00 UTC, 0 replies.
- [VOTE]FLIP-266: Simplify network memory configurations for TaskManager - posted by Yuxin Tan <ta...@gmail.com> on 2023/01/03 09:56:44 UTC, 5 replies.
- [jira] [Created] (FLINK-30549) Remove flink-connector-firehose from Flink master branch - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2023/01/03 10:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30550) Flink master to integrate KDS/KDF docs from flink-connector-aws - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2023/01/03 10:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30551) Add open method to PartitionCommitPolicy - posted by "Aitozi (Jira)" <ji...@apache.org> on 2023/01/03 11:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30552) Pulsar connector shouldn't assert the BatchMessageId size. - posted by "Yufan Sheng (Jira)" <ji...@apache.org> on 2023/01/03 12:14:00 UTC, 0 replies.
- [DISCUSS] FLIP-284: Making AsyncSinkWriter Flush triggers adjustable - posted by "Hamdy, Ahmed" <va...@amazon.co.uk.INVALID> on 2023/01/03 12:28:54 UTC, 0 replies.
- [VOTE] FLIP-274: Introduce metric group for OperatorCoordinator - posted by Hang Ruan <ru...@gmail.com> on 2023/01/04 02:07:54 UTC, 17 replies.
- Re: [DISCUSS] FLIP-281 Sink Supports Speculative Execution For Batch Job - posted by Lijie Wang <wa...@gmail.com> on 2023/01/04 04:10:50 UTC, 10 replies.
- [jira] [Created] (FLINK-30553) checkpoint always IN-PROGRESS because of hdfs - posted by "linqichen (Jira)" <ji...@apache.org> on 2023/01/04 06:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30554) Remove useless session id in the Sql Client Executor - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2023/01/04 06:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30555) Hive cluster can not read oss/s3 tables - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/01/04 07:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30556) Improve the logic for enumerating splits for Hive source to avoid potential OOM - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2023/01/04 08:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30557) Remove flink-connector-aws-kinesis-streams from Flink master branch - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2023/01/04 08:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30558) The metric 'numRestarts' reported in SchedulerBase will be overridden by metric 'fullRestarts' - posted by "xingbe (Jira)" <ji...@apache.org> on 2023/01/04 10:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30559) May get wrong result for `if` expression if it's string data type - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2023/01/04 10:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30560) Add more description of 'Overwriting a Partition' to doc 'Writing Tables' - posted by "yuzelin (Jira)" <ji...@apache.org> on 2023/01/04 11:26:00 UTC, 0 replies.
- [VOTE] FLIP-281: Sink Supports Speculative Execution For Batch Job - posted by Biao Liu <mm...@gmail.com> on 2023/01/04 12:30:54 UTC, 9 replies.
- Re: [DISCUSS] Release Flink 1.16.1 - posted by Lincoln Lee <li...@gmail.com> on 2023/01/04 12:47:42 UTC, 3 replies.
- [jira] [Created] (FLINK-30561) ChangelogStreamHandleReaderWithCache cause FileNotFoundException - posted by "Feifan Wang (Jira)" <ji...@apache.org> on 2023/01/04 12:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30562) Patterns are not emitted with parallelism >1 since 1.15.x+ - posted by "Thomas Wozniakowski (Jira)" <ji...@apache.org> on 2023/01/04 14:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30563) Update training exercises to use Flink 1.16 - posted by "David Anderson (Jira)" <ji...@apache.org> on 2023/01/04 16:49:00 UTC, 0 replies.
- Re: CDC from Oracle database reading directly logs - integration with OpenLogReplicator - posted by Adam Leszczyński <al...@bersler.com> on 2023/01/04 23:32:53 UTC, 6 replies.
- [jira] [Created] (FLINK-30564) Select from a new table with Kafka LogStore crashes with UnknownTopicOrPartitionException - posted by "Alex Sorokoumov (Jira)" <ji...@apache.org> on 2023/01/04 23:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30565) Flink-parquet free for flink-table-store-format - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/01/05 03:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30566) Add benchmark configurations for agglomerativeclustering, hashingtf, idf, kbinsdiscretizer, linearregression, linearsvc, logisticregression, ngram, regextokenizer, tokenizer and vectorindexer - posted by "Zhipeng Zhang (Jira)" <ji...@apache.org> on 2023/01/05 04:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30567) Wrong insert overwrite behavior when the table contains uppercase character with Hive dialect - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2023/01/05 04:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30568) Add benchmark for PolyNomialExpansion, Normalizer, Binarizer, Interaction, MaxAbsScaler, VectorSlicer, ElementWiseProduct and Featurehasher - posted by "weibo zhao (Jira)" <ji...@apache.org> on 2023/01/05 04:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30569) File Format can not change with data file exists - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/01/05 06:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30570) RexNodeExtractor#isSupportedPartitionPredicate generates unexpected partition predicates - posted by "Aitozi (Jira)" <ji...@apache.org> on 2023/01/05 09:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30571) Compute scale parallelism based on observed scalability - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2023/01/05 09:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30572) Make parquet as default data file format - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/01/05 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30573) Table Store dedicated compact job may skip some records when checkpoint interval is long - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2023/01/05 09:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30574) Do not scale further up if last scaling was ineffective - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2023/01/05 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30575) Autoscaler doesn't scale down on 0 load - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2023/01/05 12:30:00 UTC, 0 replies.
- [DISCUSS] FLIP-285: Refactoring the leader election code base in Flink - posted by Matthias Pohl <ma...@aiven.io.INVALID> on 2023/01/05 13:49:50 UTC, 11 replies.
- [jira] [Created] (FLINK-30576) JdbcOutputFormat refactor - posted by "João Boto (Jira)" <ji...@apache.org> on 2023/01/05 14:39:00 UTC, 0 replies.
- flink add multiple sink in sequence - posted by Great Info <gu...@gmail.com> on 2023/01/05 15:48:10 UTC, 3 replies.
- [jira] [Created] (FLINK-30577) OpenShift FlinkSessionJob artifact write error on non-default namespaces - posted by "James Busche (Jira)" <ji...@apache.org> on 2023/01/05 20:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30578) AVRO-3700: Publish SBOM artifacts - posted by "Dongjoon Hyun (Jira)" <ji...@apache.org> on 2023/01/06 00:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30579) Introducing cofigurable option to enable hive native function - posted by "dalongliu (Jira)" <ji...@apache.org> on 2023/01/06 02:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30580) [umbrella] Refactor tests for table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/01/06 03:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30581) Deprecate FileStoreTableITCase and use CatalogITCaseBase - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/01/06 03:13:00 UTC, 0 replies.
- [ANNOUNCE] Flink 1.17 feature freeze extended until January 31st, 2023 - posted by Qingsheng Ren <re...@apache.org> on 2023/01/06 04:00:43 UTC, 0 replies.
- [jira] [Created] (FLINK-30582) Flink-avro Flink-orc free for flink-table-store-format - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/01/06 05:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30583) Provide the flame graph to the subtask level - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2023/01/06 07:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30584) Update the flame graph doc of subtask level - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2023/01/06 07:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30585) Improve flame graph performance at subtask level - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2023/01/06 07:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30586) Fix calcCodeGen failed if calc with like condition contains double quotation mark - posted by "Yunhong Zheng (Jira)" <ji...@apache.org> on 2023/01/06 08:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30587) Validate primary key in an append-only table in ddl - posted by "Shammon (Jira)" <ji...@apache.org> on 2023/01/06 08:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30588) Improvement in truncate code in the new ABFSOutputstream - posted by "ramkrishna.s.vasudevan (Jira)" <ji...@apache.org> on 2023/01/06 08:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30589) Snapshot expiration should be skipped in Table Store dedicated writer jobs - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2023/01/06 09:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30590) Remove set default value manual for table options - posted by "Shammon (Jira)" <ji...@apache.org> on 2023/01/06 09:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30591) Stateful functions SDK for Flink DataStream Integration example is not available - posted by "Utopia (Jira)" <ji...@apache.org> on 2023/01/06 09:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30592) The unsupported hive version is not deleted on the hive overview document - posted by "chrismartin (Jira)" <ji...@apache.org> on 2023/01/06 10:44:00 UTC, 0 replies.
- [RESULT][VOTE]FLIP-266: Simplify network memory configurations for TaskManager - posted by Yuxin Tan <ta...@gmail.com> on 2023/01/06 11:16:50 UTC, 0 replies.
- [jira] [Created] (FLINK-30593) Determine restart time on the fly for Autoscaler - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2023/01/06 12:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30594) Update Java version because of JDK bug in the operator - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2023/01/06 15:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30595) support create table like - posted by "Jun Zhang (Jira)" <ji...@apache.org> on 2023/01/06 16:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30596) Multiple POST /jars/:jarid/run requests with the same jobId, runs duplicate jobs - posted by "Mohsen Rezaei (Jira)" <ji...@apache.org> on 2023/01/06 21:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30597) Refactor FlinkProjectJoinTransposeRule and FlinkPruneEmptyRules - posted by "Bo Cui (Jira)" <ji...@apache.org> on 2023/01/08 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30598) Wrong code generated for WatermarkGenerator because of inconsistent source type info when deserialized from exec plan - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2023/01/08 14:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30599) Publish SBOM for k8s operator - posted by "Márton Balassi (Jira)" <ji...@apache.org> on 2023/01/08 21:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30600) Merge flink-table-store-kafka to flink-table-store-connector - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/01/09 02:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30601) Omit "setKeyContextElement" call for non-keyed stream/operators to improve performance - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2023/01/09 04:19:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-279 Unified the max display column width for SqlClient and Table APi in both Streaming and Batch execMode - posted by Jing Ge <ji...@ververica.com.INVALID> on 2023/01/09 05:03:59 UTC, 2 replies.
- [jira] [Created] (FLINK-30602) Remove FileStoreTableITCase in table store - posted by "Shammon (Jira)" <ji...@apache.org> on 2023/01/09 05:12:00 UTC, 0 replies.
- [DISCUSS] Check and add sql-connector uber jar e2e tests - posted by weijie guo <gu...@gmail.com> on 2023/01/09 05:47:08 UTC, 4 replies.
- [jira] [Created] (FLINK-30603) CompactActionITCase in table store is unstable - posted by "Shammon (Jira)" <ji...@apache.org> on 2023/01/09 06:25:00 UTC, 0 replies.
- [VOTE] FLIP-279 Unified the max display column width for SqlClient and Table APi in both Streaming and Batch execMode - posted by Jing Ge <ji...@ververica.com.INVALID> on 2023/01/09 07:46:00 UTC, 5 replies.
- [jira] [Created] (FLINK-30604) Remove the limitation of that parallelism decided by adaptive batch scheduler must be power-of-two - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2023/01/09 08:20:00 UTC, 0 replies.
- [VOTE] FLIP-282: Introduce Delete & Update API - posted by yuxia <lu...@alumni.sjtu.edu.cn> on 2023/01/09 09:42:36 UTC, 5 replies.
- [VOTE] FLIP-280: Introduce EXPLAIN PLAN_ADVICE to provide SQL advice - posted by Jane Chan <qi...@gmail.com> on 2023/01/09 10:18:51 UTC, 4 replies.
- [jira] [Created] (FLINK-30605) 'Streaming File Sink end-to-end test' fails with UnsupportedOperationException - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/09 12:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30606) Bump Pulsar to 2.11.0 - posted by "Yufan Sheng (Jira)" <ji...@apache.org> on 2023/01/09 13:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30607) Table.to_pandas doesn't support Map type - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2023/01/09 14:19:00 UTC, 0 replies.
- [Discussion] externalize Hive connector - posted by Chen Qin <qi...@gmail.com> on 2023/01/09 15:21:17 UTC, 8 replies.
- [jira] [Created] (FLINK-30608) support rename table - posted by "Jun Zhang (Jira)" <ji...@apache.org> on 2023/01/09 15:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30609) Add ephemeral storage to CRD - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2023/01/09 18:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30610) Flink-table-runtime free for disk io in flink-core - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/01/10 03:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30611) Expire snapshot should be reentrant - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/01/10 03:23:00 UTC, 0 replies.
- [VOTE] FLIP-283: Use adaptive batch scheduler as default scheduler for batch jobs - posted by Junrui Lee <jr...@gmail.com> on 2023/01/10 03:30:16 UTC, 5 replies.
- [jira] [Created] (FLINK-30612) ObjectArrayConverter is not thread-safe，raised by reuseArray、reuseWriter - posted by "guoxin (Jira)" <ji...@apache.org> on 2023/01/10 03:31:00 UTC, 0 replies.
- [ANNOUNCE] New Apache Flink Committer - Lincoln Lee - posted by Jark Wu <im...@gmail.com> on 2023/01/10 03:52:13 UTC, 36 replies.
- [jira] [Created] (FLINK-30613) Improve resolving schema compatibility -- Milestone one - posted by "Hangxiang Yu (Jira)" <ji...@apache.org> on 2023/01/10 04:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30614) Improve resolving schema compatibility -- Milestone two - posted by "Hangxiang Yu (Jira)" <ji...@apache.org> on 2023/01/10 04:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30615) Refactor ReadWriteTableITCase to get rid of Managed Table - posted by "yuzelin (Jira)" <ji...@apache.org> on 2023/01/10 04:26:00 UTC, 0 replies.
- [RESULT] [VOTE] Apache Flink Kubernetes Operator Release 1.3.1, release candidate #1 - posted by Gyula Fóra <gy...@apache.org> on 2023/01/10 05:40:36 UTC, 0 replies.
- [jira] [Created] (FLINK-30616) Don't support batchMessageId when restore from checkpoint - posted by "songv (Jira)" <ji...@apache.org> on 2023/01/10 07:54:00 UTC, 0 replies.
- [VOTE] Apache Flink Table Store 0.3.0, release candidate #1 - posted by Jingsong Li <ji...@gmail.com> on 2023/01/10 08:52:24 UTC, 6 replies.
- [jira] [Created] (FLINK-30617) Wrong data type for null literal in Hive dialect - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2023/01/10 10:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30618) flink-connector-pulsar not retrievable from Apache's Snapshot Maven repository - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/10 10:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30619) AdaptiveSchedulerTest.testStatusMetrics is not stable - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/10 10:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30620) Table Store Hive catalog supports specifying custom Hive metastore client - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2023/01/10 11:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30621) Violation of main thread constraint detected - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/10 11:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30622) Support auto consume schema in Pulsar source - posted by "Yufan Sheng (Jira)" <ji...@apache.org> on 2023/01/10 12:18:00 UTC, 0 replies.
- Re: [ANNOUNCE] Performance Daily Monitoring Moved from Ververica to Apache Flink Slack Channel - posted by Matthias Pohl <ma...@aiven.io.INVALID> on 2023/01/10 12:54:28 UTC, 7 replies.
- [ANNOUNCE] Apache Flink Kubernetes Operator 1.3.1 released - posted by Gyula Fóra <gy...@apache.org> on 2023/01/10 14:34:11 UTC, 0 replies.
- [jira] [Created] (FLINK-30623) Performance regression in checkpointSingleInput.UNALIGNED on 04.01.2023 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2023/01/10 17:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30624) Performance regression in stateBackends.FS / FS_ASYNC / MEMORY on 05.01.2023 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2023/01/10 17:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30625) Performance regression in tumblingWindow on 06.01.2023 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2023/01/10 17:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30626) RabbitMQ connector has dependency convergence error for org.junit.jupiter:junit-jupiter - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2023/01/10 21:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30627) Refactor FileSystemTableSink to use FileSink instead of StreamingFileSink - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2023/01/10 21:29:00 UTC, 0 replies.
- [SUMMARY] Flink 1.17 Release Sync 1/10/2023 - posted by Qingsheng Ren <re...@apache.org> on 2023/01/11 02:25:53 UTC, 0 replies.
- [jira] [Created] (FLINK-30628) Kerberos in HiveCatalog is not work - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/01/11 04:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30629) ClientHeartbeatTest.testJobRunningIfClientReportHeartbeat is unstable - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2023/01/11 08:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30630) Python: BatchModeDataStreamTests.test_keyed_map failed - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/11 08:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30631) Limit the max number of subpartitons consumed by each downstream task - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2023/01/11 08:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30632) Introduce DataType for table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/01/11 08:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30633) Update AWS SDKv2 to v2.19.14 - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2023/01/11 09:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30634) HiveTableSourceITCase.setupSourceDatabaseAndData fails with InvalidObjectException - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/11 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30635) Fail to recover for row-format when writing to OSS using FileSystemTable connector - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2023/01/11 09:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30636) Typo fix: "to to" -> "to" - posted by "Gunnar Morling (Jira)" <ji...@apache.org> on 2023/01/11 10:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30637) In linux-aarch64 environment, using “is” judgment to match the window type of overwindow have returned incorrect matching results - posted by "Xin Chen (Jira)" <ji...@apache.org> on 2023/01/11 12:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30638) Operator doesn't forward allowNonRestoredState flag - posted by "Alexis Sarda-Espinosa (Jira)" <ji...@apache.org> on 2023/01/11 14:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30639) Publish SBOM for externalized connectors - posted by "Márton Balassi (Jira)" <ji...@apache.org> on 2023/01/11 15:24:00 UTC, 0 replies.
- Re: "Introduction to Apache Flink" presentation - posted by Ryan Skraba <ry...@aiven.io.INVALID> on 2023/01/11 17:36:18 UTC, 0 replies.
- [jira] [Created] (FLINK-30640) Unstable test in CliClientITCase - posted by "yuzelin (Jira)" <ji...@apache.org> on 2023/01/12 06:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30641) docs_404_check fail - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2023/01/12 07:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30642) CsvFileCompactionITCase>CompactionITCaseBase.testPartition timed out - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2023/01/12 08:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30643) docs_check fails - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/12 08:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30644) ChangelogCompatibilityITCase.testRestore fails due to CheckpointCoordinator being shutdown - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/12 08:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30645) [FLIP-286] The scope/stability annotation in AbstractStreamOperator are inconsistent. - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2023/01/12 09:12:00 UTC, 0 replies.
- [DISCUSS] FLIP-286: Fix the API stability/scope annotation inconsistency in AbstractStreamOperator - posted by Becket Qin <be...@gmail.com> on 2023/01/12 09:20:44 UTC, 6 replies.
- [jira] [Created] (FLINK-30646) Table Store Hive catalog throws ClassNotFoundException when custom hive-site.xml is presented - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2023/01/12 10:36:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-282: Introduce Delete & Update API - posted by yuxia <lu...@alumni.sjtu.edu.cn> on 2023/01/12 11:39:53 UTC, 0 replies.
- [jira] [Created] (FLINK-30647) Add human readable datetime of watermark column in the web for better debug experience - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2023/01/12 11:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30648) [Umbrella]FLIP-282 Introduce Delete/Update API - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2023/01/12 12:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30649) Run kubernetes session test (default input) failed with a timeout - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/12 12:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30650) FLIP-280: Introduce EXPLAIN PLAN_ADVICE to provide SQL advice - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2023/01/12 13:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30651) Move util methods to CatalogTest and remove CatalogTestUtils class - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2023/01/12 13:51:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-280: Introduce EXPLAIN PLAN_ADVICE to provide SQL advice - posted by Jane Chan <qi...@gmail.com> on 2023/01/12 13:52:16 UTC, 0 replies.
- [jira] [Created] (FLINK-30652) Use max busytime instead of average to compute true processing rate - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2023/01/12 13:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30653) Triggere resource Events on autoscaler actions - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2023/01/12 14:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30654) start cursor issue - posted by "likang (Jira)" <ji...@apache.org> on 2023/01/12 15:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30655) SqlClientITCase.testMatchRecognize failed with a 404 - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/12 15:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30656) Provide more logs for schema compatibility check - posted by "Hangxiang Yu (Jira)" <ji...@apache.org> on 2023/01/12 16:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30657) Disable Shared and Key_Shared related tests in Pulsar connector - posted by "Yufan Sheng (Jira)" <ji...@apache.org> on 2023/01/13 01:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30658) remove Flink-sql-parser-hive dependency on table-planner - posted by "Chen Qin (Jira)" <ji...@apache.org> on 2023/01/13 02:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30659) move Flink-sql-parser-hive to flink-connector-hive - posted by "Chen Qin (Jira)" <ji...@apache.org> on 2023/01/13 02:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30660) move SQLClientHiveITCase and TestHiveCatalogFactory to flink-connector-hive e2e - posted by "Chen Qin (Jira)" <ji...@apache.org> on 2023/01/13 02:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30661) Introduce interfaces fro Delete/Update - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2023/01/13 03:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30662) Add implementation for SupportsDeletePushDown - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2023/01/13 03:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30663) Add implementation for RowLevelDelete - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2023/01/13 03:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30664) [Connector/Hive] cleanup hive/haoop package ambiguous package dependencies - posted by "Chen Qin (Jira)" <ji...@apache.org> on 2023/01/13 03:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30665) Add implementation for SupportsRowLevelUpdate - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2023/01/13 03:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30666) Add document for Delete/Update API - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2023/01/13 03:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30667) remove the planner dependency in flink-connector-hive - posted by "Chen Qin (Jira)" <ji...@apache.org> on 2023/01/13 03:15:00 UTC, 0 replies.
- [DISCUSS] Enabling dynamic partition discovery by default in Kafka source - posted by Qingsheng Ren <re...@apache.org> on 2023/01/13 03:31:20 UTC, 15 replies.
- [jira] [Created] (FLINK-30668) Introduce ExplainFormat to Explainable and TableEnvironment - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2023/01/13 04:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30669) Update recent job status in FlinkDeployment resource object. - posted by "Mohemmad Zaid Khan (Jira)" <ji...@apache.org> on 2023/01/13 04:27:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-283: Use adaptive batch scheduler as default scheduler for batch jobs - posted by Junrui Lee <jr...@gmail.com> on 2023/01/13 05:16:05 UTC, 0 replies.
- [jira] [Created] (FLINK-30670) Ignore broadcast bytes when computing parallelism and input infos - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2023/01/13 06:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30671) Add AlgoOperator for ClusteringEvaluator - posted by "Zhipeng Zhang (Jira)" <ji...@apache.org> on 2023/01/13 06:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30672) Support 'EXPLAIN PLAN_ADVICE' statement - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2023/01/13 06:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30673) Add documentation for "EXPLAIN PLAN_ADVICE" statement - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2023/01/13 07:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30674) When hybrid shuffle enable speculation execution, allow consume partition in advance by default - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2023/01/13 07:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30675) Decompose printing logic from Executor - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2023/01/13 08:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30676) Introduce Data Structures for table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/01/13 10:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30677) SqlGatewayServiceStatementITCase.testFlinkSqlStatements fails - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/13 10:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30678) NettyConnectionManagerTest.testManualConfiguration appears to be unstable - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/13 11:03:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-276: Data Consistency of Streaming and Batch ETL in Flink and Table Store - posted by Shammon FY <zj...@gmail.com> on 2023/01/13 11:43:28 UTC, 4 replies.
- [jira] [Created] (FLINK-30679) Can not load the data of hive dim table when project-push-down is introduced - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2023/01/13 11:59:00 UTC, 0 replies.
- [DISCUSS] FLIP-287: Extend Sink#InitContext to expose ExecutionConfig and JobID - posted by Joao Boto <bo...@boto.pro> on 2023/01/13 14:15:04 UTC, 7 replies.
- [jira] [Created] (FLINK-30680) Consider using the autoscaler to detect slow taskmanagers - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2023/01/13 14:23:00 UTC, 0 replies.
- [RESULT][VOTE] Apache Flink Table Store 0.3.0, release candidate #1 - posted by Jingsong Li <ji...@gmail.com> on 2023/01/13 15:04:07 UTC, 0 replies.
- [ANNOUNCE] Apache Flink Table Store 0.3.0 released - posted by Jingsong Li <ji...@gmail.com> on 2023/01/13 15:48:43 UTC, 0 replies.
- [jira] [Created] (FLINK-30681) Pulsar-Flink connector corrupts its output topic - posted by "Jacek Wislicki (Jira)" <ji...@apache.org> on 2023/01/13 21:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30682) FLIP-283: Use adaptive batch scheduler as default scheduler for batch jobs - posted by "JunRui Li (Jira)" <ji...@apache.org> on 2023/01/14 02:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30683) Make adaptive batch scheduler as the default batch scheduler - posted by "Junrui Li (Jira)" <ji...@apache.org> on 2023/01/14 03:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30684) Use the default parallelism as a flag for vertices that can automatically derive parallelism. - posted by "Junrui Li (Jira)" <ji...@apache.org> on 2023/01/14 03:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30685) Support mark the transformations whose parallelism is infected by the input transformation - posted by "Junrui Li (Jira)" <ji...@apache.org> on 2023/01/14 03:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30686) Simplify the configuration of adaptive batch scheduler - posted by "Junrui Li (Jira)" <ji...@apache.org> on 2023/01/14 03:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30687) FILTER not effect in count(*) - posted by "tanjialiang (Jira)" <ji...@apache.org> on 2023/01/14 06:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30688) Disable Kryo fallback in Flink ML tests - posted by "Dong Lin (Jira)" <ji...@apache.org> on 2023/01/14 13:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30689) Use auto produce bytes schema in Pulsar sink - posted by "Yufan Sheng (Jira)" <ji...@apache.org> on 2023/01/15 03:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30690) java document, web document, word some error perfect - posted by "zheju_he (Jira)" <ji...@apache.org> on 2023/01/15 07:05:00 UTC, 0 replies.
- 取消订阅 - posted by wa...@sina.cn on 2023/01/15 09:40:52 UTC, 0 replies.
- [jira] [Created] (FLINK-30691) Sql Client supports to specify endpoint address - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2023/01/15 09:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30692) Introduce embedded session manager to support REMOVE JAR - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2023/01/15 09:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30693) Introduce RowFormat to SQL Gateway for result fetching - posted by "yuzelin (Jira)" <ji...@apache.org> on 2023/01/15 13:05:00 UTC, 0 replies.
- Supplying jar stored at S3 to flink to run the job in kubernetes - posted by rahul sahoo <ra...@gmail.com> on 2023/01/15 21:07:07 UTC, 2 replies.
- [jira] [Created] (FLINK-30694) Translate "Joins" page of "Querys" into Chinese - posted by "chenhaiyang (Jira)" <ji...@apache.org> on 2023/01/16 02:40:00 UTC, 0 replies.
- [Discuss] Checkout the CURRENT_SNAPSHOT_VERSION branch of the flink-benchmarks repo during each major release - posted by Yun Tang <my...@LIVE.COM> on 2023/01/16 05:02:52 UTC, 5 replies.
- [jira] [Created] (FLINK-30695) Support to set parallelism for compact operator according to the number of files in AQE. - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2023/01/16 07:26:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-264 Extract BaseCoordinatorContext - posted by Jark Wu <im...@gmail.com> on 2023/01/16 08:30:38 UTC, 3 replies.
- [jira] [Created] (FLINK-30696) Translate "joins" page of "Querys" into Chinese - posted by "chenhaiyang (Jira)" <ji...@apache.org> on 2023/01/16 09:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30697) Upgrade scalafmt documentation - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/16 09:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30698) SqlGatewayServiceStatementITCase.testFlinkSqlStatements fails - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/16 09:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30699) Improve the efficiency of the getRandomString method in the StringUtils class - posted by "Bingye Chen (Jira)" <ji...@apache.org> on 2023/01/16 10:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30700) Translate "Deduplication" page of "Querys" into Chinese - posted by "chenhaiyang (Jira)" <ji...@apache.org> on 2023/01/16 10:11:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-279 Unified the max display column width for SqlClient and Table APi in both Streaming and Batch execMode - posted by Jing Ge <ji...@ververica.com.INVALID> on 2023/01/16 11:07:03 UTC, 0 replies.
- [jira] [Created] (FLINK-30701) Remove SimpleTableTestHelper and use sql in SparkITCase - posted by "Shammon (Jira)" <ji...@apache.org> on 2023/01/16 12:04:00 UTC, 0 replies.
- [NOTICE] dependency-reduced pom now put in module basedir - posted by Chesnay Schepler <ch...@apache.org> on 2023/01/16 12:43:36 UTC, 0 replies.
- [NOTICE] Parallel compilation should no longer lock up - posted by Chesnay Schepler <ch...@apache.org> on 2023/01/16 13:17:45 UTC, 1 replies.
- [jira] [Created] (FLINK-30702) Introduce ElasticDialect - posted by "Grzegorz Kołakowski (Jira)" <ji...@apache.org> on 2023/01/16 13:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30703) PulsarOrderedPartitionSplitReaderTest>PulsarPartitionSplitReaderTestBase.consumeMessageCreatedBeforeHandleSplitsChangesAndResetToEarliestPosition fails - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/16 13:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30704) Add S3 delegation token support - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2023/01/16 14:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30705) CR reference generator does not respect JsonProperty annotation - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2023/01/16 20:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30706) Remove flink-table-common dependency for table store core - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/01/17 02:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30707) Let speculative execution takes input number bytes into account when detecting slow tasks - posted by "xingbe (Jira)" <ji...@apache.org> on 2023/01/17 03:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30708) Typo problem of the doc `Determinism In Continuous Queries` - posted by "Jie Han (Jira)" <ji...@apache.org> on 2023/01/17 03:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30709) NetworkInput#emitNext() should push records to DataOutput in a while loop - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2023/01/17 05:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30710) Fix invalid field id for nested type in spark catalog - posted by "Shammon (Jira)" <ji...@apache.org> on 2023/01/17 05:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30711) Support dropping partition via Flink action - posted by "yuzelin (Jira)" <ji...@apache.org> on 2023/01/17 06:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30712) Update network memory configuration docs - posted by "Yuxin Tan (Jira)" <ji...@apache.org> on 2023/01/17 06:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30713) Add Hadoop related k8s decorators exclude possibility - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2023/01/17 09:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30714) Translate "Window Aggregation" page of "Querys" into Chinese - posted by "chenhaiyang (Jira)" <ji...@apache.org> on 2023/01/17 09:02:00 UTC, 0 replies.
- [SUMMARY] Flink 1.17 Release Sync 1/17/2023 - posted by Qingsheng Ren <re...@apache.org> on 2023/01/17 09:46:42 UTC, 0 replies.
- [jira] [Created] (FLINK-30715) FLIP-289: Support Online Inference - posted by "Jiang Xin (Jira)" <ji...@apache.org> on 2023/01/17 09:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30716) [Flink SQL] SQL function TO_TIMESTAMP(string1[, string2])'s result incorrect where string2 is default: 'yyyy-MM-dd HH:mm:ss' - posted by "Jett Dai (Jira)" <ji...@apache.org> on 2023/01/17 11:51:00 UTC, 0 replies.
- [DISCUSS] FLIP-289: Operator state compression - posted by Etienne Chauchot <ec...@apache.org> on 2023/01/17 14:24:29 UTC, 1 replies.
- [jira] [Created] (FLINK-30717) Migrate Travis CI to Github Actions - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2023/01/17 14:36:00 UTC, 0 replies.
- [DISCUSS] FLIP-290: Operator state compression (FLINK-30113) - posted by Etienne Chauchot <ec...@apache.org> on 2023/01/17 14:47:39 UTC, 12 replies.
- [jira] [Created] (FLINK-30718) Cannot assign instance of java.lang.invoke.SerializedLambda to field org.apache.flink.connector.opensearch.sink.OpensearchSink.emitter - posted by "Andriy Redko (Jira)" <ji...@apache.org> on 2023/01/17 15:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30719) flink-runtime-web failed due to a corrupted - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/17 15:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30720) KafkaChangelogTableITCase.testKafkaDebeziumChangelogSource failed due to a topic already exist when creating it - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/17 16:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30721) The confluent schema registry is not compatible with Apicurio shcema registry - posted by "Pedro Mázala (Jira)" <ji...@apache.org> on 2023/01/17 16:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30722) Translate "Group Aggregation" page of "Querys" into Chinese - posted by "chenhaiyang (Jira)" <ji...@apache.org> on 2023/01/18 01:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30723) Introduce filter pushdown for parquet format - posted by "Shammon (Jira)" <ji...@apache.org> on 2023/01/18 01:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30724) Update doc of kafka per-partition watermark to FLIP-27 source - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2023/01/18 03:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30725) FLIP-281: Sink Supports Speculative Execution For Batch Job - posted by "Biao Liu (Jira)" <ji...@apache.org> on 2023/01/18 04:00:03 UTC, 0 replies.
- [jira] [Created] (FLINK-30726) Translate "Over Aggregation" page of "Querys" into Chinese - posted by "chenhaiyang (Jira)" <ji...@apache.org> on 2023/01/18 04:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30727) JoinReorderITCase.testBushyTreeJoinReorder failed due to IOException - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/18 07:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30728) Translate "Window Join" page of "Querys" into Chinese - posted by "chenhaiyang (Jira)" <ji...@apache.org> on 2023/01/18 07:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30729) AggregateITCase generates stacktraces of IllegalStateExceptions in Maven output but doesn't fail - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/18 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30730) StringIndexer cannot handle null values correctly when training - posted by "Fan Hong (Jira)" <ji...@apache.org> on 2023/01/18 07:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30731) Translate "Set Operations" page of "Querys" into Chinese - posted by "chenhaiyang (Jira)" <ji...@apache.org> on 2023/01/18 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30732) "Running HA (hashmap, sync) end-to-end test" failed with exit code 1 - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/18 08:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30733) The AzureCI Slack bot does not list all failed builds in the Slack channel - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/18 09:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30734) KBinsDiscretizer handles Double.NaN incorrectly - posted by "Fan Hong (Jira)" <ji...@apache.org> on 2023/01/18 10:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30735) Translate "Top-N" page of "Querys" into Chinese - posted by "chenhaiyang (Jira)" <ji...@apache.org> on 2023/01/18 10:27:00 UTC, 0 replies.
- [DISCUSS] Promote SinkV2 to @Public and deprecate SinkFunction - posted by Martijn Visser <ma...@apache.org> on 2023/01/18 10:50:10 UTC, 9 replies.
- [jira] [Created] (FLINK-30736) Exclude generated sources from checkstyle - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2023/01/18 12:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30737) Setup - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2023/01/18 12:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30738) Disable verbose mode - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2023/01/18 12:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30739) SqlGatewayRestEndpointStatementITCase failed with NullPointer - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2023/01/18 12:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30740) INSERT to Kafka does not work when Kafka config {{auto.create.topics.enabled}} is set to false - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2023/01/18 13:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30741) IPv6HostnamesITCase should create remote rpc service - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2023/01/18 13:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30742) Create E2E for GlueCatalog - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2023/01/18 13:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30743) Improve Kubernetes HA Services docs - posted by "Wolfgang Buchner (Jira)" <ji...@apache.org> on 2023/01/18 13:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30744) Translate "Window Top-N" page of "Querys" into Chinese - posted by "chenhaiyang (Jira)" <ji...@apache.org> on 2023/01/18 14:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30745) Check-pointing with Azure Data Lake Storage - posted by "Dheeraj Panangat (Jira)" <ji...@apache.org> on 2023/01/18 14:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30746) Flink Table / SQL Column types of query result and sink for do not match, but should - posted by "Colin Williams (Jira)" <ji...@apache.org> on 2023/01/18 15:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30747) Translate "Window Deduplication" page of "Querys" into Chinese - posted by "chenhaiyang (Jira)" <ji...@apache.org> on 2023/01/18 15:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30748) Translate "Window Deduplication" page of "Querys" into Chinese - posted by "chenhaiyang (Jira)" <ji...@apache.org> on 2023/01/18 15:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30749) Delegation token provider enabled flag documentation is wrong - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2023/01/18 15:26:00 UTC, 0 replies.
- Unequal distribtion of Kafka partitions with respect to topic when reading from multiple topics using KafkaSource API with Flink 1.14.3 - posted by "Kathula, Sandeep" <Sa...@intuit.com.INVALID> on 2023/01/18 17:22:25 UTC, 0 replies.
- [jira] [Created] (FLINK-30750) CompactActionITCase.testBatchCompact in table store is unstable - posted by "Shammon (Jira)" <ji...@apache.org> on 2023/01/19 03:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30751) Remove references to disableDataSync in RocksDB documentation - posted by "David Christle (Jira)" <ji...@apache.org> on 2023/01/19 05:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30752) Support 'EXPLAIN PLAN_ADVICE' statement in PyFlink - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2023/01/19 06:38:00 UTC, 0 replies.
- [DISCUSS] Incorporate performance regression monitoring into routine process - posted by Yanfei Lei <fr...@gmail.com> on 2023/01/19 08:01:49 UTC, 9 replies.
- [jira] [Created] (FLINK-30753) Py4J cannot acquire Table.explain() method - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2023/01/19 09:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30754) Fix ExceptionThrowingDelegationTokenProvider/Receiver multi-threaded test issues - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2023/01/19 09:51:00 UTC, 0 replies.
- [DISCUSS] Release connector-parent 1.0 - posted by Chesnay Schepler <ch...@apache.org> on 2023/01/19 10:48:20 UTC, 0 replies.
- [jira] [Created] (FLINK-30755) Make SinkV2 support speculative execution for batch jobs - posted by "Biao Liu (Jira)" <ji...@apache.org> on 2023/01/19 11:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30756) StreamTableExplainTests.test_explain fails - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/19 13:47:00 UTC, 0 replies.
- Re: Stateful Functions with Flink 1.15 and onwards - posted by Galen Warren <ga...@cvillewarrens.com> on 2023/01/19 16:04:53 UTC, 2 replies.
- [jira] [Created] (FLINK-30757) Ugrade busybox version to a pinned version for operator - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2023/01/19 16:07:00 UTC, 0 replies.
- [VOTE] Release 1.16.1, release candidate #1 - posted by Martijn Visser <ma...@apache.org> on 2023/01/19 16:07:15 UTC, 10 replies.
- [DISCUSS] Introduce Side Output Functionality to the Table & SQL API - posted by "Ber, Jeremy" <jd...@amazon.com.INVALID> on 2023/01/19 18:25:47 UTC, 2 replies.
- Py4JJavaError - posted by Amir Hossein Sharifzadeh <am...@gmail.com> on 2023/01/19 19:30:32 UTC, 0 replies.
- [jira] [Created] (FLINK-30758) Remove sql-client.display.max-column-width - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2023/01/20 03:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30759) Merge DispatcherRunnerLeaderElectionLifecycleManager into DefaultDispatcherRunner - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/20 08:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30760) Fix @GuardedBy annotations in DefaultLeaderElectionService - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/20 08:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30761) Remove JVM asserts from leader election code - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/20 08:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30762) Add nightly builds for AWS connectors repo - posted by "Aleksandr Pilipenko (Jira)" <ji...@apache.org> on 2023/01/20 10:08:00 UTC, 0 replies.
- [VOTE] FLIP-290: Operator state compression (FLINK-30113) - posted by Etienne Chauchot <ec...@apache.org> on 2023/01/20 10:24:06 UTC, 8 replies.
- [jira] [Created] (FLINK-30763) Make TestingLeaderElectionService comply to how the LeaderElectionService interface is intended - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/20 12:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30764) Include generic delegation token params in the main config page - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2023/01/20 12:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30765) LeaderElectionService.stop should always call revokeLeadership - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/20 13:40:00 UTC, 0 replies.
- [VOTE] Release flink-connector-gcp-pubsub v3.0.0, release candidate #1 - posted by Martijn Visser <ma...@apache.org> on 2023/01/20 14:38:33 UTC, 7 replies.
- Fwd: UDFs classloading changes in 1.16 - posted by Martijn Visser <ma...@apache.org> on 2023/01/20 15:49:37 UTC, 0 replies.
- [jira] [Created] (FLINK-30766) Only parameterize tests with Flink 1.14 and 1.15 - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2023/01/21 19:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30767) Unable to fetch com.nimbusds:nimbus-jose-jwt:jar:9.29 artifact in e2e tets - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/23 07:50:00 UTC, 0 replies.
- Flink connector sinks - posted by Carlos Freitas <ca...@talkdesk.com.INVALID> on 2023/01/23 12:34:14 UTC, 3 replies.
- [jira] [Created] (FLINK-30768) flink-web version cleanup - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/23 12:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30769) Use Operator SDK RuntimeInfo in Health Probe - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2023/01/23 13:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30770) OUTER join generates partial results - posted by "Thomas Erlenbach (Jira)" <ji...@apache.org> on 2023/01/23 13:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30771) different performance of conversion between datetime type in mysql and timestamp in flink - posted by "jingjing dong (Jira)" <ji...@apache.org> on 2023/01/23 15:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30772) Update Flink Shaded dependencies to the latest versions - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2023/01/23 15:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30773) Allow rescaling of jobs based on per-vertex parallelism overrides - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2023/01/23 16:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30774) flink-utils module - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/23 16:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30775) Support pluggable reconciler modules - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2023/01/23 16:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30776) Move autoscaler code into a seperate module - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2023/01/23 16:44:00 UTC, 0 replies.
- Reworking the Rescale API - posted by Maximilian Michels <mx...@apache.org> on 2023/01/23 17:07:43 UTC, 18 replies.
- [jira] [Created] (FLINK-30777) Allow Kinesis Table API Connector to specify shard assigner - posted by "Karthi Thyagarajan (Jira)" <ji...@apache.org> on 2023/01/24 00:08:00 UTC, 0 replies.
- [DISCUSS] Externalize AWS formats to flink-connector-aws - posted by "Teoh, Hong" <li...@amazon.co.uk.INVALID> on 2023/01/24 07:51:05 UTC, 6 replies.
- [jira] [Created] (FLINK-30778) Add Configuration into FunctionContext - posted by "Alexander Smirnov (Jira)" <ji...@apache.org> on 2023/01/24 10:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30779) Bomp josdk version to 4.3.2 - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2023/01/24 13:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30780) Develop ElasticCatalog to connect Flink with Elastic tables and ecosystem - posted by "Grzegorz Kołakowski (Jira)" <ji...@apache.org> on 2023/01/24 14:18:00 UTC, 0 replies.
- Re: [VOTE] Release flink-connector-hbase v3.0.0, release candidate #1 - posted by Ferenc Csaky <fe...@pm.me.INVALID> on 2023/01/24 15:45:26 UTC, 0 replies.
- [jira] [Created] (FLINK-30781) Add completed checkpoint check to cluster health check - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2023/01/24 16:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30782) Use https for schemaLocations - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2023/01/24 21:48:00 UTC, 0 replies.
- [ANNOUNCE] Share your Streaming Stories with us at Current 2023 - posted by Israel Ekpo <is...@gmail.com> on 2023/01/24 23:38:26 UTC, 0 replies.
- [jira] [Created] (FLINK-30783) Add pull request template for AWS Connectors repo - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2023/01/25 08:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30784) HiveTableSourceITCase.testPartitionFilter failed with assertion error - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/25 08:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30785) RocksDB Memory Management end-to-end test failed due to unexpected exception - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/25 09:10:00 UTC, 0 replies.
- [VOTE] FLIP-285: Refactoring LeaderElection to make Flink support multi-component leader election out-of-the-box - posted by Matthias Pohl <ma...@aiven.io.INVALID> on 2023/01/25 09:33:46 UTC, 5 replies.
- [jira] [Created] (FLINK-30786) Support merge by name for podTemplate array fields - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2023/01/25 09:57:00 UTC, 0 replies.
- [SUMMARY] Flink 1.17 release sync 23rd of January, 2023 - posted by Martijn Visser <ma...@apache.org> on 2023/01/25 10:06:43 UTC, 5 replies.
- [RESULT][VOTE] FLIP-290: Operator state compression (FLINK-30113) - posted by Etienne Chauchot <ec...@apache.org> on 2023/01/25 11:05:33 UTC, 0 replies.
- [jira] [Created] (FLINK-30787) dmesg fails to save data to file due to permissions - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/25 11:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30788) Refactor redundant code in AbstractHaServices - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/25 15:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30789) Merge MultipleComponentsLeaderElectionDriver methods notifyAllKnownLeaderInformation and notifyLeaderInformationChange into a single method and - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/25 16:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30790) [Connectors/Jdbc] Refactor of testings - posted by "João Boto (Jira)" <ji...@apache.org> on 2023/01/25 16:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30791) Codespeed machine is not responding - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2023/01/25 16:44:00 UTC, 0 replies.
- Doubt with kafka commits taking too long - posted by André Leite <an...@talkdesk.com.INVALID> on 2023/01/25 18:21:02 UTC, 0 replies.
- [jira] [Created] (FLINK-30792) clean up not uploaded state changes after materialization complete - posted by "Feifan Wang (Jira)" <ji...@apache.org> on 2023/01/26 02:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30793) PyFlink YARN per-job on Docker test fails on Azure due to permission issues - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/26 07:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30794) Disable dependency convergence check for night connector builds - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2023/01/26 09:33:00 UTC, 0 replies.
- Confluent Avro and Debezium formats - default schema name can be incompatible with registered schema name - posted by Fruzsina Nagy <fr...@cloudera.com.INVALID> on 2023/01/26 10:29:15 UTC, 1 replies.
- [jira] [Created] (FLINK-30795) StreamingWithStateTestBase of win not correct - posted by "JinxinTang (Jira)" <ji...@apache.org> on 2023/01/26 13:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30796) Make Slf4jReporter less noisy when no/few metrics exist - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2023/01/26 13:40:00 UTC, 0 replies.
- [VOTE] Externalize AWS formats to flink-connector-aws - posted by "Teoh, Hong" <li...@amazon.co.uk.INVALID> on 2023/01/26 17:14:27 UTC, 21 replies.
- [jira] [Created] (FLINK-30797) Bump json5 from 1.0.1 to 1.0.2 in - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2023/01/26 20:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30798) Make OutputFormat support speculative execution for batch jobs - posted by "Biao Liu (Jira)" <ji...@apache.org> on 2023/01/27 02:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30799) Make SinkFunction support speculative execution for batch jobs - posted by "Biao Liu (Jira)" <ji...@apache.org> on 2023/01/27 02:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30800) Add doc entry how to re-generate java doc - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2023/01/27 08:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30801) Migrate LeaderElection-related unit tests to JUnit5 - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/27 11:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30802) Improve SplitReader#fetch() documentation - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2023/01/27 14:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30803) PyFlink mishandles script dependencies - posted by "Nuno Afonso (Jira)" <ji...@apache.org> on 2023/01/27 15:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30804) flink-kubernetes-operator helm chart - allow specifying operator pod resources requests/limits - posted by "Vincent Chenal (Jira)" <ji...@apache.org> on 2023/01/27 15:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30805) SplitEnumerator#handleSplitRequest() should be called automatically - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2023/01/27 17:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30806) Bump protobuf-java dependency version for aws connectors - posted by "Aleksandr Pilipenko (Jira)" <ji...@apache.org> on 2023/01/27 17:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30807) State Processor API - Overwrite Support for Savepoints - posted by "Rion Williams (Jira)" <ji...@apache.org> on 2023/01/27 20:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30808) MultipleInputITCase failed with AdaptiveBatch Scheduler - posted by "Junrui Li (Jira)" <ji...@apache.org> on 2023/01/28 03:44:00 UTC, 0 replies.
- [Discuss] Conventions on driving FLIPs towards consensus - posted by Xintong Song <to...@gmail.com> on 2023/01/28 04:25:19 UTC, 5 replies.
- [jira] [Created] (FLINK-30809) flink-connector-elasticsearch7 updates data pipeline does not work - posted by "iduanyingjie (Jira)" <ji...@apache.org> on 2023/01/28 05:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30810) Rework the CliClientITCase to extend AbstractSqlGatewayStatementITCase - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2023/01/28 06:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30811) Fix sql gateway can not stop job correctly - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2023/01/28 08:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30812) YARN with S3 resource storage fails for Hadoop 3.3.2 - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2023/01/28 09:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30813) Residual zk data when using the kubernetes session mode - posted by "liuzhuo (Jira)" <ji...@apache.org> on 2023/01/28 10:05:00 UTC, 0 replies.
- unsucscribe - posted by Jake <ft...@qq.com.INVALID> on 2023/01/29 02:48:04 UTC, 3 replies.
- [jira] [Created] (FLINK-30814) The parallelism&maxParallelism of sort after a global partitioning is forced to be 1 - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2023/01/29 03:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30815) BatchTestBase/BatchAbstractTestBase are using Junit4 while some child tests are using JUnit5 - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2023/01/29 04:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30816) Fix Sql Client always uses the packaged highests version to connect to gateway - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2023/01/29 08:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30817) ClassCastException in TestValuesTableFactory.TestValuesScanTableSourceWithoutProjectionPushDown - posted by "Shuiqiang Chen (Jira)" <ji...@apache.org> on 2023/01/29 08:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30818) add metrics to measure the count of window - posted by "chenyuzhi (Jira)" <ji...@apache.org> on 2023/01/29 10:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30819) Fix history file records incomplete statement sets - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2023/01/29 12:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30820) Support varchar and char for spark in table store - posted by "Shammon (Jira)" <ji...@apache.org> on 2023/01/30 02:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30821) The optimized exec plan generated by OverAggregateTest#testDiffPartitionKeysWithDiffOrderKeys2 in the case of all-blocking is not as expected - posted by "Junrui Li (Jira)" <ji...@apache.org> on 2023/01/30 02:48:00 UTC, 0 replies.
- Re: [DISCUSS] Release new FRocksDB - posted by Yanfei Lei <fr...@gmail.com> on 2023/01/30 04:27:22 UTC, 0 replies.
- [jira] [Created] (FLINK-30822) KafkaSinkITCase fails in setup and teardown method because the topic couldn't be created/deleted - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/30 08:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30823) Enable speculative execution for some of the typical built-in sinks - posted by "Biao Liu (Jira)" <ji...@apache.org> on 2023/01/30 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30824) Add document for new introduced hive agg option - posted by "dalongliu (Jira)" <ji...@apache.org> on 2023/01/30 11:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30825) Ingress creation failed on K8s with version < 1.19 - posted by "Shang Yuanchun (Jira)" <ji...@apache.org> on 2023/01/30 11:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30826) HashAggITCase.testLeadLag is failing with jdk 11 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2023/01/30 12:26:00 UTC, 0 replies.
- [ANNOUNCE] FRocksDB 6.20.3-ververica-2.0 released - posted by Yanfei Lei <fr...@gmail.com> on 2023/01/30 12:40:53 UTC, 4 replies.
- [jira] [Created] (FLINK-30827) Improve the SQL Client code structure - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2023/01/30 13:12:00 UTC, 0 replies.
- [RESULT][VOTE] Release 1.16.1, release candidate #1 - posted by Martijn Visser <ma...@apache.org> on 2023/01/30 13:18:29 UTC, 2 replies.
- [jira] [Created] (FLINK-30828) SortAggITCase.testLeadLag failed - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/30 13:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30829) Make the backpressure tab could be sort by the backpressure level - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2023/01/30 14:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30830) Temporal Table Function Samples for Java Do Not Work As-Is, And Some Functions Are Deprecated - posted by "Jeremy Ber (Jira)" <ji...@apache.org> on 2023/01/30 15:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30831) Improving e2e test output in case errors/exceptions are found - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/30 15:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30832) flink-kubernetes-operator helm chart - allow specifying operator pod resources requests/limits for flink-webhook container - posted by "Vincent Chenal (Jira)" <ji...@apache.org> on 2023/01/30 16:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30833) MetricListener supports closing metric groups - posted by "Mason Chen (Jira)" <ji...@apache.org> on 2023/01/30 23:54:00 UTC, 0 replies.
- [DISCUSS] streaming shuffle to improve data clustering and tame small files problem - posted by Steven Wu <st...@gmail.com> on 2023/01/31 00:45:17 UTC, 1 replies.
- [jira] [Created] (FLINK-30834) SortAggITCase.testLeadLag is unstable in ALL_EXCHANGES_BLOCKING mode - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2023/01/31 04:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30835) Add smoke tests for flink connector - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2023/01/31 04:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30836) Release FRocksDB 6.20.3-ververica-2.0 - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2023/01/31 05:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30837) Remove dependency of MutableByteArrayInputStream from flink-avro-glue-schema-registry - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2023/01/31 06:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30838) Update documentation about the AdaptiveBatchScheduler - posted by "Junrui Li (Jira)" <ji...@apache.org> on 2023/01/31 06:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30839) Relaxed looping group pattern make the following strict contiguity relaxed too - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2023/01/31 06:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30840) Fix resource leak when creating Executor - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2023/01/31 06:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30841) Incorrect calc merge in streaming - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2023/01/31 07:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30842) Add document for sink supports speculative execution - posted by "Biao Liu (Jira)" <ji...@apache.org> on 2023/01/31 07:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30843) Add Notifier For Autoscaler - posted by "Gaurav Miglani (Jira)" <ji...@apache.org> on 2023/01/31 07:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30844) TaskTest failed fatally with exit code 239 (FatalExitExceptionHandler) - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/31 07:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30845) Params in jarURI end up in file name - posted by "Fabio Wanner (Jira)" <ji...@apache.org> on 2023/01/31 07:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30846) SpeculativeSchedulerITCase.testSpeculativeExecutionOfInputFormatSource fails - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/31 07:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30847) Some rel rules vioaltes Calcite guidance rule about instance creation - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2023/01/31 08:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30848) Enable CatalogTableITCase#testAlterTable - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2023/01/31 08:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30849) udaf validated failed with TableEnvironment#executeSql but work correctly with StreamTableEnrivorment#registerFunction - posted by "Jianhui Dong (Jira)" <ji...@apache.org> on 2023/01/31 09:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30850) Update GCP E2E tests to no longer publish their JARs - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2023/01/31 11:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30851) flink-kubernetes-operator - operator image should provide s3 support for jarUri - posted by "Vincent Chenal (Jira)" <ji...@apache.org> on 2023/01/31 11:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30852) TaskTest.testCleanupWhenSwitchToInitializationFails reports AssertionError but doesn't fail - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/01/31 12:01:00 UTC, 0 replies.
- [RESULT][VOTE] Release flink-connector-gcp-pubsub v3.0.0, release candidate #1 - posted by Martijn Visser <ma...@apache.org> on 2023/01/31 12:20:48 UTC, 0 replies.
- [VOTE] Release flink-connector-kafka, release candidate #1 - posted by Martijn Visser <ma...@apache.org> on 2023/01/31 14:23:17 UTC, 0 replies.
- [jira] [Created] (FLINK-30853) Make clear the public API for flink-avro - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2023/01/31 14:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30854) Expose periodic compaction to RocksdbCompactFilterCleanupStrategy - posted by "Hangxiang Yu (Jira)" <ji...@apache.org> on 2023/01/31 14:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30855) Remove flink-connector-gcp-pubsub from master branch - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2023/01/31 14:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30856) flink-kubernetes-operator - allow specifying job name - posted by "Vincent Chenal (Jira)" <ji...@apache.org> on 2023/01/31 15:36:00 UTC, 0 replies.
- [RESULT][VOTE] Externalize AWS formats to flink-connector-aws - posted by "Teoh, Hong" <li...@amazon.co.uk.INVALID> on 2023/01/31 16:07:17 UTC, 0 replies.
- [ANNOUNCE] Flink 1.17 feature freeze and summary of release sync 31st of January - posted by Martijn Visser <ma...@apache.org> on 2023/01/31 19:24:24 UTC, 0 replies.
- [jira] [Created] (FLINK-30857) Create table does not create topic with multiple partitions - posted by "Vicky Papavasileiou (Jira)" <ji...@apache.org> on 2023/01/31 20:02:00 UTC, 0 replies.