dev@flink.apache.org, 2021-02

You are viewing a plain text version of this content. The canonical link for it is here.

- [jira] [Created] (FLINK-21219) FlinkKafkaConsumer ignores offset overrides for new topics when restoring from savepoint. - posted by "Dominik Wosiński (Jira)" <ji...@apache.org> on 2021/02/01 00:29:02 UTC, 0 replies.
- Re: [DISCUSS] FLIP-162: Consistent Flink SQL time function behavior - posted by Kurt Young <yk...@gmail.com> on 2021/02/01 01:37:27 UTC, 15 replies.
- Re: [VOTE] FLIP-160: Declarative scheduler - posted by Yangze Guo <ka...@gmail.com> on 2021/02/01 01:50:41 UTC, 6 replies.
- Re: [VOTE] FLIP-159: Reactive Mode - posted by Zhu Zhu <re...@gmail.com> on 2021/02/01 03:21:57 UTC, 2 replies.
- [jira] [Created] (FLINK-21220) Change the type of cpuCores in ResourceProfile to CPUResource - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2021/02/01 03:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21221) Deduplication of ResourceCounter - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2021/02/01 03:51:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-156: Runtime Interfaces for Fine-Grained Resource Requirements - posted by Yangze Guo <ka...@gmail.com> on 2021/02/01 03:51:07 UTC, 8 replies.
- [VOTE] FLIP-156: Runtime Interfaces for Fine-Grained Resource Requirements - posted by Yangze Guo <ka...@gmail.com> on 2021/02/01 03:56:42 UTC, 5 replies.
- Re: [ANNOUNCE] Apache Flink 1.10.3 released - posted by Zhu Zhu <re...@gmail.com> on 2021/02/01 04:04:01 UTC, 1 replies.
- Re: [DISCUSS]FLIP-163: SQL Client Improvements - posted by Rui Li <li...@gmail.com> on 2021/02/01 06:46:17 UTC, 43 replies.
- [jira] [Created] (FLINK-21222) Support loopback mode to allow Python UDF worker and client reuse the same Python VM - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/02/01 07:09:00 UTC, 0 replies.
- Re: [DISCUSS] FLINK-21045: Support 'load module' and 'unload module' SQL syntax - posted by Jark Wu <im...@gmail.com> on 2021/02/01 07:10:02 UTC, 21 replies.
- [jira] [Created] (FLINK-21223) Support to specify the input/output types of Python UDFs via string - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/02/01 07:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21224) Remove BatchExecExchange and StreamExecExchange, and replace their functionality with ExecEdge - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/02/01 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21225) OverConvertRule does not consider distinct - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/02/01 08:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21226) Reintroduce TableColumn.of for backwards compatibility - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/02/01 09:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21227) Fixed: Upgrade Version com.google.protobuf:protoc:3.5.1:exe to 3.7.0 for (power)ppc64le support - posted by "Bivas (Jira)" <ji...@apache.org> on 2021/02/01 10:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21228) [Kinesis][Producer] Deadlock in KinesisProducer - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2021/02/01 10:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21229) Support ssl connection with schema registry format - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/02/01 14:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21230) Add protobuf wrapper types for the StateFun SDK types. - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/02/01 14:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21231) add "SHOW VIEWS" to SQL client - posted by "tim yu (Jira)" <ji...@apache.org> on 2021/02/01 15:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21232) Introduce pluggable Hadoop delegation token providers - posted by "jackwangcs (Jira)" <ji...@apache.org> on 2021/02/01 16:56:00 UTC, 0 replies.
- Re: [Announce] Documentation Freeze Feb 2nd - posted by Seth Wiesman <sj...@gmail.com> on 2021/02/01 16:57:18 UTC, 0 replies.
- Re: [DISCUSS] Support obtaining Hive delegation tokens when submitting application to Yarn - posted by Jack W <ja...@gmail.com> on 2021/02/01 17:03:05 UTC, 0 replies.
- [jira] [Created] (FLINK-21233) Race condition in CheckpointCoordinator in finishing sync savepoint - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/02/01 22:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21234) testKafkaSourceSinkWithKeyAndPartialValue[legacy = false, format = csv] hang - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/02/02 06:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21235) leaderChange_withBlockingJobManagerTermination_doesNotAffectNewLeader hang - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/02/02 06:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21236) Don't explicitly use HeapMemorySegment in row format serde - posted by "Kurt Young (Jira)" <ji...@apache.org> on 2021/02/02 07:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21237) Reflects the actual running state of the job - posted by "liuzhuo (Jira)" <ji...@apache.org> on 2021/02/02 07:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21238) Support to close PythonFunctionFactory manually - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/02/02 07:55:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-152: Hive Query Syntax Compatibility - posted by Jingsong Li <ji...@gmail.com> on 2021/02/02 09:10:31 UTC, 5 replies.
- Re: Proposal to add Google Cloud Storage FileSystem with RecoverableWriter - posted by Till Rohrmann <tr...@apache.org> on 2021/02/02 09:19:17 UTC, 5 replies.
- [DISCUSS] FLINK-21110: Optimize Scheduler Performance for Large-Scale Jobs - posted by Zhilong Hong <cy...@outlook.com> on 2021/02/02 10:00:08 UTC, 2 replies.
- [jira] [Created] (FLINK-21239) Upgrade Calcite version to 1.28 - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/02/02 10:26:01 UTC, 0 replies.
- [jira] [Created] (FLINK-21240) incompati datetime - posted by "macdoor615 (Jira)" <ji...@apache.org> on 2021/02/02 12:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21241) E2E test exception check might fail if older checkpoint not completed when triggering the stop-with-savepoint - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/02/02 12:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21242) Support state access API for map operation - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2021/02/02 12:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21243) Add Java SDK maven module - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/02/02 14:33:00 UTC, 0 replies.
- [VOTE] FLIP-158: Generalized incremental checkpoints - posted by Khachatryan Roman <kh...@gmail.com> on 2021/02/02 22:35:41 UTC, 4 replies.
- [jira] [Created] (FLINK-21244) shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel Fail - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/02/03 05:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21245) Support StreamExecCalc json serialization/deserialization - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/02/03 06:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21246) Decline Checkpoint if some tasks finished before get triggered - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/02/03 07:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21247) flink iceberg table map cannot convert to datastream - posted by "donglei (Jira)" <ji...@apache.org> on 2021/02/03 07:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21248) Checkpoint problem - posted by "Ceyhan Kasap (Jira)" <ji...@apache.org> on 2021/02/03 08:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21249) TableEnvironment does not support create method with remote nvironment - posted by "lidesheng (Jira)" <ji...@apache.org> on 2021/02/03 08:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21250) Failure to finalize checkpoint due to org.apache.hadoop.fs.FileAlreadyExistsException: /user/flink/checkpoints/9e36ed4ec2f6685f836e5ee5395f5f2e/chk-11096/_metadata for client xxx.xx.xx.xxx already exists - posted by "Fangliang Liu (Jira)" <ji...@apache.org> on 2021/02/03 09:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21251) Last valid checkpoint metadata lost after job exits restart loop - posted by "Paul Lin (Jira)" <ji...@apache.org> on 2021/02/03 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21252) Scala quickstarts should specify -target jvm version - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/02/03 09:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21253) Support grouping set/cube/rollup syntax in WindowAggregate - posted by "Andy (Jira)" <ji...@apache.org> on 2021/02/03 09:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21254) Add DeclarativeScheduler / Created state - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/02/03 11:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21255) Add DeclarativeScheduler / WaitingForResources state - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/02/03 11:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21256) Add DeclarativeScheduler / Executing state - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/02/03 11:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21257) Add DeclarativeScheduler / Restarting state - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/02/03 11:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21258) Add DeclarativeScheduler / Canceling state - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/02/03 11:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21259) Add DeclarativeScheduler / Failing state - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/02/03 11:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21260) Add DeclarativeScheduler / Finished state - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/02/03 11:08:00 UTC, 0 replies.
- PyFlink DataStream API - posted by Partha Mishra <pa...@man-es.com> on 2021/02/03 12:08:31 UTC, 1 replies.
- [jira] [Created] (FLINK-21261) Improve digest of physical Expand node - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/02/03 13:08:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-159: Reactive Mode - posted by Robert Metzger <rm...@apache.org> on 2021/02/03 14:13:16 UTC, 0 replies.
- [jira] [Created] (FLINK-21262) Remove SlotPool.suspend - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/02/03 17:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21263) Job hangs under backpressure - posted by "Lu Niu (Jira)" <ji...@apache.org> on 2021/02/03 18:14:00 UTC, 0 replies.
- Re: Is development in FlinkML still active? - posted by Badrul Chowdhury <ba...@gmail.com> on 2021/02/03 18:54:01 UTC, 2 replies.
- [DISCUSS] End to End latency measurement - posted by Sherin Thomas <sh...@gmail.com> on 2021/02/03 23:28:02 UTC, 0 replies.
- [jira] [Created] (FLINK-21264) at yarn-per-job mode, tm stopped ,the jm dont relase resource,its also running - posted by "tonychan (Jira)" <ji...@apache.org> on 2021/02/04 01:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21265) SQLClientSchemaRegistryITCase.testReading failed with DockerClientException unauthorized - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/02/04 02:33:00 UTC, 0 replies.
- Re: [DISCUSS]FLIP-150: Introduce Hybrid Source - posted by Thomas Weise <th...@apache.org> on 2021/02/04 02:48:02 UTC, 1 replies.
- [jira] [Created] (FLINK-21266) The POST request caused a JSON serialization error - posted by "chenkaiyin (Jira)" <ji...@apache.org> on 2021/02/04 03:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21267) FLIP-156: Runtime Interfaces for Fine-Grained Resource Requirements - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2021/02/04 03:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21268) Logs view can't scoll in Firefox - posted by "Frost Wong (Jira)" <ji...@apache.org> on 2021/02/04 03:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21269) Introduce runtime interfaces for specifying SSG-based resource requirements - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2021/02/04 03:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21270) Generate the slot request respect to the resource specification of SlotSharingGroup if present - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2021/02/04 03:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21271) DataStreamTests.test_key_by_on_connect_stream test failed with "ArrayIndexOutOfBoundsException" in py35 - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/02/04 03:53:00 UTC, 0 replies.
- [RESULT] [VOTE] FLIP-156: Runtime Interfaces for Fine-Grained Resource Requirements - posted by Yangze Guo <ka...@gmail.com> on 2021/02/04 05:25:01 UTC, 1 replies.
- [jira] [Created] (FLINK-21272) Resuming Savepoint (rocks, scale down, rocks timers) end-to-end test' Fail - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/02/04 06:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21273) Remove unused ExecutionVertexSchedulingRequirements - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2021/02/04 06:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21274) At per-job mode，when the upload speed of the HDFS file system is slow, the task exits abnormally, and the task archive file upload fails. - posted by "Wang Jichao (Jira)" <ji...@apache.org> on 2021/02/04 06:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21275) DataStreamTests::test_key_by_on_connect_stream Fail - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/02/04 07:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21276) flink-statefun/statefun-sdk-java should mention Protobuf in NOTICE and bundle its license - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2021/02/04 07:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21277) SQLClientSchemaRegistryITCase fails to download testcontainers/ryuk:0.3.0 - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/02/04 08:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21278) NullpointExecption error is reported when using the evictor method to filter the data before the window calculation - posted by "HunterHunter (Jira)" <ji...@apache.org> on 2021/02/04 09:03:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-160: Declarative scheduler - posted by Till Rohrmann <tr...@apache.org> on 2021/02/04 09:21:25 UTC, 0 replies.
- [jira] [Created] (FLINK-21279) flink on yarn sink nothing - posted by "Spongebob (Jira)" <ji...@apache.org> on 2021/02/04 09:54:00 UTC, 0 replies.
- Flink 1.11.4 release? And usual plan for maintenance etc - posted by Adam Roberts <ad...@gmail.com> on 2021/02/04 12:07:37 UTC, 3 replies.
- Upgrade calcite version - posted by 盛森林 <la...@qq.com> on 2021/02/04 14:46:25 UTC, 0 replies.
- [jira] [Created] (FLINK-21280) Investigate a way to disable object reuse in StateFun - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/02/04 17:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21281) Support DELETE FROM for flink sql - posted by "Jun Zhang (Jira)" <ji...@apache.org> on 2021/02/05 01:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21282) Support UPDATE for flink sql - posted by "Jun Zhang (Jira)" <ji...@apache.org> on 2021/02/05 01:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21283) Support sql extension for flink sql - posted by "Jun Zhang (Jira)" <ji...@apache.org> on 2021/02/05 01:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21284) Non-deterministic UDF functions return different values - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2021/02/05 02:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21285) Support MERGE INTO for flink sql - posted by "Jun Zhang (Jira)" <ji...@apache.org> on 2021/02/05 02:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21286) Support BUCKET for flink sql CREATE TABLE - posted by "Jun Zhang (Jira)" <ji...@apache.org> on 2021/02/05 02:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21287) Failed to build flink source code - posted by "Lei Qu (Jira)" <ji...@apache.org> on 2021/02/05 03:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21288) Support redundant task managers for fine grained resource management - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/02/05 05:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21289) Application mode on kubernetes deployment support run PackagedProgram.main with pipeline.classpaths - posted by "Zhou Parker (Jira)" <ji...@apache.org> on 2021/02/05 06:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21290) Support Projection push down for Window TVF - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/02/05 07:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21291) FlinkKafka Consumer can't dynamic discover the partition update - posted by "zhangyunyun (Jira)" <ji...@apache.org> on 2021/02/05 07:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21292) Python StreamRowBasedOperationITTests fails on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/02/05 07:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21293) Support 'LOAD/UNLOAD MODULE', 'USE MODULES', and 'SHOW [FULL] MODULES' syntax - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2021/02/05 08:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21294) Support state access API for the map operation of Python ConnectedStreams - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2021/02/05 08:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21295) Support 'LOAD/UNLOAD MODULE', 'USE MODULES', and 'SHOW [FULL] MODULES' syntax - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2021/02/05 08:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21296) Support changing the resolution order of modules in a flexible manner - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2021/02/05 08:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21297) Simplify the module discovery mapping by module name - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2021/02/05 08:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21298) Update user documentation of modules - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2021/02/05 08:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21299) Support 'USE MODULES' syntax - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2021/02/05 09:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21300) Support 'SHOW [FULL] MODULES' syntax - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2021/02/05 09:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21301) Decouple window aggregate allow lateness with state ttl configuration - posted by "Andy (Jira)" <ji...@apache.org> on 2021/02/05 09:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21302) Fix NPE when use row_number() in over agg - posted by "Andy (Jira)" <ji...@apache.org> on 2021/02/05 10:04:00 UTC, 0 replies.
- [DISCUSS] Releasing Apache Flink 1.12.2 - posted by Yuan Mei <yu...@gmail.com> on 2021/02/05 10:36:47 UTC, 16 replies.
- [jira] [Created] (FLINK-21303) Maybe remove LogicalSlot#getPhysicalSlotNumber - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/02/05 11:09:00 UTC, 0 replies.
- 回复：[DISCUSS] Releasing Apache Flink 1.12.2 - posted by 郁蓝 <ha...@foxmail.com> on 2021/02/05 11:11:52 UTC, 0 replies.
- [jira] [Created] (FLINK-21304) Support split distinct aggregate for window TVF based aggregate - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/02/05 11:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21305) Cumulative window should accumulate late events belonging to the cleaned slice - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/02/05 11:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21306) FlinkSecurityManager might avoid fatal system exits - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/02/05 14:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21307) Revisit activation model of FlinkSecurityManager - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/02/05 14:48:00 UTC, 0 replies.
- [DISCUSS] FLIP-164: Improve Schema Handling in Catalogs - posted by Timo Walther <tw...@apache.org> on 2021/02/05 15:09:44 UTC, 9 replies.
- [jira] [Created] (FLINK-21308) Cancel "sendAfter" - posted by "Stephan Pelikan (Jira)" <ji...@apache.org> on 2021/02/05 16:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21309) Metrics of JobManager and TaskManager overwrite each other in pushgateway - posted by "jiguodai (Jira)" <ji...@apache.org> on 2021/02/06 01:41:00 UTC, 0 replies.
- First development steps, broken build workarounds? - posted by Jack Phelan <ja...@bytesandwich.com> on 2021/02/06 03:36:40 UTC, 3 replies.
- 回复：First development steps, broken build workarounds? - posted by Frost Wong <ha...@foxmail.com> on 2021/02/06 09:30:07 UTC, 0 replies.
- 回复： First development steps, broken build workarounds? - posted by 肯定会有 <12...@qq.com> on 2021/02/07 02:53:57 UTC, 0 replies.
- [jira] [Created] (FLINK-21310) unexpected behavior of DataFrame union - posted by "Tianshi Zhu (Jira)" <ji...@apache.org> on 2021/02/07 02:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21311) flink1.12 cep pattern gets some problerm - posted by "forrest_feng (Jira)" <ji...@apache.org> on 2021/02/07 04:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21312) SavepointITCase.testStopSavepointWithBoundedInputConcurrently is unstable - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2021/02/07 04:44:00 UTC, 0 replies.
- Flink upset-kaka connector not working with Avro confluent - posted by shamit jain <ja...@gmail.com> on 2021/02/07 05:16:24 UTC, 2 replies.
- Need help on Upsert-kafka connector with confluent schema registry - posted by Shamit <ja...@gmail.com> on 2021/02/07 05:21:41 UTC, 1 replies.
- [jira] [Created] (FLINK-21313) Support more log4j2's configuration syntax - posted by "xiaozilong (Jira)" <ji...@apache.org> on 2021/02/07 07:21:00 UTC, 0 replies.
- [VOTE] FLIP-152: Hive Query Syntax Compatibility - posted by Rui Li <li...@gmail.com> on 2021/02/07 11:23:51 UTC, 4 replies.
- [jira] [Created] (FLINK-21314) Airflow | - posted by "ohad (Jira)" <ji...@apache.org> on 2021/02/07 12:23:00 UTC, 0 replies.
- Activate bloom filter in RocksDB State Backend via Flink configuration - posted by Jun Qin <qi...@gmail.com> on 2021/02/07 18:22:54 UTC, 3 replies.
- [jira] [Created] (FLINK-21315) Support to set operator names in state processor API - posted by "Jun Qin (Jira)" <ji...@apache.org> on 2021/02/07 20:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21316) E2E tests exceed 250 minutes. - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/02/08 03:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21317) Downstream keyed state not work after FlinkKafkaShuffle - posted by "Kezhu Wang (Jira)" <ji...@apache.org> on 2021/02/08 03:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21318) ExecutionContextTest.testCatalogs fail - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/02/08 04:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21319) hadoop-mapreduce jars are not loaded into classpath when submiting flink on yarn jobs. - posted by "Tang Yan (Jira)" <ji...@apache.org> on 2021/02/08 06:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21320) Stream from FlinkKafkaShuffle.persistentKeyBy does not end if upstream ends - posted by "Kezhu Wang (Jira)" <ji...@apache.org> on 2021/02/08 10:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21321) Change RocksDB incremental checkpoint re-scaling to use deleteRange - posted by "Joey Pereira (Jira)" <ji...@apache.org> on 2021/02/08 13:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21322) Add ExecutionGraphHandler - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/02/08 15:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21323) Stop-with-savepoint is not supported by SourceOperatorStreamTask - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/02/08 20:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21324) statefun-testutil can't assert messages function sends to itself - posted by "Timur (Jira)" <ji...@apache.org> on 2021/02/08 22:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21325) NoResourceAvailableException while cancel then resubmit jobs - posted by "hayden zhou (Jira)" <ji...@apache.org> on 2021/02/09 03:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21326) Optimize building topology when initializing ExecutionGraph - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2021/02/09 06:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21328) Optimize the initialization of DefaultExecutionTopology - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2021/02/09 07:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21327) Support window TVF in batch mode - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/02/09 07:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21329) "Local recovery and sticky scheduling end-to-end test" does not finish within 600 seconds - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/02/09 07:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21330) Optimization the initialization of PipelinedRegionSchedulingStrategy - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2021/02/09 07:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21331) Optimize calculating tasks to restart in RestartPipelinedRegionFailoverStrategy - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2021/02/09 07:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21332) Optimize releasing result partitions in RegionPartitionReleaseStrategy - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2021/02/09 07:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21333) Introduce stopping with savepoint state - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/02/09 08:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21334) Run kubernetes pyflink application test fails with Connection reset by peer on setup - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/02/09 08:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21335) READEME should use "mvn install" instead of "mvn package" to compile Flink - posted by "Dong Lin (Jira)" <ji...@apache.org> on 2021/02/09 09:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21336) Activate bloom filter in RocksDB State Backend via Flink configuration - posted by "Jun Qin (Jira)" <ji...@apache.org> on 2021/02/09 11:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21337) ComparableInputTypeStrategyTests is not running - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/02/09 12:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21338) Relax test naming constraints - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/02/09 12:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21339) ExceptionUtilsITCases is not run and fails - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/02/09 15:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21340) CheckForbiddenMethodsUsage is not run and fails - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/02/09 15:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21341) Update state reader to return InputFormat - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/02/09 15:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21342) Various classes extending TestBases cannot be instantiated - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/02/09 15:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21343) Update documentation with possible migration strategies - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/02/09 17:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21344) Support switching from/to rocks db with heap timers - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/02/09 17:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21345) NullPointerException LogicalCorrelateToJoinFromTemporalTableFunctionRule.scala:157 - posted by "lynn1.zhang (Jira)" <ji...@apache.org> on 2021/02/10 05:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21346) Tasks on AZP should timeout more gracefully - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/02/10 07:42:00 UTC, 0 replies.
- [ANNOUNCE] Welcome Roman Khachatryan a new Apache Flink Committer - posted by Piotr Nowojski <pn...@apache.org> on 2021/02/10 10:29:19 UTC, 24 replies.
- [jira] [Created] (FLINK-21347) Extract interface out of ExecutionGraph for better testability - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/02/10 11:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21348) Add tests for StateWithExecutionGraph - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/02/10 13:25:00 UTC, 0 replies.
- [ANNOUNCE] Randomized tests - posted by Arvid Heise <ar...@apache.org> on 2021/02/10 13:44:32 UTC, 2 replies.
- [jira] [Created] (FLINK-21349) 'Quickstarts Scala nightly end-to-end test' fails with errors in logs - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/02/10 14:19:00 UTC, 0 replies.
- [Announce] Hugo migration complete - posted by Seth Wiesman <sj...@gmail.com> on 2021/02/10 14:40:45 UTC, 7 replies.
- [jira] [Created] (FLINK-21350) ParquetInputFormat incorrectly interprets timestamps encoded in microseconds as timestamps encoded in milliseconds - posted by "Jeffrey Charles (Jira)" <ji...@apache.org> on 2021/02/10 14:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21351) Incremental checkpoint data would be lost once a non-stop savepoint completed - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/02/10 15:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21352) FLIP-158: Generalized incremental checkpoints - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/02/10 16:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21353) Add FS-based StateChangelog implementation - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/02/10 16:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21354) Add ChangelogStateBackend (proxy-everything) - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/02/10 16:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21355) Send changes to the state changelog (still proxy everything) - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/02/10 17:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21356) Implement incremental checkpointing and recovery using state changelog - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/02/10 17:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21357) Add periodic materialization - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/02/10 17:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21358) Missing snapshot version compatibility for 1.12 - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/02/10 17:39:00 UTC, 0 replies.
- Source of Cloudera 3 Hadoop Flink shaded uber jars? - posted by Adam Roberts <ad...@gmail.com> on 2021/02/10 17:54:33 UTC, 3 replies.
- [jira] [Created] (FLINK-21359) CompatibilityResult issues with Flink 1.9.0 - posted by "Siva (Jira)" <ji...@apache.org> on 2021/02/10 21:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21360) Add resourceTimeout configuration - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/02/11 07:47:00 UTC, 0 replies.
- Unable to resolve the operator from the metafile using State Processor API - posted by Partha Mishra <pa...@man-es.com> on 2021/02/11 07:47:54 UTC, 0 replies.
- [jira] [Created] (FLINK-21361) FlinkRelMdUniqueKeys matches on AbstractCatalogTable instead of CatalogTable - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/02/11 10:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21362) Remove State#onEnter - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/02/11 10:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21363) Fix baseurl in documentation - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/02/11 14:21:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-151: Incremental snapshots for heap-based state backend - posted by Stephan Ewen <se...@apache.org> on 2021/02/11 15:27:38 UTC, 3 replies.
- [jira] [Created] (FLINK-21364) piggyback finishedSplitIds in RequestSplitEvent - posted by "Steven Zhen Wu (Jira)" <ji...@apache.org> on 2021/02/11 16:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21365) Visibility issue in FutureUtils.ResultConjunctFuture.handleCompletedFuture - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/02/11 16:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21366) Kafka connector documentation should mentions Maxwell as CDC mechanism - posted by "Svend Vanderveken (Jira)" <ji...@apache.org> on 2021/02/12 06:56:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-147: Support Checkpoints After Tasks Finished - posted by Piotr Nowojski <pn...@apache.org> on 2021/02/12 10:36:09 UTC, 14 replies.
- [jira] [Created] (FLINK-21367) Support objectReuse in JDBC sink - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/02/12 11:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21368) Consider removing RpcService#getExecutor - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/02/12 11:24:00 UTC, 0 replies.
- [VOTE] FLIP-164: Improve Schema Handling in Catalogs - posted by Timo Walther <tw...@apache.org> on 2021/02/12 12:33:01 UTC, 4 replies.
- [jira] [Created] (FLINK-21369) Document Checkpoint Storage - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/02/12 19:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21370) flink-1.12.1 - JDBCExecutionOptions defaults config JDBCDynamicTableFactory default config is not consistent - posted by "谢波 (Jira)" <ji...@apache.org> on 2021/02/12 20:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21371) flink-runtime-web: Using lambda to replace anonymous inner classes - posted by "BeanNan (Jira)" <ji...@apache.org> on 2021/02/13 10:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21372) Arranging cluster tests, on RISC-V - posted by "Ivan Serdyuk (Jira)" <ji...@apache.org> on 2021/02/13 10:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21373) Port RabbitMQ Sink to FLIP-143 API - posted by "Jan Westphal (Jira)" <ji...@apache.org> on 2021/02/13 11:07:00 UTC, 0 replies.
- Failed to register Protobuf Kryo serialization - posted by Svend Vanderveken <sv...@kelesia.com> on 2021/02/14 10:41:54 UTC, 1 replies.
- [jira] [Created] (FLINK-21374) Upgrade built-in Hive to 2.3.8 - posted by "Yuming Wang (Jira)" <ji...@apache.org> on 2021/02/14 13:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21375) Refactor HybridMemorySegment - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/02/15 10:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21376) Failed state might not provide failureCause - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/02/15 12:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21377) Refactor some queryable-state JobMaster tests to work against schedulers - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/02/15 13:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21378) Rescale pointwise connection during unaligned checkpoint recovery - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/02/16 07:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21379) Elasticsearch (v6.3.1) sink end-to-end test fails on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/02/16 09:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21380) Restarting/Canceling/Failing expose globally-terminal EG - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/02/16 12:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21381) Kubernetes HA documentation does not state required service account and role - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/02/16 13:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21382) Standalone K8s documentation does not explain usage of standby JobManagers - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/02/16 16:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21383) Docker image does not play well together with ConfigMap based flink-conf.yamls - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/02/16 16:26:00 UTC, 0 replies.
- [VOTE] Release 1.12.2, release candidate #1 - posted by Roman Khachatryan <ro...@apache.org> on 2021/02/16 19:24:52 UTC, 9 replies.
- [jira] [Created] (FLINK-21384) Automatically copy maven dependencies to clipboard on click - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/02/16 19:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21385) AvroDeserializationSchema corrupted after getting invalid data - posted by "Leonid Ilyevsky (Jira)" <ji...@apache.org> on 2021/02/16 20:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21386) FromElements ignores returns() - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/02/16 23:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21387) DispatcherTest.testInvalidCallDuringInitialization times out on azp - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/02/17 08:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21388) Parquet DECIMAL logical type is not properly supported in ParquetInputFormat - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2021/02/17 09:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21389) ParquetInputFormat should not need parquet schema as user input - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2021/02/17 10:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21390) Rename DeclarativeScheduler to AdaptiveScheduler - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/02/17 11:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21391) Migrate AWS Glue e2e test from sh to Java - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2021/02/17 14:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21392) Support to block in connected streams - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/02/17 14:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21393) Implement ParquetAvroInputFormat - posted by "Dominik Wosiński (Jira)" <ji...@apache.org> on 2021/02/18 01:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21394) FLIP-164: Improve Schema Handling in Catalogs - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/02/18 11:11:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-164: Improve Schema Handling in Catalogs - posted by Timo Walther <tw...@apache.org> on 2021/02/18 11:13:57 UTC, 0 replies.
- [jira] [Created] (FLINK-21395) Implement Schema, ResolvedSchema, SchemaResolver - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/02/18 11:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21396) Update the Catalog APIs - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/02/18 11:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21397) BufferUnderflowException when read parquet - posted by "lihe ma (Jira)" <ji...@apache.org> on 2021/02/18 11:52:00 UTC, 0 replies.
- [statefun] [Question] Path Templating in statefun-flink-datastream API - posted by Miguel Araújo <up...@gmail.com> on 2021/02/18 13:50:32 UTC, 3 replies.
- [jira] [Created] (FLINK-21398) Adjsut JobMasterTest#testRestoring[...]FromSavepoint - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/02/18 18:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21399) Adjust JobMasterTest#testRequestNextInputSplitWith*Failover - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/02/18 18:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21400) Attempt numbers are not maintained across restarts - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/02/18 18:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21401) Tests that manually build a JobGraph cannot use DeclarativeScheduler - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/02/18 18:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21402) Consolidate Scheduler/SlotPool factories - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/02/18 18:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21403) Some tests expect to fail if parallelism cannot be met - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/02/18 18:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21404) YARNITCase runs indefinitely - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/02/18 18:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21405) SchedulerNGFactoryFactoryTest fails if DeclarativeScheduler is enabled via property - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/02/18 18:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21406) Add AvroParquetFileRecordFormat - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/02/18 18:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21407) Clarify which sources and APIs support which formats - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/02/18 19:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21408) Clarify which DataStream sources support Batch execution - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/02/18 19:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21409) Add Avro to DataTypes & Serialization docs - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/02/18 19:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21410) Document checkpoint interval trade-offs - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/02/18 19:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21411) The components on which Flink depends may contain vulnerabilities. If yes, fix them. - posted by "dgbro (Jira)" <ji...@apache.org> on 2021/02/19 01:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21412) pyflink DataTypes.DECIMAL is not available - posted by "awayne (Jira)" <ji...@apache.org> on 2021/02/19 03:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21413) TtlMapState and TtlListState cannot be clean completely with Filesystem StateBackend - posted by "Jiayi Liao (Jira)" <ji...@apache.org> on 2021/02/19 03:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21414) javax.net.ssl.SSLHandshakeException: Received fatal alert: certificate_unknown - posted by "Bhagi (Jira)" <ji...@apache.org> on 2021/02/19 06:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21415) JDBC does not query data, and the cache will store an ArrayList without data - posted by "Shuai Xia (Jira)" <ji...@apache.org> on 2021/02/19 08:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21416) FileBufferReaderITCase.testSequentialReading fails on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/02/19 08:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21417) Separate type specific memory segments. - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/02/19 08:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21418) Replace MemorySegment.wrap() with processAsByteBuffer() - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/02/19 08:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21419) Remove GC cleaner mechanism for unsafe memory segments - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/02/19 08:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21420) Add path templating to DataStream API - posted by "Miguel Araujo (Jira)" <ji...@apache.org> on 2021/02/19 09:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21421) Add coMapWithState to ConnnectedStreams - posted by "Aris Koliopoulos (Jira)" <ji...@apache.org> on 2021/02/19 17:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21422) Migrate StateFun docs to hugo - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/02/19 17:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21423) PartitionNotFoundException when job run on 2 taskmanager with standalone cluster mode - posted by "Sheng Zhang (Jira)" <ji...@apache.org> on 2021/02/20 05:34:00 UTC, 0 replies.
- 来自张亚凯的邮件 - posted by 张亚凯 <18...@163.com> on 2021/02/20 05:36:17 UTC, 1 replies.
- [jira] [Created] (FLINK-21424) Flink view cannot use hive temporal - posted by "HideOnBush (Jira)" <ji...@apache.org> on 2021/02/20 09:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21425) Incorrect implicit conversions in equals and notEquals filter predicates lead to not correctly evaluated by Table API - posted by "Suxing Lee (Jira)" <ji...@apache.org> on 2021/02/20 19:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21426) Documentation of DataStream JdbcSink should be more detailed - posted by "Svend Vanderveken (Jira)" <ji...@apache.org> on 2021/02/20 20:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21427) Recovering from savepoint unable to commit - posted by "Kenzyme Le (Jira)" <ji...@apache.org> on 2021/02/22 00:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21428) DeclarativeSchedulerSlotSharingITCase.testSchedulingOfJobRequiringSlotSharing fail - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/02/22 02:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21429) JsonFileCompactionITCase>CompactionITCaseBase.testNonPartition - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/02/22 02:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21430) Appear append data when flink sql sink mysql on key conflict - posted by "Yu Wang (Jira)" <ji...@apache.org> on 2021/02/22 02:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21431) UpsertKafkaTableITCase.testTemporalJoin hang - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/02/22 03:02:00 UTC, 0 replies.
- [VOTE] FLIP-163: SQL Client Improvements - posted by Shengkai Fang <fs...@gmail.com> on 2021/02/22 03:05:34 UTC, 3 replies.
- [ANNOUNCE] New Apache Flink Committers - Wei Zhong and Xingbo Huang - posted by Dian Fu <di...@apache.org> on 2021/02/22 03:47:43 UTC, 15 replies.
- [jira] [Created] (FLINK-21432) Web UI -- Error - {"errors":["Service temporarily unavailable due to an ongoing leader election. Please refresh."]} - posted by "Bhagi (Jira)" <ji...@apache.org> on 2021/02/22 05:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21433) Default slot resource is calculated inconsistently for pending / registered TMs - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/02/22 08:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21434) When UDAF return ROW type, and the number of fields is more than 14, the crash happend - posted by "awayne (Jira)" <ji...@apache.org> on 2021/02/22 09:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21435) Add a SqlExpression in table-common - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/02/22 10:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21436) Speed up the restore of UnionListState - posted by "fanrui (Jira)" <ji...@apache.org> on 2021/02/22 11:03:00 UTC, 0 replies.
- New Jdbc XA sink - state serialization error. - posted by Maciej Obuchowski <ob...@gmail.com> on 2021/02/22 11:17:53 UTC, 2 replies.
- [jira] [Created] (FLINK-21437) Memory leak when using filesystem state backend on Alibaba Cloud OSS - posted by "Qian Chao (Jira)" <ji...@apache.org> on 2021/02/22 11:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21438) Broken links in content.zh/docs/concepts/flink-architecture.md - posted by "Ting Sun (Jira)" <ji...@apache.org> on 2021/02/22 11:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21439) Add support for exception history - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/02/22 13:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21440) Translate Real Time Reporting with the Table API doc and correct a spelling mistake - posted by "GuotaoLi (Jira)" <ji...@apache.org> on 2021/02/22 14:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21441) FlinkKinesisProducer does not forward custom endpoint - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/02/22 14:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21442) Jdbc XA sink - restore state serialization error - posted by "Maciej Obuchowski (Jira)" <ji...@apache.org> on 2021/02/22 14:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21443) SQLClientHBaseITCase fails on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/02/22 15:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21444) RelNodeBlock#isValidBreakPoint fails to deal with lookup tables of new source (FLIP27 source) - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/02/23 02:30:00 UTC, 0 replies.
- rocksdb version inquiring - posted by 周虓岗 <zh...@163.com> on 2021/02/23 03:42:12 UTC, 0 replies.
- [jira] [Created] (FLINK-21445) Application mode does not set the configuration when building PackagedProgram - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2021/02/23 06:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21446) KafkaProducerTestBase.testExactlyOnce Fail - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/02/23 07:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21447) Resuming Savepoint (file, async, scale up) end-to-end test Fail - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/02/23 07:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21448) Test Changelog State backend - posted by "Yuan Mei (Jira)" <ji...@apache.org> on 2021/02/23 07:15:01 UTC, 0 replies.
- [jira] [Created] (FLINK-21449) Kafka011ProducerExactlyOnceITCase>KafkaProducerTestBase.testExactlyOnceRegularSink fails on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/02/23 07:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21450) Add local recovery support to adaptive scheduler - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/02/23 07:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21451) Remove TaskExecutionState#jobID - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/02/23 08:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21452) FLIP-27 sources cannot reliably downscale - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/02/23 08:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21453) BoundedOneInput.endInput is NOT called when doing stop with savepoint WITH drain - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/02/23 08:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21454) FLIP-163: SQL Client Improvements - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/02/23 09:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21455) Deploy history server on kubernetes - posted by "Yi Tang (Jira)" <ji...@apache.org> on 2021/02/23 09:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21456) TableResult#print() should correctly stringify values of TIMESTAMP type in SQL format - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/02/23 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21457) Add support to differentiate a zero length value bytes and non existing value. - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/02/23 09:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21458) Add numRestarts metric - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/02/23 10:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21459) Implement remote Java SDK for Stateful Functions - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2021/02/23 10:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21461) FileNotFoundException when sink to hive - posted by "zhuxiaoshang (Jira)" <ji...@apache.org> on 2021/02/23 10:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21460) Introduce option `table.planner`, `execution.runtime-mode` - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/02/23 10:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21462) Use `table.planner`, `execution.runtime-mode` to create TableEnvironment in sql client - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/02/23 10:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21463) Refactor client parser - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/02/23 10:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21464) Support ADD JAR command in sql client - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/02/23 10:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21465) Extend explain syntax - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/02/23 10:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21466) Simplify the command to start the sql client - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/02/23 10:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21467) Document possible recommended usage of Bounded{One/Multi}Input.endInput and emphasize that they could be called multiple times - posted by "Kezhu Wang (Jira)" <ji...@apache.org> on 2021/02/23 13:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21468) ParquetTableSource: where clause on integer does not work - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2021/02/23 13:46:00 UTC, 0 replies.
- [Parquet support] - posted by Etienne Chauchot <ec...@apache.org> on 2021/02/23 16:45:45 UTC, 5 replies.
- [jira] [Created] (FLINK-21469) stop-with-savepoint --drain doesn't advance watermark for sources chained to MultipleInputStreamTask - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/02/23 17:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21470) testSafetyNetClose fail - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/02/24 00:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21471) jobmanger, taskmanager, and job hang abnormally, and the blobstore directory is not deleted - posted by "kangTwang (Jira)" <ji...@apache.org> on 2021/02/24 02:00:01 UTC, 0 replies.
- [jira] [Created] (FLINK-21472) encingTokenException: Fencing token mismatch - posted by "hayden zhou (Jira)" <ji...@apache.org> on 2021/02/24 02:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21473) Migrate ParquetInputFormat to BulkFormat interface - posted by "Zhenqiu Huang (Jira)" <ji...@apache.org> on 2021/02/24 02:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21474) Migrate FileSystemTableSource to DynamicTable Source Interface - posted by "Zhenqiu Huang (Jira)" <ji...@apache.org> on 2021/02/24 02:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21475) StateWithExecutionGraph.suspend fails with IllegalStateException - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/02/24 06:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21476) How to appoint jobname - posted by "ranqiqiang (Jira)" <ji...@apache.org> on 2021/02/24 07:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21477) Lookup joins should deal with intermediate table scans containing just the table source correctly - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/02/24 08:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21478) Lookup joins should deal with any intermediate table scans correctly - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/02/24 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21479) Provide read-only interface of TaskManagerTracker to ResourceAllocationStrategy - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/02/24 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21481) Move git-commit-id-plugin execution to flink-runtime - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/02/24 09:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21480) Respect external resources from resource requirements - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/02/24 09:35:00 UTC, 0 replies.
- [UPDATE] Release 1.13 feature freeze - posted by Dawid Wysakowicz <dw...@apache.org> on 2021/02/24 09:49:03 UTC, 0 replies.
- [jira] [Created] (FLINK-21482) Support grouping set syntax for WindowAggregate - posted by "Andy (Jira)" <ji...@apache.org> on 2021/02/24 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21483) Disable the spot bugs plugin. - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/02/24 12:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21484) Internal enum CheckpointType is exposed via REST API, making it part of Public API - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/02/24 12:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21485) Simplify the ExecutionContext - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/02/24 13:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21486) Add sanity check when switching from Rocks to Heap timers - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/02/24 13:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21487) Replace TaskExecutor with TaskManager in ConfigOption description - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/02/24 14:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21488) Jdbc XA sink - XID generation conflicts between jobs - posted by "Maciej Obuchowski (Jira)" <ji...@apache.org> on 2021/02/24 14:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21489) Hugo docs add two anchor links to headers - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/02/24 15:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21490) UnalignedCheckpointITCase fails on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/02/24 16:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21491) Properly shade Protobuf in statefun-sdk-java - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2021/02/24 16:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21492) ActiveResourceManager swallows exception stack trace - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/02/24 18:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21493) Flink Command Line Interface Document can add command usage - posted by "zhisheng (Jira)" <ji...@apache.org> on 2021/02/25 02:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21494) Could not execute statement 'USE `default`' in Flink SQL client - posted by "Zheng Hu (Jira)" <ji...@apache.org> on 2021/02/25 02:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21495) Flink 1.12.0 execute hive sql GeneratedExpression ERROR - posted by "jiayue.yu (Jira)" <ji...@apache.org> on 2021/02/25 03:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21496) Upgrade Testcontainers to 1.15.1 in Stateful Functions - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2021/02/25 03:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21497) FileSourceTextLinesITCase.testBoundedTextFileSourceWithJobManagerFailover fail - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/02/25 04:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21498) Avoid copying when converting byte[] to ByteString in StateFun - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2021/02/25 05:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21499) maven package hang when using multithread on jdk 11 - posted by "Zhengqi Zhang (Jira)" <ji...@apache.org> on 2021/02/25 06:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21500) Failed to upload logs in Azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/02/25 08:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21501) Sync Chinese documentation with FLINK-21343 - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/02/25 09:00:12 UTC, 0 replies.
- [DISCUSS] Deprecation and removal of the legacy SQL planner - posted by Timo Walther <tw...@apache.org> on 2021/02/25 09:00:54 UTC, 2 replies.
- [jira] [Created] (FLINK-21502) Reduce frequency of global re-allocate resources - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/02/25 09:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21503) Resource management time out on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/02/25 13:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21504) Enrich checkpoint barriers with information previous checkpoint(s) - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/02/25 14:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21505) Enforce common savepoint format at the operator level - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2021/02/25 15:03:01 UTC, 0 replies.
- [jira] [Created] (FLINK-21506) Option for setting mesos task user - posted by "Qinghui Xu (Jira)" <ji...@apache.org> on 2021/02/25 18:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21507) Given a sequence of multiple custom stream partitioning operations only last transformation in sequence is applied while others are dropped - posted by "Iaroslav Zeigerman (Jira)" <ji...@apache.org> on 2021/02/26 00:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21508) CollectITCase hangs - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/02/26 03:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21509) "w.start" returns "1970-01-01" when used with Pandas UDAF after grouping by slide window with processing time - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2021/02/26 07:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21510) ExecutionGraph metrics collide on restart - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/02/26 07:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21511) Flink connector elasticsearch 6.x has a bug about BulkProcessor hangs for threads deadlocked - posted by "zhangmeng (Jira)" <ji...@apache.org> on 2021/02/26 08:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21512) flink MemorySize.parseBytes bug if users use it by setting dynamic properties like - posted by "jackylau (Jira)" <ji...@apache.org> on 2021/02/26 09:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21513) Rethink up-/down-/restartingTime metrics - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/02/26 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21514) 26.02.2021 Benchmarks are not compiling - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/02/26 12:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21515) SourceStreamTaskTest.testStopWithSavepointShouldNotInterruptTheSource is failing - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/02/26 12:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21516) UpsertKafkaTableITCase.testTemporalJoin fails on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/02/26 12:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21517) Test harnesses are bypassing serialization stack for events - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/02/26 12:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21518) CheckpointCoordinatorTest.testMinCheckpointPause fails fatally on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/02/26 13:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21519) SQLClientHBaseITCase hangs on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/02/26 14:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21520) ParquetInputFormat#setfilterPredicate() does not work - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2021/02/26 14:21:00 UTC, 0 replies.
- [DISCUSS] Apache Flink Jira Process - posted by Konstantin Knauf <kn...@apache.org> on 2021/02/26 15:17:18 UTC, 1 replies.
- [jira] [Created] (FLINK-21521) Pretty print K8s specifications - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/02/26 17:31:00 UTC, 0 replies.
- [VOTE] Release 1.12.2, release candidate #2 - posted by Roman Khachatryan <ro...@apache.org> on 2021/02/26 23:19:05 UTC, 1 replies.
- [jira] [Created] (FLINK-21522) Iterative stream could not work with stop-with-savepoint - posted by "Kezhu Wang (Jira)" <ji...@apache.org> on 2021/02/28 08:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21523) ArrayIndexOutOfBoundsException occurs while run a hive streaming source job with partitioned table source - posted by "zouyunhe (Jira)" <ji...@apache.org> on 2021/02/28 15:24:00 UTC, 0 replies.