dev@flink.apache.org, 2022-06

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

- Re: [VOTE] Apache Flink Kubernetes Operator Release 1.0.0, release candidate #3 - posted by Jim Busche <jb...@us.ibm.com> on 2022/06/01 00:29:57 UTC, 3 replies.
- Re: About Native Deployment's Autoscaling implementation - posted by Talat Uyarer <tu...@paloaltonetworks.com> on 2022/06/01 00:33:54 UTC, 1 replies.
- [jira] [Created] (FLINK-27857) Hive source support filter push down for orc format - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/06/01 01:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27858) Hive source support filter push down for parquet format - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/06/01 01:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27859) Hive dialect should support create table that begins with digits - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/06/01 02:13:00 UTC, 0 replies.
- Re: [VOTE] FLIP-235: Hybrid Shuffle Mode - posted by weijie guo <gu...@gmail.com> on 2022/06/01 02:18:15 UTC, 0 replies.
- Re: [DISCUSS] FLIP-231: Introduce SupportStatisticReport to support reporting statistics from source connectors - posted by godfrey he <go...@gmail.com> on 2022/06/01 05:30:38 UTC, 1 replies.
- [jira] [Created] (FLINK-27860) List the CSS/docs dependencies in the NOTICE - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/06/01 05:58:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-234: Support Retryable Lookup Join To Solve Delayed Updates Issue In External Systems - posted by Jingsong Li <ji...@gmail.com> on 2022/06/01 06:11:30 UTC, 6 replies.
- RE: [DISCUSS] FLIP-233: Introduce HTTP Connector - posted by Maciej Bryński <ma...@getindata.com> on 2022/06/01 06:38:55 UTC, 5 replies.
- [jira] [Created] (FLINK-27861) Introduce UserResourceManager to manage user defined resource - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/06/01 06:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27862) FLIP-235: Hybrid Shuffle Mode - posted by "Guo Weijie (Jira)" <ji...@apache.org> on 2022/06/01 06:57:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-223: Support HiveServer2 Endpoint - posted by Jingsong Li <ji...@gmail.com> on 2022/06/01 07:00:28 UTC, 5 replies.
- Re: [DISCUSS] FLIP-221 Abstraction for lookup source cache and metric - posted by Jingsong Li <ji...@gmail.com> on 2022/06/01 07:28:37 UTC, 13 replies.
- [jira] [Created] (FLINK-27863) Refactor RecordReader and RecordIterator in table store into generic types - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/06/01 07:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27864) Duplicated classes (jar hell) on flink-table-runtime - posted by "Guillaume Lederrey (Jira)" <ji...@apache.org> on 2022/06/01 09:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27865) Add guide and example for configuring SASL and SSL in Kafka SQL connector document - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2022/06/01 09:36:00 UTC, 0 replies.
- [VOTE] Apache Flink Kubernetes Operator Release 1.0.0, release candidate #4 - posted by Yang Wang <da...@gmail.com> on 2022/06/01 10:15:51 UTC, 6 replies.
- [jira] [Created] (FLINK-27866) CassandraOutputFormat and CassandraSink will timeout twice if the number of maximum requests is reached - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2022/06/01 10:50:00 UTC, 0 replies.
- Translation in korean? - posted by Dennis Jung <in...@gmail.com> on 2022/06/01 10:56:38 UTC, 2 replies.
- [jira] [Created] (FLINK-27867) SplitAggregateITCase fails on CI - posted by "Alexander Preuss (Jira)" <ji...@apache.org> on 2022/06/01 10:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27868) Harden running job check before triggering savepoints or savepoint upgrades - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/06/01 11:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27869) AdaptiveSchedulerITCase. testStopWithSavepointFailOnStop failed with FAIL_ON_CHECKPOINT_COMPLETE - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/06/01 12:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27870) SemiAntiJoinStreamITCase. testAntiJoinWithTwoSidesRetraction failed with InterruptedException - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/06/01 12:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27871) Dynamic configuration change is undedected on config removal - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/06/01 15:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27872) Allow KafkaBuilder to set arbitrary subscribers - posted by "Salva (Jira)" <ji...@apache.org> on 2022/06/01 16:15:00 UTC, 0 replies.
- [DISCUSS] suggest using granularityNumber in ColumnStats - posted by Jing Ge <ji...@ververica.com> on 2022/06/01 16:44:11 UTC, 7 replies.
- [jira] [Created] (FLINK-27873) Primary key is lost after calling addColumns - posted by "Yaroslav Tkachenko (Jira)" <ji...@apache.org> on 2022/06/01 17:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27874) KeyedStateCheckpointingITCase Timeout - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/06/02 02:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27875) Introduce TableScan and TableRead as an abstraction layer above FileStore for reading RowData - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/06/02 02:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27876) Error side is chosen in BatchPhysicalHashJoinRule when the join is Semi or Anti - posted by "xuyang (Jira)" <ji...@apache.org> on 2022/06/02 02:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27877) Improve performance of several feature engineering algorithms - posted by "Zhipeng Zhang (Jira)" <ji...@apache.org> on 2022/06/02 06:09:00 UTC, 0 replies.
- 邮件退订 - posted by lizikun <li...@163.com> on 2022/06/02 07:06:01 UTC, 6 replies.
- [ANNOUNCE] Welcome to join the Apache Flink community on Slack - posted by Xintong Song <to...@gmail.com> on 2022/06/02 07:30:11 UTC, 13 replies.
- [RESULT] [VOTE] FLIP-232: Add Retry Support For Async I/O In DataStream API - posted by Lincoln Lee <li...@gmail.com> on 2022/06/02 07:50:42 UTC, 0 replies.
- [jira] [Created] (FLINK-27878) Add Retry Support For Async I/O In DataStream API - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2022/06/02 08:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27879) Translate the "Documentation Style Guide" page into Chinese - posted by "zhenyu xing (Jira)" <ji...@apache.org> on 2022/06/02 08:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27880) CI runs keep getting stuck - posted by "Alexander Preuss (Jira)" <ji...@apache.org> on 2022/06/02 08:51:00 UTC, 0 replies.
- 回复： [DISCUSS] suggest using granularityNumber in ColumnStats - posted by "luoyuxia@alumni.sjtu.edu.cn" <lu...@alumni.sjtu.edu.cn> on 2022/06/02 09:13:34 UTC, 0 replies.
- [jira] [Created] (FLINK-27881) The key(String) in PulsarMessageBuilder returns null - posted by "Shuiqiang Chen (Jira)" <ji...@apache.org> on 2022/06/02 10:57:00 UTC, 0 replies.
- Re: [DISCUSS] Bi-Weekly Flink Community Sync Meeting - posted by Robert Metzger <me...@gmail.com> on 2022/06/02 11:00:13 UTC, 1 replies.
- [jira] [Created] (FLINK-27882) [JUnit5 Migration] Module: flink-scala - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/06/02 11:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27883) KafkaSubscriberTest failed with NPC - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/06/02 12:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27884) Introduce a flush mechanism for OutputFormats - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2022/06/02 13:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27885) [JUnit5 Migration] Module: flink-csv - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2022/06/02 14:57:00 UTC, 0 replies.
- Join Apache Flink community on Slack - posted by xun wang <w7...@gmail.com> on 2022/06/02 15:05:25 UTC, 2 replies.
- [jira] [Created] (FLINK-27886) Error way for skipping shade plugin in sub-modules - posted by "Ran Tao (Jira)" <ji...@apache.org> on 2022/06/02 15:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27887) Unable to access https://nightlies.apache.org/flink/ - posted by "Ben Carlton (Jira)" <ji...@apache.org> on 2022/06/02 19:41:00 UTC, 0 replies.
- Needed help with skipping savepoint state (unsure how to set --allowNonRestoredState in Docker) - posted by Bhavani Balasubramanyam <bh...@reddit.com.INVALID> on 2022/06/02 23:17:49 UTC, 1 replies.
- [jira] [Created] (FLINK-27888) Flink SQL execute error in Flink1.15 - posted by "songwenbin (Jira)" <ji...@apache.org> on 2022/06/03 01:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27889) Error when the LastReconciledSpec is null - posted by "Hector Miuler Malpica Gallegos (Jira)" <ji...@apache.org> on 2022/06/03 05:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27890) bug of SideOutputExample.java - posted by "XiaoWen Wei (Jira)" <ji...@apache.org> on 2022/06/03 07:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27891) Add ARRAY_APPEND and ARRAY_PREPEND supported in SQL & Table API - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/06/03 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27892) More than 1 secondary resource related to primary - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/06/03 09:33:00 UTC, 0 replies.
- [DISCUSS] Deprecate SourceFunction APIs - posted by Alexander Fedulov <al...@ververica.com> on 2022/06/03 13:54:11 UTC, 32 replies.
- [jira] [Created] (FLINK-27893) Add additionalPrinterColumns for Job Status and Reconciliation Status in CRDs - posted by "Jeesmon Jacob (Jira)" <ji...@apache.org> on 2022/06/03 14:10:00 UTC, 0 replies.
- [RESULT] [VOTE] Apache Flink Kubernetes Operator Release 1.0.0, release candidate #4 - posted by Yang Wang <da...@gmail.com> on 2022/06/03 15:57:44 UTC, 4 replies.
- [jira] [Created] (FLINK-27894) Build flink-connector-hive failed using Maven@3.8.5 - posted by "Biao Geng (Jira)" <ji...@apache.org> on 2022/06/03 16:16:00 UTC, 0 replies.
- Re: Re: [DISCUSS] FLIP-218: Support SELECT clause in CREATE TABLE(CTAS) - posted by Jing Ge <ji...@ververica.com> on 2022/06/03 19:35:59 UTC, 13 replies.
- [jira] [Created] (FLINK-27895) Enable the CI test for Hive's 3.x - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/06/04 02:47:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-222: Support full query lifecycle statements in SQL client - posted by Paul Lam <pa...@gmail.com> on 2022/06/04 08:37:49 UTC, 13 replies.
- [jira] [Created] (FLINK-27896) Clean up FlinkService#cancelJob implementation - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/06/04 08:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27897) SearchArgumentToPredicateConverter can not handle partial filters - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/06/04 11:53:00 UTC, 0 replies.
- Need help to join Apache Flink community on.Slack - posted by Sriram Ganesh <sr...@gmail.com> on 2022/06/04 15:40:32 UTC, 4 replies.
- 回复：邮件退订 - posted by 张立志 <zh...@163.com> on 2022/06/05 07:13:21 UTC, 1 replies.
- [ANNOUNCE] Apache Flink Kubernetes Operator 1.0.0 released - posted by Yang Wang <da...@gmail.com> on 2022/06/05 08:13:47 UTC, 8 replies.
- slack invite link - posted by Sucheth S <su...@gmail.com> on 2022/06/05 15:25:29 UTC, 3 replies.
- 回复： [ANNOUNCE] Apache Flink Kubernetes Operator 1.0.0 released - posted by 蒋征 <30...@qq.com.INVALID> on 2022/06/06 02:34:01 UTC, 0 replies.
- [jira] [Created] (FLINK-27898) fix PartitionPushDown in streaming mode for hive source - posted by "zoucao (Jira)" <ji...@apache.org> on 2022/06/06 03:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27899) deactivate the shade plugin doesn't take effect - posted by "jackylau (Jira)" <ji...@apache.org> on 2022/06/06 06:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27900) Decouple the advertisedAddress and rest.bind-address - posted by "Yu Wang (Jira)" <ji...@apache.org> on 2022/06/06 06:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27901) support TableEnvironment.create(configuration) in PyFlink - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2022/06/06 07:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27902) Refactor ResultPartitionType to decouple scheduling and partition release logic - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2022/06/06 07:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27903) Introduce and support HYBRID resultPartitionType - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2022/06/06 07:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27904) Introduce HsDataBuffer - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2022/06/06 07:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27905) Introduce HsSpillStrategy and Implement SelectiveSpillStrategy - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2022/06/06 07:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27906) Introduce HsDataIndex - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2022/06/06 07:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27907) Abstract and implement disk read and write logic for hybrid shuffle - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2022/06/06 07:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27908) Introduce HsResultPartition and HsSubpartitionView - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2022/06/06 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27909) Add document and tests for hybrid shuffle mode - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2022/06/06 07:42:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-228: Support Within between events in CEP Pattern - posted by Dian Fu <di...@gmail.com> on 2022/06/06 07:48:22 UTC, 7 replies.
- [DISCUSS] Api Since Version Annotation - posted by Jingsong Li <ji...@gmail.com> on 2022/06/06 07:49:33 UTC, 1 replies.
- [jira] [Created] (FLINK-27910) FileSink not registered the timer to enforce rolling policy if started from scratch - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/06/06 09:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27911) Set HDFS LEASE_TIMEOUT as user-configurable - posted by "zoucao (Jira)" <ji...@apache.org> on 2022/06/06 10:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27912) Improve operator config names - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/06/06 10:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27913) Remove savepointHistoryMaxCount and savepointHistoryMaxAge from FlinkOperatorConfiguration - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/06/06 10:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27914) Integrate JOSDK metrics with Flink Metrics reporter - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/06/06 10:38:00 UTC, 0 replies.
- How to schedule stateful function in flink - posted by Rohit Agrawal <ag...@gmail.com> on 2022/06/06 11:13:26 UTC, 0 replies.
- [jira] [Created] (FLINK-27915) WindowJoinITCase.testInnerJoinOnWTFWithOffset failed with InterruptedException - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/06/06 11:35:00 UTC, 0 replies.
- (无主题) - posted by 470905446 <47...@qq.com.INVALID> on 2022/06/06 11:40:53 UTC, 2 replies.
- [jira] [Created] (FLINK-27916) HybridSourceReaderTest.testReader failed with AssertionError - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/06/06 11:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27917) PulsarUnorderedPartitionSplitReaderTest.consumeMessageCreatedBeforeHandleSplitsChangesAndResetToEarliestPosition failed with AssertionError - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/06/06 12:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27918) SavepointITCase.testStopWithSavepointFailingAfterSnapshotCreation failed with Expected RuntimeException after snapshot creation - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/06/06 12:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27919) Add FLIP-27-based Data Generator Source - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2022/06/06 12:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27920) Documented enums constant support ExcludeFromDocumentation annotation - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2022/06/06 12:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27921) Introduce the checkResourceRequirementsWithDelay in DeclarativeSlotManager - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/06/06 12:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27922) Flink SQL unique key lost when set table.exec.mini-batch.enabled=true - posted by "zhangbin (Jira)" <ji...@apache.org> on 2022/06/06 13:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27923) Typo fix for release-1.0.0 quick-start.md - posted by "James Busche (Jira)" <ji...@apache.org> on 2022/06/06 17:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27924) Add pulsar comments in the datastream package - posted by "LuNng Wang (Jira)" <ji...@apache.org> on 2022/06/07 02:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27925) Avoid to create watcher without the resourceVersion - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/06/07 02:11:00 UTC, 0 replies.
- [VOTE] FLIP-231: Introduce SupportStatisticReport to support reporting statistics from source connectors - posted by godfrey he <go...@gmail.com> on 2022/06/07 02:41:48 UTC, 6 replies.
- Re: [DISCUSS] FLIP-224: Blacklist Mechanism - posted by Zhu Zhu <re...@gmail.com> on 2022/06/07 02:58:47 UTC, 6 replies.
- [jira] [Created] (FLINK-27926) Translate ```upgrading.md``` into chinese - posted by "Zixuan Rao (Jira)" <ji...@apache.org> on 2022/06/07 04:05:00 UTC, 0 replies.
- [VOTE] FLIP-234: Support Retryable Lookup Join To Solve Delayed Updates Issue In External Systems - posted by Lincoln Lee <li...@gmail.com> on 2022/06/07 04:17:12 UTC, 4 replies.
- [DISCUSS] FLIP-237: Thrift Format Support in Flink - posted by Chen Qin <qi...@gmail.com> on 2022/06/07 04:39:53 UTC, 5 replies.
- [jira] [Created] (FLINK-27927) Adjust table store connector common apis - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/06/07 05:12:00 UTC, 0 replies.
- [VOTE] FLIP-223: Support HiveServer2 Endpoint - posted by Shengkai Fang <fs...@gmail.com> on 2022/06/07 05:31:21 UTC, 6 replies.
- [jira] [Created] (FLINK-27928) External Resource Framework: 'external-resources' config delimiter is not working as expected - posted by "James Cho (Jira)" <ji...@apache.org> on 2022/06/07 05:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27929) Drop support for python 3.6 - posted by "LuNng Wang (Jira)" <ji...@apache.org> on 2022/06/07 06:36:00 UTC, 0 replies.
- Re: Let’s meet in Texas for amazing Apache Beam workshops and talks! - posted by Orozco Colin <or...@gmail.com> on 2022/06/07 06:39:48 UTC, 0 replies.
- [jira] [Created] (FLINK-27930) Format the timestamp in status to make it explicit - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/06/07 07:12:00 UTC, 0 replies.
- Re: [VOTE] FLIP-224: Blocklist Mechanism - posted by Chesnay Schepler <ch...@apache.org> on 2022/06/07 07:13:38 UTC, 11 replies.
- [jira] [Created] (FLINK-27931) Introduce the SqlGateway to assemble all components - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/06/07 07:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27932) align noWatermarks and withWatemarkAlignment API in PyFlink - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2022/06/07 08:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27933) Savepoint OperationResult should be serializable - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/06/07 08:50:00 UTC, 0 replies.
- Re: [DISCUSS] Update Scala 2.12.7 to 2.12.15 - posted by Martijn Visser <ma...@apache.org> on 2022/06/07 09:02:49 UTC, 2 replies.
- Re: [DISCUSS] Planning Flink 1.16 with the community - posted by Martijn Visser <ma...@apache.org> on 2022/06/07 09:15:57 UTC, 0 replies.
- [jira] [Created] (FLINK-27934) Python API- Inefficient deserialization/serialization of state variables within a batch - posted by "Frans King (Jira)" <ji...@apache.org> on 2022/06/07 09:45:00 UTC, 0 replies.
- [GitHub] [flink-connector-redis] chayim commented on pull request #2: [FLINK-15571][connector][WIP] Redis Stream connector for Flink - posted by GitBox <gi...@apache.org> on 2022/06/07 09:56:44 UTC, 0 replies.
- [jira] [Created] (FLINK-27935) Add Python doc of create temporary view API - posted by "pengmd (Jira)" <ji...@apache.org> on 2022/06/07 10:44:00 UTC, 0 replies.
- [GitHub] [flink-connector-redis] MartijnVisser commented on pull request #2: [FLINK-15571][connector][WIP] Redis Stream connector for Flink - posted by GitBox <gi...@apache.org> on 2022/06/07 12:01:10 UTC, 1 replies.
- [GitHub] [flink-connector-redis] sazzad16 commented on pull request #2: [FLINK-15571][connector][WIP] Redis Stream connector for Flink - posted by GitBox <gi...@apache.org> on 2022/06/07 12:29:08 UTC, 0 replies.
- [jira] [Created] (FLINK-27936) [JUnit5 Migration] Module: flink-connector-cassandra - posted by "Alexander Preuss (Jira)" <ji...@apache.org> on 2022/06/07 13:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27937) [JUnit5 Migration] Module: flink-connector-gcp-pubsub - posted by "Alexander Preuss (Jira)" <ji...@apache.org> on 2022/06/07 13:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27939) [JUnit5 Migration] Module: flink-connector-hive - posted by "Alexander Preuss (Jira)" <ji...@apache.org> on 2022/06/07 13:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27938) [JUnit5 Migration] Module: flink-connector-hbase - posted by "Alexander Preuss (Jira)" <ji...@apache.org> on 2022/06/07 13:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27940) [JUnit5 Migration] Module: flink-connector-jdbc - posted by "Alexander Preuss (Jira)" <ji...@apache.org> on 2022/06/07 13:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27941) [JUnit5 Migration] Module: flink-connector-kinesis - posted by "Alexander Preuss (Jira)" <ji...@apache.org> on 2022/06/07 13:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27942) [JUnit5 Migration] Module: flink-connector-rabbitmq - posted by "Alexander Preuss (Jira)" <ji...@apache.org> on 2022/06/07 13:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27943) Link Kubernetes Operator RoadMap Page To Flink RoadMap Page Web Site - posted by "ConradJam (Jira)" <ji...@apache.org> on 2022/06/07 14:15:00 UTC, 0 replies.
- [DISCUSS] FLIP-238: Introduce FLIP-27-based Data Generator Source - posted by Alexander Fedulov <al...@ververica.com> on 2022/06/07 15:47:56 UTC, 15 replies.
- [jira] [Created] (FLINK-27944) IO metric collision happens when a task has union inputs - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2022/06/07 17:04:00 UTC, 0 replies.
- Access to Apache Flink wiki (FLIP submission) - posted by dr...@gmail.com on 2022/06/07 20:01:40 UTC, 3 replies.
- [jira] [Created] (FLINK-27945) Support HA for flink operator - posted by "Jeesmon Jacob (Jira)" <ji...@apache.org> on 2022/06/07 20:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27946) Extending SQL syntax in a way similar to 'spark.sql.extensions' - posted by "liwei li (Jira)" <ji...@apache.org> on 2022/06/08 01:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27947) Introduce Spark Reader for table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/06/08 02:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27948) Unifying how result partition should be released - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2022/06/08 02:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27949) kafka create topic error - posted by "sandy du (Jira)" <ji...@apache.org> on 2022/06/08 02:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27950) flink streaming写入hive表，设置的文件后缀参数失效 - posted by "yantao (Jira)" <ji...@apache.org> on 2022/06/08 04:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27951) Translate the "Debugging Classloading" page into Chinese - posted by "Zili Sun (Jira)" <ji...@apache.org> on 2022/06/08 06:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27952) Table UDF fails when using Double.POSITIVE_INFINITY as parameters - posted by "Zhipeng Zhang (Jira)" <ji...@apache.org> on 2022/06/08 07:41:00 UTC, 0 replies.
- MATCH_RECOGNIZE And Semantics - posted by Atri Sharma <at...@apache.org> on 2022/06/08 08:23:11 UTC, 3 replies.
- [jira] [Created] (FLINK-27953) using the original order to add the primary key in PushProjectIntoTableSourceScanRule - posted by "zoucao (Jira)" <ji...@apache.org> on 2022/06/08 08:45:00 UTC, 0 replies.
- [DISCUSS] Releasing 1.15.1 - posted by David Anderson <da...@apache.org> on 2022/06/08 09:39:59 UTC, 13 replies.
- [jira] [Created] (FLINK-27954) JobVertexFlameGraphHandler does not work on standby Dispatcher - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/06/08 10:56:00 UTC, 0 replies.
- Re: [DISCUSS] Releasing Flink 1.14.5 - posted by Xingbo Huang <hx...@gmail.com> on 2022/06/08 11:16:05 UTC, 0 replies.
- [jira] [Created] (FLINK-27955) Fix the problem of windows installation failure in PyFlink - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/06/08 11:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27956) Kubernetes Operator Deployment strategy type should be Recreate - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/06/08 11:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27957) Extract AppendOnlyFileStore out of KeyValueFileStore - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/06/08 11:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27958) Compare batch maxKey to reduce comparisons in SortMergeReader - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/06/08 12:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27959) Use ResolvedSchema in flink-avro instead of TableSchema - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/06/08 12:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27960) Make the apt-get updating optional - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/06/08 14:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27961) The EventUtils generate event name should take the resource's uid into account - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/06/08 14:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27962) KafkaSourceReader fails to commit consumer offsets for checkpoints - posted by "Dmytro (Jira)" <ji...@apache.org> on 2022/06/08 22:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27963) FlinkRuntimeException in KafkaSink causes a Flink job to hang - posted by "Dmytro (Jira)" <ji...@apache.org> on 2022/06/08 22:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27964) Support Cassandra connector in Python DataStream API - posted by "pengmd (Jira)" <ji...@apache.org> on 2022/06/09 03:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27965) Query schema is not correct for insert overwrite clause when source and target table are same - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/06/09 03:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27966) All the classes move to the connector specific files - posted by "LuNng Wang (Jira)" <ji...@apache.org> on 2022/06/09 03:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27967) Unable to inject entropy on s3 prefix when doing a save point in Flink - posted by "Vinay Devadiga (Jira)" <ji...@apache.org> on 2022/06/09 07:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27968) end-to-end-tests-sql CI test failed - posted by "LuNng Wang (Jira)" <ji...@apache.org> on 2022/06/09 08:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27969) StreamPhysicalOverAggregate doesn't support consuming update and delete changes - posted by "Spongebob (Jira)" <ji...@apache.org> on 2022/06/09 08:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27970) [JUnit5 Migration] Module: flink-hadoop-buik - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2022/06/09 09:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27971) [JUnit5 Migration] Module: flink-json - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2022/06/09 09:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27972) Race condition between task/savepoint notification failure - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/06/09 10:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27973) Introduce TableWrite and TableCommit as an abstraction layer above FileStore for writing RowData - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/06/09 11:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27974) Potentially wrong classloader being used to create dynamic table sources - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/06/09 14:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27975) Remove unnecessary RBAC rules from operator - posted by "Márton Balassi (Jira)" <ji...@apache.org> on 2022/06/09 14:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27976) [WebUi] Allow order by jobname - posted by "João Boto (Jira)" <ji...@apache.org> on 2022/06/09 15:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27977) SavePoints housekeeping API in Flink Cli, Rest API, SQL client - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/06/09 18:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27978) Update spotless and add add-exports to support jdk17 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/06/09 19:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27979) Support to upgrade session cluster in a more fine grained way - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/06/10 02:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27980) Add python examples to document of "DataStream API Integration" - posted by "pengmd (Jira)" <ji...@apache.org> on 2022/06/10 03:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27981) Add python examples to document of Time Attributes" - posted by "pengmd (Jira)" <ji...@apache.org> on 2022/06/10 04:01:00 UTC, 0 replies.
- [RESULT][VOTE]FLIP-234: Support Retryable Lookup Join To Solve Delayed Updates Issue In External Systems - posted by Lincoln Lee <li...@gmail.com> on 2022/06/10 05:21:01 UTC, 0 replies.
- [RESULT][VOTE] FLIP-231: Introduce SupportsStatisticReport to support reporting statistics from source connectors - posted by godfrey he <go...@gmail.com> on 2022/06/10 05:32:18 UTC, 0 replies.
- [jira] [Created] (FLINK-27982) FLIP-231: Introduce SupportsStatisticReport to support reporting statistics from source connectors - posted by "godfrey he (Jira)" <ji...@apache.org> on 2022/06/10 05:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27983) Introduce SupportsStatisticsReport interface - posted by "godfrey he (Jira)" <ji...@apache.org> on 2022/06/10 05:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27984) Introduce FileBasedStatisticsReportableDecodingFormat interface - posted by "godfrey he (Jira)" <ji...@apache.org> on 2022/06/10 05:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27986) Refactor the name of finish method for JdbcOutputFormatBuilder - posted by "Lei Xie (Jira)" <ji...@apache.org> on 2022/06/10 05:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27985) Introduce FlinkRecomputeStatisticsProgram to compute statistics after filter push and partition pruning - posted by "godfrey he (Jira)" <ji...@apache.org> on 2022/06/10 05:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27987) Let FileSystemTableSource extend from SupportsStatisticReport - posted by "godfrey he (Jira)" <ji...@apache.org> on 2022/06/10 05:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27988) Let HiveTableSource extend from SupportsStatisticReport - posted by "godfrey he (Jira)" <ji...@apache.org> on 2022/06/10 05:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27990) Parquet format supports reporting statistics - posted by "godfrey he (Jira)" <ji...@apache.org> on 2022/06/10 05:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27989) CSV format supports reporting statistics - posted by "godfrey he (Jira)" <ji...@apache.org> on 2022/06/10 05:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27991) ORC format supports reporting statistics - posted by "godfrey he (Jira)" <ji...@apache.org> on 2022/06/10 05:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27992) cep StreamExecMatch need check the parallelism and maxParallelism of the two transformation in it - posted by "jackylau (Jira)" <ji...@apache.org> on 2022/06/10 05:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27993) When only use 'flex SQL' to develop programs, `watermark` can be defined when creating view tables - posted by "HunterHunter (Jira)" <ji...@apache.org> on 2022/06/10 05:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27994) ERROR org.apache.flink.runtime.source.coordinator.SourceCoordinator - posted by "wangkang (Jira)" <ji...@apache.org> on 2022/06/10 06:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27995) Upgrade Janio version - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/06/10 06:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27996) Hive dialect support interval - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/06/10 07:26:00 UTC, 0 replies.
- [DISCUSS] FLIP-240: Introduce "ANALYZE TABLE" Syntax - posted by godfrey he <go...@gmail.com> on 2022/06/10 07:53:38 UTC, 17 replies.
- [jira] [Created] (FLINK-27997) How to unregister custom metrics at runtime? - posted by "henvealf (Jira)" <ji...@apache.org> on 2022/06/10 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27998) Upgrade Calcite version to 1.30 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/06/10 09:41:00 UTC, 0 replies.
- [VOTE] Release 1.14.5, release candidate #1 - posted by Xingbo Huang <hx...@gmail.com> on 2022/06/10 09:57:38 UTC, 6 replies.
- [jira] [Created] (FLINK-27999) Fix test failure for Hive3 - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/06/10 10:09:00 UTC, 0 replies.
- [VOTE] Update Flink's Scala 2.12 support from 2.12.7 to 2.12.16 - posted by Martijn Visser <ma...@apache.org> on 2022/06/10 10:32:23 UTC, 4 replies.
- [jira] [Created] (FLINK-28000) security.kerberos.login.principal can be defined wihtout keytab which is wrong configuration - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/06/10 10:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28001) PlannerScalaFreeITCase.testImperativeUdaf failed with Permission denied - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/06/10 11:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28002) test_connectors.py failed with "object is not an instance of declaring class" in JDK11 - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/06/10 11:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28003) 'pos ' field would be updated to 'POSITION' when use SqlClient - posted by "Jing Zhang (Jira)" <ji...@apache.org> on 2022/06/10 12:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28004) Reduce CI heap space by 25% - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/06/10 13:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28005) Reduce network memory in UnalignedCheckpointITCase - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/06/10 13:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28006) Run architecture tests in single JVM - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/06/10 13:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28007) Tests for AWS Connectors Using SDK v2 to use Synchronous Clients - posted by "Zichen Liu (Jira)" <ji...@apache.org> on 2022/06/10 17:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28008) Can not get secondary resource from after operator restart - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/06/11 01:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28009) Optimize data split - posted by "xingyuan cheng (Jira)" <ji...@apache.org> on 2022/06/11 09:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28010) Use deleteRange to optimize the clear operation of RocksDBMapState. - posted by "ming li (Jira)" <ji...@apache.org> on 2022/06/11 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28011) Optimize getAllPartitions in HiveSource - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/06/12 05:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28012) Add built-in support for fetching jar from GCS (Google Cloud Storage) - posted by "Xin Hao (Jira)" <ji...@apache.org> on 2022/06/12 09:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28013) java.lang.ClassNotFoundException: org.apache.flink.hbase.shaded.io.netty.channel.EventLoopGroup - posted by "JasonLee (Jira)" <ji...@apache.org> on 2022/06/12 16:36:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-223: Support HiveServer2 Endpoint - posted by Shengkai Fang <fs...@gmail.com> on 2022/06/13 01:44:10 UTC, 0 replies.
- [jira] [Created] (FLINK-28014) Extract snapshot related methods to SnapshotManager - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/06/13 01:51:00 UTC, 0 replies.
- [VOTE] FLIP-228: Support Within between events in CEP Pattern - posted by Nicholas <pr...@163.com> on 2022/06/13 02:15:44 UTC, 9 replies.
- [jira] [Created] (FLINK-28015) FROM_UNIXTIME could not be used in Table API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2022/06/13 05:20:00 UTC, 0 replies.
- [ANNOUNCE] New Apache Flink PMC Member - Jingsong Lee - posted by Becket Qin <be...@gmail.com> on 2022/06/13 06:58:55 UTC, 35 replies.
- [jira] [Created] (FLINK-28016) Support Maven 3.3+ - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/06/13 08:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28017) Introduce bucket-key to table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/06/13 08:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28018) the start index to create empty splits in BinaryInputFormat#createInputSplits is inappropriate - posted by "zl (Jira)" <ji...@apache.org> on 2022/06/13 08:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28019) State staled errorRetractableTopNFunction - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2022/06/13 08:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28020) Refactor Flink connector for table store with FileStoreTable - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/06/13 09:04:00 UTC, 0 replies.
- [VOTE] FLIP-222: Support full job lifecycle statements in SQL client - posted by Paul Lam <pa...@gmail.com> on 2022/06/13 09:09:32 UTC, 4 replies.
- [jira] [Created] (FLINK-28021) Add FLIP-33 metrics to FileSystem connector - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/06/13 09:35:00 UTC, 0 replies.
- [DISCUSS ] Make state.backend.incremental as true by default - posted by Lihe Ma <ma...@163.com> on 2022/06/13 09:59:17 UTC, 19 replies.
- [jira] [Created] (FLINK-28022) Support Google Cloud PubSub connector in Python DataStream API - posted by "pengmd (Jira)" <ji...@apache.org> on 2022/06/13 12:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28023) Translate "Native Kubernetes" page into Chinese - posted by "linqichen (Jira)" <ji...@apache.org> on 2022/06/13 12:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28024) Azure worker stops operating due to log files becoming too big - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/06/13 13:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28025) Document the change of serviceAccount in upgrading doc of k8s opeator - posted by "Biao Geng (Jira)" <ji...@apache.org> on 2022/06/13 14:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28026) Add benchmark module for flink table store - posted by "Aiden Gong (Jira)" <ji...@apache.org> on 2022/06/13 14:33:00 UTC, 0 replies.
- Flink running same task on different Task Manager - posted by Great Info <gu...@gmail.com> on 2022/06/13 16:01:42 UTC, 2 replies.
- [jira] [Created] (FLINK-28027) Initialise Async Sink maximum number of in flight messages to low number for rate limiting strategy - posted by "Zichen Liu (Jira)" <ji...@apache.org> on 2022/06/13 16:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28028) Common secure credential protection mechanism in Flink SQL - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/06/13 19:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28029) Checkpoint always hangs when running some jobs - posted by "Pauli Gandhi (Jira)" <ji...@apache.org> on 2022/06/13 22:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28030) Checkpoint always hangs when running some jobs - posted by "Pauli Gandhi (Jira)" <ji...@apache.org> on 2022/06/13 22:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28031) Checkpoint always hangs when running some jobs - posted by "Pauli Gandhi (Jira)" <ji...@apache.org> on 2022/06/13 22:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28032) Flink checkpointing hangs with some jobs - posted by "Pauli Gandhi (Jira)" <ji...@apache.org> on 2022/06/13 22:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28033) find and output new min watermark mybe wrong when in multichannel - posted by "YeAble (Jira)" <ji...@apache.org> on 2022/06/14 01:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28034) ClassCastException occurred in creating a checkpoint with merge windows - posted by "Takayuki Eimizu (Jira)" <ji...@apache.org> on 2022/06/14 02:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28035) Enable scan reading different bucket num for rescale bucket - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/06/14 02:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28036) Use correct writable type to creaet ConstantObjectInspector - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/06/14 03:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28037) Flink SQL Upsert-Kafka can not support Flink1.14.x - posted by "Jiangfei Liu (Jira)" <ji...@apache.org> on 2022/06/14 04:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28038) RocksDB rescaling improvement & rescaling benchmark - umbrella ticket - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2022/06/14 06:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28039) Flink Table Store Ecosystem: Compute Engine Readers - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/06/14 06:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28040) Introduce Trino reader for table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/06/14 06:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28041) table store cannot distinguish filesystem Scheme when system have 'hadoop classpath' - posted by "yutao (Jira)" <ji...@apache.org> on 2022/06/14 07:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28042) Create an extension for resetting HiveConf - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/06/14 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28043) "Invalid lambda deserialization" in AvroParquetReaders - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2022/06/14 09:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28044) Add hadoop filesystems configuration possibility to all deployment targets - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/06/14 10:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28045) [umbrella] Deprecate SourceFunction API - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2022/06/14 10:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28046) Annotate SourceFunction as deprecated - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2022/06/14 10:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28047) Deprecate StreamExecutionEnvironment#readFiles(*) methods in favor of FileSource#forRecordStreamFormat/forBulkFileFormat. - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2022/06/14 11:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28048) Introduce Source API alternative to FiniteTestSource - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2022/06/14 11:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28049) Introduce FLIP-208 functionality to stop Source based on consumed records - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2022/06/14 11:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28050) Introduce Source API alternative to SourceExecutionContext#fromCollection(*) methods - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2022/06/14 11:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28051) Introduce Source API alternative to ExternallyInducedSource - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2022/06/14 11:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28052) Remove AdaptiveSchedulerTest#RunFailedJobListener - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/06/14 12:02:00 UTC, 0 replies.
- [DISCUSS] Dockerimage + Helm chart only patch releases for the Kubernetes operator - posted by Gyula Fóra <gy...@apache.org> on 2022/06/14 12:10:14 UTC, 7 replies.
- [jira] [Created] (FLINK-28053) Introduce queue to execute request in sequence - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/06/14 12:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28054) Introduce Source API utilities to control records emitted per checkpoint - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2022/06/14 13:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28055) Introduce Source API utilities for throttling number of records emitted per second. - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2022/06/14 13:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28056) Introduce high level API for cases that do not require specific SourceEnumerator logic. - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2022/06/14 13:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28057) LD_PRELOAD is hardcoded to x64 on flink-docker - posted by "Nicolas Ferrario (Jira)" <ji...@apache.org> on 2022/06/14 13:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28058) add option SKIP_FIRST_DATA_ROW - posted by "lucas.wu (Jira)" <ji...@apache.org> on 2022/06/14 13:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28059) Parallelize e2e tests - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/06/14 14:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28060) Kafka Commit on checkpointing fails repeatedly after a broker restart - posted by "Christian Lorenz (Jira)" <ji...@apache.org> on 2022/06/14 15:09:00 UTC, 0 replies.
- [SUMMARY] Flink 1.16 release sync of 2022-06-14 - posted by Martijn Visser <ma...@apache.org> on 2022/06/14 18:03:10 UTC, 0 replies.
- [jira] [Created] (FLINK-28061) create new tech blog for connector development based on Source API - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/06/14 20:01:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-217 Support watermark alignment of source splits - posted by Thomas Weise <th...@apache.org> on 2022/06/14 22:44:34 UTC, 12 replies.
- [jira] [Created] (FLINK-28062) Flink SQL Upsert-Kafka can not support Flink1.14.x With Sink Buffer - posted by "Jiangfei Liu (Jira)" <ji...@apache.org> on 2022/06/15 01:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28063) Optimize PredicateBuilder.in for lots of parameters - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/06/15 02:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28064) PredicateBuilder.in should accept null parameters - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/06/15 02:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28065) A never reached code in ProcessMemoryUtils Class - posted by "zhuyufeng (Jira)" <ji...@apache.org> on 2022/06/15 03:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28066) Use FileSystem.createRecoverableWriter in FileStoreCommit - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/06/15 03:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28067) Introduce a tablestore HiveCatalog - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/06/15 03:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28068) Control the total memory of a sink task - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/06/15 03:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28069) Cannot attach SSL JKS file for Kafka connector - posted by "SunShun (Jira)" <ji...@apache.org> on 2022/06/15 04:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28070) [JUnit5 Migration] Migrate ScalaAPICompletenessTestBase to Junit5 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/06/15 05:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28071) Support missing built-in functions in Table API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2022/06/15 05:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28072) Set Hadoop FileSystem for Orc reader - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/06/15 06:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28073) Table Store supports Flink 1.14 - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/06/15 06:44:00 UTC, 0 replies.
- [DISCUSS] FLIP-241: Completed Jobs Information Enhancement - posted by junhan yang <ya...@gmail.com> on 2022/06/15 07:03:35 UTC, 20 replies.
- [jira] [Created] (FLINK-28074) display - posted by "godfrey he (Jira)" <ji...@apache.org> on 2022/06/15 08:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28075) get statistics for partitioned table even without partition pruning - posted by "godfrey he (Jira)" <ji...@apache.org> on 2022/06/15 09:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28076) CI runs keep getting stuck - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/06/15 09:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28077) KeyedStateCheckpointingITCase.testWithMemoryBackendSync runs into timeout - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/06/15 09:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28078) ZooKeeperMultipleComponentLeaderElectionDriverTest.testLeaderElectionWithMultipleDrivers runs into timeout - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/06/15 09:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28079) Check Hive DDL against table store schema when creating table - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/06/15 09:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28080) Introduce MutableURLClassLoader as parent class of FlinkUserClassLoader and SafetyNetWrapperClassLoader - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/06/15 15:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28081) Remove deprecated Hadoop specific Flink configuration options - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/06/15 15:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28082) Support end to end encryption on Pulsar connector. - posted by "Yufan Sheng (Jira)" <ji...@apache.org> on 2022/06/15 17:14:00 UTC, 0 replies.
- [VOTE] Deprecate SourceFunction API - posted by Alexander Fedulov <al...@ververica.com> on 2022/06/15 17:54:06 UTC, 5 replies.
- [jira] [Created] (FLINK-28083) PulsarSource cannot work with object-reusing DeserializationSchema. - posted by "Yufan Sheng (Jira)" <ji...@apache.org> on 2022/06/15 18:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28084) Pulsar unordered reader should disable retry and delete reconsume logic. - posted by "Yufan Sheng (Jira)" <ji...@apache.org> on 2022/06/15 21:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28085) Close all the pending Pulsar transactions when flink shutdown the pipeline. - posted by "Yufan Sheng (Jira)" <ji...@apache.org> on 2022/06/15 22:00:00 UTC, 0 replies.
- About the Current22 event - posted by Becket Qin <be...@gmail.com> on 2022/06/16 02:10:31 UTC, 0 replies.
- Re: Contributing to Apache Flink - posted by Shubham Bansal <sh...@gmail.com> on 2022/06/16 02:45:13 UTC, 1 replies.
- [jira] [Created] (FLINK-28086) Table Store Catalog supports partition methods - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/06/16 02:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28087) FlinkDeployment name validation - posted by "Fred k (Jira)" <ji...@apache.org> on 2022/06/16 03:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28088) Adjust table store document to catalog - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/06/16 06:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28089) Hive dialect support "tablesample (xx rows)" - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/06/16 07:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28090) Support attachAsDatastream - posted by "Zixuan Rao (Jira)" <ji...@apache.org> on 2022/06/16 08:10:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-228: Support Within between events in CEP Pattern - posted by Nicholas <pr...@163.com> on 2022/06/16 08:18:47 UTC, 0 replies.
- [jira] [Created] (FLINK-28091) Thread leak in CheckpointResourcesCleanupRunnerTest#testCancellationAfterStart - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/06/16 09:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28092) Support ASCII and CHR built-in function in the Table API - posted by "LuNing Wang (Jira)" <ji...@apache.org> on 2022/06/16 09:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28093) Flink SQL Kafka Source Can Not Support Recovery On Checkpoint - posted by "Jiangfei Liu (Jira)" <ji...@apache.org> on 2022/06/16 09:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28094) [aws][Kinesis][Firehose] Upgrade AWS SDK to support ap-southeast-3 - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2022/06/16 10:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28095) Replace IOUtils dependency on oss filesystem - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/06/16 10:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28096) Hive dialect support set variable - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/06/16 10:30:00 UTC, 0 replies.
- [DISCUSS] How to delete deprecated configs/functions - posted by Gabor Somogyi <ga...@gmail.com> on 2022/06/16 10:43:54 UTC, 7 replies.
- [jira] [Created] (FLINK-28097) Remove bundling of formats-common in json/csv format - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/06/16 11:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28098) Refactor table store compactor - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/06/16 11:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28099) KafkaSink timeout exception - posted by "Крючкова марина Сергеевна (Jira)" <ji...@apache.org> on 2022/06/16 14:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28100) rocketmq-flink checkpoint - posted by "yantao (Jira)" <ji...@apache.org> on 2022/06/17 01:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28101) YARNHighAvailabilityITCase failed on azure - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/06/17 02:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28102) Flink AkkaRpcSystemLoader fails when temporary directory is a symlink - posted by "Prabhu Joseph (Jira)" <ji...@apache.org> on 2022/06/17 04:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28103) Job cancelling api returns 404 when job is actually running - posted by "David (Jira)" <ji...@apache.org> on 2022/06/17 06:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28104) Drop the unused order parameter in FirstValueFunction/LastValueFunction - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/06/17 07:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28105) We should test the copied object in GlobFilePathFilterTest#testGlobFilterSerializable - posted by "zl (Jira)" <ji...@apache.org> on 2022/06/17 08:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28106) Create flink-table-store-connector-base to shade all flink dependencies - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/06/17 08:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28107) Support id of document is null - posted by "LuNing Wang (Jira)" <ji...@apache.org> on 2022/06/17 08:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28108) Support compaction for append-only table - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/06/17 09:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28109) Delete useful code in the row emitter. - posted by "LuNing Wang (Jira)" <ji...@apache.org> on 2022/06/17 09:28:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-222: Support full job lifecycle statements in SQL client - posted by Paul Lam <pa...@gmail.com> on 2022/06/17 09:44:06 UTC, 0 replies.
- [jira] [Created] (FLINK-28110) Table Store Hive Reader supports projection pushdown - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/06/17 09:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28111) flinksql use hivecatalog cause union all operation lost 'eventTime attribute' - posted by "yutao (Jira)" <ji...@apache.org> on 2022/06/17 10:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28112) Misleading error message when Hadoop S3FileSystem is used and not at classpath - posted by "Prabhu Joseph (Jira)" <ji...@apache.org> on 2022/06/17 12:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28113) Document periodic savepointing - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/06/17 13:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28114) The path of the Python client interpreter could not point to an archive file in distributed file system - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2022/06/17 14:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28115) Flink 1.15.0 Parallelism Rebalance causes flink job failure - posted by "Huameng Li (Jira)" <ji...@apache.org> on 2022/06/17 17:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28116) Elasticsearch connector doesn't provide security through token - posted by "Deepika Sahu (Jira)" <ji...@apache.org> on 2022/06/17 17:42:00 UTC, 0 replies.
- Permission to create a FLIP wiki page - posted by "Teoh, Hong" <li...@amazon.co.uk.INVALID> on 2022/06/18 13:13:35 UTC, 4 replies.
- [jira] [Created] (FLINK-28117) More metrics for FileSource - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/06/18 14:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28118) Introduce TableStoreOptions to merge all options - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/06/19 10:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28119) Update the document for Contribute Documentation - posted by "Shuiqiang Chen (Jira)" <ji...@apache.org> on 2022/06/19 14:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28120) Meet assert error: BatchPhysicalExchange.BATCH_PHYSICAL has lower cost then best cost of subset :RelSubset#15.BATCH_PHYSICAL.hash[0, 1]true.[]] - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/06/20 01:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28121) Translate in "Extension Points" and "Full Stack Example" in "User-defined Sources & Sinks" page - posted by "Chengkai Yang (Jira)" <ji...@apache.org> on 2022/06/20 02:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28122) Translate "Overview " and "Project Configuration" in "User-defined Sources & Sinks" page - posted by "Chengkai Yang (Jira)" <ji...@apache.org> on 2022/06/20 02:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28123) When a flink job is restarted, the metaspce size of the taskmanager does not decrease but keeps increasing. After several restarts, the flink job metaspce oom. - posted by "Zhuang Liu (Jira)" <ji...@apache.org> on 2022/06/20 02:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28124) Flink on K8S in hosetNetwork mode, the CPU usage will spike - posted by "liuzhuo (Jira)" <ji...@apache.org> on 2022/06/20 03:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28125) Promote leadership changing logs to INFO level - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2022/06/20 05:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28126) Iteration gets stuck when replayable datastream and its downstream operator have different parallelism - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2022/06/20 05:55:00 UTC, 0 replies.
- Re: [VOTE] FLIP-168: Speculative Execution for Batch Job - posted by Yun Gao <yu...@aliyun.com.INVALID> on 2022/06/20 06:25:31 UTC, 3 replies.
- [GitHub] [flink-connector-rabbitmq] MartijnVisser commented on pull request #1: [FLINK-20628] RabbitMQ Connector using FLIP-27 Source API - posted by GitBox <gi...@apache.org> on 2022/06/20 07:34:46 UTC, 1 replies.
- [GitHub] [flink-connector-rabbitmq] wanglijie95 commented on pull request #1: [FLINK-20628] RabbitMQ Connector using FLIP-27 Source API - posted by GitBox <gi...@apache.org> on 2022/06/20 07:43:09 UTC, 0 replies.
- [DISCUSS] FLIP-242: Introduce configurable CongestionControlStrategy for Async Sink - posted by "Teoh, Hong" <li...@amazon.co.uk.INVALID> on 2022/06/20 07:52:17 UTC, 8 replies.
- [ANNOUNCE] New Apache Flink Committers: Qingsheng Ren, Shengkai Fang - posted by Jark Wu <im...@gmail.com> on 2022/06/20 07:53:05 UTC, 32 replies.
- [jira] [Created] (FLINK-28127) Cancel during stop-with-savepoint may still create savepoint - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/06/20 08:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28128) Create e2e test for spark reader - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/06/20 08:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28129) Add documentation for rescale - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/06/20 09:14:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-224: Blocklist Mechanism - posted by Lijie Wang <wa...@gmail.com> on 2022/06/20 10:09:39 UTC, 0 replies.
- [RESULT] [VOTE] Release 1.14.5, release candidate #1 - posted by Xingbo Huang <hx...@gmail.com> on 2022/06/20 10:56:22 UTC, 0 replies.
- [RESULT][VOTE] FLIP-168: Speculative Execution for Batch Job - posted by Zhu Zhu <zh...@apache.org> on 2022/06/20 11:05:57 UTC, 0 replies.
- [jira] [Created] (FLINK-28130) FLIP-224: Blocklist Mechanism - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2022/06/20 11:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28131) FLIP-168: Speculative Execution for Batch Job - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2022/06/20 11:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28132) Should we remove type validations when using lookup-key join ? - posted by "Zha Ji (Jira)" <ji...@apache.org> on 2022/06/20 11:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28133) Rework DefaultScheduler to directly deploy executions - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2022/06/20 11:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28134) Introduce SpeculativeExecutionVertex - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2022/06/20 11:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28135) Introduce SlowTaskDetector - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2022/06/20 11:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28136) Implement ExecutionTimeBasedSlowTaskDetector - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2022/06/20 11:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28137) Introduce SpeculativeScheduler - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2022/06/20 11:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28138) Add metrics for speculative execution - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2022/06/20 11:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28139) Add documentation for speculative execution - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2022/06/20 11:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28140) Improve the documentation by adding Python examples - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2022/06/20 12:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28141) Document Dynamic Namespaces - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/06/20 12:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28142) Enrich TaskManagerLocation with node information - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2022/06/20 13:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28143) Introduce BlocklistHandler - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2022/06/20 13:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28144) Let JobMaster support blocklist mechanism - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2022/06/20 13:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28145) Let ResourceManager support blocklist mechanism - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2022/06/20 13:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28146) Sync blocklist information between JobMaster & ResourceManager - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2022/06/20 13:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28147) Update httplib2 to at least 0.19.0 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/06/20 14:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28148) Unable to load jar connector to a Python Table API app - posted by "Zichen Liu (Jira)" <ji...@apache.org> on 2022/06/20 16:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28149) [FLIP-223] Support HiveServer2 Endpoint - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/06/21 02:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28150) Introduce the hiveserver2 endpoint and factory - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/06/21 02:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28151) Introduce the session-related API for HiveServer2 Endpoint - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/06/21 02:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28152) Introduce the statement-related API for HiveServer2 Endpoint - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/06/21 02:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28153) Introduce the catalog-related API for HiveServer2 Endpoint - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/06/21 02:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28154) Introduce the E2E test for HiveServer2 Endpoint - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/06/21 02:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28155) Add documentation for "ALTER TABLE ... COMPACT" - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/06/21 03:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28156) Flink KafkaSource with Bounded Throw Exception - posted by "Jiangfei Liu (Jira)" <ji...@apache.org> on 2022/06/21 03:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28157) Table Store Hive Reader supports Hive3 - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/06/21 03:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28158) Flink supports all modes of Hive UDAF (PARTIAL1, PARTIAL2, FINAL, COMPLETE) - posted by "tartarus (Jira)" <ji...@apache.org> on 2022/06/21 03:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28159) Table Store: Bucket pruning based on primary key filter - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/06/21 03:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28160) org.apache.flink.api.common.InvalidProgramException: Table program cannot be compiled. - posted by "cjh (Jira)" <ji...@apache.org> on 2022/06/21 06:02:00 UTC, 0 replies.
- [RESULT][VOTE] Deprecate SourceFunction API - posted by Alexander Fedulov <al...@ververica.com> on 2022/06/21 06:29:50 UTC, 0 replies.
- [jira] [Created] (FLINK-28161) Introduce the session related API for REST endpoint - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/06/21 06:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28162) Introduce the operation-related API for REST endpoint - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/06/21 07:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28163) Introduce the statement related API for REST endpoint - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/06/21 07:03:00 UTC, 0 replies.
- [DISCUSS] Flink Kubernetes Operator release cadence proposal - posted by Őrhidi Mátyás <ma...@gmail.com> on 2022/06/21 07:04:23 UTC, 6 replies.
- [jira] [Created] (FLINK-28164) Introduce utilities API for REST endpint - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/06/21 07:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28165) Remove include_hadoop_aws profile - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/06/21 08:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28166) Configurable Automatic Retries on Error - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/06/21 09:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28167) flink native k8s动态创建的taskmanager 直接创建pod，为啥不创建deployment？ - posted by "hob007 (Jira)" <ji...@apache.org> on 2022/06/21 09:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28168) org.apache.flink.table.api.ValidationException: Data type 'ARRAY NOT NULL' does not support null values. - posted by "熊搏 (Jira)" <ji...@apache.org> on 2022/06/21 09:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28169) GlueSchemaRegistryJsonKinesisITCase fails on JDK11 due to NoSuchMethodError - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/06/21 10:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28170) Python tests are taking more than 240 minutes to complete, causing timeouts - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/06/21 10:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28171) Adjust Job and Task manager port definitions to work with Istio+mTLS - posted by "Moshe Elisha (Jira)" <ji...@apache.org> on 2022/06/21 10:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28172) Scatter dstl files into separate directories by job id - posted by "Feifan Wang (Jira)" <ji...@apache.org> on 2022/06/21 10:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28173) Multiple Parquet format tests are failing with NoSuchMethodError - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/06/21 10:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28174) Dynamically resolve StatsD Reporter Host - posted by "Emile (Jira)" <ji...@apache.org> on 2022/06/21 10:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28175) Improve LicenseChecker output - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/06/21 10:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28176) test_es_sink_dynamic failed in jdk11 - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/06/21 11:28:00 UTC, 0 replies.
- Please add me to the contributors list - posted by Yankee <ya...@foxmail.com> on 2022/06/21 11:43:37 UTC, 2 replies.
- [jira] [Created] (FLINK-28177) Elasticsearch6DynamicSinkITCase.testWritingDocumentsNoPrimaryKey failed with 503 Service Unavailable - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/06/21 11:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28178) Show the delegated StateBackend and whether changelog is enabled in the UI - posted by "Feifan Wang (Jira)" <ji...@apache.org> on 2022/06/21 11:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28179) LeafPredicate accepts multiple literals - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/06/21 12:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28180) Unify Application and SessionJob reconcilers - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/06/21 12:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28181) Add support in FlinkSessionJob to submit job using jar available in jobManager's classpath - posted by "Jeesmon Jacob (Jira)" <ji...@apache.org> on 2022/06/21 12:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28182) Support Avro generic record decoder in PyFlink - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2022/06/21 13:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28183) flink-python is lacking several test dependencies - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/06/21 13:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28184) LogStoreE2eTest is not stable - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/06/21 13:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28185) "Invalid negative offset" when using OffsetsInitializer.timestamp(.) - posted by "Peter Schrott (Jira)" <ji...@apache.org> on 2022/06/21 13:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28186) Trigger Operator Events on Configuration Changes - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/06/21 13:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28187) Duplicate job submission for FlinkSessionJob - posted by "Jeesmon Jacob (Jira)" <ji...@apache.org> on 2022/06/21 15:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28188) Documentation: Wrong default value for classloader.parent-first-patterns.default - posted by "Arseniy Tashoyan (Jira)" <ji...@apache.org> on 2022/06/21 20:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28189) The taskmanager dynamically created by flink native k8s creates pods directly, why not create a deployment? - posted by "hob007 (Jira)" <ji...@apache.org> on 2022/06/22 01:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28190) NullPointerException is thrown if the intermediate result of nesting UDFs is used - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/06/22 03:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28191) 【flink-runtime】Achieve metrics summary and unified active reporting - posted by "fengjk (Jira)" <ji...@apache.org> on 2022/06/22 03:28:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.14.5 released - posted by Xingbo Huang <hx...@gmail.com> on 2022/06/22 03:50:18 UTC, 2 replies.
- [jira] [Created] (FLINK-28192) RescaleBucketITCase is not stable - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/06/22 07:07:00 UTC, 0 replies.
- [DISCUSS] FLIP-244: Support IterativeCondition with Accumulator in CEP Pattern - posted by md peng <pe...@gmail.com> on 2022/06/22 07:24:03 UTC, 0 replies.
- [jira] [Created] (FLINK-28193) Enable to identify whether a job vertex contains source/sink operators - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2022/06/22 08:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28194) Remove workaround around avro sql jar - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/06/22 09:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28195) Annotate Python3.6 as deprecated in PyFlink 1.16 - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/06/22 09:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28196) Rename hadoop.version property - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/06/22 10:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28197) Flink didn't deletes the YARN application files when the submit is failed in application mode - posted by "zlzhang0122 (Jira)" <ji...@apache.org> on 2022/06/22 11:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28198) CassandraConnectorITCase#testRaiseCassandraRequestsTimeouts fails with timeout - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/06/22 11:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28199) Failures on YARNHighAvailabilityITCase.testClusterClientRetrieval and YARNHighAvailabilityITCase.testKillYarnSessionClusterEntrypoint - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/06/22 11:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28200) Add Table Store Hive reader documentation - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/06/22 11:52:00 UTC, 0 replies.
- [VOTE] Release 1.15.1, release candidate #1 - posted by David Anderson <da...@apache.org> on 2022/06/22 12:20:04 UTC, 6 replies.
- [jira] [Created] (FLINK-28201) Generalize utils around dependency-plugin - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/06/22 12:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28202) Generalize utils around shade-plugin - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/06/22 12:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28203) Mark all bundled dependencies as optional - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/06/22 12:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28204) Deleting a FlinkDeployment results in an error on the pod - posted by "Matt Casters (Jira)" <ji...@apache.org> on 2022/06/22 13:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28205) jdbc connector 定时调度 flush 存在内存泄漏 bug - posted by "michaelxiang (Jira)" <ji...@apache.org> on 2022/06/22 13:59:00 UTC, 0 replies.
- [DISCUSS] Release Kubernetes operator 1.0.1 - posted by Gyula Fóra <gy...@gmail.com> on 2022/06/22 14:23:10 UTC, 5 replies.
- [DISCUSS] Support partition pruning for streaming reading - posted by cao zou <zo...@gmail.com> on 2022/06/22 16:48:47 UTC, 0 replies.
- Re: [DISCUSS] Maintain a Calcite repository for Flink to accelerate the development for Flink SQL features - posted by Martijn Visser <ma...@apache.org> on 2022/06/22 18:00:56 UTC, 2 replies.
- [jira] [Created] (FLINK-28206) EOFException on Checkpoint Recovery - posted by "uharaqo (Jira)" <ji...@apache.org> on 2022/06/22 19:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28207) Disabling webhook should also disable mutator - posted by "Márton Balassi (Jira)" <ji...@apache.org> on 2022/06/22 20:12:00 UTC, 0 replies.
- [DISCUSS] FLIP-243: Dedicated Opensearch connectors - posted by Andriy Redko <dr...@gmail.com> on 2022/06/22 20:58:43 UTC, 0 replies.
- [jira] [Created] (FLINK-28208) The method createBatchSink in class HiveTableSink should setParallelism for map operator - posted by "Liu (Jira)" <ji...@apache.org> on 2022/06/23 01:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28209) KafkaSink with EXACTLY_ONCE produce reduplicate data(flink kafka connector1.14.4) - posted by "tanyao (Jira)" <ji...@apache.org> on 2022/06/23 03:02:00 UTC, 0 replies.
- [DISCUSS] Releasing Flink ML 2.1.0 - posted by Zhipeng Zhang <zh...@gmail.com> on 2022/06/23 03:14:54 UTC, 5 replies.
- [jira] [Created] (FLINK-28210) FlinkSessionJob fails after FlinkDeployment is updated - posted by "Daniel Crowe (Jira)" <ji...@apache.org> on 2022/06/23 03:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28211) Rename Schema to TableSchema - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/06/23 03:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28212) IndexOutOfBoundsException is thrown when project contains window which dosen't refer all fields of input when using Hive dialect - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/06/23 04:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28213) StreamExecutionEnvironment configure method support override pipeline.jars option - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/06/23 04:26:00 UTC, 0 replies.
- [VOTE] FLIP-221: Abstraction for lookup source and metric - posted by Qingsheng Ren <re...@apache.org> on 2022/06/23 04:49:08 UTC, 8 replies.
- [VOTE] FLIP-241: Completed Jobs Information Enhancement - posted by junhan yang <ya...@gmail.com> on 2022/06/23 05:06:46 UTC, 5 replies.
- [jira] [Created] (FLINK-28214) ArrayDataSerializer can not be reused to copy customized type of array data - posted by "Yi Tang (Jira)" <ji...@apache.org> on 2022/06/23 05:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28215) Bump Maven Surefire plugin to 3.0.0-M7 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/06/23 05:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28216) Hadoop S3FileSystemFactory does not honor fs.s3.impl - posted by "Prabhu Joseph (Jira)" <ji...@apache.org> on 2022/06/23 06:00:00 UTC, 0 replies.
- [VOTE] Apache Flink Kubernetes Operator Release 1.0.1, release candidate #1 - posted by Gyula Fóra <gy...@apache.org> on 2022/06/23 06:34:39 UTC, 5 replies.
- [jira] [Created] (FLINK-28217) Bump mysql-connector-java from 8.0.27 to 8.0.28 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/06/23 07:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28218) Add readiness and liveliness probe to k8s operator - posted by "Márton Balassi (Jira)" <ji...@apache.org> on 2022/06/23 08:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28219) Refactor TableStoreCatalog: Introduce a dedicated Catalog for table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/06/23 08:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28220) Create Table Like support excluding physical columns - posted by "JustinLee (Jira)" <ji...@apache.org> on 2022/06/23 09:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28221) Savepoint may corrupt file metas by repeat commit - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/06/23 09:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28222) Add sql-csv/json modules - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/06/23 09:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28223) Add artifact-fetcher to the pod-template.yaml example - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/06/23 09:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28224) Add document for algorithms and features in Flink ML 2.1 - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2022/06/23 09:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28225) Supports custom ENVs in the Helm chart - posted by "Xin Hao (Jira)" <ji...@apache.org> on 2022/06/23 10:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28226) 'Run kubernetes pyflink application test' fail with "[FAIL] Test script contains errors" - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/06/23 10:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28227) Add implementations for classes in o.a.f.streaming.examples based on the new new Source API - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2022/06/23 11:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28228) Target generation logic might skip over specs when observing already upgraded clusters - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/06/23 11:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28229) Introduce Source API alternatives for StreamExecutionEnvironment#fromCollection() methods - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2022/06/23 11:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28230) Deduplicate Dependency classes across checks - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/06/23 12:32:00 UTC, 0 replies.
- RE: [DISCUSS] FLIP-223: Implement standalone mode support in the kubernetes operator - posted by zhengyu chen <ja...@gmail.com> on 2022/06/23 13:25:08 UTC, 1 replies.
- [jira] [Created] (FLINK-28231) Support Ozone file system - posted by "bianqi (Jira)" <ji...@apache.org> on 2022/06/23 14:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28232) Allow for custom pre-flight checks for SQL UDFs - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2022/06/23 14:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28233) Successful observe doesn't clear errors due to patching - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/06/23 15:36:00 UTC, 0 replies.
- [DISCUSS] Contribution of Multi Cluster Kafka Source - posted by Mason Chen <ma...@gmail.com> on 2022/06/24 01:43:38 UTC, 5 replies.
- [jira] [Created] (FLINK-28234) Infinite or NaN exception for power(-1, 0.5) - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/06/24 02:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28235) Min aggregate function support type: ''ARRAY''. - posted by "tartarus (Jira)" <ji...@apache.org> on 2022/06/24 02:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28236) managed memory no matter how much I configure, it will be exhausted - posted by "LCER (Jira)" <ji...@apache.org> on 2022/06/24 02:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28237) Improve the flink-ml python examples in doc - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/06/24 03:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28238) Fix unstable testCancelOperationAndFetchResultInParallel - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/06/24 04:33:00 UTC, 0 replies.
- 回复：RE: [DISCUSS] Release Kubernetes operator 1.0.1 - posted by 867127831 <86...@qq.com.INVALID> on 2022/06/24 06:16:02 UTC, 0 replies.
- [jira] [Created] (FLINK-28239) Table-Planner-Loader lacks access to commons-math3 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/06/24 07:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28240) NettyShuffleMetricFactory#RequestedMemoryUsageMetric#getValue may throw ArithmeticException when the total segments of NetworkBufferPool is 0 - posted by "Gen Luo (Jira)" <ji...@apache.org> on 2022/06/24 08:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28241) Massive regression on 20.06.2021 - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2022/06/24 08:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28242) CDC source with meta columns may cause error result on downstream stateful operators - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2022/06/24 08:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28243) Considering only time of targeted operation for calculation benchmarks performance - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2022/06/24 08:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28244) Introduce changelog file for DataFile - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/06/24 09:01:00 UTC, 0 replies.
- [DISCUSS] FLIP-245: Source Supports Speculative Execution For Batch Job - posted by Jing Zhang <be...@gmail.com> on 2022/06/24 09:41:03 UTC, 1 replies.
- 退订 - posted by 越张 <zh...@silvrr.com> on 2022/06/24 10:10:30 UTC, 2 replies.
- [jira] [Created] (FLINK-28245) Refactor DependencyParser#parseDependencyTreeOutput to return a Tree - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/06/24 10:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28246) Store classifier in dependency - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/06/24 10:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28247) Exception will be thrown when over window contains grouping in Hive Dialect - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/06/24 12:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28248) Metaspace memory is leaking when repeatedly submitting Beam pipelines via the REST API - posted by "Arkadiusz Gasinski (Jira)" <ji...@apache.org> on 2022/06/24 12:50:00 UTC, 0 replies.
- Azure CI build failure question - posted by Gabor Somogyi <ga...@gmail.com> on 2022/06/24 14:38:22 UTC, 3 replies.
- [VOTE] FLIP-240: Introduce "ANALYZE TABLE" Syntax - posted by godfrey he <go...@gmail.com> on 2022/06/24 15:07:08 UTC, 5 replies.
- [jira] [Created] (FLINK-28249) Flink can not delete older checkpoint folders from google storage bucket - posted by "Jie Zhang (Jira)" <ji...@apache.org> on 2022/06/24 21:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28250) exactly-once sink kafka cause out of memory - posted by "jinshuangxian (Jira)" <ji...@apache.org> on 2022/06/25 14:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28251) flink-avro format reader may thrown ’java.util.NoSuchElementException' Exception in some cases - posted by "jinshuangxian (Jira)" <ji...@apache.org> on 2022/06/25 14:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28252) Potential Refactoring - posted by "Alvin Tan Jian Jia (Jira)" <ji...@apache.org> on 2022/06/26 21:29:00 UTC, 0 replies.
- 来自杨柳的邮件 - posted by 杨柳 <18...@163.com> on 2022/06/27 00:36:51 UTC, 0 replies.
- [jira] [Created] (FLINK-28253) LocalDateTime is not supported in PyFlink - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2022/06/27 02:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28254) Add benchmark of vectorAssembler and minMaxScaler - posted by "weibo zhao (Jira)" <ji...@apache.org> on 2022/06/27 03:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28255) Add extraFiles to DataFileMeta - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/06/27 03:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28256) Move the write and prepareCommit logic of AbstractTableWrite to FileStoreWrite - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/06/27 04:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28257) Replace ValueKind to RowKind in table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/06/27 06:57:00 UTC, 0 replies.
- [REQUEST] Please update the Flink 1.16 release page - posted by Martijn Visser <ma...@apache.org> on 2022/06/27 07:01:10 UTC, 0 replies.
- [jira] [Created] (FLINK-28258) Introduce ExecutionHistory to host historical executions for each execution vertex - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2022/06/27 07:52:00 UTC, 0 replies.
- [FINAL CALL] - Travel Assistance to ApacheCon New Orleans 2022 - posted by Gavin McDonald <gm...@apache.org> on 2022/06/27 08:01:21 UTC, 0 replies.
- [jira] [Created] (FLINK-28259) flink-parquet doesn't compile on M1 mac without rosetta - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2022/06/27 08:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28260) flink-runtime-web fails to execute "npm ci" on Apple Silicon (arm64) without rosetta - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2022/06/27 08:40:00 UTC, 0 replies.
- [RESULT] [VOTE] Apache Flink Kubernetes Operator Release 1.0.1, release candidate #1 - posted by Gyula Fóra <gy...@gmail.com> on 2022/06/27 09:26:02 UTC, 0 replies.
- [jira] [Created] (FLINK-28261) Consider Using Dependent Resources for Ingress - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/06/27 10:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28262) The select result does not match the sink table - posted by "simenliuxing (Jira)" <ji...@apache.org> on 2022/06/27 11:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28263) TPC-DS Bash e2e tests don't clean-up after completing - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/06/27 11:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28264) Refactor split and read in table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/06/27 12:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28265) Inconsistency in Kubernetes HA service: broken state handle - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2022/06/27 12:30:00 UTC, 0 replies.
- [DISCUSS] FLIP-239: Port JDBC Connector Source to FLIP-27 - posted by Roc Marshal <fl...@126.com> on 2022/06/27 13:09:51 UTC, 2 replies.
- Re: Re: 【Could we support distribute by For FlinkSql】 - posted by Yun Tang <my...@live.com> on 2022/06/27 14:09:57 UTC, 0 replies.
- [jira] [Created] (FLINK-28266) Kafka connector fails: Invalid negative offset - posted by "Arseniy Tashoyan (Jira)" <ji...@apache.org> on 2022/06/27 15:37:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink Kubernetes Operator 1.0.1 released - posted by Gyula Fóra <gy...@apache.org> on 2022/06/27 16:22:05 UTC, 2 replies.
- [RESULT][VOTE] FLIP-221: Abstraction for lookup source and metric - posted by Qingsheng Ren <re...@apache.org> on 2022/06/28 06:28:40 UTC, 0 replies.
- [VOTE] Apache Flink ML Release 2.1.0, release candidate #1 - posted by Zhipeng Zhang <zh...@gmail.com> on 2022/06/28 09:28:02 UTC, 3 replies.
- [NOTICE] Dev@ ML is not receiving jira issue created notifications - posted by Xintong Song <to...@gmail.com> on 2022/06/29 02:36:34 UTC, 0 replies.
- [VOTE] FLIP-242: Introduce configurable RateLimitingStrategy for Async Sink - posted by "Teoh, Hong" <li...@amazon.co.uk.INVALID> on 2022/06/29 15:31:25 UTC, 3 replies.
- [jira] [Created] (FLINK-28303) Kafka SQL Connector loses data when restoring from a savepoint with a topic with empty partitions - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2022/06/29 17:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28304) Rework Kubernetes tests to no longer use driver version "none" - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/06/29 19:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28305) SQL Client end-to-end test failed with ElasticsearchException - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/06/30 02:02:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-241: Completed Jobs Information Enhancement - posted by junhan yang <ya...@gmail.com> on 2022/06/30 03:15:17 UTC, 0 replies.
- [jira] [Created] (FLINK-28306) Support get table statistic for Hive partition table - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/06/30 03:27:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-240: Introduce "ANALYZE TABLE" Syntax - posted by godfrey he <go...@gmail.com> on 2022/06/30 03:46:10 UTC, 0 replies.
- [jira] [Created] (FLINK-28307) FLIP-241: Completed Jobs Information Enhancement - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2022/06/30 06:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28308) Introduce accumulated time metrics that a running task is busy / idle / back-pressured - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2022/06/30 06:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28309) Introduce metrics of the duration that a task stays in each status - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2022/06/30 06:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28310) Introduce aggregating task metrics - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2022/06/30 06:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28311) Introduce REST APIs for the environmental information - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2022/06/30 06:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28312) Introduce REST APIs for log URL retrieval - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2022/06/30 06:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28313) Add history server flag to DashboardConfiguration - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2022/06/30 06:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28314) Introduce "Cluster Environment" tab under history server Web UI - posted by "Junhan Yang (Jira)" <ji...@apache.org> on 2022/06/30 06:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28315) [UI] Introduce aggregate stats in tables of the subtasks and taskmanagers - posted by "Junhan Yang (Jira)" <ji...@apache.org> on 2022/06/30 06:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28316) [UI] add external taskmanager log links in the vertex drawer under history server - posted by "Junhan Yang (Jira)" <ji...@apache.org> on 2022/06/30 06:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28317) Throw unsupport exception when RexSubQuery contains LogicalUnion and correlate variables - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/06/30 06:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28318) table idle state ttl configure does not have check when window size bigger then table state ttl - posted by "yutao (Jira)" <ji...@apache.org> on 2022/06/30 06:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28319) test_ci tests times out after/during running org.apache.flink.test.streaming.experimental - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/06/30 07:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28320) ShuffleMasterTest hangs and doesn't produce any output for 900 seconds - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/06/30 07:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28321) HiveDialectQueryITCase fails with error code 137 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/06/30 08:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28322) DataStreamScanProvider's new method is not compatible - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/06/30 08:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28323) Support using new KafkaSource in PyFlink - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2022/06/30 08:40:00 UTC, 0 replies.
- [DISCUSS] Introduce multi delete API to Flink's FileSystem class - posted by Yun Tang <my...@LIVE.COM> on 2022/06/30 08:56:19 UTC, 7 replies.
- [jira] [Created] (FLINK-28324) JUnit5 Migration] Module: flink-sql-client - posted by "zl (Jira)" <ji...@apache.org> on 2022/06/30 09:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28325) DataOutputSerializer#writeBytes increase position twice - posted by "huweihua (Jira)" <ji...@apache.org> on 2022/06/30 10:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28326) ResultPartitionTest.testIdleAndBackPressuredTime failed with AssertError - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/06/30 11:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28327) Make table store src codes compiled with Flink 1.14 - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/06/30 11:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28328) RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState failed with IllegalStateException - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/06/30 12:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28329) List top 15 biggest directories in terms of used disk space - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/06/30 12:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28330) Remove old delegation token framework code when new is working fine - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/06/30 12:25:00 UTC, 0 replies.
- Enquiry about contributing to Flink - posted by Qing Lim <q....@mwam.com.INVALID> on 2022/06/30 13:38:31 UTC, 0 replies.
- [jira] [Created] (FLINK-28331) Persist status after every observe loop - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/06/30 14:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28332) GlueSchemaRegistryJsonKinesisITCase is being Ignored due to `Access key not configured` - posted by "Ahmed Hamdy (Jira)" <ji...@apache.org> on 2022/06/30 15:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28333) GlueSchemaRegistryAvroKinesisITCase is being Ignored due to `Access key not configured` - posted by "Ahmed Hamdy (Jira)" <ji...@apache.org> on 2022/06/30 15:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-28334) PushProjectIntoTableSourceScanRule should cover the case when table source SupportsReadingMetadata and not SupportsProjectionPushDown - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2022/06/30 15:13:00 UTC, 0 replies.