dev@flink.apache.org, 2022-10

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.2.0, release candidate #2 - posted by Jim Busche <jb...@us.ibm.com> on 2022/10/01 00:23:53 UTC, 10 replies.
- [jira] [Created] (FLINK-29490) Timestamp LTZ is unsupported in table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/10/01 03:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29491) Primary key without partition field can be supported from full changelog - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/10/01 03:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29492) Kafka exactly-once sink causes OutOfMemoryError - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2022/10/01 06:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29493) [JDBC] insert sql -> except -> update sql; callback (success, fail) - posted by "seunggabi (Jira)" <ji...@apache.org> on 2022/10/01 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29494) ChangeLogNormalize operator causes undesired firing of past windows after restoration - posted by "Rashmin Patel (Jira)" <ji...@apache.org> on 2022/10/03 06:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29495) PulsarSinkE2ECase hang - posted by "Xingbo Huang (Jira)" <ji...@apache.org> on 2022/10/03 13:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29496) Unable to configure STS endpoint when using ASSUME_ROLE credential provider in Kinesis connector - posted by "Aleksandr Pilipenko (Jira)" <ji...@apache.org> on 2022/10/03 14:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29497) Provide an option to publish the flink-dist jar file artifact - posted by "Thomas Weise (Jira)" <ji...@apache.org> on 2022/10/03 17:32:00 UTC, 0 replies.
- [DISCUSS] FLIP-264 Extract BaseCoordinatorContext - posted by gang ye <ye...@gmail.com> on 2022/10/03 18:41:11 UTC, 13 replies.
- [jira] [Created] (FLINK-29498) Flink Async I/O Retry Strategies Do Not Work for Scala AsyncDataStream API - posted by "Eric Xiao (Jira)" <ji...@apache.org> on 2022/10/03 19:38:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-246: Multi Cluster Kafka Source - posted by Mason Chen <ma...@gmail.com> on 2022/10/04 03:28:49 UTC, 2 replies.
- [DISCUSS] FLIP-265 Deprecate and remove Scala API support - posted by Martijn Visser <ma...@apache.org> on 2022/10/04 04:22:11 UTC, 18 replies.
- [SUMMARY] Flink 1.16 release sync of 2022-10-04 - posted by Xingbo Huang <hx...@apache.org> on 2022/10/04 07:21:37 UTC, 0 replies.
- [jira] [Created] (FLINK-29499) DispatcherOperationCaches should implement AutoCloseableAsync - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/10/04 11:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29500) InitializeOnMaster uses wrong parallelism with AdaptiveScheduler - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2022/10/04 11:43:00 UTC, 0 replies.
- Re: [VOTE] Release 1.16.0, release candidate #1 - posted by Matthias Pohl <ma...@aiven.io.INVALID> on 2022/10/04 11:54:41 UTC, 3 replies.
- [jira] [Created] (FLINK-29501) Allow overriding JobVertex parallelisms during job submission - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2022/10/04 14:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29502) Update the Hadoop implementation for filesystems to 3.3.4 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/10/04 19:44:00 UTC, 0 replies.
- Support avro-confluent format for FileSystem SQL connector - posted by liuxiangcao <xi...@gmail.com> on 2022/10/04 20:18:03 UTC, 6 replies.
- [jira] [Created] (FLINK-29503) [OpenAPI] enum `backpressure-level` should be backpressurelevel so code generator recognizes it - posted by "Tiger (Apache) Wang (Jira)" <ji...@apache.org> on 2022/10/05 01:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29504) [OpenAPI] `application/x-java-archive` should be followed by a structure instead of `{}` - posted by "Tiger (Apache) Wang (Jira)" <ji...@apache.org> on 2022/10/05 01:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29505) [OpenAPI] Need `operationId` on certain operations - posted by "Tiger (Apache) Wang (Jira)" <ji...@apache.org> on 2022/10/05 01:33:00 UTC, 0 replies.
- [DISCUSS] Changing the minimal supported version of Hadoop to 2.10.2 - posted by Martijn Visser <ma...@apache.org> on 2022/10/05 03:01:56 UTC, 8 replies.
- [jira] [Created] (FLINK-29506) ParquetInputFormatFactory fails to create format on Flink 1.14 - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/10/05 07:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29507) Make e2e tests independent of the current directory - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/10/05 08:13:00 UTC, 0 replies.
- Flink FaultTolerant at operator level - posted by Great Info <gu...@gmail.com> on 2022/10/05 08:24:15 UTC, 1 replies.
- [DISCUSS] Aligning migration test data generation - posted by Matthias Pohl <ma...@aiven.io.INVALID> on 2022/10/05 09:42:51 UTC, 7 replies.
- [jira] [Created] (FLINK-29508) Some NOTICE files are not checked for correctness - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/10/05 11:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29509) Set correct subtaskId during recovery of committables - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2022/10/05 12:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29510) Add NoticeFileChecker tests - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/10/05 13:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29511) Sort properties in OpenAPI spec - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/10/05 15:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29512) Align SubtaskCommittableManager checkpointId with CheckpointCommittableManagerImpl checkpointId during recovery - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2022/10/05 15:50:00 UTC, 0 replies.
- [DISCUSS] Remove HCatalog connector - posted by Martijn Visser <ma...@apache.org> on 2022/10/05 16:38:58 UTC, 0 replies.
- Re: [VOTE] FLIP-262: MongoDB Connector - posted by Matthias Pohl <ma...@aiven.io.INVALID> on 2022/10/05 17:07:10 UTC, 2 replies.
- [jira] [Created] (FLINK-29513) Update Kafka version to 3.2.3 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/10/05 19:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29514) Bump Minikdc to v3.2.4 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/10/05 22:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29515) Document KafkaSource behavior with deleted topics - posted by "Mason Chen (Jira)" <ji...@apache.org> on 2022/10/06 00:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29516) Support TIMESTAMPADD built-in function in Table API - posted by "zhangjingcun (Jira)" <ji...@apache.org> on 2022/10/06 01:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29517) Support DATE_FORMAT built-in function in Table API - posted by "zhangjingcun (Jira)" <ji...@apache.org> on 2022/10/06 01:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29518) Support YEAR、QUARTER、MONTH、WEEK、HOUR、MINUTE、SECOND built-in function in Table API - posted by "zhangjingcun (Jira)" <ji...@apache.org> on 2022/10/06 01:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29519) Support DAYOFYEAR、DAYOFMONTH built-in function in Table API - posted by "zhangjingcun (Jira)" <ji...@apache.org> on 2022/10/06 01:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29520) Support PARSE_URL built-in function in Table API - posted by "zhangjingcun (Jira)" <ji...@apache.org> on 2022/10/06 02:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29521) Support REVERSE built-in function in Table API - posted by "zhangjingcun (Jira)" <ji...@apache.org> on 2022/10/06 02:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29522) Support SPLIT_INDEX built-in function in Table API - posted by "zhangjingcun (Jira)" <ji...@apache.org> on 2022/10/06 02:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29523) Support STR_TO_MAP、SUBSTR built-in function in Table API - posted by "zhangjingcun (Jira)" <ji...@apache.org> on 2022/10/06 02:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29524) Support DECODE、ENCODE built-in function in Table API - posted by "zhangjingcun (Jira)" <ji...@apache.org> on 2022/10/06 02:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29525) Support INSTR、LEFT、RIGHT built-in function in Table API - posted by "zhangjingcun (Jira)" <ji...@apache.org> on 2022/10/06 02:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29526) Java doc mistake in SequenceNumberRange#contains() - posted by "Feifan Wang (Jira)" <ji...@apache.org> on 2022/10/06 02:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29527) Make unknownFieldsIndices work for single ParquetReader - posted by "Sun Shun (Jira)" <ji...@apache.org> on 2022/10/06 09:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29528) Check if core-default-shaded is still required - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/10/06 14:36:00 UTC, 0 replies.
- Re: [VOTE] Release flink-shaded 16.0, release candidate #1 - posted by Dawid Wysakowicz <dw...@apache.org> on 2022/10/06 14:37:46 UTC, 1 replies.
- [jira] [Created] (FLINK-29529) Update flink version in flink-python-example of flink k8s operator - posted by "Biao Geng (Jira)" <ji...@apache.org> on 2022/10/06 14:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29530) CommittableMessageTypeInfo#toString may force client to have S3 credentials - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/10/06 15:00:00 UTC, 0 replies.
- [RESULT][VOTE]FLIP-260: Support Job Dynamic Parameter With Flink Rest Api - posted by Zheng Yu Chen <ja...@gmail.com> on 2022/10/06 16:01:22 UTC, 1 replies.
- [jira] [Created] (FLINK-29531) Bump protoc and protobuf-java dependencies to 3.21.7 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/10/06 20:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29532) Update Pulsar dependency to 2.10.1 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/10/06 21:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29533) Add proper table style to Flink website - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/10/07 06:34:00 UTC, 0 replies.
- [RESULT] [VOTE] Apache Flink Kubernetes Operator Release 1.2.0, release candidate #2 - posted by Gyula Fóra <gy...@apache.org> on 2022/10/07 06:46:22 UTC, 0 replies.
- [RESULT][VOTE] Release flink-shaded 16.0, release candidate #1 - posted by Chesnay Schepler <ch...@apache.org> on 2022/10/07 09:15:19 UTC, 0 replies.
- [jira] [Created] (FLINK-29534) @TypeInfo on field requires field type to be valid Pojo - posted by "Exidex (Jira)" <ji...@apache.org> on 2022/10/07 10:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29535) Flink Operator Certificate renew issue - posted by "Sebastian Struß (Jira)" <ji...@apache.org> on 2022/10/07 13:32:00 UTC, 0 replies.
- State of the Rescale API - posted by Maximilian Michels <mx...@apache.org> on 2022/10/07 13:49:19 UTC, 5 replies.
- Re: [VOTE] FLIP-254 Redis Streams connector - posted by Martijn Visser <ma...@apache.org> on 2022/10/07 14:10:22 UTC, 1 replies.
- [RESULT] [VOTE] FLIP-254: Redis Streams Connector - posted by Martijn Visser <ma...@apache.org> on 2022/10/07 14:13:17 UTC, 0 replies.
- [jira] [Created] (FLINK-29537) Rename flink-connector-redis repository to flink-connector-redis-streams - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/10/07 14:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29536) Add WATCH_NAMESPACES env var to kubernetes operator - posted by "Tony Garrard (Jira)" <ji...@apache.org> on 2022/10/07 14:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29538) Setup CI based on the new Elasticsearch CI setup - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/10/07 14:34:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink Kubernetes Operator 1.2.0 released - posted by Gyula Fóra <gy...@apache.org> on 2022/10/07 15:05:10 UTC, 0 replies.
- Need an help in understanding Kafka connector - posted by Sriram Ganesh <sr...@gmail.com> on 2022/10/07 18:42:34 UTC, 2 replies.
- [jira] [Created] (FLINK-29539) dnsPolicy in FlinkPod is not overridable - posted by "Carlos Castro (Jira)" <ji...@apache.org> on 2022/10/07 22:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29540) SubQueryAntiJoinTest started to fail after Calcite 1.27 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/10/07 22:55:00 UTC, 0 replies.
- [VOTE] Apache Flink Table Store 0.2.1, release candidate #2 - posted by Jingsong Li <ji...@gmail.com> on 2022/10/08 02:24:36 UTC, 4 replies.
- [jira] [Created] (FLINK-29541) [JUnit5 Migration] Module: flink-table-planner - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2022/10/08 02:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29542) Unload.md wrongly writes UNLOAD operation as LOAD operation - posted by "qingbo jiao (Jira)" <ji...@apache.org> on 2022/10/08 03:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29543) Jar Run Rest Handler Support Flink Configuration - posted by "ConradJam (Jira)" <ji...@apache.org> on 2022/10/08 04:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29544) Update Flink doc - posted by "ConradJam (Jira)" <ji...@apache.org> on 2022/10/08 04:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29545) kafka consuming stop when trigger first checkpoint - posted by "xiaogang zhou (Jira)" <ji...@apache.org> on 2022/10/08 08:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29546) UDF：Failed to compile split code, falling back to original code - posted by "Hui Wang (Jira)" <ji...@apache.org> on 2022/10/08 11:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29547) Select a[1] which is array type for parquet complex type throw ClassCastException - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/10/08 11:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29548) Remove deprecated class files of the 'flink-test-utils' module. - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2022/10/08 12:18:00 UTC, 0 replies.
- Would you give me the permission as a contributor? - posted by 刘鼎盛 <11...@qq.com.INVALID> on 2022/10/08 12:43:58 UTC, 1 replies.
- [jira] [Created] (FLINK-29549) Flink sql to add support of using AWS glue as metastore - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2022/10/08 16:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29550) example "basic-checkpoint-ha.yaml" not working - posted by "roa (Jira)" <ji...@apache.org> on 2022/10/08 17:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29551) Improving adaptive hash join by using sort merge join strategy per partition instead of all partitions - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/10/09 02:28:00 UTC, 0 replies.
- [DISCUSS] Reverting sink metric name changes made in 1.15 - posted by Qingsheng Ren <re...@apache.org> on 2022/10/09 02:35:12 UTC, 20 replies.
- [jira] [Created] (FLINK-29552) Repair the instructions for DAYOFYEAR, DAYOFMONTH, and DAYOFFEEK functions - posted by "zhangjingcun (Jira)" <ji...@apache.org> on 2022/10/09 03:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29553) Support UNIX_TIMESTAMP in Table API - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2022/10/09 08:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29554) Add partial-update.ignore-delete option to avoid exception after join - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/10/09 08:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29555) GlobalStreamingCommitterHandler not call notifyCheckpointCompleted after endOfInput - posted by "liwei li (Jira)" <ji...@apache.org> on 2022/10/09 11:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29556) flink sql 执行过程报java.lang.NullPointerException异常 - posted by "Luochg (Jira)" <ji...@apache.org> on 2022/10/09 16:36:00 UTC, 0 replies.
- Edit permissions to Flink wiki - posted by Abid Mohammed <ab...@icloud.com.INVALID> on 2022/10/09 21:53:53 UTC, 1 replies.
- [Discuss]- Donate Iceberg Flink Connector - posted by Abid Mohammed <ab...@icloud.com.INVALID> on 2022/10/10 01:22:08 UTC, 27 replies.
- [jira] [Created] (FLINK-29557) The SinkOperator's OutputFormat function is not recognized - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/10/10 04:22:00 UTC, 0 replies.
- Re: Sink V2 interface replacement for GlobalCommitter - posted by liwei li <hi...@gmail.com> on 2022/10/10 05:21:50 UTC, 2 replies.
- [ANNOUNCE] New Apache Flink PMC Member - Danny Cranmer - posted by Robert Metzger <rm...@apache.org> on 2022/10/10 07:05:04 UTC, 16 replies.
- [jira] [Created] (FLINK-29558) Use select count(*) from xxx; and get SQL syntax - posted by "Hang HOU (Jira)" <ji...@apache.org> on 2022/10/10 07:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29559) Disable Join Reorder for these tables whose statistics are unavailable - posted by "Yunhong Zheng (Jira)" <ji...@apache.org> on 2022/10/10 07:52:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-262: MongoDB Connector - posted by Jiabao Sun <ji...@xtransfer.cn.INVALID> on 2022/10/10 09:36:21 UTC, 0 replies.
- [jira] [Created] (FLINK-29560) Create a flink-connector-mongodb repository - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/10/10 09:54:00 UTC, 0 replies.
- [VOTE] Changing the minimal supported version of Hadoop to 2.10.2 - posted by Martijn Visser <ma...@apache.org> on 2022/10/10 09:57:18 UTC, 0 replies.
- [jira] [Created] (FLINK-29561) Log the job id when clean up session job failed - posted by "Xin Hao (Jira)" <ji...@apache.org> on 2022/10/10 09:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29562) JM/SQl gatewa OpenAPI specs should have different titles - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/10/10 10:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29564) Migrate pull request to flink-connector-mongodb repository - posted by "Jiabao Sun (Jira)" <ji...@apache.org> on 2022/10/10 10:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29563) SourceTestSuiteBase#testSourceMetrics enters an infinite waiting loop in case the number of records counter is wrong - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2022/10/10 10:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29565) flink per-job模式 webui上taskManager打印的日志不高亮，被注释，影响使用体验，详情请看图 - posted by "wangshiwei (Jira)" <ji...@apache.org> on 2022/10/10 10:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29566) Reschedule the cleanup logic if cancel job failed - posted by "Xin Hao (Jira)" <ji...@apache.org> on 2022/10/10 11:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29567) Revert sink output metric names from numRecordsSend back to numRecordsOut - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2022/10/10 12:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29568) Remove unnecessary whitespace in request/response blocks - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/10/10 12:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29569) Replace usages of deprecated expand shortcode - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/10/10 13:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29570) Bump org.jsoup:jsoup to v1.15.3 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/10/10 13:55:00 UTC, 0 replies.
- [DISCUSS] Updating Flink HBase Connectors - posted by Ferenc Csaky <fe...@pm.me.INVALID> on 2022/10/10 14:22:58 UTC, 3 replies.
- [jira] [Created] (FLINK-29571) Flink configuration only supports Map - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2022/10/10 14:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29572) Flink Task Manager skip loopback interface for resource manager registration - posted by "Kevin Li (Jira)" <ji...@apache.org> on 2022/10/10 16:57:00 UTC, 0 replies.
- Fwd: Deserialize avro message without reader schema. - posted by Sucheth S <su...@gmail.com> on 2022/10/10 17:00:34 UTC, 0 replies.
- [jira] [Created] (FLINK-29573) Flink does not work for windows if installing on other drive except for C drive - posted by "kris wang (Jira)" <ji...@apache.org> on 2022/10/10 17:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29574) Upgrade software.amazon.glue:schema-registry-common and software.amazon.glue:schema-registry-serde dependency from 1.1.8 to 1.1.14 - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2022/10/10 22:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29575) Can't Add Temporary Function USING JAR - posted by "Angelo Kastroulis (Jira)" <ji...@apache.org> on 2022/10/11 01:45:00 UTC, 0 replies.
- Flink falls back on to kryo serializer for GenericTypes - posted by Sucheth S <su...@gmail.com> on 2022/10/11 07:29:03 UTC, 1 replies.
- [jira] [Created] (FLINK-29576) SourceNAryInputChainingITCase.testDirectSourcesOnlyExecution failed - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/10/11 07:35:00 UTC, 0 replies.
- [SUMMARY] Flink 1.16 release sync of 2022-10-11 - posted by Xingbo Huang <hx...@apache.org> on 2022/10/11 07:56:39 UTC, 0 replies.
- [jira] [Created] (FLINK-29577) Disable rocksdb wal when restore from full snapshot - posted by "Cai Liuyang (Jira)" <ji...@apache.org> on 2022/10/11 08:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29578) Multiple executions of `runVertexCentricIteration` cause memory errors (flink gelly) - posted by "Shunyang Li (Jira)" <ji...@apache.org> on 2022/10/11 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29579) Flink parquet reader cannot read fully optional elements in a repeated list - posted by "Tiansu Yu (Jira)" <ji...@apache.org> on 2022/10/11 09:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29580) pulsar.consumer.autoUpdatePartitionsIntervalSeconds doesn't works and should be removed - posted by "Yufan Sheng (Jira)" <ji...@apache.org> on 2022/10/11 10:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29581) Emit warning events for session job reconciliation exception - posted by "Xin Hao (Jira)" <ji...@apache.org> on 2022/10/11 10:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29582) SavepointWriter should be usable without any transformation - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/10/11 11:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29583) Ensure correct subtaskId and checkpointId is set during committer state migration - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2022/10/11 11:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29584) Upgrade java 11 version on the microbenchmark worker - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2022/10/11 11:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29585) Migrate TableSchema to Schema for Hive connector - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/10/11 12:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29586) Let write buffer spillable - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/10/11 12:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29587) Fail to generate code for SearchOperator - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/10/11 12:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29588) Add Flink Version and Application Version to Savepoint properties - posted by "Clara Xiong (Jira)" <ji...@apache.org> on 2022/10/11 17:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29589) Data Loss in Sink GlobalCommitter during Task Manager recovery - posted by "Krzysztof Chmielewski (Jira)" <ji...@apache.org> on 2022/10/11 20:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29590) Fix constant fold issue for HiveDialect - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/10/12 02:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29591) Add built-in UDFs to convert between arrays and vectors - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2022/10/12 06:11:00 UTC, 0 replies.
- RE: [DISCUSS] FLIP-208: Update KafkaSource to detect EOF based on de-serialized record - posted by Sergey Troshkov <ka...@yandex.ru> on 2022/10/12 08:35:47 UTC, 1 replies.
- [jira] [Created] (FLINK-29592) Add Transformer and Estimator for RobustScaler - posted by "Jiang Xin (Jira)" <ji...@apache.org> on 2022/10/12 08:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29593) Add Approximate Quantile Util - posted by "Jiang Xin (Jira)" <ji...@apache.org> on 2022/10/12 08:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29594) RMQSourceITCase.testMessageDelivery timed out - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/10/12 09:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29595) Add Estimator and Transformer for ChiSqSelector - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2022/10/12 09:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29596) Add Estimator and Transformer for RFormula - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2022/10/12 09:32:00 UTC, 0 replies.
- 回复: [DISCUSS] FLIP-208: Update KafkaSource to detect EOF based on de-serialized record - posted by 阮航 <ru...@hotmail.com> on 2022/10/12 09:40:34 UTC, 0 replies.
- [jira] [Created] (FLINK-29597) Add Estimator and Transformer for QuantileDiscretizer - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2022/10/12 09:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29598) Add Estimator and Transformer for Imputer - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2022/10/12 09:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29599) Add Estimator and Transformer for MinHashLSH - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2022/10/12 10:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29601) Add Estimator and Transformer for UnivariateFeatureSelector - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2022/10/12 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29600) Add Estimator and Transformer for BucketedRandomProjectionLSH - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2022/10/12 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29602) Add Transformer for SQLTransformer - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2022/10/12 10:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29603) Add Transformer for StopWordsRemover - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2022/10/12 10:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29604) Add Estimator and Transformer for CountVectorizer - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2022/10/12 10:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29605) Create a bounded version of SourceTestSuiteBase#testSourceMetrics - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2022/10/12 10:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29606) Dynamic Execution Environment - posted by "Hamid EL MAAZOUZ (Jira)" <ji...@apache.org> on 2022/10/12 11:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29607) Simplify controller flow by introducing FlinkControllerContext - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/10/12 12:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29608) 使用 pyflink1.17dev datastream 经过reduce 后 add_sink(FlinkKafkaProducer()) 有问题 - posted by "王伟 (Jira)" <ji...@apache.org> on 2022/10/12 12:16:00 UTC, 0 replies.
- 回复: [DISCUSS] Reverting sink metric name changes made in 1.15 - posted by Ruan Hang <ru...@hotmail.com> on 2022/10/12 12:16:02 UTC, 0 replies.
- [DISCUSS] FLIP-263: Improve resolving schema compatibility - posted by Hangxiang Yu <ma...@gmail.com> on 2022/10/12 12:41:07 UTC, 18 replies.
- [VOTE] Externalized connector release details&workflow - posted by Chesnay Schepler <ch...@apache.org> on 2022/10/12 13:12:21 UTC, 16 replies.
- [jira] [Created] (FLINK-29609) Clean up jobmanager deployment on suspend after recording savepoint info - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/10/12 14:11:00 UTC, 0 replies.
- [DISCUSS] Reference operator from Flink Kubernetes deployment docs - posted by Gyula Fóra <gy...@gmail.com> on 2022/10/12 14:25:15 UTC, 6 replies.
- [DISCUSS] Adding client.id.prefix to the KafkaSink - posted by Yaroslav Tkachenko <ya...@goldsky.com.INVALID> on 2022/10/12 16:33:43 UTC, 3 replies.
- Utilizing Kafka headers in Flink Kafka connector - posted by Great Info <gu...@gmail.com> on 2022/10/12 18:03:47 UTC, 2 replies.
- [VOTE] Remove HCatalog connector - posted by Martijn Visser <ma...@apache.org> on 2022/10/12 19:45:57 UTC, 10 replies.
- Re: [DISCUSS] Drop Gelly - posted by Martijn Visser <ma...@apache.org> on 2022/10/12 20:57:34 UTC, 0 replies.
- [VOTE] Drop Gelly - posted by Martijn Visser <ma...@apache.org> on 2022/10/12 20:59:04 UTC, 17 replies.
- Re: [DISCUSS] Externalized connector release details&workflow - posted by Steven Wu <st...@gmail.com> on 2022/10/12 23:18:26 UTC, 0 replies.
- [RESULT][VOTE] Apache Flink Table Store 0.2.1, release candidate #2 - posted by Jingsong Li <ji...@gmail.com> on 2022/10/13 02:10:23 UTC, 0 replies.
- [jira] [Created] (FLINK-29610) Infinite timeout is used in SavepointHandlers calls to RestfulGateway - posted by "Jiale Tan (Jira)" <ji...@apache.org> on 2022/10/13 02:11:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink Table Store 0.2.1 released - posted by Jingsong Lee <lz...@apache.org> on 2022/10/13 02:45:50 UTC, 1 replies.
- [jira] [Created] (FLINK-29611) Fix flaky tests in CoBroadcastWithNonKeyedOperatorTest - posted by "Sopan Phaltankar (Jira)" <ji...@apache.org> on 2022/10/13 04:29:00 UTC, 0 replies.
- SQL Gateway and SQL Client - posted by Alexey Leonov-Vendrovskiy <ve...@gmail.com> on 2022/10/13 04:33:08 UTC, 5 replies.
- [jira] [Created] (FLINK-29612) Extract changelog files out of DataFileMeta#extraFiles - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/10/13 04:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29613) An error occurred during the running of the Flink pulsar，it shows "We only support normal message id currently." - posted by "qiaomengnan (Jira)" <ji...@apache.org> on 2022/10/13 06:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29614) Introduce Spark writer for table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/10/13 06:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29615) MetricStore does not remove metrics of nonexistent subtasks when adaptive scheduler lowers job parallelism - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2022/10/13 06:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29616) Polish Table Store Pom file to avoid warning. - posted by "Aiden Gong (Jira)" <ji...@apache.org> on 2022/10/13 06:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29617) Cost too much time to start SourceCoordinator of hdfsFileSource when start JobMaster - posted by "LI Mingkun (Jira)" <ji...@apache.org> on 2022/10/13 07:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29618) YARNSessionFIFOSecuredITCase.testDetachedMode timed out in Azure CI - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/10/13 07:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29619) Remove redundant MeterView updater thread from KubernetesClientMetrics - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/10/13 07:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29620) Flink deployment stuck in UPGRADING state when changing configuration - posted by "liad shachoach (Jira)" <ji...@apache.org> on 2022/10/13 07:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29621) Append-only with eventual log.consistency can not work - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/10/13 07:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29622) KerberosDelegationTokenManager fails to load DelegationTokenProvider due to NoClassDefFoundError in various tests - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/10/13 08:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29623) Bump Prometheus Java Client to 0.16.0 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/10/13 09:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29624) Upgrade org.apache.commons:commons-lang3 from 3.3.2 to 3.12.0 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/10/13 09:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29625) Optimize changelog normalize - posted by "Jiabao Sun (Jira)" <ji...@apache.org> on 2022/10/13 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29626) Update Akka to 2.6.20 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/10/13 09:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29627) Sink - Duplicate key exception during recover more than 1 committable. - posted by "Krzysztof Chmielewski (Jira)" <ji...@apache.org> on 2022/10/13 10:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29628) Bump aws-java-sdk-s3 to 1.12.319 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/10/13 11:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29629) FlameGraph is empty for Legacy Source Threads - posted by "Peter Vary (Jira)" <ji...@apache.org> on 2022/10/13 12:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29630) Junit 5.8.1 run unit test with temporary directory will occur Failed to delete temp directory. - posted by "Aiden Gong (Jira)" <ji...@apache.org> on 2022/10/13 12:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29631) [CVE-2022-42003] flink-shaded-jackson - posted by "Sergio Sainz (Jira)" <ji...@apache.org> on 2022/10/13 16:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29632) Support nodeSelector in helm template for flink operator deployment - posted by "Jeesmon Jacob (Jira)" <ji...@apache.org> on 2022/10/13 17:12:00 UTC, 0 replies.
- [VOTE] Reverting sink metric name changes made in 1.15 - posted by Qingsheng Ren <re...@apache.org> on 2022/10/13 17:24:03 UTC, 8 replies.
- [jira] [Created] (FLINK-29633) Operator doesn't pass initialSavepointPath as fromSavepoint argument - posted by "Yaroslav Tkachenko (Jira)" <ji...@apache.org> on 2022/10/13 17:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29634) Support periodic checkpoint triggering - posted by "Thomas Weise (Jira)" <ji...@apache.org> on 2022/10/13 19:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29635) Hive sink should supports merge small files in batch mode - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/10/14 02:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29636) Add micro benchmark module in flink table store - posted by "Shammon (Jira)" <ji...@apache.org> on 2022/10/14 02:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29637) Improve to reuse threads in TaskManager for different tasks between jobs - posted by "Shammon (Jira)" <ji...@apache.org> on 2022/10/14 02:41:00 UTC, 0 replies.
- jobmaster's fatal error will kill the session cluster - posted by Jie Han <tu...@gmail.com> on 2022/10/14 08:12:52 UTC, 1 replies.
- [jira] [Created] (FLINK-29638) Update jackson bom because of CVE-2022-42003 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/10/14 08:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29639) Add ResourceId in TransportException for debugging - posted by "Liu (Jira)" <ji...@apache.org> on 2022/10/14 08:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29640) Enhance the function configured by execution.shutdown-on-attached-exit by heartbeat between client and dispatcher - posted by "Liu (Jira)" <ji...@apache.org> on 2022/10/14 09:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29641) SortMergeResultPartitionReadSchedulerTest.testCreateSubpartitionReader - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/10/14 10:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29642) MySqlCatalogITCase.testWithoutCatalogDB - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/10/14 10:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29643) Possible NPE in ApplicationDispatcherBootstrap with failedJob submission and no HA - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2022/10/14 12:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29644) Reference Kubernetes operator from Flink Kubernetes deploy docs - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/10/14 13:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29645) BatchExecutionKeyedStateBackend is using incorrect ExecutionConfig when creating serializer - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2022/10/14 13:23:00 UTC, 0 replies.
- [Cassandra] source connector - posted by Etienne Chauchot <ec...@apache.org> on 2022/10/14 14:18:14 UTC, 6 replies.
- [jira] [Created] (FLINK-29646) SQL Gateway should return a simpler error message - posted by "yuanfenghu (Jira)" <ji...@apache.org> on 2022/10/14 14:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29647) report stackoverflow when using kryo - posted by "Gao Fei (Jira)" <ji...@apache.org> on 2022/10/15 05:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29648) "LocalDateTime not supported" error when retrieving Java TypeInformation from PyFlink - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2022/10/15 09:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29649) upgrade Maven checkstyle plugin to latest version >= v8.30 - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2022/10/15 19:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29650) Printing the contents of error lines when parsing yaml file may leak sensitive configuration values - posted by "luyuan (Jira)" <ji...@apache.org> on 2022/10/16 09:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29651) Code gen will fail when the literal specified in user's sql hasn't be escaped - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/10/17 01:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29652) get duplicate result from sql-client in BATCH mode - posted by "Jingqi Shi (Jira)" <ji...@apache.org> on 2022/10/17 05:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29653) close DynamicResult but it was already closed - posted by "Jingqi Shi (Jira)" <ji...@apache.org> on 2022/10/17 05:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29654) Vulnerable libraries - Flink 1.15.2 - posted by "nagasudhakar (Jira)" <ji...@apache.org> on 2022/10/17 05:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29655) Split Flink CRD from flink-kubernates-operator module - posted by "Zhenqiu Huang (Jira)" <ji...@apache.org> on 2022/10/17 07:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29656) Modify all join-related sql tests to make having statistics as the default choice - posted by "Yunhong Zheng (Jira)" <ji...@apache.org> on 2022/10/17 08:01:00 UTC, 0 replies.
- 退订 - posted by 李朋 <11...@qq.com.INVALID> on 2022/10/17 08:06:46 UTC, 0 replies.
- [jira] [Created] (FLINK-29657) Hive SQL - posted by "Runkang He (Jira)" <ji...@apache.org> on 2022/10/17 08:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29659) Deduplicate SavepointWriter factory method code - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/10/17 09:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29658) LocalTimeTypeInfo support in DataStream API in PyFlink - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2022/10/17 09:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29660) Show all attempts of subtasks in WebUI - posted by "LI Mingkun (Jira)" <ji...@apache.org> on 2022/10/17 10:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29661) DatabaseCalciteSchema$getTable() cannot get statistics for partition table - posted by "Yunhong Zheng (Jira)" <ji...@apache.org> on 2022/10/17 11:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29662) PojoSerializerSnapshot is using incorrect ExecutionConfig when restoring serializer - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2022/10/17 11:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29663) Further improvements of adaptive batch scheduler - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2022/10/17 11:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29664) Collect subpartition sizes of BLOCKING result partitions - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2022/10/17 11:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29665) Support flexible subpartition range divisions - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2022/10/17 11:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29666) Let adaptive batch scheduler divide subpartition range according to amount of data - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2022/10/17 11:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29667) Upgrade DynamoDB Connector dependencies from SNAPSHOT to release 1.16 - posted by "Daren Wong (Jira)" <ji...@apache.org> on 2022/10/17 12:42:00 UTC, 0 replies.
- [RESULT][VOTE] Drop Gelly - posted by Martijn Visser <ma...@apache.org> on 2022/10/17 13:28:53 UTC, 0 replies.
- [jira] [Created] (FLINK-29668) Remove Gelly - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/10/17 13:32:00 UTC, 0 replies.
- [RESULT][VOTE] Remove HCatalog - posted by Martijn Visser <ma...@apache.org> on 2022/10/17 13:33:52 UTC, 0 replies.
- [jira] [Created] (FLINK-29669) Remove HCatalog - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/10/17 13:35:00 UTC, 0 replies.
- [VOTE] FLIP-265 Deprecate and remove Scala API support - posted by Martijn Visser <ma...@apache.org> on 2022/10/17 13:38:42 UTC, 9 replies.
- SplitEnumerator for Bigquery Source. - posted by Lavkesh Lahngir <la...@linux.com> on 2022/10/17 14:42:29 UTC, 3 replies.
- [jira] [Created] (FLINK-29670) Add CRD compatibility check against 1.2.0 - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/10/17 15:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29671) Kubernetes e2e test fails during test initialization - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/10/17 15:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29672) Support oracle catalog - posted by "waywtdcc (Jira)" <ji...@apache.org> on 2022/10/18 01:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29673) Support sqlserver catalog - posted by "waywtdcc (Jira)" <ji...@apache.org> on 2022/10/18 01:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29674) Apache Kafka 连接器的“ setBounded”不生效 - posted by "jiangwei (Jira)" <ji...@apache.org> on 2022/10/18 01:57:00 UTC, 0 replies.
- Bigquery source/connector on Flink - posted by Lavkesh Lahngir <la...@linux.com> on 2022/10/18 06:34:31 UTC, 0 replies.
- [jira] [Created] (FLINK-29675) unexpected correlate variable $cor262 in the plan - posted by "Luochg (Jira)" <ji...@apache.org> on 2022/10/18 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29676) unexpected correlate variable $cor262 in the plan - posted by "Luochg (Jira)" <ji...@apache.org> on 2022/10/18 07:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29677) DROP CATALOG statement does not reset current catalog - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/10/18 09:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29678) Data may loss when sink bounded stream into filesystem with auto compact enabled in streaming mode - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/10/18 10:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29679) DESCRIBE statement shows comment - posted by "Yubin Li (Jira)" <ji...@apache.org> on 2022/10/18 12:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29680) Create/Use Database with DatabaseName "default" fails - posted by "Prabhu Joseph (Jira)" <ji...@apache.org> on 2022/10/18 13:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29681) Python side-output operator not generated in some cases - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2022/10/18 16:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29682) Flaky test failure in test_finegrained_resourcemanagement - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2022/10/18 19:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29683) Introduce config parser for AWS BackoffStrategy - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2022/10/18 20:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29684) [UI] Upgrade runtime web Angular framework and associated deps to v14 - posted by "Junhan Yang (Jira)" <ji...@apache.org> on 2022/10/19 06:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29685) Add JM info into ExecutionGraph - posted by "LI Mingkun (Jira)" <ji...@apache.org> on 2022/10/19 07:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29686) Flink-SQL使用Hive方言出现bug - posted by "Vincent Long (Jira)" <ji...@apache.org> on 2022/10/19 07:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29687) Do not throw exception when Lookup table is empty - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/10/19 09:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29688) Build time compatibility check for DynamoDB SDK - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2022/10/19 11:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29689) CLONE - Improve the CSV reading process - posted by "Vrinda Palod (Jira)" <ji...@apache.org> on 2022/10/19 12:15:00 UTC, 0 replies.
- [RESULT][VOTE] Reverting sink metric name changes made in 1.15 - posted by Qingsheng Ren <re...@apache.org> on 2022/10/19 12:25:12 UTC, 0 replies.
- [jira] [Created] (FLINK-29690) listTables in HiveCatalog should only return table store tables - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/10/19 13:01:00 UTC, 0 replies.
- [DISCUSS] Drop TypeSerializerConfigSnapshot and savepoint support from Flink versions < 1.8.0 - posted by Piotr Nowojski <pi...@gmail.com> on 2022/10/19 13:13:38 UTC, 4 replies.
- [jira] [Created] (FLINK-29691) Adjust org.apache.flink.test.junit5.MiniClusterExtension#registerEnv to honor DEFAULT_PARALLELISM if set - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/10/19 13:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29692) Support early/late fires for Windowing TVFs - posted by "Canope Nerda (Jira)" <ji...@apache.org> on 2022/10/19 14:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29693) MiniClusterExtension should respect DEFAULT_PARALLELISM if set - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/10/19 14:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29694) Support tolerations in helm template for flink operator deployment - posted by "Max Lim (Jira)" <ji...@apache.org> on 2022/10/19 15:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29695) Create a utility to report the status of the last savepoint - posted by "Clara Xiong (Jira)" <ji...@apache.org> on 2022/10/19 16:34:00 UTC, 0 replies.
- [VOTE] FLIP 267: Iceberg Connector - posted by ab...@icloud.com.INVALID on 2022/10/19 22:36:21 UTC, 6 replies.
- [jira] [Created] (FLINK-29696) [Doc] Operator helm install command points to wrong repo - posted by "Yufei Zhang (Jira)" <ji...@apache.org> on 2022/10/20 01:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29697) Flaky test failure KafkaShuffleExactlyOnceITCase.testAssignedToPartitionFailureRecoveryEventTime - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2022/10/20 03:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29698) Job Manager fails with FileAlreadyExistsException if java.io.tmpdir points to a symbolic link - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/10/20 04:30:00 UTC, 0 replies.
- [DISCUSS] REST API to suspend & resume checkpointing - posted by Saurabh Kaul <sa...@gmail.com> on 2022/10/20 05:53:08 UTC, 8 replies.
- [jira] [Created] (FLINK-29699) Debezium format parsing supports converting strings and numbers with Z at the end to timestamp - posted by "waywtdcc (Jira)" <ji...@apache.org> on 2022/10/20 07:28:00 UTC, 0 replies.
- [DISCUSS] Planning Flink 1.17 - posted by Qingsheng Ren <re...@apache.org> on 2022/10/20 07:44:36 UTC, 13 replies.
- [jira] [Created] (FLINK-29700) Serializer to BinaryInMemorySortBuffer is wrong - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/10/20 08:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29701) Refactor flink-table-store-benchmark and create micro benchmarks module - posted by "Shammon (Jira)" <ji...@apache.org> on 2022/10/20 08:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29702) Add merge tree reader and writer micro benchmarks - posted by "Shammon (Jira)" <ji...@apache.org> on 2022/10/20 08:26:00 UTC, 0 replies.
- [VOTE] Release 1.16.0, release candidate #2 - posted by Xingbo Huang <hx...@apache.org> on 2022/10/20 09:20:13 UTC, 26 replies.
- [jira] [Created] (FLINK-29703) Fail to call unix_timestamp in runtime in Hive dialect - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/10/20 10:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29704) E2E test for delegation token framework - posted by "Márton Balassi (Jira)" <ji...@apache.org> on 2022/10/20 11:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29705) Document the least access with RBAC setting for native K8s integration - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/10/20 11:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29706) Remove japicmp dependency bumps - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/10/20 14:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29707) Fix possible comparator violation for "flink list" - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2022/10/20 14:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29708) Enrich Flink Kubernetes Operator CRD error field - posted by "Daren Wong (Jira)" <ji...@apache.org> on 2022/10/20 18:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29709) Bump Pulsar to 2.10.2 - posted by "Yufan Sheng (Jira)" <ji...@apache.org> on 2022/10/20 20:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29710) Upgrade the minimal supported hadoop version to 2.10.2 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/10/20 20:08:00 UTC, 0 replies.
- [DISCUSS] Create a dedicated aws-base connector repository - posted by Danny Cranmer <da...@apache.org> on 2022/10/20 20:38:05 UTC, 8 replies.
- [jira] [Created] (FLINK-29711) Topic notification not present in metadata after 60000 ms. - posted by "Durgesh Mishra (Jira)" <ji...@apache.org> on 2022/10/21 02:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29712) The same batch task works fine in 1.15.2 and 1.16.0-rc1, but fails in 1.16.0-rc2 - posted by "macdoor615 (Jira)" <ji...@apache.org> on 2022/10/21 05:09:00 UTC, 0 replies.
- Modify savepoints in Flink - posted by Sriram Ganesh <sr...@gmail.com> on 2022/10/21 07:52:18 UTC, 1 replies.
- [jira] [Created] (FLINK-29713) Kubernetes operator should restart failed jobs - posted by "Peter Vary (Jira)" <ji...@apache.org> on 2022/10/21 08:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29714) Merge TableWrite and TableCompact into one interface - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/10/21 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29715) Expose max_parallelism in JSON plan - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/10/21 08:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29716) Separate slf4j jar in the lib folder from the distribution - posted by "Alexis Sarda-Espinosa (Jira)" <ji...@apache.org> on 2022/10/21 08:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29717) Supports hive udaf such as sum/count by native implementation - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/10/21 10:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29719) Supports hive count function by native implementation - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/10/21 12:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29718) Supports hive sum function by native implementation - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/10/21 12:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29720) Supports hive average function by native implemetatoin - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/10/21 12:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29721) Supports hive min function by native implementation - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/10/21 12:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29722) Supports hive max function by native implementation - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/10/21 12:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29723) Supports hive first_value function by native implementation - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/10/21 12:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29724) Supports hive last_value function by native implementation - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/10/21 12:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29725) Supports hive std function by native implementation - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/10/21 12:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29726) Supports hive stddev_samp function by native implementation - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/10/21 12:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29727) Fall back to flink-conf.yaml if no JOB_MANAGER_RPC_ADDRESS is specified - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2022/10/21 14:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29728) TablePlanner prevents Flink from starting is working directory is a symbolic link - posted by "Angelo Kastroulis (Jira)" <ji...@apache.org> on 2022/10/22 03:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29729) Support including the configured properties from flink-conf.yaml during create ParquetReader - posted by "Zhiping Wu (Jira)" <ji...@apache.org> on 2022/10/22 09:57:00 UTC, 0 replies.
- Building flink kubernetes operator on Mac. - posted by Sriram Ganesh <sr...@gmail.com> on 2022/10/22 11:29:26 UTC, 2 replies.
- [jira] [Created] (FLINK-29730) Simplify the ChannelStateWriteRequestDispatcherImpl due to not supported concurrent unaligned checkpoint - posted by "fanrui (Jira)" <ji...@apache.org> on 2022/10/22 13:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29731) Protobuf-confluent format - posted by "Krishnaiah Narukulla (Jira)" <ji...@apache.org> on 2022/10/23 13:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29732) Support configuring session with SQL statement - posted by "yuzelin (Jira)" <ji...@apache.org> on 2022/10/24 02:57:00 UTC, 0 replies.
- [DISCUSS] Issue tracking workflow - posted by Xintong Song <to...@gmail.com> on 2022/10/24 05:28:32 UTC, 9 replies.
- [jira] [Created] (FLINK-29733) Error Flink connector hive - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2022/10/24 06:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29734) Support authentication in the Flink SQL Gateway - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/10/24 06:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29735) Introduce Metadata tables for table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/10/24 08:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29736) Abstract a table interface for both data and metadata tables - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/10/24 08:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29737) Support DataGen on waveform function - posted by "chenzihao (Jira)" <ji...@apache.org> on 2022/10/24 08:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29738) Allow UDT codec registration for CassandraSinkBuilder - posted by "Bill G (Jira)" <ji...@apache.org> on 2022/10/24 09:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29739) [FLIP-265] Deprecate and remove Scala API support - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/10/24 09:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29740) Deprecate all customer-facing Scala APIs - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/10/24 09:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29741) Remove all Scala APIs - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/10/24 09:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29742) Support completing statement - posted by "yuzelin (Jira)" <ji...@apache.org> on 2022/10/24 09:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29743) CatalogPropertiesUtil supports de/serializing column comment - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/10/24 11:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29744) Throw DeploymentFailedException on ImagePullBackOff - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/10/24 22:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29745) Split reader/writer factory for compaction in MergeTreeTest - posted by "Shammon (Jira)" <ji...@apache.org> on 2022/10/25 01:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29746) Add workflow in github for micro benchmarks - posted by "Shammon (Jira)" <ji...@apache.org> on 2022/10/25 01:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29747) [UI] Refactor runtime web from module-based to standalone components - posted by "Junhan Yang (Jira)" <ji...@apache.org> on 2022/10/25 02:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29748) Expose the optimize phase in the connector context - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/10/25 03:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29749) flink info command support dynamic properties - posted by "jackylau (Jira)" <ji...@apache.org> on 2022/10/25 05:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29750) Improve PostgresCatalog#listTables() by reusing resources - posted by "Mingliang Liu (Jira)" <ji...@apache.org> on 2022/10/25 06:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29751) Migrate SQL Client Local Mode to use sql gateway - posted by "yuzelin (Jira)" <ji...@apache.org> on 2022/10/25 06:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29752) Modify Flink Table Store connector to trigger full compaction constantly when full changelog is needed - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/10/25 07:19:00 UTC, 0 replies.
- Re: Limiting backpressure during checkpoints - posted by Hangxiang Yu <ma...@gmail.com> on 2022/10/25 08:18:53 UTC, 0 replies.
- [jira] [Created] (FLINK-29753) FileSource throws exception reading file with name that ends with xz - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2022/10/25 08:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29754) HadoopConfigLoader should consider Hadoop configuration files - posted by "Peter Vary (Jira)" <ji...@apache.org> on 2022/10/25 08:22:00 UTC, 0 replies.
- [DISCUSS] Release Flink 1.15.3 - posted by Fabian Paul <fp...@apache.org> on 2022/10/25 09:11:00 UTC, 6 replies.
- flink-s3-fs-hadoop dependencies - posted by Péter Váry <pe...@gmail.com> on 2022/10/25 09:42:25 UTC, 6 replies.
- [jira] [Created] (FLINK-29755) PulsarSourceUnorderedE2ECase.testSavepoint failed because of missing TaskManagers - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/10/25 10:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29756) Support materialized column to improve query performance for complex types - posted by "Nicholas Jiang (Jira)" <ji...@apache.org> on 2022/10/25 11:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29757) ContinuousFileSplitEnumerator skip unprocessed splits when the file is splittable - posted by "Hanley Yang (Jira)" <ji...@apache.org> on 2022/10/25 12:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29758) Enum - posted by "Alexandre Decuq (Jira)" <ji...@apache.org> on 2022/10/25 12:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29759) Cast type in LEFT JOIN - posted by "Alexandre Decuq (Jira)" <ji...@apache.org> on 2022/10/25 13:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29760) Introduce snapshots metadata table - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/10/25 14:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29761) Simplify HadoopModule - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/10/25 18:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29762) Can not create a standalone cluster with reactive mode using the operator - posted by "yuvipanda (Jira)" <ji...@apache.org> on 2022/10/25 18:38:00 UTC, 0 replies.
- [ANNOUNCE] Performance Daily Monitoring Moved from Ververica to Apache Flink Slack Channel - posted by yanfei lei <fr...@gmail.com> on 2022/10/26 03:32:08 UTC, 8 replies.
- [jira] [Created] (FLINK-29763) TaskManager heatbeat timeout exception in Github CI for python tests - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2022/10/26 04:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29764) Automatic judgment of parallelism of source - posted by "waywtdcc (Jira)" <ji...@apache.org> on 2022/10/26 05:28:00 UTC, 0 replies.
- [VOTE] Dedicated AWS externalized connector repo - posted by Danny Cranmer <da...@apache.org> on 2022/10/26 06:47:45 UTC, 8 replies.
- [RESULT] [VOTE] Release 1.16.0, release candidate #2 - posted by Xingbo Huang <hx...@gmail.com> on 2022/10/26 08:39:18 UTC, 0 replies.
- [jira] [Created] (FLINK-29765) SQL query not executing properly - posted by "Aqib Mehmood (Jira)" <ji...@apache.org> on 2022/10/26 09:04:00 UTC, 0 replies.
- Stateful Functions with Flink 1.15 and onwards - posted by Filip Karnicki <fi...@gmail.com> on 2022/10/26 10:29:36 UTC, 11 replies.
- [jira] [Created] (FLINK-29766) Speculative execution supports hybrid shuffle mode. - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2022/10/26 11:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29767) Adaptive batch scheduler supports hybrid shuffle - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2022/10/26 11:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29768) Hybrid shuffle supports the update of ResultPartition information - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2022/10/26 11:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29769) Further limit the explosion range of failover in hybrid shuffle mode - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2022/10/26 12:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29770) hbase connector supports out-of-order data - posted by "Bo Cui (Jira)" <ji...@apache.org> on 2022/10/26 13:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29771) Fix flaky RollbackTest - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/10/26 15:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29772) Kafka table source scan blocked - posted by "shizhengchao (Jira)" <ji...@apache.org> on 2022/10/27 02:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29773) PreAggregationITCase.LastValueAggregation and PreAggregationITCase.LastNonNullValueAggregation are unstable - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/10/27 03:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29774) Introduce options metadata table - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/10/27 03:26:00 UTC, 0 replies.
- [DISCUSS ] add --jars to support users dependencies jars. - posted by Jacky Lau <li...@gmail.com> on 2022/10/27 04:58:48 UTC, 5 replies.
- [jira] [Created] (FLINK-29775) [JUnit5 Migration] Module: flink-statebackend-rocksdb - posted by "Hangxiang Yu (Jira)" <ji...@apache.org> on 2022/10/27 07:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29776) [JUnit5 Migration] Module: flink-statebackend-changelog - posted by "Hangxiang Yu (Jira)" <ji...@apache.org> on 2022/10/27 07:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29777) [JUnit5 Migration] Module: flink-dstl - posted by "Hangxiang Yu (Jira)" <ji...@apache.org> on 2022/10/27 08:00:00 UTC, 0 replies.
- [DISCUSS] Delete useless branches from Flink repository - posted by Leonard Xu <xb...@gmail.com> on 2022/10/27 08:12:28 UTC, 10 replies.
- [jira] [Created] (FLINK-29778) fix error in flink-1.13.md - posted by "hcj (Jira)" <ji...@apache.org> on 2022/10/27 08:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29779) Allow using MiniCluster with a PluginManager to use metrics reporters - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2022/10/27 10:57:00 UTC, 0 replies.
- [DISCUSS] Remove FlinkKafkaConsumer and FlinkKafkaProducer in the master for 1.17 release - posted by Jing Ge <ji...@ververica.com> on 2022/10/27 12:05:57 UTC, 4 replies.
- Re: [DISCUSS] Repeatable cleanup of checkpoint data - posted by Matthias Pohl <ma...@aiven.io.INVALID> on 2022/10/27 12:20:08 UTC, 0 replies.
- [jira] [Created] (FLINK-29780) how to persist flink table like spark persist dataset - posted by "qingwei zhong (Jira)" <ji...@apache.org> on 2022/10/27 13:03:00 UTC, 0 replies.
- [DISCUSS] FLINK-20578 Cannot create empty array using ARRAY[] - posted by eric xiao <xi...@gmail.com> on 2022/10/27 13:13:51 UTC, 5 replies.
- [jira] [Created] (FLINK-29781) ChangelogNormalize uses wrong keys after transformation by WatermarkAssignerChangelogNormalizeTransposeRule - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2022/10/27 13:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29782) Bash-Java-utils.jar still uses Log4j 2.16.0 - posted by "K Bharath (Jira)" <ji...@apache.org> on 2022/10/27 14:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29783) Flaky test: KafkaShuffleExactlyOnceITCase.testAssignedToPartitionFailureRecoveryEventTime - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/10/27 16:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29784) Build fails with There is at least one incompatibility: org.apache.flink.api.connector.source.SourceReader - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/10/27 18:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29785) Upgrade Flink Elasticsearch-7 connector elasticsearch.version to 7.17.0 - posted by "Elkhan Dadashov (Jira)" <ji...@apache.org> on 2022/10/27 23:25:00 UTC, 0 replies.
- Want to help upgrading Flink ElasticSearch connector - posted by Elkhan Dadashov <el...@gmail.com> on 2022/10/27 23:45:45 UTC, 1 replies.
- [VOTE] FLIP-263: Improve resolving schema compatibility - posted by Hangxiang Yu <ma...@gmail.com> on 2022/10/28 01:23:50 UTC, 8 replies.
- [jira] [Created] (FLINK-29786) VarianceThresholdSelector Uses FeaturesCol as Input Param - posted by "Jiang Xin (Jira)" <ji...@apache.org> on 2022/10/28 01:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29787) fix ci METHOD_NEW_DEFAULT issue - posted by "Yubin Li (Jira)" <ji...@apache.org> on 2022/10/28 03:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29788) StatefulJobWBroadcastStateMigrationITCase failed in native savepoints - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/10/28 03:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29789) Fix flaky tests in CheckpointCoordinatorTest - posted by "Sopan Phaltankar (Jira)" <ji...@apache.org> on 2022/10/28 04:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29790) Table Store Catalog implement getDatabase - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/10/28 06:38:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.16.0 released - posted by Xingbo Huang <hx...@apache.org> on 2022/10/28 06:45:28 UTC, 22 replies.
- [jira] [Created] (FLINK-29791) Print sink result mess up with GC log in E2eTestBase - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/10/28 07:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29792) FileStoreCommitTest is unstable and may stuck - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/10/28 09:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29793) Scala Code 2 Java Code - posted by "linweijiang (Jira)" <ji...@apache.org> on 2022/10/28 10:31:00 UTC, 0 replies.
- [VOTE] Drop TypeSerializerConfigSnapshot and savepoint support from Flink versions < 1.8.0 - posted by Piotr Nowojski <pn...@apache.org> on 2022/10/28 14:57:29 UTC, 6 replies.
- Would like to fix "FLINK-27246 Code of method "processElement...grows beyond 64 KB" - posted by Krzysztof Chmielewski <kr...@gmail.com> on 2022/10/28 19:55:56 UTC, 1 replies.
- [jira] [Created] (FLINK-29794) Flink Operator Need to Include Cause for Exceptions If Possible - posted by "Zhou Jiang (Jira)" <ji...@apache.org> on 2022/10/28 21:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29795) The source.file.stream.io-fetch-size can not be set by with properties - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/10/29 08:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29796) pyflink protobuf requirement out of date - posted by "Jorge Villatoro (Jira)" <ji...@apache.org> on 2022/10/29 20:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29797) can't run a job on yarn, if set fs.default-scheme - posted by "wangmenglong (Jira)" <ji...@apache.org> on 2022/10/30 02:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29798) Rename K8s operator client code module - posted by "Márton Balassi (Jira)" <ji...@apache.org> on 2022/10/30 14:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29799) How to override ConfigMap values while deploying the Operator via OLM? - posted by "Cansu Kavili (Jira)" <ji...@apache.org> on 2022/10/30 16:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29800) Continuous failover will leak the inprogress output file - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/10/31 04:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29801) OperatorCoordinator need open the way to operate metricGroup interface - posted by "yuemeng (Jira)" <ji...@apache.org> on 2022/10/31 06:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29802) ChangelogStateBackend supports native savepoint - posted by "Hangxiang Yu (Jira)" <ji...@apache.org> on 2022/10/31 06:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29803) Table API Scala APIs lack proper source jars - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/10/31 08:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29804) Support convertion of Correlate to Join if correlation variable is unused introduced in Calcite 1.28 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/10/31 08:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29805) Table Store sink continuously fails with "Trying to add file which is already added" when snapshot committing is slow - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/10/31 09:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29806) Move related class StateChangeOperation into package org.apache.flink.state.changelog.restore - posted by "senbork (Jira)" <ji...@apache.org> on 2022/10/31 09:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29807) Drop TypeSerializerConfigSnapshot and savepoint support from Flink versions < 1.8.0 - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2022/10/31 09:55:00 UTC, 1 replies.
- [jira] [Created] (FLINK-29808) Grant leadership to leaderContender while it is closing may lead to deadlock - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2022/10/31 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29809) REST API for running a Flink job - posted by "Nguyễn Minh Phú (Jira)" <ji...@apache.org> on 2022/10/31 10:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29810) AzureFileSystemBehaviorITCase is not executed on AzureCI - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/10/31 11:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29811) HadoopOSSFileSystemBehaviorITCase is not executed on AzureCI - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/10/31 11:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29812) Remove deprecated Netty API usages - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/10/31 11:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29813) Remove deprecated Curator API usages - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/10/31 11:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29814) Upgrade Stateful Functions to use Flink 1.15 - posted by "Fil Karnicki (Jira)" <ji...@apache.org> on 2022/10/31 11:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29815) image apache/flink:1.16.0-scala_2.12 does not exist - posted by "Harkin (Jira)" <ji...@apache.org> on 2022/10/31 12:24:00 UTC, 0 replies.
- support Kryo.setRegistrationRequired(false) - posted by Galen Warren <ga...@cvillewarrens.com> on 2022/10/31 12:30:19 UTC, 0 replies.
- [jira] [Created] (FLINK-29816) Userfunction exception in ProcessWindowFunction was called before invoke during restore state(subtask was in INITIALIZING state), but SteamTask skip handle Exception - posted by "Xie Yi (Jira)" <ji...@apache.org> on 2022/10/31 12:53:00 UTC, 0 replies.
- [GitHub] [flink-connector-shared-utils] zentol opened a new pull request, #1: Add first version of release scripts - posted by GitBox <gi...@apache.org> on 2022/10/31 12:53:19 UTC, 0 replies.
- [GitHub] [flink-connector-shared-utils] zentol commented on pull request #1: [FLINK-29472] Add first version of release scripts - posted by GitBox <gi...@apache.org> on 2022/10/31 13:05:09 UTC, 0 replies.
- [ANNOUNCE] Starting with Flink 1.17 release sync - posted by Martijn Visser <ma...@apache.org> on 2022/10/31 13:42:45 UTC, 0 replies.
- [jira] [Created] (FLINK-29817) Published metadata for apache-flink in pypi are inconsistent and causes poetry to fail - posted by "André Casimiro (Jira)" <ji...@apache.org> on 2022/10/31 14:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29818) HsResultPartitionTest.testAvailability fails - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/10/31 14:52:00 UTC, 0 replies.
- [DISCUSS] Flink release retro - posted by Matthias Pohl <ma...@aiven.io.INVALID> on 2022/10/31 15:01:14 UTC, 0 replies.
- [jira] [Created] (FLINK-29819) Record an error event when savepoint fails within grace period - posted by "Clara Xiong (Jira)" <ji...@apache.org> on 2022/10/31 15:48:00 UTC, 0 replies.