You are viewing a plain text version of this content. The canonical link for it is here.
- [jira] [Created] (FLINK-27462) could not trigger checkpoint when using table function - posted by "Spongebob (Jira)" <ji...@apache.org> on 2022/05/01 03:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27463) The JDBC connector should support option for ‘upsert’ or ‘insert’ - posted by "Liam (Jira)" <ji...@apache.org> on 2022/05/01 10:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27464) java.lang.NoClassDefFoundError - posted by "zhangxin (Jira)" <ji...@apache.org> on 2022/05/01 18:33:00 UTC, 0 replies.
- Re: Source alignment for Iceberg - posted by Steven Wu <st...@gmail.com> on 2022/05/02 02:26:21 UTC, 13 replies.
- [jira] [Created] (FLINK-27465) AvroRowDeserializationSchema.convertToTimestamp fails with negative nano seconds - posted by "Thomas Weise (Jira)" <ji...@apache.org> on 2022/05/02 04:50:00 UTC, 0 replies.
- Re: Failed Unit Test on Master Branch - posted by Thomas Weise <th...@apache.org> on 2022/05/02 04:50:33 UTC, 0 replies.
- Re: [DISCUSS] FLIP-224: Blacklist Mechanism - posted by Martijn Visser <ma...@apache.org> on 2022/05/02 06:49:18 UTC, 27 replies.
- [jira] [Created] (FLINK-27466) JDBC metaspace leak fix is misleading - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/05/02 06:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27467) Remove CliFrontendTestBase - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/05/02 08:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27468) Observing JobManager deployment. Previous status: MISSING - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/05/02 08:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27469) Remove CliFrontendRunWithYarnTest - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/05/02 09:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27470) [JUnit5 Migration] Module: flink-statebackend-heap-spillable - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/05/02 10:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27471) Add ARRAY_DISTINCT supported in SQL & Table API - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/05/02 11:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27472) Setup flink-connector-redis repository - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/05/02 11:57:00 UTC, 0 replies.
- [GitHub] [flink-connector-redis] MartijnVisser merged pull request #1: [FLINK-27472][Connector][Redis] Setup Redis connector repository - posted by GitBox <gi...@apache.org> on 2022/05/02 12:05:20 UTC, 0 replies.
- [jira] [Created] (FLINK-27473) Capture time that a job spends on initializing tasks - posted by "Jun Qin (Jira)" <ji...@apache.org> on 2022/05/02 12:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27474) Use Hugo build information to derive current branch for externally hosted documentation - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/05/02 13:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27475) Clean-up unused Maven settings from flink-connector-elasticsearch - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/05/02 13:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27476) Build new import option that only focus on maven main classes - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/05/02 15:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27477) Drop flink-yarn test-jar - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/05/02 17:03:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-227: Support overdraft buffer - posted by Piotr Nowojski <pn...@apache.org> on 2022/05/02 19:38:45 UTC, 17 replies.
- Re: [RESULT] [VOTE] Release 1.15.0, release candidate #4 - posted by Thomas Weise <th...@apache.org> on 2022/05/03 01:21:45 UTC, 3 replies.
- [jira] [Created] (FLINK-27478) failed job by uncertain cause - posted by "teeguo (Jira)" <ji...@apache.org> on 2022/05/03 03:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27479) HybridSource refreshes availability future - posted by "Mason Chen (Jira)" <ji...@apache.org> on 2022/05/03 07:46:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-221 Abstraction for lookup source cache and metric - posted by Александр Смирнов <sm...@gmail.com> on 2022/05/03 08:15:11 UTC, 39 replies.
- [jira] [Created] (FLINK-27480) KafkaSources sharing the groupId might lead to InstanceAlreadyExistException warning - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2022/05/03 08:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27481) Flink checkpoints are very slow after upgrading from Flink 1.13.1 to Flink 1.14.3 - posted by "Monika Hristova (Jira)" <ji...@apache.org> on 2022/05/03 08:26:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-217 Support watermark alignment of source splits - posted by Piotr Nowojski <pn...@apache.org> on 2022/05/03 10:24:45 UTC, 16 replies.
- REMINDER - Travel Assistance available for ApacheCon NA New Orleans 2022 - posted by Gavin McDonald <gm...@apache.org> on 2022/05/03 11:05:04 UTC, 0 replies.
- [jira] [Created] (FLINK-27482) Dashboard not showing after installation - posted by "Aarsh Shah (Jira)" <ji...@apache.org> on 2022/05/03 13:14:00 UTC, 0 replies.
- Re: [DISCUSS] DockerHub repository maintainers - posted by Yang Wang <da...@gmail.com> on 2022/05/03 14:09:31 UTC, 7 replies.
- [jira] [Created] (FLINK-27483) Support adding HTTP header for HTTP based Jar fetch - posted by "Fuyao Li (Jira)" <ji...@apache.org> on 2022/05/03 23:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27484) Reduce ArchUnit violations in the project - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2022/05/04 07:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27485) Documentation build pipeline is broken - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/05/04 07:38:00 UTC, 0 replies.
- [DISCUSS] Backport scalafmt to 1.15 branch - posted by Timo Walther <tw...@apache.org> on 2022/05/04 08:13:46 UTC, 2 replies.
- [jira] [Created] (FLINK-27486) Reduce ArchUnit violations in connector base module - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2022/05/04 08:21: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/05/04 08:42:57 UTC, 9 replies.
- [jira] [Created] (FLINK-27487) KafkaMetricWrappers do incorrect cast - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/05/04 11:33:00 UTC, 0 replies.
- [VOTE] FLIP-225: Implement standalone mode support in the kubernetes operator - posted by "Jassat, Usamah" <us...@amazon.co.uk.INVALID> on 2022/05/04 12:32:19 UTC, 5 replies.
- Re: [DISCUSS] FLIP-91: Support SQL Client Gateway - posted by Martijn Visser <ma...@apache.org> on 2022/05/04 13:41:44 UTC, 24 replies.
- Re: [DISCUSS] FLIP-223: Support HiveServer2 Endpoint - posted by Martijn Visser <ma...@apache.org> on 2022/05/04 13:44:27 UTC, 3 replies.
- [jira] [Created] (FLINK-27488) Migrate flink-docker CI to github actions - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/05/04 13:46:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-218: Support SELECT clause in CREATE TABLE(CTAS) - posted by Martijn Visser <ma...@apache.org> on 2022/05/04 13:49:00 UTC, 10 replies.
- [jira] [Created] (FLINK-27489) Allow users to run dedicated tests in the CI - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2022/05/04 14:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27490) [JUnit5 Migration] Module: flink-table-code-splitter - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/05/04 15:17:00 UTC, 0 replies.
- Pause processing of Timer messages temporarily. - posted by Rajat Gupta <ra...@gmail.com> on 2022/05/04 20:22:26 UTC, 0 replies.
- Re: [VOTE] FLIP-216: Introduce pluggable dialect and plan for migrating Hive dialect - posted by yuxia <lu...@alumni.sjtu.edu.cn> on 2022/05/05 01:37:15 UTC, 0 replies.
- [jira] [Created] (FLINK-27491) Support env replacement in flink-kubernetes-operator CR - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/05/05 01:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27492) Flink table / sql scala API is missing in the binary package - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/05/05 02:45:00 UTC, 0 replies.
- Re: [VOTE] Apache Flink Table Store 0.1.0, release candidate #2 - posted by Jingsong Li <ji...@gmail.com> on 2022/05/05 03:52:41 UTC, 10 replies.
- [DISCUSS] FLIP-228: Support Within between events in CEP Pattern - posted by Nicholas <pr...@163.com> on 2022/05/05 06:27:42 UTC, 7 replies.
- [ANNOUNCE] Apache Flink 1.15.0 released - posted by Yun Gao <ga...@apache.org> on 2022/05/05 06:37:53 UTC, 20 replies.
- Re: [DISCUSS] Keep the Community Member Information Up-to-Date - posted by Xintong Song <to...@gmail.com> on 2022/05/05 06:51:56 UTC, 1 replies.
- [jira] [Created] (FLINK-27493) Forward all numeric Kafka metrics to Flink's metrics system - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2022/05/05 08:12:00 UTC, 0 replies.
- Re: [DISCUSS] Maintain a Calcite repository for Flink to accelerate the development for Flink SQL features - posted by godfrey he <go...@gmail.com> on 2022/05/05 08:33:13 UTC, 0 replies.
- [jira] [Created] (FLINK-27494) Documentation is unavailable - posted by "李伟高 (Jira)" <ji...@apache.org> on 2022/05/05 08:39:00 UTC, 0 replies.
- Re: [DISCUSS] Planning Flink 1.16 - posted by Konstantin Knauf <kn...@apache.org> on 2022/05/05 10:10:26 UTC, 0 replies.
- [jira] [Created] (FLINK-27495) Observer should update last savepoint information directly from cluster too - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/05/05 10:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27496) Add test for rollback during application upgrade - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/05/05 10:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27497) Track terminal job states in the observer - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/05/05 10:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27498) Add E2E tests to cover Flink 1.15 - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/05/05 10:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27499) Bump base Flink version to 1.15.0 - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/05/05 10:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27501) [JUnit5 Migration] SerializerTestBase - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/05/05 10:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27500) Validation error handling inside controller blocks reconciliation - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/05/05 10:39:00 UTC, 0 replies.
- [ANNOUNCE] New Flink PMC member: Yang Wang - posted by Xintong Song <to...@gmail.com> on 2022/05/05 11:18:10 UTC, 36 replies.
- [DISCUSS] Process regarding to new connectors - posted by Martijn Visser <ma...@apache.org> on 2022/05/05 11:59:21 UTC, 1 replies.
- [jira] [Created] (FLINK-27502) Add file Suffix to data files - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/05/05 13:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27503) Rename sst file to data file - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/05/05 13:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27504) State compaction not happening with sliding window and incremental RocksDB backend - posted by "Alexis Sarda-Espinosa (Jira)" <ji...@apache.org> on 2022/05/05 15:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27505) Add javadoc comments to AsyncSinkBase - posted by "Zichen Liu (Jira)" <ji...@apache.org> on 2022/05/05 17:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27506) update playgrounds for Flink 1.14 - posted by "David Anderson (Jira)" <ji...@apache.org> on 2022/05/05 18:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27507) Update operations playground for 1.14 - posted by "David Anderson (Jira)" <ji...@apache.org> on 2022/05/05 18:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27508) Update pyflink walkthrough playground for 1.14 - posted by "David Anderson (Jira)" <ji...@apache.org> on 2022/05/05 18:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27509) Update table walkthrough playground for 1.14 - posted by "David Anderson (Jira)" <ji...@apache.org> on 2022/05/05 18:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27510) update playgrounds for Flink 1.15 - posted by "David Anderson (Jira)" <ji...@apache.org> on 2022/05/05 18:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27511) Update operations playground for 1.15 - posted by "David Anderson (Jira)" <ji...@apache.org> on 2022/05/05 18:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27512) Update pyflink walkthrough playground for 1.15 - posted by "David Anderson (Jira)" <ji...@apache.org> on 2022/05/05 18:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27513) Update table walkthrough playground for 1.15 - posted by "David Anderson (Jira)" <ji...@apache.org> on 2022/05/05 18:45:00 UTC, 0 replies.
- Re: Supporting Collector API in Kinesis Connector - posted by Danny Cranmer <da...@apache.org> on 2022/05/05 19:05:32 UTC, 0 replies.
- [jira] [Created] (FLINK-27514) Website links to up-to-date committer and PMC member lists - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2022/05/06 01:40:00 UTC, 0 replies.
- Emitting metrics from Flink SQL LookupTableSource - posted by santhosh venkat <sa...@gmail.com> on 2022/05/06 02:30:49 UTC, 1 replies.
- [jira] [Created] (FLINK-27515) Support 'ALTER TABLE ... COMPACT' in TableStore - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/05/06 02:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27516) The config execution.attached doesn't take effect because it is override by Cli param - posted by "Liu (Jira)" <ji...@apache.org> on 2022/05/06 03:04:00 UTC, 0 replies.
- [DISCUSS] FLIP-229: Introduces Join Hint for Flink SQL Batch Job - posted by Xuyang <xy...@163.com> on 2022/05/06 03:07:15 UTC, 8 replies.
- [jira] [Created] (FLINK-27517) Introduce rolling file writer to write one record each time for append-only table. - posted by "Zheng Hu (Jira)" <ji...@apache.org> on 2022/05/06 03:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27518) Refactor migration tests to support generate snapshots of new version automatically - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/05/06 04:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27519) Fix duplicates names when there are multiple levels of over window aggregate - posted by "jinfeng (Jira)" <ji...@apache.org> on 2022/05/06 04:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27520) Use admission-controller-framework in Webhook - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/05/06 05:40:00 UTC, 0 replies.
- Facing Difficulty in Deseralizing the Avro messages - posted by Vishist Bhoopalam <vi...@gmail.com> on 2022/05/06 06:32:46 UTC, 1 replies.
- [jira] [Created] (FLINK-27521) FLIP-205: Support Cache in DataStream for Batch Processing - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2022/05/06 06:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27522) Ignore max buffers per channel when allocate buffer - posted by "fanrui (Jira)" <ji...@apache.org> on 2022/05/06 06:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27523) Runtime supports producing and consuming cached intermediate result - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2022/05/06 06:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27524) Introduce cache API to DataStream - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2022/05/06 06:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27525) Add a demo for using kafka sink via Flink SQL - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/05/06 06:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27526) Support scaling bucket number for FileStore - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/05/06 07:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27527) Create a file-based Upsert sink for testing internal components - posted by "Alexander Preuss (Jira)" <ji...@apache.org> on 2022/05/06 07:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27528) Introduce a new configuration option key 'compact-rescale' - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/05/06 07:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27529) HybridSourceSplitEnumerator sourceIndex use error Integer check - posted by "Ran Tao (Jira)" <ji...@apache.org> on 2022/05/06 08:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27530) Support overdraft buffer - posted by "fanrui (Jira)" <ji...@apache.org> on 2022/05/06 08:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27531) Add explict doc on data consistency problem of RocksDB's map state iterator - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2022/05/06 08:57:00 UTC, 0 replies.
- Fwd: [Discuss] Creating an Apache Flink slack workspace - posted by Xintong Song <to...@gmail.com> on 2022/05/06 09:07:24 UTC, 27 replies.
- [jira] [Created] (FLINK-27532) Drop flink-clients test-jar - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/05/06 09:36:00 UTC, 0 replies.
- [REMINDER] Final Call for Presentations for Flink Forward San Francisco 2022 - posted by Timo Walther <tw...@apache.org> on 2022/05/06 09:57:37 UTC, 0 replies.
- [jira] [Created] (FLINK-27533) Unstable AdaptiveSchedulerSimpleITCase#testJobCancellationWhileRestartingSucceeds - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/05/06 11:03:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-220: Temporal State - posted by Nico Kruber <ni...@apache.org> on 2022/05/06 12:37:47 UTC, 1 replies.
- [jira] [Created] (FLINK-27534) Apply scalafmt to 1.15 branch - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2022/05/06 12:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27535) Optimize the unit test execution time - posted by "Dong Lin (Jira)" <ji...@apache.org> on 2022/05/06 12:43:00 UTC, 0 replies.
- Edit Permissions for Flink Connector Template - posted by "Ber, Jeremy" <jd...@amazon.com.INVALID> on 2022/05/06 13:25:13 UTC, 4 replies.
- [jira] [Created] (FLINK-27536) Rename method parameter in AsyncSinkWriter - posted by "Zichen Liu (Jira)" <ji...@apache.org> on 2022/05/06 13:54:00 UTC, 0 replies.
- How to support C#/dotNet ? - posted by Bruce Tian <br...@gmail.com> on 2022/05/06 14:05:31 UTC, 4 replies.
- [jira] [Created] (FLINK-27537) Remove requirement for Async Sink's RequestEntryT to be serializable - posted by "Zichen Liu (Jira)" <ji...@apache.org> on 2022/05/06 16:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27538) Change flink.version 1.15-SNAPSHOT to 1.15.0 in table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/05/07 02:50:00 UTC, 0 replies.
- [DISCUSS ] HybridSouce Table & Sql api timeline - posted by Ran Tao <ch...@gmail.com> on 2022/05/07 03:59:16 UTC, 8 replies.
- flink Job is throwing depdnecy issue when submitted to clusrer - posted by Great Info <gu...@gmail.com> on 2022/05/07 05:21:18 UTC, 2 replies.
- [jira] [Created] (FLINK-27539) support consuming update and delete changes In Windowing TVFs - posted by "hjw (Jira)" <ji...@apache.org> on 2022/05/07 07:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27540) Let FileStoreSource accept pre-planned manifest entries - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/05/07 07:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27541) Support distribute by For FlinkSql - posted by "Aiden (Jira)" <ji...@apache.org> on 2022/05/07 09:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27542) Add end to end tests for Hive to read external table store files - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/05/07 09:48:00 UTC, 0 replies.
- Log File of Flink Unit Test - posted by Prabhu Joseph <pr...@gmail.com> on 2022/05/08 11:28:27 UTC, 2 replies.
- [jira] [Created] (FLINK-27543) Introduce StatsProducer to refactor code in DataFileWriter - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/05/08 11:57:00 UTC, 0 replies.
- Contributing to Flink - posted by Atri Sharma <at...@apache.org> on 2022/05/08 19:45:34 UTC, 3 replies.
- [jira] [Created] (FLINK-27544) Example code in 'Structure of Table API and SQL Programs' is out of date and cannot run - posted by "Chengkai Yang (Jira)" <ji...@apache.org> on 2022/05/09 02:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27545) Update examples in PyFlink shell - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2022/05/09 02:32:00 UTC, 0 replies.
- 【Could we support distribute by For FlinkSql】 - posted by "lpengdream@163.com" <lp...@163.com> on 2022/05/09 03:16:00 UTC, 6 replies.
- 回复: 【Could we support distribute by For FlinkSql】 - posted by "lpengdream@163.com" <lp...@163.com> on 2022/05/09 03:22:19 UTC, 0 replies.
- [jira] [Created] (FLINK-27546) Add append only writer which implements the RecordWriter interface. - posted by "Zheng Hu (Jira)" <ji...@apache.org> on 2022/05/09 03:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27547) Hardcode of pom aboout java11 & java17 target java version may cause hidden error - posted by "Ran Tao (Jira)" <ji...@apache.org> on 2022/05/09 05:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27548) Improve quick-start of table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/05/09 05:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27549) Inconsistent bytecode version when enable jdk11 or higher version - posted by "Ran Tao (Jira)" <ji...@apache.org> on 2022/05/09 05:27:00 UTC, 0 replies.
- [Question][Kafka SQL Connector] When will decoding format emits multiple keys for a Kafka key; why do a cartesian product. - posted by Yufei Zhang <af...@gmail.com> on 2022/05/09 05:57:22 UTC, 2 replies.
- [jira] [Created] (FLINK-27550) Remove checking yarn queues before submitting job to Yarn - posted by "Junfan Zhang (Jira)" <ji...@apache.org> on 2022/05/09 06:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27551) Consider implementing our own status update logic - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/05/09 06:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27552) Prometheus metrics - posted by "João Boto (Jira)" <ji...@apache.org> on 2022/05/09 06:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27553) Clarify the semantic of RecordWriter interface. - posted by "Zheng Hu (Jira)" <ji...@apache.org> on 2022/05/09 06:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27554) The asf-site does not build on Apple Silicon - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2022/05/09 06:57:00 UTC, 0 replies.
- [DISCUSS] Add scala-2.13 support for implementing completed jdk11 or higher flink version - posted by Ran Tao <ch...@gmail.com> on 2022/05/09 07:24:54 UTC, 4 replies.
- [jira] [Created] (FLINK-27555) Performance regression in schedulingDownstreamTasks on 02.05.2022 - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/05/09 08:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27556) Performance regression in checkpointSingleInput.UNALIGNED on 29.04.2022 - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/05/09 08:36:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-226: Introduce Schema Evolution on Table Store - posted by Caizhi Weng <ts...@gmail.com> on 2022/05/09 08:44:04 UTC, 5 replies.
- [DISCUSS] Planning Flink 1.16 with the community - posted by Martijn Visser <ma...@apache.org> on 2022/05/09 10:27:58 UTC, 6 replies.
- [RESULT] [VOTE] Apache Flink Table Store 0.1.0, release candidate #2 - posted by Jingsong Li <ji...@gmail.com> on 2022/05/09 10:36:25 UTC, 0 replies.
- [jira] [Created] (FLINK-27557) Create the empty writer for 'ALTER TABLE ... COMPACT' - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/05/09 13:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27558) Introduce a new optional option for TableStoreFactory to represent planned manifest entries - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/05/09 15:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27559) Some question about flink operator state - posted by "Underwood (Jira)" <ji...@apache.org> on 2022/05/10 02:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27560) Refactor SimpleStateRequestHandler for PyFlink state - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2022/05/10 03:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27561) [JUnit5 Migration] Module: flink-connector-aws-base - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/05/10 08:41:00 UTC, 0 replies.
- JobManager High Availability - posted by Őrhidi Mátyás <ma...@gmail.com> on 2022/05/10 08:55:38 UTC, 4 replies.
- [jira] [Created] (FLINK-27562) Creating HDFS table in SQL client throws UnsupportedFileSystemSchemeException even if hadoop jar is added through --jar argument - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/05/10 09:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27563) Resource Providers - Yarn doc page has minor display error - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2022/05/10 09:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27564) Split PyFlink DataStream connectors into separate files - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2022/05/10 12:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27565) Bump minimist from 1.2.5 to 1.2.6 in /flink-runtime-web/web-dashboard - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/05/10 13:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27566) [JUnit5 Migration] Module: flink-connector-aws-kinesis-firehose - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/05/10 13:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27567) [JUnit5 Migration] Module: flink-connector-aws-kinesis-streams - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/05/10 14:29:00 UTC, 0 replies.
- Flink job restarted from empty state when execution.shutdown-on-application-finish is enabled - posted by Gyula Fóra <gy...@apache.org> on 2022/05/10 19:41:08 UTC, 3 replies.
- [jira] [Created] (FLINK-27568) Cannot submit JobGraph - posted by "Jason Kania (Jira)" <ji...@apache.org> on 2022/05/11 03:17:00 UTC, 0 replies.
- Re: Re: [DISCUSS] FLIP-168: Speculative execution for Batch Job - posted by Zhu Zhu <re...@gmail.com> on 2022/05/11 04:29:36 UTC, 1 replies.
- Flink job restarted from empty state when execution.shutdown-on-application-finish is false - posted by Gyula Fóra <gy...@apache.org> on 2022/05/11 05:03:16 UTC, 1 replies.
- Pulsar/Flink Error: PulsarAdminException$NotFoundException: Topic not exist - posted by Jason Kania <ja...@ymail.com.INVALID> on 2022/05/11 05:03:46 UTC, 0 replies.
- [ANNOUNCE] Apache Flink Table Store 0.1.0 released - posted by Jingsong Lee <lz...@apache.org> on 2022/05/11 05:55:17 UTC, 1 replies.
- [jira] [Created] (FLINK-27569) Terminated Flink job restarted from empty state when execution.shutdown-on-application-finish is false - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/05/11 07:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27570) A checkpoint path error does not cause the job to stop - posted by "Underwood (Jira)" <ji...@apache.org> on 2022/05/11 08:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27571) Recognize "less is better" benchmarks in regression detection script - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/05/11 08:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27572) Verify HA Metadata present before performint last-state restore - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/05/11 08:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27573) Configuring a new random job result store directory - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/05/11 10:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27574) [QUESTION] In Flink k8s Application mode with HA can not using History Server for history backend - posted by "tanjialiang (Jira)" <ji...@apache.org> on 2022/05/11 11:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27575) Support PyFlink in Python3.9 - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/05/11 11:33:00 UTC, 0 replies.
- [QUESTION] In Flink k8s Application mode with HA can not using History Server for history backend - posted by 谭家良 <ta...@126.com> on 2022/05/11 11:52:33 UTC, 1 replies.
- [jira] [Created] (FLINK-27576) Flink will request new pod when jm pod is delete, but will remove when TaskExecutor exceeded the idle timeout - posted by "zhisheng (Jira)" <ji...@apache.org> on 2022/05/11 12:12:00 UTC, 0 replies.
- [DISCUSS] Release first version of Elasticsearch connector from external repository - posted by Martijn Visser <ma...@apache.org> on 2022/05/11 18:09:55 UTC, 3 replies.
- Incompatible data types while using firehose sink - posted by Zain Haider Nemati <za...@retailo.co> on 2022/05/11 19:41:04 UTC, 0 replies.
- [jira] [Created] (FLINK-27577) Add windowAll operator - posted by "zhangjingcun (Jira)" <ji...@apache.org> on 2022/05/12 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27578) Elasticsearch6SinkE2ECase.testScaleUp fails after "Exhausted retry attempts" - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/05/12 07:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27579) The param client.timeout can not be set by dynamic properties when stopping the job - posted by "Liu (Jira)" <ji...@apache.org> on 2022/05/12 08:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27580) Implement filter pushdown for TableStoreHiveStorageHandler - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/05/12 08:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27581) modify the number of parameters - posted by "zeliu (Jira)" <ji...@apache.org> on 2022/05/12 08:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27582) modify the number of parameters - posted by "zeliu (Jira)" <ji...@apache.org> on 2022/05/12 08:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27583) Improve the plan for TPC-DS queries - posted by "godfrey he (Jira)" <ji...@apache.org> on 2022/05/12 08:59:00 UTC, 0 replies.
- [VOTE] FLIP-226: Introduce Schema Evolution on Table Store - posted by Jingsong Li <ji...@gmail.com> on 2022/05/12 09:06:23 UTC, 3 replies.
- [jira] [Created] (FLINK-27584) Support broadcast state in PyFlink DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2022/05/12 09:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27585) JdbcOutpuFormat fails to flush data on checkpoint and causes data loss - posted by "Paul Lin (Jira)" <ji...@apache.org> on 2022/05/12 09:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27586) Support non-keyed co-broadcast processing - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2022/05/12 09:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27587) Support keyed co-broadcast processing - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2022/05/12 09:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27588) Update broadcast state related docs for PyFlink - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2022/05/12 09:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27589) Fix incorrect implementation of TableStoreDateObjectInspector - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/05/12 10:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27590) Provide endpoint with information about leader Jobmanager in HA setups via Zookeeper - posted by "Dhruv Patel (Jira)" <ji...@apache.org> on 2022/05/12 10:30:00 UTC, 0 replies.
- Batching in kinesis sink - posted by Zain Haider Nemati <za...@retailo.co> on 2022/05/12 10:30:47 UTC, 0 replies.
- [jira] [Created] (FLINK-27591) Improve the plan for batch queries when statistics is unavailable - posted by "godfrey he (Jira)" <ji...@apache.org> on 2022/05/12 10:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27592) WebUI - Status CANCELING not showing in overview - posted by "Peter Schrott (Jira)" <ji...@apache.org> on 2022/05/12 11:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27593) Parquet/Orc format reader optimization - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/05/12 11:59:00 UTC, 0 replies.
- [DISCUSS] FLIP-232: Add Retry Support For Async I/O In DataStream API - posted by Lincoln Lee <li...@gmail.com> on 2022/05/12 12:56:27 UTC, 21 replies.
- [jira] [Created] (FLINK-27594) Only recover JM deployment if HA metadata available - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/05/12 13:06:00 UTC, 0 replies.
- [ANNOUNCE] Problems with build due to tests using too much disk space - posted by Martijn Visser <ma...@apache.org> on 2022/05/12 13:39:18 UTC, 3 replies.
- [jira] [Created] (FLINK-27595) Helm: We should make security context configurable - posted by "Xin Hao (Jira)" <ji...@apache.org> on 2022/05/12 16:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27596) [Umbrella] Optimize Hive source - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/05/13 02:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27597) Get statistic for Hive paritioned table - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/05/13 02:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27598) Improve the exception message when mixing use Python UDF and Pandas UDF - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2022/05/13 06:44:00 UTC, 0 replies.
- Split string flatmap -> Arraylist/List - posted by Zain Haider Nemati <za...@retailo.co> on 2022/05/13 07:29:01 UTC, 1 replies.
- [jira] [Created] (FLINK-27599) Setup flink-connector-rabbitmq repository - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/05/13 07:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27600) Add basic logs for coping and deleting jars - posted by "Xin Hao (Jira)" <ji...@apache.org> on 2022/05/13 08:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27601) Translation in Korean - posted by "Kwang-in (Dennis) JUNG (Jira)" <ji...@apache.org> on 2022/05/13 09:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27602) Add docs in Python ML - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/05/13 09:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27603) Hive dialect support "reload function" - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/05/13 10:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27604) flink sql read hive on hbase throw NPE - posted by "zhangsan (Jira)" <ji...@apache.org> on 2022/05/13 10:46:00 UTC, 0 replies.
- [DISCUSS] FLIP-231: Introduce SupportStatisticReport to support reporting statistics from source connectors - posted by godfrey he <go...@gmail.com> on 2022/05/13 10:56:20 UTC, 11 replies.
- [jira] [Created] (FLINK-27605) Upgrade mockito to a version where static function mocking is possible - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/05/13 10:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27606) Fix code generator exception when using imperative udaf that is introduced for planner scala-free - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/05/13 12:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27607) [JUnit5 Migration] Module: flink-connector-files - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/05/13 13:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27608) Flink may throw PartitionNotFound Exception if the downstream task reached Running state earlier than it's upstream task - posted by "zlzhang0122 (Jira)" <ji...@apache.org> on 2022/05/13 13:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27609) Tracking flink-version and flink-revision in FlinkDeploymentStatus - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/05/13 13:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27610) PrometheusPushGatewayReporter doesn't support basic authentication - posted by "Qihong Jiang (Jira)" <ji...@apache.org> on 2022/05/13 19:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27611) ConcurrentModificationException during Flink-Pulsar checkpoint notification - posted by "Jason Kania (Jira)" <ji...@apache.org> on 2022/05/14 04:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27612) Generate waring events when deleting the session cluster - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/05/14 06:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27613) Add label for the session job to help list the session jobs in the same session cluster - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/05/14 08:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27614) Use informer in webhook to avoid query apiserver at each update - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/05/14 08:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27615) Document the minimum supported version of k8s for flink k8s operator - posted by "Biao Geng (Jira)" <ji...@apache.org> on 2022/05/14 09:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27616) Modify the spelling mistakes of the comment word - posted by "codingcaproni (Jira)" <ji...@apache.org> on 2022/05/14 11:58:00 UTC, 0 replies.
- taskexecutor .out files - posted by Zain Haider Nemati <za...@retailo.co> on 2022/05/15 11:04:37 UTC, 2 replies.
- Kinesis Sink - Data being received with intermittent breaks - posted by Zain Haider Nemati <za...@retailo.co> on 2022/05/15 22:12:35 UTC, 0 replies.
- [jira] [Created] (FLINK-27617) Add more analysis functions for Flink batch - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/05/16 01:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27618) Suuport CumeDist - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/05/16 01:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27619) Support NTIE - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/05/16 01:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27620) Support percent_rank - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/05/16 01:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27621) expose SafetyNetWrapperClassLoader from private to public and add addUrl method for flink client - posted by "jackylau (Jira)" <ji...@apache.org> on 2022/05/16 02:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27622) Make `AsyncDataStream.OutputMode` configurable for table module - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2022/05/16 03:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27623) Add 'table.exec.async-lookup.output-mode' to ExecutionConfigOptions - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2022/05/16 03:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27624) Add plan validation when 'table.exec.async-lookup.output-mode' is unordered - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2022/05/16 03:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27625) Add query hint for async lookup join - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2022/05/16 03:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27626) Introduce pre-aggregated merge to table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/05/16 03:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27627) Incorrect result when order by (string, double) pair with NaN values - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/05/16 03:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27628) Table Store records and fetches incorrect results with NaN - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/05/16 04:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27629) Table Store throws NullPointerException when pushing down NotEqual predicate to a column consisting of nulls - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/05/16 06:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27631) Datastream job combined with table job - posted by "waywtdcc (Jira)" <ji...@apache.org> on 2022/05/16 06:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27630) maven-source-plugin for table planner values connector for debug - posted by "jackylau (Jira)" <ji...@apache.org> on 2022/05/16 06:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27632) Improve connector testing framework to support more cases - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2022/05/16 08:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27633) Add FLIP-33 metric validation case in connector testing framework - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2022/05/16 08:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27634) Add component failure cases in connector testing framework - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2022/05/16 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27635) Add data type coverage and abilities test cases for table connectors in testing framework - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2022/05/16 08:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27636) Add data type coverage and sync / async tests for catalog in connector testing framework - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2022/05/16 08:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27637) Optimize the log information when the asynchronous part of checkpoint is canceled - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2022/05/16 08:42:00 UTC, 0 replies.
- Fw: What is the alternative schema of DirectOutput - posted by Boot <33...@qq.com.INVALID> on 2022/05/16 09:59:17 UTC, 1 replies.
- [RESULT][VOTE] FLIP-226: Introduce Schema Evolution on Table Store - posted by Jingsong Li <ji...@gmail.com> on 2022/05/16 10:55:37 UTC, 0 replies.
- [jira] [Created] (FLINK-27638) failed to join with table function - posted by "Spongebob (Jira)" <ji...@apache.org> on 2022/05/16 11:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27639) Flink JOIN uses the now() function when inserting data, resulting in data that cannot be deleted - posted by "lvycc (Jira)" <ji...@apache.org> on 2022/05/16 12:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27640) Flink not compiling, flink-connector-hive_2.12 is missing pentaho-aggdesigner-algorithm:jar:5.1.5-jhyde - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2022/05/16 12:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27641) Create view lost Time attribute in Hive Catalog - posted by "Robert Wu (Jira)" <ji...@apache.org> on 2022/05/16 12:31:00 UTC, 0 replies.
- Re: [DISCUSS] Next Flink Kubernetes Operator release timeline - posted by Gyula Fóra <gy...@apache.org> on 2022/05/16 12:50:34 UTC, 4 replies.
- [jira] [Created] (FLINK-27642) Make sure that the Elasticsearch E2E tests only try a limited amount of retries in case of test failures - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/05/16 13:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27643) Document new deployment lifecycle features for the operator - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/05/16 13:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27644) Update CRD documentation with new spec/status changes - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/05/16 13:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27645) Update overview / supported features page for 1.0.0 - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/05/16 13:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27646) Create Roadmap page for Flink Kubernetes operator - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/05/16 13:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27647) Improve Metrics documentation to include newly added metrics - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/05/16 13:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27648) Review example YAMLs in the documentation - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/05/16 13:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27649) Reduce the number of outputted log lines by Elasticsearch6SinkE2ECase and Elasticsearch7SinkE2ECase - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/05/16 13:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27650) First environment variable of top level pod template is lost - posted by "Simon Paradis (Jira)" <ji...@apache.org> on 2022/05/16 14:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27651) Support CREATE FUNCTION USING JAR syntax - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/05/16 15:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27652) CompactManager.Rewriter cannot handle different partition keys invoked compaction - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/05/16 15:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27653) Pulsar Connector bug: The startCursor has been setted default value of "MessageId.earliest", Every time to restart the job,the Consumer will do the seek operation. - posted by "wawa (Jira)" <ji...@apache.org> on 2022/05/16 15:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27654) Older jackson-databind found in /flink-kubernetes-shaded-1.0-SNAPSHOT.jar - posted by "James Busche (Jira)" <ji...@apache.org> on 2022/05/16 22:58:00 UTC, 0 replies.
- [VOTE] FLIP-229: Introduces Join Hint for Flink SQL Batch Job - posted by Xuyang <xy...@163.com> on 2022/05/17 02:21:12 UTC, 6 replies.
- [jira] [Created] (FLINK-27655) Implement Avro File statistic collector - posted by "Zheng Hu (Jira)" <ji...@apache.org> on 2022/05/17 02:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27656) Add parquet file format - posted by "Zheng Hu (Jira)" <ji...@apache.org> on 2022/05/17 02:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27657) Implement remote operator state backend in PyFlink - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2022/05/17 06:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27658) Introduce MutableURLClassLoader allow to register and remove user jar dynamically - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/05/17 06:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27659) Planner support to use jar which is registered by "USING JAR" syntax - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/05/17 06:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27660) Table API support create function using customed jar - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/05/17 06:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27661) [Metric]Flink-Metrics pushgateway support authentication - posted by "jiangchunyang (Jira)" <ji...@apache.org> on 2022/05/17 07:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27662) [JUnit5 Migration] Migrate TypeInformationTestBase to Junit5 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/05/17 07:36:00 UTC, 0 replies.
- [VOTE] Creating an Apache Flink slack workspace - posted by Xintong Song <to...@gmail.com> on 2022/05/17 08:23:59 UTC, 20 replies.
- [jira] [Created] (FLINK-27663) upsert-kafka can't process delete message from upsert-kafka sink - posted by "Zhiwen Sun (Jira)" <ji...@apache.org> on 2022/05/17 09:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27664) cron_snapshot_deployment_maven fails due to JavaDoc building error - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/05/17 09:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27665) Optimise event triggering on DeploymentFailedExceptions - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/05/17 10:15:00 UTC, 0 replies.
- Channel became inactive while submitting job - posted by Zain Haider Nemati <za...@retailo.co> on 2022/05/17 10:33:44 UTC, 1 replies.
- [jira] [Created] (FLINK-27666) Cover manual savepoint triggering in E2E tests - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/05/17 10:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27667) YARNHighAvailabilityITCase fails with "Failed to delete temp directory /tmp/junit1681" - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/05/17 11:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27668) Document dynamic operator configuration - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/05/17 13:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27669) [JUnit5 Migration] Migrate flink-file-sink-common - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/05/17 13:57:00 UTC, 0 replies.
- [DISCUSS] FLIP-233: Introduce HTTP Connector - posted by "Ber, Jeremy" <jd...@amazon.com.INVALID> on 2022/05/17 14:21:31 UTC, 2 replies.
- [jira] [Created] (FLINK-27670) Python wrappers for Kinesis Sinks - posted by "Zichen Liu (Jira)" <ji...@apache.org> on 2022/05/17 14:41:00 UTC, 0 replies.
- [ANNOUNCE] Kubernetes Operator release-1.0 branch cut - posted by Gyula Fóra <gy...@apache.org> on 2022/05/17 14:45:56 UTC, 2 replies.
- [jira] [Created] (FLINK-27671) Publish SNAPSHOT docker images - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2022/05/17 15:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27672) [JUnit5 Migration] Module: flink-table-common - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/05/17 19:13:00 UTC, 0 replies.
- Metrics in Flink UI - posted by Zain Haider Nemati <za...@retailo.co> on 2022/05/17 19:28:50 UTC, 1 replies.
- Memory configuration for Queue - posted by Zain Haider Nemati <za...@retailo.co> on 2022/05/17 20:50:13 UTC, 0 replies.
- Data Engineering Track at ApacheCon (October 3-6, New Orleans) - CFP ends 23/05 - posted by Ismaël Mejía <ie...@gmail.com> on 2022/05/17 20:58:01 UTC, 0 replies.
- [jira] [Created] (FLINK-27673) [JUnit5 Migration] Module: flink-table-api-scala - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/05/17 21:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27674) Elasticsearch6SinkE2ECase test hangs - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/05/18 02:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27675) Improve manual savepoint tracking - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/05/18 05:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27676) Output records from on_timer are behind the triggering watermark in PyFlink - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2022/05/18 07:45:00 UTC, 0 replies.
- Could not copy native libraries - Permission denied - posted by Zain Haider Nemati <za...@retailo.co> on 2022/05/18 08:07:04 UTC, 0 replies.
- [jira] [Created] (FLINK-27677) Kubernetes reuse rest.bind-port, but do not support a range of ports - posted by "tartarus (Jira)" <ji...@apache.org> on 2022/05/18 08:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27678) Support append-only table for file store. - posted by "Zheng Hu (Jira)" <ji...@apache.org> on 2022/05/18 08:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27679) Support append-only table for log store. - posted by "Zheng Hu (Jira)" <ji...@apache.org> on 2022/05/18 08:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27680) Disable PulsarSinkITCase on JDK 11 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/05/18 09:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27681) Improve the availability of Flink when the RocksDB file is corrupted. - posted by "ming li (Jira)" <ji...@apache.org> on 2022/05/18 09:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27682) [JUnit5 Migration] Migrate ComparatorTestBase to Junit5 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/05/18 10:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27683) Insert into (column1, column2) Values(.....) can't work with sql Hints - posted by "Xin Yang (Jira)" <ji...@apache.org> on 2022/05/18 10:29:00 UTC, 0 replies.
- [ANNOUNCE] Call for Presentations for ApacheCon Asia 2022 streaming track - posted by Yu Li <ca...@gmail.com> on 2022/05/18 11:47:47 UTC, 1 replies.
- [jira] [Created] (FLINK-27684) FlinkKafkaConsumerBase could record partitions offset when GROUP_OFFSETS - posted by "SilkyAlex (Jira)" <ji...@apache.org> on 2022/05/18 12:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27685) Add scale subresource - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/05/18 13:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27686) Only patch status when the status actually changed - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/05/18 15:45:00 UTC, 0 replies.
- Kafka Sink Key and Value Avro Schema Usage Issues - posted by "Ghiya, Jay (GE Healthcare)" <Ja...@ge.com> on 2022/05/18 16:21:06 UTC, 1 replies.
- [jira] [Created] (FLINK-27687) SpanningWrapper shouldn't assume temp folder exists - posted by "Gaël Renoux (Jira)" <ji...@apache.org> on 2022/05/18 16:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27688) Pluggable backend for EventUtils - posted by "Márton Balassi (Jira)" <ji...@apache.org> on 2022/05/18 19:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27689) Pulsar Connector support PulsarSchema - posted by "LuNng Wang (Jira)" <ji...@apache.org> on 2022/05/19 03:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27690) Add Pulsar Source connector document - posted by "LuNng Wang (Jira)" <ji...@apache.org> on 2022/05/19 03:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27691) RankHarnessTest. testUpdateRankWithRowNumberSortKeyDropsToNotLast test failed with result mismatch - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/05/19 06:12:00 UTC, 0 replies.
- Re: Flink Kubernetes operator not having a scale subresource - posted by Gyula Fóra <gy...@apache.org> on 2022/05/19 06:13:49 UTC, 0 replies.
- [jira] [Created] (FLINK-27692) Support local recovery for materialized part(write, restore, discard) - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2022/05/19 06:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27695) KafkaTransactionLogITCase failed on azure due to Could not find a valid Docker environment - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/05/19 06:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27693) Support local recovery for non-materialized part(write, restore, discard) - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2022/05/19 06:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27694) Move lint-python log location - posted by "LuNng Wang (Jira)" <ji...@apache.org> on 2022/05/19 06:19:00 UTC, 0 replies.
- [DISCUSS] FLIP-235: Hybrid Shuffle Mode - posted by weijie guo <gu...@gmail.com> on 2022/05/19 06:30:38 UTC, 16 replies.
- [jira] [Created] (FLINK-27696) Add bin-pack strategy to split the whole bucket data files into several small splits for append-only table. - posted by "Zheng Hu (Jira)" <ji...@apache.org> on 2022/05/19 07:22:00 UTC, 0 replies.
- [DISCUSS] FLINK-27625: Add a new query hint for async lookup join - posted by Lincoln Lee <li...@gmail.com> on 2022/05/19 07:29:13 UTC, 0 replies.
- [jira] [Created] (FLINK-27697) Restoring from a checkpoint will start duplicated application when mixing use streaming sinks and sql sinks in code. - posted by "Ying Lin (Jira)" <ji...@apache.org> on 2022/05/19 08:41:00 UTC, 0 replies.
- Flink application on yarn cluster - main method not found - posted by Zain Haider Nemati <za...@retailo.co> on 2022/05/19 08:49:23 UTC, 2 replies.
- [jira] [Created] (FLINK-27698) [JUnit5 Migration] Module: flink-table-api-java-bridge - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/05/19 09:04:00 UTC, 0 replies.
- Final reminder: ApacheCon North America call for presentations closing soon - posted by Rich Bowen <rb...@apache.org> on 2022/05/19 09:44:23 UTC, 0 replies.
- [DISCUSS] FLIP-234: Support Retryable Lookup Join To Solve Delayed Updates Issue In External Systems - posted by Lincoln Lee <li...@gmail.com> on 2022/05/19 10:24:29 UTC, 6 replies.
- [jira] [Created] (FLINK-27699) Align Pulsar source atPublishTime method - posted by "LuNng Wang (Jira)" <ji...@apache.org> on 2022/05/19 11:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27700) BroadcastOutputTest tests failed - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/05/19 11:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27701) HashMapStateBackendWindowITCase. testAggregateWindowStateReader failed with Not all required tasks are currently running - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/05/19 12:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27702) Flink table code splitter does not throw anything if result is not compiled - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/05/19 12:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27703) FileChannelManagerImplTest.testDirectoriesCleanupOnKillWithoutCallerHook failed with The marker file was not found within 10000 msecs - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/05/19 12:52:00 UTC, 0 replies.
- Job Logs - Yarn Application Mode - posted by Zain Haider Nemati <za...@retailo.co> on 2022/05/19 14:56:39 UTC, 5 replies.
- [jira] [Created] (FLINK-27704) Java 17 compatibility - posted by "Jordan Kaye (Jira)" <ji...@apache.org> on 2022/05/19 16:08:00 UTC, 0 replies.
- [RESULT] [VOTE] FLIP-229: Introduces Join Hint for Flink SQL Batch Job - posted by Xuyang <xy...@163.com> on 2022/05/20 02:16:38 UTC, 0 replies.
- [jira] [Created] (FLINK-27705) num-sorted-run.compaction-trigger should not interfere the num-levels - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/05/20 02:35:00 UTC, 0 replies.
- [VOTE] FLIP-91: Support SQL Gateway - posted by Shengkai Fang <fs...@gmail.com> on 2022/05/20 02:38:39 UTC, 9 replies.
- [jira] [Created] (FLINK-27706) Refactor all subclasses of FileStoreTableITCase to use the batchSql. - posted by "Zheng Hu (Jira)" <ji...@apache.org> on 2022/05/20 03:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27707) Implement TableStoreFactory#onCompactTable - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/05/20 03:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27708) Add background compaction task for append-only table when ingesting. - posted by "Zheng Hu (Jira)" <ji...@apache.org> on 2022/05/20 03:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27709) Add comment to schema - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/05/20 03:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27710) Improve logs to better display Execution - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2022/05/20 04:17:00 UTC, 0 replies.
- [VOTE] FLIP-224: Blocklist Mechanism - posted by Lijie Wang <wa...@gmail.com> on 2022/05/20 04:57:31 UTC, 5 replies.
- [jira] [Created] (FLINK-27711) Align setTopicPattern for Pulsar Connector - posted by "LuNng Wang (Jira)" <ji...@apache.org> on 2022/05/20 05:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27712) Job failed to start due to "Time should be non negative" - posted by "Sharon Xie (Jira)" <ji...@apache.org> on 2022/05/20 05:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27713) Bump Apache Beam to 2.40.0 - posted by "LuNng Wang (Jira)" <ji...@apache.org> on 2022/05/20 07:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27714) Migrate to java-operator-sdk v3 - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/05/20 07:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27715) Add more Python ML examples - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/05/20 07:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27716) Add Python API docs in ML - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/05/20 07:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27717) Document operator compatibility guarantees - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/05/20 08:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27718) Hive dialect supports to count mutiple fields - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/05/20 08:31:00 UTC, 0 replies.
- [DISCUSS] Update Scala 2.12.7 to 2.12.15 - posted by Martijn Visser <ma...@apache.org> on 2022/05/20 08:36:47 UTC, 4 replies.
- Flatmap node at 100% - posted by Zain Haider Nemati <za...@retailo.co> on 2022/05/20 08:51:14 UTC, 3 replies.
- [jira] [Created] (FLINK-27719) Create Apache Flink slack workspace - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2022/05/20 09:39:00 UTC, 0 replies.
- [RESULT][VOTE] Creating an Apache Flink slack workspace - posted by Xintong Song <to...@gmail.com> on 2022/05/20 09:39:44 UTC, 0 replies.
- [jira] [Created] (FLINK-27720) Slack: Update the project website regarding communication channels - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2022/05/20 09:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27721) Slack: set up archive - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2022/05/20 09:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27722) Slack: set up auto-updated invitation link - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2022/05/20 09:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27723) Slack: revisit how this communication channel works - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2022/05/20 09:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27724) The SubtaskCheckpointCoordinatorImpl#close() isn't called in anywhere - posted by "fanrui (Jira)" <ji...@apache.org> on 2022/05/20 09:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27725) Create tests for TypeInformation and TypeSerializer classes in table - posted by "Alexander Preuss (Jira)" <ji...@apache.org> on 2022/05/20 13:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27726) shad thrift and fb303 in hive connector - posted by "Chen Qin (Jira)" <ji...@apache.org> on 2022/05/20 16:29:00 UTC, 0 replies.
- Task Manager Heap Memory Overflowing - posted by Zain Haider Nemati <za...@retailo.co> on 2022/05/20 21:19:07 UTC, 0 replies.
- [jira] [Created] (FLINK-27727) [JUnit5 Migration] Migrate TypeSerializerUpgradeTestBase to Junit5 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/05/21 00:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27728) dockerFile build results in five vulnerabilities - posted by "James Busche (Jira)" <ji...@apache.org> on 2022/05/21 02:03:00 UTC, 0 replies.
- Json Deserialize in DataStream API with array length not fixed - posted by Zain Haider Nemati <za...@retailo.co> on 2022/05/21 06:58:33 UTC, 1 replies.
- [jira] [Created] (FLINK-27729) Support constructing StartCursor and StopCursor from MessageId - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2022/05/21 10:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27730) Kafka connector document code sink has an error - posted by "liuwei (Jira)" <ji...@apache.org> on 2022/05/22 01:56:00 UTC, 0 replies.
- Request for Review: FLINK-27507 and FLINK-27509 - posted by Shubham Bansal <sh...@gmail.com> on 2022/05/22 02:12:23 UTC, 1 replies.
- Contributing to Apache Flink - posted by Shubham Bansal <sh...@gmail.com> on 2022/05/22 02:34:39 UTC, 0 replies.
- [jira] [Created] (FLINK-27731) Cannot build documentation with Hugo docker image - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2022/05/22 06:22:00 UTC, 0 replies.
- Apply for Contributor Permission - posted by DavidLiu <da...@126.com> on 2022/05/22 10:58:02 UTC, 2 replies.
- [jira] [Created] (FLINK-27732) [JUnit5 Migration] Module: flink-examples-table - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/05/22 12:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27733) Rework on_timer output behind watermark bug fix - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2022/05/22 15:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27734) Not showing checkpoint interval properly in WebUI when checkpoint is disabled - posted by "Feifan Wang (Jira)" <ji...@apache.org> on 2022/05/22 15:45:00 UTC, 0 replies.
- Application mode -yarn dependancy error - posted by Zain Haider Nemati <za...@retailo.co> on 2022/05/22 15:58:56 UTC, 1 replies.
- Flink UI in Application Mode - posted by Zain Haider Nemati <za...@retailo.co> on 2022/05/22 17:43:17 UTC, 1 replies.
- [jira] [Created] (FLINK-27735) Update testcontainers dependency to v1.17.2 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/05/23 01:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27736) Pulsar sink catch watermark error - posted by "LuNng Wang (Jira)" <ji...@apache.org> on 2022/05/23 03:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27737) Clean the outdated comments and unfencedMainExecutor - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/05/23 05:05:00 UTC, 0 replies.
- [DISCUSS] Initializing Apache Flink Slack - posted by Xintong Song <to...@gmail.com> on 2022/05/23 05:13:58 UTC, 12 replies.
- [jira] [Created] (FLINK-27738) instance KafkaSink support config topic properties - posted by "LCER (Jira)" <ji...@apache.org> on 2022/05/23 06:24:00 UTC, 0 replies.
- About Native Deployment's Autoscaling implementation - posted by Talat Uyarer <tu...@paloaltonetworks.com> on 2022/05/23 06:32:32 UTC, 9 replies.
- [jira] [Created] (FLINK-27739) Add benchmark module for table store - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/05/23 07:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27740) [JUnit5 Migration] Module: flink-test-utils-junit - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/05/23 07:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27741) Fix NPE when use dense_rank() and rank() in over aggregation - posted by "chenzihao (Jira)" <ji...@apache.org> on 2022/05/23 08:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27742) Fix Compatibility Issues Between Flink ML Operators. - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2022/05/23 09:07:00 UTC, 0 replies.
- TolerableCheckpointFailureNumber not always applying - posted by Gaël Renoux <ga...@datadome.co.INVALID> on 2022/05/23 09:18:09 UTC, 0 replies.
- [jira] [Created] (FLINK-27743) Support function params when create UDTF in flink sql - posted by "konwu (Jira)" <ji...@apache.org> on 2022/05/23 10:10:00 UTC, 0 replies.
- StreamGraph vs JobGraph vs ExecutionGraph - posted by Prabhu Joseph <pr...@gmail.com> on 2022/05/23 10:36:14 UTC, 4 replies.
- [jira] [Created] (FLINK-27744) CheckPubSubEmulatorTest.testPull failed with AssertionError - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/05/23 11:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27745) ClientUtilsTest.uploadAndSetUserArtifacts failed with NoClassDefFoundError - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/05/23 12:34:00 UTC, 0 replies.
- [VOTE] Apache Flink Kubernetes Operator Release 1.0.0, release candidate #1 - posted by Yang Wang <da...@gmail.com> on 2022/05/23 12:57:31 UTC, 5 replies.
- Access to confluence - posted by Александр Смирнов <sm...@gmail.com> on 2022/05/23 14:38:10 UTC, 1 replies.
- [GitHub] [flink-connector-rabbitmq] pscls opened a new pull request, #1: [FLINK-20628] RabbitMQ Connector using FLIP-27 Source API - posted by GitBox <gi...@apache.org> on 2022/05/23 18:36:35 UTC, 0 replies.
- [GitHub] [flink-connector-rabbitmq] pscls commented on pull request #1: [FLINK-20628] RabbitMQ Connector using FLIP-27 Source API - posted by GitBox <gi...@apache.org> on 2022/05/23 18:37:30 UTC, 1 replies.
- 1.13.5版本sql大小64k限制bug - posted by "Lose control ./" <28...@qq.com.INVALID> on 2022/05/24 01:15:23 UTC, 0 replies.
- [jira] [Created] (FLINK-27746) Flink kubernetes operator docker image could not build with source release - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/05/24 01:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27747) Flink kubernetes operator helm chart release the Chart.yaml file doesn't have an apache license header - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/05/24 01:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27748) AdaptiveScheduler should support operator fixed parallelism - posted by "john (Jira)" <ji...@apache.org> on 2022/05/24 01:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27749) Job submit failed when JM enabled HA with flink 1.15.0 - posted by "JasonLee (Jira)" <ji...@apache.org> on 2022/05/24 04:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27750) The configuration of - posted by "dong (Jira)" <ji...@apache.org> on 2022/05/24 04:52:00 UTC, 0 replies.
- All flink-ci fail - posted by rui fan <19...@gmail.com> on 2022/05/24 06:12:26 UTC, 2 replies.
- [DISCUSS] Releasing Flink 1.14.5 - posted by Xingbo Huang <hx...@gmail.com> on 2022/05/24 06:22:28 UTC, 3 replies.
- [jira] [Created] (FLINK-27751) Scala suffix check failed - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/05/24 06:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27752) Change 'path' to 'root-path' in table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/05/24 07:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27753) Scala suffix checks should check for maven errors - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/05/24 08:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27754) Getting Flink config fails if multiple files in /lib match flink-dist-* - posted by "Rudi Kershaw (Jira)" <ji...@apache.org> on 2022/05/24 08:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27755) Introduce a filesystem catalog for table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/05/24 09:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27756) Fix Intermittingly failing test in `AsyncSinkWriterTest` - posted by "Ahmed Hamdy (Jira)" <ji...@apache.org> on 2022/05/24 11:09:00 UTC, 0 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/05/24 12:38:02 UTC, 0 replies.
- Re: [DISCUSS] Docker images for SNAPSHOT - posted by Alexander Fedulov <al...@ververica.com> on 2022/05/24 14:53:42 UTC, 0 replies.
- [jira] [Created] (FLINK-27757) Elasticsearch connector should not use flink-table-planner but flink-table-planner-loader - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/05/24 18:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27758) [JUnit5 Migration] Module: flink-table-runtime - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/05/24 20:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27759) Rethink how to get the git commit id for docker image in Flink Kubernetes operator - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/05/25 02:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27760) NPE is thrown when executing PyFlink jobs in batch mode - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2022/05/25 03:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27761) Add database and table field in canal-json sink - posted by "Zhiwen Sun (Jira)" <ji...@apache.org> on 2022/05/25 03:54:00 UTC, 0 replies.
- Issue in seeing job manager and task manager logs in history sever - posted by Sriram Ganesh <sr...@gmail.com> on 2022/05/25 05:29:33 UTC, 2 replies.
- [jira] [Created] (FLINK-27762) Kafka WakeUpException during handling splits changes - posted by "zoucan (Jira)" <ji...@apache.org> on 2022/05/25 06:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27763) Remove netty bundling&relocation in flink-streaming-kinesis-tests - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/05/25 06:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27764) SetOperatorsITCase tests failed - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/05/25 06:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27765) TaskManagerProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure failed with FlinkJobNotFoundException - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/05/25 07:10: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/05/25 07:12:14 UTC, 0 replies.
- [RESULT][VOTE] FLIP-91: Support SQL Gateway - posted by Shengkai Fang <fs...@gmail.com> on 2022/05/25 07:19:47 UTC, 0 replies.
- [jira] [Created] (FLINK-27767) Introduce Endpoint API and utils - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/05/25 07:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27766) Introduce the framework of the GatewayService - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/05/25 07:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27770) Introduce the script to start/stop/stop-all gateway - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/05/25 07:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27768) Allow to execute sql for the SqlGatewayService - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/05/25 07:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27769) Introduce the REST endpoint framework - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/05/25 07:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27772) Expose Operation-level logs in the SqlGatewayService - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/05/25 07:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27771) Introduce the listAPIs in the SqlGatewayService - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/05/25 07:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27773) Introduce the E2E tests for SQL Gateway - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/05/25 07:30:00 UTC, 0 replies.
- Fwd: Flink Kinesis Connector GetRecords Frequency - posted by Aqib Mehmood <aq...@retailo.co> on 2022/05/25 09:36:54 UTC, 2 replies.
- [jira] [Created] (FLINK-27774) Window Agg doesn't work when used in Batch Table API - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/05/25 09:45:00 UTC, 0 replies.
- [DISCUSS] Publish flink-end-to-end-tests-common to Maven - posted by Alexander Fedulov <al...@ververica.com> on 2022/05/25 09:55:51 UTC, 6 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/05/25 11:52:30 UTC, 0 replies.
- [jira] [Created] (FLINK-27775) FlinkKafkaProducer VS KafkaSink - posted by "Jiangfei Liu (Jira)" <ji...@apache.org> on 2022/05/25 11:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27776) Throws exception when udaf used in sliding window does not implement merge method in PyFlink - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/05/25 12:10:00 UTC, 0 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/05/25 12:13:01 UTC, 0 replies.
- [jira] [Created] (FLINK-27777) Can not get the parquet.compression when using native parquet&orc writer to sink hive - posted by "Small Wong (Jira)" <ji...@apache.org> on 2022/05/25 12:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27778) table-planner should explicitly depend on table-code-splitter - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/05/25 13:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27779) Connectors should not depend on `flink-table-planner` - posted by "Alexander Preuss (Jira)" <ji...@apache.org> on 2022/05/25 14:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27781) Connector-kafka should not depend on `flink-table-planner` - posted by "Alexander Preuss (Jira)" <ji...@apache.org> on 2022/05/25 14:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27780) Connector-cassandra should not depend on `flink-table-planner` - posted by "Alexander Preuss (Jira)" <ji...@apache.org> on 2022/05/25 14:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27782) Connector-kinesis should not depend on `flink-table-planner` - posted by "Alexander Preuss (Jira)" <ji...@apache.org> on 2022/05/25 14:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27783) Connector-aws-kinesis should not depend on `flink-table-planner` - posted by "Alexander Preuss (Jira)" <ji...@apache.org> on 2022/05/25 14:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27784) Connector-jdbc should not depend on `flink-table-planner` - posted by "Alexander Preuss (Jira)" <ji...@apache.org> on 2022/05/25 15:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27786) Connector-hive should not depend on `flink-table-planner` - posted by "Alexander Preuss (Jira)" <ji...@apache.org> on 2022/05/25 15:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27785) Connector-hbase should not depend on `flink-table-planner` - posted by "Alexander Preuss (Jira)" <ji...@apache.org> on 2022/05/25 15:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27787) New tasks think they've been restored from savepoint (even when they weren't present in that savepoint) - posted by "Stephen Patel (Jira)" <ji...@apache.org> on 2022/05/25 23:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27788) Adding annotation to k8 operator Pod - posted by "Jaganathan Asokan (Jira)" <ji...@apache.org> on 2022/05/25 23:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27789) LegacySource compatible with overdraft buffer - posted by "fanrui (Jira)" <ji...@apache.org> on 2022/05/26 01:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27790) Move ADD/Remove Jar syntax code implementation from SqlClient to TableEnvironment side - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/05/26 01:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27791) SlotCountExceedingParallelismTest tests failed with NoResourceAvailableException - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/05/26 02:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27792) WindowDistinctAggregateITCase. testTumbleWindow_Rollup failed with InterruptedException - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/05/26 02:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27793) After upgrading to flink-1.15.0, flink jobmanager cannot shutdown - posted by "jinshuangxian (Jira)" <ji...@apache.org> on 2022/05/26 03:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27794) The primary key obtained from MySQL is incorrect by using MysqlCatalog - posted by "dusukang (Jira)" <ji...@apache.org> on 2022/05/26 03:37:00 UTC, 0 replies.
- [VOTE] FLIP-227: Support overdraft buffer - posted by rui fan <19...@gmail.com> on 2022/05/26 04:00:38 UTC, 5 replies.
- [jira] [Created] (FLINK-27795) SqlValidatorException when insert null value - posted by "linqichen (Jira)" <ji...@apache.org> on 2022/05/26 04:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27796) Document approaches to updating existing instances of stateful functions - posted by "Zixuan Rao (Jira)" <ji...@apache.org> on 2022/05/26 05:04:00 UTC, 0 replies.
- Performance benchmarking for flink. - posted by Sriram Ganesh <sr...@gmail.com> on 2022/05/26 06:04:20 UTC, 2 replies.
- flinksql关联hive维表java.lang.UnsupportedOperationException错误 - posted by "hdxg1101300123@163.com" <hd...@163.com> on 2022/05/26 06:16:33 UTC, 3 replies.
- [jira] [Created] (FLINK-27797) PythonTableUtils.getCollectionInputFormat cannot correctly handle None values - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2022/05/26 07:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27798) Migrate Flink ML to Flink 1.15.0 - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2022/05/26 07:41:00 UTC, 0 replies.
- [VOTE] FLIP-235: Hybrid Shuffle Mode - posted by weijie guo <gu...@gmail.com> on 2022/05/26 07:46:33 UTC, 5 replies.
- [VOTE] Apache Flink Kubernetes Operator Release 1.0.0, release candidate #2 - posted by Yang Wang <da...@gmail.com> on 2022/05/26 07:47:23 UTC, 5 replies.
- [VOTE] FLIP-168: Speculative Execution for Batch Job - posted by Zhu Zhu <zh...@apache.org> on 2022/05/26 07:55:48 UTC, 3 replies.
- [jira] [Created] (FLINK-27799) Version 1.13.5 is not compatible with version 1.10 UDF - posted by "Yichao Yang (Jira)" <ji...@apache.org> on 2022/05/26 09:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27800) addInEdge check state error - posted by "Licho sun (Jira)" <ji...@apache.org> on 2022/05/26 10:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27801) Disable flushing stream when call Jackson's writeValue() method for CsvBulkWriter - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/05/26 12:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27802) Job submission errors are swallowed for Flink 1.15 + HA - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/05/26 12:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27803) Unable to write to s3 with Hudi format via Flink - Scala - posted by "sathyan sethumadhavan (Jira)" <ji...@apache.org> on 2022/05/26 14:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27804) Do not observe cluster/job mid upgrade - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/05/26 15:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27805) Bump ORC version to 1.7.2 - posted by "jia liu (Jira)" <ji...@apache.org> on 2022/05/27 02:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27806) Datagen add binary & varbinary type support - posted by "Ran Tao (Jira)" <ji...@apache.org> on 2022/05/27 02:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27807) The improvement of addBatch is empty when jdbc batch submit - posted by "shmily (Jira)" <ji...@apache.org> on 2022/05/27 03:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27808) Allow "kubernetes" as setting for HA_MODE - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/05/27 07:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27809) Clarify that cluster-id is mandatory for Kubernetes HA in standalone mode - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/05/27 08:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27810) Elasticsearch e2e jars bundle way more than they should - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/05/27 08:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27811) Remove netty dependency in flink-test-utils - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/05/27 09:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27812) Support Dynamic change of watched namespaces - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/05/27 09:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27813) java.lang.IllegalStateException: afte migration from statefun 3.1.1 to 3.2.0 - posted by "Oleksandr (Jira)" <ji...@apache.org> on 2022/05/27 09:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27814) Add an abstraction layer for connectors to read and write row data instead of key-values - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/05/27 09:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27815) Improve the join reorder strategy for batch sql job - posted by "godfrey he (Jira)" <ji...@apache.org> on 2022/05/27 09:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27816) file source reader has Some requirements - posted by "jinshuangxian (Jira)" <ji...@apache.org> on 2022/05/27 10:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27817) TaskManager metaspace OOM for session cluster - posted by "godfrey he (Jira)" <ji...@apache.org> on 2022/05/27 10:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27818) Model enums as references in OpenAPI spec - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/05/27 12:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27819) Generate better operationIds for OpenAPI spec - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/05/27 12:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27820) Handle Upgrade/Deployment errors gracefully - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/05/27 13:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27821) Cannot delete flinkdeployment when the pod and deployment deleted manually - posted by "Hector Miuler Malpica Gallegos (Jira)" <ji...@apache.org> on 2022/05/27 13:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27822) Translate the doc of checkpoint/savepoint guarantees - posted by "fanrui (Jira)" <ji...@apache.org> on 2022/05/28 02:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27823) Standalone Job continously restart by illegal checkpointId check on PartitionTimeCommitTrigger when use FilesystemTableSink - posted by "suheng.cloud (Jira)" <ji...@apache.org> on 2022/05/28 07:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27824) Implement Pyflink KeyedSchema - posted by "Zixuan Rao (Jira)" <ji...@apache.org> on 2022/05/28 08:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27825) Update the doc of aligned checkpoint timeout - posted by "fanrui (Jira)" <ji...@apache.org> on 2022/05/28 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27826) Support machine learning training for high dimesional models - posted by "Zhipeng Zhang (Jira)" <ji...@apache.org> on 2022/05/28 12:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27827) StreamExecutionEnvironment method supporting explicit Boundedness - posted by "Andreas Hailu (Jira)" <ji...@apache.org> on 2022/05/28 15:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27828) FlinkKafkaProducer VS KafkaSink - posted by "Jiangfei Liu (Jira)" <ji...@apache.org> on 2022/05/29 01:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27829) Remove Calcite usages in flink-python - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/05/29 06:54:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-227: Support overdraft buffer - posted by rui fan <19...@gmail.com> on 2022/05/29 07:37:03 UTC, 0 replies.
- [jira] [Created] (FLINK-27830) My Pyflink job could not submit to Flink cluster - posted by "TongMeng (Jira)" <ji...@apache.org> on 2022/05/29 16:41:00 UTC, 0 replies.
- Table API thrift support - posted by Chen Qin <qi...@gmail.com> on 2022/05/29 17:04:29 UTC, 3 replies.
- [jira] [Created] (FLINK-27831) Provide example of Beam on the k8s operator - posted by "Márton Balassi (Jira)" <ji...@apache.org> on 2022/05/30 01:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27832) SplitAggregateITCase tests failed with Could not acquire the minimum required resources - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/05/30 02:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27833) PulsarSourceITCase.testTaskManagerFailure failed with AssertionError - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/05/30 02:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27834) Flink kubernetes operator dockerfile could not work with podman - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/05/30 02:39:00 UTC, 0 replies.
- [VOTE] FLIP-232: Add Retry Support For Async I/O In DataStream API - posted by Lincoln Lee <li...@gmail.com> on 2022/05/30 07:39:47 UTC, 4 replies.
- [jira] [Created] (FLINK-27835) Introduce LeafPredicate interface and children method in Predicate - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/05/30 07:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27836) RocksDBMapState iteration may stop too early for var-length prefixes - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2022/05/30 09:00:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-213: TaskManager's Flame Graphs - posted by Alexander Fedulov <al...@ververica.com> on 2022/05/30 09:17:37 UTC, 0 replies.
- [jira] [Created] (FLINK-27837) Support statement set in the SQL Gateway - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/05/30 12:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27838) Support timeout mechansim for executeStatement API - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/05/30 12:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27840) org.apache.flink.kafka.shaded.org.apache.kafka.common.errors.DisconnectException - posted by "lijixiang (Jira)" <ji...@apache.org> on 2022/05/30 15:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27839) org.apache.flink.kafka.shaded.org.apache.kafka.common.errors.InterruptException - posted by "lijixiang (Jira)" <ji...@apache.org> on 2022/05/30 15:10:00 UTC, 0 replies.
- [DISCUSS] FLIP-236: Asynchronous Job Submission - posted by "Afonso, Nuno" <af...@amazon.com.INVALID> on 2022/05/30 16:11:24 UTC, 0 replies.
- [jira] [Created] (FLINK-27841) RocksDB cache miss increase in 1.15 - posted by "Feifan Wang (Jira)" <ji...@apache.org> on 2022/05/30 16:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27842) Rename ndv to granularityNumber - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/05/30 18:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27843) Schema evolution for data file meta - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/05/31 02:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27844) Schema evolution for ManifestFileMeta - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/05/31 02:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27845) Introduce Column Type Schema evolution - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/05/31 02:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27846) Schema evolution for data file reading - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/05/31 02:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27847) SchemaManager supports schema evolution - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/05/31 02:14:00 UTC, 0 replies.
- [VOTE] Apache Flink Kubernetes Operator Release 1.0.0, release candidate #3 - posted by Yang Wang <da...@gmail.com> on 2022/05/31 06:26:02 UTC, 3 replies.
- [jira] [Created] (FLINK-27848) ZooKeeperLeaderElectionDriver keeps writing leader information, using up zxid - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2022/05/31 06:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27849) Harden correctness for non-deterministic updates present in the changelog pipeline - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2022/05/31 06:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27850) Hive dialect supports "add file xxx" - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/05/31 07:20:00 UTC, 0 replies.
- [DISCUSS] Bi-Weekly Flink Community Sync Meeting - posted by Robert Metzger <rm...@apache.org> on 2022/05/31 07:37:50 UTC, 4 replies.
- [jira] [Created] (FLINK-27851) Join can't access the pk from source table - posted by "xuyang (Jira)" <ji...@apache.org> on 2022/05/31 08:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27852) Contribute k8s operator to OperatorHub - posted by "Márton Balassi (Jira)" <ji...@apache.org> on 2022/05/31 13:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27853) FLIP-229: Introduces Join Hint for Flink SQL Batch Job - posted by "xuyang (Jira)" <ji...@apache.org> on 2022/05/31 15:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27854) Refactor FlinkImageBuilder and FlinkContainerBuilder - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2022/05/31 15:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27855) Job Manager fails to recover with S3 storage and HA enabled - posted by "Sushant (Jira)" <ji...@apache.org> on 2022/05/31 16:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27856) Adding pod template without spec crashes job manager - posted by "Jeesmon Jacob (Jira)" <ji...@apache.org> on 2022/05/31 18:40:00 UTC, 0 replies.