You are viewing a plain text version of this content. The canonical link for it is here.
- [jira] [Created] (FLINK-22816) Investigate feasibility of supporting multiple RM leader sessions within JM process - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/06/01 03:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22817) About flink1.13 hive integration Kafka SQL - posted by "xingyuan cheng (Jira)" <ji...@apache.org> on 2021/06/01 06:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22818) IgnoreInFlightDataITCase fails on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/06/01 07:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22819) YARNFileReplicationITCase fails with "The YARN application unexpectedly switched to state FAILED during deployment" - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/06/01 07:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22820) Stopping Yarn session cluster will cause fatal error - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2021/06/01 07:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22821) FlinkKafkaProducerMigrationTest fails with "Address already in use" - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/06/01 07:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22822) Drop usages of legacy planner in JDBC module - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/06/01 08:14:00 UTC, 0 replies.
- Re: [DISCUSS] Dashboard/HistoryServer authentication - posted by Till Rohrmann <tr...@apache.org> on 2021/06/01 08:14:11 UTC, 38 replies.
- Re: How to use or configure flink checkpointing with siddhi internal state - posted by Till Rohrmann <tr...@apache.org> on 2021/06/01 08:17:43 UTC, 1 replies.
- [jira] [Created] (FLINK-22823) Add Basic and SPNEGO authentication support - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2021/06/01 08:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22824) Drop usages of legacy planner in Kafka modules - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/06/01 08:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22825) link sql1.13.1基于change log流数据join导致数据丢失 - posted by "徐州州 (Jira)" <ji...@apache.org> on 2021/06/01 08:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22826) link sql1.13.1基于change log流数据join导致数据丢失 - posted by "徐州州 (Jira)" <ji...@apache.org> on 2021/06/01 08:49:00 UTC, 0 replies.
- Re: The partition tracker should support remote shuffle properly - posted by Till Rohrmann <tr...@apache.org> on 2021/06/01 08:58:47 UTC, 1 replies.
- [jira] [Created] (FLINK-22827) Hive CREATE TABLE Support CLUSTERED BY - posted by "Ma Jun (Jira)" <ji...@apache.org> on 2021/06/01 09:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22828) Allow using a custom AWS credentials provider for the Kinesis Connector - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/06/01 10:02:00 UTC, 0 replies.
- Re: [DISCUSS] SQL CTAS Syntax - posted by Jingsong Li <ji...@gmail.com> on 2021/06/01 10:06:33 UTC, 0 replies.
- [jira] [Created] (FLINK-22829) Drop usages of legacy planner in Hbase modules - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/06/01 10:39:00 UTC, 0 replies.
- Getting Abstract method Error with flink 1.13.0 and 1.12.0 - posted by Dipanjan Mazumder <ja...@yahoo.com.INVALID> on 2021/06/01 11:30:46 UTC, 2 replies.
- [jira] [Created] (FLINK-22830) DataSet API to allow to collect and do the bulk upload in DB - posted by "Ravi (Jira)" <ji...@apache.org> on 2021/06/01 11:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22831) Drop usages of legacy planner in Scala shell - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/06/01 11:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22832) Drop usages of legacy planner in SQL Client - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/06/01 13:05:00 UTC, 0 replies.
- Re: recover from svaepoint - posted by Till Rohrmann <tr...@apache.org> on 2021/06/01 13:16:14 UTC, 6 replies.
- [jira] [Created] (FLINK-22833) Source tasks (both old and new) are not reporting checkpointStartDelay via CheckpointMetrics - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/06/01 14:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22834) KafkaITCase.testBigRecordJob times out on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/06/01 14:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22835) ChangelogStateBackend tests use nested backend on recovery - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/06/01 16:14:00 UTC, 0 replies.
- [VOTE] Watermark propagation with Sink API - posted by Eron Wright <ew...@streamnative.io.INVALID> on 2021/06/01 17:17:05 UTC, 13 replies.
- Re: [DISCUSS]FLIP-150: Introduce Hybrid Source - posted by Steven Wu <st...@gmail.com> on 2021/06/01 22:09:42 UTC, 8 replies.
- [jira] [Created] (FLINK-22836) OffsetsInitializerTest.testTimestampOffsetsInitializer fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/06/02 02:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22837) Assign-evenly kafkaTopicPartitions of multiple topics to flinkKafkaConsumer subtask - posted by "Xu xiaolong (Jira)" <ji...@apache.org> on 2021/06/02 02:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22838) Flink Dashboard display incorrect Version in 1.13,actual display 1.12.2 - posted by "Gao Fei (Jira)" <ji...@apache.org> on 2021/06/02 02:36:00 UTC, 0 replies.
- Re: [DISCUSS][Statebackend][Runtime] Changelog Statebackend Configuration Proposal - posted by Yun Tang <my...@live.com> on 2021/06/02 02:36:31 UTC, 3 replies.
- [jira] [Created] (FLINK-22839) Assign-evenly kafkaTopicPartitions of multiple topics to flinkKafkaConsumer subtask - posted by "Xu xiaolong (Jira)" <ji...@apache.org> on 2021/06/02 02:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22840) Assign-evenly kafkaTopicPartitions of multiple topics to flinkKafkaConsumer subtask - posted by "Xu xiaolong (Jira)" <ji...@apache.org> on 2021/06/02 02:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22841) how to update configuration of the native kubernetes deployment model flink cluster? - posted by "lukehua (Jira)" <ji...@apache.org> on 2021/06/02 02:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22842) Streaming File Sink end-to-end test fail due to not finish after 900s - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/06/02 04:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22843) Document and code are inconsistent. - posted by "xiaozilong (Jira)" <ji...@apache.org> on 2021/06/02 04:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22844) Add doc to introduce ExplainDetails for EXPLAIN sytnax - posted by "WeiNan Zhao (Jira)" <ji...@apache.org> on 2021/06/02 04:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22845) Add Basic authentication support - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2021/06/02 07:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22846) Add SPNEGO authentication support - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2021/06/02 07:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22847) SET should print options quoted - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/06/02 07:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22848) Deprecate unquoted options for SET / RESET - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/06/02 07:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22849) Drop remaining usages of legacy planner in E2E tests and Python - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/06/02 07:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22850) org.apache.flink.configuration.ConfigOptions.defaultValue() and noDefaultValue() is Deprecated. - posted by "lixiaobao (Jira)" <ji...@apache.org> on 2021/06/02 10:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22851) Add basic authentication support - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2021/06/02 10:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22852) Add SPNEGO authentication support - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2021/06/02 10:11:00 UTC, 0 replies.
- [Discuss] Planning Flink 1.14 - posted by Xintong Song <xt...@apache.org> on 2021/06/02 10:45:09 UTC, 9 replies.
- [jira] [Created] (FLINK-22853) FLinkSql聚合函数max/min/sum返回结果重复 - posted by "Raypon Wang (Jira)" <ji...@apache.org> on 2021/06/02 10:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22854) Translate 'Apache Flink Documentation' index page to Chinese - posted by "Roc Marshal (Jira)" <ji...@apache.org> on 2021/06/02 12:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22855) Translate the 'Overview of Python API' page into Chinese. - posted by "Roc Marshal (Jira)" <ji...@apache.org> on 2021/06/02 12:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22856) Move our Azure pipelines away from Ubuntu 16.04 by September - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/06/02 12:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22857) Add possibility to call built-in functions in SpecializedFunction - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/06/02 14:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22858) avro-confluent doesn't support confluent schema registry that has security enabled - posted by "TAO XIAO (Jira)" <ji...@apache.org> on 2021/06/02 15:49:00 UTC, 0 replies.
- Integrating new connector with Flink SQL. - posted by santhosh venkat <sa...@gmail.com> on 2021/06/02 21:19:16 UTC, 3 replies.
- [jira] [Created] (FLINK-22859) Wordcount on Docker test (custom fs plugin) fails due to output hash mismatch - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/06/03 01:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22860) Supplementary 'HELP' command prompt message for SQL-Cli. - posted by "Roc Marshal (Jira)" <ji...@apache.org> on 2021/06/03 02:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22861) TIMESTAMPADD + timestamp_ltz type throws CodeGenException when comparing with timestamp type - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/06/03 03:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22862) Support profiling in PyFlink - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/06/03 03:58:00 UTC, 0 replies.
- [DISCUSS] FLIP-169: DataStream API for Fine-Grained Resource Requirements - posted by Yangze Guo <ka...@gmail.com> on 2021/06/03 07:12:41 UTC, 23 replies.
- [jira] [Created] (FLINK-22863) ArrayIndexOutOfBoundsException may happen when building rescale edges - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2021/06/03 07:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22864) Remove the legacy planner code base - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/06/03 07:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22865) Optimize state serialize/deserialize in PyFlink - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/06/03 08:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22866) I need to use the current Fraud Detection example that needs flink-walkthrough-common in Python - posted by "Abeer Mohamed (Jira)" <ji...@apache.org> on 2021/06/03 13:20:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-147: Support Checkpoints After Tasks Finished - posted by Dawid Wysakowicz <dw...@apache.org> on 2021/06/03 13:21:41 UTC, 11 replies.
- [jira] [Created] (FLINK-22867) I see that there is lake of documentation in python - posted by "Abeer Mohamed (Jira)" <ji...@apache.org> on 2021/06/03 13:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22868) Update training exercises for 1.13 - posted by "David Anderson (Jira)" <ji...@apache.org> on 2021/06/03 14:05:00 UTC, 0 replies.
- Re: [DISCUSS] Watermark propagation with Sink API - posted by Piotr Nowojski <pn...@apache.org> on 2021/06/03 14:56:39 UTC, 20 replies.
- Flattening of events - posted by Satish Saley <sa...@apache.org> on 2021/06/03 18:28:54 UTC, 1 replies.
- [jira] [Created] (FLINK-22869) SQLClientSchemaRegistryITCase timeouts on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/06/04 01:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22870) Grouping sets + case when + constant string throws AssertionError - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/06/04 02:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22871) pyflink deploy support yarn application mode - posted by "konwu (Jira)" <ji...@apache.org> on 2021/06/04 03:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22872) Remove usages of legacy planner test utilities in Python - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/06/04 04:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22873) Add ToC to configuration documentation - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/06/04 08:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22874) flink table partition trigger doesn't effect as expectation when sink into hive table - posted by "Spongebob (Jira)" <ji...@apache.org> on 2021/06/04 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22875) Cannot work by Pickler and Unpickler - posted by "JYXL (Jira)" <ji...@apache.org> on 2021/06/04 09:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22876) Adding SharedObjects junit rule to ease test development - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/06/04 09:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22877) Remove BatchTableEnvironment and related API classes - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/06/04 10:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22878) Allow placeholder options in format factories - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/06/04 11:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22879) Remove "blink" suffix from table modules - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/06/04 13:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22880) Remove "blink" term in code base - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/06/04 13:16:00 UTC, 0 replies.
- Add control mode for flink - posted by 刘建刚 <li...@gmail.com> on 2021/06/04 14:09:26 UTC, 20 replies.
- [jira] [Created] (FLINK-22881) Tasks are blocked while emitting stream status - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/06/04 16:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22882) Tasks are blocked while emitting records - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/06/04 16:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22883) Select view columns fail when store metadata with hive - posted by "ELLEX_SHEN (Jira)" <ji...@apache.org> on 2021/06/05 02:40:00 UTC, 0 replies.
- 退订 - posted by lizikunn <li...@163.com> on 2021/06/05 05:08:30 UTC, 8 replies.
- [jira] [Created] (FLINK-22884) Select view columns fail when store metadata with hive - posted by "ELLEX_SHEN (Jira)" <ji...@apache.org> on 2021/06/05 06:57:00 UTC, 0 replies.
- [DISCUSS] Support specifying custom transactional.id prefix in FlinkKafkaProducer - posted by Wenhao Ji <pr...@gmail.com> on 2021/06/05 07:47:58 UTC, 2 replies.
- [jira] [Created] (FLINK-22885) Support 'SHOW COLUMNS'. - posted by "Roc Marshal (Jira)" <ji...@apache.org> on 2021/06/06 04:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22886) Thread leak in RocksDBStateUploader - posted by "Jiayi Liao (Jira)" <ji...@apache.org> on 2021/06/06 05:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22887) Backlog based optimizations for RebalancePartitioner and RescalePartitioner - posted by "Jiayi Liao (Jira)" <ji...@apache.org> on 2021/06/06 05:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22888) Matches results may be wrong when using notNext as the last part of the pattern with Window - posted by "Yue Ma (Jira)" <ji...@apache.org> on 2021/06/06 08:50:00 UTC, 0 replies.
- Job gets stuck with exactly once checkpointing and Kafka when initializing. - posted by Anil Singh <an...@neptune-ubi.com> on 2021/06/06 10:44:32 UTC, 0 replies.
- [jira] [Created] (FLINK-22889) JdbcExactlyOnceSinkE2eTest hangs on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/06/06 18:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22890) Few tests fail in HiveTableSinkITCase - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/06/06 18:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22891) FineGrainedSlotManagerDefaultResourceAllocationStrategyITCase fails on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/06/06 18:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22892) Resuming Externalized Checkpoint (rocks, incremental, scale down) end-to-end test fails - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/06/06 18:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22893) ResumeCheckpointManuallyITCase hangs on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/06/06 18:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22894) Window Top-N should allow n=1 - posted by "David Anderson (Jira)" <ji...@apache.org> on 2021/06/06 18:36:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-148: Introduce Sort-Merge Based Blocking Shuffle to Flink - posted by Yingjie Cao <ke...@gmail.com> on 2021/06/07 02:11:04 UTC, 4 replies.
- [jira] [Created] (FLINK-22895) Table common document misspelled - posted by "sujun (Jira)" <ji...@apache.org> on 2021/06/07 03:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22896) Flink sql supports parallelism at the operator level - posted by "Fangliang Liu (Jira)" <ji...@apache.org> on 2021/06/07 06:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22897) FlinkSQL1.12 Sink to Hive with diffrent parallelism will due to produce many small files - posted by "zhengjiewen (Jira)" <ji...@apache.org> on 2021/06/07 07:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22898) HiveParallelismInference limit return wrong parallelism - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/06/07 08:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22899) ValuesUpsertSinkFunction needs to use global upsert - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/06/07 08:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22900) flink 1.11.2 fileSystem source table read fileSystem sink table path multi-partition error - posted by "bigdataf (Jira)" <ji...@apache.org> on 2021/06/07 09:34:00 UTC, 0 replies.
- Re: [DISCUSS] Feedback Collection Jira Bot - posted by Arvid Heise <ar...@apache.org> on 2021/06/07 11:48:03 UTC, 17 replies.
- [jira] [Created] (FLINK-22901) Introduce getChangeLogUpsertKeys in FlinkRelMetadataQuery - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/06/07 12:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22902) Port KafkaSink to FLIP-143 - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/06/07 12:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22903) Code of method xxx of class "StreamExecCalc$1248" grows beyond 64 KB - posted by "smith jayden (Jira)" <ji...@apache.org> on 2021/06/07 13:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22904) Performance regression on 25.05.2020 in mapRebalanceMapSink - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/06/07 14:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22905) Versioned Table's SQL Script was missing a "," at Line 7 which yields Could not execute SQL statement ERROR - posted by "liuyan (Jira)" <ji...@apache.org> on 2021/06/07 14:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22906) Add build time to Flink documentation - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/06/07 14:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22907) SQL Client queries fails on select statement - posted by "Ryan Darling (Jira)" <ji...@apache.org> on 2021/06/07 17:00:03 UTC, 0 replies.
- [DISCUSS] Limit size of already processed files in File Source SplitEnumerator - posted by Tianxin Zhao <ti...@gmail.com> on 2021/06/07 22:11:06 UTC, 4 replies.
- [jira] [Created] (FLINK-22908) FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/06/08 02:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22909) Supports change log inputs for event time operators - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/06/08 03:00:00 UTC, 0 replies.
- Apply for permission to edit wiki - posted by Senhong Liu <se...@gmail.com> on 2021/06/08 03:37:04 UTC, 0 replies.
- [jira] [Created] (FLINK-22910) ShuffleMaster enhancement for pluggable shuffle service framework - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2021/06/08 04:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22911) Align FLIP-136 (Improve interoperability between DataStream and Table API) in PyFlink Table API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/06/08 05:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22912) Support state ttl in Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/06/08 05:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22913) Support Python UDF chaining in Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/06/08 06:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22914) Use Kafka New Source in Table/SQL connector - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2021/06/08 06:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22915) Extend Flink ML API to support Estimator/Transformer DAG - posted by "Dong Lin (Jira)" <ji...@apache.org> on 2021/06/08 06:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22916) Revisit and close JIRA issues around legacy planner - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/06/08 07:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22917) Dynamically change the log level of apache flink at runtime - posted by "pierrexiong (Jira)" <ji...@apache.org> on 2021/06/08 07:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22918) StreamingFileSink does not commit partition when no message is sent between checkpoints - posted by "lihe ma (Jira)" <ji...@apache.org> on 2021/06/08 08:34:00 UTC, 0 replies.
- [DISCUSS]FLIP-170 Adding Checkpoint Rejection Mechanism - posted by Senhong Liu <se...@gmail.com> on 2021/06/08 09:00:43 UTC, 3 replies.
- [jira] [Created] (FLINK-22919) Remove support for Hadoop1.x in HadoopInputFormatCommonBase.getCredentialsFromUGI - posted by "Junfan Zhang (Jira)" <ji...@apache.org> on 2021/06/08 09:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22920) Guava version conflict in flink-format module - posted by "sujun (Jira)" <ji...@apache.org> on 2021/06/08 09:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22921) SQL Client can't resolve the escape of "'" correctly. - posted by "Roc Marshal (Jira)" <ji...@apache.org> on 2021/06/08 10:15:00 UTC, 0 replies.
- How to unsubscribe? - posted by Geldenhuys, Morgan Karl <mo...@tu-berlin.de> on 2021/06/08 10:31:49 UTC, 1 replies.
- [jira] [Created] (FLINK-22922) Migrate flink website to hugo - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/06/08 11:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22923) Queryable state (rocksdb) with TM restart end-to-end test unstable - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/06/08 11:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22924) Expose create_local_environment in PyFlink - posted by "Maciej Bryński (Jira)" <ji...@apache.org> on 2021/06/08 13:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22925) "FieldDescriptor does not match message type" ERROR when use protobuf-router - posted by "Bill lee (Jira)" <ji...@apache.org> on 2021/06/08 13:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22926) IDLE source should go ACTIVE when registering a new split - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/06/08 13:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22927) Exception on JobClient.get_job_status().result() - posted by "Maciej Bryński (Jira)" <ji...@apache.org> on 2021/06/08 13:41:00 UTC, 0 replies.
- Flink 1.14. Bi-weekly 2021-06-08 - posted by Johannes Moser <jo...@data-artisans.com> on 2021/06/08 14:17:45 UTC, 1 replies.
- [DISCUSS] Definition of idle partitions - posted by Arvid Heise <ar...@apache.org> on 2021/06/08 14:34:55 UTC, 9 replies.
- [jira] [Created] (FLINK-22928) Unexpected exception happens in RecordWriter when stopping-with-savepoint - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/06/08 14:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22929) Change the default failover strategy to FixDelayRestartStrategy - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/06/08 16:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22930) [flink-python]: Resources should be closed - posted by "wuguihu (Jira)" <ji...@apache.org> on 2021/06/08 16:30:00 UTC, 0 replies.
- Request to open the contributor permission! - posted by "w.gh123" <w....@qq.com> on 2021/06/08 16:53:23 UTC, 2 replies.
- [jira] [Created] (FLINK-22931) Migrate to flink-shaded-force-shading - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/06/08 18:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22932) RocksDBStateBackendWindowITCase fails with savepoint timeout - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/06/08 19:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22933) Upgrade the Flink Fabric8io/kubernetes-client version to >=5.4.0 to be FIPS compliant - posted by "Fuyao Li (Jira)" <ji...@apache.org> on 2021/06/08 22:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22934) Add instructions for using the " ' " escape syntax of SQL client - posted by "Roc Marshal (Jira)" <ji...@apache.org> on 2021/06/09 02:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22935) Can not start standalone cluster - posted by "Lyubing Qiang (Jira)" <ji...@apache.org> on 2021/06/09 02:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22936) Support column comment in Schema and ResolvedSchema - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/06/09 02:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22937) rocksdb cause jvm to crash - posted by "Piers (Jira)" <ji...@apache.org> on 2021/06/09 04:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22938) Slot request bulk is not fulfillable! Could not allocate the required slot within slot request timeout - posted by "Bhagi (Jira)" <ji...@apache.org> on 2021/06/09 05:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22939) Generalize JDK switch in azure setup - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/06/09 05:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22940) Make SQL column max column widh configurable - posted by "Svend Vanderveken (Jira)" <ji...@apache.org> on 2021/06/09 06:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22941) support column comment in catalogTable column schema - posted by "peng wang (Jira)" <ji...@apache.org> on 2021/06/09 07:36:00 UTC, 0 replies.
- [DISCUSS] FLIP-171: Async Sink - posted by "Hausmann, Steffen" <sh...@amazon.de.INVALID> on 2021/06/09 07:48:44 UTC, 0 replies.
- State migration scenario's - posted by Marlo Ploemen <ma...@icloud.com.INVALID> on 2021/06/09 07:57:55 UTC, 2 replies.
- [jira] [Created] (FLINK-22942) Disable upsert into syntax in Flink SQL - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2021/06/09 08:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22943) java.lang.ClassCastException: java.time.Instant cannot be cast to java.sql.Timestamp - posted by "jack wang (Jira)" <ji...@apache.org> on 2021/06/09 09:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22944) Optimize writing state changes - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/06/09 10:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22945) StackOverflowException can happen when a large scale job is CANCELED/FAILED - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2021/06/09 11:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22946) Network buffer deadlock introduced by unaligned checkpoint - posted by "Guokuai Huang (Jira)" <ji...@apache.org> on 2021/06/09 11:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22947) Reduce DataSet visibility in documentation - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/06/09 14:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22948) Scala example for toDataStream does not compile - posted by "David Anderson (Jira)" <ji...@apache.org> on 2021/06/09 14:40:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-171: Async Sink - posted by Piotr Nowojski <pn...@apache.org> on 2021/06/09 17:24:23 UTC, 12 replies.
- [jira] [Created] (FLINK-22949) java.io.InvalidClassException With Flink Kafka Beam - posted by "Ravikiran Borse (Jira)" <ji...@apache.org> on 2021/06/09 18:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22950) Back-pressure report final sink operator is not accurate - posted by "Fu Kai (Jira)" <ji...@apache.org> on 2021/06/10 02:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22951) First parameter of ROW() function must be constant - posted by "Fu Kai (Jira)" <ji...@apache.org> on 2021/06/10 02:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22952) docs_404_check fail on azure due to ruby version not available - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/06/10 02:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22953) Using Types.LIST(Types.STRING()) in datastream result in crash - posted by "awayne (Jira)" <ji...@apache.org> on 2021/06/10 02:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22954) Don't support consuming update and delete changes when use table function that does not contain table field - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2021/06/10 03:21:00 UTC, 0 replies.
- 1 - posted by fengcheng <53...@qq.com> on 2021/06/10 03:32:27 UTC, 0 replies.
- [jira] [Created] (FLINK-22955) lookup join filter push down result to mismatch function signature - posted by "Cooper Luan (Jira)" <ji...@apache.org> on 2021/06/10 04:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22957) Rank TTL should use enableTimeToLive of state instead of timer - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/06/10 04:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22956) Stream Over TTL should use enableTimeToLive of state instead of timer - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/06/10 04:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22958) Reused content in docs causes confusing navigation jumps - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/06/10 06:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22959) Keep the job jar files on JobManager - posted by "lukehua (Jira)" <ji...@apache.org> on 2021/06/10 08:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22960) Temporal join TTL should use enableTimeToLive of state instead of timer - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/06/10 08:50:00 UTC, 0 replies.
- [VOTE] FLIP-129 (Update): Registering sources/sinks on Table API without SQL - posted by Ingo Bürk <in...@ververica.com> on 2021/06/10 10:02:35 UTC, 2 replies.
- [jira] [Created] (FLINK-22961) Incorrect calculation of alignment timeout for LocalInputChannel - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/06/10 10:39:00 UTC, 0 replies.
- [DISCUSS] FLIP-129 (Update): Registering sources/sinks on Table API without SQL - posted by Ingo Bürk <in...@ververica.com> on 2021/06/10 11:45:17 UTC, 3 replies.
- [jira] [Created] (FLINK-22962) Key group is not in KeyGroupRange error while checkpointing - posted by "Prateek Kohli (Jira)" <ji...@apache.org> on 2021/06/10 12:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22963) The description of taskmanager.memory.task.heap.size in the official document is incorrect - posted by "JasonLee (Jira)" <ji...@apache.org> on 2021/06/10 14:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22964) Connector-base exposes dependency to flink-core. - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/06/10 14:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22965) Association with remote system has failed, address is now gated - posted by "Bhagi (Jira)" <ji...@apache.org> on 2021/06/10 16:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22966) NPE in StateAssignmentOperation when rescaling - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/06/10 17:09:00 UTC, 0 replies.
- Flink TM Heartbeat Timeout - posted by Lu Niu <qq...@gmail.com> on 2021/06/10 17:32:48 UTC, 2 replies.
- [jira] [Created] (FLINK-22967) CodeGenException: Unsupported cast for nested Decimals - posted by "Maciej Bryński (Jira)" <ji...@apache.org> on 2021/06/10 18:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22968) String type cannot be used when creating Flink SQL - posted by "DaChun (Jira)" <ji...@apache.org> on 2021/06/11 01:19:00 UTC, 0 replies.
- Question About 'SHOW COLUMNS' statement in SQL - posted by Roc Marshal <fl...@126.com> on 2021/06/11 02:41:48 UTC, 0 replies.
- [jira] [Created] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/06/11 02:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22970) The documentation for `TO_TIMESTAMP` UDF has an incorrect description - posted by "Wei-Che Wei (Jira)" <ji...@apache.org> on 2021/06/11 05:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22971) Initialization of Testcontainers unstable on Azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/06/11 07:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22972) Deprecate/Remove StreamOperator#dispose method - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/06/11 07:49:00 UTC, 0 replies.
- [DISCUSS] Lifecycle of ShuffleMaster and its Relationship with JobMaster and PartitionTracker - posted by Yingjie Cao <ke...@gmail.com> on 2021/06/11 08:14:47 UTC, 0 replies.
- [jira] [Created] (FLINK-22973) Provide benchmark for unaligned checkpoints performance - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/06/11 08:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22974) No execution checkpointing config desc in flink-conf.yaml - posted by "tinawenqiao (Jira)" <ji...@apache.org> on 2021/06/11 09:16:00 UTC, 0 replies.
- Re: [table-walkthrough] docker-compose build issues - posted by Lingfeng Pu <pu...@mtu.edu> on 2021/06/11 09:20:02 UTC, 0 replies.
- [jira] [Created] (FLINK-22975) Specify port or range for k8s service - posted by "Jun Zhang (Jira)" <ji...@apache.org> on 2021/06/11 11:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22976) Whether to consider adding config-option to control whether to exclude record.key value from record.value value - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2021/06/11 11:16:00 UTC, 0 replies.
- Output from RichAsyncFunction on failure - posted by Satish Saley <sa...@apache.org> on 2021/06/11 17:40:56 UTC, 2 replies.
- [DISCUSS] FLIP-172: Support custom transactional.id prefix in FlinkKafkaProducer - posted by Wenhao Ji <pr...@gmail.com> on 2021/06/12 07:49:30 UTC, 4 replies.
- [jira] [Created] (FLINK-22977) jobmanager.rpc.addresss does not support hostname with an underscore - posted by "Nikesh Hajari (Jira)" <ji...@apache.org> on 2021/06/14 02:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22978) Flink Maintenance activities Documentation and Testcases for maintainance - posted by "Bhagi (Jira)" <ji...@apache.org> on 2021/06/14 06:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22979) JobMasterExecutionDeploymentReconciliationTest error while setting up logger - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/06/14 07:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22980) FileExecutionGraphInfoStoreTest hangs on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/06/14 07:25:02 UTC, 0 replies.
- [jira] [Created] (FLINK-22981) FlinkKafkaProducerMigrationTest.testRestoreProducer fail with timeout - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/06/14 07:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22982) java.lang.ClassCastException when using Python UDF - posted by "Maciej Bryński (Jira)" <ji...@apache.org> on 2021/06/14 13:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22983) Support lazy evaluation in Flink SQL - posted by "Maciej Bryński (Jira)" <ji...@apache.org> on 2021/06/14 13:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22984) UnsupportedOperationException when using Python UDF to generate watermark - posted by "Maciej Bryński (Jira)" <ji...@apache.org> on 2021/06/14 19:55:00 UTC, 0 replies.
- Got multiple issues when running the tutorial project "table-walkthrough" on IDEA - posted by Lingfeng Pu <pu...@mtu.edu> on 2021/06/15 02:29:18 UTC, 1 replies.
- Security Vulnerabilities with Flink OpenJDK Docker Image - posted by Daniel Moore <da...@sugarcrm.com.INVALID> on 2021/06/15 02:32:56 UTC, 0 replies.
- [jira] [Created] (FLINK-22985) sql syntax, NullPointerException - posted by "simenliuxing (Jira)" <ji...@apache.org> on 2021/06/15 03:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22986) FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown hangs on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/06/15 03:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22987) Scala suffix check isn't working - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/06/15 06:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22988) Port TestingUtils to Java - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/06/15 06:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22989) Port Tasks to Java - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/06/15 06:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22990) Remove unused ScalaUtils/TestingMessages - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/06/15 06:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22991) Use Optional in NetworkBufferPool - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/06/15 06:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22992) Move SSLUtils#is*Enabled to SecurityOptions - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/06/15 06:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22993) CompactFileWriter won't emit EndCheckpoint with Long.MAX_VALUE checkpointId - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2021/06/15 06:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22994) Improve the performance of invoking nesting udf - posted by "lynn1.zhang (Jira)" <ji...@apache.org> on 2021/06/15 07:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22995) Failed to acquire lease 'ConfigMapLock: .... retrying... - posted by "Bhagi (Jira)" <ji...@apache.org> on 2021/06/15 08:17:00 UTC, 0 replies.
- Apply for FLIP Wiki Page Edit Permission - posted by Roc Marshal <fl...@126.com> on 2021/06/15 08:17:09 UTC, 1 replies.
- [VOTE] FLIP-169: DataStream API for Fine-Grained Resource Requirements - posted by Yangze Guo <ka...@gmail.com> on 2021/06/15 08:56:22 UTC, 7 replies.
- [jira] [Created] (FLINK-22996) The description about coalesce is wrong - posted by "lothar (Jira)" <ji...@apache.org> on 2021/06/15 09:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22997) Replace AkkaUtils#get*Timeout* - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/06/15 10:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22998) Flink SQL does not support block comment before SET command - posted by "Zhiwen Sun (Jira)" <ji...@apache.org> on 2021/06/15 10:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22999) Using the column 'user' in Table API is not possible - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/06/15 12:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23000) Allow downloading all Flink logs from the UI - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/06/15 13:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23001) flink-avro-glue-schema-registry lacks scala suffix - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/06/15 15:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23002) C# SDK for Stateful Functions - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2021/06/15 15:56:00 UTC, 0 replies.
- Re: [DISCUSS] Moving to JUnit5 - posted by Arvid Heise <ar...@ververica.com> on 2021/06/15 19:13:17 UTC, 4 replies.
- [jira] [Created] (FLINK-23003) resource leak in RocksIncrementalSnapshotStrategy - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2021/06/16 02:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23004) Fix misleading log - posted by "Junfan Zhang (Jira)" <ji...@apache.org> on 2021/06/16 03:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23005) Optimize the deployment of tasks - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2021/06/16 03:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23006) issue in configuring History server - posted by "Bhagi (Jira)" <ji...@apache.org> on 2021/06/16 06:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23007) Introduce java code splitter to split generated code - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/06/16 07:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23008) Upload file not exist when submit job use RestClient - posted by "YufeiLiu (Jira)" <ji...@apache.org> on 2021/06/16 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23009) Bump up Guava in Kinesis Connector - posted by "Emre Kartoglu (Jira)" <ji...@apache.org> on 2021/06/16 08:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23010) HivePartitionFetcherContextBase::getComparablePartitionValueList can return partitions that don't exist - posted by "Rui Li (Jira)" <ji...@apache.org> on 2021/06/16 09:00:00 UTC, 0 replies.
- [ANNOUNCE] New PMC member: Arvid Heise - posted by Dawid Wysakowicz <dw...@apache.org> on 2021/06/16 09:21:24 UTC, 27 replies.
- [ANNOUNCE] New PMC member: Xintong Song - posted by Dawid Wysakowicz <dw...@apache.org> on 2021/06/16 09:23:08 UTC, 29 replies.
- Unsubscribe Dev-Mail - posted by 雒正林 <lu...@163.com> on 2021/06/16 10:04:30 UTC, 1 replies.
- [jira] [Created] (FLINK-23011) FLIP-27 sources are generating non-deterministic results when using event time - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/06/16 10:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23012) Add v1.13 docs link in "Pick Docs Version" for master branch - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/06/17 02:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23013) Introduce faker source connector - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/06/17 03:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23014) Support streaming window Deduplicate in planner - posted by "JING ZHANG (Jira)" <ji...@apache.org> on 2021/06/17 03:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23015) Implement streaming window Deduplicate operator - posted by "JING ZHANG (Jira)" <ji...@apache.org> on 2021/06/17 03:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23016) Job client must be a Coordination Request Gateway when submit a job on web ui - posted by "wen qi (Jira)" <ji...@apache.org> on 2021/06/17 06:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23017) HELP in sql-client still shows the removed SOURCE functionality - posted by "Daniel Lenz (Jira)" <ji...@apache.org> on 2021/06/17 08:13:00 UTC, 0 replies.
- 来自chenxuying的邮件 - posted by chenxuying <cx...@163.com> on 2021/06/17 08:21:43 UTC, 1 replies.
- [jira] [Created] (FLINK-23018) TTL state factory should handle extended state descriptors - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/06/17 08:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23019) Avoid errors when identifiers use reserved keywords - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/06/17 08:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23020) NullPointerException when running collect from Python API - posted by "Maciej Bryński (Jira)" <ji...@apache.org> on 2021/06/17 09:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23021) Check if the restarted job topology is consistent on restart - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/06/17 10:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23022) Plugin classloader settings do not work as described - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/06/17 11:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23023) Support offset in window TVF - posted by "JING ZHANG (Jira)" <ji...@apache.org> on 2021/06/17 13:02:00 UTC, 0 replies.
- join example in batch mode using DataStream API - posted by Etienne Chauchot <ec...@apache.org> on 2021/06/17 13:04:53 UTC, 0 replies.
- Assign-evenly kafkaTopicPartitions of multiple topics to flinkKafkaConsumer subtask - posted by 徐小龙 <xi...@163.com> on 2021/06/17 13:41:44 UTC, 0 replies.
- [jira] [Created] (FLINK-23024) RPC result TaskManagerInfoWithSlots not serializable - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/06/17 14:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23025) sink-buffer-max-rows and sink-buffer-flush-interval options produce a lot of duplicates - posted by "Johannes Moser (Jira)" <ji...@apache.org> on 2021/06/17 15:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23026) OVER WINDOWS function lost data - posted by "MOBIN (Jira)" <ji...@apache.org> on 2021/06/18 03:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23027) Move chill dependency to flink-scala - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/06/18 06:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23028) Improve documentation for pages of SQL. - posted by "Roc Marshal (Jira)" <ji...@apache.org> on 2021/06/18 06:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23029) Extend PluginLoader to allow closing of backing ClassLoader - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/06/18 06:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23030) PartitionRequestClientFactory#createPartitionRequestClient should throw when network failure - posted by "Jin Xing (Jira)" <ji...@apache.org> on 2021/06/18 07:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23031) Support to emit window result with periodic or non_periodic - posted by "Aitozi (Jira)" <ji...@apache.org> on 2021/06/18 07:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23032) Refactor HiveSource to make it usable in data stream job - posted by "Rui Li (Jira)" <ji...@apache.org> on 2021/06/18 09:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23033) Support object array in Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/06/18 10:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23034) NPE in JobDetailsDeserializer during the reading old version of ExecutionState - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/06/18 12:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23035) Add explicit method to StateChangelogWriter to write metadata - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/06/18 12:45:00 UTC, 0 replies.
- Change in accumutors semantics with jobClient - posted by Etienne Chauchot <ec...@apache.org> on 2021/06/18 12:45:27 UTC, 4 replies.
- [jira] [Created] (FLINK-23037) Document limitations of UC - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/06/18 12:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23036) org.apache.flink.util.FlinkRuntimeException: Error while adding data to RocksDB - posted by "guxiang (Jira)" <ji...@apache.org> on 2021/06/18 12:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23038) Broken link in Documentation Style Guide - posted by "Daisy Tsang (Jira)" <ji...@apache.org> on 2021/06/18 13:14:01 UTC, 0 replies.
- [jira] [Created] (FLINK-23039) Support pluggable transports for HTTP endpoints - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/06/18 13:18:00 UTC, 0 replies.
- [DISCUSS] Releasing Flink 1.11.4, 1.12.5, 1.13.2 - posted by Dawid Wysakowicz <dw...@apache.org> on 2021/06/18 13:26:34 UTC, 12 replies.
- [jira] [Created] (FLINK-23040) Consider ConfigOption fallback keys in FactoryUtil - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/06/18 14:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23041) Change local alignment timeout back to the global time out - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/06/18 15:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23042) Flink Chinese docs Fraud Detection with the DataStream API page picture display issue - posted by "kevin (Jira)" <ji...@apache.org> on 2021/06/20 04:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23043) Wrong master address displayed when run application in native K8s with -Dkubernetes.rest-service.exposed.type=NodePort - posted by "Shang Yuanchun (Jira)" <ji...@apache.org> on 2021/06/20 05:21:00 UTC, 0 replies.
- [DISCUSS] FLIP-168: Speculative execution for Batch Job - posted by wa...@sina.cn on 2021/06/20 14:35:15 UTC, 0 replies.
- [jira] [Created] (FLINK-23044) fix typos in docs - posted by "Huang Yu (Jira)" <ji...@apache.org> on 2021/06/21 02:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23045) RunnablesTest.testExecutorService_uncaughtExceptionHandler fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/06/21 02:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23046) OperatorEventSendingCheckpointITCase.testOperatorEventLostNoReaderFailure fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/06/21 02:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23047) CassandraConnectorITCase.testCassandraBatchTupleFormat fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/06/21 02:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23048) GroupWindowITCase.testEventTimeSlidingGroupWindowOverTimeNonOverlappingSplitPane fails due to akka timeout - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/06/21 02:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23049) UnalignedCheckpointCompatibilityITCase hangs on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/06/21 02:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23050) Add Chinese version of documentation of unaligned checkpoint - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/06/21 03:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23051) Savepoint an application for source of cdc-kafka, then restart the application from the savepoint, offset not be recovered. - posted by "Carl (Jira)" <ji...@apache.org> on 2021/06/21 03:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23052) cron_snapshot_deployment_maven unstable on maven - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/06/21 03:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23053) Translate "DataSet Transformations" pages into Chinese - posted by "Zhiliang Zhang (Jira)" <ji...@apache.org> on 2021/06/21 06:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23054) Correct upsert optimization by upsert keys - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/06/21 07:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23055) Add document for Window TVF offset - posted by "JING ZHANG (Jira)" <ji...@apache.org> on 2021/06/21 07:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23056) flink docs sql builtin functions out of date - posted by "Junhan Yang (Jira)" <ji...@apache.org> on 2021/06/21 08:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23057) flink-console.sh doesn't do variable expansion for FLINK_ENV_JAVA_OPTS like flink-daemon.sh - posted by "LIU Xiao (Jira)" <ji...@apache.org> on 2021/06/21 09:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23058) flink-elasticsearch-6 not work - posted by "yandufeng (Jira)" <ji...@apache.org> on 2021/06/21 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23059) Update playgrounds for Flink 1.13 - posted by "David Anderson (Jira)" <ji...@apache.org> on 2021/06/21 09:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23060) Move FutureUtils.toJava into separate class - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/06/21 10:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23061) Split BootstrapTools - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/06/21 10:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23062) FLIP-129: Register sources/sinks in Table API - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/06/21 10:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23063) Remove TableEnvironment#connect - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/06/21 10:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23065) Implement TableEnvironment#createTemporaryTable - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/06/21 10:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23064) Centralize connector options - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/06/21 10:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23067) Implement Table#executeInsert(TableDescriptor) - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/06/21 10:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23066) Implement TableEnvironment#from - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/06/21 10:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23069) Support schema-less #executeInsert(TableDescriptor) - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/06/21 10:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23068) Support LIKE in TableDescriptor - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/06/21 10:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23070) Implement TableEnvironment#createTable - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/06/21 10:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23071) Implement StatementSet#addInsert(TableDescriptor, Table) - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/06/21 11:08:00 UTC, 0 replies.
- [VOTE] FLIP-129 Register sources/sinks in Table API - posted by Ingo Bürk <in...@ververica.com> on 2021/06/21 11:24:14 UTC, 5 replies.
- [jira] [Created] (FLINK-23072) Add benchmarks for SQL internal and external serializers - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/06/21 13:55:00 UTC, 0 replies.
- PR: "Propagate watermarks to sink API" - posted by Eron Wright <ew...@streamnative.io.INVALID> on 2021/06/21 18:18:15 UTC, 1 replies.
- [jira] [Created] (FLINK-23073) Fix space handling in CSV timestamp parser - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/06/21 18:37:00 UTC, 0 replies.
- trying (and failing) to update pyflink-walkthrough for Flink 1.13 - posted by David Anderson <da...@apache.org> on 2021/06/21 20:06:10 UTC, 1 replies.
- [jira] [Created] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet - posted by "Ada Wong (Jira)" <ji...@apache.org> on 2021/06/22 02:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23075) Python API for enabling ChangelogStateBackend - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2021/06/22 03:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23076) DispatcherTest.testWaitingForJobMasterLeadership fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/06/22 03:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23077) Running nexmark q5 with 1.13.1 of pipeline.object-reuse=true, the taskmanager will be killed and produce failover. - posted by "xiaojin.wy (Jira)" <ji...@apache.org> on 2021/06/22 03:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23078) Scheduler Benchmarks not compiling - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/06/22 06:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23079) HiveTableSinkITCase fails - posted by "JING ZHANG (Jira)" <ji...@apache.org> on 2021/06/22 06:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23080) Add finish method to the SinkFunction - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/06/22 06:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23081) Move Executors#directExecutorContext to AkkaFutureUtils - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/06/22 07:46:00 UTC, 0 replies.
- [DISCUSS] Drop Mesos in 1.14 - posted by Chesnay Schepler <ch...@apache.org> on 2021/06/22 08:29:36 UTC, 13 replies.
- [jira] [Created] (FLINK-23082) Split AkkaRpcServiceUtils - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/06/22 08:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23083) Isolate RpcConnectionTest from runtime implementations - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/06/22 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23084) Move ExecutorThreadFactory to flink-core - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/06/22 08:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23085) Consolidate FutureUtils to flink-core - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/06/22 08:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23086) Add getRuntimeExecutionMode to StreamExecutionEnvironment - posted by "Shuo Cheng (Jira)" <ji...@apache.org> on 2021/06/22 08:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23087) AddressResolution should be a top-level class - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/06/22 08:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23088) Add flink-rpc-core module - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/06/22 08:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23089) Add flink-rpc-akka module - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/06/22 08:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23090) Add RpcSystem abstraction - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/06/22 08:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23091) Bump Akka to 2.6 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/06/22 09:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23092) Fix built-in functions are unsupported in Python Group Window UDAF - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/06/22 09:11:00 UTC, 0 replies.
- [DISCUSS] Do not merge PRs with "unrelated" test failures. - posted by Xintong Song <to...@gmail.com> on 2021/06/22 09:12:07 UTC, 28 replies.
- [jira] [Created] (FLINK-23093) Limit number of I/O pool and Future threads in Mini Cluster - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2021/06/22 11:46:00 UTC, 0 replies.
- [VOTE] FLIP-171: Async Sink - posted by "Hausmann, Steffen" <sh...@amazon.de.INVALID> on 2021/06/22 12:28:03 UTC, 4 replies.
- [jira] [Created] (FLINK-23094) encounter thread-safe problem when using StreamExecutionEnvironment#initializeContextEnvironment in multiple-threads environment - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/06/22 12:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23095) Close the channel unspilling thread pool after restore - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/06/22 12:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23096) HiveParser could not attach the sessionstate of hive - posted by "shizhengchao (Jira)" <ji...@apache.org> on 2021/06/22 13:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23097) 'Queryable state (rocksdb) with TM restart end-to-end test' fails on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/06/22 14:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23098) Update operations playground for 1.13 - posted by "David Anderson (Jira)" <ji...@apache.org> on 2021/06/22 14:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23099) Update table walkthrough playground for 1.13 - posted by "David Anderson (Jira)" <ji...@apache.org> on 2021/06/22 14:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23100) Update pyflink walkthrough playground for 1.13 - posted by "David Anderson (Jira)" <ji...@apache.org> on 2021/06/22 14:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23101) Flame Graphs initial view says it is 18800 days in the past - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/06/22 15:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23102) Accessing FlameGraphs while not being enabled returns an exception - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/06/22 15:40:00 UTC, 0 replies.
- Migration to akka 2.6 - posted by Etienne Chauchot <ec...@apache.org> on 2021/06/22 16:16:37 UTC, 1 replies.
- [jira] [Created] (FLINK-23103) Provide Inteceptor for connector - posted by "lqjacklee (Jira)" <ji...@apache.org> on 2021/06/22 16:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23104) flink-statebackend-changelog does not build with scala 2.12 - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/06/23 02:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23105) YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/06/23 02:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23106) RetractableTopNFunction should send retract first and then send insert - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/06/23 04:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23107) Separate deduplicate rank from rank functions - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/06/23 04:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23108) KafkaITCase.testCancelingEmptyTopic fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/06/23 06:06:00 UTC, 0 replies.
- CONTENTS DELETED in nabble frontend - posted by Matthias Pohl <ma...@ververica.com> on 2021/06/23 06:16:17 UTC, 5 replies.
- [jira] [Created] (FLINK-23109) Translate "Scala API Extensions" pages into Chinese - posted by "Zhiliang Zhang (Jira)" <ji...@apache.org> on 2021/06/23 06:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23110) Modernize Flink UI - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/06/23 06:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23111) Update Angular - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/06/23 06:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23112) Formatting should be enforced for Flink UI - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/06/23 06:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23113) Linting for Flink UI - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/06/23 06:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23114) Address vulnerabilities in Flink UI - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/06/23 06:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23116) Update documentation about TableDescriptors - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/06/23 07:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23115) Expose new APIs from PyFlink - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/06/23 07:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23117) TaskExecutor.allocateSlot is a logical error - posted by "zhouzhengde (Jira)" <ji...@apache.org> on 2021/06/23 07:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23118) Drop mesos - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/06/23 08:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23119) Fix the issue that the exception that General Python UDAF is unsupported is not thrown in Compile Stage. - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/06/23 08:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23120) ByteArrayWrapperSerializer.serialize should use writeInt to serialize the length - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/06/23 09:00:12 UTC, 0 replies.
- [jira] [Created] (FLINK-23121) Fix the issue that the InternalRow as arguments in Python UDAF - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/06/23 10:03:00 UTC, 0 replies.
- [DISCUSS] Incrementally deprecating the DataSet API - posted by Timo Walther <tw...@apache.org> on 2021/06/23 10:23:11 UTC, 3 replies.
- [jira] [Created] (FLINK-23122) Provide the Dynamic register converter - posted by "lqjacklee (Jira)" <ji...@apache.org> on 2021/06/23 12:52:00 UTC, 0 replies.
- [DISCUSS] [FLINK-23122] Provide the Dynamic register converter - posted by 云华 <yu...@dtstack.com> on 2021/06/23 13:09:29 UTC, 1 replies.
- [jira] [Created] (FLINK-23123) Implement at-least-once Kafka Sink - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/06/23 14:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23124) Implement exactly-once Kafka Sink - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/06/23 14:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23125) Run StateFun smoke E2E tests for multiple language SDKs - posted by "Evans Ye (Jira)" <ji...@apache.org> on 2021/06/23 16:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23126) Refactor smoke-e2e into smoke-e2e-common and smoke-e2e-embedded - posted by "Evans Ye (Jira)" <ji...@apache.org> on 2021/06/23 16:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23127) Can't use plugins for GCS filesystem - posted by "Yaroslav Tkachenko (Jira)" <ji...@apache.org> on 2021/06/23 16:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23128) Translate update to operations playground docs to Chinese - posted by "David Anderson (Jira)" <ji...@apache.org> on 2021/06/23 19:00:05 UTC, 0 replies.
- [jira] [Created] (FLINK-23129) When cancelling any running job of multiple jobs in an application cluster, JobManager shuts down - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/06/23 20:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23130) RestServerEndpoint references on netty 3 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/06/23 20:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23131) Remove scala from plugin parent-first patterns - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/06/23 21:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23132) flink upgrade issue(1.11.3->1.13.0) - posted by "Jeff Hu (Jira)" <ji...@apache.org> on 2021/06/24 02:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23133) The dependencies are not handled properly when mixing use of Python Table API and Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/06/24 06:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23134) add URL decode for metric rest - posted by "tartarus (Jira)" <ji...@apache.org> on 2021/06/24 07:10:01 UTC, 0 replies.
- [jira] [Created] (FLINK-23135) Error while applying rule AggregateReduceGroupingRule - posted by "zhengjiewen (Jira)" <ji...@apache.org> on 2021/06/24 07:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23136) Make `addSource` method with specific boundedness in `StreamExecutionEnvironment` public - posted by "Shuo Cheng (Jira)" <ji...@apache.org> on 2021/06/24 07:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23137) State ownership: disable discarding state of ChangelogStateBackendHandle on JM - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/06/24 07:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23138) Raise an exception if types other than PickledBytesTypeInfo are specified for state descriptor - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/06/24 07:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23139) State ownership: track and discard state (materialized and non-materialized) - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/06/24 07:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23140) Invalid link in Data Sources documentation - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/06/24 08:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23141) Support KafkaSerializationSchema in Kafka connector for Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/06/24 09:52:00 UTC, 0 replies.
- [DISCUSS] Releasing Flink 1.12.5 - posted by Jingsong Li <ji...@gmail.com> on 2021/06/24 09:53:27 UTC, 3 replies.
- [jira] [Created] (FLINK-23142) UpdatableTopNFunction output wrong order in the same unique key - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/06/24 11:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23143) Support state migration - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/06/24 11:43:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-129 Register sources/sinks in Table API - posted by Ingo Bürk <in...@ververica.com> on 2021/06/24 12:00:38 UTC, 0 replies.
- 回复:[DISCUSS] [FLINK-23122] Provide the Dynamic register converter - posted by 云华 <yu...@dtstack.com> on 2021/06/24 12:19:25 UTC, 1 replies.
- [jira] [Created] (FLINK-23144) Add percentiles to checkpoint stats - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/06/24 12:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23145) TIMESTAMP_WITH_TIME_ZONE support - posted by "lqjacklee (Jira)" <ji...@apache.org> on 2021/06/24 13:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23146) Data cannot be consumed when upsert Kafka is used as the source - posted by "JasonLee (Jira)" <ji...@apache.org> on 2021/06/24 15:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23147) ThreadPools can be poisoned by context class loaders - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/06/24 18:33:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-169: DataStream API for Fine-Grained Resource Requirements - posted by Yangze Guo <ka...@gmail.com> on 2021/06/25 02:00:37 UTC, 0 replies.
- [jira] [Created] (FLINK-23148) flink-mesos does not build with scala 2.12 - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/06/25 02:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23149) Introduce Java code splitter for code generation - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/06/25 02:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23150) Clean up the old implementation of code splitting - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/06/25 02:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23151) KinesisTableApiITCase.testTableApiSourceAndSink fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/06/25 03:24:00 UTC, 0 replies.
- 回复:回复:[DISCUSS] [FLINK-23122] Provide the Dynamic register converter - posted by 云华 <yu...@dtstack.com> on 2021/06/25 03:41:10 UTC, 0 replies.
- [jira] [Created] (FLINK-23152) Flink - {"errors":["Service temporarily unavailable due to an ongoing leader election. Please refresh."]} - posted by "liu zhuang (Jira)" <ji...@apache.org> on 2021/06/25 04:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23153) Benchmark not compiling - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2021/06/25 06:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23154) Fix Python PackagedProgramRetrieverImplTest implementations - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/06/25 06:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23155) Streaming File Sink s3 end-to-end test fail on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/06/25 06:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23156) Change the reference of 'docs/dev/table/sql/queries' - posted by "zoucao (Jira)" <ji...@apache.org> on 2021/06/25 07:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23157) Fix missing comma in SQL example in "Versioned Table" page - posted by "HanWei (Jira)" <ji...@apache.org> on 2021/06/25 08:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23158) Source transformation is not added to the StreamExecutionEnvironment explicitly - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/06/25 09:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23159) Correlated sql subquery on the source created via fromValues() failed to compile - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/06/25 09:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23160) upgrade kafka-schema-registry-client to 6.1.2 for Flink-avro-confluent-registry - posted by "Lian Jiang (Jira)" <ji...@apache.org> on 2021/06/25 14:44:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-171: Async Sink - posted by "Hausmann, Steffen" <sh...@amazon.de.INVALID> on 2021/06/25 15:15:58 UTC, 0 replies.
- [jira] [Created] (FLINK-23161) Cannot have more than one execute() or executeAsync() call in a single environment. - posted by "roberto hashioka (Jira)" <ji...@apache.org> on 2021/06/25 15:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23162) Create table uses time_ltz in the column name and it's expression which results in exception - posted by "Mans Singh (Jira)" <ji...@apache.org> on 2021/06/26 21:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23163) Add debug ability for kubernetes client - posted by "Aitozi (Jira)" <ji...@apache.org> on 2021/06/27 07:44:00 UTC, 0 replies.
- Re: [Question] Why doesn't Flink use Calcite adapter? - posted by Israel Ekpo <is...@gmail.com> on 2021/06/28 00:27:58 UTC, 1 replies.
- [jira] [Created] (FLINK-23164) JobMasterTest.testMultipleStartsWork unstable on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/06/28 02:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23165) Add StreamExecutionEnvironment#registerSlotSharingGroup to PyFlink - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2021/06/28 06:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23166) ZipUtils doesn't handle properly for softlinks inside the zip file - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/06/28 07:51:00 UTC, 0 replies.
- Flink 1.14. Bi-weekly 2021-06-22 - posted by Johannes Moser <jo...@data-artisans.com> on 2021/06/28 07:54:22 UTC, 3 replies.
- [VOTE] FLIP-147: Support Checkpoint After Tasks Finished - posted by Yun Gao <yu...@aliyun.com.INVALID> on 2021/06/28 08:45:20 UTC, 3 replies.
- [jira] [Created] (FLINK-23167) Port Kinesis Table API e2e tests to release-1.12 branch - posted by "Emre Kartoglu (Jira)" <ji...@apache.org> on 2021/06/28 08:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23168) Catalog shouldn't merge properties for alter DB operation - posted by "Rui Li (Jira)" <ji...@apache.org> on 2021/06/28 10:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23169) Support user-level app staging directory when yarn.staging-directory is specified - posted by "jinfeng (Jira)" <ji...@apache.org> on 2021/06/28 11:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23170) Write metadata after materialization - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/06/28 13:23:00 UTC, 0 replies.
- [VOTE] FLIP-172: Support custom transactional.id prefix in FlinkKafkaProducer - posted by Wenhao Ji <pr...@gmail.com> on 2021/06/28 14:00:00 UTC, 2 replies.
- [jira] [Created] (FLINK-23171) Can't execute SET table.sql-dialect=hive; - posted by "JasonLee (Jira)" <ji...@apache.org> on 2021/06/28 14:33:00 UTC, 0 replies.
- [DISCUSS] Better user experience in the WindowAggregate upon Changelog (contains update message) - posted by JING ZHANG <be...@gmail.com> on 2021/06/29 03:08:51 UTC, 0 replies.
- [jira] [Created] (FLINK-23172) Links of restart strategy in configuration page is broken - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2021/06/29 03:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23173) Inconsistency detected by ld.so - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/06/29 03:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23174) Log improvement in Task throws Error - posted by "Bo Cui (Jira)" <ji...@apache.org> on 2021/06/29 03:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23175) Write data to hive table in batch mode throws FileNotFoundException. - posted by "chrismartin (Jira)" <ji...@apache.org> on 2021/06/29 06:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23176) my flink application has failed when i executed an savepoint - posted by "Carl (Jira)" <ji...@apache.org> on 2021/06/29 06:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23177) watermarks generated in dateStream can not flow into table - posted by "Spongebob (Jira)" <ji...@apache.org> on 2021/06/29 06:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23178) Raise an error for writing stream data into partitioned hive/FS tables without a partition committer - posted by "Rui Li (Jira)" <ji...@apache.org> on 2021/06/29 07:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23179) Support PIVOT and UNPIVOT - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/06/29 07:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23180) Initialize checkpoint location lazily in DataStream Batch Jobs - posted by "Jiayi Liao (Jira)" <ji...@apache.org> on 2021/06/29 07:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23181) Add support for multi hop window - posted by "Aitozi (Jira)" <ji...@apache.org> on 2021/06/29 08:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23182) Connection leak in RMQSource - posted by "Michał Ciesielczyk (Jira)" <ji...@apache.org> on 2021/06/29 11:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23183) Lost ACKs for redelivered messages in RMQSource - posted by "Michał Ciesielczyk (Jira)" <ji...@apache.org> on 2021/06/29 11:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23184) CompileException Assignment conversion not possible from type "int" to type "short" - posted by "xiaojin.wy (Jira)" <ji...@apache.org> on 2021/06/29 12:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23185) REST API docs refer to removed rescaling endpoints - posted by "Juha (Jira)" <ji...@apache.org> on 2021/06/29 13:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23186) Update "Local Installation" page - posted by "Daisy Tsang (Jira)" <ji...@apache.org> on 2021/06/29 16:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23187) [Documentation] PubSubSink should use "withTopicName" rather than "withSubscriptionName" - posted by "Jared Wasserman (Jira)" <ji...@apache.org> on 2021/06/29 22:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23188) Unsupported function definition: IFNULL. Only user defined functions are supported as inline functions - posted by "xiaojin.wy (Jira)" <ji...@apache.org> on 2021/06/30 02:27:00 UTC, 0 replies.
- 回复: [DISCUSS] FLIP-171: Async Sink - posted by 123052475 <re...@foxmail.com> on 2021/06/30 02:41:52 UTC, 0 replies.
- [jira] [Created] (FLINK-23189) Count and fail the task when the disk is error on JobManager - posted by "zlzhang0122 (Jira)" <ji...@apache.org> on 2021/06/30 05:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23190) Make task-slot allocation much more evenly - posted by "loyi (Jira)" <ji...@apache.org> on 2021/06/30 05:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23191) Azure: Upload CI logs to S3 as well - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/06/30 07:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23192) Move connector/format option classes into a common package - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/06/30 10:48:00 UTC, 0 replies.
- [DISCUSS] Releasing Flink 1.11.4 - posted by godfrey he <go...@gmail.com> on 2021/06/30 12:14:19 UTC, 0 replies.
- [jira] [Created] (FLINK-23193) Support to display Options when using desc table statement - posted by "Fangliang Liu (Jira)" <ji...@apache.org> on 2021/06/30 13:07:00 UTC, 0 replies.
- [VOTE] Migrating Test Framework to JUnit 5 - posted by Qingsheng Ren <re...@gmail.com> on 2021/06/30 15:56:09 UTC, 0 replies.
- [jira] [Created] (FLINK-23194) Cache and reuse the ContainerLaunchContext and accelarate the progress of createTaskExecutorLaunchContext on yarn - posted by "zlzhang0122 (Jira)" <ji...@apache.org> on 2021/06/30 16:02:00 UTC, 0 replies.
- Re: Job Recovery Time on TM Lost - posted by Lu Niu <qq...@gmail.com> on 2021/06/30 16:33:03 UTC, 0 replies.