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

---

- [jira] [Created] (FLINK-30858) Kubernetes operator does not update reconciled generation - posted by "Thomas Weise (Jira)" <ji...@apache.org> on 2023/02/01 00:51:00 UTC, 0 replies.
- Re: [VOTE] Apache Flink Kubernetes Operator Release 1.3.1, release candidate #1 - posted by Thomas Weise <th...@apache.org> on 2023/02/01 01:06:57 UTC, 2 replies.
- Re: [DISCUSS] FLIP-274 : Introduce metric group for OperatorCoordinator - posted by Hang Ruan <ru...@gmail.com> on 2023/02/01 06:11:44 UTC, 3 replies.
- [jira] [Created] (FLINK-30859) Remove flink-connector-kafka rom master branch - posted by "Mason Chen (Jira)" <ji...@apache.org> on 2023/02/01 06:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30860) Add document for hybrid shuffle with adaptive batch scheduler - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2023/02/01 06:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30861) Table Store Hive Catalog throws java.lang.ClassNotFoundException: org.apache.hadoop.hive.common.ValidWriteIdList under certain environment - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2023/02/01 07:17:00 UTC, 0 replies.
- Re: [VOTE] Release flink-connector-kafka, release candidate #1 - posted by Mason Chen <ma...@gmail.com> on 2023/02/01 08:15:38 UTC, 3 replies.
- Re: Reworking the Rescale API - posted by Gyula Fóra <gy...@gmail.com> on 2023/02/01 08:55:59 UTC, 7 replies.
- [jira] [Created] (FLINK-30862) Config doc generation should keep @deprecated ConfigOption - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2023/02/01 09:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30863) Do not delete the local changelog file of aborted checkpoint - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2023/02/01 10:25:00 UTC, 0 replies.
- Re: [DISCUSS] Delete useless branches from Flink repository - posted by Matthias Pohl <ma...@aiven.io.INVALID> on 2023/02/01 11:10:28 UTC, 3 replies.
- [jira] [Created] (FLINK-30864) Optional pattern at the start of a group pattern not working - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2023/02/01 11:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30865) Make pyflink-ml modules consistent with Flink ML Java library packages - posted by "Dong Lin (Jira)" <ji...@apache.org> on 2023/02/01 11:27:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-287: Extend Sink#InitContext to expose ExecutionConfig and JobID - posted by Lijie Wang <wa...@gmail.com> on 2023/02/01 11:27:45 UTC, 3 replies.
- [jira] [Created] (FLINK-30866) Introduce FileIO for table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/02/01 11:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30867) Support streaming read changes from overwrite - posted by "yuzelin (Jira)" <ji...@apache.org> on 2023/02/01 12:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30868) Revert to use LongSerializer for seralization in the TimeIndicatorTypeInfo - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2023/02/01 12:23:00 UTC, 0 replies.
- [DISCUSS] FLIP-289: Support online inference (Flink ML) - posted by Dong Lin <li...@gmail.com> on 2023/02/01 12:38:43 UTC, 4 replies.
- [jira] [Created] (FLINK-30869) Remove remote branches not being used anymore - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/01 12:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30870) Performance regressions notifications in Slack are cut off - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2023/02/01 13:16:01 UTC, 0 replies.
- [jira] [Created] (FLINK-30871) add bloom filter for orc - posted by "Jun Zhang (Jira)" <ji...@apache.org> on 2023/02/01 16:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30872) Move GCP example to GCP connector repo - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2023/02/01 18:22:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.16.1 released - posted by Martijn Visser <ma...@apache.org> on 2023/02/01 19:25:31 UTC, 3 replies.
- [jira] [Created] (FLINK-30873) FileSystem Table API connector doesn't discover new files when partitions are specified - posted by "Yaroslav Tkachenko (Jira)" <ji...@apache.org> on 2023/02/01 21:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30874) Introduce configuration for table store - posted by "Shammon (Jira)" <ji...@apache.org> on 2023/02/02 03:57:00 UTC, 0 replies.
- Re: [ANNOUNCE] Flink 1.17 feature freeze and summary of release sync 31st of January - posted by Xintong Song <to...@gmail.com> on 2023/02/02 04:07:49 UTC, 1 replies.
- [jira] [Created] (FLINK-30875) Remove legacy AdaptiveBatchScheduler min parallelism configuration call. - posted by "Junrui Li (Jira)" <ji...@apache.org> on 2023/02/02 07:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30876) Fix ResetTransformationProcessor don't reset the transformation of ExecNode in BatchExecMultiInput.rootNode - posted by "Yunhong Zheng (Jira)" <ji...@apache.org> on 2023/02/02 08:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30877) Add support for @Before / @After for JUnit 4 and 5 - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2023/02/02 08:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30878) KubernetesHighAvailabilityRecoverFromSavepointITCase fails due to a deadlock - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/02 08:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30879) KafkaShuffleITCase failed with multiple test failures due to a TimeoutException while creating topics - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/02 08:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30880) [Connectors/Jdbc] Update flink to 1.16.1 - posted by "João Boto (Jira)" <ji...@apache.org> on 2023/02/02 10:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30881) Crictl/Minikube version mismatch causes errors in k8s setup - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/02 11:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30882) Introduce partition.expiration-time to automatically delete expired partitions - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/02/02 11:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30883) Missing JobID caused the k8s e2e test to fail - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/02 11:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30884) GetTable from Flink catalog should be judged whether it is a sink table - posted by "yuanfenghu (Jira)" <ji...@apache.org> on 2023/02/02 12:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30885) Optional group pattern starts with non-optional looping pattern get wrong result on followed-by - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2023/02/02 12:32:00 UTC, 0 replies.
- Re: [DISCUSS] Incorporate performance regression monitoring into routine process - posted by Martijn Visser <ma...@apache.org> on 2023/02/02 13:09:03 UTC, 1 replies.
- [jira] [Created] (FLINK-30886) Content area is too narrow to show all content - posted by "Ari Huttunen (Jira)" <ji...@apache.org> on 2023/02/02 13:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30887) CI workflow for externalized connectors doesn't cache Flink's binary download - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2023/02/02 13:26:00 UTC, 0 replies.
- [VOTE] FLIP-274: Introduce metric group for OperatorCoordinator - posted by Hang Ruan <ru...@gmail.com> on 2023/02/02 13:30:48 UTC, 7 replies.
- Need help how to use Table API to join two Kafka streams - posted by Amir Hossein Sharifzadeh <am...@gmail.com> on 2023/02/02 20:45:08 UTC, 11 replies.
- [jira] [Created] (FLINK-30888) Flink Doc(zh version) has misspelled words - posted by "Xu (Jira)" <ji...@apache.org> on 2023/02/03 00:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30889) Rename the configuration key SPECULATIVE_ENABLED. - posted by "Junrui Li (Jira)" <ji...@apache.org> on 2023/02/03 03:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30890) Backup codespeed‘s data regularly - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2023/02/03 04:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30891) Introduce Preconditions for table store - posted by "Shammon (Jira)" <ji...@apache.org> on 2023/02/03 04:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30892) Clean codes for memory and tests - posted by "Feng Wang (Jira)" <ji...@apache.org> on 2023/02/03 07:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30893) Replace not specifying a driver in Minikube by something else - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/03 07:56:00 UTC, 0 replies.
- [DISCUSS] FLIP-291: Externalized Declarative Resource Management - posted by David Morávek <dm...@apache.org> on 2023/02/03 08:42:06 UTC, 23 replies.
- Re: [DISCUSS] FLIP-278: Hybrid Source Connector - posted by Ran Tao <ch...@gmail.com> on 2023/02/03 09:09:46 UTC, 1 replies.
- [jira] [Created] (FLINK-30894) Introduce Serializer to serialize internal data structure - posted by "Feng Wang (Jira)" <ji...@apache.org> on 2023/02/03 09:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30895) SlotSharingSlotAllocator may waste slots - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2023/02/03 10:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30896) Reduce usage of CatalogViewImpl in planner - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2023/02/03 11:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30897) Avoid timeouts in JUnit tests - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2023/02/03 12:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30898) Do not include and build examples in operator image - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2023/02/03 12:54:00 UTC, 0 replies.
- Re: [VOTE] FLIP-285: Refactoring LeaderElection to make Flink support multi-component leader election out-of-the-box - posted by David Morávek <dm...@apache.org> on 2023/02/03 14:25:01 UTC, 1 replies.
- Re: [DISCUSS] FLIP-276: Data Consistency of Streaming and Batch ETL in Flink and Table Store - posted by Piotr Nowojski <pn...@apache.org> on 2023/02/03 14:43:36 UTC, 4 replies.
- [RESULT][VOTE] FLIP-285: Refactoring LeaderElection to make Flink support multi-component leader election out-of-the-box - posted by Matthias Pohl <ma...@aiven.io.INVALID> on 2023/02/03 14:43:40 UTC, 0 replies.
- Re: [DISCUSS] Promote SinkV2 to @Public and deprecate SinkFunction - posted by Konstantin Knauf <kn...@apache.org> on 2023/02/03 18:04:31 UTC, 15 replies.
- [jira] [Created] (FLINK-30899) FileSystemTableSource with CSV format incorrectly selects fields if filtering for partition - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2023/02/04 16:05:00 UTC, 0 replies.
- [DISCUSS] Introducing OpenTelemetry to Apache Flink - posted by John Gerassimou <jo...@gmail.com> on 2023/02/04 19:13:21 UTC, 0 replies.
- [jira] [Created] (FLINK-30900) Introduce utils for table store - posted by "Shammon (Jira)" <ji...@apache.org> on 2023/02/06 02:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30901) Fix set jobVertex parallelismConfigured don't contain chained sources. - posted by "Junrui Li (Jira)" <ji...@apache.org> on 2023/02/06 03:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30902) Partition reuse does not take effect on edges of hybrid selective type - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2023/02/06 04:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30903) Fix the maxParallelism of DefaultVertexParallelismAndInputInfosDecider fallback to default parallelism - posted by "Junrui Li (Jira)" <ji...@apache.org> on 2023/02/06 06:07:00 UTC, 0 replies.
- Re: [VOTE] FLIP-208: Add RecordEvaluator to dynamically stop source based on de-serialized records - posted by Dong Lin <li...@gmail.com> on 2023/02/06 06:38:59 UTC, 2 replies.
- [jira] [Created] (FLINK-30904) Update the documentation and configuration description of slow task detector - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2023/02/06 07:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30905) doc generation fails with "concurrent map read and map write" - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/06 07:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30906) TwoInputStreamTask passes wrong configuration object when creating input processor - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2023/02/06 07:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30907) HiveSinkCompactionITCase.testSingleParallelism fails with test timeout - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/06 07:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30908) Fatal error in ResourceManager caused YARNSessionFIFOSecuredITCase.testDetachedMode to fail - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/06 07:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30909) Running HA (hashmap, sync) end-to-end test - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/06 07:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30910) ApplicationDispatcherBootstrapTest.testApplicationIsStoppedWhenStoppingBootstrap fails with assertion - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/06 07:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30911) KafkaSinkE2ECase.testStartFromSavepoint fails with TimeoutException because the topic doesn't become available in the meta file - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/06 08:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30912) CreateTableAsITCase seem to have timed out on Azure - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/06 08:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30913) Various PyFlink tests fail - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/06 08:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30914) ZooKeeperLeaderElectionTest.testUnExpectedErrorForwarding failed - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/06 08:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30915) `flink-fs-hadoop-s3` connector is unable to find IRSA credentials - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2023/02/06 08:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30916) RocksDBStateUploaderTest.testUploadedSstCanBeCleanedUp failed with assertion - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/06 08:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30917) The user configured max parallelism does not take effect when using adaptive batch scheduler - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2023/02/06 08:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30918) Refactor CompositePkAndMultiPartitionedTableITCase to get rid of managed table - posted by "yuzelin (Jira)" <ji...@apache.org> on 2023/02/06 09:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30919) Fix typo in the document of User-defined Sources & Sinks - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2023/02/06 09:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30920) K8 cluster autoscaler | exclude operator id from scaler - posted by "Gaurav Miglani (Jira)" <ji...@apache.org> on 2023/02/06 09:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30921) Too many CI failed due to "Could not connect to azure.archive.ubuntu.com" - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2023/02/06 10:00:00 UTC, 0 replies.
- [Discuss] :Introduce Catalog dynamic registration in flink catalog manager. - posted by Feng Jin <ji...@gmail.com> on 2023/02/06 10:21:29 UTC, 10 replies.
- RE: Re: Confluent Avro and Debezium formats - default schema name can be incompatible with registered schema name - posted by Fruzsina Nagy <fr...@cloudera.com.INVALID> on 2023/02/06 10:34:50 UTC, 1 replies.
- [jira] [Created] (FLINK-30922) SQL validate fail to parse writing metadata - posted by "tanjialiang (Jira)" <ji...@apache.org> on 2023/02/06 10:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30923) Provide single script for installing Hugo - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/06 11:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30924) Conversion issues between timestamp and bingint - posted by "Feng Jin (Jira)" <ji...@apache.org> on 2023/02/06 11:41:00 UTC, 0 replies.
- Flink Kubernetes Operator 1.4.0 release planning - posted by Gyula Fóra <gy...@gmail.com> on 2023/02/06 11:43:09 UTC, 1 replies.
- [jira] [Created] (FLINK-30925) Add docs for the SQL Client gateway mode - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2023/02/06 11:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30926) [Umbrella] Test Flink Release 1.17 - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2023/02/06 11:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30927) Several tests fail with two non-abstract methods have the same parameter types, declaring type and return type - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2023/02/06 12:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30928) Use temurin JRE in test hadoop docker image - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2023/02/06 12:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30929) Add helpful message when ElasticsearchSink.Builder.build() throws a IllegalArgumentException. - posted by "Kenny Wu (Jira)" <ji...@apache.org> on 2023/02/06 13:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30930) Automatically determine Flink binary download URL from version - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2023/02/06 13:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30931) Adaptive scheduler wastes slots for multiple slot sharing groups with different max parallelism - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2023/02/06 15:20:00 UTC, 0 replies.
- [NOTICE] Website now has a staging environment - posted by Chesnay Schepler <ch...@apache.org> on 2023/02/06 16:09:34 UTC, 0 replies.
- [jira] [Created] (FLINK-30932) Enabling producer metrics for KafkaSink is not documented - posted by "Mason Chen (Jira)" <ji...@apache.org> on 2023/02/07 02:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30933) Result of join inside iterationBody loses max watermark - posted by "Zhipeng Zhang (Jira)" <ji...@apache.org> on 2023/02/07 06:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30934) Refactor ComputedColumnAndWatermarkTableITCase to get rid of managed table - posted by "yuzelin (Jira)" <ji...@apache.org> on 2023/02/07 07:00:00 UTC, 0 replies.
- Re: [Discuss] Conventions on driving FLIPs towards consensus - posted by Xintong Song <to...@gmail.com> on 2023/02/07 07:26:34 UTC, 0 replies.
- [jira] [Created] (FLINK-30935) Add KafkaSerializer deserialize check when using SimpleVersionedSerializer - posted by "Ran Tao (Jira)" <ji...@apache.org> on 2023/02/07 08:15:00 UTC, 0 replies.
- Pull Request for FLINK-30927 - posted by Krzysztof Chmielewski <kr...@gmail.com> on 2023/02/07 08:54:50 UTC, 0 replies.
- [ANNOUNCE] release-1.17 branch cut - posted by Leonard Xu <xb...@gmail.com> on 2023/02/07 09:25:47 UTC, 2 replies.
- [jira] [Created] (FLINK-30936) Release Testing: Verify FLINK-29941 Support SQL Client connects to SQL Gateway - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2023/02/07 09:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30937) Add Transformer and Estimator for GBTClassifier and GBTRegressor - posted by "Fan Hong (Jira)" <ji...@apache.org> on 2023/02/07 11:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30938) Release Testing: Verify FLINK-29766 Adaptive Batch Scheduler should also work with hybrid shuffle mode - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2023/02/07 11:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30939) Add public APIs and topmost framework for GBTClassifer - posted by "Fan Hong (Jira)" <ji...@apache.org> on 2023/02/07 11:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30940) InterruptedException in ExecutorImplITCase which doesn't fail the test - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/07 11:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30941) Error when downloading the flink binaries into the Docker container - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/07 11:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30942) Fix the bug that the decided parallelism by adaptive batch scheduler may be larger than the max parallelism - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2023/02/07 12:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30943) Hide sensitive command-line configurations - posted by "Bo Cui (Jira)" <ji...@apache.org> on 2023/02/07 14:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30944) ExecutionGraphPartitionReleaseTest leaks threads - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/07 15:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30945) FTS does not support multiple writers into the same table and topic - posted by "Vicky Papavasileiou (Jira)" <ji...@apache.org> on 2023/02/07 15:44:00 UTC, 0 replies.
- Flink Operator - Supporting Recovery from Snapshot - posted by Kevin Lam <ke...@shopify.com.INVALID> on 2023/02/07 21:42:57 UTC, 4 replies.
- [jira] [Created] (FLINK-30946) Sync master Avro GlueSchemaRegistry formats flink-connector-aws - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2023/02/07 23:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30947) Sync flink-avro-glue-schema-registry and flink-json-glue-schema-registry to flink-connector-aws - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2023/02/07 23:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30948) Remove flink-avro-glue-schema-registry and flink-json-glue-schema-registry from Flink main repo - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2023/02/07 23:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30949) Sync flink-connector-aws-base from Flink main to flink-connector-aws - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2023/02/07 23:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30950) Remove flink-connector-aws-base from Flink main repo - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2023/02/07 23:31:00 UTC, 0 replies.
- Request to join Mailing List - posted by Reme Ajayi <re...@gmail.com> on 2023/02/07 23:58:48 UTC, 1 replies.
- [jira] [Created] (FLINK-30951) Release Testing: Verify FLINK-29635 Hive sink should support merge files in batch mode - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2023/02/08 01:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30952) Add main training and transforming part. - posted by "Fan Hong (Jira)" <ji...@apache.org> on 2023/02/08 01:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30954) Add estimator and transformer for GBTRegressor. - posted by "Fan Hong (Jira)" <ji...@apache.org> on 2023/02/08 02:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30953) Support intermediate state management and model save/load. - posted by "Fan Hong (Jira)" <ji...@apache.org> on 2023/02/08 02:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30955) Support early stopping with validation set. - posted by "Fan Hong (Jira)" <ji...@apache.org> on 2023/02/08 02:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30956) Add Python implementation of GBTClassifer and GBTRegressor. - posted by "Fan Hong (Jira)" <ji...@apache.org> on 2023/02/08 02:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30957) Support other missing features - posted by "Fan Hong (Jira)" <ji...@apache.org> on 2023/02/08 02:42:00 UTC, 0 replies.
- How to find the root cause of e2e ci failure? - posted by Rui Fan <fa...@apache.org> on 2023/02/08 02:46:30 UTC, 4 replies.
- [RESULT][VOTE] FLIP-274: Introduce metric group for OperatorCoordinator (FLINK-29801) - posted by Hang Ruan <ru...@gmail.com> on 2023/02/08 03:03:35 UTC, 0 replies.
- Re: [Discussion] externalize Hive connector - posted by yuxia <lu...@alumni.sjtu.edu.cn> on 2023/02/08 04:28:52 UTC, 0 replies.
- [jira] [Created] (FLINK-30958) Rest API doc generation failure caused by JobClientHeartbeatHeaders - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2023/02/08 06:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30959) UNIX_TIMESTAMP's return value does not meet expected - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2023/02/08 07:25:00 UTC, 0 replies.
- Looking for a jira to get started with contributing - posted by Joern Kottmann <ko...@gmail.com> on 2023/02/08 08:35:42 UTC, 8 replies.
- [jira] [Created] (FLINK-30960) OutOfMemory error using jdbc sink - posted by "Bo Shen (Jira)" <ji...@apache.org> on 2023/02/08 08:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30961) Remove deprecated tests_require in setup.py - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2023/02/08 09:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30962) Improve error messaging when launching py4j gateway server - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2023/02/08 10:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30963) Switch binary downloads to archive.apache.org - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2023/02/08 11:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30964) flink-mirror repo sync release branches failed - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2023/02/08 12:39:00 UTC, 0 replies.
- Confusion about some overlapping functionality of SupportsProjectionPushDown and SupportsReadingMetadata - posted by Ran Tao <ch...@gmail.com> on 2023/02/08 12:46:45 UTC, 6 replies.
- [jira] [Created] (FLINK-30965) git-repo-sync doesn't pick up the 2nd-most-recently published Flink version (even though it's still supported) after a new release branch is cut - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/08 13:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30966) Flink SQL IF FUNCTION logic error - posted by "谢波 (Jira)" <ji...@apache.org> on 2023/02/08 13:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30967) Add MongoDB connector documentation - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2023/02/08 16:03:00 UTC, 0 replies.
- Fwd: [FLINK-30596] Duplicate jobs on /run with the same jobId - posted by Mohsen Rezaei <mo...@gmail.com> on 2023/02/08 17:21:54 UTC, 1 replies.
- [jira] [Created] (FLINK-30968) Sql-client supports dynamic config to open session - posted by "Shammon (Jira)" <ji...@apache.org> on 2023/02/09 02:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30969) Pyflink table example throws "module 'pandas' has no attribute 'Int8Dtype'" - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2023/02/09 02:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30970) Fix SQL Client doc still uses old style output - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2023/02/09 02:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30971) Modify the default value of parameter 'table.exec.local-hash-agg.adaptive.sampling-threshold' - posted by "Yunhong Zheng (Jira)" <ji...@apache.org> on 2023/02/09 03:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30972) E2e tests always fail in phase "Prepare E2E run" - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2023/02/09 05:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30973) e2e test prepare crashes with libssl dependency not being available - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/09 06:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30974) NoClassDefFoundError org/apache/flink/hbase/shaded/org/apache/commons/io/IOUtils - posted by "xi chaomin (Jira)" <ji...@apache.org> on 2023/02/09 06:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30975) Upgrade aws sdk to v2 - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2023/02/09 06:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30976) docs_404_check fails occasionally - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/09 06:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30977) flink tumbling window stream converting to pandas dataframe not work - posted by "Joekwal (Jira)" <ji...@apache.org> on 2023/02/09 06:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30978) ExecutorImplITCase.testInterruptExecution hangs waiting for SQL gateway service closing - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2023/02/09 06:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30979) The buckets of the secondary partition should fall on different tasks - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/02/09 07:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30980) Support s3.signer-type for S3 - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/02/09 07:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30981) explain_sql throws java method not exist - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2023/02/09 07:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30982) Support checkpoint mechanism in GBT - posted by "Fan Hong (Jira)" <ji...@apache.org> on 2023/02/09 07:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30983) the security.ssl.algorithms configuration does not take effect in rest ssl - posted by "luyuan (Jira)" <ji...@apache.org> on 2023/02/09 08:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30984) Remove explicit cast required by 3.1.x janino - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2023/02/09 08:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30985) [Flink][table-store] Change the Splits allocation algorithm of ContinuousFileSplitEnumerator in TableStore to a fair algorithm. - posted by "ming li (Jira)" <ji...@apache.org> on 2023/02/09 08:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30986) Refactor CreateTableITCase and DropTableITCase to get rid of managed table - posted by "yuzelin (Jira)" <ji...@apache.org> on 2023/02/09 08:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30987) output source exception for SocketStreamIterator - posted by "chenyuzhi (Jira)" <ji...@apache.org> on 2023/02/09 08:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30988) Refactor E2E tests to get rid of managed table - posted by "yuzelin (Jira)" <ji...@apache.org> on 2023/02/09 11:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30989) Configuration table.exec.spill-compression.block-size not take effect in batch job - posted by "shen (Jira)" <ji...@apache.org> on 2023/02/09 12:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30990) Performance of has worsened DownstreamTasks.BATCH - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2023/02/09 12:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30991) Introduce LongSerializer for Table Store - posted by "Feng Wang (Jira)" <ji...@apache.org> on 2023/02/09 14:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30992) Introduce ShortSerializer for Table Store - posted by "Feng Wang (Jira)" <ji...@apache.org> on 2023/02/09 14:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30994) Introduce DoubleSerializer for Table Store - posted by "Feng Wang (Jira)" <ji...@apache.org> on 2023/02/09 14:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30993) Introduce FloatSerializer for Table Store - posted by "Feng Wang (Jira)" <ji...@apache.org> on 2023/02/09 14:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30995) Introduce ByteSerializer for Table Store - posted by "Feng Wang (Jira)" <ji...@apache.org> on 2023/02/09 14:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30996) Sync Kafka 1.17 commits from apache/flink repo to flink-connector-kafka - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2023/02/09 14:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30997) Refactor tests in connector to extends AbstractTestBase - posted by "Shammon (Jira)" <ji...@apache.org> on 2023/02/09 14:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30998) Add optional exception handler to flink-connector-opensearch - posted by "Leonid Ilyevsky (Jira)" <ji...@apache.org> on 2023/02/09 21:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-30999) Introduce flink-table-store-test-utils for table store - posted by "Shammon (Jira)" <ji...@apache.org> on 2023/02/10 01:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31000) Upgrade test units in flink-table-store-common to junit5 - posted by "Shammon (Jira)" <ji...@apache.org> on 2023/02/10 01:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31001) Introduce Hive writer - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/02/10 01:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31002) Provide data sampling query - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/02/10 01:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31003) Flink SQL IF / CASE WHEN Funcation incorrect - posted by "weiqinpan (Jira)" <ji...@apache.org> on 2023/02/10 03:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31004) Introduce data input and output stream for table store - posted by "Shammon (Jira)" <ji...@apache.org> on 2023/02/10 03:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31005) Release Testing: Verify FLIP-281 Supports speculative execution of sinks - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2023/02/10 04:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31006) job is not finished when using pipeline mode to run bounded source like kafka/pulsar - posted by "jackylau (Jira)" <ji...@apache.org> on 2023/02/10 05:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31007) The code generated by the IF function throws NullPointerException - posted by "tivanli (Jira)" <ji...@apache.org> on 2023/02/10 07:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31008) [Flink][Table Store] The Split allocation of the same bucket in ContinuousFileSplitEnumerator may be out of order - posted by "ming li (Jira)" <ji...@apache.org> on 2023/02/10 07:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31009) Add recordCount to snapshot meta - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/02/10 08:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31010) Add Transformer and Estimator for GBTClassifier and GBTRegressor - posted by "Fan Hong (Jira)" <ji...@apache.org> on 2023/02/10 08:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31011) upgrade hiverunner version - posted by "Jun Zhang (Jira)" <ji...@apache.org> on 2023/02/10 09:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31012) Update docs for files table in table store - posted by "Shammon (Jira)" <ji...@apache.org> on 2023/02/10 09:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31013) SessionWindowAggregation cannot get trigger window using event time - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2023/02/10 09:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31014) Expose exceptions in connector testing framework - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/10 10:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31015) SplitReader doesn't extend AutoCloseable but implements close - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/10 10:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31016) "Run kubernetes pyflink application test" fails due to Rust package manager not being listed in the PATH - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/10 11:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31017) Early-started partial match timeout not yield completed matches - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2023/02/10 14:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31018) SQL Client -j option does not load user jars to classpath. - posted by "Krzysztof Chmielewski (Jira)" <ji...@apache.org> on 2023/02/10 15:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31019) Migrate FileSystemTableSink to FileSink - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2023/02/10 20:36:00 UTC, 0 replies.
- Re: [DISCUSS] Enabling dynamic partition discovery by default in Kafka source - posted by Martijn Visser <ma...@apache.org> on 2023/02/10 20:51:27 UTC, 4 replies.
- [jira] [Created] (FLINK-31020) Provide read-only mode for flink web UI - posted by "Omkar Deshpande (Jira)" <ji...@apache.org> on 2023/02/11 02:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31021) JavaCodeSplitter doesn't split static method properly - posted by "Xingcan Cui (Jira)" <ji...@apache.org> on 2023/02/11 03:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31022) Using new Serializer for table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/02/11 13:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31023) Introduce ConfigOption for table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/02/11 15:56:00 UTC, 0 replies.
- Proposal to mark package private classes public - posted by tom yang <en...@gmail.com> on 2023/02/11 17:14:32 UTC, 0 replies.
- [jira] [Created] (FLINK-31024) Copy code splitter to table store from flink table - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/02/12 07:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31025) Release Testing: Verify FLINK-30650 Introduce EXPLAIN PLAN_ADVICE to provide SQL advice - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2023/02/13 03:03:00 UTC, 0 replies.
- [VOTE] FLIP-289: Support online inference (Flink ML) - posted by Dong Lin <li...@gmail.com> on 2023/02/13 03:03:25 UTC, 6 replies.
- [ANNOUNCE] New Apache Flink Committer - Weijie Guo - posted by Xintong Song <xt...@apache.org> on 2023/02/13 03:44:51 UTC, 27 replies.
- [jira] [Created] (FLINK-31026) KBinsDiscretizer should gives binEdges wrong bin edges when all values are same. - posted by "Fan Hong (Jira)" <ji...@apache.org> on 2023/02/13 04:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31027) Introduce annotation for table store - posted by "Shammon (Jira)" <ji...@apache.org> on 2023/02/13 05:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31028) Provide different compression methods for per level - posted by "Jun Zhang (Jira)" <ji...@apache.org> on 2023/02/13 05:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31029) KBinsDiscretizer gives wrong bin edges when input data contains only 2 distinct values - posted by "Fan Hong (Jira)" <ji...@apache.org> on 2023/02/13 06:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31030) Support more binary classification evaluation metrics. - posted by "Fan Hong (Jira)" <ji...@apache.org> on 2023/02/13 06:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31031) Disable the output buffer of Python process to make it more convenient for interactive users - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2023/02/13 06:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31032) Supports AND predicate in orc format for table store - posted by "Shammon (Jira)" <ji...@apache.org> on 2023/02/13 08:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31033) UsingRemoteJarITCase.testUdfInRemoteJar failed with assertion - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/13 09:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31034) Deploy Maven Snapshot failed - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/13 09:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31035) add warn info to user when NoNodeException happend - posted by "xy (Jira)" <ji...@apache.org> on 2023/02/13 09:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31036) StateCheckpointedITCase timed out due to deadlock - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/13 09:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31037) Table Store supports streaming reading a whole snapshot in one checkpoint - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/02/13 10:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31038) Avoid accessing non-TableStore tables in HiveCatalog.listTables - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/02/13 10:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31039) ChangelogWithKeyFileStoreTableITCase in table store is not stable - posted by "Shammon (Jira)" <ji...@apache.org> on 2023/02/13 10:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31040) Looping pattern notFollowedBy at end missing an element - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2023/02/13 11:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31041) Race condition in DefaultScheduler results in memory leak and busy loop - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2023/02/13 11:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31042) AfterMatchSkipStrategy not working on notFollowedBy ended pattern - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2023/02/13 11:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31043) KeyError exception is thrown in CachedMapState - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2023/02/13 11:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31044) Unexpected behavior using greedy on looping pattern with notFollowedBy at end - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2023/02/13 13:49:00 UTC, 0 replies.
- Proposal to add support for Kafka Headers to KafkaRecordSerializationSchemaWrapper - posted by Alex Gout <al...@shopify.com.INVALID> on 2023/02/13 15:08:24 UTC, 4 replies.
- [jira] [Created] (FLINK-31045) In IntelliJ: flink-clients cannot find symbol symbol: class TestUserClassLoaderJobLib - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2023/02/13 16:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31046) Support Extra environment variables from field ref - posted by "Tamir Sagi (Jira)" <ji...@apache.org> on 2023/02/13 16:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31047) Support Topology spread constrains when HA is enabled. - posted by "Tamir Sagi (Jira)" <ji...@apache.org> on 2023/02/13 16:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31048) Java doc of PulsarSourceBuilder was not updated in time - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2023/02/13 17:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31049) Add support for Kafka record headers to KafkaSink - posted by "Alex Gout (Jira)" <ji...@apache.org> on 2023/02/13 21:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31050) Supports IN predicate in ORC format of table store - posted by "Nicholas Jiang (Jira)" <ji...@apache.org> on 2023/02/14 01:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31051) Introduce `delete` action to support deleting from table - posted by "yuzelin (Jira)" <ji...@apache.org> on 2023/02/14 02:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31052) Release Testing: Verify FLINK-30707 Improve slow task detection - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2023/02/14 03:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31053) Example Repair the log output format of the CheckpointCoordinator - posted by "xzw0223 (Jira)" <ji...@apache.org> on 2023/02/14 05:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31054) Flink free to common codegen core shade - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/02/14 06:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31055) The dynamic flag of stream graph does not take effect when translating the transformations - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2023/02/14 07:13:00 UTC, 0 replies.
- [ANNOUNCE] New Apache Flink Committer - Jing Ge - posted by godfrey he <go...@gmail.com> on 2023/02/14 07:49:24 UTC, 32 replies.
- [jira] [Created] (FLINK-31057) upgrade usage of aws sdk to v2 for flink-json-glue-schema-registry - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2023/02/14 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31056) upgrade usage of aws sdk to v2 for flink-avro-glue-schema-registry - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2023/02/14 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31058) upgrade usage of aws sdk to v2 for flink-connector-aws - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2023/02/14 08:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31059) Release Testing: Verify FLINK-29717 Supports hive udaf such as sum/count by native implementation - posted by "dalongliu (Jira)" <ji...@apache.org> on 2023/02/14 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31060) Release Testing: Verify FLINK-30542 Support adaptive local hash aggregate in runtime - posted by "Yunhong Zheng (Jira)" <ji...@apache.org> on 2023/02/14 08:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31061) Release Testing: Verify FLINK-30376 Introduce a new flink bushy join reorder rule which based on greedy algorithm - posted by "Yunhong Zheng (Jira)" <ji...@apache.org> on 2023/02/14 08:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31062) Release Testing: Verify FLINK-29942 New dynamic partition pruning strategy to support more dpp patterns - posted by "Yunhong Zheng (Jira)" <ji...@apache.org> on 2023/02/14 08:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31063) Prevent duplicate reading when restoring from a checkpoint. - posted by "Jiabao Sun (Jira)" <ji...@apache.org> on 2023/02/14 10:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31064) Error while retrieving the leader gateway - posted by "Tobias Hofer (Jira)" <ji...@apache.org> on 2023/02/14 10:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31065) Support more split assigner strategy for batch job - posted by "yunfan (Jira)" <ji...@apache.org> on 2023/02/14 13:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31066) Release Testing: Verify FLINK-29932 Upgrade Calcite to 1.29.0 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2023/02/14 13:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31067) Add pull request template for flink-pulsar-connector - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2023/02/14 14:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31068) Document how to use Opensearch connector with OpenSearch 1.x / 2.x / ... clusters - posted by "Andriy Redko (Jira)" <ji...@apache.org> on 2023/02/14 18:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31069) Pyflink 1.16.1 has unclosed resources at the end of unit tests - posted by "Nathanael England (Jira)" <ji...@apache.org> on 2023/02/14 20:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31070) Update jline to 3.22.0 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2023/02/14 22:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31071) Release Testing: Verify FLIP-283 Use adaptive batch scheduler as default scheduler for batch jobs - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2023/02/15 03:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31072) Introduce streaming-read-atomic to ensure UB and UA cannot be split - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/02/15 03:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31073) Pyflink testing library can't be used out of the box - posted by "Nathanael England (Jira)" <ji...@apache.org> on 2023/02/15 05:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31074) Introduce value filter for table store - posted by "Shammon (Jira)" <ji...@apache.org> on 2023/02/15 05:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31075) Upgrade test units in table store to junit5 - posted by "Shammon (Jira)" <ji...@apache.org> on 2023/02/15 05:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31076) Supports filter predicate in Parquet format of table store - posted by "Nicholas Jiang (Jira)" <ji...@apache.org> on 2023/02/15 05:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31077) Trigger checkpoint failed but it were shown as COMPLETED by rest API - posted by "Junrui Li (Jira)" <ji...@apache.org> on 2023/02/15 06:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31078) Flink-table-planner free for flink-table-store-core - posted by "Shammon (Jira)" <ji...@apache.org> on 2023/02/15 06:42:00 UTC, 0 replies.
- [SUMMARY] Flink 1.17 Release Sync 2/14/2023 - posted by Qingsheng Ren <re...@apache.org> on 2023/02/15 06:46:05 UTC, 0 replies.
- [jira] [Created] (FLINK-31079) Release Testing: Verify FLINK-29663 Further improvements of adaptive batch scheduler - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2023/02/15 07:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31080) Idle slots are not released due to a mismatch in time between DeclarativeSlotPoolService and SlotSharingSlotAllocator - posted by "Prabhu Joseph (Jira)" <ji...@apache.org> on 2023/02/15 07:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31081) Update Jira links in How To Contribute guide - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/15 08:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31082) Setting maven property 'flink.resueForks' to false in table planner module - posted by "Yunhong Zheng (Jira)" <ji...@apache.org> on 2023/02/15 08:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31083) Python ProcessFunction with OutputTag cannot be reused - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2023/02/15 09:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31084) DataGen sequence generator requires the definition of start/end values - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/15 09:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31085) Add schema option to confluent registry avro formats - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2023/02/15 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31086) [DOC]update connector lable for blackhole and kafka - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2023/02/15 09:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31087) Introduce InsertChangesAction. - posted by "yuzelin (Jira)" <ji...@apache.org> on 2023/02/15 11:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31088) Flink free for flink-table-store-docs - posted by "Shammon (Jira)" <ji...@apache.org> on 2023/02/15 11:30:00 UTC, 0 replies.
- [DISCUSS] Release Flink 1.15.4 - posted by Danny Cranmer <da...@apache.org> on 2023/02/15 11:30:48 UTC, 11 replies.
- [jira] [Created] (FLINK-31089) pin L0 index in memory can lead to slow memory grow finally lead to memory beyond limit - posted by "xiaogang zhou (Jira)" <ji...@apache.org> on 2023/02/15 12:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31090) Flink fail to select INTERVAL - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2023/02/15 12:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31091) SQL interval related queries stop working via SQL client - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2023/02/15 14:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31092) Hive ITCases fail with OutOfMemoryError - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/15 14:56:00 UTC, 0 replies.
- [VOTE] Apache Flink Kubernetes Operator Release 1.4.0, release candidate #1 - posted by Gyula Fóra <gy...@gmail.com> on 2023/02/15 15:09:45 UTC, 9 replies.
- [jira] [Created] (FLINK-31093) NullpointerException when restoring a FlinkSQL job from a savepoint - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/15 16:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31094) Add table name to write operator - posted by "DaiXinyu (Jira)" <ji...@apache.org> on 2023/02/16 01:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31095) FileSink doesn't work with s3a on EKS - posted by "Sylvia Lin (Jira)" <ji...@apache.org> on 2023/02/16 02:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31096) Unify versions in pom of table store - posted by "Shammon (Jira)" <ji...@apache.org> on 2023/02/16 02:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31097) mysql catalog datatype mapping error tinyint mapping boolean - posted by "谢波 (Jira)" <ji...@apache.org> on 2023/02/16 03:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31098) Add ARRAY_SIZE supported in SQL & Table API - posted by "jackylau (Jira)" <ji...@apache.org> on 2023/02/16 04:08:00 UTC, 0 replies.
- [ANNOUNCE] New Apache Flink PMC Member - Dong Lin - posted by Guowei Ma <gu...@gmail.com> on 2023/02/16 06:19:08 UTC, 31 replies.
- [jira] [Created] (FLINK-31099) Chained WindowOperator throws NPE in PyFlink ThreadMode - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2023/02/16 07:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31100) Support the short topic pattern subscriber on default tenant and namespace - posted by "Yufan Sheng (Jira)" <ji...@apache.org> on 2023/02/16 08:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31101) Replace all the JUnit 5 assertions to AssertJ - posted by "Yufan Sheng (Jira)" <ji...@apache.org> on 2023/02/16 09:01:00 UTC, 0 replies.
- [DISCUSS] Extract core autoscaling algorithm as new SubModule in flink-kubernetes-operator - posted by Samrat Deb <de...@gmail.com> on 2023/02/16 09:26:44 UTC, 18 replies.
- [jira] [Created] (FLINK-31102) Add ARRAY_REMOVE supported in SQL & Table API - posted by "jackylau (Jira)" <ji...@apache.org> on 2023/02/16 09:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31103) Public Table API for table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/02/16 09:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31104) TPC-DS test timed out in query 36 - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/16 09:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31105) SqlClient doesn't respond to QUIT or HELP command even though it's mentioned in the welcome message - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/16 11:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31106) Skip history server archiving for suspended jobs on JsonResponseHistoryServerArchivist - posted by "xy (Jira)" <ji...@apache.org> on 2023/02/16 12:13:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-289: Support online inference (Flink ML) - posted by Dong Lin <li...@gmail.com> on 2023/02/16 13:42:40 UTC, 0 replies.
- [jira] [Created] (FLINK-31107) Can't subscribe the non-persistent topics by using regex in Pulsar 2.11.0 - posted by "Yufan Sheng (Jira)" <ji...@apache.org> on 2023/02/16 16:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31108) Use StreamARN for API calls in Kinesis Connector - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2023/02/16 17:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31109) Fails with proxy user not supported even when security.kerberos.fetch.delegation-token is set to false - posted by "Venkata krishnan Sowrirajan (Jira)" <ji...@apache.org> on 2023/02/16 21:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31110) Web UI shows "User Configuration" preserving lines and whitespaces - posted by "Mingliang Liu (Jira)" <ji...@apache.org> on 2023/02/16 22:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31111) Introduce CatalogTestBase - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/02/17 03:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31112) How to Change the default mode of the volume attached to flink-config-volume in a pod on Flink native Kubernetes - posted by "hob007 (Jira)" <ji...@apache.org> on 2023/02/17 04:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31113) Support AND filter for flink-orc - posted by "Shammon (Jira)" <ji...@apache.org> on 2023/02/17 04:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31114) Batch job fails with IllegalStateException when using adaptive batch scheduler - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2023/02/17 05:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31115) Support a task to specify multiple slots - posted by "waywtdcc (Jira)" <ji...@apache.org> on 2023/02/17 06:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31116) Support taskmanager related parameters in session mode Support job granularity setting - posted by "waywtdcc (Jira)" <ji...@apache.org> on 2023/02/17 07:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31117) Split flink connector to each module of each version - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/02/17 08:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31118) Add ARRAY_UNION supported in SQL & Table API - posted by "jackylau (Jira)" <ji...@apache.org> on 2023/02/17 09:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31119) JobRecoveryITCase.testTaskFailureRecovery failed due to the job not finishing successfully - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/17 10:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31120) ConcurrentModificationException occurred in StringFunctionsITCase.test - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/17 10:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31121) KafkaSink should be able to catch and ignore exp via config on/off - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2023/02/17 10:34:00 UTC, 0 replies.
- Should the sink writer and committer always be chained together - posted by Hang Ruan <ru...@gmail.com> on 2023/02/17 11:19:17 UTC, 0 replies.
- [jira] [Created] (FLINK-31122) Expose MetricGroup to Committer of new Unified Sink v2 - posted by "Theo Diefenthal (Jira)" <ji...@apache.org> on 2023/02/17 12:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31123) Add it case for FileSink speculative execution - posted by "Biao Liu (Jira)" <ji...@apache.org> on 2023/02/17 13:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31124) Add it case for HiveTableSink speculative execution - posted by "Biao Liu (Jira)" <ji...@apache.org> on 2023/02/17 13:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31125) Flink ML benchmark result should not include data generation overhead - posted by "Dong Lin (Jira)" <ji...@apache.org> on 2023/02/17 14:17:00 UTC, 0 replies.
- [DISCUSS] Flink minor version support policy for old releases - posted by Danny Cranmer <da...@apache.org> on 2023/02/17 16:51:01 UTC, 12 replies.
- [jira] [Created] (FLINK-31126) Move classes not dependenting on Flink runtime from flink-ml-core to flink-ml-servable-core - posted by "Dong Lin (Jira)" <ji...@apache.org> on 2023/02/19 08:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31127) Add public API classes for FLIP-289 - posted by "Dong Lin (Jira)" <ji...@apache.org> on 2023/02/19 09:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31128) Add Create Table As for flink table store - posted by "Jun Zhang (Jira)" <ji...@apache.org> on 2023/02/19 14:50:00 UTC, 0 replies.
- Re: Metrics or runtimeContext in global commit - posted by yuxia <lu...@alumni.sjtu.edu.cn> on 2023/02/20 02:31:22 UTC, 1 replies.
- [jira] [Created] (FLINK-31129) Introduce FlinkEmbeddedHiveRunner for junit5 in table store - posted by "Shammon (Jira)" <ji...@apache.org> on 2023/02/20 05:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31130) Improve version info for the doc of SQL Gateway - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2023/02/20 06:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31131) The INITIALIZING of ExecutionState is missed in the doc - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2023/02/20 09:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31132) Set sink.parallelism doesn't work for Hive table - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2023/02/20 10:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31133) AdaptiveSchedulerITCase took extraordinary long to finish - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/20 10:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31134) Out of memory error in KafkaSourceE2ECase>SourceTestSuiteBase.testScaleDown - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/20 10:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31135) ConfigMap DataSize went > 1 MB and cluster stopped working - posted by "Sriram Ganesh (Jira)" <ji...@apache.org> on 2023/02/20 10:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31136) SQL Client Gateway mode should not read read execution config - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2023/02/20 10:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31137) SQL Client doesn't print results for SHOW CREATE TABLE/DESC in hive dialect - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2023/02/20 10:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31138) Either StreamCheckpointingITCase/StreamFaultToleranceTestBase or EventTimeWindowCheckpointingITCase are timinng out - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/20 10:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31139) not upload empty state changelog file - posted by "Feifan Wang (Jira)" <ji...@apache.org> on 2023/02/20 12:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31140) Load additional dependencies in Operator classpath - posted by "Tamir Sagi (Jira)" <ji...@apache.org> on 2023/02/20 12:37:00 UTC, 0 replies.
- [ANNOUNCE] New Apache Flink Committer - Anton Kalashnikov - posted by Piotr Nowojski <pn...@apache.org> on 2023/02/20 14:18:54 UTC, 21 replies.
- [ANNOUNCE] New Apache Flink Committer - Rui Fan - posted by Piotr Nowojski <pn...@apache.org> on 2023/02/20 14:18:57 UTC, 23 replies.
- [jira] [Created] (FLINK-31141) CreateTableAsITCase.testCreateTableAs fails - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2023/02/20 14:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31142) Some queries lead to abrupt sql client close - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2023/02/20 14:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31143) Invalid request: offset doesn't match when restarting from a savepoint - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/20 16:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31144) Slow scheduling on large-scale batch jobs - posted by "Julien Tournay (Jira)" <ji...@apache.org> on 2023/02/20 17:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31145) Stabilize Kafka-related tests - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/20 17:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31146) Flink 1.17 Release - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/20 17:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31147) Create a new version in JIRA - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/20 18:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31148) Triage release-blocking issues in JIRA - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/20 18:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31149) Review and update documentation - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/20 18:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31150) Cross team testing - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/20 18:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31151) Review Release Notes in JIRA - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/20 18:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31152) Setup for the executing release manager - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/20 18:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31153) Create a release branch - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/20 18:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31154) Build Release Candidate: 1.17.0-rc1 - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/20 18:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31155) Build and stage Java and Python artifacts - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/20 19:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31156) Stage source and binary releases on dist.apache.org - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/20 19:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31157) Propose a pull request for website updates - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/20 19:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31158) Vote on the release candidate - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/20 19:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31159) Release Testing: Verify FLINK-30583 Provide the flame graph to the subtask level - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2023/02/20 21:21:00 UTC, 0 replies.
- Proposal to improve the Apache Flink website - posted by "Mohan, Deepthi" <md...@amazon.com.INVALID> on 2023/02/21 00:13:02 UTC, 15 replies.
- [jira] [Created] (FLINK-31160) Support join/cogroup in BroadcastUtils.withBroadcastStream - posted by "Zhipeng Zhang (Jira)" <ji...@apache.org> on 2023/02/21 01:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31161) upgrade MojoHaus Versions Maven Plugin to 2.14.2 - posted by "jackylau (Jira)" <ji...@apache.org> on 2023/02/21 04:20:00 UTC, 0 replies.
- Connectin two jobs with socket over AWS EMR - How to define the ip? - posted by Itay Sali <it...@Skyhawk.security> on 2023/02/21 06:20:50 UTC, 1 replies.
- [jira] [Created] (FLINK-31162) Avoid setting private tokens to AM container context when kerberos delegation token fetch is disabled - posted by "Venkata krishnan Sowrirajan (Jira)" <ji...@apache.org> on 2023/02/21 06:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31163) Unexpected correlate variable $cor0 in the plan error in where clause - posted by "P Rohan Kumar (Jira)" <ji...@apache.org> on 2023/02/21 07:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31164) Unexpected correlate variable $cor0 in the plan error in where clause - posted by "P Rohan Kumar (Jira)" <ji...@apache.org> on 2023/02/21 07:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31165) Over Agg: The window rank function without order by error in top N query - posted by "P Rohan Kumar (Jira)" <ji...@apache.org> on 2023/02/21 08:55:00 UTC, 0 replies.
- [DISCUSS] Proposal to improve Auxiliary Sql Statements - posted by Ran Tao <ch...@gmail.com> on 2023/02/21 09:51:54 UTC, 9 replies.
- [jira] [Created] (FLINK-31166) array_contains element type error - posted by "jackylau (Jira)" <ji...@apache.org> on 2023/02/21 10:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31167) Verify that no exclusions were erroneously added to the japicmp plugin - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/21 11:09:00 UTC, 0 replies.
- [ANNOUNCE] New Apache Flink Committer - Sergey Nuyanzin - posted by Timo Walther <tw...@apache.org> on 2023/02/21 11:50:30 UTC, 13 replies.
- Connecting two jobs with socket over AWS EMR - How to define the ip? - cont' - posted by Itay Sali <it...@Skyhawk.security> on 2023/02/21 12:27:15 UTC, 0 replies.
- [jira] [Created] (FLINK-31168) JobManagerHAProcessFailureRecoveryITCase failed due to job not being found - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/21 12:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31169) KubernetesResourceManagerDriverTest fails fatally due to 239 exit code - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/21 12:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31170) The spelling error of the document word causes sql to fail to execute - posted by "BoYi Zhang (Jira)" <ji...@apache.org> on 2023/02/21 13:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31171) Support iterate in Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2023/02/22 01:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31172) Support coGroup in Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2023/02/22 01:37:00 UTC, 0 replies.
- [DISCUSS] FLIP-296: Watermark options for table API & SQL - posted by kui yuan <ca...@gmail.com> on 2023/02/22 02:22:21 UTC, 16 replies.
- [jira] [Created] (FLINK-31173) TailOperator should only have one input - posted by "Zhipeng Zhang (Jira)" <ji...@apache.org> on 2023/02/22 02:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31174) [Doc] Inconsistent data format between flink-training-repo and learn-flink doc - posted by "CHEN Zhongpu (Jira)" <ji...@apache.org> on 2023/02/22 03:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31175) Fix link doesn't work in hive_reaad_write doc - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2023/02/22 03:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31176) correct the description of sql gateway configuration - posted by "wangkang (Jira)" <ji...@apache.org> on 2023/02/22 03:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31177) To introduce a formatter for Markdown files - posted by "CHEN Zhongpu (Jira)" <ji...@apache.org> on 2023/02/22 06:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31178) Public Writer API - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/02/22 07:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31179) Make data structures serializable - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/02/22 07:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31180) Fail early when installing minikube and check whether we can retry - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/22 07:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31181) Support LIKE operator pushdown - posted by "Grzegorz Kołakowski (Jira)" <ji...@apache.org> on 2023/02/22 08:19:00 UTC, 0 replies.
- [jira](FLINK-31177) To introduce a formatter for Markdown files - posted by Zhongpu Chen <ch...@gmail.com> on 2023/02/22 08:42:56 UTC, 0 replies.
- [discussion] To introduce a formatter for Markdown files - posted by Zhongpu Chen <ch...@gmail.com> on 2023/02/22 08:49:28 UTC, 6 replies.
- [VOTE] Flink minor version support policy for old releases - posted by Danny Cranmer <da...@apache.org> on 2023/02/22 09:10:57 UTC, 8 replies.
- [jira] [Created] (FLINK-31182) CompiledPlan cannot deserialize BridgingSqlFunction correctly - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2023/02/22 10:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31183) Flink Kinesis EFO Consumer can fail to stop gracefully - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2023/02/22 10:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31184) Failed to get python udf runner directory via running GET_RUNNER_DIR_SCRIPT - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2023/02/22 11:33:00 UTC, 0 replies.
- [RESULT] [VOTE] Apache Flink Kubernetes Operator Release 1.4.0, release candidate #1 - posted by Gyula Fóra <gy...@gmail.com> on 2023/02/22 11:38:51 UTC, 0 replies.
- [jira] [Created] (FLINK-31185) Python BroadcastProcessFunction not support side output - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2023/02/22 12:02:00 UTC, 0 replies.
- [DISCUSS] FLIP-297: Improve Auxiliary Sql Statements - posted by Ran Tao <ch...@gmail.com> on 2023/02/22 12:17:13 UTC, 33 replies.
- [jira] [Created] (FLINK-31186) Removing topic from kafka source does nothing - posted by "Exidex (Jira)" <ji...@apache.org> on 2023/02/22 12:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31187) Standalone HA mode does not work if dynamic properties are supplied - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2023/02/22 18:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31188) Expose kubernetes scheduler configOption when running flink on kubernetes - posted by "Kelu Tao (Jira)" <ji...@apache.org> on 2023/02/23 02:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31189) Allow ignore less frequent values in StringIndexer - posted by "Fan Hong (Jira)" <ji...@apache.org> on 2023/02/23 03:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31190) Supports Spark call procedure command on Table Store - posted by "Nicholas Jiang (Jira)" <ji...@apache.org> on 2023/02/23 04:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31191) VectorIndexer should check whether doublesByColumn is null before snapshot - posted by "Zhipeng Zhang (Jira)" <ji...@apache.org> on 2023/02/23 06:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31192) dataGen takes too long to initialize under sequence - posted by "xzw0223 (Jira)" <ji...@apache.org> on 2023/02/23 06:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31193) The option `table.exec.hive.native-agg-function.enabled` should work at job level when using it in SqlClient side - posted by "dalongliu (Jira)" <ji...@apache.org> on 2023/02/23 06:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31194) ntroduces savepoint mechanism of Table Store - posted by "Nicholas Jiang (Jira)" <ji...@apache.org> on 2023/02/23 07:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31195) FullChangelogStoreSinkWrite bucket writer conflicts with rescale - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/02/23 08:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31196) Flink on YARN honors env.java.home - posted by "Prabhu Joseph (Jira)" <ji...@apache.org> on 2023/02/23 09:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31197) Exception while writing Parqeut files containing Arrays with complex types. - posted by "Krzysztof Chmielewski (Jira)" <ji...@apache.org> on 2023/02/23 10:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31198) Class loader problem by incorrect classloader in flink sql 1.16 - posted by "Rascal Wu (Jira)" <ji...@apache.org> on 2023/02/23 11:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31199) Add MAP_KEYS supported in SQL & Table API - posted by "jackylau (Jira)" <ji...@apache.org> on 2023/02/23 11:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31200) Add MAP_VALUES supported in SQL & Table API - posted by "jackylau (Jira)" <ji...@apache.org> on 2023/02/23 11:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31201) Provides option to sort partition for full stage in streaming read - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/02/23 11:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31202) Add support for reading Parquet files containing Arrays with complex types. - posted by "Krzysztof Chmielewski (Jira)" <ji...@apache.org> on 2023/02/23 11:37:00 UTC, 0 replies.
- [ANNOUNCE] Flink project website is now powered by Hugo - posted by Martijn Visser <ma...@apache.org> on 2023/02/23 14:28:27 UTC, 9 replies.
- [ANNOUNCE] Apache Flink Kubernetes Operator 1.4.0 released - posted by Gyula Fóra <gy...@apache.org> on 2023/02/23 16:16:42 UTC, 0 replies.
- [jira] [Created] (FLINK-31203) Application upgrade rollbacks failed in Flink Kubernetes Operator - posted by "hjw (Jira)" <ji...@apache.org> on 2023/02/23 16:34:00 UTC, 0 replies.
- [VOTE] Release 1.15.4, release candidate #1 - posted by Danny Cranmer <da...@gmail.com> on 2023/02/23 18:06:46 UTC, 7 replies.
- [jira] [Created] (FLINK-31204) HiveCatalogITCase fails due to avro conflict in table store - posted by "Shammon (Jira)" <ji...@apache.org> on 2023/02/24 00:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31205) do optimize for multi sink in a single relNode tree - posted by "Aitozi (Jira)" <ji...@apache.org> on 2023/02/24 02:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31206) Broken links on flink.apache.org - posted by "Zili Chen (Jira)" <ji...@apache.org> on 2023/02/24 04:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31207) supports high order function like other engine - posted by "jackylau (Jira)" <ji...@apache.org> on 2023/02/24 05:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31208) KafkaSourceReader overrides meaninglessly a method(pauseOrResumeSplits) - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2023/02/24 06:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31209) Introduce creation time to files table - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/02/24 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31210) Azure Pipelines report warning on "no space left on device" in Restore Docker images step - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/24 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31211) Flink chk files not delete automic after 1.13 - posted by "leo.zhi (Jira)" <ji...@apache.org> on 2023/02/24 08:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31212) Data lost if window group after interval left join - posted by "Lyn Zhang (Jira)" <ji...@apache.org> on 2023/02/24 10:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31213) Aggregation merge engine supports retract inputs - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/02/24 13:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31214) Add support for new command line option -py.pythonpath - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2023/02/24 14:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31215) Backpropagate processing rate limits from non-scalable bottlenecks to upstream operators - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2023/02/24 15:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31216) Update kryo to current - posted by "Morey Straus (Jira)" <ji...@apache.org> on 2023/02/24 15:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31217) Update netty to current - posted by "Morey Straus (Jira)" <ji...@apache.org> on 2023/02/24 15:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31218) Improve health probe to recognize informers already failed at start - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2023/02/24 16:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31219) Add support for canary resources - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2023/02/24 16:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31220) Replace Pod with PodTemplateSpec for the pod template properties - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2023/02/24 17:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31221) Fix Typo in YarnConfigOptions - posted by "Shilun Fan (Jira)" <ji...@apache.org> on 2023/02/24 21:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31222) Remove usage of deprecated ConverterUtils.toApplicationId - posted by "Shilun Fan (Jira)" <ji...@apache.org> on 2023/02/25 04:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31223) sql-client.sh fails to start with ssl enabled - posted by "macdoor615 (Jira)" <ji...@apache.org> on 2023/02/25 07:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31224) Add metrics for flink table store - posted by "Jun Zhang (Jira)" <ji...@apache.org> on 2023/02/25 14:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31225) rocksdb max open file can lead to oom - posted by "xiaogang zhou (Jira)" <ji...@apache.org> on 2023/02/26 04:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31226) Bump the FRocksDB version in table-store's lookup module - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2023/02/26 09:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31227) Remove 'scala version' from file sink modules - posted by "Kwang-in (Dennis) JUNG (Jira)" <ji...@apache.org> on 2023/02/26 12:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31228) flink-playgrounds is using a buggy zookeeper - posted by "CHEN Zhongpu (Jira)" <ji...@apache.org> on 2023/02/26 14:05:00 UTC, 0 replies.
- [Discuss] Some questions on flink-table-store micro benchmark - posted by Yun Tang <my...@LIVE.COM> on 2023/02/26 17:24:12 UTC, 4 replies.
- [jira] [Created] (FLINK-31229) Implement a Pub/Sub Lite source and sink - posted by "Daniel Collins (Jira)" <ji...@apache.org> on 2023/02/26 18:19:00 UTC, 0 replies.
- Contributing a Google Cloud Pub/Sub Lite source and sink? - posted by Daniel Collins <dp...@google.com.INVALID> on 2023/02/26 18:26:39 UTC, 5 replies.
- [jira] [Created] (FLINK-31230) Improve YarnClusterDescriptor memory unit display - posted by "Shilun Fan (Jira)" <ji...@apache.org> on 2023/02/27 01:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31231) flink-playgrounds has permission errors in mounted files - posted by "CHEN Zhongpu (Jira)" <ji...@apache.org> on 2023/02/27 04:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31232) Parquet format supports MULTISET type for Table Store - posted by "Nicholas Jiang (Jira)" <ji...@apache.org> on 2023/02/27 06:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31233) no error should be logged when retrieving the task manager's stdout if it does not exist - posted by "Weihua Hu (Jira)" <ji...@apache.org> on 2023/02/27 06:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31234) Add an option to redirect stdout/stderr for flink on kubernetes - posted by "Weihua Hu (Jira)" <ji...@apache.org> on 2023/02/27 06:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31235) Flink Jdbc Connector can not push down where condition - posted by "leo.zhi (Jira)" <ji...@apache.org> on 2023/02/27 08:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31236) Limit pushdown will open useless RecordReader - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/02/27 08:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31237) Fix possible bug of array_distinct - posted by "jackylau (Jira)" <ji...@apache.org> on 2023/02/27 08:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31238) Use IngestDB to speed up Rocksdb rescaling recovery - posted by "Yue Ma (Jira)" <ji...@apache.org> on 2023/02/27 08:57:00 UTC, 0 replies.
- Slack community invitation request - posted by Viacheslav Chernyshev <v....@outlook.com> on 2023/02/27 08:59:41 UTC, 2 replies.
- [jira] [Created] (FLINK-31239) Fix sum function can't get the corrected value when the argument type is string - posted by "dalongliu (Jira)" <ji...@apache.org> on 2023/02/27 09:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31240) Reduce the overhead of conversion between DataStream and Table - posted by "Jiang Xin (Jira)" <ji...@apache.org> on 2023/02/27 09:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31241) Hive dependency cannot be resolved - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/27 10:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31242) Correct the definition of creating functions in the SQL client documentation - posted by "Xianxun Ye (Jira)" <ji...@apache.org> on 2023/02/27 11:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31243) KryoSerializer when loaded from user code classloader cannot load Scala extensions from app classloader - posted by "Amit Gurdasani (Jira)" <ji...@apache.org> on 2023/02/27 12:01:00 UTC, 0 replies.
- [DISCUSS] SourceCoordinator and ExternallyInducedSourceReader do not work well together - posted by ming li <jo...@gmail.com> on 2023/02/27 12:34:42 UTC, 2 replies.
- [DISCUSS] FLIP-298: Unifying the Implementation of SlotManager - posted by Weihua Hu <hu...@gmail.com> on 2023/02/27 12:40:58 UTC, 5 replies.
- [jira] [Created] (FLINK-31244) OffHeapUnsafeMemorySegmentTest.testCallCleanerOnceOnConcurrentFree prints IllegalStateException - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2023/02/27 12:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31245) Adaptive scheduler does not reset the state of GlobalAggregateManager when rescaling - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2023/02/27 13:04:00 UTC, 0 replies.
- [DISCUSS] Deprecating GlobalAggregateManager - posted by Zhanghao Chen <zh...@outlook.com> on 2023/02/27 13:44:35 UTC, 1 replies.
- [jira] [Created] (FLINK-31246) Remove PodTemplate description from the SpecChange message - posted by "Peter Vary (Jira)" <ji...@apache.org> on 2023/02/27 20:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31247) Support for fine-grained resource allocation (slot sharing groups) at the TableAPI level - posted by "Sergio Sainz (Jira)" <ji...@apache.org> on 2023/02/27 22:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31248) Improve documentation for append-only table - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/02/28 02:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31249) Checkpoint Timer failed to process timeout events when it blocked at writing _metadata to DFS - posted by "renxiang zhou (Jira)" <ji...@apache.org> on 2023/02/28 03:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31250) ParquetSchemaConverter supports MULTISET type for parquet format - posted by "Nicholas Jiang (Jira)" <ji...@apache.org> on 2023/02/28 05:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31251) Deprecate deserialize method in DeserializationSchema - posted by "Shammon (Jira)" <ji...@apache.org> on 2023/02/28 06:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31252) Improve StaticFileStoreSplitEnumerator to assign batch splits - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/02/28 06:09:00 UTC, 0 replies.
- [DISCUSS] Deprecate deserialize method in DeserializationSchema - posted by Shammon FY <zj...@gmail.com> on 2023/02/28 06:14:10 UTC, 4 replies.
- [jira] [Created] (FLINK-31253) Port itcases to Flink 1.15 and 1.14 - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/02/28 07:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31254) Improve the read performance for files table - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/02/28 07:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31255) OperatorUtils#createWrappedOperatorConfig fails to wrap operator config - posted by "Zhipeng Zhang (Jira)" <ji...@apache.org> on 2023/02/28 08:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31256) FLIP-297: Improve Auxiliary Sql Statements - posted by "Ran Tao (Jira)" <ji...@apache.org> on 2023/02/28 08:48:00 UTC, 0 replies.
- [SUMMARY] Flink 1.17 Release Sync 2/28/2023 - posted by Qingsheng Ren <re...@apache.org> on 2023/02/28 09:29:34 UTC, 0 replies.
- [jira] [Created] (FLINK-31257) Fix errors in “CSV Formats" page - posted by "ZhengYi Weng (Jira)" <ji...@apache.org> on 2023/02/28 11:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31258) can not get kerberos keytab in flink operator - posted by "Jun Zhang (Jira)" <ji...@apache.org> on 2023/02/28 12:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31259) Gateway supports initialization of catalog at startup - posted by "Shammon (Jira)" <ji...@apache.org> on 2023/02/28 12:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31260) PushLocalHashAggIntoScanRule should also work with union RelNode - posted by "Aitozi (Jira)" <ji...@apache.org> on 2023/02/28 12:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31261) Make AdaptiveScheduler aware of the (local) state size - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2023/02/28 13:07:00 UTC, 0 replies.
- [VOTE] FLIP-291: Externalized Declarative Resource Management - posted by David Morávek <dm...@apache.org> on 2023/02/28 13:46:33 UTC, 2 replies.
- [jira] [Created] (FLINK-31262) Add sql connector fat jar test to SmokeKafkaITCase - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2023/02/28 16:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31263) Add smoke test for ElasticSearch connector - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2023/02/28 16:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31264) Add smoke test for HBase connector - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2023/02/28 16:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-31265) Add smoke test for Pulsar connector - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2023/02/28 17:05:00 UTC, 0 replies.