You are viewing a plain text version of this content. The canonical link for it is here.
- [jira] [Created] (FLINK-23195) No value for kafka metrics in Flink Web ui - posted by "MOBIN (Jira)" <ji...@apache.org> on 2021/07/01 02:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23196) JobMasterITCase fail on azure due to BindException - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/07/01 02:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23197) Errorneous description about 'TIMESTAMP WITH TIME ZONE' date type - posted by "wangqinghuan (Jira)" <ji...@apache.org> on 2021/07/01 02:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23198) An old interface method is used in this section of [Passing Options Factory to RocksDB]. - posted by "Carl (Jira)" <ji...@apache.org> on 2021/07/01 03:36:00 UTC, 0 replies.
- [VOTE] FLIP-150: Introduce Hybrid Source - posted by 蒋晓峰 <pr...@163.com> on 2021/07/01 05:49:44 UTC, 10 replies.
- [jira] [Created] (FLINK-23199) Clarify differences of overloaded term "user-defined function" - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/07/01 06:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23200) Correct grammatical mistakes in 'Table API' page of 'Table API & SQL' - posted by "weizheng (Jira)" <ji...@apache.org> on 2021/07/01 06:40:00 UTC, 0 replies.
- Re: [VOTE] FLIP-147: Support Checkpoint After Tasks Finished - posted by Arvid Heise <ar...@apache.org> on 2021/07/01 07:09:41 UTC, 3 replies.
- [jira] [Created] (FLINK-23201) The check on alignmentDurationNanos seems to be too strict - posted by "Jun Qin (Jira)" <ji...@apache.org> on 2021/07/01 07:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23202) RpcService should fail result futures if messages could not be sent - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/07/01 08:49:00 UTC, 0 replies.
- Re: Job Recovery Time on TM Lost - posted by Till Rohrmann <tr...@apache.org> on 2021/07/01 08:49:05 UTC, 17 replies.
- Improvements of left state in TemporalRowTimeJoinOperator - posted by Tony Wei <to...@gmail.com> on 2021/07/01 08:59:15 UTC, 0 replies.
- [jira] [Created] (FLINK-23203) Program cannot parse the parameter value with special characters - posted by "Jacob.Q.Cao (Jira)" <ji...@apache.org> on 2021/07/01 09:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23204) Provide StateBackends access to MailboxExecutor - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/07/01 10:28:00 UTC, 0 replies.
- Re: [DISCUSS] Feedback Collection Jira Bot - posted by Stephan Ewen <se...@apache.org> on 2021/07/01 10:35:04 UTC, 3 replies.
- [VOTE] Release 1.13.2, release candidate #1 - posted by Yun Tang <my...@LIVE.COM> on 2021/07/01 10:57:50 UTC, 14 replies.
- [DISCUSS] FLIP-173: Support DAG of algorithms (Flink ML) - posted by Dong Lin <li...@gmail.com> on 2021/07/01 11:22:44 UTC, 3 replies.
- [jira] [Created] (FLINK-23205) Relax Time Intervals of Flink Jira Bot - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2021/07/01 12:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23206) Flink Jira Bot Moves Tickets to "Not a Priority" Instead of Closing Them - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2021/07/01 12:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23207) Flink Jira Bot to Ignore Tickets with fixVersion set - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2021/07/01 12:50:00 UTC, 0 replies.
- Re: [DISCUSS] Better user experience in the WindowAggregate upon Changelog (contains update message) - posted by Jark Wu <im...@gmail.com> on 2021/07/01 13:20:37 UTC, 2 replies.
- [jira] [Created] (FLINK-23208) Late processing timers need to wait 1ms at least to be fired - posted by "Jiayi Liao (Jira)" <ji...@apache.org> on 2021/07/01 13:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23209) Timeout heartbeat if the heartbeat target is no longer reachable - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/07/01 13:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23210) Running HA per-job cluster (hashmap, sync) end-to-end test failed on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/01 14:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23211) An old interface method is used in this section of [Passing Options Factory to RocksDB]. - posted by "Carl (Jira)" <ji...@apache.org> on 2021/07/02 01:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23212) Skip code-wise tests for pure documentation changing PRs - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/07/02 03:53:00 UTC, 0 replies.
- Re: [DISCUSS] Do not merge PRs with "unrelated" test failures. - posted by Xintong Song <to...@gmail.com> on 2021/07/02 03:57:05 UTC, 2 replies.
- [jira] [Created] (FLINK-23213) Remove ProcessFunctionOperation - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/07/02 03:58:00 UTC, 0 replies.
- [ANNOUNCE] Criteria for merging pull requests is updated - posted by Xintong Song <to...@gmail.com> on 2021/07/02 04:59:37 UTC, 4 replies.
- [jira] [Created] (FLINK-23214) Make ShuffleMaster a cluster level shared service - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2021/07/02 06:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23215) flink-table-code-splitter: NOTICE should in META-INF - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/07/02 06:34:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-147: Support Checkpoint After Tasks Finished - posted by Yun Gao <yu...@aliyun.com.INVALID> on 2021/07/02 06:35:50 UTC, 32 replies.
- [jira] [Created] (FLINK-23216) RM keeps allocating and freeing slots after a TM lost until its heartbeat timeout - posted by "Gen Luo (Jira)" <ji...@apache.org> on 2021/07/02 06:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23217) Support StreamExecValues json serialization/deserialization - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/07/02 07:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23218) Distribute the ShuffleDescriptors via blob server - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2021/07/02 07:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23219) temproary join ttl configruation does not take effect - posted by "waywtdcc (Jira)" <ji...@apache.org> on 2021/07/02 08:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23220) MailboxProcessor should wait for default action available even if there are no mails - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/02 10:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23221) Docker image vulnerability - posted by "Razvan AGAPE (Jira)" <ji...@apache.org> on 2021/07/02 11:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23222) Translate page 'Application Profiling & Debugging' of 'Operations/Debugging' into Chinese - posted by "pierrexiong (Jira)" <ji...@apache.org> on 2021/07/02 11:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23223) When flushAlways is enabled the subpartition may lose notification of data availability - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/07/02 11:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23224) Support timestamp_ltz type in hive connector - posted by "Rui Li (Jira)" <ji...@apache.org> on 2021/07/02 12:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23225) There is some mismatches between the current translation and the latest English version on the Flink-Architecture page - posted by "wuguihu (Jira)" <ji...@apache.org> on 2021/07/03 15:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23226) Flink Chinese doc learn-flink/etl transformation.svg display issue - posted by "kevin (Jira)" <ji...@apache.org> on 2021/07/03 16:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23227) Flink Chinese docs [learn-flink/etl]: no translation and mismatch in some place within this doc - posted by "kevin (Jira)" <ji...@apache.org> on 2021/07/03 17:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23228) Translate "Stateful Stream Processing" page into Chinese - posted by "kevin (Jira)" <ji...@apache.org> on 2021/07/04 10:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23229) Translate "Timely Stream Processing" page into Chinese - posted by "kevin (Jira)" <ji...@apache.org> on 2021/07/04 10:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23230) Cannot compile Flink on MacOS with M1 chip - posted by "Osama Neiroukh (Jira)" <ji...@apache.org> on 2021/07/04 14:47:00 UTC, 0 replies.
- [RESULT] [VOTE] FLIP-150: Introduce Hybrid Source - posted by 蒋晓峰 <pr...@163.com> on 2021/07/05 01:08:25 UTC, 1 replies.
- [jira] [Created] (FLINK-23231) The JM's pod was failed when the high-availability.storageDir which using the S3 - posted by "Levi Lv (Jira)" <ji...@apache.org> on 2021/07/05 02:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23232) PyFlink tox check fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/07/05 02:37:00 UTC, 0 replies.
- [VOTE] Release 1.12.5, release candidate #1 - posted by Jingsong Li <ji...@gmail.com> on 2021/07/05 03:17:51 UTC, 9 replies.
- [jira] [Created] (FLINK-23233) OperatorEventSendingCheckpointITCase.testOperatorEventLostWithReaderFailure fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/07/05 03:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23234) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails on azure with NoResourceAvailableException - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/07/05 04:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23235) SinkITCase.writerAndCommitterAndGlobalCommitterExecuteInStreamingMode fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/07/05 04:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23236) FanOutShardSubscriberTest.testTimeoutEnqueuingEvent fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/07/05 04:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23237) Add log to print data that failed to deserialize when ignore-parse-error=true and threre is NPE question when use `new String(message) ` if message = null - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2021/07/05 04:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23238) EventTimeWindowCheckpointingITCase.testTumblingTimeWindowWithKVStateMaxMaxParallelism fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/07/05 05:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23239) HiveTableSinkITCase hangs on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/07/05 05:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23240) ResumeCheckpointManuallyITCase.testExternalizedFSCheckpointsWithLocalRecoveryZookeeper fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/07/05 05:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23241) Translate the page of "Working with State " into Chinese - posted by "baobinliang (Jira)" <ji...@apache.org> on 2021/07/05 07:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23242) Translate the page of "Handling Application Parameters" into Chinese - posted by "baobinliang (Jira)" <ji...@apache.org> on 2021/07/05 07:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23243) Translate "Windowing table-valued functions (Windowing TVFs)" page into Chinese - posted by "Edmond Wang (Jira)" <ji...@apache.org> on 2021/07/05 07:33:00 UTC, 0 replies.
- Re: [VOTE] Migrating Test Framework to JUnit 5 - posted by Arvid Heise <ar...@apache.org> on 2021/07/05 07:45:31 UTC, 2 replies.
- Re: [DISCUSS] Dashboard/HistoryServer authentication - posted by Márton Balassi <ba...@gmail.com> on 2021/07/05 08:15:23 UTC, 0 replies.
- [jira] [Created] (FLINK-23244) Refactor the time indicator materialization - posted by "JING ZHANG (Jira)" <ji...@apache.org> on 2021/07/05 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23245) Materialize rowtime attribute fields of regular join's inputs - posted by "JING ZHANG (Jira)" <ji...@apache.org> on 2021/07/05 08:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23246) Refactor the time indicator materialization - posted by "JING ZHANG (Jira)" <ji...@apache.org> on 2021/07/05 08:38:00 UTC, 0 replies.
- [RESULT][VOTE] Migrating Test Framework to JUnit 5 - posted by Qingsheng Ren <re...@gmail.com> on 2021/07/05 08:39:07 UTC, 0 replies.
- [jira] [Created] (FLINK-23247) Materialize rowtime attribute fields of regular join's inputs - posted by "JING ZHANG (Jira)" <ji...@apache.org> on 2021/07/05 08:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23248) SinkWriter is not close when failing - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/07/05 08:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23249) Introduce ShuffleMasterContext to ShuffleMaster - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2021/07/05 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23250) Jira Bot Should Not Unassign Automatically - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2021/07/05 10:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23251) Support more than one retained checkpoints - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/07/05 11:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23252) Support recovery with altered "changelog.enabled" option - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/07/05 11:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23253) Expose some interfaces of changelog to users - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2021/07/05 11:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23254) Upgrade Test Framework to JUnit 5 - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2021/07/05 13:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23255) Add JUnit 5 jupiter and vintage engine - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2021/07/05 13:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23256) Explain string shows output of legacy planner - posted by "Mans Singh (Jira)" <ji...@apache.org> on 2021/07/05 16:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23257) docker-build.sh outdated - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/07/05 16:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23258) Make incremental jekyll opt in and log a warning - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/07/05 17:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23259) [DOCS]The 'window' link on page A is failed and 404 is returned - posted by "wuguihu (Jira)" <ji...@apache.org> on 2021/07/05 17:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23260) [DOCS]The link on page docs/libs/gelly/overview is failed and 404 is returned - posted by "wuguihu (Jira)" <ji...@apache.org> on 2021/07/05 17:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23261) StateFun - HTTP State Access Interface - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2021/07/06 00:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23262) FileReadingWatermarkITCase.testWatermarkEmissionWithChaining fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/07/06 02:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23263) LocalBufferPool can not request memory. - posted by "Ada Wong (Jira)" <ji...@apache.org> on 2021/07/06 02:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23264) Fine Grained Resource Management Phase 2 - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2021/07/06 02:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23265) Support evenly spread out in fine-grained resource management - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2021/07/06 02:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23266) HA per-job cluster (rocks, non-incremental) hangs on Azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/07/06 03:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23267) Activate Java code splitter for all generated classes - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/07/06 05:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23268) [DOCS]The link on page docs/dev/table/sql/queries/match_recognize/ is failed and 404 is returned - posted by "wuguihu (Jira)" <ji...@apache.org> on 2021/07/06 05:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23269) json format decode number to vatchar error when define Decimal type in ddl - posted by "silence (Jira)" <ji...@apache.org> on 2021/07/06 06:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23270) The examples in the documentation are inappropriate - posted by "Fangliang Liu (Jira)" <ji...@apache.org> on 2021/07/06 07:47:00 UTC, 0 replies.
- Re: [VOTE] FLIP-172: Support custom transactional.id prefix in FlinkKafkaProducer - posted by Daniel Lorych <d....@gmail.com> on 2021/07/06 07:54:03 UTC, 2 replies.
- [jira] [Created] (FLINK-23271) RuntimeException: while resolving method 'booleanValue' in class class java.math.BigDecimal - posted by "xiaojin.wy (Jira)" <ji...@apache.org> on 2021/07/06 07:56:00 UTC, 0 replies.
- Re: [IGNORE] [RESULT] [VOTE] FLIP-150: Introduce Hybrid Source - posted by 蒋晓峰 <pr...@163.com> on 2021/07/06 08:11:34 UTC, 2 replies.
- [jira] [Created] (FLINK-23272) FLIP-181: Custom netty HTTP request inbound/outbound handlers - posted by "Márton Balassi (Jira)" <ji...@apache.org> on 2021/07/06 08:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23273) Implement basic authentication handler - posted by "Márton Balassi (Jira)" <ji...@apache.org> on 2021/07/06 08:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23274) Implement SPNEGO authentication handler - posted by "Márton Balassi (Jira)" <ji...@apache.org> on 2021/07/06 08:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23275) Support to release cluster partitions stored externally - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2021/07/06 09:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23276) Changelog backend not always updates delegating functions - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/07/06 09:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23277) Changelog backend doesn't apply TTL after recovery - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/07/06 09:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23279) Enable changelog backend in tests - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/07/06 09:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23278) Changelog backend creates "raw materialized" savepoint but expects it's "normal" snapshot on recovery - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/07/06 09:59:00 UTC, 0 replies.
- Re: [DISCUSS] Releasing Flink 1.11.4 - posted by Matthias Pohl <ma...@ververica.com> on 2021/07/06 10:47:22 UTC, 4 replies.
- [jira] [Created] (FLINK-23280) Python ExplainDetails does not have JSON_EXECUTION_PLAN option - posted by "Mans Singh (Jira)" <ji...@apache.org> on 2021/07/06 12:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23281) StateFun - Simplify Getting Stared Experience with HTTP Ingresses and Egresses - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2021/07/06 12:27:00 UTC, 0 replies.
- [VOTE] FLIP-181: Custom netty HTTP request inbound/outbound handlers - posted by Márton Balassi <ba...@gmail.com> on 2021/07/06 12:49:52 UTC, 8 replies.
- Re: [DISCUSS] Incrementally deprecating the DataSet API - posted by Etienne Chauchot <ec...@apache.org> on 2021/07/06 13:05:05 UTC, 5 replies.
- [ANNOUNCE] New PMC member: Guowei Ma - posted by Kurt Young <ku...@apache.org> on 2021/07/06 13:56:44 UTC, 28 replies.
- [jira] [Created] (FLINK-23282) Compile error in `Streaming Java` module: MailboxProcessor.java:[217,13] - posted by "JING ZHANG (Jira)" <ji...@apache.org> on 2021/07/06 14:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23283) GroupWindowITCase.testWindowAggregateOnUpsertSource fails on azure - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/07/06 14:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23284) All records are processed in the close stage in ContinuousFileReaderOperatorBenchmark - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/06 14:53:00 UTC, 0 replies.
- [ANNOUNCE] The term "blink" has been removed from the code base - posted by Timo Walther <tw...@apache.org> on 2021/07/06 15:51:08 UTC, 2 replies.
- [jira] [Created] (FLINK-23285) The link on page docs/dev/datastream/event-time/generating_atermarks/ is failed and 404 is returned - posted by "wuguihu (Jira)" <ji...@apache.org> on 2021/07/06 16:57:00 UTC, 0 replies.
- [ANNOUNCE] New Apache Flink Committer - Yang Wang - posted by Xintong Song <to...@gmail.com> on 2021/07/07 02:08:47 UTC, 26 replies.
- [jira] [Created] (FLINK-23286) Create user document for Window Join in SQL - posted by "JING ZHANG (Jira)" <ji...@apache.org> on 2021/07/07 03:00:03 UTC, 0 replies.
- [jira] [Created] (FLINK-23287) Create user document for Window Join in SQL - posted by "JING ZHANG (Jira)" <ji...@apache.org> on 2021/07/07 03:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23288) Inserting (1.378593404E9) (0.6047707965147558) to a double type, it will generate CodeGenException - posted by "xiaojin.wy (Jira)" <ji...@apache.org> on 2021/07/07 03:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23289) BinarySection should null check in contusctor method - posted by "Terry Wang (Jira)" <ji...@apache.org> on 2021/07/07 03:39:00 UTC, 0 replies.
- I want to contribute to Apache Flink - posted by pang pan <pa...@gmail.com> on 2021/07/07 03:56:32 UTC, 1 replies.
- [jira] [Created] (FLINK-23290) cast '(LZ *3' as boolean, get a null - posted by "xiaojin.wy (Jira)" <ji...@apache.org> on 2021/07/07 06:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23291) Bump flink-shaded-jackson to 2.12.3 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/07/07 07:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23292) [DOCS]Some links on page docs/content/docs/dev/table/concepts/dynamic_tables is failed and 404 is returned - posted by "wuguihu (Jira)" <ji...@apache.org> on 2021/07/07 07:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23293) Support pluggable / extendable HTTP transport for StateFun remote invocations - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2021/07/07 07:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23295) Introduce extension module SPI to StateFun - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2021/07/07 07:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23294) Default NOTICE files should use artifact id instead of module name as their title. - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/07/07 07:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23296) Add RequestReplyClientFactory as a pluggable extension - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2021/07/07 08:14:00 UTC, 0 replies.
- [DISCUSS] Cleaning up outdated test instability JIRA tickets - posted by Xintong Song <to...@gmail.com> on 2021/07/07 08:15:32 UTC, 0 replies.
- [jira] [Created] (FLINK-23297) Upgrade Protobuf to 3.17.3 - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/07/07 09:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23298) [datagen] Normalize parameter names in RandomGeneratorVisitor and SequenceGeneratorVisitor - posted by "fhan (Jira)" <ji...@apache.org> on 2021/07/07 09:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23299) Bump Zookeeper 3.5 to 3.5.9 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/07/07 09:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23300) Job fails very slow because of no notifyAllocationFailure for DeclarativeSlotManager - posted by "Liu (Jira)" <ji...@apache.org> on 2021/07/07 09:53:00 UTC, 0 replies.
- Re: [DISCUSS] Lifecycle of ShuffleMaster and its Relationship with JobMaster and PartitionTracker - posted by Guowei Ma <gu...@gmail.com> on 2021/07/07 10:50:09 UTC, 4 replies.
- [ANNOUNCE] New Apache Flink Committer - Yuan Mei - posted by Yu Li <ca...@gmail.com> on 2021/07/07 17:21:40 UTC, 22 replies.
- [jira] [Created] (FLINK-23301) StateFun HTTP Ingress - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2021/07/07 18:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23302) Precondition failed building CheckpointMetrics. - posted by "Kyle Weaver (Jira)" <ji...@apache.org> on 2021/07/08 01:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23303) org.apache.calcite.rex.RexLiteral cannot be cast to org.apache.calcite.rex.RexCall - posted by "xiaojin.wy (Jira)" <ji...@apache.org> on 2021/07/08 02:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23304) More detail information in sql validate exception - posted by "YING HOU (Jira)" <ji...@apache.org> on 2021/07/08 03:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23305) Support semi/anti interval joins - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/07/08 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23306) FlinkRelMdUniqueKeys causes exception when used with new Schema - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/07/08 08:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23307) Rowtime attributes are not properly resolved for views - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/07/08 08:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23308) Performance regression on 06.07 - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/08 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23309) Optimize the finish bundle logic in PyFlink - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/07/08 08:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23310) Correct the `ModifyKindSetTrait` for `GroupWindowAggregate` when the input is an update stream - posted by "Shuo Cheng (Jira)" <ji...@apache.org> on 2021/07/08 08:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23311) Improve PojoSerializer test - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/07/08 08:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23312) Use -Dfast for building e2e tests on AZP - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/07/08 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23313) Reintroduce temporal table function documentation - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/07/08 11:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23314) State left behind for short lived keys - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/08 12:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23315) Bump log4j to 2.14.1 for version 1.13.2 - posted by "Guilaume Kermorgant (Jira)" <ji...@apache.org> on 2021/07/08 12:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23316) There's no test for custom PartitionCommitPolicy - posted by "Rui Li (Jira)" <ji...@apache.org> on 2021/07/08 12:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23317) Only keep the latest checkpoint in CompletedCheckpointStore - posted by "David Morávek (Jira)" <ji...@apache.org> on 2021/07/08 13:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23318) AkkaRpcActorTest#testOnStopFutureCompletionDirectlyTerminatesAkkaRpcActor fails on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/08 14:18:00 UTC, 0 replies.
- [DISCUSS] FLIP-179: Expose Standardized Operator Metrics - posted by Arvid Heise <ar...@apache.org> on 2021/07/08 14:25:22 UTC, 21 replies.
- [jira] [Created] (FLINK-23319) Support semi/anti lookup joins - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/07/08 14:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23320) Support semi/anti temporal joins - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/07/08 14:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23321) Make REST Netty thread county configurable - posted by "Nicolas Raga (Jira)" <ji...@apache.org> on 2021/07/09 00:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23322) RMQSourceITCase.testStopWithSavepoint fails on azure due to timeout - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/07/09 02:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23323) HAQueryableStateRocksDBBackendITCase failed due to heap OOM - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/07/09 03:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23324) Postgres of JDBC Connector enable case-sensitive. - posted by "Ada Wong (Jira)" <ji...@apache.org> on 2021/07/09 06:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23325) Bump flink-shaded-netty to 4.1.65 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/07/09 07:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23326) Bump flink-shaded-guava to 30.1.1 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/07/09 07:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23327) Spark Structured Streaming runner sources should be put back to main src folder - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2021/07/09 07:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23328) UDF Improvement - posted by "waywtdcc (Jira)" <ji...@apache.org> on 2021/07/09 09:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23329) Bump flink-shaded to 14.0 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/07/09 09:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23330) Deprecate toAppendStream and toRetractStream - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/07/09 09:25:00 UTC, 0 replies.
- [DISCUSS] FLIP-182: Watermark alignment - posted by Piotr Nowojski <pi...@gmail.com> on 2021/07/09 11:40:31 UTC, 5 replies.
- [jira] [Created] (FLINK-23331) FileReadingWatermarkITCase.testWatermarkEmissionWithChaining fails on Azure - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/07/09 12:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23332) Update flink-training exercises gradle version - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/07/09 13:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23333) Improve gradle setup for flink-training exercises - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/07/09 13:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23334) Move 'application' implementation decision to subprojects - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/07/09 13:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23335) Add a separate 'runSolution' gradle task - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/07/09 13:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23336) Use the same log4j version as in Flink 1.13 - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/07/09 13:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23337) Properly use the 'shadow' plugin and remove flinkShadowJar - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/07/09 13:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23338) Use Spotless for flink-training exercises as well - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/07/09 13:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23339) Disable flink-training exercises in Scala by default - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/07/09 13:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23340) Improve development instructions for flink-training exercises - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/07/09 13:26:00 UTC, 0 replies.
- [DISCUSS] FLIP-183: Dynamic buffer size adjustment - posted by "Anton,Kalashnikov" <ka...@yandex.ru> on 2021/07/09 14:48:49 UTC, 10 replies.
- [jira] [Created] (FLINK-23341) AkkaRpcActorTest.testOnStopFutureCompletionDirectlyTerminatesAkkaRpcActor fails on azure - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/07/09 16:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23342) State ownership: compute shared state on recovery - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/07/09 21:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23343) State ownership: prevent shared state deletion on TM - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/07/09 21:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23344) State ownership: track and discard private state (rocks, heap) - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/07/09 21:58:00 UTC, 0 replies.
- [RESULT] [VOTE] FLIP-172: Support custom transactional.id prefix in FlinkKafkaProducer - posted by Wenhao Ji <pr...@gmail.com> on 2021/07/10 04:23:02 UTC, 1 replies.
- Re: [DISCUSS] FLIP-172: Support custom transactional.id prefix in FlinkKafkaProducer - posted by Wenhao Ji <pr...@gmail.com> on 2021/07/10 04:35:42 UTC, 0 replies.
- Sideoutput in Flink Web Dashboard - posted by Dipanjan Mazumder <ja...@yahoo.com.INVALID> on 2021/07/11 04:29:25 UTC, 1 replies.
- [jira] [Created] (FLINK-23345) Migrate to the next version of Python `requests` when released - posted by "Jarek Potiuk (Jira)" <ji...@apache.org> on 2021/07/11 11:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23346) RocksDBStateBackend may core dump in flink_compactionfilterjni.cc - posted by "Congxian Qiu (Jira)" <ji...@apache.org> on 2021/07/11 14:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23347) Datastream operators overview refers to DataStreamStream - posted by "Mans Singh (Jira)" <ji...@apache.org> on 2021/07/11 22:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23348) Kafka At-Least-Once related IT cases are not activated - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/07/12 02:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23349) GroupWindowITCase JVM crash on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/07/12 02:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23350) Write doc for change log disorder by special operators - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/07/12 02:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23351) FileReadingWatermarkITCase.testWatermarkEmissionWithChaining fails due to "too few watermarks emitted" on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/07/12 03:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23352) Collect Sink Operator Factory does not support to configure max bytes per batch - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/07/12 03:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23353) UDTAGG can't execute in Batch mode - posted by "hayden zhou (Jira)" <ji...@apache.org> on 2021/07/12 07:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23354) Limit the size of blob cache on TaskExecutor - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2021/07/12 07:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23355) Use Flink SQL ,How to implement insert into seq to multi sinks? - posted by "Bo Wang (Jira)" <ji...@apache.org> on 2021/07/12 07:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23356) HBase delegation token expired after 7 days - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2021/07/12 08:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23358) Refactor CoreOptions parent-first patterns to List options - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/07/12 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23357) jobmanager metaspace oom - posted by "Borland Won (Jira)" <ji...@apache.org> on 2021/07/12 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23359) Fix the number of available slots in testResourceCanBeAllocatedForDifferentJobAfterFree - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2021/07/12 09:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23360) Facing broker disconnected issue while establishing Kafka with Azure Event hubs in Spring boot application #543 - posted by "Rajiya Mulani (Jira)" <ji...@apache.org> on 2021/07/12 10:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23361) After ZooKeeper sets authority, HA does not work - posted by "shouzuo meng (Jira)" <ji...@apache.org> on 2021/07/12 11:34:00 UTC, 0 replies.
- [DISCUSS] Release flink-shaded 14 - posted by Chesnay Schepler <ch...@apache.org> on 2021/07/12 12:33:25 UTC, 0 replies.
- Flink 1.14. Bi-weekly 2021-07-206 - posted by Johannes Moser <jo...@ververica.com> on 2021/07/12 14:59:53 UTC, 0 replies.
- Re: [DISCUSS]FLIP-170 Adding Checkpoint Rejection Mechanism - posted by Stephan Ewen <se...@apache.org> on 2021/07/12 17:18:11 UTC, 3 replies.
- [jira] [Created] (FLINK-23362) ClientTest.testSimpleRequests fails due to timeout on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/07/13 02:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23363) JavaCodeSplitter can not split the code from ProjectionCodeGenerator - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/07/13 02:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23364) Check all GeneratedClass to make sure they can be split by JavaCodeSplitter - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/07/13 02:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23365) flink-azure-fs-hadoop compile error because of json-smart - posted by "kevinsun (Jira)" <ji...@apache.org> on 2021/07/13 03:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23366) AkkaRpcActorTest. testOnStopFutureCompletionDirectlyTerminatesAkkaRpcActor fails on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/07/13 03:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23367) testKeyGroupedInternalPriorityQueue does not dispose rocksdb properly, and fails the test - posted by "Yuan Mei (Jira)" <ji...@apache.org> on 2021/07/13 04:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23368) Fix the wrong mapping of state cache in PyFlink - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/07/13 08:00:29 UTC, 0 replies.
- [DISCUSS] FLIP-184: Refine ShuffleMaster lifecycle management for pluggable shuffle service framework - posted by Yingjie Cao <ke...@gmail.com> on 2021/07/13 08:59:36 UTC, 0 replies.
- [jira] [Created] (FLINK-23369) Use enums for connector options - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/07/13 10:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23370) Propagate Boundedness of SourceFunctionProvider to Transformation - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/07/13 11:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23371) Disable AutoWatermarkInterval for bounded legacy sources - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/07/13 11:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23372) Disable AllVerticesInSameSlotSharingGroupByDefault in DataStream batch mode - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/07/13 12:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23373) Support object reuse disabled in OperatorChain - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/07/13 13:09:01 UTC, 0 replies.
- [DISCUSS] Address deprecation warnings when upgrading dependencies - posted by Stephan Ewen <se...@apache.org> on 2021/07/13 16:15:06 UTC, 16 replies.
- [NOTICE] flink-runtime now scala-free - posted by Chesnay Schepler <ch...@apache.org> on 2021/07/13 16:20:18 UTC, 5 replies.
- [jira] [Created] (FLINK-23374) Clean up logs produced by code splitter - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/07/14 02:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23375) Flink connector jdbc tests jar is almost empty - posted by "Maciej Bryński (Jira)" <ji...@apache.org> on 2021/07/14 06:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23376) Flink history server not showing running applications - posted by "kevinsun (Jira)" <ji...@apache.org> on 2021/07/14 06:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23377) Flink on Yarn could not set priority - posted by "HideOnBush (Jira)" <ji...@apache.org> on 2021/07/14 06:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23378) ContinuousProcessingTimeTrigger最后一个定时器无法触发 - posted by "frey (Jira)" <ji...@apache.org> on 2021/07/14 07:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23380) The parameter contains "#" and content after "#" cannot be recognized - posted by "Jacob.Q.Cao (Jira)" <ji...@apache.org> on 2021/07/14 08:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23379) interval left join null value result out of order - posted by "waywtdcc (Jira)" <ji...@apache.org> on 2021/07/14 08:15:00 UTC, 0 replies.
- [VOTE] Release 1.13.2, release candidate #2 - posted by Yun Tang <my...@LIVE.COM> on 2021/07/14 08:48:52 UTC, 1 replies.
- [jira] [Created] (FLINK-23381) Provide backpressure (currently job fails if a limit hit) - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/07/14 11:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23382) Performance regression on 13.07.2021 - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/07/14 12:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23383) FlinkEnvironmentContext#setUp is called twice - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/07/14 12:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23384) Use upper case name for all BuiltInFunctionDefinitions - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/07/14 12:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23385) org.apache.flink.table.api.TableException when using REGEXP_EXTRACT - posted by "Maciej Bryński (Jira)" <ji...@apache.org> on 2021/07/14 14:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23386) Running 'Resuming Savepoint (rocks, scale down, rocks timers) end-to-end test failed with TimeoutException when stopping with savepoint - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/14 14:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23387) WindowRankITCase.testEventTimeTumbleWindowWithoutRankNumber fails on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/14 14:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23388) Non-static Scala case classes cannot be serialised - posted by "Toby Miller (Jira)" <ji...@apache.org> on 2021/07/14 15:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23389) AWS Glue Schema Registry JSON support for Apache Flink - posted by "Kexin Hui (Jira)" <ji...@apache.org> on 2021/07/14 20:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23390) FlinkKafkaInternalProducerITCase.testResumeTransactionAfterClosed - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/07/15 02:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23391) KafkaSourceReaderTest.testKafkaSourceMetrics fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/07/15 02:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23392) Benchmarks should exclude startup/shutdown time - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/07/15 06:19:00 UTC, 0 replies.
- [VOTE] Release flink-shaded 14.0, release candidate 1 - posted by Chesnay Schepler <ch...@apache.org> on 2021/07/15 07:02:18 UTC, 3 replies.
- [jira] [Created] (FLINK-23393) Benchmarks do not support logging - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/07/15 07:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23394) Add the HbaseOptions to the configuration generator - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/07/15 08:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23395) Bump Okhttp to 3.14.9 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/07/15 08:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23396) Exception when restoring SQL job after upgrade from 1.12 to 1.13 - posted by "Maciej Bryński (Jira)" <ji...@apache.org> on 2021/07/15 09:13:00 UTC, 0 replies.
- [NOTICE] Permission mistake may have removed committer permissions - posted by Chesnay Schepler <ch...@apache.org> on 2021/07/15 09:31:32 UTC, 0 replies.
- [jira] [Created] (FLINK-23397) [DOCS] task_failure_recovery page return 404 - posted by "Dino Zhang (Jira)" <ji...@apache.org> on 2021/07/15 09:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23398) State backend benchmarks are failing - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/07/15 09:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23399) Add a benchmark for rescaling - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2021/07/15 09:39:00 UTC, 0 replies.
- [VOTE] Release 1.12.5, release candidate #2 - posted by Jingsong Li <ji...@gmail.com> on 2021/07/15 10:52:44 UTC, 1 replies.
- [jira] [Created] (FLINK-23400) Support to decode a single record for the Python coder - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/07/15 11:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23401) Separate data and timer connection into different channel - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/07/15 11:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23402) Expose a consistent GlobalDataExchangeMode - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/07/15 14:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23403) Decrease default values for heartbeat timeout and interval - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/07/15 17:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23404) function UNIX_TIMESTAMP's result incorrect when format is 'EEE MMM dd HH:mm:ss z yyyy' - posted by "alfred.zou (Jira)" <ji...@apache.org> on 2021/07/16 03:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23405) FlinkKafkaProducerMigrationOperatorTest.testRestoreProducer fails due to BindException - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/07/16 05:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23406) ClusterUncaughtExceptionHandlerITCase.testExitDueToUncaughtException fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/07/16 05:59:00 UTC, 0 replies.
- [VOTE] FLIP-184: Refine ShuffleMaster lifecycle management for pluggable shuffle service framework - posted by Yingjie Cao <ke...@gmail.com> on 2021/07/16 09:36:29 UTC, 4 replies.
- [jira] [Created] (FLINK-23407) Mechanism to document enums used for ConfigOptions - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/07/16 10:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23408) Wait for a checkpoint completed after finishing a task - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/16 10:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23409) CrossITCase fails with "NoResourceAvailableException: Slot request bulk is not fulfillable! Could not allocate the required slot within slot request timeout" - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/16 12:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23410) Use a pool of KafkaProducers to commit Kafka Transactions - posted by "Jun Qin (Jira)" <ji...@apache.org> on 2021/07/16 15:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23411) Expose Flink checkpoint details metrics - posted by "Jun Qin (Jira)" <ji...@apache.org> on 2021/07/16 15:46:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-171: Async Sink - posted by Till Rohrmann <tr...@apache.org> on 2021/07/16 16:09:16 UTC, 4 replies.
- [DISCUSS] FLIP-185: Shorter heartbeat timeout and interval default values - posted by Till Rohrmann <tr...@apache.org> on 2021/07/16 17:04:50 UTC, 10 replies.
- Introduction email - posted by Srinivasulu Punuru <sr...@gmail.com> on 2021/07/16 18:35:52 UTC, 4 replies.
- [jira] [Created] (FLINK-23412) Improve sourceSink description - posted by "Mans Singh (Jira)" <ji...@apache.org> on 2021/07/16 22:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23413) Port RelTimeIndicatorConverter from SCALA to JAVA - posted by "JING ZHANG (Jira)" <ji...@apache.org> on 2021/07/17 01:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23414) Split Match_ROWTIME return type converter into a separator class - posted by "JING ZHANG (Jira)" <ji...@apache.org> on 2021/07/17 01:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23415) Shade kryo library to reduce class conflict - posted by "Aitozi (Jira)" <ji...@apache.org> on 2021/07/17 02:26:00 UTC, 0 replies.
- Please unsubscribe me - posted by R Bhaaagi <bh...@gmail.com> on 2021/07/17 03:55:06 UTC, 0 replies.
- [jira] [Created] (FLINK-23416) Don't log NoResourceAvailableException stacktrace - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/07/17 18:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23417) MiniClusterITCase.testHandleBatchJobsWhenNotEnoughSlot fails on Azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/18 08:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23418) 'Run kubernetes application HA test' fail on Azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/18 08:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23419) CheckpointBarrierTrackerTest.testNextFirstCheckpointBarrierOvertakesCancellationBarrier fails on Azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/18 08:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23420) sql stream mode lag function java.lang.NullPointerException - posted by "xiechenling (Jira)" <ji...@apache.org> on 2021/07/19 02:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23421) Unify the space handling in RowData CSV parser - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/07/19 02:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23422) window function not support in window agg function - posted by "silence (Jira)" <ji...@apache.org> on 2021/07/19 06:42:00 UTC, 0 replies.
- [DISCUSS] FLIP-180: Adjust StreamStatus and Idleness definition - posted by Arvid Heise <ar...@apache.org> on 2021/07/19 06:53:05 UTC, 5 replies.
- Re: [DISCUSS] Definition of idle partitions - posted by Arvid Heise <ar...@apache.org> on 2021/07/19 06:57:33 UTC, 0 replies.
- Re: [DISCUSS] Watermark propagation with Sink API - posted by Arvid Heise <ar...@apache.org> on 2021/07/19 06:58:27 UTC, 0 replies.
- [DISCUSS] FLIP-177: Extend Sink API - posted by Arvid Heise <ar...@apache.org> on 2021/07/19 07:38:14 UTC, 12 replies.
- [jira] [Created] (FLINK-23423) Translate the page of "Elasticsearch Connector" into Chinese - posted by "huxixiang (Jira)" <ji...@apache.org> on 2021/07/19 07:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23424) Disable key sorting for Transformations created within table planner - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/07/19 08:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23425) The impact of cpu cores on test results for StreamingJobGraphGeneratorTest#testSlotSharingResourceConfigurationWithDefaultSlotSharingGroup - posted by "tartarus (Jira)" <ji...@apache.org> on 2021/07/19 09:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23426) Support changelog processing in batch mode - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/07/19 10:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23427) Translate the page of "Blocking Shuffle" into Chinese - posted by "Aiden Gong (Jira)" <ji...@apache.org> on 2021/07/19 11:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23428) Performance regression in state benchmarks on Jul 16 2021 - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/07/19 12:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23429) State Processor API failed with FileNotFoundException when working with state files on Cloud Storage - posted by "Jun Qin (Jira)" <ji...@apache.org> on 2021/07/19 15:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23430) Do not take snapshot for operator coordinators which all tasks finished - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/19 15:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23431) KafkaProducerExactlyOnceITCase.testMultipleSinkOperators fails with "The topic metadata failed to propagate to Kafka broker." - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/19 19:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23432) [DOCS] The 'docs/content.zh/docs/ops/state/checkpoints' page did not add a newline, which invalidated the Markdown header - posted by "wuguihu (Jira)" <ji...@apache.org> on 2021/07/20 02:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23433) Metrics cannot be initialized in format - posted by "Fangliang Liu (Jira)" <ji...@apache.org> on 2021/07/20 03:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23434) Inconsistent rowtypes occur in IncrementalAggregateRule - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/07/20 04:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23435) Improve the exception message when a query has lateral table join without 'AS' which return type is simple type - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/07/20 06:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23436) When implements the LookupFunction In SQL that indirect extends (Async)TableFunction, throw exception - posted by "吴彦祖 (Jira)" <ji...@apache.org> on 2021/07/20 08:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23437) Connection leak in XaFacadePoolingImpl - posted by "Maciej Bryński (Jira)" <ji...@apache.org> on 2021/07/20 12:16:01 UTC, 0 replies.
- [jira] [Created] (FLINK-23438) Bump httpclient from 4.5.3 to 4.5.13 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/07/20 18:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23439) Update "Local Installation" Page - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/07/20 21:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23440) The "State. Backend" of "Flink-CONF.YAML" is inconsistent with the documentation - posted by "yang89520 (Jira)" <ji...@apache.org> on 2021/07/21 02:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23441) Remove CheckpointOptions Argument away from Snapshotable#snapshot - posted by "Yuan Mei (Jira)" <ji...@apache.org> on 2021/07/21 02:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23442) FileSystemFactory refactor in flink-table-runtime - posted by "Yubin Li (Jira)" <ji...@apache.org> on 2021/07/21 02:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23443) LaunchCoordinatorTest fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/07/21 03:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23444) Slf4j 1.7.15 has the high-risk vulnerability CVE-2018-8088 - posted by "Hui Wang (Jira)" <ji...@apache.org> on 2021/07/21 03:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23445) Separate data and timer connection into different channels for Python Table API operators - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/07/21 03:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23446) Refactor SQL Client end to end tests - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/07/21 03:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23447) Bump lz4-java to 1.8 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/07/21 07:06:00 UTC, 0 replies.
- [RESULT] [VOTE] Release flink-shaded 14.0, release candidate 1 - posted by Chesnay Schepler <ch...@apache.org> on 2021/07/21 07:25:13 UTC, 0 replies.
- Flink 1.14. Bi-weekly 2021-07-20 - posted by Johannes Moser <jo...@ververica.com> on 2021/07/21 07:27:26 UTC, 1 replies.
- [jira] [Created] (FLINK-23448) Update and fix up README - posted by "Daisy Tsang (Jira)" <ji...@apache.org> on 2021/07/21 10:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23449) YarnTaskExecutorRunner does not contains MapReduce classes - posted by "Kai Chen (Jira)" <ji...@apache.org> on 2021/07/21 10:35:00 UTC, 0 replies.
- [VOTE] FLIP-183: Dynamic buffer size adjustment - posted by Anton Kalashnikov <ka...@yandex.com> on 2021/07/21 11:20:45 UTC, 3 replies.
- [VOTE] FLIP-182: Support watermark alignment of FLIP-27 Sources - posted by Piotr Nowojski <pn...@apache.org> on 2021/07/21 11:49:02 UTC, 3 replies.
- [jira] [Created] (FLINK-23450) Properties map is not set in DebeziumAvroFormatFactory - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/07/21 11:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23451) FLIP-183: Dynamic buffer size adjustment - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/07/21 12:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23452) Measuring subtask throughput - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/07/21 12:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23453) Dynamic calculation of the buffer size - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/07/21 12:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23454) Sending the buffer of the right size for unicast - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/07/21 12:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23455) Remove the usage of the yaml file in SQLJobSubmission - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/07/21 12:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23456) Manually test on cluster - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/07/21 12:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23457) Sending the buffer of the right size for broadcast - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/07/21 12:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23459) New metrics for dynamic buffer size - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/07/21 12:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23458) Document required number of buffers in the network stack - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/07/21 12:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23460) Add a global flag for enabling/disabling final checkpoints - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/21 13:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23461) Consider disallowing in-memory state handles for materialized state - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/07/21 16:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23462) Translate the abfs documentation to chinese - posted by "Srinivasulu Punuru (Jira)" <ji...@apache.org> on 2021/07/21 21:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23463) Replace the
tag with ShortCodes in document - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2021/07/22 03:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23464) Benchmarks aren't compiling - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/07/22 06:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23465) JobListener#onJobExecuted cannot be called when sql job finished - posted by "camilesing (Jira)" <ji...@apache.org> on 2021/07/22 06:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23466) UnalignedCheckpointITCase hangs on Azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/22 07:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23467) Remove the usage of the yaml file in pyflink e2e test - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/07/22 08:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23468) Benchmarks networkThroughput for OpenSSL do not run - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/22 09:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23469) StateBackendContext does not close underlying MiniCluster - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/22 09:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23470) Use blocking shuffles but pipeline within a slot - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/07/22 10:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23471) Try best to ensure all operators and state manager handle the checkpoint notification - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/07/22 10:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23472) Math functions with DECIMAL argument should return DECIMAL result - posted by "Maciej Bryński (Jira)" <ji...@apache.org> on 2021/07/22 11:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23473) Do not create transaction in TwoPhaseCommitSinkFunction after finish() - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/22 12:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23474) InputStatus should not contain END_OF_RECOVERY - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/22 12:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23475) Handle BroadcastState with finished operators - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/22 14:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23476) Snapshot deployments are broken - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/07/22 20:26:00 UTC, 0 replies.
- 退订 - posted by "wangweiguang@stevegame.cn" <wa...@stevegame.cn> on 2021/07/23 02:45:06 UTC, 0 replies.
- [jira] [Created] (FLINK-23477) wasbs/s3 FileSystem support - posted by "Harshvardhan (Jira)" <ji...@apache.org> on 2021/07/23 05:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23478) KubernetesSharedInformerITCase.testWatchWithBlockHandler fails on Azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/23 05:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23479) IncrementalAggregateJsonPlanTest.testIncrementalAggregateWithSumCountDistinctAndRetraction fail - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/23 05:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23480) about proxy-user problem - posted by "ighack (Jira)" <ji...@apache.org> on 2021/07/23 06:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23481) KubernetesSharedInformerITCase is unstable - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/07/23 07:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23482) Simplify BlinkExecutorFactory stack - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/07/23 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23483) Add document to describe how to submit job to different executor for sql client - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/07/23 08:43:00 UTC, 0 replies.
- Still receiving these emails.. please unsubscribe me - posted by R Bhaaagi <bh...@gmail.com> on 2021/07/23 09:45:03 UTC, 3 replies.
- [jira] [Created] (FLINK-23485) Add a benchmark for the Changelog DFS writer - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/07/23 11:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23484) Add a benchmark for the ChangelogStateBackend - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/07/23 11:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23486) Add monitoring/metrics for the ChangelogStateBackend - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/07/23 11:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23487) IRSA doesn't work with S3 - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/07/23 12:08:00 UTC, 0 replies.
- [VOTE] Release 1.13.2, release candidate #3 - posted by Yun Tang <my...@LIVE.COM> on 2021/07/23 14:03:43 UTC, 6 replies.
- [jira] [Created] (FLINK-23488) Please unsubscribe/remove me from jira user emails - posted by "Bhagi (Jira)" <ji...@apache.org> on 2021/07/24 01:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23489) For page deployment/cli/,the name of the configuration file is flink-conf.yaml instead of flink-config.yaml - posted by "wuguihu (Jira)" <ji...@apache.org> on 2021/07/24 06:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23490) Flink Table Example - StreamWindowSQLExample shows output in older format - posted by "Mans Singh (Jira)" <ji...@apache.org> on 2021/07/24 22:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23491) Scheduler benchmark not running - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2021/07/26 03:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23492) JobVertexThreadInfoTrackerTest.testCachedStatsCleanedAfterCleanupInterval fails on Azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/26 06:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23493) pyflink/datastream/tests/test_stream_execution_environment.py hangs on Azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/26 06:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23494) Building snapshot binary release hangs on Azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/26 06:57:00 UTC, 0 replies.
- [DISCUSS] Change Default Jira Priority from "Major" to "Minor" - posted by Konstantin Knauf <kn...@apache.org> on 2021/07/26 07:34:43 UTC, 10 replies.
- [jira] [Created] (FLINK-23495) [GCP PubSub] Make checkpoint optional for preview/staging mode - posted by "Brachi Packter (Jira)" <ji...@apache.org> on 2021/07/26 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23496) Maven snapshot build does not use MAVEN_GLOBAL_OPTIONS - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/07/26 09:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23497) flink-table-planner does not compile on scala 2.12 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/07/26 10:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23498) Use a layered configuration in Executor and Planner - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/07/26 10:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23499) ConfigurationUtils#splitPaths may split scheme from path - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/07/26 11:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23500) AkkaRpcSystemLoader fails if tmp directory does not exist - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/07/26 11:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23501) [GCP PubSub] Support add table source API for GCP PubSub - posted by "Brachi Packter (Jira)" <ji...@apache.org> on 2021/07/26 11:31:00 UTC, 0 replies.
- FW: Time windowing - posted by Ravi Sankar Reddy Sangana <Ra...@radware.com> on 2021/07/26 11:51:20 UTC, 1 replies.
- [jira] [Created] (FLINK-23502) Benchmarks use outdated flink-shaded-netty-dynamic version - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/07/26 12:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23503) csv格式数据带双引号反序列化失败 - posted by "陈磊 (Jira)" <ji...@apache.org> on 2021/07/26 15:19:00 UTC, 0 replies.
- [VOTE] Release 1.11.4, release candidate #1 - posted by godfrey he <go...@gmail.com> on 2021/07/26 15:25:27 UTC, 5 replies.
- [RESULT] [VOTE] FLIP-183: Dynamic buffer size adjustment - posted by Anton Kalashnikov <ka...@yandex.com> on 2021/07/26 15:58:46 UTC, 0 replies.
- [jira] [Created] (FLINK-23504) Rework TestingRpcService to not depend on akka - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/07/26 18:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23505) Trim down kafka-client dependency from AWS Glue module - posted by "Kexin Hui (Jira)" <ji...@apache.org> on 2021/07/27 01:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23506) word_count.py 执行错误 - posted by "zhanghw (Jira)" <ji...@apache.org> on 2021/07/27 02:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23507) The node IP obtained in NodePort mode is a VIP - posted by "john (Jira)" <ji...@apache.org> on 2021/07/27 03:38:00 UTC, 0 replies.
- [VOTE] Release 1.12.5, release candidate #3 - posted by Jingsong Li <ji...@gmail.com> on 2021/07/27 03:54:35 UTC, 8 replies.
- [jira] [Created] (FLINK-23508) HA mode cannot coexist with history server - posted by "john (Jira)" <ji...@apache.org> on 2021/07/27 06:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23509) FlinkKafkaInternalProducer overrides static final ProducerIdAndEpoch#NONE during transaction recovery (fails) - posted by "Matthias Schwalbe (Jira)" <ji...@apache.org> on 2021/07/27 06:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23510) add a new metric to show the max usage of inputExclusiveBuffer for each inputChannel - posted by "zoucao (Jira)" <ji...@apache.org> on 2021/07/27 07:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23511) Fix the location error in metric page. - posted by "zoucao (Jira)" <ji...@apache.org> on 2021/07/27 07:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23513) Remove old connectors and formats - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/07/27 07:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23512) Check for illegal modifications of JobGraph with partially finished operators - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/07/27 07:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23514) foreach exec SQL - posted by "ighack (Jira)" <ji...@apache.org> on 2021/07/27 08:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23515) I try to specify savepoint dir in my app. However, the startup task reports an error, java.lang.unsupported operationexception: the configuration is unmodifiable; its contents cannot be changed. - posted by "李伟高 (Jira)" <ji...@apache.org> on 2021/07/27 09:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23516) I try to specify savepoint dir in my app. However, the startup task reports an error, java.lang.unsupported operationexception: the configuration is unmodifiable; its contents cannot be changed. - posted by "李伟高 (Jira)" <ji...@apache.org> on 2021/07/27 09:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23517) Add messages to bannedDependencies enforcer rules - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/07/27 09:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23518) ZooKeeperLeaderElectionConnectionHandlingTest hangs on Azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/27 13:40:00 UTC, 0 replies.
- Unable to read state Witten by Beam application with Flink runner using Flink's State Processor API - posted by "Kathula, Sandeep" <Sa...@intuit.com.INVALID> on 2021/07/27 15:38:44 UTC, 1 replies.
- [jira] [Created] (FLINK-23519) Aggregate State Backend Latency by State Level - posted by "Mason Chen (Jira)" <ji...@apache.org> on 2021/07/27 16:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23520) Improve StateFun <-> DataStream Interop - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/07/27 17:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23521) flinksql - posted by "didiaode18 (Jira)" <ji...@apache.org> on 2021/07/28 02:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23522) Fix typo `TAble` -> `Table` - posted by "zhihao zhang (Jira)" <ji...@apache.org> on 2021/07/28 06:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23523) Fix typo `TAble` -> `Table` - posted by "zhihao zhang (Jira)" <ji...@apache.org> on 2021/07/28 06:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23524) AdaptiveSchedulerClusterITCase fails on Azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/28 06:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23525) Docker command fails on Azure: Exit code 137 returned from process: file name '/usr/bin/docker' - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/28 06:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23526) py36-cython: commands failed on Azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/28 06:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23527) Clarify `SourceFunction#cancel()` contract about interrupting - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/07/28 10:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23528) stop-with-savepoint can fail with FlinkKinesisConsumer - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/07/28 10:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23529) Add Flink 1.13 & 1.14 MigrationVersion - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/07/28 11:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23530) JoinITCase.testJoinOnCustomTypeInputWithKeyExtractorAndTupleInputWithKeyFieldSelector fails on Azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/28 16:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23531) Allow skip everytime change log for row-time deduplicate mini-batch - posted by "tartarus (Jira)" <ji...@apache.org> on 2021/07/29 03:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23532) Unify stop-with-savepoint w drain and w/o drain - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/29 04:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23533) Split InputSelection into public and internal parts - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/29 04:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23534) Banned dependencies in flink-statebackend-changelog - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/29 05:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23535) The value of option high-availability.cluster-id in flink-conf.yaml is replaced improperly - posted by "tim yu (Jira)" <ji...@apache.org> on 2021/07/29 05:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23536) Documentation of DeserializationSchema#deserialize is incorrect - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/07/29 05:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23537) Easy way to append metadata to deserialized row data for connector implementations - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/07/29 05:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23538) FlinkKinesisConsumer should not interrupt the legacy source thread in cancel - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/29 06:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23539) The job cannot report any metrics to influxdb when a SQL statement contains '\n' - posted by "tim yu (Jira)" <ji...@apache.org> on 2021/07/29 06:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23540) Cannot build succesfully flink runtime project - posted by "tim yu (Jira)" <ji...@apache.org> on 2021/07/29 07:37:15 UTC, 0 replies.
- [jira] [Created] (FLINK-23541) Call StreamOperator#finish on EndOfData - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/29 08:07:00 UTC, 0 replies.
- Looking for Maintainers for Flink on YARN - posted by Konstantin Knauf <kn...@apache.org> on 2021/07/29 08:15:18 UTC, 1 replies.
- [jira] [Created] (FLINK-23542) Upgrade Checkstyle to at least 8.29 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/07/29 09:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23543) Window TVF Supports session window - posted by "JING ZHANG (Jira)" <ji...@apache.org> on 2021/07/29 10:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23544) Window TVF Supports session window - posted by "JING ZHANG (Jira)" <ji...@apache.org> on 2021/07/29 10:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23545) Use new schema in SqlCreateTableConverter - posted by "jinfeng (Jira)" <ji...@apache.org> on 2021/07/29 12:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23546) stop-cluster.sh produces warning on macOS 11.4 - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/07/29 14:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23547) StateFun does not execute integration tests - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/07/29 15:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23548) Flink Session Cluster (Standalone) in Kubernetes: Exception occurred in REST handler: Could not execute application. - posted by "adis cesir (Jira)" <ji...@apache.org> on 2021/07/29 21:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23549) Kafka table connector create table example in docs has syntax error - posted by "Mans Singh (Jira)" <ji...@apache.org> on 2021/07/29 23:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23550) Supports brotli compression algorithm - posted by "rufei xing (Jira)" <ji...@apache.org> on 2021/07/30 02:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23551) Bump ORC to 1.6.9 - posted by "Dongjoon Hyun (Jira)" <ji...@apache.org> on 2021/07/30 04:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23552) Remove yaml not found log in sql-client - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/07/30 05:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23553) Trigger global failover for a synchronous savepoint failure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/30 06:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23554) SqlCli throws an exception and hang - posted by "JING ZHANG (Jira)" <ji...@apache.org> on 2021/07/30 06:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23555) Improve common subexpression elimination by using local references - posted by "weibowen (Jira)" <ji...@apache.org> on 2021/07/30 06:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23556) SQLClientSchemaRegistryITCase fails with " Subject ... not found" - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/30 07:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23557) 'Resuming Externalized Checkpoint (hashmap, sync, no parallelism change) end-to-end test' fails on Azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/30 07:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23558) E2e tests fail because of quiesced system timers service - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/30 07:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23559) Enable periodic materialisation in tests - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/07/30 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23560) Performance regression on 29.07.2021 - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/07/30 09:12:00 UTC, 0 replies.
- [VOTE] FLIP-179: Expose Standardized Operator Metrics - posted by Arvid Heise <ar...@apache.org> on 2021/07/30 10:55:02 UTC, 1 replies.
- [jira] [Created] (FLINK-23561) Detail the container completed message - posted by "zlzhang0122 (Jira)" <ji...@apache.org> on 2021/07/30 11:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23562) Update CI docker image to latest java version (1.8.0_292) - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/07/30 11:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23563) Sometimes ‘Stop’ cannot stop the job - posted by "Han Yin (Jira)" <ji...@apache.org> on 2021/07/30 11:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23564) Make taskmanager.out and taskmanager.err rollable - posted by "zlzhang0122 (Jira)" <ji...@apache.org> on 2021/07/30 11:39:00 UTC, 0 replies.
- [VOTE] FLIP-177: Extend Sink API - posted by Arvid Heise <ar...@apache.org> on 2021/07/30 12:03:44 UTC, 0 replies.
- [jira] [Created] (FLINK-23565) Window TVF Supports session window in runtime - posted by "JING ZHANG (Jira)" <ji...@apache.org> on 2021/07/30 14:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23566) Mysql 8.0 Public Key Retrieval is not allowed - posted by "MING (Jira)" <ji...@apache.org> on 2021/07/30 14:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23567) Hive 1.1.0 failed to write using flink sql 1.3.1 because the JSON class was not found - posted by "wuyang (Jira)" <ji...@apache.org> on 2021/07/31 02:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23568) Plaintext Java Keystore Password Risks in the flink-conf.yaml File - posted by "Hui Wang (Jira)" <ji...@apache.org> on 2021/07/31 03:59:00 UTC, 0 replies.
- Julia SDK for Stateful Functions - posted by Tom Breloff <to...@breloff.com> on 2021/07/31 15:29:48 UTC, 0 replies.
- [jira] [Created] (FLINK-23569) There is a spelling error in a word in the document - posted by "erick.liu (Jira)" <ji...@apache.org> on 2021/07/31 16:48:00 UTC, 0 replies.