You are viewing a plain text version of this content. The canonical link for it is here.
- Re: [DISCUSS] Deprecate Java 8 support - posted by "wenlong.lwl" <we...@gmail.com> on 2021/12/01 01:31:00 UTC, 4 replies.
- Re: [ANNOUNCE] Open source of remote shuffle project for Flink batch data processing - posted by Jing Zhang <be...@gmail.com> on 2021/12/01 02:34:40 UTC, 7 replies.
- [jira] [Created] (FLINK-25116) Fabric8FlinkKubeClientITCase hangs on Azure - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/12/01 02:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25117) NoSuchMethodError getCatalog() - posted by "zzt (Jira)" <ji...@apache.org> on 2021/12/01 03:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25118) Add vertex index as prefix in vertex name - posted by "Wenlong Lyu (Jira)" <ji...@apache.org> on 2021/12/01 03:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25119) The name of freeSlots parameter in SlotSharingSlotAllocator#determineParallelism method is named incorrectly. - posted by "Cassie (Jira)" <ji...@apache.org> on 2021/12/01 03:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25120) Add many kinds of checks in ML Python API - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/12/01 03:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25121) Support ML Python API - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/12/01 03:26:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-194: Introduce the JobResultStore - posted by Xintong Song <to...@gmail.com> on 2021/12/01 04:56:27 UTC, 4 replies.
- [jira] [Created] (FLINK-25122) flink-dist/src/main/flink-bin/bin/flink does not expand variable for FLINK_ENV_JAVA_OPTS - posted by "L Z (Jira)" <ji...@apache.org> on 2021/12/01 05:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25123) Improve expression description in SQL operator - posted by "Wenlong Lyu (Jira)" <ji...@apache.org> on 2021/12/01 06:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25124) A deadlock occurs when the jdbc sink uses two consecutive dimension tables to associate - posted by "shizhengchao (Jira)" <ji...@apache.org> on 2021/12/01 07:05:00 UTC, 0 replies.
- Re: FLink Accessing two hdfs cluster - posted by David Morávek <dm...@apache.org> on 2021/12/01 07:25:53 UTC, 0 replies.
- [jira] [Created] (FLINK-25125) Verify that downloaded artifact is not corrupt - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/12/01 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25126) when SET 'execution.runtime-mode' = 'batch' and 'sink.delivery-guarantee' = 'exactly-once',kafka conncetor will commit fail - posted by "eric yu (Jira)" <ji...@apache.org> on 2021/12/01 08:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25127) Reuse a single Collection in GlobalWindows#assignWindows - posted by "bx123 (Jira)" <ji...@apache.org> on 2021/12/01 08:51:00 UTC, 0 replies.
- Flink 1.15. Bi-weekly 2021-11-30 - posted by Johannes Moser <jo...@ververica.com> on 2021/12/01 09:12:18 UTC, 0 replies.
- [jira] [Created] (FLINK-25128) Introduce flink-table-planner-loader - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/12/01 09:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25129) Update docs and examples to use flink-table-planner-loader instead of flink-table-planner - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/12/01 09:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25130) Update flink-table-uber to ship flink-table-planner-loader instead of flink-table-planner - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/12/01 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25131) Update sql client to ship flink-table-planner-loader instead of flink-table-planner - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/12/01 09:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25132) KafkaSource cannot work with object-reusing DeserializationSchema - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2021/12/01 09:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25133) Introduce a Version class that keeps track of all the released versions - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/12/01 10:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25134) Unused RetryRule in KafkaConsumerTestBase swallows retries - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/12/01 11:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25135) HBase downloads in e2e tests fail often - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/12/01 12:14:00 UTC, 0 replies.
- [VOTE] FLIP-193: Snapshots ownership - posted by Dawid Wysakowicz <dw...@apache.org> on 2021/12/01 12:22:54 UTC, 7 replies.
- [jira] [Created] (FLINK-25136) the parallelism not appear right when rescale by use scheduler in reactive mode - posted by "KevinyhZou (Jira)" <ji...@apache.org> on 2021/12/01 13:03:00 UTC, 0 replies.
- Re: [DISCUSS] Definition of Done for Apache Flink - posted by Johannes Moser <jo...@ververica.com> on 2021/12/01 13:50:00 UTC, 0 replies.
- Be able to use a custom KafkaSubscriber to have dynamic custom topic selection - posted by CARRIERE Etienne <et...@socgen.com.INVALID> on 2021/12/01 14:02:39 UTC, 3 replies.
- Re: [DISCUSS] FLIP-190: Support Version Upgrades for Table API & SQL Programs - posted by Timo Walther <tw...@apache.org> on 2021/12/01 15:29:43 UTC, 23 replies.
- Re: [DISCUSS] Shall casting functions return null or throw exceptions for invalid input - posted by Marios Trivyzas <ma...@gmail.com> on 2021/12/01 16:13:06 UTC, 2 replies.
- [jira] [Created] (FLINK-25137) Cannot do window aggregation after a regular join: Window can only be defined on a time attribute column - posted by "Hongbo (Jira)" <ji...@apache.org> on 2021/12/01 17:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25138) SQL Client improve completion for commands - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2021/12/01 18:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25139) Shaded Hadoop S3A with credentials provider failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/12/02 03:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25140) Streaming File Sink s3 end-to-end test failed due to job has not started within a timeout of 10 sec - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/12/02 03:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25141) Elasticsearch connector customize sink parallelism - posted by "Ada Wong (Jira)" <ji...@apache.org> on 2021/12/02 03:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25142) The user-defined hive udtf initialize exception in hive dialect - posted by "xiangqiao (Jira)" <ji...@apache.org> on 2021/12/02 08:14:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-191: Extend unified Sink interface to support small file compaction - posted by Roman Khachatryan <ro...@apache.org> on 2021/12/02 09:15:09 UTC, 10 replies.
- Re: [DISCUSS] Releasing Flink 1.14.1 - posted by Qingsheng Ren <re...@gmail.com> on 2021/12/02 09:44:01 UTC, 11 replies.
- [jira] [Created] (FLINK-25143) Add ITCase for periodic materialization - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/12/02 11:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25144) Manual test - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/12/02 11:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25145) Add support for Zookeeper 3.6 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/12/02 13:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25146) Drop support for Zookeeper 3.4 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/12/02 13:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25147) Migrate cassandra tests to test containers - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2021/12/02 13:08:00 UTC, 0 replies.
- [DISCUSS] FLIP-196: Source API stability guarantees - posted by Till Rohrmann <tr...@apache.org> on 2021/12/02 14:48:13 UTC, 14 replies.
- [DISCUSS] FLIP-197: API stability graduation process - posted by Till Rohrmann <tr...@apache.org> on 2021/12/02 14:57:28 UTC, 10 replies.
- [ANNOUNCE] New Apache Flink Committer - Ingo Bürk - posted by Till Rohrmann <tr...@apache.org> on 2021/12/02 15:24:03 UTC, 31 replies.
- [ANNOUNCE] New Apache Flink Committer - Matthias Pohl - posted by Till Rohrmann <tr...@apache.org> on 2021/12/02 15:27:55 UTC, 29 replies.
- [jira] [Created] (FLINK-25148) PipelinedSubpartition.resumeConsumption throws IllegalStateException - posted by "Dong Lin (Jira)" <ji...@apache.org> on 2021/12/03 02:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25149) getScanRuntimeProvider method called before the pushDown method, - posted by "waittting (Jira)" <ji...@apache.org> on 2021/12/03 03:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25150) org.apache.flink.connector.file.src.reader.TextLineInputFormat.createReader failed due to violate ApiAnnotationRules - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/12/03 07:23:00 UTC, 0 replies.
- Re: [VOTE] FLIP-188 Introduce Built-in Dynamic Table Storage - posted by Jingsong Li <ji...@gmail.com> on 2021/12/03 07:37:42 UTC, 0 replies.
- [jira] [Created] (FLINK-25151) FLIP-188: Introduce Built-in Dynamic Table Storage - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/12/03 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25152) [DISCUSS] FLIP-188: Introduce Built-in Dynamic Table Storage - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/12/03 07:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25153) Inappropriate variable naming - posted by "Junfan Zhang (Jira)" <ji...@apache.org> on 2021/12/03 08:09:00 UTC, 0 replies.
- [DISCUSS] Change some default config values of blocking shuffle - posted by Yingjie Cao <ke...@gmail.com> on 2021/12/03 09:02:05 UTC, 12 replies.
- Re: [DISCUSS] Conventions on assertions to use in tests - posted by Matthias Pohl <ma...@ververica.com> on 2021/12/03 10:37:25 UTC, 3 replies.
- [jira] [Created] (FLINK-25154) FLIP-193: Snapshots ownership - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/12/03 11:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25155) Implement claim snapshot mode - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/12/03 11:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25157) Introduce NULL type to string cast rule - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/12/03 14:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25156) DISTINCT is not handled correctly by CastRules - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/12/03 14:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25158) Fix formatting for true, false and null to uppercase - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/12/03 14:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25159) Streaming E2E surefire configuration setup - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/12/03 14:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25160) Make doc clear: tolerable-failed-checkpoints counts consecutive failures - posted by "Jun Qin (Jira)" <ji...@apache.org> on 2021/12/03 14:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25161) Update dependency for japicmp-maven-plugin - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2021/12/03 15:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25162) Flink : Connectors : Hive fails with VectorizedRowBatch not found - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2021/12/03 18:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25163) Add more options for rocksdb state backend to make configuration more flexible - posted by "刘方奇 (Jira)" <ji...@apache.org> on 2021/12/04 01:00:34 UTC, 0 replies.
- [jira] [Created] (FLINK-25164) DogStatsD Metrics Reporter - posted by "Yaroslav Tkachenko (Jira)" <ji...@apache.org> on 2021/12/04 05:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25165) CassandraConnectorITCase.testCassandraPojoAtLeastOnceSink failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/12/04 08:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25166) UpsertKafkaDynamicTableFactoryTest failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/12/04 08:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25167) Support user-defined `StreamOperatorFactory` in `ConnectedStreams`#transform - posted by "Lsw_aka_laplace (Jira)" <ji...@apache.org> on 2021/12/05 04:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25168) Azure failed due to unable to transfer maven artifacts - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/12/05 13:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25169) CsvFileSystemFormatFactory#CsvInputFormat supports recursion - posted by "Bo Cui (Jira)" <ji...@apache.org> on 2021/12/06 03:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25170) cep supports dynamic rule updates - posted by "ZhuoYu Chen (Jira)" <ji...@apache.org> on 2021/12/06 03:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25171) When the DDL statement was executed, the column names of the Derived Columns were not validated - posted by "shouzuo meng (Jira)" <ji...@apache.org> on 2021/12/06 03:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25172) Fix Document display bug - posted by "quyanghaoren (Jira)" <ji...@apache.org> on 2021/12/06 06:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25173) Introduce CatalogLock - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/12/06 07:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25174) Introduce ManagedTableFactory - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/12/06 07:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25175) Introduce TableDescriptor.forManaged - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/12/06 07:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25176) Introduce "ALTER TABLE ... COMPACT" SQL - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/12/06 07:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25177) Support "DESCRIBE TABLE EXTENDED" with managed table - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/12/06 07:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25178) Throw exception when managed table sink needs checkpoint - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/12/06 07:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25179) Add document for array,map,row types support for parquet row writer - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/12/06 07:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25180) Jepsen test fails while setting up libzip4 - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/12/06 07:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25181) KafkaSourceITCase.testValueOnlyDeserializer fails on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/12/06 08:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25182) NoClassDefFoundError of PulsarAdminImpl by using flink-connector-pulsar:1.14 on k8s flink cluster - posted by "HeYe (Jira)" <ji...@apache.org> on 2021/12/06 08:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25183) Optimize changelog normalize for the managed table upsert mode - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/12/06 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25184) Introduce setDeliveryCallback to KafkaWriter - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/12/06 08:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25185) StreamFaultToleranceTestBase hangs on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/12/06 08:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25186) KafkaDynamicTableFactoryTest and UpsertKafkaDynamicTableFactoryTest fails on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/12/06 08:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25187) Apply padding for BINARY() - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/12/06 08:53:00 UTC, 0 replies.
- [VOTE] FLIP-194: Introduce the JobResultStore - posted by David Morávek <dm...@apache.org> on 2021/12/06 08:59:44 UTC, 6 replies.
- [jira] [Created] (FLINK-25188) Cannot install PyFlink in M1 CPU - posted by "Ada Wong (Jira)" <ji...@apache.org> on 2021/12/06 09:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25189) Update Elasticsearch Sinks to latest minor versions - posted by "Alexander Preuss (Jira)" <ji...@apache.org> on 2021/12/06 09:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25190) The number of TaskManagers whose status is Pending should be reported - posted by "john (Jira)" <ji...@apache.org> on 2021/12/06 11:17:00 UTC, 0 replies.
- [DISCUSS] Strong read-after-write consistency of Flink FileSystems - posted by David Morávek <dm...@apache.org> on 2021/12/06 11:27:53 UTC, 3 replies.
- [jira] [Created] (FLINK-25191) Skip savepoints for recovery - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/12/06 12:18:00 UTC, 0 replies.
- Re: [DISCUSS] Drop Zookeeper 3.4 - posted by Chesnay Schepler <ch...@apache.org> on 2021/12/06 13:00:35 UTC, 6 replies.
- [jira] [Created] (FLINK-25192) Implement proper no-claim mode support - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/12/06 13:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25193) Document claim & no-claim mode - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/12/06 13:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25194) Implement an API for duplicating artefacts - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/12/06 13:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25195) Use duplicating API for shared artefacts in RocksDB snapshots - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/12/06 13:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25196) Add Documentation for Data Sink - posted by "ZhuoYu Chen (Jira)" <ji...@apache.org> on 2021/12/06 14:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25197) Using Statefun RequestReplyFunctionBuilder fails with Java 8 date/time type `java.time.Duration` not supported by default: add Module "org.apache.flink.shaded.jackson2.com.fasterxml.jackson.datatype:jackson-datatype-jsr310" to enable handling - posted by "Galen Warren (Jira)" <ji...@apache.org> on 2021/12/06 14:52:00 UTC, 3 replies.
- [VOTE] Deprecate Java 8 support - posted by Chesnay Schepler <ch...@apache.org> on 2021/12/06 15:44:46 UTC, 11 replies.
- [jira] [Created] (FLINK-25198) add document about how to debug with the name and description - posted by "Wenlong Lyu (Jira)" <ji...@apache.org> on 2021/12/06 16:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25199) fromValues does not emit final MAX watermark - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/12/06 17:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25201) Implement duplicating for gcs - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/12/06 18:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25200) Implement duplicating for s3 filesystem - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/12/06 18:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25202) Implement duplicating for azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/12/06 18:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25203) Implement duplicating for aliyun - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/12/06 18:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25204) Spell one more as in the DataStream interval join docs - posted by "tartarus (Jira)" <ji...@apache.org> on 2021/12/07 07:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25205) Optimize SinkUpsertMaterializer - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/12/07 07:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25206) Add config option to disable configurations in the user program - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/12/07 08:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25207) sample pyflink from documentation doesn't work in jupyter notebooks - posted by "Stephan Pirson (Jira)" <ji...@apache.org> on 2021/12/07 09:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25208) AsyncSink\Source lock of documentation or Blog - posted by "ZhuoYu Chen (Jira)" <ji...@apache.org> on 2021/12/07 09:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25209) SQLClientSchemaRegistryITCase#testReading is broken - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/12/07 10:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25210) PulsarSource(Un)OrderedE2ECase is brokern - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/12/07 10:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25211) Elasticsearch connector version compatibility - posted by "Adam Roberts (Jira)" <ji...@apache.org> on 2021/12/07 10:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25212) Support "yarn-ships" directory in client classpath - posted by "jocean.shi (Jira)" <ji...@apache.org> on 2021/12/07 11:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25213) Add @Public annotations to flink-table-common - posted by "ZhuoYu Chen (Jira)" <ji...@apache.org> on 2021/12/07 11:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25214) FlinkKafkaProducerITCase.testMigrateFromAtLeastOnceToExactlyOnce fails on AZP with incorrect result - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/12/07 11:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25215) ISODOW for timestamps with timezones fails with Invalid start unit - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2021/12/07 12:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25216) test_sliding_group_window_over_proctime failed with "IndexError: list index out of range" - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/12/07 12:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25217) FLIP-190: Support Version Upgrades for Table API & SQL Programs - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/12/07 15:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25218) Performance issues with lookup join accessing external dimension tables - posted by "ZhuoYu Chen (Jira)" <ji...@apache.org> on 2021/12/08 03:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25219) load configuration from flink-conf.yaml, some of my parameters were modified - posted by "jackie (Jira)" <ji...@apache.org> on 2021/12/08 10:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25220) Writing an architectural rule for all IT cases w.r.t. MiniCluster - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2021/12/08 10:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25221) Allow global table options for all table connectors - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/12/08 13:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25222) Remove NetworkFailureProxy used for Kafka connector tests - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/12/08 13:52:00 UTC, 0 replies.
- FileSink in Apache Flink not generating logs in output folder - posted by "Dhingra, Kajal" <Ka...@ncr.com.INVALID> on 2021/12/08 14:53:32 UTC, 0 replies.
- [jira] [Created] (FLINK-25223) ElasticsearchWriterITCase fails on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/12/08 15:59:00 UTC, 0 replies.
- [DISCUSS] Deprecate MapR FS - posted by Martijn Visser <ma...@ververica.com> on 2021/12/08 16:03:35 UTC, 3 replies.
- [DISCUSS][FLINK-24427] Hide Scala from table planner - posted by Francesco Guardiani <fr...@ververica.com> on 2021/12/08 17:02:30 UTC, 2 replies.
- [jira] [Created] (FLINK-25224) Bump the hadoop version up - posted by "刘方奇 (Jira)" <ji...@apache.org> on 2021/12/09 00:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25225) Add e2e TPCDS tests to run against the AdatpiveBatchScheduler - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2021/12/09 03:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25226) Add documentation about the AdaptiveBatchScheduler - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2021/12/09 03:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25227) Comparing the equality of the same (boxed) numeric values returns false - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/12/09 06:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25228) Introduce flink-table-test-utils - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/12/09 08:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25229) Introduce flink-table-api-bridge-common - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/12/09 08:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25230) Harden type serialization in JSON plan - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/12/09 08:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25231) Update PyFlink to use the new type system - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/12/09 09:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25232) flink sql supports fine-grained state configuration - posted by "ZhuoYu Chen (Jira)" <ji...@apache.org> on 2021/12/09 09:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25233) UpsertKafkaTableITCase.testAggregate fails on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/12/09 10:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25234) Flink should parse ISO timestamp in UTC format - posted by "Egor Ryashin (Jira)" <ji...@apache.org> on 2021/12/09 13:31:00 UTC, 0 replies.
- Re: [DISCUSS] Creating an external connector repository - posted by Arvid Heise <ar...@apache.org> on 2021/12/09 14:37:44 UTC, 3 replies.
- [jira] [Created] (FLINK-25235) Re-enable ZooKeeperLeaderElectionITCase#testJobExecutionOnClusterWithLeaderChange - posted by "David Morávek (Jira)" <ji...@apache.org> on 2021/12/09 14:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25236) Add a mechanism to generate and validate a jobgraph with a checkpoint before submission - posted by "Ben Augarten (Jira)" <ji...@apache.org> on 2021/12/09 18:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25244) Deprecate Java 8 support - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/12/10 08:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25245) Allow Kubernetes E2E tests to run on Java 11 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/12/10 08:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25246) Run benchmarks on Java 11 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/12/10 09:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25247) Inform users about deprecation - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/12/10 09:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25248) Deprecate components that inherently require Java 8 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/12/10 09:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25249) Reimplement KafkaSourceTestEnv with KafkaContainer - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2021/12/10 09:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25250) Consider Java 11 as default version on CI - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/12/10 09:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25251) Docker image should use Java 11 by default - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/12/10 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25252) Check whether Kafka E2E tests could be run on Java 11 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/12/10 09:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25253) An ClassNotFoundException of missing Hadoop class occurred when submitting to yarn - posted by "ghost synth (Jira)" <ji...@apache.org> on 2021/12/10 09:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25254) Default Completed Job List is not ordered by time in web page - posted by "Liu (Jira)" <ji...@apache.org> on 2021/12/10 10:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25255) Consider/design implementing State Processor API (FC) - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/12/10 10:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25256) Savepoints do not work with ExternallyInducedSources - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/12/10 10:53:00 UTC, 0 replies.
- [DISCUSS] FLIP-200: Support Multiple Rule and Dynamic Rule Changing (Flink CEP) - posted by Yunfeng Zhou <fl...@gmail.com> on 2021/12/10 11:16:27 UTC, 32 replies.
- [jira] [Created] (FLINK-25257) Make the TaskExecutor not depend on concrete BlobServiceCache implementation - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/12/10 11:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25258) Update log4j2 version to avoid - posted by "Jing Zhang (Jira)" <ji...@apache.org> on 2021/12/10 11:47:00 UTC, 0 replies.
- About FLIP Page Edit Permission - posted by Yuepeng Pan <fl...@126.com> on 2021/12/10 16:41:35 UTC, 1 replies.
- [DISCUSS] FLIP-198: Working directory for Flink processes - posted by Till Rohrmann <tr...@apache.org> on 2021/12/10 16:54:18 UTC, 12 replies.
- [VOTE] FLIP-196: Source API stability guarantees - posted by Till Rohrmann <tr...@apache.org> on 2021/12/10 17:07:35 UTC, 4 replies.
- [VOTE] FLIP-197: API stability graduation process - posted by Till Rohrmann <tr...@apache.org> on 2021/12/10 17:09:43 UTC, 4 replies.
- confluence permission apply - posted by Yuepeng Pan <fl...@126.com> on 2021/12/11 07:22:38 UTC, 0 replies.
- Re:Re: About FLIP Page Edit Permission & confluence permission apply - posted by Yuepeng Pan <fl...@126.com> on 2021/12/11 09:05:43 UTC, 0 replies.
- [jira] [Created] (FLINK-25259) NO_CALLS_TO_VISIBLE_FOR_TESTING_METHODS should take the package into consideration - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/12/11 13:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25260) Recovery fails when using changelog+s3+presto - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/12/11 22:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25261) Changelog not truncated on materialization - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/12/11 22:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25262) Support to send data to lookup table for KeyGroupStreamPartitioner way for SQL - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2021/12/12 07:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25263) KafkaSourceE2ECase is broken - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/12/12 11:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25264) Does the binlog_row_image of MySQL must be in full mode when Flink CDC is used? - posted by "coco (Jira)" <ji...@apache.org> on 2021/12/12 11:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25265) RUNNING to FAILED with failure cause. This might indicate that the remote task manager was lost. - posted by "coco (Jira)" <ji...@apache.org> on 2021/12/12 12:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25266) StreamingKafkaITCase fails with incorrect number of messages - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/12/12 12:12:00 UTC, 0 replies.
- [DISCUSS] Immediate dedicated Flink releases for log4j vulnerability - posted by Stephan Ewen <se...@apache.org> on 2021/12/12 22:23:16 UTC, 15 replies.
- [jira] [Created] (FLINK-25267) Unable to (always) recover using checkpoint in HA setup (both Zookeeper and Kubernetes) - posted by "Kerem Ulutaş (Jira)" <ji...@apache.org> on 2021/12/12 23:10:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-168: Speculative execution for Batch Job - posted by 刘建刚 <li...@gmail.com> on 2021/12/13 03:37:54 UTC, 0 replies.
- [jira] [Created] (FLINK-25268) Support task manager node-label in Yarn deployment - posted by "Junfan Zhang (Jira)" <ji...@apache.org> on 2021/12/13 05:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25269) Quickstarts Scala nightly end-to-end test failed on azure due to could not connect to resource manager - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/12/13 07:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25270) Azure failed due to stopped hearing from agent AlibabaCI006-agent01 - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/12/13 07:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25271) ApplicationDispatcherBootstrapITCase. testDispatcherRecoversAfterLosingAndRegainingLeadership failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/12/13 07:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25272) Flink sql syntax analysis is inconsistent with the sql grammer declared now - posted by "Jianhui Dong (Jira)" <ji...@apache.org> on 2021/12/13 07:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25273) Some doubts about the FLINK-22848 - posted by "Jianhui Dong (Jira)" <ji...@apache.org> on 2021/12/13 07:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25274) Use ResolvedSchema in DataGen instead of TableSchema - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2021/12/13 11:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25275) Weighted KeyGroup assignment - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/12/13 13:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25276) Support native and incremental savepoints - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/12/13 14:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25277) Introduce explicit shutdown signalling between TaskManager and JobManager - posted by "Niklas Semmler (Jira)" <ji...@apache.org> on 2021/12/13 14:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25278) Azure failed due to unable to transfer jar from confluent maven repo - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/12/13 15:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25279) KafkaSourceLegacyITCase.testKeyValueSupport failed on azure due to topic already exists - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/12/13 15:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25280) KafkaPartitionSplitReaderTest failed on azure due to Offsets out of range with no configured reset policy for partitions - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/12/13 15:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25281) Azure failed due to python tests "tox check failed" - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/12/13 15:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25282) Move runtime dependencies from table-planner to table-runtime - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/12/13 15:50:00 UTC, 0 replies.
- [VOTE] Release 1.11.5/1.12.6/1.13.4/1.14.1, release candidate #1 - posted by Chesnay Schepler <ch...@apache.org> on 2021/12/13 19:28:10 UTC, 14 replies.
- [jira] [Created] (FLINK-25283) End-to-end application modules create oversized jars - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/12/13 19:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25284) Support nulls in DataGen - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2021/12/13 22:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25285) CoGroupedStreams has inner Maps without easy ways to set uid - posted by "Daniel Bosnic Hill (Jira)" <ji...@apache.org> on 2021/12/14 01:02:00 UTC, 0 replies.
- [Proposal] It is hoped that Apache APISIX and Apache Flink will carry out diversified community cooperation - posted by yeliang wang <wa...@gmail.com> on 2021/12/14 04:05:01 UTC, 2 replies.
- [jira] [Created] (FLINK-25286) Improve connector testing framework to support more scenarios - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2021/12/14 05:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25287) Refactor connector testing framework interfaces - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2021/12/14 05:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25289) Add DataStream sink test suite in connector testing framework - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2021/12/14 05:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25288) Add savepoint and metric cases in DataStream source suite of connector testing framework - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2021/12/14 05:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25290) Add table source and sink test suite in connector testing framework - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2021/12/14 05:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25291) Add failure cases in DataStream source and sink suite of connector testing framework - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2021/12/14 05:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25292) Azure failed due to unable to fetch some archives - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/12/14 06:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25293) Option to let fail if KafkaSource keeps failing to commit offset - posted by "rerorero (Jira)" <ji...@apache.org> on 2021/12/14 06:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25294) Incorrect cloudpickle import - posted by "arya (Jira)" <ji...@apache.org> on 2021/12/14 07:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25295) Update Log4j to 2.16.0 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/12/14 08:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25296) CheckpointingOptions[state.checkpoints.num-retained ] - posted by "chenqizhu (Jira)" <ji...@apache.org> on 2021/12/14 08:24:00 UTC, 0 replies.
- [DISCUSS] Changing the minimal supported version of Hadoop - posted by David Morávek <dm...@apache.org> on 2021/12/14 08:25:00 UTC, 7 replies.
- [jira] [Created] (FLINK-25297) Publich flink-shaded-swagger - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/12/14 08:54:00 UTC, 0 replies.
- [VOTE] Release flink-shaded 15.0, release candidate #1 - posted by Chesnay Schepler <ch...@apache.org> on 2021/12/14 08:57:25 UTC, 0 replies.
- [jira] [Created] (FLINK-25298) Create docker image for release environment - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/12/14 09:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25299) Improve LIKE operator efficiency - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/12/14 09:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25300) Remove CEIL and FLOOR call with one argument for integral values - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/12/14 09:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25301) Add a separate script for signing binaries - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/12/14 09:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25302) Find a way to keep release guides for previous releases - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/12/14 09:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25303) LookupTableSource/TableFunction - posted by "waittting (Jira)" <ji...@apache.org> on 2021/12/14 11:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25304) TIMESTAMP/TIMESTAMP_LTZ Pad with trailing zeros for fractional seconds depending on the precision specified - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/12/14 12:12:00 UTC, 0 replies.
- Flink 1.15. Bi-weekly 2021-12-14 - posted by Johannes Moser <jo...@ververica.com> on 2021/12/14 12:25:57 UTC, 0 replies.
- [jira] [Created] (FLINK-25305) Always wait for input channel state and result partition state get completed in AsyncRunnable - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/12/14 14:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25306) Flink CLI end-to-end test timeout on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/12/14 15:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25307) Resuming Savepoint (hashmap, async, no parallelism change) end-to-end test timeout on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/12/14 15:21:00 UTC, 0 replies.
- Unable to restore from checkpoint (Flink 1.13.2 and 1.13.0): serial version has changed in InflightDataRescalingDescriptor - posted by Adam Roberts <ad...@gmail.com> on 2021/12/14 16:16:35 UTC, 1 replies.
- [jira] [Created] (FLINK-25308) Support different remote functions module names - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/12/14 16:27:00 UTC, 0 replies.
- [VOTE] FLIP-190: Support Version Upgrades for Table API & SQL Programs - posted by Timo Walther <tw...@apache.org> on 2021/12/14 16:45:01 UTC, 6 replies.
- [jira] [Created] (FLINK-25309) Upgrade to the latest Flink version - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/12/14 17:48:00 UTC, 0 replies.
- [CANCELLED] Release 1.11.5/1.12.6/1.13.4/1.14.1, release candidate #1 - posted by Chesnay Schepler <ch...@apache.org> on 2021/12/14 21:38:02 UTC, 5 replies.
- [jira] [Created] (FLINK-25310) Fix the incorrect description for output network buffers in buffer debloat documenation - posted by "Liu (Jira)" <ji...@apache.org> on 2021/12/15 02:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25311) DelimitedInputFormat cannot read compressed files correctly - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/12/15 02:50:00 UTC, 0 replies.
- [VOTE] Release 1.11.6/1.12.7/1.13.5/1.14.2, release candidate #1 - posted by Chesnay Schepler <ch...@apache.org> on 2021/12/15 02:55:49 UTC, 17 replies.
- [jira] [Created] (FLINK-25312) Hive supports managed table - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/12/15 03:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25313) Enable flink-web-ui - posted by "Junfan Zhang (Jira)" <ji...@apache.org> on 2021/12/15 03:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25314) Update log4j2 version to 2.16.0 - posted by "Jinzhong Li (Jira)" <ji...@apache.org> on 2021/12/15 03:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25315) Add some extensions and utils to help the Junit5 migration - posted by "Hang Ruan (Jira)" <ji...@apache.org> on 2021/12/15 06:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25316) BlobServer can get stuck during shutdown - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/12/15 06:25:00 UTC, 0 replies.
- Some doubts about the FLINK-22848 - posted by 董剑辉 <mu...@gmail.com> on 2021/12/15 06:43:55 UTC, 1 replies.
- [jira] [Created] (FLINK-25317) ApplicationDispatcherBootstrapITCase blocked on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/12/15 07:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25318) Improvement of scheduler and execution for Flink OLAP - posted by "Shammon (Jira)" <ji...@apache.org> on 2021/12/15 07:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25319) Quickstarts Scala nightly end-to-end test failed due to akka rpc server failed to start - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/12/15 08:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25320) The flink history web page shows the number of running jobs instead of just showing the number of completed jobs - posted by "Zhuang Liu (Jira)" <ji...@apache.org> on 2021/12/15 08:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25321) standalone deploy on k8s,pod always OOM killed,actual heap memory usage is normal, gc is normal - posted by "Gao Fei (Jira)" <ji...@apache.org> on 2021/12/15 09:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25322) Support no-claim mode in changelog state backend - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/12/15 09:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25323) Support side output late data for interval join - posted by "chenyuzhi (Jira)" <ji...@apache.org> on 2021/12/15 09:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25324) Migration Flink from Junit4 to Junit5 - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2021/12/15 10:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25325) Migration Flink from Junit4 to Junit5 - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2021/12/15 10:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25326) KafkaUtil.createKafkaContainer log levels are not set correctly - posted by "Alexander Preuss (Jira)" <ji...@apache.org> on 2021/12/15 10:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25327) ApplicationMode "DELETE /cluster" REST call leads to exit code 2, instead of 0 - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/12/15 11:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25328) Improvement of share memory manager between jobs if they use the same slot in TaskManager for flink olap queries - posted by "Shammon (Jira)" <ji...@apache.org> on 2021/12/15 11:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25329) Improvement of disk operations in flink session cluster for jobs - posted by "Shammon (Jira)" <ji...@apache.org> on 2021/12/15 11:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25330) Flink SQL doesn't retract all versions of Hbase data - posted by "Bruce Wong (Jira)" <ji...@apache.org> on 2021/12/15 12:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25331) Allow testcontainer tests to run on Java 11 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/12/15 16:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25332) When using Pyflink Table API, 'where' clause seems to work incorrectly - posted by "TongMeng (Jira)" <ji...@apache.org> on 2021/12/15 16:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25333) Harden UID management when constructing statefun universe - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/12/15 16:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25334) Manage and share gateways of taskmanagers between jobs in session cluster - posted by "Shammon (Jira)" <ji...@apache.org> on 2021/12/16 02:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25335) Improvoment of task deployment by enable source split async enumerate - posted by "KevinyhZou (Jira)" <ji...@apache.org> on 2021/12/16 03:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25336) Kafka connector compatible problem in Flink sql - posted by "Yuan Zhu (Jira)" <ji...@apache.org> on 2021/12/16 03:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25337) Check whether the target table is valid when SqlToOperationConverter.convertSqlInsert - posted by "vim-wang (Jira)" <ji...@apache.org> on 2021/12/16 03:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25338) Improvement of connection from TM to JM in session cluster - posted by "Shammon (Jira)" <ji...@apache.org> on 2021/12/16 06:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25339) Moving to hadoop-free flink runtime. - posted by "David Morávek (Jira)" <ji...@apache.org> on 2021/12/16 07:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25340) Cleanup temporary directories from JM container before tearing down FlinkContainers - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2021/12/16 08:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25341) Improve casting structured type to STRING - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/12/16 08:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25342) DataStream.sinkTo will not add sink to the sinks field in the StreamGraph - posted by "Hang Ruan (Jira)" <ji...@apache.org> on 2021/12/16 09:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25343) HBaseConnectorITCase.testTableSourceSinkWithDDL fail on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/12/16 10:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25344) flink kafka connector Property group.id is required when using committed offset for offsets initializer - posted by "jingzi (Jira)" <ji...@apache.org> on 2021/12/16 10:56:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-196: Source API stability guarantees - posted by Till Rohrmann <tr...@apache.org> on 2021/12/16 11:25:23 UTC, 0 replies.
- [RESULT][VOTE] FLIP-197: API stability graduation process - posted by Till Rohrmann <tr...@apache.org> on 2021/12/16 11:25:25 UTC, 0 replies.
- [jira] [Created] (FLINK-25345) FLIP-196: Source API stability guarantees - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/12/16 11:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25346) FLIP-197: API stability graduation process - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/12/16 11:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25347) Replace deprecated TableSchema with Schema in MergeTableLikeUtil - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2021/12/16 12:38:00 UTC, 0 replies.
- [VOTE] FLIP-198: Working directory for Flink processes - posted by Till Rohrmann <tr...@apache.org> on 2021/12/16 13:42:09 UTC, 6 replies.
- [jira] [Created] (FLINK-25348) Update release guide to reset japicmp exceptions for every release - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/12/16 13:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25349) Add test that ensures that parameter/return types have the same or stronger stability guarantee than method - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/12/16 13:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25350) Verify stability guarantees of annotated classes - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/12/16 13:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25351) Add FlinkVersion - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/12/16 13:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25352) Update stability annotations to include the since and missedGraduations fields - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/12/16 14:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25353) Add tests to ensure API graduation process is honoured - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/12/16 14:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25354) Document API graduation process - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/12/16 14:06:00 UTC, 0 replies.
- [DISCUSS] GHA migration roadmap - posted by Nicolaus Weidner <ni...@ververica.com> on 2021/12/16 14:59:08 UTC, 5 replies.
- [ANNOUNCE] Apache Flink 1.14.2 / 1.13.5 / 1.12.7 / 1.11.6 released - posted by Chesnay Schepler <ch...@apache.org> on 2021/12/16 17:26:19 UTC, 7 replies.
- [DISCUSS] Immediate dedicated StateFun releases for log4j vulnerability - posted by Igal Shilman <ig...@apache.org> on 2021/12/16 18:30:05 UTC, 5 replies.
- [jira] [Created] (FLINK-25355) Upgrade Flink dependency to 1.13.3 - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/12/16 21:03:00 UTC, 0 replies.
- 回复: [DISCUSS] FLIP-191: Extend unified Sink interface to support small file compaction - posted by GALENO <70...@qq.com.INVALID> on 2021/12/17 01:28:16 UTC, 0 replies.
- [jira] [Created] (FLINK-25356) Add benchmarks for performance in OLAP scenarios - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/12/17 02:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25357) SQL planner incorrectly changes a streaming join with FLOOR(rowtime) into interval join - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/12/17 03:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25358) New File Sink end-to-end test failed due to TM could not connect to RM - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/12/17 05:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25359) flink1.13.2 心跳超时 - posted by "mindezhi (Jira)" <ji...@apache.org> on 2021/12/17 06:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25360) Add State Desc to CheckpointMetadata - posted by "刘方奇 (Jira)" <ji...@apache.org> on 2021/12/17 08:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25361) Support bounded timestamp in kafka table connector - posted by "ZhuoYu Chen (Jira)" <ji...@apache.org> on 2021/12/17 09:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25362) Incorrect dependencies in Table Confluent/Avro docs - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/12/17 09:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25363) Replace LogicalWindow and related planner expressions - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/12/17 13:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25364) Don't generate code in open() methods of Python operators - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/12/17 13:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25365) Remove remaining references to planner from Python - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/12/17 13:05:00 UTC, 0 replies.
- [DISCUSS] JUnit 5 Migration - posted by Hang Ruan <ru...@gmail.com> on 2021/12/17 13:14:12 UTC, 1 replies.
- [jira] [Created] (FLINK-25366) Enforce BINARY/VARBINARY precision when outputing to a Sink - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/12/17 13:52:00 UTC, 0 replies.
- [DISCUSS] Releasing Flink ML 2.0.0 - posted by Dong Lin <li...@gmail.com> on 2021/12/17 14:20:28 UTC, 3 replies.
- [jira] [Created] (FLINK-25367) Upgrade Flink dependency to 1.13.5 - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/12/17 15:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25368) Use AdminClient to get offsets rather than KafkaConsumer - posted by "dengziming (Jira)" <ji...@apache.org> on 2021/12/18 02:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25369) CatalogManager provide wrong tables or views in given catalog database name - posted by "Yubin Li (Jira)" <ji...@apache.org> on 2021/12/18 05:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25370) HBase SQL Connector Options 'table-name' description - posted by "Ibson (Jira)" <ji...@apache.org> on 2021/12/18 07:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25371) Include port as part of the host info for subtask detail panel on Web UI - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2021/12/18 10:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25372) Add thread dump feature for jobmanager - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2021/12/18 12:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25373) task manager can not free memory when jobs are finished - posted by "Spongebob (Jira)" <ji...@apache.org> on 2021/12/19 03:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25374) Azure pipeline get stalled on scanning project - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/12/19 05:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25375) Update Log4j to 2.17.0 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2021/12/19 15:36:00 UTC, 0 replies.
- Sending watermarks into Kafka - posted by Niels Basjes <Ni...@basjes.nl> on 2021/12/19 15:46:13 UTC, 9 replies.
- [jira] [Created] (FLINK-25376) Too many JM logs in flink session cluster for olap queries - posted by "Shammon (Jira)" <ji...@apache.org> on 2021/12/20 03:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25378) kubernetes's request/limit resource can been seperated? - posted by "jeff-zou (Jira)" <ji...@apache.org> on 2021/12/20 04:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25377) kubernetes's request/limit resource can been seperated? - posted by "jeff-zou (Jira)" <ji...@apache.org> on 2021/12/20 04:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25379) Support limit push down in DATAGEN connector. - posted by "Moses (Jira)" <ji...@apache.org> on 2021/12/20 07:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25380) Introduce DynamicTableSink & DynamicTableSource for RabbitMQ - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2021/12/20 07:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25381) JdbcExactlyOnceSinkE2eTest.testInsert fails on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/12/20 08:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25382) Failure in "Upload Logs" task - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/12/20 10:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25383) Skip waiting for the final checkpoint if the task do not contains 2-pc operators - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/12/20 10:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25384) Job can not migrate from flink-1.12 to flink-1.13 - posted by "tanjialiang (Jira)" <ji...@apache.org> on 2021/12/20 10:37:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-190: Support Version Upgrades for Table API & SQL Programs - posted by Timo Walther <tw...@apache.org> on 2021/12/20 12:31:57 UTC, 0 replies.
- [jira] [Created] (FLINK-25385) Harden function serialization in JSON plan - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/12/20 12:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25386) Harden table serialization in JSON plan - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/12/20 12:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25387) Introduce ExecNodeMetadata annotation and tooling - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/12/20 12:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25388) Add annotation to all StreamExec nodes - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/12/20 12:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25389) Update JSON plan with new ExecNodeMetadata - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/12/20 12:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25390) Support mutable options in DynamicTableFactory - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/12/20 12:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25391) Updating existing table factories for mutable table options - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/12/20 12:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25392) Add new STATEMENT SET syntax - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/12/20 12:57:00 UTC, 0 replies.
- [DISCUSS] FLIP-203: Incremental savepoints - posted by Piotr Nowojski <pn...@apache.org> on 2021/12/20 13:02:26 UTC, 4 replies.
- [jira] [Created] (FLINK-25393) Make ConfigMap Name for Leader Election Configurable - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2021/12/20 13:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25394) [Flink-ML] Upgrade log4j to 2.17.0 to address CVE-2021-45105 - posted by "Abdelrahman (Jira)" <ji...@apache.org> on 2021/12/20 16:06:00 UTC, 0 replies.
- [VOTE] Stateful functions 3.1.1 release - posted by Igal Shilman <ig...@apache.org> on 2021/12/20 16:52:37 UTC, 4 replies.
- [jira] [Created] (FLINK-25395) Incremental shared state might be discarded by TM - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/12/20 20:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25396) lookupjoin source table for pre-partitioning - posted by "HunterHunter (Jira)" <ji...@apache.org> on 2021/12/21 02:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25397) grouped_execution - posted by "ZhuoYu Chen (Jira)" <ji...@apache.org> on 2021/12/21 04:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25398) Show complete stacktrace when requesting thread dump - posted by "Junfan Zhang (Jira)" <ji...@apache.org> on 2021/12/21 05:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25399) AZP fails with exit code 137 when running checkpointing test cases - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/12/21 08:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25400) RocksDBStateBackend configurations does not work with SavepointEnvironment - posted by "wuzhiyu (Jira)" <ji...@apache.org> on 2021/12/21 08:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25401) DefaultCompletedCheckpointStore may not return the latest CompletedCheckpoint after JM failover. - posted by "Joyce.Li (Jira)" <ji...@apache.org> on 2021/12/21 08:40:00 UTC, 0 replies.
- [DISCUSS] Releasing Flink 1.14.3 - posted by Martijn Visser <ma...@ververica.com> on 2021/12/21 10:26:48 UTC, 7 replies.
- [RESULT][VOTE] FLIP-198: Working directory for Flink processes - posted by Till Rohrmann <tr...@apache.org> on 2021/12/21 15:02:20 UTC, 0 replies.
- [jira] [Created] (FLINK-25402) FLIP-198: Working directory for Flink processes - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/12/21 15:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25403) Make BlobServer/BlobCache compatible with local working directories - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/12/21 15:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25404) Store blobs in /blobs - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/12/21 15:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25405) Let BlobServer/BlobCache detect & delete corrupted blobs - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/12/21 15:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25406) Make sure that FileSystemBlobStore flushes all writes to disk to persist stored blobs - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/12/21 15:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25407) Network stack deadlock when cancellation happens during initialisation - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/12/21 15:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25408) Chinese Translation - Add documentation for KDS Async Sink - posted by "Zichen Liu (Jira)" <ji...@apache.org> on 2021/12/21 16:35:00 UTC, 0 replies.
- [RESULT][VOTE] Apache Flink Stateful Functions Release 3.1.1, release candidate #2 - posted by Igal Shilman <ig...@apache.org> on 2021/12/21 21:12:20 UTC, 0 replies.
- [jira] [Created] (FLINK-25409) Add cache metric to LookupFunction - posted by "Yuan Zhu (Jira)" <ji...@apache.org> on 2021/12/22 01:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25410) Flink CLI should exit when app is accepted with detach mode on Yarn - posted by "Junfan Zhang (Jira)" <ji...@apache.org> on 2021/12/22 05:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25411) JsonRowSerializationSchema unable to parse TIMESTAMP_LTZ fields - posted by "Surendra Lalwani (Jira)" <ji...@apache.org> on 2021/12/22 05:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25412) Upgrade of flink to 1.14.2 is showing internal server errors in the UI - posted by "srujankumar (Jira)" <ji...@apache.org> on 2021/12/22 06:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25413) Use append yarn and hadoop config to replace overwrite - posted by "qiunan (Jira)" <ji...@apache.org> on 2021/12/22 07:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25414) Provide metrics to measure how long task has been blocked - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/12/22 09:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25415) implement retrial on connections to Cassandra container - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2021/12/22 09:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25416) Build unified Parquet BulkFormat for both Table API and DataStream API - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2021/12/22 10:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25417) Too many connections for TM - posted by "fanrui (Jira)" <ji...@apache.org> on 2021/12/22 11:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25418) flink任务中指定了dir_cache没网的时候还是会去请求下载python第三方库,t_env.set_python_requirements(dir_requirements, dir_cache) - posted by "yangcai (Jira)" <ji...@apache.org> on 2021/12/22 11:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25419) Support the metadata column to generate dynamic index - posted by "jinfeng (Jira)" <ji...@apache.org> on 2021/12/22 11:53:00 UTC, 0 replies.
- [DISCUSS] Slimmed down docker images. - posted by David Morávek <dm...@apache.org> on 2021/12/22 13:42:36 UTC, 1 replies.
- [jira] [Created] (FLINK-25420) Port JDBC Source to new Source API (FLIP-27) - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/12/22 14:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25421) Port JDBC Sink to new Unified Sink API (FLIP-143) - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/12/22 14:39:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink Stateful Functions 3.1.1 released - posted by Igal Shilman <ig...@apache.org> on 2021/12/22 16:40:14 UTC, 1 replies.
- [jira] [Created] (FLINK-25422) Azure pipelines are failing due to Python tests unable to install dependencies - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/12/22 19:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25423) Enable loading state backend via configuration in state processor api - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/12/23 04:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25424) Checkpointing is currently not supported for operators that implement InputSelectable - posted by "Zhipeng Zhang (Jira)" <ji...@apache.org> on 2021/12/23 06:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25425) flink sql cassandra connector - posted by "sky (Jira)" <ji...@apache.org> on 2021/12/23 08:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25426) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails on AZP because it cannot allocate enough network buffers - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/12/23 08:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25428) Expose complex types CAST to String - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/12/23 08:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25427) SavepointITCase.testTriggerSavepointAndResumeWithNoClaim fails on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/12/23 08:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25429) Avoid to close output streams twice during uploading changelogs - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/12/23 11:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25430) Introduce JobResultStore - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2021/12/23 12:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25431) Implement file-based JobResultStore - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2021/12/23 12:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25432) Implement cleanup strategy - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2021/12/23 12:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25433) Integrate retry strategy for cleanup stage - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2021/12/23 12:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25434) Throw an error when BigDecimal precision overflows. - posted by "Ada Wong (Jira)" <ji...@apache.org> on 2021/12/23 12:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25435) Can not read jobmanager/taskmanager.log in yarn-per-job mode. - posted by "Moses (Jira)" <ji...@apache.org> on 2021/12/23 12:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25436) Allow BlobServer/BlobCache to clean up unused blobs after recovering from working directory - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/12/23 16:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25437) Build wheels failed - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/12/24 02:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25438) KafkaProducerExactlyOnceITCase.testMultipleSinkOperators failed due to topic 'exactlyTopicCustomOperator20' already exists - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/12/24 02:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25439) StreamExecCalc collect new StreamRecord to Downstream lost timestamp Attributes - posted by "HunterHunter (Jira)" <ji...@apache.org> on 2021/12/24 02:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25440) Apache Pulsar Connector Document description error about 'Starting Position'. - posted by "xiechenling (Jira)" <ji...@apache.org> on 2021/12/24 04:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25441) ProducerFailedException will cause task status switch from RUNNING to CANCELED, which will cause the job to hang. - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2021/12/24 08:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25442) HBaseConnectorITCase.testTableSink failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/12/25 03:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25443) Embedded statefulfunction jakson /java8 date time issue - posted by "Ashok (Jira)" <ji...@apache.org> on 2021/12/25 12:44:00 UTC, 1 replies.
- [jira] [Created] (FLINK-25444) ExecutionConfig can not be Serializable due to TextElement used in side - posted by "Wen Zhou (Jira)" <ji...@apache.org> on 2021/12/27 01:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25445) TaskExecutor always creates local file for task even when local state store is not used - posted by "Shammon (Jira)" <ji...@apache.org> on 2021/12/27 03:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25446) Avoid sanity check on read bytes on DataInputStream#read(byte[]) - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/12/27 03:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25447) batch query cannot generate plan when a sorted view into multi sinks - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2021/12/27 04:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25448) TaskManagerRunnerTest.testShouldShutdownIfRegistrationWithJobManagerFails failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/12/27 06:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25449) KafkaSourceITCase.testRedundantParallelism failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/12/27 06:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25450) JobMasterTest.testJobFailureWhenTaskExecutorHeartbeatTimeout is unstable on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/12/27 06:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25451) KafkaEnumeratorTest.testDiscoverPartitionsPeriodically failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/12/27 06:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25452) FlinkKafkaProducerITCase.testRestoreUsingDifferentTransactionalIdPrefix failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/12/27 06:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25453) LocalFileSystem#listStatus throws FileNotFoundException when a file is deleted concurrently in the directory - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/12/27 07:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25454) Negative time in throughput calculator - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/12/27 08:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25455) FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinator fails on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/12/27 08:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25456) FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/12/27 09:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25457) Read timeouts when downloading from alicloud-mvn-mirror - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/12/27 09:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25458) Supports local recovery - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/12/27 09:52:00 UTC, 0 replies.
- About ClickHouse Connector - posted by 柳尘 <yu...@gmail.com> on 2021/12/27 10:20:22 UTC, 0 replies.
- [jira] [Created] (FLINK-25459) When inserting row type fields into sink, the order needs to be maintained - posted by "qyw (Jira)" <ji...@apache.org> on 2021/12/27 12:09:00 UTC, 0 replies.
- [NOTICE] Increased build instability - posted by Till Rohrmann <tr...@apache.org> on 2021/12/27 13:02:19 UTC, 0 replies.
- About Clickhouse connector - posted by 柳尘 <yu...@gmail.com> on 2021/12/27 13:36:48 UTC, 1 replies.
- [jira] [Created] (FLINK-25460) Update slf4j-api dependency to 1.7.32 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/12/27 14:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25461) Update net.sf.py4j:py4j dependency to 0.10.8.1 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/12/27 14:31:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-188: Introduce Built-in Dynamic Table Storage - posted by Jingsong Li <ji...@gmail.com> on 2021/12/28 03:23:11 UTC, 4 replies.
- [VOTE] Apache Flink ML Release 2.0.0, release candidate #1 - posted by Yun Gao <yu...@aliyun.com.INVALID> on 2021/12/28 03:45:36 UTC, 2 replies.
- [jira] [Created] (FLINK-25462) Allow override partitioning for KeyedStream - posted by "Viktor Feklin (Jira)" <ji...@apache.org> on 2021/12/28 04:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25463) Set is not supported in User Defined Functions - posted by "Surendra Lalwani (Jira)" <ji...@apache.org> on 2021/12/28 04:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25464) Python tests hangs on install dependencies - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/12/28 06:22:00 UTC, 0 replies.
- [DISCUSS] Introduce Hash Lookup Join - posted by Jing Zhang <be...@gmail.com> on 2021/12/28 07:10:31 UTC, 15 replies.
- [jira] [Created] (FLINK-25465) Correct the logic to materizate on wrapped changelog state - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/12/28 07:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25466) TTL configuration could parse in StateTtlConfig#DISABLED - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/12/28 07:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25467) Job failed during initialization of JobManager - posted by "tim.yuan (Jira)" <ji...@apache.org> on 2021/12/28 11:22:00 UTC, 0 replies.
- [VOTE] Apache Flink ML Release 2.0.0, release candidate #2 - posted by Yun Gao <yu...@aliyun.com.INVALID> on 2021/12/28 12:58:08 UTC, 3 replies.
- [DISCUSS] FLIP-201: Persist local state in working directory - posted by Till Rohrmann <tr...@apache.org> on 2021/12/28 14:22:47 UTC, 3 replies.
- [jira] [Created] (FLINK-25468) Local recovery fails if local state storage and RocksDB working directory are not on the same volume - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/12/28 14:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25469) FlinkKafkaProducerITCase.testScaleUpAfterScalingDown fails on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/12/28 17:52:00 UTC, 0 replies.
- [DISCUSS] FLIP-206: Support PyFlink Runtime Execution in Thread Mode - posted by Xingbo Huang <hx...@gmail.com> on 2021/12/29 03:56:51 UTC, 2 replies.
- [jira] [Created] (FLINK-25470) Add/Expose/differentiate metrics of checkpoint size between changelog size vs materialization size - posted by "Yuan Mei (Jira)" <ji...@apache.org> on 2021/12/29 05:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25471) wrong result if table toDataStream then keyey by sum - posted by "zhangzh (Jira)" <ji...@apache.org> on 2021/12/29 05:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25472) Update to Log4j 2.17.1 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/12/29 06:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25473) Azure pipeline failed due to stopped hearing from agent Azure Pipelines 11 - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/12/29 06:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25474) Idea Scala plugin can not compile RexExplainUtil - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/12/29 07:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25475) When windowAgg and groupAgg are included at the same time, there is no assigner generated but MiniBatch optimization is still used. - posted by "ChangjiGuo (Jira)" <ji...@apache.org> on 2021/12/29 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25476) CharType lost in the creation of MaxAggFunction & MinAggFunction - posted by "zoucao (Jira)" <ji...@apache.org> on 2021/12/29 08:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25477) The directory structure of the State Backends document is not standardized - posted by "Hangxiang Yu (Jira)" <ji...@apache.org> on 2021/12/29 09:01:00 UTC, 0 replies.
- [DISCUSS] FLIP-205: Support cache in DataStream for Batch Processing - posted by Xuannan Su <su...@gmail.com> on 2021/12/29 09:36:40 UTC, 4 replies.
- [jira] [Created] (FLINK-25478) Changelog materialization with incremental checkpoint could cause checkpointed data lost - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/12/29 13:01:00 UTC, 0 replies.
- [DISCUSS] FLIP-207: Flink backward and forward compatibility - posted by Jing Ge <ji...@ververica.com> on 2021/12/29 13:06:51 UTC, 4 replies.
- [jira] [Created] (FLINK-25479) Changlog materialization with incremental checkpoint cannot work well in local tests - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/12/29 13:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25480) Create dashboard/monitoring to see resource usage per E2E test - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/12/29 14:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25481) SourceIndex comparison in SplitEnumeratorContextProxy - posted by "Yuhao Bi (Jira)" <ji...@apache.org> on 2021/12/29 15:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25482) Hive Lookup Join with decimal type failed - posted by "miaojianlong (Jira)" <ji...@apache.org> on 2021/12/29 16:09:00 UTC, 0 replies.
- Re: Unable to update logback configuration in Flink Native Kubernetes - posted by Sharon Xie <sh...@gmail.com> on 2021/12/29 19:24:09 UTC, 0 replies.
- [jira] [Created] (FLINK-25483) When FlinkSQL writes ES, it will not write and update the null value field - posted by "陈磊 (Jira)" <ji...@apache.org> on 2021/12/30 04:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25484) TableRollingPolicy do not support inactivityInterval config which is supported in datastream api - posted by "LiChang (Jira)" <ji...@apache.org> on 2021/12/30 05:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25485) JDBC connector implicitly add options when use mysql - posted by "Ada Wong (Jira)" <ji...@apache.org> on 2021/12/30 09:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25486) Perjob can not recover from checkpoint when zookeeper leader changes - posted by "Liu (Jira)" <ji...@apache.org> on 2021/12/30 11:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25487) Improve exception when flink-table-runtime is not in classpath - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/12/30 13:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25488) Using a pipe symbol as pair delimiter in STR_TO_MAP in combination with concatenation results in broken output - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/12/30 13:20:00 UTC, 0 replies.
- [NOTICE] Table API is now Scala-free by introducing a flink-table-planner-loader - posted by Timo Walther <tw...@apache.org> on 2021/12/30 14:01:43 UTC, 2 replies.
- [jira] [Created] (FLINK-25489) failed at task: node and npm install when building flink from source in mac m1 - posted by "jie han (Jira)" <ji...@apache.org> on 2021/12/30 15:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25490) Update the Chinese document related to final checkpoint - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/12/30 16:19:00 UTC, 0 replies.
- [VOTE] Apache Flink ML Release 2.0.0, release candidate #3 - posted by Yun Gao <yu...@aliyun.com.INVALID> on 2021/12/30 17:24:18 UTC, 3 replies.
- [jira] [Created] (FLINK-25491) Code generation: init method exceeds 64 KB when there is a large IN filter with Table API - posted by "Daniel Cheng (Jira)" <ji...@apache.org> on 2021/12/31 01:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25492) Changelog with InMemoryStateChangelogStorage cannot work well - posted by "Hangxiang Yu (Jira)" <ji...@apache.org> on 2021/12/31 03:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25493) 日期类型数据为空导致SQL校验失败原因为null - posted by "kunghsu (Jira)" <ji...@apache.org> on 2021/12/31 06:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25494) Duplicate element serializer during DefaultOperatorStateBackendSnapshotStrategy#syncPrepareResources - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/12/31 06:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25495) Client support attach mode when using the deployment of application mode - posted by "Junfan Zhang (Jira)" <ji...@apache.org> on 2021/12/31 07:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25496) ThreadDumpInfoTest.testComparedWithDefaultJDKImplemetation failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/12/31 07:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25497) Add more ML Python examples - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/12/31 09:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25498) FlinkKafkaProducerITCase. testRestoreToCheckpointAfterExceedingProducersPool failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/12/31 10:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25499) Column 'window_start' is ambiguous - posted by "Shandy (Jira)" <ji...@apache.org> on 2021/12/31 13:00:00 UTC, 0 replies.