You are viewing a plain text version of this content. The canonical link for it is here.
- Re: [DISCUSS] Flink Kubernetes Operator controller flow - posted by Thomas Weise <th...@apache.org> on 2022/03/01 01:16:05 UTC, 5 replies.
- [jira] [Created] (FLINK-26404) Currently, Flink-ML only supports local file systems - posted by "mumu (Jira)" <ji...@apache.org> on 2022/03/01 01:52:00 UTC, 0 replies.
- Re: Re: Change of focus - posted by Lijie Wang <wa...@gmail.com> on 2022/03/01 01:52:40 UTC, 19 replies.
- [jira] [Created] (FLINK-26405) Add validation check of num of JM replica - posted by "Biao Geng (Jira)" <ji...@apache.org> on 2022/03/01 03:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26406) Significant differences of Fault Tolerance between English and Chinese version - posted by "tonny (Jira)" <ji...@apache.org> on 2022/03/01 03:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26407) MetricsAvailabilityITCase.testReporter failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/03/01 03:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26408) retract a non-existent record in RetractableTopNFunction - posted by "Hengyu Dai (Jira)" <ji...@apache.org> on 2022/03/01 03:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26409) Remove meaningless Kafka connector test case KafkaConsumerTestBase.runBrokerFailureTest - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2022/03/01 04:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26410) support hive transform - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/03/01 04:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26411) Hive dialect supports CLUSTERED BY/ SORTED BY table - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/03/01 04:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26412) Hive dialect supports "CREATE TEMPORARY FUNCTION USING xxx.jar" - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/03/01 06:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26413) Hive dialect support "LOAD DATA INPATH" - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/03/01 06:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26414) Hive dialect supports "Marco" - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/03/01 06:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26415) Improve view usage in hive dialect - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/03/01 06:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26416) Release Testing: - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2022/03/01 07:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26417) Async can Sink violate At Least Once during checkpointing - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2022/03/01 08:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26418) Tests on flink-table-planner produce tmp_XXX dirs which are not cleaned up - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2022/03/01 09:00:00 UTC, 0 replies.
- Flink 1.15 Stabilisation Weekly Update - posted by Johannes Moser <jo...@ververica.com> on 2022/03/01 09:14:09 UTC, 0 replies.
- [jira] [Created] (FLINK-26419) StreamConfig.toString uses a wrong classloader - posted by "David Morávek (Jira)" <ji...@apache.org> on 2022/03/01 09:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26420) error numRecordsOut metric in file connector - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/03/01 09:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26421) Cleanup EnvironmentSettings and only use ConfigOptions - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2022/03/01 09:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26422) Update Chinese documentation with the new TablePipeline docs - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/03/01 10:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26423) Integrate log store to StoreSink - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/03/01 12:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26424) RequestTimeoutException - posted by "xinchenyuan (Jira)" <ji...@apache.org> on 2022/03/01 12:24:00 UTC, 0 replies.
- [DISCUSS] Manual savepoint triggering in flink-kubernetes-operator - posted by Őrhidi Mátyás <ma...@gmail.com> on 2022/03/01 12:51:24 UTC, 4 replies.
- Re: [DISCUSS] CAST legacy behaviour - posted by Timo Walther <tw...@apache.org> on 2022/03/01 12:51:41 UTC, 2 replies.
- [jira] [Created] (FLINK-26425) Yarn aggregate log files in a rolling fashion for flink - posted by "wang da wei (Jira)" <ji...@apache.org> on 2022/03/01 12:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26426) Hive dialect support "create table like" - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/03/01 12:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26427) Streaming File Sink Uploading Smaller Versions Of The Same Part File To S3 (Race Condition) - posted by "JOHN ERVINE (Jira)" <ji...@apache.org> on 2022/03/01 13:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26428) Translate "Stateful Stream Processing" to Chinese - posted by "tonny (Jira)" <ji...@apache.org> on 2022/03/01 13:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26429) Bump karma from 6.3.11 to 6.3.14 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/03/01 13:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26430) Bump follow-redirects from 1.14.7 to 1.14.8 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/03/01 13:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26431) Release Testing: Exception history for the adaptive scheduler - posted by "Niklas Semmler (Jira)" <ji...@apache.org> on 2022/03/01 14:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26432) Cleanly separate validator, observer and reconciler modules - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/01 14:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26433) Bump netty to 4.1.74 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/03/01 15:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26434) Remove 'table.planner' table config option - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2022/03/01 16:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26435) Provide the container name for CI debug log - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/03/01 16:12:00 UTC, 0 replies.
- [DISCUSS] Enable scala formatting check - posted by Francesco Guardiani <fr...@ververica.com> on 2022/03/01 16:52:31 UTC, 20 replies.
- [jira] [Created] (FLINK-26436) SharedIndexInformer should respect watched namespaces - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/01 18:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26437) Cannot discover a connector using option: 'connector'='jdbc' - posted by "Arindam Bhattacharjee (Jira)" <ji...@apache.org> on 2022/03/01 18:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26438) expat critical vulnerabilities CVE-2021-45960 - posted by "neal zheng (Jira)" <ji...@apache.org> on 2022/03/01 19:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26439) Introduce version.field to custom the order of the records - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/03/02 02:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26440) CompactorOperatorStateHandler can not work with unaligned checkpoint - posted by "Gen Luo (Jira)" <ji...@apache.org> on 2022/03/02 03:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26441) Overwrite commit kind should not be APPEND - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/03/02 04:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26442) Allow ManifestFile to write a list of ManifestFileMeta into multiple files if too many. - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/03/02 05:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26443) Add a benchmark framework for flinkml - posted by "Zhipeng Zhang (Jira)" <ji...@apache.org> on 2022/03/02 06:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26444) Window allocator supporting pyflink datastream API - posted by "zhangjingcun (Jira)" <ji...@apache.org> on 2022/03/02 07:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26445) Unified Sink cannot restore committer state - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2022/03/02 07:54:00 UTC, 0 replies.
- Re: [VOTE] Release 1.14.4, release candidate #1 - posted by Yun Tang <my...@live.com> on 2022/03/02 09:04:47 UTC, 3 replies.
- [jira] [Created] (FLINK-26446) Update Feature Radar in Apache Flink Roadmap - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2022/03/02 10:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26447) Clean up webhook jar and dependency management - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/02 11:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26448) Disable tests in KafkaSourceLegacyITCase for test stability issues - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/03/02 12:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26449) Enable tests in KafkaSourceLegacyITCase for test stability issues - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/03/02 12:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26450) FileStateHandle.discardState does not process return value - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/03/02 13:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26451) Test GCS FileSystem w/ RecoverableWriter manually - posted by "Galen Warren (Jira)" <ji...@apache.org> on 2022/03/02 14:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26452) Flink deploy on k8s when kubeconfig server is hostname not ip - posted by "hjw (Jira)" <ji...@apache.org> on 2022/03/02 15:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26453) execution.allow-client-job-configurations not checked for executeAsync - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2022/03/02 16:54:00 UTC, 0 replies.
- Help with pom dependencies for Flink with Table - posted by Adesh Dsilva <ad...@gmail.com> on 2022/03/02 17:33:50 UTC, 3 replies.
- [jira] [Created] (FLINK-26454) Improve operator logging - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/02 18:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26455) [Changelog] Materialization interleaved with task cancellation can fail the job - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/03/02 23:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26456) StreamExecutionEnvironmentTests::test_add_python_file failed with ModuleNotFoundError - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/03/03 02:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26457) Introduce Join Accumulator for Wide table - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/03/03 05:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26458) Rename Accumulator to MergeFunction - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/03/03 06:00:00 UTC, 0 replies.
- Re: SourceEvent Task Failure Handling - posted by Qingsheng Ren <re...@gmail.com> on 2022/03/03 07:47:19 UTC, 0 replies.
- [jira] [Created] (FLINK-26459) Streaming File Sink s3 end-to-end test failed on azure due to not enough resource - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/03/03 08:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26460) Fix Unsupported type when convertTypeToSpec: MAP - posted by "tartarus (Jira)" <ji...@apache.org> on 2022/03/03 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26461) Throw CannotPlanException in TableFunction - posted by "Spongebob (Jira)" <ji...@apache.org> on 2022/03/03 09:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26462) Release Testing: Running Python UDF in different Execution Mode - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/03/03 09:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26463) TableEnvironmentITCase should use MiniCluster - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/03/03 10:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26464) Introduce new metrics to represent full checkpoint size - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2022/03/03 11:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26465) Optimize SortMergeReader: use loser tree to reduce comparisons - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/03/03 12:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26466) Wrong dependency in pyflink: Broken toolchain: cannot link a simple C++ program. note: A compiler with support for C++11 language features is required. - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/03/03 12:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26467) Compile RowDataToStringConverter lazily - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2022/03/03 14:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26468) Test default binding to localhost - posted by "Mika Naylor (Jira)" <ji...@apache.org> on 2022/03/03 15:05:00 UTC, 0 replies.
- [ANNOUNCE] New Apache Flink Committer - Martijn Visser - posted by Robert Metzger <rm...@apache.org> on 2022/03/03 15:49:05 UTC, 32 replies.
- [jira] [Created] (FLINK-26469) Adaptive job shows error when not enough resource are available - posted by "Niklas Semmler (Jira)" <ji...@apache.org> on 2022/03/03 16:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26470) [Java][TypeExtractor] Missing type information in POJO types of some types (List, Map, UUID) - posted by "Antoine Michaud (Jira)" <ji...@apache.org> on 2022/03/03 17:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26471) Deleting the operator while jobs are running causes the jobs to fail - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/03 19:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26472) Introduce Savepoint object in JobStatus - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/03/03 21:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26473) Observer should support JobManager deployment crashed or deleted externally - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/03/04 03:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26474) Fail to call hive udf when secondary parameter required constant but pass value like "-1" - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/03/04 03:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26475) FileStoreScan supports delta consuming - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/03/04 04:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26476) Introduce flink-kubernetes-shaded to avoid overlapping classes - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/03/04 04:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26477) Finalize the window support in Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2022/03/04 06:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26478) Support evictor in Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2022/03/04 06:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26479) Add time_window and count_window in KeyedStream in Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2022/03/04 06:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26480) Support window_all in Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2022/03/04 06:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26481) Support side output for windowing in Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2022/03/04 06:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26482) Support WindowedStream.reduce in Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2022/03/04 06:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26483) Support WindowedStream.aggregate in Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2022/03/04 06:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26484) BlobServer cleanup does not work for the presto filesystem - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/03/04 06:46:00 UTC, 0 replies.
- [DISUCSS] When timestamp - offset + windowSize < 0, elements cannot be assigned to the correct window - posted by 邓子琦 <dz...@gmail.com> on 2022/03/04 06:59:18 UTC, 2 replies.
- [jira] [Created] (FLINK-26485) [Changelog] State not discarded after multiple retries - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/03/04 07:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26486) The operator restart ingress is lost - posted by "leinenglian (Jira)" <ji...@apache.org> on 2022/03/04 07:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26487) Upgrade to Operator SDK 2.2.0 and replace custom informereventsource logic - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/04 07:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26488) FileSystem.listFiles is not implemented consistently - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/03/04 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26489) FlinkDeploymentSpec add imagePullSecrets - posted by "leinenglian (Jira)" <ji...@apache.org> on 2022/03/04 09:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26490) Adjust the MaxParallelism or remove the MaxParallelism check when unnecessary. - posted by "刘方奇 (Jira)" <ji...@apache.org> on 2022/03/04 09:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26491) In org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java#L173 the annotation should be "if" instead of "iff" - posted by "Zhuang Liu (Jira)" <ji...@apache.org> on 2022/03/04 10:51:00 UTC, 0 replies.
- [ANNOUNCE] New Apache Flink Committer - David Morávek - posted by Robert Metzger <rm...@apache.org> on 2022/03/04 11:34:30 UTC, 25 replies.
- [jira] [Created] (FLINK-26492) rename numRecordsOutErrors to numRecordsSendErrors in SinkWriterMetricGroup - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/03/04 13:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26493) Use state machine based mechanism to simply the reconciler - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/03/04 15:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26494) Missing logs during retry - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/03/04 17:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26495) Dynamic table options does not work for view - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/03/05 09:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26496) [JUnit5 Migration] Module: flink-yarn-test - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2022/03/05 10:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26497) Cast Exception when use split agg with multiple filters - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/03/05 12:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26498) The window result may not have been emitted when use window emit feature and use lateTrigger. - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2022/03/05 16:08:00 UTC, 0 replies.
- Require help regarding possible issue/bug I'm facing while using Flink - posted by "Chia De Xun ." <de...@bytedance.com> on 2022/03/06 09:27:33 UTC, 0 replies.
- [jira] [Created] (FLINK-26499) Azure hang due to unable to download akka artifact - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/03/06 15:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26500) AdaptiveSchedulerClusterITCase.testAutomaticScaleUp failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/03/06 15:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26501) Quickstarts Scala nightly end-to-end test failed on azure due to checkponts failed and logs contains exceptions - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/03/06 15:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26502) Multiple component leader election has different close/stop behavior - posted by "Niklas Semmler (Jira)" <ji...@apache.org> on 2022/03/06 19:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26503) Multi-network deployments may lead to hard-to-debug issues - posted by "Niklas Semmler (Jira)" <ji...@apache.org> on 2022/03/06 21:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26504) Fix the incorrect type error in unbounded Python UDAF - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/03/07 03:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26505) Support non equality condition in Hive dialect - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/03/07 03:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26506) Support StreamExecutionEnvironment.registerCachedFile in Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2022/03/07 07:08:00 UTC, 0 replies.
- [DISCUSS] The abstraction of cache lookupFunction and cache metric - posted by "zstraw@163.com" <zs...@163.com> on 2022/03/07 08:00:10 UTC, 5 replies.
- [jira] [Created] (FLINK-26507) Last state upgrade mode should allow reconciliation regardless of job and deployment status - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/07 08:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26508) Webhook should only validate on /validate endpoint end log errors for others - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/07 08:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26509) Improve Kubernetes Operator documentation - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/07 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26510) Document FlinkDeployment CRD - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/07 08:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26511) Document FlinkDeployment lifecycle - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/07 08:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26512) Document debugging and manual error handling - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/07 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26513) Document operator helm chart - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/07 08:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26514) YARNSessionFIFOITCase.testDetachedMode failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/03/07 08:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26515) RetryingExecutorTest.testTimeout failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/03/07 08:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26516) Sink V2 is not state compatible with Sink V1 - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2022/03/07 09:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26517) Normalize the decided parallelism to power of 2 when using adaptive batch scheduler - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2022/03/07 09:33:00 UTC, 0 replies.
- [DISCUSS] Flink's supported APIs and Hive query syntax - posted by Martijn Visser <ma...@apache.org> on 2022/03/07 11:23:00 UTC, 9 replies.
- [jira] [Created] (FLINK-26518) Support the new type inference in Scala Table API table functions - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2022/03/07 12:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26519) Remove FlinkTypeFactory.INSTANCE singleton - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/03/07 13:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26520) Implement SEARCH operator - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/03/07 13:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26521) Reconsider setting generationAwareEventProcessing = true - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/07 14:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26522) Refactoring code for multiple component leader election - posted by "Niklas Semmler (Jira)" <ji...@apache.org> on 2022/03/07 15:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26523) Flink : E2E Tests : Kinesis SQL tests - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/03/07 15:57:00 UTC, 0 replies.
- Flink 1.15 Stabilisation Sync skipped tomorrow - posted by Johannes Moser <jo...@ververica.com> on 2022/03/07 16:15:26 UTC, 6 replies.
- [jira] [Created] (FLINK-26524) Elasticsearch (v5.3.3) sink end-to-end test - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/03/07 16:25:00 UTC, 0 replies.
- [DISCUSS] [statefun] resolve placeholders in module.yaml - posted by Filip Karnicki <fi...@gmail.com> on 2022/03/07 16:50:01 UTC, 2 replies.
- [jira] [Created] (FLINK-26525) new ArchUnit rules for SourceTestSuiteBase and SinkTestSuiteBase - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/03/07 17:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26526) Record hasNull and allNull instead of nullCount in fieldStats - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/03/08 03:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26527) ClassCastException in TemporaryClassLoaderContext - posted by "shizhengchao (Jira)" <ji...@apache.org> on 2022/03/08 03:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26528) Trigger the updateControl when the FlinkDeployment have changed - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/03/08 03:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26529) PyFlink 'tuple' object has no attribute '_values' - posted by "James Schulte (Jira)" <ji...@apache.org> on 2022/03/08 04:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26530) Refactor the FileStoreITCase and StoreSink - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/03/08 04:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26531) KafkaWriterITCase.testMetadataPublisher failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/03/08 06:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26532) SinkMetricsITCase.testMetrics failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/03/08 06:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26533) KafkaSinkITCase.testRecoveryWithExactlyOnceGuarantee failed on azure due to delete topic timeout - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/03/08 06:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26534) shuffle by sink's primary key should cover the case that input changelog stream has a different parallelism - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2022/03/08 07:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26535) Introduce StoreTableSource and StoreTableSink - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/03/08 08:04:00 UTC, 0 replies.
- status of Apple Silicon (M1) as Flink dev platform? - posted by David Anderson <da...@apache.org> on 2022/03/08 08:25:18 UTC, 2 replies.
- [jira] [Created] (FLINK-26536) PyFlink RemoteKeyedStateBackend#merge_namespaces bug - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2022/03/08 09:07:00 UTC, 0 replies.
- 回复:[DISCUSS] Flink's supported APIs and Hive query syntax - posted by "罗宇侠(莫辞)" <lu...@alibaba-inc.com.INVALID> on 2022/03/08 09:38:55 UTC, 0 replies.
- Why does Flink Table API not wait for job to complete? - posted by Adesh Dsilva <ad...@gmail.com> on 2022/03/08 12:24:10 UTC, 1 replies.
- [jira] [Created] (FLINK-26537) Allow disabling StatefulFunctionsConfigValidator validation for classloader.parent-first-patterns.additional - posted by "Fil Karnicki (Jira)" <ji...@apache.org> on 2022/03/08 16:49:00 UTC, 0 replies.
- [DISCUSS] (FLINK-26537) Allow disabling StatefulFunctionsConfigValidator validation for classloader.parent-first-patterns.additional - posted by Filip Karnicki <fi...@gmail.com> on 2022/03/08 16:59:25 UTC, 0 replies.
- [jira] [Created] (FLINK-26538) Ability to restart deployment w/o spec change - posted by "Thomas Weise (Jira)" <ji...@apache.org> on 2022/03/08 18:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26539) Support dynamic partial features update in Cassandra connector - posted by "Zhenqiu Huang (Jira)" <ji...@apache.org> on 2022/03/09 02:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26540) Support handle join involving complex types in on condition - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/03/09 02:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26541) SQL Client should support submitting SQL jobs in application mode - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2022/03/09 03:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26542) Fix the issue that schema of both sides of union won't match when one side of union select fields with same names - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/03/09 03:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26543) Fix the issue that exceptions generated in startup is missed in Python loopback mode - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/03/09 06:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26544) Apply key & value filter in FileStoreScanImpl - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/03/09 07:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26545) Ingress rules should be created in the same namespace with FlinkDeployment CR - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/03/09 07:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26546) Extract Observer Interface - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/03/09 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26547) Accepting slots without a matching requirement lead to unfulfillable requirements - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/03/09 10:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26548) the source parallelism is not set correctly with AdaptiveBatchScheduler - posted by "zl (Jira)" <ji...@apache.org> on 2022/03/09 11:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26549) INSERT INTO with VALUES leads to wrong type inference with nested types - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/03/09 11:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26550) Correct the information of checkpoint failure - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2022/03/09 11:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26551) Make the legacy behavior disabled by default - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/03/09 13:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26552) Try to use @EnableKubernetesMockClient(crud = true) in controller test - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/09 13:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26553) Enable scalafmt for scala codebase - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/03/09 14:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26554) Clean termination of FlinkDeployment - posted by "Thomas Weise (Jira)" <ji...@apache.org> on 2022/03/09 15:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26555) Missing close in FileSystemJobResultStore - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/03/09 16:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26556) Refactoring MiniCluster and TestingMiniCluster - posted by "Niklas Semmler (Jira)" <ji...@apache.org> on 2022/03/09 17:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26557) Extend CsvFormat documentation based on release-testing feedback - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2022/03/09 21:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26558) Errors when reporting on Job status - posted by "Jeremy DeGroot (Jira)" <ji...@apache.org> on 2022/03/09 22:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26559) Support Customized Kubernetes Schedulers for Flink Kubernetes - posted by "bo zhao (Jira)" <ji...@apache.org> on 2022/03/10 01:56:00 UTC, 0 replies.
- Add libatomic1 to flink image - posted by "Almeida, Julius" <Ju...@intuit.com.INVALID> on 2022/03/10 02:20:29 UTC, 1 replies.
- [jira] [Created] (FLINK-26560) make the threshold of the overlap fraction of incremental restoring configurable - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2022/03/10 02:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26561) Deployment Status cannot be updated - posted by "leinenglian (Jira)" <ji...@apache.org> on 2022/03/10 03:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26562) Introduce table path option - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/03/10 03:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26563) HadoopS3RecoverableWriterITCase hang on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/03/10 03:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26564) CompactCoordinatorStateHandler doesn't properly handle the cleanup-in-progress requests. - posted by "Gen Luo (Jira)" <ji...@apache.org> on 2022/03/10 03:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26565) Use lateTrigger when the window maxtimestap of data is less than currentwatermark and it is not discarded because the allow latency parameter - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2022/03/10 03:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26566) FlinkKafkaProducerITCase.testFailAndRecoverSameCheckpointTwice failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/03/10 03:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26567) FileStoreSourceSplitReader should deal with value count - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/03/10 06:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26568) BlockingShuffleITCase.testDeletePartitionFileOfBoundedBlockingShuffle timing out on Azure - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/03/10 06:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26569) testResumeWithWrongOffset(org.apache.flink.runtime.fs.hdfs.HadoopRecoverableWriterTest) failing on master - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/03/10 06:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26570) Remote module configuration interpolation - posted by "Fil Karnicki (Jira)" <ji...@apache.org> on 2022/03/10 06:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26571) Savepoint trigger/tracking improvements - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/10 07:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26572) Re-schedule reconcile more often until job is in ready state - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/10 07:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26573) ChangelogPeriodicMaterializationRescaleITCase.testRescaleIn failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/03/10 07:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26574) Allow definining Operator configuration in Helm chart Values - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/10 07:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26575) Improve the info message when restoring keyed state backend - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2022/03/10 07:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26576) The value of 'readerParallelism' passed to ContinuousFileMonitoringFunction is wrong - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2022/03/10 08:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26577) Avoid state loss when switching to last-state upgrade mode - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/10 08:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26578) Translate new Project Configuration section to Chinese - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/03/10 08:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26579) The default source parallelism configuration in adaptive batch scheduling does not take effect - posted by "kangTwang (Jira)" <ji...@apache.org> on 2022/03/10 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26580) FileSink CompactCoordinator add illegal committable as toCompacted. - posted by "Gen Luo (Jira)" <ji...@apache.org> on 2022/03/10 10:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26581) Job supports the specified HADOOP_USER_NAME - posted by "Bo Cui (Jira)" <ji...@apache.org> on 2022/03/10 11:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26582) Run the assertj conversion script to convert assertions in flink-table - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/03/10 11:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26583) Yarn's Application Mode does not fail when submitting a job with a ID that's listed in the JobResultStore - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/03/10 12:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26584) State Processor API fails to write savepoints exceeding 5MB - posted by "Matthias Schwalbe (Jira)" <ji...@apache.org> on 2022/03/10 12:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26585) State Processor API: Loading a state set buffers the whole state set in memory before starting to process - posted by "Matthias Schwalbe (Jira)" <ji...@apache.org> on 2022/03/10 13:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26586) FileSystem uses unbuffered read I/O - posted by "Matthias Schwalbe (Jira)" <ji...@apache.org> on 2022/03/10 13:18:00 UTC, 0 replies.
- Cutting the 1.15 branch and releasing RC0 - posted by Johannes Moser <jo...@ververica.com> on 2022/03/10 14:02:07 UTC, 0 replies.
- [jira] [Created] (FLINK-26587) Replace Configuration arg of RichFunction#open with ReadableConfig - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2022/03/10 14:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26588) Translate the new CAST documentation to Chinese - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/03/10 14:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26589) Update the logging level of Kinesis Streams and Firehose sinks - posted by "Zichen Liu (Jira)" <ji...@apache.org> on 2022/03/10 15:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26590) Triggered checkpoints can be delayed by discarding shared state - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/03/10 15:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26591) Compilation fails due to RawToBinaryCastRule - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/03/10 17:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26592) [Changelog] Deadlock in FsStateChangelogWriter - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/03/10 22:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26593) task manager can not free memory when jobs are finished caused the linux out of memory - posted by "ren shangtao (Jira)" <ji...@apache.org> on 2022/03/11 02:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26594) Helm: Replace Values.operatorNamespace with built-in Release.Namespace - posted by "Xin Hao (Jira)" <ji...@apache.org> on 2022/03/11 04:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26595) Improve the PostgresDialect method for getting upsert statements. - posted by "wuguihu (Jira)" <ji...@apache.org> on 2022/03/11 06:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26596) ZooKeeperLeaderRetrievalConnectionHandlingTest.testNewLeaderAfterReconnectTriggersListenerNotification failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/03/11 07:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26597) OracleTableSinkITCase failed on azure due to container failed to startup - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/03/11 07:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26598) OracleTableSinkITCase failed on azure due to container failed to startup - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/03/11 07:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26599) CheckpointCoordinatorTest.testMinCheckpointPause failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/03/11 07:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26600) PerJobMiniClusterFactoryTest.testJobClientSavepoint failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/03/11 07:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26601) Flink HBase HBaseRowDataAsyncLookupFunction threadPool not close cause container has so many 'hbase-async-lookup-worker' thread - posted by "zhisheng (Jira)" <ji...@apache.org> on 2022/03/11 07:34:00 UTC, 0 replies.
- [RESULT] [VOTE] Release 1.14.4, release candidate #1 - posted by Konstantin Knauf <kn...@apache.org> on 2022/03/11 08:35:56 UTC, 1 replies.
- [jira] [Created] (FLINK-26602) The Rocksdb task failed savepoint, and then checkpoint failed several times - posted by "liuchenhong (Jira)" <ji...@apache.org> on 2022/03/11 09:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26603) [Umbrella] Decouple Hive with Flink itself - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/03/11 09:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26604) update AvroParquet format user-facing document - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/03/11 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26605) JobManagerDeploymentStatus.READY does not correctly reflect the real Flink cluster status - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/03/11 10:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26606) CompletedCheckpoints that failed to be discarded are not stored in the CompletedCheckpointStore - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/03/11 10:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26607) There are multiple MAX_LONG_VALUE value errors in pyflink code - posted by "zhangjingcun (Jira)" <ji...@apache.org> on 2022/03/11 10:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26609) Add a "sum" operator In PyFlink KeyedStream API - posted by "CaoYu (Jira)" <ji...@apache.org> on 2022/03/11 11:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26608) Add a "sum" operator In PyFlink KeyedStream API - posted by "CaoYu (Jira)" <ji...@apache.org> on 2022/03/11 11:14:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-213: TaskManager's Flame Graphs - posted by Yufei Liu <li...@gmail.com> on 2022/03/11 11:41:05 UTC, 0 replies.
- [jira] [Created] (FLINK-26610) FileSink can not upgrade from 1.13 if the uid of the origin sink is not set. - posted by "Gen Luo (Jira)" <ji...@apache.org> on 2022/03/11 12:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26611) Generate documentation for OperatorConfigOptions - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/11 13:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26612) Create docs webpages like other Flink projects - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/11 13:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26613) Stateful unified Sink V2 upgrades only work when operator uids are given - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2022/03/11 14:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26614) Upsert Kafka SQL Connector:Support startup mode of timestamp and specific offsets - posted by "Ning Ma (Jira)" <ji...@apache.org> on 2022/03/11 14:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26615) BatchingStateChangeUploadSchedulerTest.testRetryOnTimeout fails on azure - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/03/11 15:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26616) AdaptiveSchedulerITCase.testExceptionHistoryIsRetrievableFromTheRestAPI failed with a timeout - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/03/11 15:22:00 UTC, 0 replies.
- [DISCUSS] Preview release for Flink Kubernetes Operator - posted by Gyula Fóra <gy...@apache.org> on 2022/03/11 17:10:43 UTC, 10 replies.
- [jira] [Created] (FLINK-26617) Pass Kafka headers to remote functions and egresses - posted by "Fil Karnicki (Jira)" <ji...@apache.org> on 2022/03/12 21:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26618) Remove jar statement not aligned with pipleline.jars - posted by "Paul Lin (Jira)" <ji...@apache.org> on 2022/03/13 04:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26619) Write the window allocator usage document of pyflink data flow API - posted by "zhangjingcun (Jira)" <ji...@apache.org> on 2022/03/13 05:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26620) Mark CRD classes experimental - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/13 20:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26621) flink-tests failed on azure due to Error occurred in starting fork - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/03/14 01:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26622) Azure failed due to Connection timed out - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/03/14 05:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26623) BlobsCleanupITCase failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/03/14 05:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26624) Running HA (hashmap, async) end-to-end test failed on azure due to unable to find master logs - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/03/14 05:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26625) KinesisFirehoseSinkITCase failed on azure due to Could not find a valid Docker environment - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/03/14 05:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26627) Allow user to config the init/max wait time in the ExponentialWaitStrategy of job submission - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2022/03/14 06:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26626) Add Estimator and Transformer of StandardScaler in FlinkML - posted by "Zhipeng Zhang (Jira)" <ji...@apache.org> on 2022/03/14 06:53:00 UTC, 0 replies.
- [ANNOUNCE] New PMC member: Yuan Mei - posted by Yu Li <ca...@gmail.com> on 2022/03/14 08:02:09 UTC, 33 replies.
- [jira] [Created] (FLINK-26628) Use REST program arguments in StatefulFunctionsJob - posted by "Fil Karnicki (Jira)" <ji...@apache.org> on 2022/03/14 08:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26629) Error in code comment for SubtaskStateMapper.RANGE - posted by "Shubin Ruan (Jira)" <ji...@apache.org> on 2022/03/14 08:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26630) EmbeddedHaServices is not made for recovery on a single instance - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/03/14 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26631) The official website is unavailable - posted by "李伟高 (Jira)" <ji...@apache.org> on 2022/03/14 09:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26632) JobManagerHAProcessFailureRecoveryITCase failed due to JVM exits with code 239 - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/03/14 10:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26633) Elasticsearch connector does not report recordsSend metric - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2022/03/14 10:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26634) Update Chinese version of Elasticsearch connector docs - posted by "Alexander Preuss (Jira)" <ji...@apache.org> on 2022/03/14 10:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26635) KafkaSourceE2ECase.testMultipleSplits failed on azure with Correlation id for response does not match request - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/03/14 10:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26636) EmbeddedMultiThreadDependencyTests test_add_python_file failed on azure - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/03/14 11:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26637) Document Basic Concepts and Architecture - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/03/14 12:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26638) Reintroduce ActionFailureHandler for Elasticsearch sink connectors - posted by "Alexander Preuss (Jira)" <ji...@apache.org> on 2022/03/14 14:30:00 UTC, 0 replies.
- [ANNOUNCE] release-1.15 branch cut - posted by Yun Gao <yu...@aliyun.com.INVALID> on 2022/03/14 17:35:20 UTC, 4 replies.
- [jira] [Created] (FLINK-26639) Publish flink-kubernetes-operator maven artifacts - posted by "Thomas Weise (Jira)" <ji...@apache.org> on 2022/03/14 21:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26640) Consider changing flinkVersion to enum type or removing it completely - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/14 21:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26641) Optimize the time of fetching job status in the job submission of session cluster - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2022/03/15 02:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26642) Pulsar sink fails with non-partitioned topic - posted by "goldenyang (Jira)" <ji...@apache.org> on 2022/03/15 04:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26643) Exception occues when use TypeInformationKeyValueSerializationSchema to deserialize data from kafka - posted by "Hengtai Nie (Jira)" <ji...@apache.org> on 2022/03/15 06:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26644) python StreamExecutionEnvironmentTests.test_generate_stream_graph_with_dependencies failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/03/15 06:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26645) Pulsar Source subscribe to a single topic partition will consume all partitions from that topic - posted by "Yufei Zhang (Jira)" <ji...@apache.org> on 2022/03/15 07:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26646) Flink kubernetes operator helm template is broken - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/03/15 07:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26647) Can not add extra config files on native Kubernetes - posted by "Zhe Wang (Jira)" <ji...@apache.org> on 2022/03/15 07:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26648) Ban dependencies on flink-table-planner and depend on flink-table-planner-loader instead - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/03/15 08:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26649) Add startTime in JobStatus - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/03/15 09:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26650) Avoid to print stack trace for checkpoint trigger failure if not all tasks are started - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2022/03/15 09:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26651) The connector CI build timeout in azure - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2022/03/15 10:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26652) Failing to cleanup a job should not fail the flink cluster - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/03/15 12:04:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.1.4.4 released - posted by Konstantin Knauf <kn...@apache.org> on 2022/03/15 13:21:18 UTC, 5 replies.
- [jira] [Created] (FLINK-26653) [umbrella] Enhance Table Store SQL ITCases - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/03/15 13:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26654) Add support for Apicurio Schema Registry - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/03/15 14:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26655) Merge isJobManagerPortReady and isJobManagerServing to check if JM pod can work correctly - posted by "Biao Geng (Jira)" <ji...@apache.org> on 2022/03/15 14:52:00 UTC, 0 replies.
- 回复:Re: Fwd: [DISCUSS] Flink's supported APIs and Hive query syntax - posted by "罗宇侠(莫辞)" <lu...@alibaba-inc.com.INVALID> on 2022/03/15 15:07:04 UTC, 0 replies.
- [jira] [Created] (FLINK-26656) Change/remove mentions of "mode" in Source and Sink documentation - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/03/15 15:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26657) Resilient Kinesis consumption - posted by "John Karp (Jira)" <ji...@apache.org> on 2022/03/15 15:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26658) Migrate documentation generation to Github Actions - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/03/15 15:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26659) Document UI access via Ingress - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/03/15 16:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26660) Specify EventSource when watching multiple namespaces - posted by "Márton Balassi (Jira)" <ji...@apache.org> on 2022/03/15 16:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26661) Document Pod template usage - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/15 16:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26662) Document logging & metrics configs for Operator - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/15 16:21:00 UTC, 0 replies.
- Re: [DISCUSS] Conventions on assertions to use in tests - posted by Francesco Guardiani <fr...@ververica.com> on 2022/03/15 16:55:58 UTC, 0 replies.
- [jira] [Created] (FLINK-26663) Pod augmentation for the operator - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/03/15 18:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26664) Improve Python exception messages to be more Pythonic in PyFlink - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/03/16 02:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26665) Improve the error of incomplete pyflink installation package - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/03/16 02:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26666) Improve the error message of pyflink and flink version mismatch - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/03/16 02:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26667) Improve the error message that the declared type of UDF is inconsistent with the actual return type - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/03/16 02:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26668) Unsupportedoperation exception caused by createActualEdge error in adaptive batch scheduler - posted by "kangTwang (Jira)" <ji...@apache.org> on 2022/03/16 03:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26669) Refactor ReadWriteITCase and add more test cases - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/03/16 03:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26670) Rescaling api not working - posted by "Aarsh Shah (Jira)" <ji...@apache.org> on 2022/03/16 05:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26671) Update 'Developer Guide' in README - posted by "Biao Geng (Jira)" <ji...@apache.org> on 2022/03/16 06:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26672) In Table/SQL API, Table configuration ' table.local-time-zone' does not work - posted by "RuiLin-Zhang (Jira)" <ji...@apache.org> on 2022/03/16 06:32:00 UTC, 0 replies.
- [DISCUSS] Support the session job management in kubernetes operator - posted by Aitozi <gj...@gmail.com> on 2022/03/16 07:41:27 UTC, 13 replies.
- [jira] [Created] (FLINK-26673) ChangelogPeriodicMaterializationITCase.testNonMaterialization failed on master - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/03/16 07:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26674) flink-tests module exit with code 137 - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/03/16 07:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26675) Parallelized heavy serialization operations in StreamingJobGraphGenerator - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2022/03/16 08:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26676) Set ClusterIP service type when watching specific namespaces - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/16 09:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26677) Make flink-connector-base dependency consistent - posted by "Yubin Li (Jira)" <ji...@apache.org> on 2022/03/16 10:00:22 UTC, 0 replies.
- [jira] [Created] (FLINK-26678) make flink-console.sh script clean - posted by "jackylau (Jira)" <ji...@apache.org> on 2022/03/16 10:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26679) Add FileStore Continuous Reading ITCase - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/03/16 10:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26680) SessionDispatcherLeaderProcess#onAddJobGraph crashes if the job is marked as deleted - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/03/16 11:00:02 UTC, 0 replies.
- [jira] [Created] (FLINK-26681) Remove possbile semicolon in the end of SQL statemnt in HiveParser - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/03/16 11:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26682) Migrate regression check script to python and to main repository - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2022/03/16 11:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26683) Terminate the job anyway if savepoint finished when stop-with-savepoint - posted by "Liu (Jira)" <ji...@apache.org> on 2022/03/16 12:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26684) Build failure in ChangelogPeriodicMaterializationITCase.testFailedMaterialization due to NoSuchFileException - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/03/16 12:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26685) Investigate/improve tests stability when using InMemory Changelog implementation - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/03/16 13:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26686) Use a junit temp folder for TestingTaskManagerRuntimeInfo tmpWorkingDirectory - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2022/03/16 13:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26687) Remove NiFi connector - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/03/16 14:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26688) Remove usages of deprecated TableConfig options - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2022/03/16 15:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26689) Replace TableConfig with ReadableConfig where possible - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2022/03/16 15:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26690) DefaultJobGraphStore.globalCleanup does not trigger the cleanup when retrying the cleanup after a failover - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/03/16 16:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26691) pyflink failed with quite a few connection refused errors - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/03/16 18:15:00 UTC, 0 replies.
- Beam College is starting soon! - posted by Carolina Escobar <ca...@sg.com.mx> on 2022/03/16 22:15:50 UTC, 0 replies.
- [jira] [Created] (FLINK-26692) migrate TpcdsTestProgram.java to new source - posted by "zl (Jira)" <ji...@apache.org> on 2022/03/17 01:45:00 UTC, 0 replies.
- 答复: [DISCUSS] Support the session job management in kubernetes operator - posted by Geng Biao <bi...@gmail.com> on 2022/03/17 02:55:02 UTC, 0 replies.
- [jira] [Created] (FLINK-26693) Modify the grammar mistakes in savepoints.md - posted by "Liu (Jira)" <ji...@apache.org> on 2022/03/17 03:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26694) LookupFunction doesn't support multilevel inheritance - posted by "tsianglei (Jira)" <ji...@apache.org> on 2022/03/17 03:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26695) Fabric8FlinkKubeClient.deleteConfigMap doesn't necessarily fail if the deletion didn't succeed - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/03/17 05:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26696) Reuse the method of judgment - posted by "Junfan Zhang (Jira)" <ji...@apache.org> on 2022/03/17 07:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26697) Detailed log with flink app name - posted by "Junfan Zhang (Jira)" <ji...@apache.org> on 2022/03/17 07:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26698) FileSystemJobResultStore#constructDirtyPath might lost the scheme - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/03/17 07:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26699) Update AWS SDK v1 and AWS SDK v2 to the latest versions - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/03/17 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26700) Update chinese documentation regarding restore modes - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2022/03/17 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26701) Relocation of connector-base might break user jars due to changed imports - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2022/03/17 08:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26702) Sporadic failures in JobObserverTest - posted by "Márton Balassi (Jira)" <ji...@apache.org> on 2022/03/17 09:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26703) Introduce flink-table-store-dist module for packaging - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/03/17 10:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26704) Remove string expression DSL - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/03/17 10:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26705) use threadlocal to decrease ObjectSizeCalculator memory use - posted by "hd zhou (Jira)" <ji...@apache.org> on 2022/03/17 10:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26706) Introduce Ingress URL templating - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/03/17 12:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26707) Rework README with Doc website in mind - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/17 13:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26708) TimestampsAndWatermarksOperator should not propagate WatermarkStatus - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2022/03/17 13:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26709) Replace TableConfig.getConfiguration().get(Option) with TableConfig.get(Option) - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2022/03/17 13:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26710) TestLoggerResource hides log lines - posted by "Niklas Semmler (Jira)" <ji...@apache.org> on 2022/03/17 14:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26711) Remove change tracking in TableStore - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/03/17 14:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26712) Metadata keys should not conflict with physical columns - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2022/03/17 14:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26713) Flink Pulsar connector isue - posted by "Vijaya Bhaskar V (Jira)" <ji...@apache.org> on 2022/03/17 14:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26714) Remove .sec from OperatorConfigOptions and use Duration type config instead - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/17 16:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26715) E2E tests should cover different watchNamespace scenarios - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/17 16:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26716) Migrate PostgreSQL tests to Testcontainers - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2022/03/17 21:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26717) Move s3 common utils to flink-core - posted by "wujinhu (Jira)" <ji...@apache.org> on 2022/03/18 02:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26718) Limitations of flink+hive dimension table - posted by "kunghsu (Jira)" <ji...@apache.org> on 2022/03/18 06:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26719) Rethink the default reschedule reconcile loop - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/03/18 06:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26720) Support stop-with-savepoint on web UI - posted by "Paul Lin (Jira)" <ji...@apache.org> on 2022/03/18 06:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26721) PulsarSourceITCase.testSavepoint failed on azure pipeline - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/03/18 06:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26722) the result is wrong when using file connector with csv format - posted by "zl (Jira)" <ji...@apache.org> on 2022/03/18 07:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26723) Fix the content of exception in SourceCoordinatorContext - posted by "zoucao (Jira)" <ji...@apache.org> on 2022/03/18 08:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26724) FlinkKafkaProducerMigrationOperatorTest.testRestoreProducer failed on azure due to Container startup failed - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/03/18 08:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26725) Support the new type inference in Scala Table API aggregate functions - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2022/03/18 08:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26726) Remove the unregistered task from readersAwaitingSplit - posted by "zoucao (Jira)" <ji...@apache.org> on 2022/03/18 08:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26727) Fix the implementation of sub-interpreter in Thread Mode - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/03/18 08:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26728) Support min operation in DataStream - posted by "CaoYu (Jira)" <ji...@apache.org> on 2022/03/18 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26729) Support minby operation in DataStream - posted by "CaoYu (Jira)" <ji...@apache.org> on 2022/03/18 09:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26730) Support max operation in DataStream - posted by "CaoYu (Jira)" <ji...@apache.org> on 2022/03/18 09:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26731) Support maxby operation in DataStream - posted by "CaoYu (Jira)" <ji...@apache.org> on 2022/03/18 09:24:00 UTC, 0 replies.
- [VOTE]FLIP-215: Introduce FlinkSessionJob CRD in the kubernetes operator - posted by Aitozi <gj...@gmail.com> on 2022/03/18 09:29:41 UTC, 7 replies.
- [jira] [Created] (FLINK-26732) DefaultResourceAllocationStrategy need more log info to troubleshoot - posted by "jackylau (Jira)" <ji...@apache.org> on 2022/03/18 09:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26733) Deprecate TableConfig ctor and use getDefault() instead - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2022/03/18 10:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26734) Various usage examples of adding window operation - posted by "zhangjingcun (Jira)" <ji...@apache.org> on 2022/03/18 10:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26735) RMQSource queueing mechanism leads to OOM - posted by "Daniel Hristov (Jira)" <ji...@apache.org> on 2022/03/18 14:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26736) [JUnit5 Migration] Module: flink-avro-confluent-registry - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2022/03/18 17:31:00 UTC, 0 replies.
- proposal to allow configuration of Statefun exponential backoff - posted by Galen Warren <ga...@cvillewarrens.com> on 2022/03/18 20:43:27 UTC, 1 replies.
- [jira] [Created] (FLINK-26737) Add CRD management in development doc - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/03/19 10:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26738) Default value of StateDescriptor is valid when enable state ttl config - posted by "Jianhui Dong (Jira)" <ji...@apache.org> on 2022/03/19 11:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26739) Support Hive 2.3.8 and 2.3.9 - posted by "Cheng Pan (Jira)" <ji...@apache.org> on 2022/03/19 12:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26740) KubernetesCheckpointIDCounter operates even when not running - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/03/19 15:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26741) CheckpointIDCounter.shutdown should expose errors asynchronously - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/03/19 15:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26742) DefaultCompletedCheckpointStore.shutdown does not clean the checkpoints atomically - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/03/19 15:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26743) [umbrella] Build Document for Table Store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/03/20 06:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26744) Init document for table store and introduce quickstart - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/03/20 06:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26745) Unable to create new env - posted by "Rahul Desai (Jira)" <ji...@apache.org> on 2022/03/20 09:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26746) Update the documentation of Timer's Fault Tolerance section - posted by "Liwei Lin (Jira)" <ji...@apache.org> on 2022/03/20 10:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26747) [JUnit5 Migration] Module: flink-external-resources - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2022/03/20 13:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26748) flink jobmanager metaspace oom - posted by "leishuiyu (Jira)" <ji...@apache.org> on 2022/03/20 14:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26749) Publish the Flink Operator image to public registry - posted by "Xin Hao (Jira)" <ji...@apache.org> on 2022/03/20 14:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26750) HA cluster cleanup not complete - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/03/20 14:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26751) [FLIP-171] Kafka implementation of Async Sink - posted by "Almog Tavor (Jira)" <ji...@apache.org> on 2022/03/20 19:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26752) Online Machine Learning Training - posted by "TheIoTAcademy (Jira)" <ji...@apache.org> on 2022/03/20 20:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26753) PK constraint should include partition key - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/03/21 02:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26754) KafkaCommitterTest#testRetryCommittableOnRetriableError stuck - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/03/21 03:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26755) Cleanup inprogressfileRecoverable for FileSink on restoring - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/03/21 03:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26756) Failed to deserialize for match recognize - posted by "godfrey he (Jira)" <ji...@apache.org> on 2022/03/21 03:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26757) change the default value of state.backend.rocksdb.restore-overlap-fraction-threshold - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2022/03/21 03:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26758) [JUnit5 Migration] Module: flink-container - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2022/03/21 04:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26759) Legacy source support waiting for recordWriter to be available - posted by "fanrui (Jira)" <ji...@apache.org> on 2022/03/21 04:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26760) The new CSV source (file system source + CSV format) does not support reading files whose file encoding is not UTF-8 - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2022/03/21 06:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26761) Fix the cast exception thrown by PreValidateReWriter when insert into/overwrite a partitioned table. - posted by "zoucao (Jira)" <ji...@apache.org> on 2022/03/21 06:46:00 UTC, 0 replies.
- [DISCUSS] FLIP-214 Support Advanced Function DDL - posted by 刘大龙 <ld...@zju.edu.cn> on 2022/03/21 06:57:32 UTC, 2 replies.
- [jira] [Created] (FLINK-26762) Add the overdraft buffer in BufferPool to reduce unaligned checkpoint being blocked - posted by "fanrui (Jira)" <ji...@apache.org> on 2022/03/21 07:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26763) PyFlink support using system conda when running checks and tests - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2022/03/21 07:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26764) Support RESPECT NULLS for FIRST_VALUE/LAST_VALUE - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/03/21 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26765) Document RBAC model - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/03/21 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26766) Mistake in ChangelogStateHandleStreamImpl#getIntersection - posted by "Feifan Wang (Jira)" <ji...@apache.org> on 2022/03/21 08:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26767) Replace TableConfig.getConfiguration().get(Option) with TableConfig.get(Option) (python) - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2022/03/21 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26768) reconciliationStatus.error could not be cleared properly - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/03/21 08:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26769) Individual upgradeMode - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/03/21 08:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26770) Nullable ArrayData should not be Object[] - posted by "Wenlong Lyu (Jira)" <ji...@apache.org> on 2022/03/21 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26771) Hive dialect supports to compare boolean type with numeric type - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/03/21 09:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26772) Kubernetes Native in HA Application Mode does not retry resource cleanup - posted by "Mika Naylor (Jira)" <ji...@apache.org> on 2022/03/21 09:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26773) ResourceManager leader election can a reconnect while shutting down the JobMaster - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/03/21 10:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26774) Flink UI freezes on Safari - posted by "Maciej Bryński (Jira)" <ji...@apache.org> on 2022/03/21 11:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26775) PyFlink WindowOperator#process_element register wrong cleanup timer - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2022/03/21 11:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26776) The LocalBufferPoolDestroyTest#isInBlockingBufferRequest is fragile in different JDK environment - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/03/21 11:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26777) Remove PlannerConfig - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2022/03/21 12:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26778) Introduce snapshot latest and earliest hint files - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/03/21 13:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26779) StopWithSavepoint fails when called from standby JM - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/03/21 13:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26780) Add an option to force serialization for rpc invocations - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/03/21 13:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26781) Link operator doc site to Flink Website - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/21 13:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26782) Remove PlannerExpression and related - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/03/21 13:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26783) Restore from a stop-with-savepoint if failed during committing - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2022/03/21 13:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26784) FLIP-215: Introduce FlinkSessionJob CRD in the kubernetes operator - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/03/21 14:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26785) Add FlinkSessionJob CRD - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/03/21 14:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26786) Add default container annotation to the operator deployment - posted by "Xin Hao (Jira)" <ji...@apache.org> on 2022/03/21 14:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26787) Implement FlinkSessionJobController and Reconciler - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/03/21 14:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26788) AbstractDeserializationSchema should add cause when thow a FlinkRuntimeException - posted by "zlzhang0122 (Jira)" <ji...@apache.org> on 2022/03/21 15:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26789) RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState failed - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/03/21 17:47:00 UTC, 0 replies.
- Weekly 1.15 Sync tomorrow cancelled - posted by Johannes Moser <jo...@ververica.com> on 2022/03/21 19:59:37 UTC, 3 replies.
- [jira] [Created] (FLINK-26790) Description image about Unaligned Checkpointing maybe incorrect. - posted by "jinghaihang (Jira)" <ji...@apache.org> on 2022/03/22 03:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26791) Finish projection push down for table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/03/22 05:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26792) BufferedMutator failed when insert and update with a flush in Hbase Sink - posted by "lothar (Jira)" <ji...@apache.org> on 2022/03/22 05:58:00 UTC, 0 replies.
- Flink cassandra connector performance issue - posted by "Ghiya, Jay (GE Healthcare)" <Ja...@ge.com> on 2022/03/22 06:32:41 UTC, 4 replies.
- [jira] [Created] (FLINK-26793) Flink Cassandra connector performance issue - posted by "Jay Ghiya (Jira)" <ji...@apache.org> on 2022/03/22 06:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26794) ChangelogRescalingITCase.test failed on azure due to java.nio.file.NoSuchFileException - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/03/22 07:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26795) Fix the CI not fail fast after build failed - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/03/22 07:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26796) TaskManagerProcessFailureStreamingRecoveryITCase.testTaskManagerProcessFailure failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/03/22 07:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26797) ZKCheckpointIDCounterMultiServersTest.testRecoveredAfterConnectionLoss failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/03/22 07:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26798) JobMaster.testJobFailureWhenTaskExecutorHeartbeatTimeout failed due to missing Execution - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/03/22 07:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26799) StateChangeFormat#read not seek to offset correctly - posted by "Feifan Wang (Jira)" <ji...@apache.org> on 2022/03/22 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26800) write small data file using share write buffer manager - posted by "YufeiLiu (Jira)" <ji...@apache.org> on 2022/03/22 08:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26801) LogisticRegressionTest.testGetModelData» Runtime Failed to fetch next res... - posted by "Zhipeng Zhang (Jira)" <ji...@apache.org> on 2022/03/22 08:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26802) StreamPhysicalOverAggregate doesn't support consuming update and delete changes which is produced by node Deduplicate - posted by "zhiyuan (Jira)" <ji...@apache.org> on 2022/03/22 09:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26803) Merge small ChannelState file for Unaligned Checkpoint - posted by "fanrui (Jira)" <ji...@apache.org> on 2022/03/22 10:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26804) Operator e2e tests sporadically fail: DEPLOYED_NOT_READY - posted by "Márton Balassi (Jira)" <ji...@apache.org> on 2022/03/22 11:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26805) Managed table breaks legacy connector without 'connector.type' - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/03/22 13:29:00 UTC, 0 replies.
- [DISCUSS] Structure of the Flink Documentation (Languages & APIs) - posted by Konstantin Knauf <kn...@apache.org> on 2022/03/22 13:39:14 UTC, 7 replies.
- [jira] [Created] (FLINK-26806) Add deployment guide for Argo CD - posted by "Xin Hao (Jira)" <ji...@apache.org> on 2022/03/22 15:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26807) The batch job not work well with Operator - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/03/22 15:47:00 UTC, 0 replies.
- [ANNOUNCE] Call for Presentations is open for Flink Forward San Francisco 2022 in-person! - posted by Timo Walther <tw...@apache.org> on 2022/03/22 15:52:12 UTC, 0 replies.
- [jira] [Created] (FLINK-26808) [flink v1.14.2] Submit jobs via REST API not working after set web.submit.enable: false - posted by "Luís Manuel Azevedo Costa (Jira)" <ji...@apache.org> on 2022/03/22 16:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26809) ChangelogStorageMetricsTest.testAttemptsPerUpload failed - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/03/22 16:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26810) The local time zone does not take effect when the dynamic index uses a field of type timestamp_ltz - posted by "jinfeng (Jira)" <ji...@apache.org> on 2022/03/22 17:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26811) Document CRD upgrade process - posted by "Thomas Weise (Jira)" <ji...@apache.org> on 2022/03/22 18:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26812) Flink native k8s integration should support owner reference - posted by "Thomas Weise (Jira)" <ji...@apache.org> on 2022/03/22 18:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26813) Supports ADD/MODIFY column/watermark/constraint syntax parse for ALTER TABLE - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/03/23 01:53:00 UTC, 0 replies.
- 回复:Re:[DISCUSS] FLIP-214 Support Advanced Function DDL - posted by "罗宇侠(莫辞)" <lu...@alibaba-inc.com.INVALID> on 2022/03/23 02:02:26 UTC, 8 replies.
- [jira] [Created] (FLINK-26814) Solve the problem that "should only have one jar" is reported as an error when the application submits an operation in the yarn mode - posted by "zhangjingcun (Jira)" <ji...@apache.org> on 2022/03/23 02:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26815) NullPointerException in FlinkConfigBuilderTest - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/03/23 06:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26816) Verify the java doc is consistent with the code implementation - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/03/23 07:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26817) Update ingress docs with templating examples - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/03/23 07:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26818) Required Information on parsing complex nested JSON using SQL API - posted by "Arindam Bhattacharjee (Jira)" <ji...@apache.org> on 2022/03/23 07:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26819) AppendOnlyFirstNFunction produce wrong result when with offset and without rank number - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2022/03/23 08:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26820) Improve Cassandra connector by adding missing features and refactoring to latest standards - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/03/23 08:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26821) Refactor Cassandra Sink implementation to the ASync Sink - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/03/23 08:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26822) Add Source implementation for Cassandra connector - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/03/23 08:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26823) Make Cassandra Source available for Flink SQL users - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/03/23 08:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26824) Upgrade Flink's supported Cassandra versions to match with the Cassandra community supported versions - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/03/23 08:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26825) Document State Machine Graph for JM Deployment - posted by "Biao Geng (Jira)" <ji...@apache.org> on 2022/03/23 08:29:00 UTC, 0 replies.
- 问题咨询: Too more data in this partition: 2147483648 - posted by Kevin Lee <ke...@gmail.com> on 2022/03/23 08:39:59 UTC, 0 replies.
- [jira] [Created] (FLINK-26826) env.readFile() fails if auto-generated UIDs disabled - posted by "Arseniy Tashoyan (Jira)" <ji...@apache.org> on 2022/03/23 10:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26827) FlinkSQL和hive整合报错 - posted by "zhushifeng (Jira)" <ji...@apache.org> on 2022/03/23 12:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26829) ClassCastException will be thrown when the second operand of divide is a function call - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/03/23 12:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26828) build flink-ml example module - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/03/23 12:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26830) Move jobs to suspended state before upgrading - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/23 13:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26831) Move JarHandlers to flink-runtime - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/03/23 13:45:00 UTC, 0 replies.
- Apache Flink 1.15 Meetup - posted by Johannes Moser <jo...@ververica.com> on 2022/03/23 15:04:10 UTC, 0 replies.
- [jira] [Created] (FLINK-26832) Output more status info for JobObserver - posted by "Biao Geng (Jira)" <ji...@apache.org> on 2022/03/23 16:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26833) missing link to setup-pyflink-virtual-env.sh / error during deploy - posted by "Kafka Chris (Jira)" <ji...@apache.org> on 2022/03/24 02:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26834) Introduce BlockingIterator to help testing - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/03/24 03:47:00 UTC, 0 replies.
- [ANNOUNCE] Release 1.15.0, release candidate #0 - posted by Yun Gao <yu...@aliyun.com.INVALID> on 2022/03/24 06:56:09 UTC, 0 replies.
- [jira] [Created] (FLINK-26835) WordCountSubclassPOJOITCase failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/03/24 07:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26836) Add sanity check for state.savepoints.dir when using savepoint upgrade mode - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/03/24 07:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26837) KafkaSinkE2ECase.testMetrics failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/03/24 07:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26838) BatchingStateChangeUploadSchedulerTest.testRetryOnTimeout failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/03/24 07:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26840) [minor refactor] Add a common TopNBufferCacheRemovalListener for topN function - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2022/03/24 08:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26839) SessionDispatcherLeaderProcessTest.recoverJobs_withJobIdRecoveryFailure_failsFatally failed on azures - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/03/24 08:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26841) @param The The type parameter of the elements in the second stream - posted by "thecai (Jira)" <ji...@apache.org> on 2022/03/24 08:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26842) Remove flink-python Scala dependency - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/03/24 09:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26843) Cleanup code around TableConfig/ReadableConfig - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2022/03/24 09:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26844) ConnectionUtilsTest run failed - posted by "Wenjun Ruan (Jira)" <ji...@apache.org> on 2022/03/24 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26845) Document testing guidelines - posted by "Salva (Jira)" <ji...@apache.org> on 2022/03/24 09:46:00 UTC, 0 replies.
- flink提交错误时报错信息不清晰 - posted by 丛鹏 <co...@gmail.com> on 2022/03/24 10:48:13 UTC, 1 replies.
- flink1.12. The error message is maybe misguided - posted by 丛鹏 <co...@gmail.com> on 2022/03/24 11:05:06 UTC, 3 replies.
- [jira] [Created] (FLINK-26846) Gauge metrics doesn't work in PyFlink - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2022/03/24 12:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26847) Unify the logic for the command line option -py and -pym - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2022/03/24 12:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26848) JDBC don't flush data when disable flush-max-rows and flush-interval - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2022/03/24 13:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26849) Deduplicate MetricRegistry code for (un)registering metrics with reporters - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/03/24 13:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26850) Add MetricType enum - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/03/24 13:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26851) Properly model reporter options as ConfigOptions - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/03/24 13:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26852) RocksDBMapState#clear not forwarding exceptions - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2022/03/24 14:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26853) HeapStateBackend ignores metadata updates in certain cases - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/03/24 18:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26854) 重定向数据库无法写入 - posted by "liuminghao (Jira)" <ji...@apache.org> on 2022/03/25 01:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26855) ImportError: cannot import name 'environmentfilter' from 'jinja2' - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2022/03/25 02:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26856) Add ITCase for compound primary key and multi-partition - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/03/25 02:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26857) Add ITCase for projection and filter predicate - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/03/25 02:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26858) When submitting a task, an error is reported and the description is inaccurate, which will lead to misleading - posted by "丛鹏 (Jira)" <ji...@apache.org> on 2022/03/25 03:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26859) Log cannot be printed completely when use System.exit(1) - posted by "chenzihao (Jira)" <ji...@apache.org> on 2022/03/25 07:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26860) FileStore continuous bug for delete row kind records - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/03/25 07:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26861) Log cannot be printed completely when use System.exit(1) - posted by "chenzihao (Jira)" <ji...@apache.org> on 2022/03/25 08:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26862) Link the Github repository from Operator documentation - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/03/25 09:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26863) Filter predicate does not work - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/03/25 09:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26864) Performance regression on 25.03.2022 - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2022/03/25 09:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26865) Fix the potential failure of loading library in Thread Mode - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/03/25 09:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26866) Expired cert during Helm installation - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/03/25 11:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26867) Hybrid reading wrong because of disordered commits - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/03/25 11:20:00 UTC, 0 replies.
- 退订 - posted by Peter Gee <gu...@gmail.com> on 2022/03/25 11:25:27 UTC, 0 replies.
- FLIP-216 Decouple Hive connector with Flink planner - posted by 罗宇侠 <yu...@qq.com.INVALID> on 2022/03/25 12:19:37 UTC, 1 replies.
- [DISCUSS] FLIP-216 Decouple Hive connector with Flink planner - posted by "罗宇侠(莫辞)" <lu...@alibaba-inc.com.INVALID> on 2022/03/25 12:41:15 UTC, 2 replies.
- [jira] [Created] (FLINK-26868) In JobLeaderIdService.java#L36 the annotation may be " Start the service with the given job leader id actions" instead of "Start the service with the given job leader actions." - posted by "Zhuang Liu (Jira)" <ji...@apache.org> on 2022/03/26 02:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26869) Querying job overview in the REST API fails - posted by "Peihui He (Jira)" <ji...@apache.org> on 2022/03/26 10:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26870) Implement session job observer - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/03/26 12:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26871) Handle Session job spec change - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/03/26 12:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26872) The network memory min (xx mb) and max (xx mb) mismatch - posted by "吴中勤 (Jira)" <ji...@apache.org> on 2022/03/26 14:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26873) Align the helm chart version with the flink operator - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/03/26 15:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26874) Add Operator repo to list of main repos on flink website - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/27 08:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26875) Operator Helm: Extends the rbac options with separate namespaces param - posted by "Xin Hao (Jira)" <ji...@apache.org> on 2022/03/27 10:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26876) flink-statebackend-rocksdb EmbeddedRocksDBStateBackend crashing on mac m1 - posted by "Damian Święcki (Jira)" <ji...@apache.org> on 2022/03/27 20:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26877) Introduce auto type inference for filter push down - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/03/28 01:25:00 UTC, 0 replies.
- Wrong format when passing arguments with space - posted by Kevin Lee <ke...@gmail.com> on 2022/03/28 03:58:59 UTC, 0 replies.
- [jira] [Created] (FLINK-26878) get previous window values in udf - posted by "Karthik (Jira)" <ji...@apache.org> on 2022/03/28 05:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26879) LogStartupMode.LATEST does not work - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/03/28 06:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26880) PyFlinkStreamUserDefinedFunctionTests.test_udf_in_join_condition failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/03/28 06:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26881) Stop with savepoint should pick up the targetDirectory from Flink configuration - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/03/28 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26882) Unaligned checkpoint with 0s timeout would fail RescaleCheckpointManuallyITCase - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2022/03/28 08:53:00 UTC, 0 replies.
- [ANNOUNCE] Kubernetes Operator release-0.1 branch cut - posted by Gyula Fóra <gy...@apache.org> on 2022/03/28 08:53:34 UTC, 2 replies.
- 回复:FLIP-216 Decouple Hive connector with Flink planner - posted by "罗宇侠(莫辞)" <lu...@alibaba-inc.com.INVALID> on 2022/03/28 08:56:53 UTC, 0 replies.
- [jira] [Created] (FLINK-26883) Bump dependency-check-maven to 2.10.1 - posted by "zl (Jira)" <ji...@apache.org> on 2022/03/28 12:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26884) Move Elasticsearch connector to external connector repository - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/03/28 12:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26885) Cleanup MetricRegistryImplTest - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/03/28 14:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26886) Document reporter behavior w.r.t. scopes & push/pull - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/03/28 14:09:00 UTC, 0 replies.
- [VOTE] Apache Flink Kubernetes Operator Release 0.1.0, release candidate #1 - posted by Gyula Fóra <gy...@apache.org> on 2022/03/28 14:14:38 UTC, 10 replies.
- [jira] [Created] (FLINK-26887) Drop Jepsen tests - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/03/28 14:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26888) Add e2e tests for network partitions - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/03/28 14:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26889) Eliminate the duplicated construct for FlinkOperatorConfiguration in test - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/03/28 14:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26890) [Kinesis][Consumer] DynamoDB consumer error consuming partitions close to retention - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2022/03/28 15:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26891) Emit events for important Deployment / Job changes - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/28 19:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26892) Observe current status before validating CR changes - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/28 19:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26893) Validate checkpoint config with last-state upgrade mode - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/28 20:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26894) Support custom validator implementations - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/28 20:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26895) Improve cancelWithSavepoint timeout error message - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/28 20:03:00 UTC, 0 replies.
- Flink 1.15 Stabilisation Sync - posted by Johannes Moser <jo...@ververica.com> on 2022/03/28 21:18:14 UTC, 0 replies.
- [jira] [Created] (FLINK-26896) Logging - Support yaml/xml/json format in Log4j2 - posted by "Koala Lam (Jira)" <ji...@apache.org> on 2022/03/29 02:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26897) Provide an additional way to add dependency files to k8s - posted by "liuzhuo (Jira)" <ji...@apache.org> on 2022/03/29 03:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26898) Introduce creating table document for table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/03/29 03:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26899) Introduce query table document for table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/03/29 03:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26901) Introduce config options document for table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/03/29 03:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26900) Introduce Best Practices document for table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/03/29 03:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26902) Introduce benchmark document for table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/03/29 03:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26903) Add correct NOTICE file to flink-kubernetes-operator - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/03/29 05:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26904) Update load(...) of all Stage subclasses to use StreamTableEnvironment - posted by "Dong Lin (Jira)" <ji...@apache.org> on 2022/03/29 06:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26905) Re-add FlinkDeploymentList and FlinkSessionJobList classes - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/29 06:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26906) Spelling error for AdaptiveBatch in elastic_scaling.md - posted by "Liu (Jira)" <ji...@apache.org> on 2022/03/29 07:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26907) RMQSourceITCase failed on azure due to ContainerLaunchException: Container startup failed - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/03/29 07:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26908) HA job cannot to restarting - posted by "WangMinChao (Jira)" <ji...@apache.org> on 2022/03/29 07:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26909) Support AdaptiveBatch when parallelism is -1 from Cli - posted by "Liu (Jira)" <ji...@apache.org> on 2022/03/29 08:57:00 UTC, 0 replies.
- [VOTE] Apache Flink Kubernetes Operator Release 0.1.0, release candidate #2 - posted by Gyula Fóra <gy...@apache.org> on 2022/03/29 09:10:37 UTC, 6 replies.
- [jira] [Created] (FLINK-26910) flink-benchmarks build fails on Apple M1 silicon - posted by "Sebastian Mattheis (Jira)" <ji...@apache.org> on 2022/03/29 09:14:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-193: Snapshots ownership - posted by Hangxiang Yu <ma...@gmail.com> on 2022/03/29 09:17:00 UTC, 1 replies.
- [jira] [Created] (FLINK-26911) Introduce parallelism setter for table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/03/29 09:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26912) EventTimeWindowCheckpointingITCase.testTumblingTimeWindow failed on azure - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/03/29 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26913) Add ITCase for computed column and watermark - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/03/29 10:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26914) Notice files improvements in flink-kubernetes-operator - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/03/29 10:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26915) Extend the Reconciler and Observer interface - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/03/29 15:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26916) The Operator Ignores job related changes (jar, parallelism) during last-state upgrades - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/03/29 15:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26917) Enforce Kubernetes HA during validation for last-state mode - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/29 17:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26918) Add documentation build to Github Actions - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/03/30 03:20:00 UTC, 0 replies.
- Re: Re: [VOTE] FLIP-173: Support DAG of algorithms - posted by Dong Lin <li...@gmail.com> on 2022/03/30 04:10:17 UTC, 0 replies.
- [jira] [Created] (FLINK-26919) Table API program compiles field with "Cannot resolve field [a], input field list:[EXPR$0]" - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2022/03/30 05:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26920) It reported "The configured managed memory fraction for Python worker process must be within (0, 1], was: %s." - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2022/03/30 06:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26921) KafkaSinkE2ECase.testStartFromSavepoint failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/03/30 07:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26922) KafkaSinkITCase.testRecoveryWithExactlyOnceGuaranteeAndConcurrentCheckpoints failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/03/30 07:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26923) SavepointITCase.testStopWithSavepointFailsOverToSavepoint failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/03/30 07:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26924) Decide on operator docker image name - posted by "Márton Balassi (Jira)" <ji...@apache.org> on 2022/03/30 08:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26925) loss scale in union situation - posted by "Spongebob (Jira)" <ji...@apache.org> on 2022/03/30 08:10:00 UTC, 0 replies.
- [DISCUSS] assign SQL Table properties from environment variables - posted by "Teunissen, F.G.J. (Fred)" <Fr...@ing.com.INVALID> on 2022/03/30 08:25:22 UTC, 0 replies.
- [jira] [Created] (FLINK-26926) Allow users to force upgrade even if savepoint is in progress - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/30 08:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26927) Support restarting JobManager in FlinkContainers - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2022/03/30 09:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26928) Remove unnecessary Docker network creation in Kafka connector tests - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2022/03/30 09:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26929) Introduce adaptive hash join for batch sql optimization - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/03/30 10:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26930) Rethink last-state upgrade implementation in flink-kubernetes-operator - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/03/30 11:41:00 UTC, 0 replies.
- Call for Presentations now open, ApacheCon North America 2022 - posted by Rich Bowen <rb...@apache.org> on 2022/03/30 12:16:06 UTC, 0 replies.
- [jira] [Created] (FLINK-26931) Pulsar sink's producer name should be unique - posted by "Yufan Sheng (Jira)" <ji...@apache.org> on 2022/03/30 12:17:00 UTC, 0 replies.
- [GitHub] [flink-connector-elasticsearch] JingGe opened a new pull request #2: [Flink-26884][draft] move elasticsearch connectors to the external repo - posted by GitBox <gi...@apache.org> on 2022/03/30 12:51:22 UTC, 0 replies.
- [GitHub] [flink-connector-elasticsearch] MartijnVisser commented on pull request #2: [Flink-26884][draft] move elasticsearch connectors to the external repo - posted by GitBox <gi...@apache.org> on 2022/03/30 13:38:10 UTC, 1 replies.
- [GitHub] [flink-connector-elasticsearch] MartijnVisser edited a comment on pull request #2: [Flink-26884][draft] move elasticsearch connectors to the external repo - posted by GitBox <gi...@apache.org> on 2022/03/30 13:38:20 UTC, 0 replies.
- [GitHub] [flink-connector-elasticsearch] JingGe commented on pull request #2: [Flink-26884][draft] move elasticsearch connectors to the external repo - posted by GitBox <gi...@apache.org> on 2022/03/30 13:50:46 UTC, 0 replies.
- [GitHub] [flink-connector-elasticsearch] MartijnVisser opened a new pull request #3: [hotfix] Change email/repository notifications to match with Flink Core - posted by GitBox <gi...@apache.org> on 2022/03/30 14:26:14 UTC, 0 replies.
- [VOTE] Apache Flink Kubernetes Operator Release 0.1.0, release candidate #3 - posted by Gyula Fóra <gy...@apache.org> on 2022/03/30 14:38:53 UTC, 4 replies.
- 回复:[DISCUSS] FLIP-216 Decouple Hive connector with Flink planner - posted by "罗宇侠(莫辞)" <lu...@alibaba-inc.com.INVALID> on 2022/03/30 14:44:49 UTC, 0 replies.
- [jira] [Created] (FLINK-26932) TaskManager hung in cleanupAllocationBaseDirs not exit. - posted by "huweihua (Jira)" <ji...@apache.org> on 2022/03/30 14:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26933) FlinkKinesisConsumer incorrectly determines shards as newly discovered when tested against Kinesalite when consuming DynamoDB streams - posted by "Arian Rohani (Jira)" <ji...@apache.org> on 2022/03/30 15:17:00 UTC, 0 replies.
- [GitHub] [flink-connector-elasticsearch] AHeise merged pull request #3: [hotfix] Change email/repository notifications to match with Flink Core - posted by GitBox <gi...@apache.org> on 2022/03/30 15:20:53 UTC, 0 replies.
- [jira] [Created] (FLINK-26934) Add reference to operator meetup talk to docs - posted by "Márton Balassi (Jira)" <ji...@apache.org> on 2022/03/30 16:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26935) Sort records by sequence number when continuous reading - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/03/31 01:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26936) Pushdown watermark to table store source - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/03/31 01:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26937) Introduce Leveled compression for LSM - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/03/31 03:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26938) HybridSource recovery from savepoint fails When flink parallelism is greater than the number of Kafka partitions - posted by "文报 (Jira)" <ji...@apache.org> on 2022/03/31 05:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26939) Add TRANSLATE supported in SQL & Table API - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/03/31 06:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26940) Add SUBSTRING_INDEX supported in SQL & Table API - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/03/31 06:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26941) Support Pattern end with notFollowedBy with window - posted by "Yue Ma (Jira)" <ji...@apache.org> on 2022/03/31 06:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26942) Support SELECT clause in CREATE TABLE(CTAS) - posted by "tartarus (Jira)" <ji...@apache.org> on 2022/03/31 06:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26943) Add DATE_ADD supported in SQL & Table API - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/03/31 06:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26944) Add ADD_MONTHS supported in SQL and Table API - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/03/31 07:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26945) Add DATE_SUB supported in SQL & Table API - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/03/31 07:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26946) Add SHIFTRIGHT supported in SQL & Table API - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/03/31 07:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26947) Add ARRAY_CONTAINS supported in SQL & Table API - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/03/31 07:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26948) Add SORT_ARRAY supported in SQL & Table API - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/03/31 07:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26949) Add NVL supported in SQL & Table API - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/03/31 07:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26950) Remove TableSink and TableSource interfaces - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/03/31 08:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26951) Add HASH supported in SQL & Table API - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/03/31 08:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26952) Remove old CSV connector - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/03/31 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26953) Introduce Operator Specific Metrics - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/03/31 08:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26954) Support Kafka bounded read in TableAPI - posted by "Yuan Zhu (Jira)" <ji...@apache.org> on 2022/03/31 09:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26955) Add CRD compatibility check - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/31 09:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26956) AZP: don't log "[ERROR] Picked up JAVA_TOOL_OPTIONS: -XX:+HeapDumpOnOutOfMemoryError" - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/03/31 10:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26957) FileSystemJobResultStore calls flush on an already closed OutputStream - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/03/31 10:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26958) Add Github Actions build pipeline for flink-connector-elasticsearch - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/03/31 12:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26959) Improve quickstart to use the release helm repo - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/03/31 12:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26960) Make it possible to drop an old unused registered Kryo serializer - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2022/03/31 12:45:00 UTC, 0 replies.
- Speeding up the test builds - posted by Piotr Nowojski <pn...@apache.org> on 2022/03/31 12:48:03 UTC, 2 replies.
- [jira] [Created] (FLINK-26961) Update multiple Jackson dependencies to v2.13.2.1 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/03/31 13:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26962) Fix comment style error - posted by "yingjie.wang (Jira)" <ji...@apache.org> on 2022/03/31 14:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26963) Allow heap state backend creation customization - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/03/31 15:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26964) Notify CheckpointStrategy about checkpoint completion/abortion - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/03/31 15:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26965) Allow reuse of PeriodicMaterializationManager - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/03/31 15:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26966) Implement incremental checkpoints - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/03/31 15:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26967) Fix race condition in CopyOnWriteStateMap - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/03/31 15:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26968) Bump CopyOnWriteStateMap entry version before write - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/03/31 15:36:00 UTC, 0 replies.