dev@flink.apache.org, 2021-04

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

- 1 - posted by 醉时无梦生 <14...@qq.com> on 2021/04/01 01:10:02 UTC, 0 replies.
- Re: Apply external 3 days for FLINK-20387 after feature freeze - posted by Jark Wu <im...@gmail.com> on 2021/04/01 02:06:02 UTC, 0 replies.
- [jira] [Created] (FLINK-22076) Python Test failed with "OSError: [Errno 12] Cannot allocate memory" - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/04/01 02:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22077) Wrong way to calculate cross-region ConsumedPartitionGroups in PipelinedRegionSchedulingStrategy - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2021/04/01 03:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22079) ReactiveModeITCase stack with fine grained resource manager. - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/04/01 04:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22078) Introduce a Printer interface to rederict the output to the desired stream - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/04/01 04:04:00 UTC, 0 replies.
- Re: [DISCUSS] Feature freeze date for 1.13 - posted by Kurt Young <yk...@gmail.com> on 2021/04/01 04:21:05 UTC, 6 replies.
- [jira] [Created] (FLINK-22080) Refactor SqlClient for better testing - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/04/01 04:22:00 UTC, 0 replies.
- Re: [VOTE] Apache Flink Stateful Functions 3.0.0, release candidate #1 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2021/04/01 04:46:16 UTC, 8 replies.
- [jira] [Created] (FLINK-22081) Entropy key not resolved if flink-s3-fs-hadoop is added as a plugin - posted by "Chen Qin (Jira)" <ji...@apache.org> on 2021/04/01 04:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22082) Nested projection push down doesn't work for data: row(array(row)) - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/04/01 05:31:00 UTC, 0 replies.
- 退订 - posted by Chouchou Mei <ch...@gmail.com> on 2021/04/01 06:51:07 UTC, 1 replies.
- [jira] [Created] (FLINK-22083) Python tests fail on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/01 07:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22084) RescalingITCase fails with adaptive scheduler - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/01 07:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22085) KafkaSourceLegacyITCase hangs on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/01 07:45:00 UTC, 0 replies.
- [DISCUSS] Increase the parallel of flink connector. - posted by jie mei <me...@gmail.com> on 2021/04/01 07:46:10 UTC, 0 replies.
- [jira] [Created] (FLINK-22086) Read hive - posted by "ying zhang (Jira)" <ji...@apache.org> on 2021/04/01 07:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22087) CheckpointPlanCalculator should abort checkpoint if tasks is in canceling/canceled and so on - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/04/01 09:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22088) CheckpointCoordinator might not be able to abort triggering checkpoint if failover happens during triggering - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/04/01 10:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22089) cdc checkpoint invalid - posted by "Simon Tao (Jira)" <ji...@apache.org> on 2021/04/01 10:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22090) Upload logs fails - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/04/01 11:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22091) env.java.home option didn't take effect in resource negotiator - posted by "zlzhang0122 (Jira)" <ji...@apache.org> on 2021/04/01 11:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22092) Prevent HiveCatalog from reading hive-site in classpath - posted by "Rui Li (Jira)" <ji...@apache.org> on 2021/04/01 13:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22093) Unstable test "ThreadInfoSampleServiceTest.testShouldThrowExceptionIfTaskIsNotRunningBeforeSampling" - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2021/04/01 14:49:00 UTC, 0 replies.
- Re: [VOTE] Release flink-shaded 13.0, release candidate #0 - posted by Robert Metzger <rm...@apache.org> on 2021/04/01 17:50:50 UTC, 1 replies.
- [jira] [Created] (FLINK-22094) Update release scripts after documentation switch to Hugo - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/01 18:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22095) Creating python release binaries does not work - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/01 19:41:00 UTC, 0 replies.
- [ANNOUNCE] Release 1.13.0, release candidate #0 - posted by Dawid Wysakowicz <dw...@apache.org> on 2021/04/01 20:04:36 UTC, 1 replies.
- [jira] [Created] (FLINK-22096) ServerTransportErrorHandlingTest.testRemoteClose fail - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/02 00:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22097) testChangelogResultViewClearEmptyResult fail. - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/02 03:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22098) Fix bug for window join: plan test is wrong if join condition contain 'IS NOT DISTINCT FROM' - posted by "Andy (Jira)" <ji...@apache.org> on 2021/04/02 03:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22099) Fix bug for semi/anti window join. - posted by "Andy (Jira)" <ji...@apache.org> on 2021/04/02 05:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22100) BatchFileSystemITCaseBase.testPartialDynamicPartition fail because of no output for 900 seconds - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/02 05:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22101) PyFlinkBatchUserDefinedTableFunctionTests fail - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/02 05:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22102) Throw meaningful exceptions for features we don't support - posted by "Rui Li (Jira)" <ji...@apache.org> on 2021/04/02 06:00:02 UTC, 0 replies.
- [jira] [Created] (FLINK-22103) testNumberOfBuiltinFunctions fail - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/02 06:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22104) SqlClientTest.testExecuteSqlFile fail - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/02 06:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22105) testForceAlignedCheckpointResultingInPriorityEvents unstable - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/04/02 07:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22106) ResultType of GeneratedExpression in StringCallGen should be compatible with their definition in FlinkSqlOperatorTable - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/04/02 08:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22107) Include antlr into hive connector uber jars - posted by "Rui Li (Jira)" <ji...@apache.org> on 2021/04/02 12:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22108) Ephemeral socket address was checkpointed to state and restored back in CollectSinkOperatorCoordinator - posted by "Kezhu Wang (Jira)" <ji...@apache.org> on 2021/04/02 20:29:00 UTC, 0 replies.
- Zigzag shape in TM JVM used memory - posted by Lu Niu <qq...@gmail.com> on 2021/04/05 04:06:24 UTC, 5 replies.
- Automatic backpressure detection - posted by Lu Niu <qq...@gmail.com> on 2021/04/05 21:19:43 UTC, 6 replies.
- [jira] [Created] (FLINK-22109) Misleading exception message if the number of arguments of a nested function is incorrect - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/04/06 05:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22110) KinesisTableApiITCase.testTableApiSourceAndSink failed due to download docker image throw IOException - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/06 06:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22111) ClientTest.testSimpleRequests fail - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/06 06:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22112) EmulatedPubSubSinkTest fail due to pull docker image failure - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/06 07:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22113) UniqueKey constraint is lost with multiple sources join in SQL - posted by "Fu Kai (Jira)" <ji...@apache.org> on 2021/04/06 07:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22114) Streaming File Sink s3 end-to-end test fail because the test did not finish after 900 seconds. - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/06 07:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22115) JobManager dies with IllegalStateException SharedSlot (physical request SlotRequestId{%}) has been released - posted by "wym_maozi (Jira)" <ji...@apache.org> on 2021/04/06 08:10:00 UTC, 0 replies.
- [RESULT] [VOTE] Release flink-shaded 13.0, release candidate #1 - posted by Chesnay Schepler <ch...@apache.org> on 2021/04/06 08:21:44 UTC, 0 replies.
- [jira] [Created] (FLINK-22116) Setup .asf.yaml in flink-web - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/04/06 08:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22117) Not print stack trace for checkpoint trigger failure if not all tasks are started. - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/04/06 09:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22118) Always apply projection push down in blink planner - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/04/06 09:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22119) Update document for hive dialect - posted by "Rui Li (Jira)" <ji...@apache.org> on 2021/04/06 10:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22120) Bug when generate code for map get - posted by "Zou (Jira)" <ji...@apache.org> on 2021/04/06 11:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22121) FlinkLogicalRankRuleBase should check if name of rankNumberType already exists in the input - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/04/06 12:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22122) StreamingKafkaITCase Fail due to TestTimedOutException - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/06 12:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22123) Test state access in Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/04/06 12:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22124) The job finished without any exception if error was thrown during state access - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/04/06 12:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22125) Revisit the return value of MapState.get when the key doesn't exists - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/04/06 12:49:00 UTC, 0 replies.
- Re: Flink job cannot find recover path after using entropy injection for s3 file systems - posted by chenqin <qi...@gmail.com> on 2021/04/06 14:56:47 UTC, 0 replies.
- [jira] [Created] (FLINK-22126) when i set ssl ,the jobmanager got certificate_unknown exception - posted by "tonychan (Jira)" <ji...@apache.org> on 2021/04/07 01:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22127) Enrich error message of read buffer request timeout exception - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2021/04/07 04:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22128) Window aggregation should have unique keys - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/04/07 05:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22129) OrcFileSystemITCase hangs on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/07 06:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22130) Test row based operations in Python Table API - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/04/07 07:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22131) Fix the bug of general udf and pandas udf chained together in map operation - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/04/07 07:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22132) Test unaligned checkpoints rescaling manually on a real cluster - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/04/07 08:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22133) SplitEmumerator does not provide checkpoint id in snapshot - posted by "Brian Zhou (Jira)" <ji...@apache.org> on 2021/04/07 08:30:00 UTC, 0 replies.
- [DISCUSS] Backport FLIP-27 Kafka source connector fixes with API change to release-1.12. - posted by Becket Qin <be...@gmail.com> on 2021/04/07 08:43:00 UTC, 6 replies.
- [jira] [Created] (FLINK-22134) Test the reactive mode - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/04/07 09:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22135) Test the adaptive scheduler - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/04/07 09:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22136) Device application for unaligned checkpoint test on cluster - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/04/07 09:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22137) Execute unaligned checkpoint test on a cluster - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/04/07 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22138) Better support structured types as toDataStream output - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/04/07 09:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22139) Flink Jobmanager & Task Manger logs are not writing to the logs files - posted by "Bhagi (Jira)" <ji...@apache.org> on 2021/04/07 09:51:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink-shaded 13.0 released - posted by Chesnay Schepler <ch...@apache.org> on 2021/04/07 09:56:53 UTC, 0 replies.
- [jira] [Created] (FLINK-22140) Test the unified binary savepoint - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/07 11:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22141) Manually test exactly-once JDBC sink - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/04/07 11:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22142) Remove console logging for Kafka connector for AZP runs - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/04/07 12:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22143) Flink returns less rows than expected when using limit in SQL - posted by "Peng Yu (Jira)" <ji...@apache.org> on 2021/04/07 12:16:00 UTC, 0 replies.
- [ANNOUNCE] Release 1.13 branch - posted by Dawid Wysakowicz <dw...@apache.org> on 2021/04/07 12:25:57 UTC, 0 replies.
- [jira] [Created] (FLINK-22144) Test display last n exceptions/causes for job restarts in Web UI - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/04/07 16:00:02 UTC, 0 replies.
- [jira] [Created] (FLINK-22145) CheckStyle for scala not work - posted by "MaChengLong (Jira)" <ji...@apache.org> on 2021/04/08 02:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22146) Migrate StateBackend related Chinese docs to latest state backend - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/04/08 02:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22147) Refactor Partition Discovery Logic in KafkaSourceEnumerator - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2021/04/08 03:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22148) Planner rules should use RexCall#equsls to check whether two rexCalls are equivalent - posted by "Shuo Cheng (Jira)" <ji...@apache.org> on 2021/04/08 06:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22149) Test Python UDAF in Group Window - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/04/08 07:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22150) Test user-defined window in Python DataStream API - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/04/08 07:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22151) Implement type inference for agg functions - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/04/08 08:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22152) Fix the bug of same timers are registered multiple times - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/04/08 09:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22153) Manually test the sort-merge blocking shuffle - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2021/04/08 10:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22154) PushFilterIntoTableSourceScanRule fails to deal with IN expressions - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/04/08 12:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22155) Fix EXPLAIN implementation - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/04/08 12:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22156) HiveDialectQueryITCase fails on Azure because of no output for 900 seconds - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2021/04/08 12:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22157) Join & Select a part of composite primary key will cause ArrayIndexOutOfBoundsException - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/04/08 12:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22158) Test native Kubernetes pod template - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2021/04/08 13:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22159) Add documentation for the new window TVF based operations - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/04/08 13:22:00 UTC, 0 replies.
- Dev process: testing one suite only (and are our docs suggesting Java 8 accurate?) - posted by Adam Roberts <ad...@gmail.com> on 2021/04/08 14:29:10 UTC, 4 replies.
- [jira] [Created] (FLINK-22160) Test Window TVF based aggregation and TopN - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/04/08 14:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22161) 'Run Mesos WordCount test' failed on Azure - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/04/08 14:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22162) Make Max Operator name Length Configurable - posted by "Lu Niu (Jira)" <ji...@apache.org> on 2021/04/08 17:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22163) DataTypes implementation for flink-csv with ZonedDateTime support - posted by "François Lacombe (Jira)" <ji...@apache.org> on 2021/04/08 17:27:00 UTC, 0 replies.
- Flink does not cleanup some disk memory after submitting jar over rest - posted by Great Info <gu...@gmail.com> on 2021/04/08 17:52:46 UTC, 0 replies.
- [jira] [Created] (FLINK-22164) Add jobId and JobName variable to JobManager metrics in per-job deployment mode - posted by "Lu Niu (Jira)" <ji...@apache.org> on 2021/04/08 23:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22165) How to set rabbitmq correlationId when using rabbitmq sink in dataStreamEnv - posted by "Spongebob (Jira)" <ji...@apache.org> on 2021/04/09 01:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22166) Empty values with sort willl fail - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/04/09 03:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22167) Partial insert not works when complex fields reorder - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/04/09 03:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22168) Partition insert with union all will fail - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/04/09 03:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22169) Beautify the CliTableauResultView when print - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/04/09 04:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22170) Manual test for hive dialect - posted by "Rui Li (Jira)" <ji...@apache.org> on 2021/04/09 05:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22171) Update the doc about SQL Client - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/04/09 06:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22172) Fix the bug of shared resource among Python Operators of the same slot is not released - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/04/09 06:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22173) UnalignedCheckpointRescaleITCase fails on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/09 06:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22174) `csv.quote-character` does not work for csv format when sink - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2021/04/09 08:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22175) some mistakes in common.md - posted by "wym_maozi (Jira)" <ji...@apache.org> on 2021/04/09 08:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22176) Test SQL Client manually - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/04/09 09:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22177) Add docs for consistent time functions and compatibility specification - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2021/04/09 09:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22178) Support ignore-first-line option in new csv format - posted by "Kurt Young (Jira)" <ji...@apache.org> on 2021/04/09 09:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22179) Manual test time function changes and new time attributes support - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2021/04/09 09:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22180) EmptyWorksetIterationITCase fail on Azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/09 13:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22181) SourceNAryInputChainingITCase hangs on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/09 13:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22182) Incorrect round when dividing two decimals - posted by "Maciej Bryński (Jira)" <ji...@apache.org> on 2021/04/09 13:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22183) Update Website copyright footer - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/04/09 13:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22184) Rest client shutdown on failure runs in netty thread - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/04/09 14:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22185) Add k8s example to flink-statefun-playground - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/04/09 16:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22186) Standalone webUI Internal server error flink.client.program.PackagedProgram.close()V - posted by "刘虎 (Jira)" <ji...@apache.org> on 2021/04/10 08:22:00 UTC, 0 replies.
- Re: [DISCUSS] Support registering custom JobStatusListeners when scheduling a job - posted by Wenhao Ji <pr...@gmail.com> on 2021/04/10 13:32:41 UTC, 0 replies.
- [jira] [Created] (FLINK-22187) Remove description of sync checkpoint mode of HashMapStateBackend - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/04/10 14:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22188) Flink SQL Client Error running SQL job - posted by "Phil Chen (Jira)" <ji...@apache.org> on 2021/04/11 02:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22189) Flink SQL Client Hudi batch write crashes JobManager - posted by "Phil Chen (Jira)" <ji...@apache.org> on 2021/04/11 03:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22190) no guarantee on Flink exactly_once sink to Kafka - posted by "Spongebob (Jira)" <ji...@apache.org> on 2021/04/11 03:19:00 UTC, 0 replies.
- Using FileSystem SQL Connector to Commit Hive Partition Exception - posted by chenzuoli <ch...@163.com> on 2021/04/11 03:59:03 UTC, 7 replies.
- [jira] [Created] (FLINK-22191) PyFlinkStreamUserDefinedFunctionTests.test_udf_in_join_condition_2 fail due to NPE - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/11 05:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22192) HiveTableSinkITCase.testDefaultSerPartStreamingWrite fail - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/11 05:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22193) HiveTableSinkITCase.testNonPartStreamingMrWrite fail - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/11 05:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22194) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers fail due to commit timeout - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/11 05:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22195) YARNHighAvailabilityITCase.testClusterClientRetrieval because of TestTimedOutException - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/11 06:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22196) FlinkRelMdUniqueKeys#getTableUniqueKeys should filter out the column indices which the does not exist - posted by "Lsw_aka_laplace (Jira)" <ji...@apache.org> on 2021/04/11 06:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22197) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fail due to NoSuchFileException - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/11 06:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22198) org.apache.flink.streaming.connectors.kafka.table.KafkaTableITCase hang. - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/11 06:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22199) The JDBC connector does not support TIMESTAMP(6) WITH LOCAL TIME ZONE NOT NULL. - posted by "Tomoyuki NAKAMURA (Jira)" <ji...@apache.org> on 2021/04/11 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22200) Flink SQL Client Error with: Could not find any factory for identifier 'hudi' that implements 'org.apache.flink.table.factories.DynamicTableSourceFactory - posted by "Phil Chen (Jira)" <ji...@apache.org> on 2021/04/11 14:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22201) Incorrect output for simple sql query - posted by "Jamie Brandon (Jira)" <ji...@apache.org> on 2021/04/11 23:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22202) Thread safety in ParquetColumnarRowInputFormat - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/04/12 02:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22203) KafkaChangelogTableITCase.testKafkaCanalChangelogSource fail due to ConcurrentModificationException - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/12 03:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22204) Does it support rate-limiting in flink 1.12? - posted by "ying zhang (Jira)" <ji...@apache.org> on 2021/04/12 03:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22205) Does it support gpu coding in flink? - posted by "ying zhang (Jira)" <ji...@apache.org> on 2021/04/12 05:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22206) Add support server-mode submit for flink SQL. eg : FlinkServer - posted by "xiangtao (Jira)" <ji...@apache.org> on 2021/04/12 06:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22207) Hive Catalog retrieve Flink Properties error - posted by "wangzeyu (Jira)" <ji...@apache.org> on 2021/04/12 06:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22208) Bump snappy-java to 1.1.5+ - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/04/12 07:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22209) Make StreamTask#triggerCheckpointAsync return void - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/12 08:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22210) Log conversion of input channels on debug - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/04/12 08:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22211) DataStream.collect() logs warnings if job is not initialized yet - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/04/12 08:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22212) Clean up RM resource requirement logging - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/04/12 08:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22213) Do not log hashcode of filesystem factory - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/04/12 08:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22215) Rename RECOVERING state to RESTORING - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/04/12 08:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22214) Add quotes around checkpoint storage types - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/04/12 08:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22216) Log start of RM on info, instead of DeclarativeSlotManager - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/04/12 08:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22217) Add quotes around job names - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/04/12 08:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22218) Skip logging of final null input split - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/04/12 09:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22219) Deduplicate enabling of external resources - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/04/12 09:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22220) Log task registration at network on debug - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/04/12 09:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22222) Global config is logged twice by the client for batch jobs - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/04/12 09:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22221) Unclear purpose of spill directories - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/04/12 09:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22223) Explicitly configure rest.address in distribution config - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/04/12 09:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22224) Nettys NativeLibraryLoader is quite noisy - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/04/12 09:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22225) Improve time formatting in LeaderRetrievalUtils - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/04/12 09:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22226) Insufficient slots when submitting jobs results in massive stacktrace - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/04/12 09:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22227) Job name, Job ID and receiving Dispatcher should be logged by the client - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/04/12 09:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22228) Random log exception when tasks finish after a checkpoint was started - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/04/12 09:10:00 UTC, 1 replies.
- [jira] [Created] (FLINK-22229) Noise stacktraces if checkpoints fails because sources are not ready - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/04/12 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22230) Misleading TaskExecutorResourceUtils log messages - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/04/12 09:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22231) Add Rule to deprioritize Critical/Blocker Non-Bugs - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2021/04/12 09:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22232) Improve test coverage for network stack - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/04/12 10:09:01 UTC, 0 replies.
- [jira] [Created] (FLINK-22233) 源码中单词"constaint"拼写错误 - posted by "王高超 (Jira)" <ji...@apache.org> on 2021/04/12 10:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22234) Read savepoint before creating ExecutionGraph - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/04/12 10:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22235) Document stability concerns of flamegraphs for heavier jobs - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/04/12 10:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22236) Document opt-in behavior of flamegraph - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/04/12 10:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22237) Cleanup flamegraph html component - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/04/12 10:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22238) Investigate angular native flamegraph library - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/04/12 10:59:00 UTC, 0 replies.
- [DISCUSS] Flink should rely on flink-shaded SNAPSHOT artifacts - posted by Chesnay Schepler <ch...@apache.org> on 2021/04/12 11:17:16 UTC, 6 replies.
- [jira] [Created] (FLINK-22239) Improve support for JdbcXaSinkFunction - posted by "Yuan Mei (Jira)" <ji...@apache.org> on 2021/04/12 11:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22240) Sanity/phrasing pass for ExternalResourceUtils - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/04/12 11:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22241) Record AllocationID instead of JobID when marking slot active failed - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2021/04/12 13:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22242) Improve missing attribute error on GeneratedAddressedScopedStorage - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/04/12 16:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22243) Reactive Mode parallelism changes are not shown in the job graph visualization in the UI - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/04/12 18:37:00 UTC, 0 replies.
- (无主题) - posted by lian <lz...@126.com> on 2021/04/12 18:48:42 UTC, 0 replies.
- [jira] [Created] (FLINK-22244) Clarify Reactive Mode documentation wrt to timeouts - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/04/12 18:51:00 UTC, 0 replies.
- handle SUSPENDED in ZooKeeperLeaderRetrievalService - posted by chenqin <qi...@gmail.com> on 2021/04/12 23:31:35 UTC, 11 replies.
- [jira] [Created] (FLINK-22245) Reuse PrintUtils.MAX_COLUMN_WIDTH in CliChangelogResultView and CliTableResultView - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/04/13 03:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22246) when use HiveCatalog create table , can't set Table owner property correctly - posted by "xiangtao (Jira)" <ji...@apache.org> on 2021/04/13 03:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22247) can not pass AddressList when connecting to rabbitmq - posted by "Spongebob (Jira)" <ji...@apache.org> on 2021/04/13 04:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22248) JobMasterStopWithSavepointITCase.suspendWithSavepointWithoutComplicationsShouldSucceedAndLeadJobToFinished fail because of TestTimedOutException - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/13 04:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22249) JobMasterStopWithSavepointITCase failed due to status is FAILING - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/13 04:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22250) flink-sql-parser model Class ParserResource lack ParserResource.properties - posted by "WeiNan Zhao (Jira)" <ji...@apache.org> on 2021/04/13 04:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22251) PrometheusReporterEndToEndITCase.testReporter fail because Dispatcher REST endpoint did not start in time. - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/13 06:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22252) Backquotes are not rendered correctly in config option descriptions - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/04/13 06:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22253) Update backpressure monitoring documentation - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/13 08:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22254) Only trigger scale up if the resources have stabilized - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/04/13 09:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22255) AdaptiveScheduler improvements - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/04/13 09:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22256) Persist checkpoint type information - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/04/13 09:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22257) Clarify Flink ConfigOptions Usage - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/04/13 09:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22258) Adaptive Scheduler: Show history of rescales in the Web UI - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/04/13 10:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22259) UnalignedCheckpointITCase fails with "Value too large for header, this indicates that the test is running too long" - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/13 11:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22260) Source schema in CREATE TABLE LIKE statements is not inferred correctly - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/04/13 12:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22261) Python StreamingModeDataStreamTests is failed on Azure - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/04/13 13:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22262) Flink on Kubernetes ConfigMaps are created without OwnerReference - posted by "Andrea Peruffo (Jira)" <ji...@apache.org> on 2021/04/13 14:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22263) Using TIMESTAMPADD function with partition value has some problem when push partition into TableSource - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2021/04/13 15:30:00 UTC, 0 replies.
- Re: [DISCUSS]FLIP-150: Introduce Hybrid Source - posted by Stephan Ewen <se...@apache.org> on 2021/04/13 19:14:32 UTC, 5 replies.
- Add jobId and JobName variable to JobManager metrics in per-job deployment mode - posted by Lu Niu <qq...@gmail.com> on 2021/04/13 21:58:56 UTC, 1 replies.
- [jira] [Created] (FLINK-22264) Fix misleading statement about per-job mode support for Kubernetes in Concept/Flink Architecture page - posted by "Fuyao Li (Jira)" <ji...@apache.org> on 2021/04/14 01:13:00 UTC, 0 replies.
- subscribed - posted by boyi <zh...@163.com> on 2021/04/14 02:49:26 UTC, 0 replies.
- [jira] [Created] (FLINK-22265) Abnormal document display - posted by "BoYi Zhang (Jira)" <ji...@apache.org> on 2021/04/14 03:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22266) JobMasterStopWithSavepointITCase.throwingExceptionOnCallbackWithoutRestartsHelper fail - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/14 03:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22267) Savepoint an application for source of upsert-kafka, then restart the application from the savepoint, state not be recovered. - posted by "Carl (Jira)" <ji...@apache.org> on 2021/04/14 03:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22268) JobMasterStopWithSavepointITCase.testRestartCheckpointCoordinatorIfStopWithSavepointFails fail because of "Not all required tasks are currently running." - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/14 03:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22269) JobMasterStopWithSavepointITCase.throwingExceptionOnCallbackWithRestartsShouldSimplyRestartInSuspend failed. - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/14 03:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22270) Python test pipeline no output for 900 seconds - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/14 03:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22271) FlinkSQL Read Hive(parquet file) field does not exist - posted by "moran (Jira)" <ji...@apache.org> on 2021/04/14 06:51:00 UTC, 0 replies.
- Re: [VOTE] Deprecating Mesos support - posted by Konstantin Knauf <kn...@apache.org> on 2021/04/14 07:05:37 UTC, 9 replies.
- [jira] [Created] (FLINK-22272) Some scenes can't drop table by hive catalog - posted by "wangzeyu (Jira)" <ji...@apache.org> on 2021/04/14 07:26:00 UTC, 0 replies.
- Re: [BULK]Re: [SURVEY] Remove Mesos support - posted by Matthias Pohl <ma...@ververica.com> on 2021/04/14 07:36:43 UTC, 0 replies.
- [DISCUSS] Add checkpoint id in FLIP-27 source SplitEnumerator::snapshotState() - posted by "Zhou, Brian" <B....@dell.com> on 2021/04/14 07:42:34 UTC, 2 replies.
- [jira] [Created] (FLINK-22273) Add documentation for General Python Group Window Aggregation in Python Table API - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/04/14 08:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22274) SQL parser fails to parse group by statements with brackets in views - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/04/14 09:05:00 UTC, 0 replies.
- Update on Implementation of Flink Jira Process & Bot (go live today) - posted by Konstantin Knauf <kn...@apache.org> on 2021/04/14 09:25:24 UTC, 4 replies.
- [jira] [Created] (FLINK-22275) Datagen add a max lag option for a series of timestamp-related types - posted by "Yi Tang (Jira)" <ji...@apache.org> on 2021/04/14 09:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22276) ExceptionHistoryEntryExtractor throws fatal error when task failure - posted by "Jin Xing (Jira)" <ji...@apache.org> on 2021/04/14 09:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22277) Refactor sql client's DynamicResult - posted by "Kurt Young (Jira)" <ji...@apache.org> on 2021/04/14 10:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22278) Refactor sql client's DynamicResult - posted by "Kurt Young (Jira)" <ji...@apache.org> on 2021/04/14 10:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22279) Upload the pipeline.classpaths file in yarn application mode - posted by "renjianxu (Jira)" <ji...@apache.org> on 2021/04/14 13:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22280) Add XML output format for Flink Table - posted by "François Lacombe (Jira)" <ji...@apache.org> on 2021/04/14 13:35:00 UTC, 0 replies.
- [PSA] Documentation is currently not being updated - posted by Chesnay Schepler <ch...@apache.org> on 2021/04/14 16:48:16 UTC, 2 replies.
- [jira] [Created] (FLINK-22281) flink sql - posted by "xx chai (Jira)" <ji...@apache.org> on 2021/04/15 01:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22282) Move creation of SplitEnumerator to the SourceCoordinator thread - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2021/04/15 01:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22283) GraphiteReporter Metrics named xxx alredy exists - posted by "HideOnBush (Jira)" <ji...@apache.org> on 2021/04/15 03:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22284) Null address will be logged when channel is closed in NettyPartitionRequestClient - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2021/04/15 03:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22285) org.apache.flink.yarn.YARNHighAvailabilityITCase Hang - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/15 06:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22286) Fix the state doesn't support custom python class - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/04/15 07:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22287) Java documentation of mini cluster should mention usage of before() and after() - posted by "Svend Vanderveken (Jira)" <ji...@apache.org> on 2021/04/15 08:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22289) Update JDBC XA sink docs - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/04/15 08:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22288) Remove unnecesary argument from JdbcSink.exactlyOnceSink - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/04/15 08:49:00 UTC, 0 replies.
- Welcome to create Pulsar + Flink solutions at Pulsar Hackathon! - posted by Dianjin Wang <dj...@streamnative.io.INVALID> on 2021/04/15 09:25:16 UTC, 0 replies.
- [jira] [Created] (FLINK-22290) Add new unaligned checkpiont options to Python API. - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/04/15 09:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22291) Fix split switching in HiveInputFormatPartitionReader - posted by "Miklos Gergely (Jira)" <ji...@apache.org> on 2021/04/15 10:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22292) Add documentation about state access in Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/04/15 11:16:00 UTC, 0 replies.
- Please submit talk proposals for the ApacheCons as soon as possilbe - posted by Christofer Dutz <ch...@c-ware.de> on 2021/04/15 11:20:29 UTC, 0 replies.
- [jira] [Created] (FLINK-22294) Throw IllegalArgumentException when getNumFiles with partitions on different hdfs nameservices - posted by "Junfan Zhang (Jira)" <ji...@apache.org> on 2021/04/15 11:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22293) Throw IllegalArgumentException when getNumFiles with partitions on different hdfs nameservices - posted by "Junfan Zhang (Jira)" <ji...@apache.org> on 2021/04/15 11:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22295) Document sort-merge blocking shuffle - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/04/15 12:21:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink Stateful Functions 3.0.0 released - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2021/04/15 15:08:35 UTC, 0 replies.
- [jira] [Created] (FLINK-22296) Introduce Preconditions-util into Python API - posted by "Roc Marshal (Jira)" <ji...@apache.org> on 2021/04/15 16:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22297) Perform early check to ensure that the length of the result is the same as the input for Pandas UDF - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/04/16 03:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22298) The ExecNode's id should always start from 1 in json plan test - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/04/16 03:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22299) should remind users to ignoreParseErrors option when parser failed - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/04/16 04:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22300) Why TimeEvictor of Keyed Windows evictor do not support ProcessingTime of TimeCharacteristic - posted by "Bo Huang (Jira)" <ji...@apache.org> on 2021/04/16 05:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22301) Statebackend and CheckpointStorage type is not shown in the Web UI - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/04/16 06:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22302) Restructure SQL "Queries" documentation into one page per operation - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/04/16 07:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22303) FlinkRelMdFilteredColumnInterval should remapping the columnIndex of the inputRel otherwise may cause IllegalArgumentException or get incorrectly metadata - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2021/04/16 07:24:00 UTC, 0 replies.
- [DISCUSS] Releasing Flink 1.12.3 - posted by Arvid Heise <ar...@apache.org> on 2021/04/16 07:46:04 UTC, 3 replies.
- [jira] [Created] (FLINK-22304) Refactor some interfaces for TVF based window to improve the scalability - posted by "Shuo Cheng (Jira)" <ji...@apache.org> on 2021/04/16 08:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22305) Increase the default value of taskmanager.network.sort-shuffle.min-buffers - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2021/04/16 08:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22306) KafkaITCase.testCollectingSchema failed on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/04/16 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22307) Increase the data writing cache size of sort-merge blocking shuffle - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2021/04/16 09:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22308) Fix CliTableauResultView print results after cancel in STREAMING mode - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/04/16 10:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22309) Reduce response time when using SQL Client submit query(SELECT) - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/04/16 10:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22310) The result of LogicalWindowJsonDeserializer is incorrect - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/04/16 10:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22312) YARNSessionFIFOSecuredITCase>YARNSessionFIFOITCase.checkForProhibitedLogContents due to the heartbeat exception with Yarn RM - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/16 10:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22311) Flink JDBC XA connector need to set maxRetries to 0 to properly working - posted by "Maciej Bryński (Jira)" <ji...@apache.org> on 2021/04/16 10:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22313) Redundant CAST in plan when selecting window start and window end in window agg - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/04/16 10:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22314) AggRecordsCombiner should combine buffered records first instead of accumulate on state directly - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/04/16 12:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22315) Support ADD column/constraint/watermark for ALTER TABLE statement - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/04/16 13:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22316) Support MODIFY column/constraint/watermark for ALTER TABLE statement - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/04/16 13:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22318) Support RENAME column name for ALTER TABLE statement - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/04/16 13:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22317) Support DROP column/constraint/watermark for ALTER TABLE statement - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/04/16 13:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22320) Add documentation for new introduced ALTER TABLE statements - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/04/16 13:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22319) Support RESET table option for ALTER TABLE statement - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/04/16 13:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22321) Drop old user-defined function stack - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/04/16 14:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22322) Build hang when compiling Web UI - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/16 14:13:00 UTC, 0 replies.
- confluence permission apply - posted by Roc Marshal <fl...@126.com> on 2021/04/16 14:16:41 UTC, 1 replies.
- [jira] [Created] (FLINK-22323) JobEdges Typos - posted by "lqjacklee (Jira)" <ji...@apache.org> on 2021/04/16 14:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22324) Backport FLINK-18071 for 1.12.x - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2021/04/16 15:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22325) Channel state iterator is accessed concurrently without proper synchronization - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/04/16 15:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22326) Job contains Iterate Operator always fails on Checkpoint - posted by "Lu Niu (Jira)" <ji...@apache.org> on 2021/04/16 19:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22327) NPE exception happens if it throws exception in finishBundle during job shutdown - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/04/16 22:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22328) Failed to send data to Kafka: Producer attempted an operation with an old epoch - posted by "孙峰 (Jira)" <ji...@apache.org> on 2021/04/17 06:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22329) Missing crendentials in jobconf causes repeated authentication in Hive datasources - posted by "Junfan Zhang (Jira)" <ji...@apache.org> on 2021/04/17 10:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22330) Bumps checkstyle, junit, log4j version for security - posted by "Brandon Jiang (Jira)" <ji...@apache.org> on 2021/04/17 14:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22331) CLI Frontend (RestClient) doesn't work on Apple M1 - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/04/17 18:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22332) ConnectedComponentsWithObjectMapITCase.testJobWithoutObjectReuse due to NPE when calling "notifyDataAvailable" - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/18 02:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22333) Elasticsearch7DynamicSinkITCase.testWritingDocuments fail due to deploy task timeout. - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/18 02:49:00 UTC, 0 replies.
- [VOTE] Release 1.13.0, release candidate #1 - posted by Guowei Ma <gu...@gmail.com> on 2021/04/18 20:54:29 UTC, 1 replies.
- [jira] [Created] (FLINK-22334) Fail to translate the hive-sql in STREAMING mode - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/04/19 01:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22335) Increase default resource wait timeout for the adaptive scheduler - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/04/19 02:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22336) [umbrella] Enhance testing for built-in functions - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/04/19 03:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22337) Support 'ALTER TABLE ADD' statement - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2021/04/19 03:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22339) Fix some encoding exceptions were not thrown in cython coders - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/04/19 03:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22338) Clear watermark output when test finished for FromElementSourceFunctionWithWatermark - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/04/19 03:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22340) Concurrent access to ThresholdMeter may lead to NPE - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/04/19 05:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22341) Describe table doesn't work with hive dialect - posted by "Rui Li (Jira)" <ji...@apache.org> on 2021/04/19 05:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22342) FlinkKafkaProducerITCase fails with producer leak - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/19 07:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22343) Running HA per-job cluster (rocks, non-incremental) end-to-end test fails on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/19 07:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22344) KafkaTableITCase.testKafkaSourceSinkWithKeyAndFullValue times out - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/19 07:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22345) CoordinatorEventsExactlyOnceITCase hangs on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/19 07:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22346) sql-client-defaults.yaml should be removed from dist - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/04/19 07:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22347) Support renaming shipped archives on Yarn - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2021/04/19 07:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22348) Fix the Python operators of Python DataStream API doesn't use managed memory in execute_and_collect - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/04/19 08:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22350) Add the doc of user-defined window in Python DataStream API - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/04/19 09:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22349) LOCALTIMESTAMP doesn't return correct result when setting session time zone to 'UTC-09:00' - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/04/19 09:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22351) Promote the log level of the resource declaration to INFO in FineGrainedSlotManager - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2021/04/19 09:28:00 UTC, 0 replies.
- [RESULT][VOTE] Deprecating Mesos support - posted by Matthias Pohl <ma...@ververica.com> on 2021/04/19 09:46:43 UTC, 1 replies.
- [jira] [Created] (FLINK-22352) Deprecate Mesos Support in documentation - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/04/19 09:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22353) Introduce CPU metrics in TaskManager and JobManager - posted by "Roc Marshal (Jira)" <ji...@apache.org> on 2021/04/19 12:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22354) Failed to define watermark on computed column of CURRENT_TIMESTAMP and LOCALTIMESTAMP - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/04/19 12:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22355) Simple Task Manager Memory Model image does not show up - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/19 13:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22356) Filesystem/Hive partition file is not committed when watermark is applied on rowtime of TIMESTAMP_LTZ type - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/04/19 13:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22357) Mark FLIP-27 Source API as stable - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2021/04/19 16:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22358) Add missing stability annotation to Split Reader API classes - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2021/04/19 16:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22359) Python tests do not pass on 1.x branch if it has not been released - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/19 16:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22360) Docker e2e tests do not work on 1.x branch if it has not been released - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/19 16:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22361) flink run -c not upload udf jar - posted by "todd (Jira)" <ji...@apache.org> on 2021/04/20 02:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22362) Don't appear target address when taskmanager connect to jobmanager error - posted by "Yu Wang (Jira)" <ji...@apache.org> on 2021/04/20 03:13:00 UTC, 0 replies.
- Re:[jira] [Created] (FLINK-21986) taskmanager native memory not release timely after restart - posted by zoltar9264 <zo...@163.com> on 2021/04/20 03:34:47 UTC, 1 replies.
- [jira] [Created] (FLINK-22363) Python test pipeline failed because of failure of downloading deps. - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/20 04:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22364) Translate the page of "Data Sources" to Chinese. - posted by "Senhong Liu (Jira)" <ji...@apache.org> on 2021/04/20 04:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22365) Images are not displayed in "Data Sources" documentation page - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/04/20 04:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22366) HiveSinkCompactionITCase fails on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/20 06:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22367) JobMasterStopWithSavepointITCase.terminateWithSavepointWithoutComplicationsShouldSucceedAndLeadJobToFinished times out - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/20 06:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22368) UnalignedCheckpointITCase hangs on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/20 06:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22369) RocksDB state backend might occur ClassNotFoundException when deserializing on TM side - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/04/20 07:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22370) ParquetColumnarRowSplitReader#reachedEnd() returns false after it returns true - posted by "Danny Chen (Jira)" <ji...@apache.org> on 2021/04/20 07:56:00 UTC, 0 replies.
- [DISCUSS] Simplify SQL lookup join (temporal join with latest) syntax - posted by Gyula Fóra <gy...@gmail.com> on 2021/04/20 08:55:14 UTC, 2 replies.
- [jira] [Created] (FLINK-22371) Chinese grammatical error - posted by "simenliuxing (Jira)" <ji...@apache.org> on 2021/04/20 10:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22372) Rename LogicalTypeCasts class variables in the castTo method. - posted by "Wong Mulan (Jira)" <ji...@apache.org> on 2021/04/20 12:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22373) Create release notes for 1.13 - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/20 13:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22374) ConfigOptionsDocsCompletenessITCase fails on traivs - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2021/04/20 13:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22375) Disable JDBC XA connection pooling if unnecessary - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/04/20 14:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22376) SequentialChannelStateReaderImpl may recycle buffer twice - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/04/20 14:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22377) Ignore if writer is stopped when aborting channel state writing - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/04/20 14:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22378) Type mismatch when declaring SOURCE_WATERMARK on TIMESTAMP_LTZ column - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/04/20 15:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22379) Introduce a new JobStatus to avoid premature checkpoint triggering - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/04/20 15:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22380) Pub/Sub Lite Connector for Flink - posted by "Evan Palmer (Jira)" <ji...@apache.org> on 2021/04/20 19:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22381) RocksDBStateBackendTests::test_get_set_number_of_transfering_threads fails on azure - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/04/20 20:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22382) ProcessFailureCancelingITCase.testCancelingOnProcessFailure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/20 20:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22383) HiveParser may fail to call Flink functions - posted by "Rui Li (Jira)" <ji...@apache.org> on 2021/04/21 02:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22384) Chinese typos - posted by "simenliuxing (Jira)" <ji...@apache.org> on 2021/04/21 03:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22385) Type mismatch in NetworkBufferPool - posted by "sharkd tu (Jira)" <ji...@apache.org> on 2021/04/21 04:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22386) Introduce cache for docker images - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/21 06:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22387) UpsertKafkaTableITCase hangs - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/21 07:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22388) KafkaITCase.testMetricsAndEndOfStream times out on topic creation - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/21 07:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22389) Expose Message Batches to SDKs - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2021/04/21 07:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22390) Support for OpenTracing - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2021/04/21 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22391) Support State Introspection - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2021/04/21 08:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22392) Check 1.13 licensing - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/21 08:35:00 UTC, 0 replies.
- [DISCUSS] Merge StreamTableEnvironment.to/fromChangelogStream to release-1.13 - posted by Timo Walther <tw...@apache.org> on 2021/04/21 08:52:06 UTC, 4 replies.
- [jira] [Created] (FLINK-22393) Translate the page of "Execution Mode (Batch/Streaming)" into Chinese - posted by "Jianzhang Chen (Jira)" <ji...@apache.org> on 2021/04/21 09:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22394) Auto Close issues with resolution "Auto Closed" instead of "Fixed" - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2021/04/21 09:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22395) Extend RetryRule to allow class-wide defaults - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/04/21 09:27:00 UTC, 0 replies.
- 来自窦永鹏的邮件 - posted by 窦永鹏 <sg...@163.com> on 2021/04/21 09:54:25 UTC, 0 replies.
- [jira] [Created] (FLINK-22396) Unnecessary entries in sql hbase-1.4 connector NOTICE file - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/21 11:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22397) OrcFileSystemITCase fails on Azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/21 11:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22398) The code comments in InputOutputFormatVertex are incorrect - posted by "Li (Jira)" <ji...@apache.org> on 2021/04/21 12:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22399) KinesisTableApiITCase times out - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/04/21 14:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22400) NPE problem when call HiveInspectors.toFlinkObject for hive-exec 2.0.0 - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2021/04/21 15:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22401) Python tests fail with "Slot ... is not allocated by job ..." - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/21 15:43:00 UTC, 1 replies.
- Re: Task Local Recovery with mountable disks in the cloud - posted by Stephan Ewen <se...@apache.org> on 2021/04/21 17:26:13 UTC, 1 replies.
- [ANNOUNCE] New Apache Flink Committer - Rui Li - posted by Jark Wu <im...@gmail.com> on 2021/04/22 03:20:34 UTC, 22 replies.
- [jira] [Created] (FLINK-22402) Add hive dialect test in sql-client - posted by "Rui Li (Jira)" <ji...@apache.org> on 2021/04/22 06:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22403) Update Chinese version of JDBC sink docs - posted by "Yuan Mei (Jira)" <ji...@apache.org> on 2021/04/22 07:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22404) Document inconsistencies around +I and +U generation in retract streams - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/04/22 07:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22405) Support fixed-lengh chars in the LeadLag built-in function - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/04/22 08:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22406) ReactiveModeITCase.testScaleDownOnTaskManagerLoss() - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2021/04/22 08:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22407) upgrade log4j to 2.14 - posted by "Svend Vanderveken (Jira)" <ji...@apache.org> on 2021/04/22 09:01:00 UTC, 0 replies.
- [ANNOUNCE] Flink Jira Bot fully live (& Useful Filters to Work with the Bot) - posted by Konstantin Knauf <kn...@apache.org> on 2021/04/22 09:16:19 UTC, 2 replies.
- [jira] [Created] (FLINK-22408) Flink Table Parsr Hive Drop Partitions Syntax unparse is Error - posted by "Ma Jun (Jira)" <ji...@apache.org> on 2021/04/22 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22409) Rename ResourceProfile class throwUnsupportedOperationExecptionIfUnknown method - posted by "simenliuxing (Jira)" <ji...@apache.org> on 2021/04/22 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22410) "Resuming Savepoint (rocks, scale up, heap timers)" fails with BindException - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/22 09:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22411) Checkpoint failed caused by Mkdirs failed to create file, the path for Flink state.checkpoints.dir in docker-compose can not work from Flink Operations Playground - posted by "lisijie (Jira)" <ji...@apache.org> on 2021/04/22 09:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22412) SplitAggregateRule support optimization of aggregate function reuse - posted by "tartarus (Jira)" <ji...@apache.org> on 2021/04/22 10:53:02 UTC, 0 replies.
- [jira] [Created] (FLINK-22413) Hide Checkpointing page in the UI for batch jobs - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/04/22 11:34:02 UTC, 0 replies.
- [jira] [Created] (FLINK-22414) Consider {{env.hadoop.conf.dir}} when looking for the hadoop configuration - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/04/22 12:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22415) JsonBatchFileSystemITCase fails on Azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/22 13:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22416) UpsertKafkaTableITCase hangs when collecting results - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/22 14:10:00 UTC, 0 replies.
- Flink SQL ordering issues ? - posted by Etienne Chauchot <ec...@apache.org> on 2021/04/22 14:24:02 UTC, 1 replies.
- [jira] [Created] (FLINK-22417) OrcFileSystemITCase.testOrcFilterPushDown fails on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/04/22 15:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22418) The currently activated tab in the same page isn't consistent - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/04/23 02:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22419) testScheduleRunAsync fail - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/23 02:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22420) UnalignedCheckpointITCase failed - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/23 03:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22421) Does flink support multi cluster deployment with HA on multi kubernetes clusters - posted by "Bhagi (Jira)" <ji...@apache.org> on 2021/04/23 05:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22422) -ynm option doesn't effect when deploying flink on yarn - posted by "Spongebob (Jira)" <ji...@apache.org> on 2021/04/23 06:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22423) Log error cause for state transition in ExecutionGraph - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/23 07:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22424) Writing to already released buffers potentially causing data corruption - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/04/23 07:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22425) allowedLateness and sideOutput not having an effect - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/04/23 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22426) Reduce usage of TableSchema in the planner - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/04/23 09:03:00 UTC, 0 replies.
- [DISCUSS] Add async backpressure support to FlinkKafkaProducer - posted by Wenhao Ji <pr...@gmail.com> on 2021/04/23 09:15:06 UTC, 0 replies.
- [jira] [Created] (FLINK-22427) Support default value option to simplify data clean process - posted by "张超明 (Jira)" <ji...@apache.org> on 2021/04/23 09:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22428) Translate timezone page to Chinese - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2021/04/23 10:53:00 UTC, 0 replies.
- [DISCUSS] Feedback Collection Jira Bot - posted by Konstantin Knauf <kn...@apache.org> on 2021/04/23 12:25:12 UTC, 0 replies.
- [jira] [Created] (FLINK-22429) Exlude Sub-Tasks in all bot "stale-unassigned" rule of Jira Bot - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2021/04/23 12:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22430) Increase "stale-assigned.stale-days" to 14 - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2021/04/23 12:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22431) AdaptiveScheduler does not log failure cause when recovering - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/04/23 13:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22432) Update upgrading.md with 1.13.x - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/23 13:31:00 UTC, 0 replies.
- CFP for ApacheCon 2021 closes in ONE WEEK - posted by Rich Bowen <rb...@apache.org> on 2021/04/23 15:00:01 UTC, 0 replies.
- [jira] [Created] (FLINK-22433) CoordinatorEventsExactlyOnceITCase stalls on Adaptive Scheduler - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2021/04/23 15:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22434) Dispatcher does not store suspended jobs in execution graph store - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/04/23 15:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22436) twitter datastream connector gets Invalid 'expires' attribute - posted by "Jason Perez (Jira)" <ji...@apache.org> on 2021/04/23 15:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22435) twitter datastream connector gets Invalid 'expires' attribute - posted by "Jason Perez (Jira)" <ji...@apache.org> on 2021/04/23 15:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22437) Miss adding parallesim for filter operator in batch mode - posted by "zoucao (Jira)" <ji...@apache.org> on 2021/04/23 16:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22438) add numRecordsOut metric for Async IO - posted by "Zhengqi Zhang (Jira)" <ji...@apache.org> on 2021/04/23 17:08:00 UTC, 0 replies.
- [VOTE] Release 1.13.0, release candidate #2 - posted by Dawid Wysakowicz <dw...@apache.org> on 2021/04/23 17:35:59 UTC, 22 replies.
- [VOTE] Release 1.12.3, release candidate #1 - posted by Arvid Heise <ar...@apache.org> on 2021/04/23 21:52:09 UTC, 5 replies.
- [jira] [Created] (FLINK-22439) UnalignedCheckpointITCase hangs - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/24 03:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22440) UpsertKafkaTableITCase fail due to create topic timeout - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/24 03:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22441) In Flink v1.11.3 contains netty(version:3.10.6) netty(version:4.1.60) . There are many vulnerabilities, like CVE-2021-21409 etc. please confirm these version and fix. thx - posted by "张健 (Jira)" <ji...@apache.org> on 2021/04/24 12:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22442) Using scala api to change the TimeCharacteristic of the PatternStream is invalid - posted by "Cedric Chen (Jira)" <ji...@apache.org> on 2021/04/24 13:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22443) can not be execute an extreme long sql under batch mode - posted by "macdoor615 (Jira)" <ji...@apache.org> on 2021/04/25 02:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22444) Drop async checkpoint description of state backends in Chinese docs - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/04/25 02:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22445) Add more examples of row-based operations in PyFlink doc - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/04/25 03:29:00 UTC, 0 replies.
- when should `FlinkYarnSessionCli` be included for parsing CLI arguments? - posted by Tony Wei <to...@gmail.com> on 2021/04/25 03:32:47 UTC, 7 replies.
- [jira] [Created] (FLINK-22446) Relocate dependencies in hive connector uber jar - posted by "Rui Li (Jira)" <ji...@apache.org> on 2021/04/25 06:00:01 UTC, 0 replies.
- [jira] [Created] (FLINK-22447) when job failed and restore from rocksdb, it produced a exception "Could not load the native RocksDB library" - posted by "zlzhang0122 (Jira)" <ji...@apache.org> on 2021/04/25 06:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22448) FlinkRexUtil create Sarg String array elemet supplement space - posted by "Junning Liang (Jira)" <ji...@apache.org> on 2021/04/25 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22449) Casting an invalid constant string to int throws exception from SinkNotNullEnforcer - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/04/25 08:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22450) SQL parser fails to parse subquery containing INTERSECT in a view - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/04/25 08:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22451) Support (*) as parameter of table UserDefinedFunction - posted by "Yi Tang (Jira)" <ji...@apache.org> on 2021/04/25 09:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22452) Support specifying custom transactional.id prefix in FlinkKafkaProducer - posted by "Wenhao Ji (Jira)" <ji...@apache.org> on 2021/04/25 09:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22453) Can not stop job when not ust "-m" option - posted by "Liu (Jira)" <ji...@apache.org> on 2021/04/25 09:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22454) Ignore CAST condition in temporal join - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/04/25 09:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22455) FlinkRelBuilder#windowAggregate will throw ClassCastException when function reuse - posted by "tartarus (Jira)" <ji...@apache.org> on 2021/04/25 14:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22456) Support InitializeOnMaster and FinalizeOnMaster to be used in InputFormat - posted by "Li (Jira)" <ji...@apache.org> on 2021/04/26 02:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22457) KafkaSourceLegacyITCase.testMultipleSourcesOnePartition fails because of timeout - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/26 02:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22458) Failed when operating empty catalog table - posted by "Spongebob (Jira)" <ji...@apache.org> on 2021/04/26 03:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22459) FlinkKafkaProducerITCase testScaleUpAfterScalingDown failed because of Timeout expired after 60000milliseconds while awaiting EndTxn(COMMIT) - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/26 03:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22460) Conversion to relational algebra failed caused by '' - posted by "Haiwei Zhou (Jira)" <ji...@apache.org> on 2021/04/26 03:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22461) Resuming Savepoint (file, async, scale down) end-to-end test failed because of binding port fail - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/26 03:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22462) JdbcExactlyOnceSinkE2eTest.testInsert failed because of too many clients. - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/26 03:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22463) IllegalArgumentException is thrown in WindowAttachedWindowingStrategy when two phase is enabled for distinct agg - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/04/26 03:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22464) OperatorEventSendingCheckpointITCase.testOperatorEventLostWithReaderFailure hangs with `AdaptiveScheduler` - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/26 03:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22465) KafkaSourceITCase.testValueOnlyDeserializer hangs - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/26 04:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22466) KafkaSourceLegacyITCase.testOneToOneSources fail because the OperatorEvent lost - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/26 04:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22467) OverAggregateITCase.testRowNumberOnOver is unstable - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/04/26 04:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22468) Make StateFun build with Java 11 - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2021/04/26 04:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22469) HistoryServer starts with NoSuchFileException - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2021/04/26 05:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22470) The root cause of the exception encountered during compiling the job was not exposed to users in certain cases - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/04/26 07:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22471) Use formatted descriptions for connector options - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/04/26 07:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22472) The real partition data produced time is behind meta(_SUCCESS) file produced - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2021/04/26 07:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22473) Kinesis connector options are not listed by its factory - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/04/26 07:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22474) Display job configuration in web-ui - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/04/26 07:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22475) Datagen connector does not list its available options with placeholders - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/04/26 07:39:00 UTC, 0 replies.
- [DISCUSS] Using timeouts in JUnit tests - posted by Dawid Wysakowicz <dw...@apache.org> on 2021/04/26 07:54:04 UTC, 12 replies.
- [jira] [Created] (FLINK-22476) Extend the description of the config option `execution.target` - posted by "Wei-Che Wei (Jira)" <ji...@apache.org> on 2021/04/26 09:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22477) Remove DefaultSlotPoolServiceFactory and SlotPoolImpl - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/04/26 11:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22478) confluent schema registry avro (de)serialization https support - posted by "Lars Bachmann (Jira)" <ji...@apache.org> on 2021/04/26 12:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22479) [Kinesis][Consumer] Potential lock-up under error condition - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2021/04/26 13:00:04 UTC, 0 replies.
- Last boarding call for ApacheCon NA/EU and Asia .... CFP closes in a week ... - posted by Christofer Dutz <ch...@c-ware.de> on 2021/04/26 14:17:31 UTC, 0 replies.
- [jira] [Created] (FLINK-22480) KafkaChangelogTableITCase hangs on Azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/26 14:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22481) RocksDBStateBackendWindowITCase times out on Azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/26 14:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22482) ParquetFileSystemITCase fails on Azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/26 14:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22483) Recover checkpoints when JobMaster gains leadership - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/04/26 15:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22484) Buit-in functions for collections - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2021/04/26 15:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22485) Support client attach on application mode - posted by "Junfan Zhang (Jira)" <ji...@apache.org> on 2021/04/27 03:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22486) Wrong results of the IN operator - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/04/27 03:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22487) Support `print` to print logs in PyFlink - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/04/27 04:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22488) KafkaSourceLegacyITCase.testOneToOneSources failed due to "OperatorEvent from an OperatorCoordinator to a task was lost" - posted by "Dong Lin (Jira)" <ji...@apache.org> on 2021/04/27 05:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22489) subtask backpressure indicator shows value for entire job - posted by "David Anderson (Jira)" <ji...@apache.org> on 2021/04/27 09:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22490) YarnApplicationClusterEntryPoint does not pass configuration parameters - posted by "ZRCoder (Jira)" <ji...@apache.org> on 2021/04/27 10:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22491) JdbcBatchingOutputFormat checks size of buffer in TableBufferReducedStatementExecutor - posted by "Leon Hao (Jira)" <ji...@apache.org> on 2021/04/27 11:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22492) KinesisTableApiITCase with wrong results - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/27 12:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22493) AdaptiveSchedulerITCase found unexpected files - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/27 14:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22494) Avoid discarding checkpoints in case of failure - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/04/27 16:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22495) Document how to use the reactive mode on K8s - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/04/27 17:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22496) ClusterEntrypointTest.testCloseAsyncShouldBeExecutedInShutdownHook failed - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/28 02:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22497) When using DefaultRollingPolicy in StreamingFileSink, the file will be finished delayed - posted by "ChangjiGuo (Jira)" <ji...@apache.org> on 2021/04/28 03:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22498) cast the primary key for source table that has a decimal primary key as string, and then insert into a kudu table that has a string primary key throw the exception : UpsertStreamTableSink requires that Table has a full primary keys if it is updated - posted by "Carl (Jira)" <ji...@apache.org> on 2021/04/28 03:36:00 UTC, 0 replies.
- flink1.12.1 read hive orc table exception. could not initialize class org.apache.orc.impl.ZlibCodec - posted by WSJian <52...@qq.com> on 2021/04/28 03:36:18 UTC, 1 replies.
- [jira] [Created] (FLINK-22499) JDBC sink table-api support "sink.parallelism" ? - posted by "ranqiqiang (Jira)" <ji...@apache.org> on 2021/04/28 03:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22500) flink stop 命令找不到00000000000000000000000000000000 - posted by "陈孝忠 (Jira)" <ji...@apache.org> on 2021/04/28 07:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22501) Flink HiveCatalog ParquetTable join Dim table error - posted by "zhanglw (Jira)" <ji...@apache.org> on 2021/04/28 07:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22502) DefaultCompletedCheckpointStore drops unrecoverable checkpoints silently - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/04/28 07:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22503) getting eroor on select query in flink sql - posted by "Bhagi (Jira)" <ji...@apache.org> on 2021/04/28 08:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22504) add serialVersionUID for all Serializable class - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2021/04/28 08:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22505) Limit the precision of Resource - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2021/04/28 08:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22506) YARN job cluster stuck in retrying creating JobManager if savepoint is corrupted - posted by "Paul Lin (Jira)" <ji...@apache.org> on 2021/04/28 09:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22507) add serialVersionUID for all Serializable class in table module - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2021/04/28 09:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22508) add serialVersionUID for all Serializable class in non-table module - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2021/04/28 09:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22509) ./bin/flink run -m yarn-cluster -d submission leads to IllegalStateException - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/04/28 11:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22510) ConfigurationUtils always serializes Duration to nanoseconds - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/04/28 12:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22511) Fix the bug of non-composite result type in Python TableAggregateFunction - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/04/28 12:17:00 UTC, 0 replies.
- [RESULT][VOTE] Release 1.12.3, release candidate #1 - posted by Arvid Heise <ar...@apache.org> on 2021/04/28 12:30:30 UTC, 0 replies.
- [jira] [Created] (FLINK-22512) Can't call current_timestamp with hive dialect for hive-3.1 - posted by "Rui Li (Jira)" <ji...@apache.org> on 2021/04/28 12:55:00 UTC, 0 replies.
- Does flink support multi cluster deployment with HA on multi k8s clusters - posted by "bhagi@R" <bh...@gmail.com> on 2021/04/28 13:25:46 UTC, 4 replies.
- [jira] [Created] (FLINK-22513) Failed to upload compile artifacts - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/04/28 15:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22514) TypeExtractor - Improving log message - posted by "Avishay Balderman (Jira)" <ji...@apache.org> on 2021/04/28 15:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22515) Add Documentation for Flink Glue Schema Registry Integration - posted by "Linyu Yao (Jira)" <ji...@apache.org> on 2021/04/28 18:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22516) ResourceManager cannot establish leadership - posted by "Ricky Burnett (Jira)" <ji...@apache.org> on 2021/04/28 21:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22517) Fix pickle compatibility problem in different Python versions - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/04/29 02:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22518) Translate the page of "High Availability (HA)" into Chinese - posted by "movesan (Jira)" <ji...@apache.org> on 2021/04/29 03:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22519) Have python-archives also take tar.gz - posted by "Yik San Chan (Jira)" <ji...@apache.org> on 2021/04/29 03:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22520) KafkaSourceLegacyITCase.testMultipleSourcesOnePartition hangs - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/04/29 04:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22521) flink stop 00000000000000000000000000000000 error - posted by "陈孝忠 (Jira)" <ji...@apache.org> on 2021/04/29 06:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22522) BytesHashMap has many verbose logs - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/04/29 06:55:01 UTC, 0 replies.
- [jira] [Created] (FLINK-22523) TUMBLE TVF should throw helpful exception when specifying second interval parameter - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/04/29 06:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22524) Fix the incorrect Java groupBy clause in Table API docs - posted by "Huachao Mao (Jira)" <ji...@apache.org> on 2021/04/29 06:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22525) The zone id in exception message should be GMT+08:00 instead of GMT+8:00 - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2021/04/29 09:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22526) Rename TopicId to topic in Kafka related code - posted by "dengziming (Jira)" <ji...@apache.org> on 2021/04/29 09:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22527) Give friendly hint when click FlameGraph without rest.flamegraph.enabled - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/04/29 10:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22528) Document latency tracking metrics for state accesses - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/04/29 10:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22529) StateFun Kinesis ingresses should support configs that are available via FlinkKinesisConsumer's ConsumerConfigConstants - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2021/04/29 10:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22530) RuntimeException after subsequent windowed grouping in TableAPI - posted by "Christopher Rost (Jira)" <ji...@apache.org> on 2021/04/29 11:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22531) Improve the support for finite streaming jobs with async operations. - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/04/29 12:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22532) Improve the support for remote functions in the DataStream integration - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/04/29 12:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22533) Allow creating custom metrics - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/04/29 12:30:00 UTC, 0 replies.
- [RESULT][VOTE] Release 1.13.0, release candidate #2 - posted by Dawid Wysakowicz <dw...@apache.org> on 2021/04/29 12:36:27 UTC, 0 replies.
- [jira] [Created] (FLINK-22534) Set delegation token's service name as credential alias - posted by "Junfan Zhang (Jira)" <ji...@apache.org> on 2021/04/29 13:55:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.12.3 released - posted by Arvid Heise <ar...@apache.org> on 2021/04/29 14:04:02 UTC, 1 replies.
- [jira] [Created] (FLINK-22535) Resource leak would happen if exception thrown during AbstractInvokable#restore of task life - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/04/29 14:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22536) Promote the critical log in FineGrainedSlotManager to INFO level - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2021/04/30 02:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22537) Add documentation how to interact with DataStream API - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/04/30 07:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22538) How to check sql is right before to execute accross API - posted by "ranqiqiang (Jira)" <ji...@apache.org> on 2021/04/30 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22539) Restructure the Python dependency management documentation - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/04/30 09:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22540) Remove YAML environment file support in SQL Client - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/04/30 09:08:00 UTC, 0 replies.