dev@flink.apache.org, 2022-04

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

- [jira] [Created] (FLINK-26969) Write operation examples of tumbling window, sliding window, session window and time window based on pyflink - posted by "zhangjingcun (Jira)" <ji...@apache.org> on 2022/04/01 00:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26970) Fix comment style error - posted by "yingjie.wang (Jira)" <ji...@apache.org> on 2022/04/01 02:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26971) UniversalCompaction should pick by size ratio after picking by file num - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/04/01 04:28:00 UTC, 0 replies.
- Re: [VOTE] Apache Flink Kubernetes Operator Release 0.1.0, release candidate #3 - posted by Thomas Weise <th...@apache.org> on 2022/04/01 05:02:26 UTC, 7 replies.
- [jira] [Created] (FLINK-26972) Support spot instance in Flink Kubernetes operator - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/04/01 05:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26973) Emit events on state transitions for FlinkDeployment - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/04/01 06:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26974) Python EmbeddedThreadDependencyTests.test_add_python_file failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/04/01 06:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26975) TableTestBase will not generate exec node tree after generating rel node tree - posted by "xuyang (Jira)" <ji...@apache.org> on 2022/04/01 07:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26976) HistoryServer archiving is not idempotent - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/04/01 07:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26977) JobMasterStopWithSavepointITCase.throwingExceptionOnCallbackWithRestartsShouldSimplyRestartInTerminate failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/04/01 07:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26978) Flink-SQL cannot display Timestamp time correctly. - posted by "Siqi Ouyang (Jira)" <ji...@apache.org> on 2022/04/01 07:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26979) JsonFunctionsITCase.test failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/04/01 07:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26980) PulsarUnorderedSourceReaderTest hang on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/04/01 07:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26981) [Umbrella] Make Flink work on Apple M1 ARM chipset - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/04/01 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26982) strike a balance between reuse the same RelNode and project/filter/limit/partition push down - posted by "zoucao (Jira)" <ji...@apache.org> on 2022/04/01 07:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26983) When the startup mode in the command line submission task is filled in incorrectly, the code judgment is wrong, and the error information will be misleading - posted by "丛鹏 (Jira)" <ji...@apache.org> on 2022/04/01 08:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26984) HistoryServer archiving is not retried - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/04/01 08:41:00 UTC, 0 replies.
- [DISCUSS] Flink SQL Syntax for Query/Savepoint Management - posted by Paul Lam <pa...@gmail.com> on 2022/04/01 09:24:13 UTC, 11 replies.
- Re: [DISCUSS] assign SQL Table properties from environment variables - posted by Martijn Visser <ma...@apache.org> on 2022/04/01 09:39:35 UTC, 2 replies.
- Re: Question about community collaboration options - posted by Martijn Visser <ma...@apache.org> on 2022/04/01 10:07:19 UTC, 3 replies.
- [jira] [Created] (FLINK-26985) With legacy restore mode, incremantal checkpoints would be deleted by mistake - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2022/04/01 10:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26986) Remove deprecated string expressions in Python Table API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2022/04/01 11:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26987) ZooKeeperStateHandleStore.getAllAndLock ends up in a infinite loop if there's an entry marked for deletion that's not cleaned up, yet - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/04/01 11:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26988) Better error reporting when format fails - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/04/01 11:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26989) Fix the potential lost of secondary resource when watching a namespace - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/04/01 11:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26990) BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByTime failed - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/04/01 12:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26991) Limit operator docs build to main repository - posted by "Márton Balassi (Jira)" <ji...@apache.org> on 2022/04/01 12:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26992) PojoSerializer may cause concurrent exception passing directly between threads - posted by "Yuan Mei (Jira)" <ji...@apache.org> on 2022/04/01 12:44:00 UTC, 0 replies.
- [DISCUSS] Make Kubernetes Operator config "dynamic" and consider merging with flinkConfiguration - posted by Gyula Fóra <gy...@apache.org> on 2022/04/01 18:25:14 UTC, 7 replies.
- [jira] [Created] (FLINK-26993) CheckpointCoordinatorTest#testMinCheckpointPause - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/01 20:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26994) Merge libraries CI profile into core - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/01 20:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26995) Enable fork-reuse for all unit tests - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/01 20:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26996) Break the reconcile after first create session cluster - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/04/02 01:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26997) Add table store links to Community page - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/04/02 02:20:00 UTC, 0 replies.
- Re: Wrong format when passing arguments with space - posted by Kevin Lee <ke...@gmail.com> on 2022/04/02 02:23:37 UTC, 1 replies.
- [jira] [Created] (FLINK-26998) Remove log-related configuration from predefined options in RocksDB state backend - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2022/04/02 03:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26999) Introduce ClickHouse Connector - posted by "ZhuoYu Chen (Jira)" <ji...@apache.org> on 2022/04/02 04:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27000) Support to set JVM args for operator - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/04/02 05:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27001) Support to specify the resource of the operator - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/04/02 05:28:00 UTC, 0 replies.
- 回复: [GitHub] [flink] flinkbot edited a comment on pull request #15519: [FLINK-22120] Remove duplicate code in generated code for map get - posted by 范佳兴 <fa...@hotmail.com> on 2022/04/02 06:35:11 UTC, 0 replies.
- [jira] [Created] (FLINK-27002) Optimize batch multiple partitions inserting - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/04/02 06:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27003) Operator Helm chart improvements - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/04/02 07:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27004) Use '. - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/04/02 07:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27005) Bump CRD version to v1alpha2 - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/04/02 08:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27006) Support SingleValueAggFunction for Char data type - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/04/02 08:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27007) Should the MailboxDefaultAction interface be annotated with @FunctionalInterface? - posted by "Shubin Ruan (Jira)" <ji...@apache.org> on 2022/04/02 08:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27008) Document the configurable parameters of the helm chart and their default values - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/04/02 08:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27009) Support SQL job submission in flink kubernetes opeartor - posted by "Biao Geng (Jira)" <ji...@apache.org> on 2022/04/02 08:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27010) Support setting sql client args via flink conf - posted by "Luning Wang (Jira)" <ji...@apache.org> on 2022/04/02 09:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27011) Add various types of state usage examples - posted by "zhangjingcun (Jira)" <ji...@apache.org> on 2022/04/02 09:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27012) Caching maven dependencies to speed up workflows for flink-kubernetes-operator - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/04/02 10:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27013) Hive dialect supports IS_DISTINCT_FROM - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/04/02 10:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27014) Hive dialect support select null literal in subquery - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/04/02 11:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27015) Hive dialect supports cast timestamp to decimal implicitly while inserting - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/04/02 11:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27016) Improve supporting for complex data type for Hive dialect - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/04/02 11:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27017) Hive dialect supports divide by zero - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/04/02 11:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27018) timestamp missing end zero when outputing to kafka - posted by "jeff-zou (Jira)" <ji...@apache.org> on 2022/04/02 11:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27019) use hive dialect in SqlClient would thrown an error based on 1.15 version - posted by "Jing Zhang (Jira)" <ji...@apache.org> on 2022/04/02 12:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27020) use hive dialect in SqlClient would thrown an error based on 1.15 version - posted by "Jing Zhang (Jira)" <ji...@apache.org> on 2022/04/02 12:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27021) CRD improvements for v1alpha2 - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/04/02 13:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27022) Expose taskSlots in TaskManager spec - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/04/02 13:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27023) Merge default flink and operator configuration settings for the operator - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/04/02 13:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27024) Cleanup surefire configuration - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/02 14:00:00 UTC, 0 replies.
- [RESULT] [VOTE] Apache Flink Kubernetes Operator Release 0.1.0, release candidate #3 - posted by Gyula Fóra <gy...@apache.org> on 2022/04/02 14:45:05 UTC, 2 replies.
- Creating flink-kubernetes-operator project on Dockerhub - posted by Gyula Fóra <gy...@apache.org> on 2022/04/02 16:49:26 UTC, 2 replies.
- [jira] [Created] (FLINK-27025) Cannot read parquet file, after putting the jar in the right place with right permissions - posted by "Ziheng Wang (Jira)" <ji...@apache.org> on 2022/04/02 18:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27026) Upgrade checkstyle plugin - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/02 19:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27027) Get rid of oddly named mvn-${sys mvn.forkNumber}.log files - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/02 20:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27028) Support to upload jar and run jar in RestClusterClient - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/04/03 05:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27029) DeploymentValidator should take default flink config into account during validation - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/04/03 06:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27030) RpcEndpointTest.testCancelScheduledTask failed - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/04/03 08:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27031) ChangelogRescalingITCase.test failed due to IllegalStateException - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/04/03 09:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27032) PyFlink end-to-end test failed due to str object not having expected attribute _j_expr - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/04/03 09:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27033) YARNITCase failed due to OOM - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/04/03 09:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27034) Use testcontainers for google cloud pubsub e2e test - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/03 10:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27035) Reduce memory usage of ByteArrayWrapperSerializerTest - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/03 12:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27036) Do not build and push images on final release tags - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/04/03 12:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27037) Publish Javadocs for Kubernetes Operator - posted by "Márton Balassi (Jira)" <ji...@apache.org> on 2022/04/03 13:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27038) Publish Javadocs for Kubernetes Operator - posted by "Márton Balassi (Jira)" <ji...@apache.org> on 2022/04/03 13:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27039) Publish Javadocs for Kubernetes Operator - posted by "Márton Balassi (Jira)" <ji...@apache.org> on 2022/04/03 13:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27040) Better structure for the helm chart configs - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/04/03 15:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27041) KafkaSource in batch mode failing on 0 messages in any topic partition - posted by "Terxor (Jira)" <ji...@apache.org> on 2022/04/03 20:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27042) StreamTaskITCase#testMailboxMetricsScheduling is unstable - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/03 21:25:00 UTC, 0 replies.
- [GitHub] [flink-kubernetes-operator] Aitozi commented on a diff in pull request #153: [FLINK-27000] Support to set JVM args for operator - posted by GitBox <gi...@apache.org> on 2022/04/03 23:54:33 UTC, 1 replies.
- [GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #153: [FLINK-27000] Support to set JVM args for operator - posted by GitBox <gi...@apache.org> on 2022/04/04 04:56:17 UTC, 0 replies.
- [GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #72: [FLINK-26899] Introduce write/query table document for table store - posted by GitBox <gi...@apache.org> on 2022/04/04 06:27:43 UTC, 0 replies.
- [DISCUSS] Bumping operator CRD version to v1alpha2 - posted by Gyula Fóra <gy...@apache.org> on 2022/04/04 06:47:10 UTC, 3 replies.
- [GitHub] [flink-statefun] FilKarnicki commented on a diff in pull request #309: [FLINK-26570][statefun] Remote module configuration interpolation - posted by GitBox <gi...@apache.org> on 2022/04/04 07:51:24 UTC, 0 replies.
- [GitHub] [flink] XComp commented on a diff in pull request #19275: [FLINK-24491][runtime] Make the job termination wait until the archiving of ExecutionGraphInfo finishes - posted by GitBox <gi...@apache.org> on 2022/04/04 07:56:29 UTC, 0 replies.
- [jira] [Created] (FLINK-27043) Remove CSV connector test usages - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/04/04 07:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27044) Drop support for Hive versions 1.*, 2.1.* and 2.2.* - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/04/04 09:05:00 UTC, 0 replies.
- Regarding java.lang.NullPointerException - posted by Josemon Maliakal <jo...@gmail.com> on 2022/04/04 09:29:01 UTC, 1 replies.
- [jira] [Created] (FLINK-27045) Remove shared TestingUtils executor - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/04 09:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27046) [JUnit5 Migration] Module: flink-*-glue-schema-registry - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2022/04/04 10:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27047) DispatcherResourceCleanupTest is unstable - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/04 10:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27048) Add ArchUnit tests for Elasticsearch to only depend on public API - posted by "Alexander Preuss (Jira)" <ji...@apache.org> on 2022/04/04 11:16:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink Kubernetes Operator 0.1.0 released - posted by Gyula Fóra <gy...@apache.org> on 2022/04/04 11:45:57 UTC, 2 replies.
- [jira] [Created] (FLINK-27049) Add "What is Flink Kubernetes Operator?" link to flink website - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/04/04 11:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27050) TestingDispatcher.Builder instantiates a RPCSystem without shutting it down - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/04/04 12:46:00 UTC, 0 replies.
- [NOTICE] Migration to GitHub Actions - posted by Chesnay Schepler <ch...@apache.org> on 2022/04/04 12:48:57 UTC, 3 replies.
- [jira] [Created] (FLINK-27051) CompletedCheckpoint.DiscardObject.discard is not idempotent - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/04/04 13:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27052) FsCompletedCheckpointStorageLocation.disposeStorageLocation doesn't expose errors properly (not processing the return value) - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/04/04 13:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27053) IncrementalRemoteKeyedStateHandle.discardState swallows errors - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/04/04 14:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27054) Elasticsearch SQL connector SSL issue - posted by "ricardo (Jira)" <ji...@apache.org> on 2022/04/04 17:12:00 UTC, 0 replies.
- Pyflink + TABLE API + snowflake - posted by Shameet Doshi <sh...@firstperformance.com> on 2022/04/04 17:41:38 UTC, 4 replies.
- [jira] [Created] (FLINK-27055) java.lang.ArrayIndexOutOfBoundsException in BinarySegmentUtils - posted by "Kenny Ma (Jira)" <ji...@apache.org> on 2022/04/05 00:12:00 UTC, 0 replies.
- [ANNOUNCE] Flink Table Store release-0.1 branch cut - posted by Jingsong Li <ji...@gmail.com> on 2022/04/05 02:35:33 UTC, 0 replies.
- [jira] [Created] (FLINK-27056) "pipeline.time-characteristic" should be deprecated and have EVENT_TIME as default value - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2022/04/05 04:30:00 UTC, 0 replies.
- Re: Flink 1.15 Stabilisation Sync - posted by Robert Metzger <me...@gmail.com> on 2022/04/05 05:33:35 UTC, 3 replies.
- pyflink on Python 3.9 dev guide - posted by Luan Cooper <gc...@gmail.com> on 2022/04/05 09:39:08 UTC, 4 replies.
- [jira] [Created] (FLINK-27057) Connector to external repo migration - Elasticsearch Connector - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/04/05 10:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27058) Add support for Python 3.9 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/04/05 10:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27059) [JUnit5 Migration] Module: flink-compress - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2022/04/05 10:57:00 UTC, 0 replies.
- [ANNOUNCE] Dependabot has been enabled for the Apache organization including the Flink project - posted by Martijn Visser <ma...@apache.org> on 2022/04/05 12:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27060) Extending /jars/:jarid/run API to - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2022/04/05 13:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27061) Improve the ArchUnit test infra in the external elasticsearch connector - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/04/05 14:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27062) Add Boring Cyborg bot to flink-connector-elasticsearch - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/04/05 15:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27063) Upgrade Hive 2.3 connector to version 2.3.6 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/04/05 17:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27065) Store lastReconciledSpec as String in status - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/04/05 18:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27064) Centralize ArchUnit rules for production code - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/04/05 18:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27066) Reintroduce e2e tests in ES as Java tests. - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2022/04/05 19:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27067) Prevent usage of deprecated APIs in PyFlink examples - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2022/04/06 03:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27068) test_keyed_min_and_max and test_keyed_min_by_and_max_by failed in py36,37 - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/04/06 03:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27069) Fix the potential memory corruption in Thread Mode - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/04/06 06:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27070) Reuse FileFormat instead of DecodingFormat/EncodingFormat to ensure thread safety. - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/04/06 06:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27071) For jdbcsink function to support config table name in SQL parameter - posted by "haixiaCao (Jira)" <ji...@apache.org> on 2022/04/06 06:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27072) Add Bucketizer in FlinkML - posted by "Zhipeng Zhang (Jira)" <ji...@apache.org> on 2022/04/06 06:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27073) HAQueryableStateFsBackendITCase hangs on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/04/06 06:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27074) python_job.py should write to TEST_DATA_DIR - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/06 06:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27075) Migrate CI from Azure to Github Actions - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/06 06:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27076) Setup runners - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/06 06:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27079) Setup cron jobs - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/06 06:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27077) Setup per-commit builds for master - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/06 06:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27078) There is a performance gap between the new csv source(file system source + CSV format) and legacy CsvTableSource. - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2022/04/06 06:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27080) Enable builds for pull requests - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/06 06:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27081) Remove Azure integration - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/06 06:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27082) Disable tests relying on non-writable directories - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/06 07:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27083) SavepointITCase.testStopWithSavepointFailingAfterSnapshotCreation failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/04/06 07:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27084) Perround mode recreating operator fails - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2022/04/06 07:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27085) Introduce snapshot.num-retained.min option - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/04/06 07:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27086) Add a QA about how to handle exception when use hive parser in hive dialect document - posted by "Jing Zhang (Jira)" <ji...@apache.org> on 2022/04/06 07:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27087) Configuration "taskmanager.network.detailed-metrics" in metrics document was mistaken as "taskmanager.net.detailed-metrics" - posted by "Smile (Jira)" <ji...@apache.org> on 2022/04/06 08:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27088) The example of using StringDeserializer for deserializing Kafka message value as string has an error - posted by "Penguin (Jira)" <ji...@apache.org> on 2022/04/06 08:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27089) Calling TRY_CAST with an invalid value throws IndexOutOfBounds Exception. - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/04/06 09:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27090) Add Estimator and Transformer for FTRL - posted by "Dong Lin (Jira)" <ji...@apache.org> on 2022/04/06 11:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27091) Add Estimator and Transformer for SVM - posted by "Dong Lin (Jira)" <ji...@apache.org> on 2022/04/06 11:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27092) Add Estimator and Transformer for Bucketizer - posted by "Dong Lin (Jira)" <ji...@apache.org> on 2022/04/06 11:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27093) Add Estimator and Transformer for LinearReg - posted by "Dong Lin (Jira)" <ji...@apache.org> on 2022/04/06 11:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27094) Use Boring Cyborg to link issues back to Jira - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/04/06 11:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27096) Benchmark all algorithms included in Flink ML 2.1 release and achieve performance parity with Spark - posted by "Dong Lin (Jira)" <ji...@apache.org> on 2022/04/06 12:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27095) Allow FlinkDeployment Mode Switching - posted by "Usamah Jassat (Jira)" <ji...@apache.org> on 2022/04/06 12:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27097) Document custom validator implementations - posted by "Nicholas Jiang (Jira)" <ji...@apache.org> on 2022/04/06 14:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27098) The session job controller should create FlinkDeployment informer event source with namespace definition - posted by "Xin Hao (Jira)" <ji...@apache.org> on 2022/04/06 15:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27099) RestClient fills /tmp directory - posted by "Mexicapita (Jira)" <ji...@apache.org> on 2022/04/06 16:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27100) Support parquet format in FileStore - posted by "Yubin Li (Jira)" <ji...@apache.org> on 2022/04/06 16:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27101) Periodically break the chain of incremental checkpoint - posted by "Steven Zhen Wu (Jira)" <ji...@apache.org> on 2022/04/06 17:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27102) Add BinaryClassificationEvaluator - posted by "Dong Lin (Jira)" <ji...@apache.org> on 2022/04/07 00:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27103) Don't store redundant primary key fields - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/04/07 02:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27104) ClassNotFound when submit jobs to session cluster with external jars - posted by "Sitan Pang (Jira)" <ji...@apache.org> on 2022/04/07 03:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27105) wrong metric type - posted by "Feifan Wang (Jira)" <ji...@apache.org> on 2022/04/07 04:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27106) Flink command line support submit one job with multi jars - posted by "FanJia (Jira)" <ji...@apache.org> on 2022/04/07 06:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27107) Typo in Task - posted by "dizhou cao (Jira)" <ji...@apache.org> on 2022/04/07 06:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27108) State cache clean up doesn't work as expected - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2022/04/07 07:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27109) The naming pattern of ClusterRole in Flink K8s operator should consider namespace - posted by "Biao Geng (Jira)" <ji...@apache.org> on 2022/04/07 07:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27110) using TIMESTAMP_LTZ cause Flink web ui watermark display problem - posted by "tanjialiang (Jira)" <ji...@apache.org> on 2022/04/07 09:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27111) Update docs regarding EnvironmentSettings / TableConfig - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2022/04/07 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27112) Optimize the term usage on the job overview WebUI - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/04/07 09:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27113) Flink Sql Client CREATE CATALOG 'type'='jdbc', 'base-url' = 'jdbc:mysql://ip:port', ERROR MySQLDialect is not supported - posted by "haojiawei (Jira)" <ji...@apache.org> on 2022/04/07 09:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27114) On JM restart, the information about the initial checkpoints can be lost - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/04/07 09:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27115) Error while executing BLOB connection. java.io.IOException: Unknown operation 80 - posted by "zhiyuan (Jira)" <ji...@apache.org> on 2022/04/07 09:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27116) Supports Hive table partitioned by decimal - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/04/07 10:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27117) FLIP-217: Support watermark alignment of source splits - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2022/04/07 10:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27118) Flink on Yarned failed with the default flink-conf - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/04/07 10:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27119) Cleanup JobMasters - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/07 10:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27120) Translate "configuration" page of "Application Development > Project Configuration > Overview > Gradle (tab)" to Chinese - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2022/04/07 10:29:00 UTC, 0 replies.
- Performance Engineering Track CFP for ApacheCon NA New Orleans - posted by sharanf <sh...@apache.org> on 2022/04/07 10:34:49 UTC, 0 replies.
- [jira] [Created] (FLINK-27121) Translate "Configuration#overview" paragraph and the code example in "Application Development > Table API & SQL" to Chinese - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2022/04/07 10:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27122) Remove FutureUtils#retryWithDelay variants without RetryStrategy - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/07 11:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27123) Introduce filter predicate for 'IN' and 'LIKE' - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/04/07 11:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27124) Flink Kubernetes operator prints starting logs with wrong version - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/04/07 11:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27125) Tests leak executor services - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/07 11:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27126) Respect the state cache size configurations in Python DataStream API operators - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2022/04/07 12:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27127) Local recovery on task manager process restart - posted by "Abdullah alkhawatrah (Jira)" <ji...@apache.org> on 2022/04/07 13:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27128) Broadcast stream Iteration closeWith failed starting version 1.12.2 - posted by "Jeff Hu (Jira)" <ji...@apache.org> on 2022/04/07 15:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27129) Hardcoded namespace in FlinkDeployment manifests may fail to deploy - posted by "Ted Chang (Jira)" <ji...@apache.org> on 2022/04/08 01:44:00 UTC, 0 replies.
- Re: Re: Re: Re: 回复：Re:[DISCUSS] FLIP-214 Support Advanced Function DDL - posted by 刘大龙 <ld...@zju.edu.cn> on 2022/04/08 02:09:46 UTC, 4 replies.
- [jira] [Created] (FLINK-27130) unable to read custom System properties in job class - posted by "Adrian Zhong (Jira)" <ji...@apache.org> on 2022/04/08 03:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27131) CastFunctionITCase.test failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/04/08 06:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27132) CheckpointResourcesCleanupRunner might discard shared state of the initial checkpoint - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/04/08 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27133) Performance regression in serializerHeavyString - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2022/04/08 09:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27134) OSS sink can't get access key id - posted by "Alex Z (Jira)" <ji...@apache.org> on 2022/04/08 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27135) Rename 'file.path' table option in table store to 'path' - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/04/08 09:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27136) Disable rolling file when writing level 0 sst files - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/04/08 09:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27137) Remove usage of AdminClient from KafkaSource logic - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/04/08 09:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27138) flink1.14.0-standalone部署-sql方式提交job-失败报错-提示不支持 - posted by "yanbiao (Jira)" <ji...@apache.org> on 2022/04/08 10:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27139) FileStoreCommitImpl#filterCommitted should exit when faced with expired files - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/04/08 10:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27140) Move JobResultStore dirty entry creation into ioExecutor - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/04/08 10:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27141) Improve FlinkService#waitForClusterShutdown logic - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/04/08 10:21:00 UTC, 0 replies.
- Re: Speeding up the test builds - posted by Piotr Nowojski <pn...@apache.org> on 2022/04/08 10:36:11 UTC, 0 replies.
- [jira] [Created] (FLINK-27142) Remove bash tests dependencies on the Elasticsearch connector. - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2022/04/08 11:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27143) [JUnit5 Migration] Module: flink-docs - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2022/04/08 11:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27144) Provide timeout details when calling FutureUtils.orTimeout - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/04/08 12:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27145) The code generated for agg function accepts empty parameters can't be compiled - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/04/08 12:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27146) [JUnit5 Migration] Module: flink-filesystems - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/08 12:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27147) Move DataStream's RequestReplyFunctionBuilder to use the netty client - posted by "Fil Karnicki (Jira)" <ji...@apache.org> on 2022/04/08 14:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27148) UnalignedCheckpointITCase fails on AZP - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/04/08 16:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27149) KafkaSourceE2ECase.testScaleUp failed on AZP - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/04/08 16:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27150) Improve error reporting in Flink UI - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/04/08 20:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27151) Group By Aggregation With Sorted Data - posted by "Karthik (Jira)" <ji...@apache.org> on 2022/04/09 09:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27152) Examples of state usage of various data structures - posted by "zhangjingcun (Jira)" <ji...@apache.org> on 2022/04/09 11:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27153) Allow optional last-state fallback for savepoint upgrade mode - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/04/09 14:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27154) Disable web.cancel.enable for application clusters - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/04/09 14:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27155) Reduce multiple reads to the same Changelog file in the same taskmanager during restore - posted by "Feifan Wang (Jira)" <ji...@apache.org> on 2022/04/09 16:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27156) [FLIP-171] MongoDB implementation of Async Sink - posted by "Almog Tavor (Jira)" <ji...@apache.org> on 2022/04/09 17:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27157) Add version field to manifest entries - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/04/11 01:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27158) Adjust default value of compaction and compress - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/04/11 02:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27159) Support first_value/last_value in the Table API - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/04/11 03:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27160) Add e2e tests for FlinkSessionJob type - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/04/11 05:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27161) Support user jar from different type of filesystems - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/04/11 05:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27162) RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/04/11 06:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27163) Fix typo issue in Flink Metrics documentation - posted by "hao wang (Jira)" <ji...@apache.org> on 2022/04/11 07:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27164) ResumeCheckpointManuallyITCase.testExternalizedFSCheckpointsWithLocalRecoveryZookeeper failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/04/11 07:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27165) Benchmark test SerializationFrameworkMiniBenchmarks#serializerHeavyString became unstable - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/04/11 07:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27166) Introduce file structure document for table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/04/11 08:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27167) Deploying master snapshot failed due to generating javadoc failed - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/04/11 08:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27168) Add continuousprocessingtimetrigger and continuouseventtimetrigger triggers - posted by "zhangjingcun (Jira)" <ji...@apache.org> on 2022/04/11 08:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27169) PartiallyFinishedSourcesITCase.test hangs on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/04/11 08:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27170) Support Ftrl in FlinkML - posted by "weibo zhao (Jira)" <ji...@apache.org> on 2022/04/11 08:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27171) Add periodic kerberos delegation token obtain possibility to DelegationTokenManager - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/04/11 08:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27172) Support bulk based format provided by Flink - posted by "Yubin Li (Jira)" <ji...@apache.org> on 2022/04/11 08:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27173) CoGroupedStreams$TaggedUnion cannot be used as a POJO type - posted by "Jun Qin (Jira)" <ji...@apache.org> on 2022/04/11 09:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27174) Non-null check for bootstrapServers field is incorrect in KafkaSink - posted by "Zhengqi Zhang (Jira)" <ji...@apache.org> on 2022/04/11 10:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27175) Fail to call Hive UDAF when the UDAF is with only one parameter with array type - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/04/11 11:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27176) FLIP-220: Temporal State - posted by "David Anderson (Jira)" <ji...@apache.org> on 2022/04/11 12:25:01 UTC, 0 replies.
- [jira] [Created] (FLINK-27177) Implement Temporal State - posted by "David Anderson (Jira)" <ji...@apache.org> on 2022/04/11 12:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27178) create examples that use temporal state - posted by "David Anderson (Jira)" <ji...@apache.org> on 2022/04/11 12:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27179) Update training example to use temporal state - posted by "David Anderson (Jira)" <ji...@apache.org> on 2022/04/11 12:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27180) Docs for temporal state - posted by "David Anderson (Jira)" <ji...@apache.org> on 2022/04/11 12:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27181) Optimize TemporalRowTimeJoinOperator by using temporal state - posted by "David Anderson (Jira)" <ji...@apache.org> on 2022/04/11 12:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27182) Optimize RowTimeSortOperator by using temporal state - posted by "David Anderson (Jira)" <ji...@apache.org> on 2022/04/11 12:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27183) Optimize CepOperator by using temporal state - posted by "David Anderson (Jira)" <ji...@apache.org> on 2022/04/11 12:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27184) Optimize IntervalJoinOperator by using temporal state - posted by "David Anderson (Jira)" <ji...@apache.org> on 2022/04/11 12:50:00 UTC, 0 replies.
- [DISCUSS] FLIP-220: Temporal State - posted by David Anderson <da...@apache.org> on 2022/04/11 12:54:15 UTC, 21 replies.
- [jira] [Created] (FLINK-27185) Run the assertj conversion script to convert assertions in connectors and formats - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/04/11 12:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27186) support ElasticSearch 8 - posted by "macdoor615 (Jira)" <ji...@apache.org> on 2022/04/11 13:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27187) The attemptsPerUpload metric may be lower than it actually is - posted by "Feifan Wang (Jira)" <ji...@apache.org> on 2022/04/11 16:37:00 UTC, 0 replies.
- Apache Flink Statefun - broadcast state - posted by M Singh <ma...@yahoo.com.INVALID> on 2022/04/11 17:56:50 UTC, 0 replies.
- [jira] [Created] (FLINK-27188) Deprecate StreamingFileSink - posted by "Daisy Tsang (Jira)" <ji...@apache.org> on 2022/04/11 18:07:00 UTC, 0 replies.
- [VOTE] Release 1.15.0, release candidate #1 - posted by Yun Gao <yu...@aliyun.com.INVALID> on 2022/04/11 18:12:18 UTC, 5 replies.
- [jira] [Created] (FLINK-27189) Ability for table api to always add quotes to generated csv - posted by "shameet (Jira)" <ji...@apache.org> on 2022/04/11 18:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27190) Revisit error handling in main reconcile() loop - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/04/11 20:28:00 UTC, 0 replies.
- FLINK-11746 work - posted by Chen Qin <qi...@gmail.com> on 2022/04/12 02:36:19 UTC, 2 replies.
- Supporting Collector API in Kinesis Connector - posted by Blake Wilson <bl...@yellowpapersun.com> on 2022/04/12 02:51:59 UTC, 5 replies.
- [jira] [Created] (FLINK-27191) Support multi kerberos-enabled Hive clusters - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/04/12 03:03:01 UTC, 0 replies.
- Discuss making KafkaSubscriber Public - posted by Mason Chen <ma...@gmail.com> on 2022/04/12 03:46:05 UTC, 4 replies.
- [jira] [Created] (FLINK-27192) Hi, - posted by "Karthik (Jira)" <ji...@apache.org> on 2022/04/12 03:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27193) Kyro Serialisation and Deserialisation returns a different object - posted by "Akshay Hazari (Jira)" <ji...@apache.org> on 2022/04/12 05:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27194) Whether to consider adding the configuration of ignore when data deserialization failed. - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2022/04/12 06:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27195) KafkaSourceReader offsetsToCommit should be mutable - posted by "Mason Chen (Jira)" <ji...@apache.org> on 2022/04/12 06:40:00 UTC, 0 replies.
- Contributing to FLINK-27195 - posted by Mason Chen <ma...@gmail.com> on 2022/04/12 06:42:13 UTC, 1 replies.
- [jira] [Created] (FLINK-27196) Remove old format interfaces - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/04/12 07:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27197) Port ArrowTableSource and PythonInputFormatTableSource to DynamicTableSource - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/04/12 07:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27198) Cleanup tests testing legacy TableSink/TableSource - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/04/12 07:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27199) Bump Pulsar to 2.10.0 for increasing the test stability - posted by "Yufan Sheng (Jira)" <ji...@apache.org> on 2022/04/12 07:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27200) Replace CollectionTableSource and CollectionTableSink with new table stack alternatives - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/04/12 07:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27201) Remove CollectTableSink - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/04/12 08:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27202) NullPointerException on stop-with-savepoint with AsyncWaitOperator followed by FlinkKafkaProducer - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2022/04/12 08:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27203) Add supports for uploading jars from object storage (s3, gcs, oss) - posted by "Xin Hao (Jira)" <ji...@apache.org> on 2022/04/12 09:38:00 UTC, 0 replies.
- Update regarding externalizing existing connectors and new connectors - posted by Martijn Visser <ma...@apache.org> on 2022/04/12 11:41:13 UTC, 1 replies.
- [jira] [Created] (FLINK-27204) FileSystemJobResultStore should operator on the ioExecutor - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/04/12 13:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27205) Translate "Concepts -> Glossary" page into Chinese - posted by "Zhuang Liu (Jira)" <ji...@apache.org> on 2022/04/12 13:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27206) Deprecate reflection-based reporter instantiation - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/12 14:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27207) Support built-in parquet format - posted by "Yubin Li (Jira)" <ji...@apache.org> on 2022/04/12 14:58:00 UTC, 0 replies.
- [VOTE] Release 1.15.0, release candidate #2 - posted by Yun Gao <yu...@aliyun.com.INVALID> on 2022/04/12 15:09:39 UTC, 4 replies.
- [jira] [Created] (FLINK-27208) Update the documentation to configure the IDE with scalafmt - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2022/04/12 15:16:00 UTC, 0 replies.
- [ANNOUNCE] New scalafmt formatter has been merged - posted by Francesco Guardiani <fr...@ververica.com> on 2022/04/12 15:21:04 UTC, 5 replies.
- [jira] [Created] (FLINK-27209) Half the Xmx and double the forkCount for unit tests - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2022/04/12 15:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27210) StateFun example link on datastream integration page is broken - posted by "Mans Singh (Jira)" <ji...@apache.org> on 2022/04/12 18:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27211) RBAC deployments/finalizers missing for OpenShift Deployment - posted by "James Busche (Jira)" <ji...@apache.org> on 2022/04/12 23:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27212) Failed to CAST('abcde', VARBINARY) - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/04/13 03:00:01 UTC, 0 replies.
- [jira] [Created] (FLINK-27213) Add PurgingTrigger - posted by "zhangjingcun (Jira)" <ji...@apache.org> on 2022/04/13 04:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27214) Build Failed on state backend benchmark - posted by "Yuan Mei (Jira)" <ji...@apache.org> on 2022/04/13 04:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27215) JDBC sink transiently deleted a record because of -u message of that record - posted by "tim yu (Jira)" <ji...@apache.org> on 2022/04/13 06:43:00 UTC, 0 replies.
- [DISCUSS] Roadmap update for 1.15 - posted by Johannes Moser <jo...@ververica.com> on 2022/04/13 07:05:52 UTC, 4 replies.
- [jira] [Created] (FLINK-27216) CheckpointCoordinatorTest.testMinCheckpointPause failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/04/13 07:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27217) Support partition filter push down when there exists default_parition - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/04/13 07:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27218) Serializer in OperatorState has not been updated when new Serializers are NOT incompatible - posted by "Yue Ma (Jira)" <ji...@apache.org> on 2022/04/13 07:12:00 UTC, 0 replies.
- Re: [DISCUSS] The abstraction of cache lookupFunction and cache metric - posted by Qingsheng Ren <re...@gmail.com> on 2022/04/13 08:20:01 UTC, 2 replies.
- OLM Bundle planned? - posted by Thoms Sven <sv...@inventx.ch> on 2022/04/13 08:38:28 UTC, 0 replies.
- [jira] [Created] (FLINK-27219) CliClientITCase.testSqlStatements failed on azure with jdk11 - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/04/13 09:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27220) Remove redundant null-check for int parameter. - posted by "da (Jira)" <ji...@apache.org> on 2022/04/13 09:18:00 UTC, 0 replies.
- [DISCUSS] FLIP-217 Support watermark alignment of source splits - posted by Sebastian Mattheis <se...@ververica.com> on 2022/04/13 09:27:24 UTC, 17 replies.
- [jira] [Created] (FLINK-27221) Improvements to YAML parsing - posted by "yao.zhou (Jira)" <ji...@apache.org> on 2022/04/13 10:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27222) Execution history limit can lead to eviction of critical local-recovery information - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/13 10:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27223) State access doesn't work as expected when cache size is set to 0 - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2022/04/13 10:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27224) Drop redundant flink.forkCountTestPackage property - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/13 11:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27225) Remove redundant reuseForks settings - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/13 12:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27226) How to implement two partition methods for an operator at the same time? - posted by "Underwood (Jira)" <ji...@apache.org> on 2022/04/13 12:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27227) ScalarFunctionsTest#testExtract fails with Extract operator does not support unit - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/04/13 12:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27228) Redistributed modules across CI profiles - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/13 13:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27229) Cassandra overrides netty version in tests - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2022/04/13 13:55:00 UTC, 0 replies.
- 回复：Re: [DISCUSS] FLIP-216 Decouple Hive connector with Flink planner - posted by "罗宇侠(莫辞)" <lu...@alibaba-inc.com.INVALID> on 2022/04/13 14:11:51 UTC, 0 replies.
- [jira] [Created] (FLINK-27230) Unnecessary entries in connector-kinesis NOTICE file - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2022/04/13 14:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27231) SQL pulsar connector lists dependencies under wrong license - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2022/04/13 14:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27232) .scalafmt.conf can - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/13 15:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27233) Unnecessary entries in connector-elasticsearch7 in NOTICE file - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2022/04/13 15:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27234) Enable fork-reuse for connector-jdbc - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/13 19:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27235) Publish Flink k8s Operator Helm Charts via Github Actions - posted by "Gezim Sejdiu (Jira)" <ji...@apache.org> on 2022/04/13 20:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27236) No task slot allocated for job in larege-scale job - posted by "yanpengshi (Jira)" <ji...@apache.org> on 2022/04/14 01:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27237) Partition table statement enhancement - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/04/14 02:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27238) The HiveGenericUDTF should support primitive array，for example Array Array ... - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2022/04/14 02:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27239) rewrite PreValidateReWriter from scala to java - posted by "xuyang (Jira)" <ji...@apache.org> on 2022/04/14 03:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27240) Support ADD PARTITION statement - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/04/14 03:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27241) Support DROP PARTITION statement - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/04/14 03:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27243) Support SHOW PARTITIONS statement for partitioned table - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/04/14 03:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27242) Support RENAME PARTITION statement for partitioned table - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/04/14 03:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27244) Support subdirectories with Hive tables - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/04/14 05:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27245) Flink job on Yarn cannot revover when zookeeper in Exception - posted by "hjw (Jira)" <ji...@apache.org> on 2022/04/14 07:25:00 UTC, 0 replies.
- Alertmanager Sink Connector - posted by Dhruv Patel <dh...@gmail.com> on 2022/04/14 07:27:27 UTC, 1 replies.
- [jira] [Created] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB - posted by "Maciej Bryński (Jira)" <ji...@apache.org> on 2022/04/14 07:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27247) when add numeric casting rules, some logics are lost - posted by "xuyang (Jira)" <ji...@apache.org> on 2022/04/14 08:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27248) can not call function collect_set() in hive module - posted by "macdoor615 (Jira)" <ji...@apache.org> on 2022/04/14 08:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27249) Change the state field in the FlinkSessionJob.Spec.Job into desiredState - posted by "Xin Hao (Jira)" <ji...@apache.org> on 2022/04/14 08:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27250) Remove custom surefire config from sql-parser[-hive] - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/14 13:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27251) Solve the problem that upstream Task cannot be switched to Unaligned Checkpoint - posted by "fanrui (Jira)" <ji...@apache.org> on 2022/04/14 14:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27252) Remove surefire fork options from connector-hive - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/14 15:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27253) Remove custom surefire config from connector-cassandra - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/14 15:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27254) Add Volume and VolumeMount supports for FlinkSessionJob - posted by "Xin Hao (Jira)" <ji...@apache.org> on 2022/04/14 18:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27255) Flink-avro does not support serialization and deserialization of avro schema longer than 65535 characters - posted by "Haizhou Zhao (Jira)" <ji...@apache.org> on 2022/04/15 00:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27256) Log the root exception in closing the task manager connection - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2022/04/15 02:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27257) Flink kubernetes operator triggers savepoint failed because of not all tasks running - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/04/15 02:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27258) Deployment Chinese document malformed text - posted by "FanJia (Jira)" <ji...@apache.org> on 2022/04/15 03:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27259) Observer should not clear savepoint errors even though deployment is healthy - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/04/15 03:39:00 UTC, 0 replies.
- [VOTE] Release 1.15.0, release candidate #3 - posted by Yun Gao <yu...@aliyun.com.INVALID> on 2022/04/15 04:56:03 UTC, 5 replies.
- [jira] [Created] (FLINK-27260) Expose changelog configuration in RestAPI and WebUI - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2022/04/15 06:50:00 UTC, 0 replies.
- Discussion about enhancing the partitioned table syntax - posted by 刘大龙 <ld...@zju.edu.cn> on 2022/04/15 07:07:29 UTC, 5 replies.
- [jira] [Created] (FLINK-27261) Disable web.cancel.enable for session jobs - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/04/15 07:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27262) Enrich validator for FlinkSesionJob - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/04/15 07:38:00 UTC, 0 replies.
- Re: [SPAM] Re: Re: Re: Re: Re: 回复：Re:[DISCUSS] FLIP-214 Support Advanced Function DDL - posted by 刘大龙 <ld...@zju.edu.cn> on 2022/04/15 08:35:55 UTC, 2 replies.
- [jira] [Created] (FLINK-27263) Rename the metadata column to the user specified name in DDL - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/04/15 11:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27264) Add ITCase for concurrent batch overwrite and streaming insert - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/04/15 11:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27265) The problem described by the filesystem.md and hive_write_read.mddocumentation - posted by "陈磊 (Jira)" <ji...@apache.org> on 2022/04/15 12:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27266) in hive_read_write.md, there is an extra backtick in the description - posted by "陈磊 (Jira)" <ji...@apache.org> on 2022/04/15 12:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27267) [JUnit5 Migration] Module: flink-contrib - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2022/04/16 01:16:00 UTC, 0 replies.
- Re: [DISCUSS] JUnit 5 Migration - posted by Mingliang Liu <li...@apache.org> on 2022/04/16 05:50:40 UTC, 0 replies.
- [jira] [Created] (FLINK-27268) build sql query error in JdbcDynamicTableSource - posted by "chouc (Jira)" <ji...@apache.org> on 2022/04/16 07:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27269) Clean up the jar file after submitting the job - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/04/16 12:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27270) Add document of session job operations - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/04/16 13:06:00 UTC, 0 replies.
- how to initialize few things at task managers - posted by Great Info <gu...@gmail.com> on 2022/04/16 15:44:12 UTC, 0 replies.
- [jira] [Created] (FLINK-27271) Add globalwindows window allocator - posted by "zhangjingcun (Jira)" <ji...@apache.org> on 2022/04/17 03:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27272) The plan for query with local sort is incorrect if adaptive batch scheduler is enabled - posted by "godfrey he (Jira)" <ji...@apache.org> on 2022/04/17 03:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27273) Support both configMap and zookeeper based HA data clean up - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/04/17 03:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27274) Job cannot be recovered, after restarting cluster - posted by "macdoor615 (Jira)" <ji...@apache.org> on 2022/04/17 07:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27275) Support null value not update in flink-connector-jdbc - posted by "Fangliang Liu (Jira)" <ji...@apache.org> on 2022/04/17 11:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27276) Translate "Data Types" page of "Table API & SQL" in to Chinese - posted by "Chengkai Yang (Jira)" <ji...@apache.org> on 2022/04/17 11:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27277) consist the naming style of SessionJob's state field - posted by "Xin Hao (Jira)" <ji...@apache.org> on 2022/04/17 15:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27278) Fix wrong indentation in doc dev/datastream/operators/windows.md - posted by "Mingliang Liu (Jira)" <ji...@apache.org> on 2022/04/17 18:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27279) Extract common status interfaces - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/04/18 06:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27280) Support rollback for session jobs. - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/04/18 06:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27281) Improve stability conditions for rollback logic - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/04/18 07:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27282) Fix the bug of wrong positions mapping in RowCoder - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/04/18 07:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27283) Add end to end tests for table store - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/04/18 07:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27284) KafkaSinkITCase$IntegrationTests.testScaleUp failed on azures due to failed to create topic - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/04/18 07:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27285) CassandraConnectorITCase failed on azure due to NoHostAvailableException - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/04/18 07:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27286) Fix table store connector throws ClassNotFoundException: org.apache.flink.table.store.shaded.org.apache.flink.connector.file.table.RowDataPartitionComputer - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/04/18 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27287) FileExecutionGraphInfoStoreTest unstable with "Could not start rest endpoint on any port in port range 8081" - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2022/04/18 08:53:00 UTC, 0 replies.
- [DISCUSS] FLIP-222: Support full query lifecycle statements in SQL client - posted by Paul Lam <pa...@gmail.com> on 2022/04/18 09:12:18 UTC, 6 replies.
- [jira] [Created] (FLINK-27288) flink operator crd is too long - posted by "kent (Jira)" <ji...@apache.org> on 2022/04/18 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27289) Do some optimizations for "FlinkService#stopSessionCluster" - posted by "liuzhuo (Jira)" <ji...@apache.org> on 2022/04/18 10:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27290) Translate the "Data Type" section of "Data Types" in to Chinese - posted by "Chengkai Yang (Jira)" <ji...@apache.org> on 2022/04/18 11:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27291) Translate the "List of Data Types" section of "Data Types" in to Chinese - posted by "Chengkai Yang (Jira)" <ji...@apache.org> on 2022/04/18 11:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27292) Translate the "Data Type Extraction" section of "Data Types" in to Chinese - posted by "Chengkai Yang (Jira)" <ji...@apache.org> on 2022/04/18 11:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27293) CVE-2020-36518 in flink-shaded jackson - posted by "Spencer Deehring (Jira)" <ji...@apache.org> on 2022/04/18 21:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27294) Add Transformer for EvalBinaryClass - posted by "weibo zhao (Jira)" <ji...@apache.org> on 2022/04/19 01:58:00 UTC, 0 replies.
- [DISCUSS] FLIP-221 Abstraction for lookup source cache and metric - posted by Qingsheng Ren <re...@gmail.com> on 2022/04/19 02:47:11 UTC, 5 replies.
- [jira] [Created] (FLINK-27295) UnalignedCheckpointITCase failed due to OperatorCoordinatorHolder cannot mark checkpoint - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2022/04/19 02:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27296) CalcOperator CodeGenException: Boolean expression type expected - posted by "tartarus (Jira)" <ji...@apache.org> on 2022/04/19 03:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27297) Add the StreamExecutionEnvironment#getExecutionEnvironment(Configuration) method in PyFlink - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/04/19 03:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27298) in sqlClient.md, table name inconsistency problem. - posted by "陈磊 (Jira)" <ji...@apache.org> on 2022/04/19 03:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27299) [BUG] Flink parsing parameter bug - posted by "Huajie Wang (Jira)" <ji...@apache.org> on 2022/04/19 03:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27300) Support scala case class for PulsarSchema - posted by "Ben Longo (Jira)" <ji...@apache.org> on 2022/04/19 04:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27301) KafkaSourceE2ECase#restartFromSavepoint is failed on Azure - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2022/04/19 07:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27302) Document regular CRD upgrade process - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/04/19 07:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27303) Flink Operator will create a large amount of temp log config files - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/04/19 07:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27304) Flink doesn't support Hive primitive type void yet - posted by "tartarus (Jira)" <ji...@apache.org> on 2022/04/19 07:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27305) Hive Dialect support implicit conversion - posted by "tartarus (Jira)" <ji...@apache.org> on 2022/04/19 07:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27306) Chinese translation for 1.15 roadmap update - posted by "Joe Moser (Jira)" <ji...@apache.org> on 2022/04/19 08:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27307) Flink table store support append-only ingestion without primary keys. - posted by "Zheng Hu (Jira)" <ji...@apache.org> on 2022/04/19 08:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27308) Update the Hadoop implementation for filesystems to 3.3.2 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/04/19 09:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27309) Allow to load default flink configs in the k8s operator dynamically - posted by "Biao Geng (Jira)" <ji...@apache.org> on 2022/04/19 09:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27310) FlinkOperatorITCase failure due to JobManager replicas less than one - posted by "Usamah Jassat (Jira)" <ji...@apache.org> on 2022/04/19 09:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27311) Rocksdb mapstate behaves unexpectedly - posted by "Jonathan diamant (Jira)" <ji...@apache.org> on 2022/04/19 10:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27312) Implicit casting should be introduced with Rules during planning - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2022/04/19 11:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27313) Flink Datadog reporter add custom and dynamic tags to custom metrics when job running - posted by "Huibo Peng (Jira)" <ji...@apache.org> on 2022/04/19 12:59:00 UTC, 0 replies.
- Re: Re: [DISCUSS] FLIP-216 Decouple Hive connector with Flink planner - posted by Jark Wu <im...@gmail.com> on 2022/04/19 15:29:50 UTC, 1 replies.
- [jira] [Created] (FLINK-27314) Enable active resource management (reactive scaling) in Flink Kubernetes Operator - posted by "Fuyao Li (Jira)" <ji...@apache.org> on 2022/04/19 20:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27315) Fix the demo of MemoryStateBackendMigration - posted by "Echo Lee (Jira)" <ji...@apache.org> on 2022/04/20 00:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27316) Prevent users from changing bucket number - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/04/20 07:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27317) Snapshot deployment fails due to .scalafmt.conf not being found - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/20 07:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27318) KafkaSink: when init transaction, it take too long to get a producerId with epoch=0 - posted by "Zhengqi Zhang (Jira)" <ji...@apache.org> on 2022/04/20 09:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27319) Duplicated "-t" option for savepoint format and deployment target - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2022/04/20 09:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27320) When using KafkaSink EXACTLY_ONCE semantics, frequent OutOfOrderSequenceException anomalies - posted by "Zhengqi Zhang (Jira)" <ji...@apache.org> on 2022/04/20 09:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27321) [JUnit5 Migration] Module: java-ci-tools - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/20 10:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27322) Add license headers and spotless checks for them - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2022/04/20 10:22:00 UTC, 0 replies.
- [VOTE] FLIP-214: Support Advanced Function DDL - posted by 刘大龙 <ld...@zju.edu.cn> on 2022/04/20 10:28:28 UTC, 8 replies.
- [jira] [Created] (FLINK-27323) [JUnit5 Migration] Module: flink-table-api-java - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/04/20 10:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27324) [JUnit5 Migration] Module: flink-rpc-akka-loader - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/20 10:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27325) Remove unnecessary forkCount settings - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/20 10:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27326) Remove LocalExecutor#createWithFactory - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/20 11:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27327) Add description about changing max parallelism explicitly leads to state incompatibility - posted by "Hangxiang Yu (Jira)" <ji...@apache.org> on 2022/04/20 12:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27328) Could not resolve ResourceManager address - posted by "Viswanath Shanmugam (Jira)" <ji...@apache.org> on 2022/04/20 13:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27329) Add default value of replica of JM pod and remove declaring it in example yamls - posted by "Biao Geng (Jira)" <ji...@apache.org> on 2022/04/20 14:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27330) Why Read File Stream Function Deprecated? - posted by "Karthik (Jira)" <ji...@apache.org> on 2022/04/20 14:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27331) Support Avro microsecond precision for TIME - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2022/04/20 15:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27332) org.apache.flink.streaming.api.functions.sink.filesystem.Bucket can't receive completion notification for savepoint - posted by "Darcy Lin (Jira)" <ji...@apache.org> on 2022/04/20 18:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27333) Upgrade flink-filesystems hadoop version to version 3.3.2 - posted by "Chinmay Sumant (Jira)" <ji...@apache.org> on 2022/04/20 19:47:00 UTC, 0 replies.
- Upgrade flink-filesystems hadoop version to version 3.3.2 - posted by Chinmay Sumant <cs...@apple.com.INVALID> on 2022/04/20 20:23:15 UTC, 2 replies.
- [VOTE] Release 1.15.0, release candidate #4 - posted by Yun Gao <yu...@aliyun.com.INVALID> on 2022/04/21 03:49:19 UTC, 14 replies.
- [jira] [Created] (FLINK-27334) Support auto generate the doc for the KubernetesOperatorConfigOptions - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/04/21 03:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27335) Optimize async compaction in MergeTreeWriter - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/04/21 04:12:00 UTC, 0 replies.
- [DISCUSS] FLIP-91: Support SQL Client Gateway - posted by Shengkai Fang <fs...@gmail.com> on 2022/04/21 06:42:30 UTC, 8 replies.
- [DISCUSS] FLIP-223: Support HiveServer2 Endpoint - posted by Shengkai Fang <fs...@gmail.com> on 2022/04/21 06:45:13 UTC, 7 replies.
- [jira] [Created] (FLINK-27336) Avoid merging when there is only one record - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/04/21 07:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27337) Prevent session cluster to be deleted when there are running jobs - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/04/21 07:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27338) Improve spliting file for Hive soure - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/04/21 07:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27339) Some classes don't have a package - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/21 09:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27340) [JUnit5 Migration] Module: flink-python - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/04/21 11:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27341) TaskManager running together with JobManager are bind to 127.0.0.1 - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/04/21 13:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27342) Link to Apache privacy policy - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/21 14:20:00 UTC, 0 replies.
- [DISCUSS] Docker images for SNAPSHOT - posted by Alexander Fedulov <al...@ververica.com> on 2022/04/21 18:22:44 UTC, 5 replies.
- Issue while running word_count.py - posted by Rohith Vallu <vr...@gmail.com> on 2022/04/21 22:20:28 UTC, 1 replies.
- [jira] [Created] (FLINK-27343) flink jdbc sink with default param will lead buffer records in one batch unorder - posted by "pengyusong (Jira)" <ji...@apache.org> on 2022/04/22 01:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27344) FLIP-222: Support full query lifecycle statements in SQL client - posted by "Paul Lin (Jira)" <ji...@apache.org> on 2022/04/22 02:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27345) operator does not update related resource when flinkConfiguration, logConfiguration are updated. - posted by "ChangZhuo Chen (陳昌倬) (Jira)" <ji...@apache.org> on 2022/04/22 02:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27347) Create flink-table-store-hive module - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/04/22 02:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27346) [umbrella] Introduce Hive reader for table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/04/22 02:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27348) Flink KafkaSource doesn't set groupId - posted by "Ahmet Gürbüz (Jira)" <ji...@apache.org> on 2022/04/22 02:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27349) The timeout of some methods such as JobMaster#requestJobXXX(Time timeout) does not take effect - posted by "Echo Lee (Jira)" <ji...@apache.org> on 2022/04/22 02:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27350) JobManager doesn't bring up new TaskManager during failure recovery - posted by "Chenyu Zheng (Jira)" <ji...@apache.org> on 2022/04/22 04:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27351) TaskExecutorBuilder configures unreasonable amount of memory - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/22 07:26:00 UTC, 0 replies.
- [DISCUSS] Maintain a Calcite repository for Flink to accelerate the development for Flink SQL features - posted by godfrey he <go...@gmail.com> on 2022/04/22 07:31:33 UTC, 16 replies.
- [jira] [Created] (FLINK-27352) [JUnit5 Migration] Module: flink-json - posted by "EMing Zhou (Jira)" <ji...@apache.org> on 2022/04/22 08:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27353) Update training exercises to use Flink 1.15 - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2022/04/22 09:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27354) JobMaster still processes requests while terminating - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/04/22 10:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27355) JobManagerRunnerRegistry.localCleanupAsync does not call the JobManagerRunner.close method repeatedly - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/04/22 11:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27356) Incorrect Number of Methods Listed for SplitReader - posted by "Austin Cawley-Edwards (Jira)" <ji...@apache.org> on 2022/04/22 19:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27357) In Flink HA Service, Web UI External Service should update with new elected Job Manager leader's IP - posted by "Jesus H Christ (Jira)" <ji...@apache.org> on 2022/04/22 22:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27358) Kubernetes operator throws NPE when testing with Flink 1.15 - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/04/23 04:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27359) Kubernetes operator throws NPE when testing with Flink 1.15 - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/04/23 04:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27360) Rename clusterId field of FlinkSessionJobSpec to deploymentName - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/04/23 18:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27361) Introduce retry mechanism for SnapshotFinder - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/04/24 03:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27362) Support restartNonce semantics in session job - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/04/24 06:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27363) Support EXCHANGE PARTITION statement for partitioned table - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/04/24 07:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27364) Support DESC EXTENDED partition statement for partitioned table - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/04/24 07:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27365) [umbrella] Schema evolution on table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/04/24 09:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27366) Record metadata on filesystem path - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/04/24 09:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27367) CAST between INT and DATE is broken - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2022/04/24 10:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27368) CAST(' 1 ' as BIGINT) reutrns wrong result - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2022/04/24 11:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27369) COALESCE('1', CAST(NULL as varchar)) throws expression type mismatch - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2022/04/24 12:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27370) Add a new SessionJobState - Failed - posted by "Xin Hao (Jira)" <ji...@apache.org> on 2022/04/24 14:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27371) Record schema id in snapshot and manifestFileMeta and SstFileMeta - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/04/25 02:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27372) Make SstFileMeta and ManifestFileMeta schemaless - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/04/25 02:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27373) Disable installing PyFlink using `python setup.py install` - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2022/04/25 03:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27374) Convert Hive's void type to Flink's string type - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/04/25 03:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27375) Hive dialect support "over() without order keys inside" - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/04/25 04:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27376) Hive dialect supports "select current_database()" - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/04/25 04:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27377) Job manager blocks on marking vertex finished - posted by "Yi Tang (Jira)" <ji...@apache.org> on 2022/04/25 04:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27378) Unexpected rexnode : org.apache.calcite.rex.RexFieldAccess - posted by "tartarus (Jira)" <ji...@apache.org> on 2022/04/25 06:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27379) CodeGenException: Unable to find common type of - posted by "tartarus (Jira)" <ji...@apache.org> on 2022/04/25 06:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27380) Failed to get Hive result type from org.apache.hadoop.hive.ql.udf.generic.GenericUDAFPercentileApprox - posted by "tartarus (Jira)" <ji...@apache.org> on 2022/04/25 06:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27381) HybridSource split should use Arrays.hashcode - posted by "Ran Tao (Jira)" <ji...@apache.org> on 2022/04/25 07:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27382) Make Job mode wait with cluster shutdown until the cleanup is done - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/04/25 07:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27383) Make Application mode wait with cluster shutdown until cleanup is done - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/04/25 07:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27384) In the Hive dimension table, when the data is changed on the original partition, the create_time configuration does not take effect - posted by "陈磊 (Jira)" <ji...@apache.org> on 2022/04/25 07:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27385) Field #1: values VARCHAR(2147483647) ARRAY does not exist for expression index($0, 0) - posted by "tartarus (Jira)" <ji...@apache.org> on 2022/04/25 08:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27386) throw NPE if multi MAPJOIN hint union all - posted by "tartarus (Jira)" <ji...@apache.org> on 2022/04/25 08:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27387) Support Insert Multi-Table - posted by "tartarus (Jira)" <ji...@apache.org> on 2022/04/25 08:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27388) PulsarSourceEnumeratorTest#discoverPartitionsTriggersAssignments seems flaky - posted by "Sebastian Mattheis (Jira)" <ji...@apache.org> on 2022/04/25 09:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27389) Move test utils from flink-test to flink-test-utils - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/25 10:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27390) Remove unused flink-tests dependencies - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/25 10:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27391) Support Hive bucket table - posted by "tartarus (Jira)" <ji...@apache.org> on 2022/04/25 10:19:00 UTC, 0 replies.
- [DISCUSS] FLIP-223: Implement standalone mode support in the kubernetes operator - posted by "Jassat, Usamah" <us...@amazon.co.uk.INVALID> on 2022/04/25 10:25:11 UTC, 3 replies.
- [jira] [Created] (FLINK-27392) CEP Pattern supports definition of the maximum time gap between events - posted by "Nicholas Jiang (Jira)" <ji...@apache.org> on 2022/04/25 10:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27393) Move Elasticsearch documentation from Flink repository to the Flink Elasticsearch connector repository - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/04/25 10:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27394) Integrate the Flink Elasticsearch documentation in the Flink documentation - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/04/25 11:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27395) IllegalStateException: Could not find policy 'pick_first'. on Flink Application - posted by "Natan HP (Jira)" <ji...@apache.org> on 2022/04/25 11:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27396) Reduce the Heartbeat timeout after zookeeper suspended - posted by "fanrui (Jira)" <ji...@apache.org> on 2022/04/25 14:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27397) Improve the CrdReferenceDoclet generator to handle the abstract class - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/04/25 15:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27398) Move completeness test to flink-scala - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/25 15:49:00 UTC, 0 replies.
- [DISCUSS] Next Flink Kubernetes Operator release timeline - posted by Gyula Fóra <gy...@apache.org> on 2022/04/25 18:22:08 UTC, 6 replies.
- [jira] [Created] (FLINK-27399) Pulsar connector didn't set start consuming position correctly - posted by "Yufan Sheng (Jira)" <ji...@apache.org> on 2022/04/25 22:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27400) Pulsar connector subscribed the system topic when using the regex - posted by "Yufan Sheng (Jira)" <ji...@apache.org> on 2022/04/25 22:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27401) CEP supports AggregateFunction in IterativeCondition - posted by "Nicholas Jiang (Jira)" <ji...@apache.org> on 2022/04/26 01:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27402) Unexpected boolean expression simplification for AND expression - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/04/26 02:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27403) Align existing feature engineering algorithms in ML Python API - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/04/26 02:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27404) Add algorithms completeness test in ML Python API - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/04/26 03:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27405) Refactor SourceCoordinator to abstract BaseCoordinator implementation - posted by "gang ye (Jira)" <ji...@apache.org> on 2022/04/26 04:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27406) After canceling the job, it is falsely reported as a job failure. - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2022/04/26 04:17:00 UTC, 0 replies.
- [RESULT] [VOTE] Release 1.15.0, release candidate #4 - posted by Yun Gao <yu...@aliyun.com.INVALID> on 2022/04/26 04:17:02 UTC, 0 replies.
- [jira] [Created] (FLINK-27407) Exception of "unable to find common type of Boolean and Char(4)" will be thrown when RexSarg contains "Boolean" and "Char(4)" - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/04/26 04:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27408) Package Flink runtime dependencies into associated table store modules instead of flink-table-store-dist - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/04/26 04:43:00 UTC, 0 replies.
- [DISCUSS] More public interfaces for internal data structures - posted by Jingsong Li <ji...@gmail.com> on 2022/04/26 06:02:40 UTC, 1 replies.
- [jira] [Created] (FLINK-27409) Cleanup stale slot allocation record when the resource requirement of a job is empty - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2022/04/26 06:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27410) Create ArchUnit rules for Public API dependencies - posted by "Alexander Preuss (Jira)" <ji...@apache.org> on 2022/04/26 06:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27411) Move lookup table source cache logic to flink-table-runtime module - posted by "Alexander Smirnov (Jira)" <ji...@apache.org> on 2022/04/26 08:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27412) Allow flinkVersion v1_13 in flink-kubernetes-operator - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/04/26 08:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27413) Drop scala 2.11 support from the flink-docker - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/04/26 09:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27414) Support operator state in PyFlink DataStream API - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2022/04/26 10:00:00 UTC, 0 replies.
- [DISCUSS] Planning Flink 1.16 - posted by Konstantin Knauf <kn...@apache.org> on 2022/04/26 10:23:28 UTC, 12 replies.
- [jira] [Created] (FLINK-27415) Read empty csv file throws exception in FileSystem table connector - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/04/26 10:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27416) FLIP-225: Implement standalone mode support in the kubernetes operator - posted by "Usamah Jassat (Jira)" <ji...@apache.org> on 2022/04/26 12:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27417) Flink JDBC SQL Connector：SELECT * FROM table WHERE co > 100; mysql will execute SELECT * FROM table to scan the whole table - posted by "haojiawei (Jira)" <ji...@apache.org> on 2022/04/26 13:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27418) Flink SQL TopN result is wrong - posted by "zhangbin (Jira)" <ji...@apache.org> on 2022/04/26 14:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27419) Endpoint to cancel savepoints - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2022/04/26 14:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27420) Suspended SlotManagers fail to reregister metrics when started again - posted by "Ben Augarten (Jira)" <ji...@apache.org> on 2022/04/26 20:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27421) Bundle test utility classes into the PyFlink package to make users write test cases easily - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2022/04/27 01:13:00 UTC, 0 replies.
- [DISCUSS] FLIP-224: Blacklist Mechanism - posted by Lijie Wang <wa...@gmail.com> on 2022/04/27 02:04:14 UTC, 3 replies.
- Re: [DISCUSS] FLIP-168: Speculative execution for Batch Job - posted by Zhu Zhu <zh...@apache.org> on 2022/04/27 02:46:06 UTC, 4 replies.
- [jira] [Created] (FLINK-27422) Do not create temporary pod template files for JobManager and TaskManager if not configured explicitly - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/04/27 03:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27423) Upgrade Hive 3.1 connector from 3.1.2 to 3.1.3 - posted by "Jeff Yang (Jira)" <ji...@apache.org> on 2022/04/27 04:49:00 UTC, 0 replies.
- [DISCUSS] FLIP-227: Support overdraft buffer - posted by rui fan <19...@gmail.com> on 2022/04/27 05:46:51 UTC, 9 replies.
- [jira] [Created] (FLINK-27424) StreamExecutionEnvironment.readFile() api monitor file directory errors - posted by "zhangqw152 (Jira)" <ji...@apache.org> on 2022/04/27 06:28:00 UTC, 0 replies.
- Add a init-file option into FLIP-91 - posted by LuNing Wang <wa...@gmail.com> on 2022/04/27 09:22:40 UTC, 1 replies.
- [jira] [Created] (FLINK-27425) Default job service account needs access to services to work with Kafka - posted by "Mark Nuttall (Jira)" <ji...@apache.org> on 2022/04/27 09:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27426) Replace Time with Duration in RPC system internals - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/27 10:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27427) Remove timeouts from RpcUtils#terminate* - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/27 10:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27428) Deduplicate #toDuration(Time) - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/27 11:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27429) Implement Vertica JDBC Dialect - posted by "Jasmin Redzepovic (Jira)" <ji...@apache.org> on 2022/04/27 12:44:00 UTC, 0 replies.
- [VOTE] FLIP-216: Introduce pluggable dialect and plan for migrating Hive dialect - posted by yuxia <lu...@alumni.sjtu.edu.cn> on 2022/04/27 13:14:35 UTC, 6 replies.
- [jira] [Created] (FLINK-27430) Remove unused MockResourceManagerRuntimeServices#timeout - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/27 15:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27431) Allow Duration for RpcTimeouts - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/27 16:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27432) Replace Time with Duration in TaskSlotTable - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/27 17:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27433) E2E log artifacts contain several thousand rocksdb logs - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/27 17:34:00 UTC, 0 replies.
- Latest Keynotes and sessions confirmed - posted by Carolina Escobar <ca...@sg.com.mx> on 2022/04/27 17:42:59 UTC, 0 replies.
- [jira] [Created] (FLINK-27434) How to get CatalogManager.schemaResolver from Catalog.alterTable interface？ - posted by "wuwenchi (Jira)" <ji...@apache.org> on 2022/04/28 02:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27435) Kubernetes Operator keeps savepoint history - posted by "Thomas Weise (Jira)" <ji...@apache.org> on 2022/04/28 03:36:00 UTC, 0 replies.
- [DISCUSS] DockerHub repository maintainers - posted by Xintong Song <to...@gmail.com> on 2022/04/28 05:39:09 UTC, 5 replies.
- [VOTE] Apache Flink Table Store 0.1.0, release candidate #1 - posted by Jingsong Li <ji...@gmail.com> on 2022/04/28 06:50:30 UTC, 2 replies.
- [jira] [Created] (FLINK-27436) option `properties.group.id` is not effective in kafka connector for finksql - posted by "Spongebob (Jira)" <ji...@apache.org> on 2022/04/28 07:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27437) Syntax error when running tpcds test - posted by "Yao Zhang (Jira)" <ji...@apache.org> on 2022/04/28 07:31:00 UTC, 0 replies.
- [DISCUSS] FLIP-218: Support SELECT clause in CREATE TABLE(CTAS) - posted by Mang Zhang <zh...@163.com> on 2022/04/28 08:57:24 UTC, 1 replies.
- [jira] [Created] (FLINK-27438) SQL validation failed when constructing a map array - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2022/04/28 09:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27439) Fix ClassNotFoundException when using array type in table store - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/04/28 09:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27440) adds ignore-parse-errors configuration in avro format - posted by "陈磊 (Jira)" <ji...@apache.org> on 2022/04/28 10:55:00 UTC, 0 replies.
- [DISCUSS] Keep the Community Member Information Up-to-Date - posted by Xintong Song <to...@gmail.com> on 2022/04/28 11:58:25 UTC, 5 replies.
- [jira] [Created] (FLINK-27441) Scrollbar is missing for particular UI elements (Accumulators, Backpressure, Watermarks) - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2022/04/28 13:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27442) Module flink-sql-avro-confluent-registry does not configure Confluent repo - posted by "Nicolaus Weidner (Jira)" <ji...@apache.org> on 2022/04/28 14:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27443) Add standalone mode parameters and decorators - posted by "Usamah Jassat (Jira)" <ji...@apache.org> on 2022/04/28 15:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27444) Create standalone mode ClusterDescriptor - posted by "Usamah Jassat (Jira)" <ji...@apache.org> on 2022/04/28 15:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27445) Create Flink Standalone Service - posted by "Usamah Jassat (Jira)" <ji...@apache.org> on 2022/04/28 15:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27446) Introduce Standalone Mode - posted by "Usamah Jassat (Jira)" <ji...@apache.org> on 2022/04/28 15:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27447) Implement last-state with ZooKeeper HA - posted by "Usamah Jassat (Jira)" <ji...@apache.org> on 2022/04/28 15:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27448) Enable standalone mode for old Flink versions - posted by "Usamah Jassat (Jira)" <ji...@apache.org> on 2022/04/28 15:30:00 UTC, 0 replies.
- Failed Unit Test on Master Branch - posted by Haizhou Zhao <zh...@gmail.com> on 2022/04/28 21:38:33 UTC, 1 replies.
- [jira] [Created] (FLINK-27449) The comment is lost when printing table schema - posted by "Yuan Huang (Jira)" <ji...@apache.org> on 2022/04/29 01:23:00 UTC, 0 replies.
- [VOTE] Apache Flink Table Store 0.1.0, release candidate #2 - posted by Jingsong Li <ji...@gmail.com> on 2022/04/29 02:24:09 UTC, 3 replies.
- [jira] [Created] (FLINK-27450) [JDK 11] Hive SessionState can't be initialized due to classloader problem - posted by "tartarus (Jira)" <ji...@apache.org> on 2022/04/29 06:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27451) Enable the validator plugin in webhook - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/04/29 08:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27452) Move Te - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/29 09:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27453) Cleanup TestBaseUtils - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/29 09:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27454) Remove inheritance from TestBaseUtils - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/29 09:40:00 UTC, 0 replies.
- [DISCUSS] FLIP-226: Introduce Schema Evolution on Table Store - posted by Jingsong Li <ji...@gmail.com> on 2022/04/29 09:54:20 UTC, 0 replies.
- [jira] [Created] (FLINK-27455) [JUnit5 Migration] SnapshotMigrationTestBase - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/29 10:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27456) mistake and confusion with CEP example in docs - posted by "David Anderson (Jira)" <ji...@apache.org> on 2022/04/29 10:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27457) CassandraOutputFormats should support flush - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2022/04/29 15:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27458) Expose allowNonRestoredState flag in JobSpec - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/04/29 15:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27459) JsonJobGraphGenerationTest doesn't reset context environment - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/04/29 17:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27460) Remove unused notifyPartitionDataAvailable process - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2022/04/30 08:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-27461) Add a convenient way to set userAgent for the kubeclient - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/04/30 13:30:00 UTC, 0 replies.