You are viewing a plain text version of this content. The canonical link for it is here.
- [jira] [Created] (FLINK-25901) Investigate why hostname might be resolved to different ips on azure pipeline - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/01 05:30:00 UTC, 0 replies.
- MetricRegistryTestUtils java class (flink-runtime/metrics) not found in source code version 1.14.3 - posted by Prasanna kumar <pr...@gmail.com> on 2022/02/01 06:28:48 UTC, 3 replies.
- [jira] [Created] (FLINK-25902) NullPointerException in RescalingITCase.testSavepointRescalingOutKeyedState - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/02/01 08:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25903) Heartbeat timeout in BoundedSourceITCase.test[complex graph] - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/02/01 08:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25904) NullArgumentException in case of increasing number of nodes for the job - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/02/01 09:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25905) Promoting Experimental methods is marked as a violation - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/02/01 09:12:00 UTC, 0 replies.
- Re: [VOTE] Deprecate Per-Job Mode in Flink 1.15 - posted by Konstantin Knauf <kn...@apache.org> on 2022/02/01 09:27:17 UTC, 3 replies.
- [ANNOUNCE] Apache Flink Stateful Functions 3.2.0 released - posted by Till Rohrmann <tr...@apache.org> on 2022/02/01 11:23:17 UTC, 1 replies.
- Re: [VOTE] FLIP-211: Kerberos delegation token framework - posted by David Morávek <dm...@apache.org> on 2022/02/01 11:45:44 UTC, 1 replies.
- Re: [DISCUSS] Releasing Flink 1.13.6 - posted by Martijn Visser <ma...@ververica.com> on 2022/02/01 12:26:35 UTC, 1 replies.
- Re: JDBC: Support connection pooling - posted by Martijn Visser <ma...@ververica.com> on 2022/02/01 12:33:07 UTC, 0 replies.
- [jira] [Created] (FLINK-25906) Remove the ExecutionEnvironment dependency in LocalStreamEnvironment - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/02/01 12:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25907) Add pluggable delegation token manager - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/02/01 12:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25908) Move Hadoop FS token obtain functionality into HadoopFSDelegationTokenProvider - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/02/01 12:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25909) Move HBase token obtain functionality into HBaseDelegationTokenProvider - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/02/01 12:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25910) Propagate obtained delegation tokens to TaskManagers - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/02/01 12:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25911) Add delegation token framework documentation - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/02/01 13:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25912) HashMapStateBackend performance regression on 31.01.2022 - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2022/02/01 13:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25913) Disable japicmp binary compatibility check - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/02/01 14:25:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-212: Introduce Flink Kubernetes Operator - posted by Márton Balassi <ba...@gmail.com> on 2022/02/01 14:26:18 UTC, 35 replies.
- [jira] [Created] (FLINK-25914) Performance regression in checkpointSingleInput.UNALIGNED on 31.01.2022 - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2022/02/01 15:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25915) Implement Matomo on Statefun website - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/02/01 18:26:00 UTC, 0 replies.
- Re: [DISCUSS] Looking for maintainers for Cassandra connector or decide to remove connector - posted by Martijn Visser <ma...@ververica.com> on 2022/02/01 20:07:32 UTC, 2 replies.
- Re: Need help with finding inner workings of watermark stream idleness - posted by Jeff Carter <jp...@gmail.com> on 2022/02/01 20:34:30 UTC, 2 replies.
- [jira] [Created] (FLINK-25916) Using upsert-kafka with a flush buffer results in Null Pointer Exception - posted by "Corey Shaw (Jira)" <ji...@apache.org> on 2022/02/01 21:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25917) Share RpcSystem aross tests - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/02/02 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25918) Use FileEnumerator to implement filter pushdown of filepath metadata - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/02/02 08:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25919) Sink V2 improvements and followups - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2022/02/02 09:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25920) Allow receiving updates of CommittableSummary - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2022/02/02 09:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25921) Support different input parallelism for preCommit topology - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2022/02/02 09:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25922) KinesisFirehoseSinkITCase hangs on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/02/02 10:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25923) Add tests for native savepoint format schema evolution - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2022/02/02 11:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25924) KDF Integration tests intermittently fails - posted by "Zichen Liu (Jira)" <ji...@apache.org> on 2022/02/02 11:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25925) JobMasterTest.testJobMasterAcceptsExcessSlotsWhenJobIsRestarting - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/02/02 11:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25926) Update org.postgresql:postgresql to 42.3.2 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/02/02 12:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25927) Make flink-connector-base dependency usage consistent across all connectors. - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2022/02/02 14:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25928) Refactor timestamp<->number validation messages - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2022/02/02 14:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25929) Jepsen tests don't work with Zookeeper 3.4 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/02/02 14:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25930) Remove identity casting from ScalarOperatorGens - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2022/02/02 14:49:00 UTC, 0 replies.
- Off for a week starting Friday - posted by Etienne Chauchot <ec...@apache.org> on 2022/02/02 14:55:25 UTC, 2 replies.
- [jira] [Created] (FLINK-25931) Add projection pushdown support for CsvFormatFactory - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2022/02/02 16:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25932) Introduce ExecNodeContext.generateUid() - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2022/02/02 17:18:00 UTC, 0 replies.
- Statefun async http request via RequestReplyFunctionBuilder - posted by Galen Warren <ga...@cvillewarrens.com> on 2022/02/02 17:30:22 UTC, 7 replies.
- [jira] [Created] (FLINK-25933) Allow configuring different transports in RequestReplyFunctionBuilder - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2022/02/02 19:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25934) Modernize statefun playground examples - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2022/02/02 19:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25935) Add a harness based entry point to simply getting started. - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2022/02/02 20:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25936) MutableTypeCell is not setting correctly the value's type_name - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2022/02/02 20:49:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-211: Kerberos delegation token framework - posted by Chesnay Schepler <ch...@apache.org> on 2022/02/03 08:17:31 UTC, 25 replies.
- [jira] [Created] (FLINK-25937) SQL Client end-to-end test e2e fails on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/02/03 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25938) SynchronousCheckpointITCase.taskDispatcherThreadPoolAllowsForSynchronousCheckpoints fails on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/02/03 09:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25939) PyFlink YARN per-job on Docker test fails on AZP because it could not acquire all required slots - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/02/03 09:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25940) pyflink/datastream/tests/test_data_stream.py::StreamingModeDataStreamTests::test_keyed_process_function_with_state failed on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/02/03 09:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25941) KafkaSinkITCase.testAbortTransactionsAfterScaleInBeforeFirstCheckpoint fails on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/02/03 09:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25943) New Kinesis, Firehose to provide a state serializer - posted by "Zichen Liu (Jira)" <ji...@apache.org> on 2022/02/03 10:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25942) Use jackson jdk8/time modules for Duration ser/de - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/02/03 10:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25944) Intermittent Failures on KDF AZP - posted by "Zichen Liu (Jira)" <ji...@apache.org> on 2022/02/03 10:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25945) Intermittent Failures on KDF AZP 2 - posted by "Zichen Liu (Jira)" <ji...@apache.org> on 2022/02/03 10:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25946) table-planner-loader jar NOTICE should list Scala - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/02/03 10:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25947) License checker doesn't flink-table-planner - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/02/03 10:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25948) KDS / KDF Sink should call .close() to clean up resources - posted by "Zichen Liu (Jira)" <ji...@apache.org> on 2022/02/03 12:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25949) [FLIP-171] Kinesis Firehose sink builder falls back to wrong http protocol. - posted by "Ahmed Hamdy (Jira)" <ji...@apache.org> on 2022/02/03 12:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25950) Delete retry mechanism from ZooKeeperUtils.deleteZNode - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/02/03 14:09:00 UTC, 0 replies.
- Re: [DISCUSS] Move Flink website to privacy friendly Analytics solution - posted by Martijn Visser <ma...@ververica.com> on 2022/02/03 14:13:30 UTC, 2 replies.
- [jira] [Created] (FLINK-25951) Implement Matomo on JavaDocs - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/02/03 14:15:00 UTC, 0 replies.
- Re: [VOTE] Deprecate NiFi connector - posted by Fabian Paul <fp...@apache.org> on 2022/02/03 14:37:31 UTC, 4 replies.
- Re: [VOTE] Remove Twitter connector - posted by Ingo Bürk <ai...@apache.org> on 2022/02/03 14:38:33 UTC, 4 replies.
- [jira] [Created] (FLINK-25952) Savepoint on S3 are not relocatable even if entropy injection is not enabled - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2022/02/03 16:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25953) Reorganizes tests around Dispatcher cleanup - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/02/04 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25954) Add cleanup tests to BlobServerCleanupTest - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/02/04 08:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25955) Add JobManagerRunner implementation that picks up dirty job results to be cleaned up - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/02/04 08:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25956) KryoSerializer is noisy in scala-free Flink - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/02/04 08:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25957) Cache cassandra/pulsar images - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/02/04 09:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25958) OOME Checkpoints & Savepoints were shown as COMPLETE in Flink UI - posted by "Victor Xu (Jira)" <ji...@apache.org> on 2022/02/04 10:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25959) Add a micro-benchmark for the sort-based blocking shuffle - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2022/02/04 11:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25960) Distribute the data read buffers more fairly among result partitions for sort-shuffle - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2022/02/04 11:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25961) Remove transport client from Elasticsearch 6/7 connectors (tests only) - posted by "Andriy Redko (Jira)" <ji...@apache.org> on 2022/02/04 15:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25962) Flink generated Avro schemas can't be parsed using Python - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2022/02/04 17:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25963) FLIP-212: Introduce Flink Kubernetes Operator - posted by "Thomas Weise (Jira)" <ji...@apache.org> on 2022/02/04 23:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25964) Support shipping extra local files/jars to job/task manager classpaths - posted by "Chenya Zhang (Jira)" <ji...@apache.org> on 2022/02/04 23:51:00 UTC, 0 replies.
- [VOTE] FLIP-212: Introduce Flink Kubernetes Operator - posted by Thomas Weise <th...@apache.org> on 2022/02/05 02:00:03 UTC, 13 replies.
- [VOTE] Release 1.13.6, release candidate #1 - posted by Konstantin Knauf <kn...@apache.org> on 2022/02/05 20:06:19 UTC, 4 replies.
- [jira] [Created] (FLINK-25965) Add a Couchbase sink - posted by "Nir Tsruya (Jira)" <ji...@apache.org> on 2022/02/06 21:08:00 UTC, 0 replies.
- [DISCUSS] Checkpointing (partially) failing jobs - posted by Gyula Fóra <gy...@apache.org> on 2022/02/06 21:22:40 UTC, 15 replies.
- [jira] [Created] (FLINK-25966) KafkaSourceITCase failed on azure due to Create test topic : topic1 failed - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/07 07:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25967) StreamingModeDataStreamTests.test_keyed_process_function_with_state failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/07 07:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25968) Possible class leaks in flink-table / sql modules - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/07 08:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25969) org.apache.flink.table.runtime.generated.CompileUtils might cause class leaks - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/07 08:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25970) SerializedThrowable should record type of the original throwable. - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2022/02/07 08:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25971) org.apache.flink.table.planner.plan.nodes.exec.serde.JsonSerdeUtil#OBJECT_MAPPER_INSTANCE might cause class leaks - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/07 08:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25972) org.apache.calcite.rel.metadata.JaninoRelMetadataProvider#HANDLERS might cause class leaks - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/07 08:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25973) Rename ArchivedExecutionGraph.createFromInitializingJob into more generic createSparseArchivedExecutionGraph - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/02/07 09:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25974) Make cancellation of jobs depend on the JobResultStore - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/02/07 10:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25975) add doc for how to use AvroParquetRecordFormat - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/02/07 11:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25976) Update the KDS and KDF Sink's defaults & update the docs - posted by "Zichen Liu (Jira)" <ji...@apache.org> on 2022/02/07 11:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25977) Close sink client and sink http client for KDS/KDF Sinks - posted by "Zichen Liu (Jira)" <ji...@apache.org> on 2022/02/07 11:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25978) DispatcherTest.testJobDataAreCleanedUpInCorrectOrderOn*Job can be removed - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/02/07 12:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25979) Suspicious Classloading error during close of KafkaEnumerator - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/02/07 12:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25980) remove unnecessary condition in IntervalJoinOperator - posted by "hongshu (Jira)" <ji...@apache.org> on 2022/02/07 13:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25981) ZooKeeperMultipleComponentLeaderElectionDriverTest failed - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/02/07 13:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25982) Support idleness with watermark alignment - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2022/02/07 13:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25983) Add WatermarkStrategy#withWatermarkAlignment - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2022/02/07 13:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25984) Add types to ConfigOptions and replace usages of the untyped methods defaultValue and noDefaultValue with the corresponding typed ones. - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2022/02/07 13:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25985) e2e test covering the main functionality of the JobResultStore - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/02/07 14:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25986) Add FLIP-190 new API methods to python - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/02/07 15:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25987) IllegalArgumentException thrown from FsStateChangelogWriter.truncate - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/02/07 15:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25988) UnalignedCheckpointRescaleITCase failed with exit code 137 - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/07 15:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25989) EventTimeWindowCheckpointingITCase failed with exit code 137 - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/07 16:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25990) Expose uid generator for DataStream/Transformation providers - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2022/02/07 17:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25991) Allow custom metadata to be committed alongside the offsets - posted by "Frederic Hemery (Jira)" <ji...@apache.org> on 2022/02/07 19:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25992) JobDispatcherITCase..testRecoverFromCheckpointAfterLosingAndRegainingLeadership fails on azure - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/02/07 20:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25993) Option to disable Kryo.setRegistrationRequired(false) - posted by "Shane Bishop (Jira)" <ji...@apache.org> on 2022/02/07 22:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25994) Implement FileStoreExpire - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/02/08 02:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25995) Make implicit assumption of SQL local keyBy/groupBy explicit - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2022/02/08 03:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25996) Introduce job property isDynamicGraph to ExecutionConfig - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2022/02/08 03:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25997) FsStateChangelogWriter cannot work well when there is no change appended - posted by "Hangxiang Yu (Jira)" <ji...@apache.org> on 2022/02/08 05:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25998) Flink akka runs into NoClassDefFoundError on shutdown - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2022/02/08 07:12:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-211: Kerberos delegation token framework - posted by Gabor Somogyi <ga...@gmail.com> on 2022/02/08 07:33:16 UTC, 2 replies.
- [jira] [Created] (FLINK-26000) Drop Per-Job Mode - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2022/02/08 08:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25999) Deprecate Per-Job Mode - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2022/02/08 08:16:00 UTC, 0 replies.
- [RESULT] [VOTE] Deprecate Per-Job Mode - posted by Konstantin Knauf <kn...@apache.org> on 2022/02/08 08:23:28 UTC, 0 replies.
- [jira] [Created] (FLINK-26001) Implement ProjectableDecodingFormat for avro bulk format - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/02/08 08:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26002) Add test coverage for native format job upgrades - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2022/02/08 08:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26003) Use Jackson serialization for persisting TaskExecutor state to working directory - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/02/08 09:11:00 UTC, 0 replies.
- 来自高大余的邮件 - posted by 高大余 <18...@163.com> on 2022/02/08 09:25:38 UTC, 1 replies.
- [jira] [Created] (FLINK-26004) Introduce ForwardForLocalKeyByPartitioner - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2022/02/08 09:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26005) TableEnvironment.createTemporarySystemFunction cause NPE when using leftOuterLateralJoin - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/02/08 10:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26006) KinesisFirehoseSinkITCase leaks resources - posted by "David Morávek (Jira)" <ji...@apache.org> on 2022/02/08 11:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26007) Use durationType instead of stringType for time related config options - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2022/02/08 11:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26008) [FLIP-171] Update Kinesalite docker container reference - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2022/02/08 11:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26009) ArchUnit for Flink - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/02/08 13:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26010) Develop ArchUnit test for filesystems - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/02/08 13:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26011) Develop ArchUnit test for formats - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/02/08 13:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26012) Develop ArchUnit test for Flink table - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/02/08 13:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26013) Develop ArchUnit test for Flink core and runtime - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/02/08 13:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26014) Document how to use the working directory for faster local recoveries - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/02/08 14:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26015) FileSystemJobResultStore fails to access Minio - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/02/08 15:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26016) FileSystemLookupFunction does not produce correct results when hive table uses columnar storage - posted by "jinfeng (Jira)" <ji...@apache.org> on 2022/02/08 16:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26017) Add debug log message when marking a job result as dirty - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/02/08 17:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26018) Late events in the new KafkaSource - posted by "Jun Qin (Jira)" <ji...@apache.org> on 2022/02/08 20:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26019) Changelogged PriorityQueue elements recovered out-of-order - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/02/09 00:35:01 UTC, 0 replies.
- [jira] [Created] (FLINK-26020) Unified Pulsar Connector config model - posted by "Yufan Sheng (Jira)" <ji...@apache.org> on 2022/02/09 00:35:01 UTC, 0 replies.
- [jira] [Created] (FLINK-26021) Pulsar topic deduplicated in both sink and source connector - posted by "Yufan Sheng (Jira)" <ji...@apache.org> on 2022/02/09 01:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26022) Implement at-least-once and exactly-once Pulsar Sink - posted by "Yufan Sheng (Jira)" <ji...@apache.org> on 2022/02/09 01:44:00 UTC, 0 replies.
- [DISCUSS]Support the merge statement in FlinkSQL - posted by zhou chao <zh...@hotmail.com> on 2022/02/09 03:15:57 UTC, 8 replies.
- [jira] [Created] (FLINK-26023) Create a Pulsar sink config model for matching ProducerConfigurationData - posted by "Yufan Sheng (Jira)" <ji...@apache.org> on 2022/02/09 03:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26024) Create a PulsarSerializationSchema for better records serialization - posted by "Yufan Sheng (Jira)" <ji...@apache.org> on 2022/02/09 03:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26025) Replace MockPulsar with new Pulsar test tools based on PulsarStandalone - posted by "Yufan Sheng (Jira)" <ji...@apache.org> on 2022/02/09 03:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26026) Test FLIP-191 PulsarSink - posted by "Yufan Sheng (Jira)" <ji...@apache.org> on 2022/02/09 03:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26027) Add FLIP-33 metrics to new PulsarSink - posted by "Yufan Sheng (Jira)" <ji...@apache.org> on 2022/02/09 03:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26028) Write documentation for new PulsarSink - posted by "Yufan Sheng (Jira)" <ji...@apache.org> on 2022/02/09 03:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26029) Generalize the checkpoint protocol of OperatorCoordinator. - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2022/02/09 05:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26030) Set FLINK_LIB_DIR to lib under working dir in YARN containers - posted by "Biao Geng (Jira)" <ji...@apache.org> on 2022/02/09 06:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26031) Support projection pushdown on keys and values in sst file readers - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/02/09 06:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26032) log job info in the ContextEnvironment - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/02/09 07:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26033) In KafkaConnector, when 'sink.partitioner' is configured as 'round-robin', it does not take effect - posted by "shizhengchao (Jira)" <ji...@apache.org> on 2022/02/09 07:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26034) Add maven wapper for flink - posted by "Aiden Gong (Jira)" <ji...@apache.org> on 2022/02/09 07:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26035) Rework loader-bundle into separate module - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/02/09 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26036) LocalRecoveryITCase.testRecoverLocallyFromProcessCrashWithWorkingDirectory timeout on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/09 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26037) TaskManagerRunnerTest JVM crash with exit code 239 - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/09 07:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26038) Support delay message on Pulsar sink - posted by "Yufan Sheng (Jira)" <ji...@apache.org> on 2022/02/09 07:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26039) Incorrect value getter in map unnest table function - posted by "Han (Jira)" <ji...@apache.org> on 2022/02/09 07:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26040) PrometheusReporterEndToEndITCase hang on azure pipeline - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/09 07:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26041) AbstractTaskManagerProcessFailureRecoveryTest.testTaskManagerProcessFailure hang on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/09 08:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26042) PyFlinkEmbeddedSubInterpreterTests. test_udf_without_arguments failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/09 08:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26043) Add periodic kerberos relogin to DelegationTokenManager - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/02/09 08:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26044) Properly declare internal UNNEST function - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2022/02/09 08:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26045) Document error status codes for the REST API - posted by "David Morávek (Jira)" <ji...@apache.org> on 2022/02/09 08:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26046) Link to OpenAPI specification is dead - posted by "David Morávek (Jira)" <ji...@apache.org> on 2022/02/09 08:48:00 UTC, 0 replies.
- Azure Pipelines are dealing with an incident, causing pipeline runs to fail - posted by Martijn Visser <ma...@ververica.com> on 2022/02/09 09:55:18 UTC, 8 replies.
- [jira] [Created] (FLINK-26047) Support usrlib in HDFS for YARN application mode - posted by "Biao Geng (Jira)" <ji...@apache.org> on 2022/02/09 10:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26048) Yarn access should be separated by semicolon - posted by "MichealShin (Jira)" <ji...@apache.org> on 2022/02/09 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26049) The tolerable-failed-checkpoints logic is invalid when checkpoint trigger failed - posted by "fanrui (Jira)" <ji...@apache.org> on 2022/02/09 10:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26050) Too Many small sst files in rocksdb state backend when using processing time window - posted by "shen (Jira)" <ji...@apache.org> on 2022/02/09 10:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26051) row_number =1 and Subsequent SQL has "case when" and "where" statement : The window can only be ordered in ASCENDING mode - posted by "chuncheng wu (Jira)" <ji...@apache.org> on 2022/02/09 10:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26052) Update chinese documentation regarding FLIP-203 - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2022/02/09 11:25:00 UTC, 0 replies.
- [DISCUSS] FLINK-25927: Make flink-connector-base dependency usage consistent across all connectors - posted by Alexander Fedulov <al...@ververica.com> on 2022/02/09 11:25:42 UTC, 5 replies.
- [DISCUSS] Drop Jepsen tests - posted by Chesnay Schepler <ch...@apache.org> on 2022/02/09 11:40:37 UTC, 6 replies.
- [jira] [Created] (FLINK-26053) Fix parser generator warnings - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/02/09 12:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26054) Enable maven-enforcer to disable table-planner and table-runtime as dependencies - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/02/09 12:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26055) Use new FlinkVersion enum for serde plans - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2022/02/09 13:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26056) CLONE - [FLIP-171] KDS implementation of Async Sink Table API - posted by "Ahmed Hamdy (Jira)" <ji...@apache.org> on 2022/02/09 14:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26057) CLONE - [FLIP-171] Add SQL Client Uber jar for KinesisDataStreams Sink. - posted by "Ahmed Hamdy (Jira)" <ji...@apache.org> on 2022/02/09 14:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26058) KinesisDynamicTableFactory implements DynamicSourceFactory but uses sink options - posted by "Ahmed Hamdy (Jira)" <ji...@apache.org> on 2022/02/09 14:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26059) ResourceProfile#ANY can cause overflow exceptions - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/02/09 14:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26060) Make Python specific exec nodes unsupported - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/02/09 15:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26061) FileSystem.getFileStatus fails for directories - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/02/09 18:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26062) [Changelog] Non-deterministic recovery of PriorityQueue states - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/02/09 19:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26063) [Changelog] Incorrect key group logged for PQ.poll and remove - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/02/09 19:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26064) KinesisFirehoseSinkITCase IllegalStateException: Trying to access closed classloader - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2022/02/09 20:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26065) org.apache.flink.table.api.PlanReference$ContentPlanReference $FilePlanReference $ResourcePlanReference violation the api rules - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/10 02:51:00 UTC, 0 replies.
- [RESULT] [VOTE] FLIP-212: Introduce Flink Kubernetes Operator - posted by Thomas Weise <th...@apache.org> on 2022/02/10 04:32:16 UTC, 0 replies.
- [jira] [Created] (FLINK-26066) Introduce FileStoreRead - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/02/10 05:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26067) ZooKeeperLeaderElectionConnectionHandlingTest. testLoseLeadershipOnLostConnectionIfTolerateSuspendedConnectionsIsEnabled failed due to timeout - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/10 07:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26068) ZooKeeperJobGraphsStoreITCase.testPutAndRemoveJobGraph failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/10 07:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26069) KinesisFirehoseSinkITCase failed due to org.testcontainers.containers.ContainerLaunchException: Container startup failed - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/10 07:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26070) Update dependency numpy to >=1.21.0,<1.22 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/02/10 08:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26071) TableEnvironment#compilePlan should fail - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/02/10 10:11:00 UTC, 0 replies.
- RE: Re: [DISCUSS] FLIP-213: TaskManager's Flame Graphs - posted by Jacky Lau <28...@qq.com.INVALID> on 2022/02/10 13:01:28 UTC, 6 replies.
- [jira] [Created] (FLINK-26072) Mark NiFi connector as deprecated - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/02/10 13:22:00 UTC, 0 replies.
- [RESULT][VOTE] [VOTE] Deprecate NiFi connector - posted by Martijn Visser <ma...@ververica.com> on 2022/02/10 13:22:06 UTC, 0 replies.
- [RESULT][VOTE] Remove Twitter connector - posted by Martijn Visser <ma...@ververica.com> on 2022/02/10 13:24:47 UTC, 0 replies.
- [jira] [Created] (FLINK-26073) Remove Twitter connector - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/02/10 13:25:00 UTC, 0 replies.
- Re: [VOTE] Deprecate Cassandra connector - posted by Martijn Visser <ma...@ververica.com> on 2022/02/10 13:27:37 UTC, 0 replies.
- [jira] [Created] (FLINK-26074) Improve FlameGraphs scalability for high parallelism jobs - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2022/02/10 14:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26075) Persist per-ExecNode configuration - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2022/02/10 14:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26076) Fix ArchUnit violations in SourceMetricsITCase - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2022/02/10 15:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26077) Support operators send request to Coordinator and return a response - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2022/02/10 15:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26078) Initial Kubernetes Operator Prototype contribution - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/02/10 18:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26079) Disallow combination of Changelog backend and CLAIM restore mode - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/02/10 21:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26080) PartitionRequest client use Netty's IdleStateHandler to monitor channel's status - posted by "Cai Liuyang (Jira)" <ji...@apache.org> on 2022/02/11 02:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26081) Update document,becasue of add maven wapper. - posted by "Aiden Gong (Jira)" <ji...@apache.org> on 2022/02/11 05:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26082) CancelPartitionRequestTest.testDuplicateCancel failed on azure due to bind failed - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/11 07:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26083) CassandraConnectorITCase.testCassandraPojoNoAnnotatedKeyspaceAtLeastOnceSink failed on azure due to table exists - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/11 07:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26084) Python tests exit with code 137 - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/11 07:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26085) Statefun Support PbJson Type - posted by "xinchenyuan (Jira)" <ji...@apache.org> on 2022/02/11 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26086) fixed some causing ambiguities including the 'shit' comment - posted by "nyingping (Jira)" <ji...@apache.org> on 2022/02/11 08:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26087) S3 filesystem tests never run in AzureCI - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/02/11 08:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26088) Add Elasticsearch 8.0 support - posted by "Yuhao Bi (Jira)" <ji...@apache.org> on 2022/02/11 08:51:00 UTC, 0 replies.
- [ANNOUNCE] Pushing the feature freeze by a couple of days - posted by Johannes Moser <jo...@ververica.com> on 2022/02/11 08:54:05 UTC, 1 replies.
- [jira] [Created] (FLINK-26089) Introduce TablePipeline - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/02/11 09:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26090) Remove pre FLIP-84 methods - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/02/11 09:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26091) SafetyNetCloseableRegistryTest.testNonBlockingClose failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/11 09:29:00 UTC, 0 replies.
- [DISCUSS] Release Flink 1.14.4 - posted by Konstantin Knauf <kn...@apache.org> on 2022/02/11 09:29:10 UTC, 9 replies.
- [jira] [Created] (FLINK-26092) JsonAggregationFunctionsITCase fails with NPE when using RocksDB - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/02/11 10:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26093) SavepointFormatITCase fails with ChangelogStateBackend - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/02/11 13:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26094) Graph library not producing output to file - posted by "Hariharan Gopalan (Jira)" <ji...@apache.org> on 2022/02/11 14:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26095) MetricQueryService actor system binds to different address than main actor system - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/02/11 14:09:00 UTC, 0 replies.
- Re: Re: [DISCUSS] Future of Per-Job Mode - posted by Jark Wu <im...@gmail.com> on 2022/02/11 14:24:48 UTC, 7 replies.
- [jira] [Created] (FLINK-26096) add isolationLevel for jdbc Connector Options - posted by "nyingping (Jira)" <ji...@apache.org> on 2022/02/12 04:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26097) Kafka tombstone messages not working - posted by "Maik (Jira)" <ji...@apache.org> on 2022/02/12 14:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26098) TableAPI does not forward idleness configuration from DataStream - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/02/12 19:52:00 UTC, 0 replies.
- [hotfix datastream improvement] remove unnecessary condition - posted by 弘树 <ho...@gmail.com> on 2022/02/13 08:59:27 UTC, 1 replies.
- [jira] [Created] (FLINK-26099) Table connector proctime attributes has syntax error - posted by "Mans Singh (Jira)" <ji...@apache.org> on 2022/02/13 23:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26100) Set up Flink ML Document Website - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2022/02/14 02:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26101) Avoid shared state registry to discard duplicate changelog state - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2022/02/14 02:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26102) connector test by using 'flink run --python' - posted by "waittting (Jira)" <ji...@apache.org> on 2022/02/14 03:23:00 UTC, 0 replies.
- Flink restarts after hitting outOfMemory - posted by Misha Hungyo <mk...@gmail.com> on 2022/02/14 05:56:41 UTC, 1 replies.
- [jira] [Created] (FLINK-26103) Introduce log store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/02/14 06:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26104) KeyError: 'type_info' in PyFlink test - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/02/14 06:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26105) Running HA (hashmap, async) end-to-end test failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/14 07:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26106) BoundedSourceITCase failed due to JVM exits with code 239 - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/14 07:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26107) CoordinatorEventsExactlyOnceITCase.test failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/14 07:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26108) CoordinatedSourceITCase.testEnumeratorCreationFails failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/14 07:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26109) Avro Confluent Schema Registry nightly end-to-end test failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/14 07:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26110) AvroStreamingFileSinkITCase failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/14 07:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26111) ElasticsearchSinkITCase.testElasticsearchSink failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/14 07:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26112) Port getEndpoint method to the specific service type subclass - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/02/14 07:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26113) (1.16) Follow up tasks and code refactoring for FLIP-147 - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/14 07:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26114) DefaultScheduler fails fatally in case of an error when shutting down the checkpoint-related resources - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/02/14 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26115) Multiple Kafka connector tests failed due to The topic metadata failed to propagate to Kafka broker - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/14 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26116) FLIP-188: Implement Table Store V0.1 - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/02/14 08:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26117) JobManagerMetricGroup needs to implement GloballyCleanableResource as well - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/02/14 08:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26118) AsyncSinks do not support downscaling with state - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2022/02/14 09:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26119) AsyncSinkWriterStateSerializer needs to be PublicEvolving - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2022/02/14 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26120) ZooKeeperCheckpointIDCounterITCase.testConcurrentGetAndIncrement failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/14 09:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26121) ZooKeeperLeaderRetrievalConnectionHandlingTest.testNewLeaderAfterReconnectTriggersListenerNotification failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/14 09:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26122) JobManagerMetricGroup.addJob returns null when already being closed - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/02/14 09:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26124) JobManagerMetricGroup is never actually used - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/02/14 09:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26123) The data of the upsert-kafka source cannot be written to HBase under sql where conditions - posted by "Carl (Jira)" <ji...@apache.org> on 2022/02/14 09:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26125) Doc overhaul for the CAST behaviour - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/02/14 09:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26127) Cleanup usage of deprecated table methods in doc - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/02/14 09:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26126) Sink V2 will cause error numRecordsOut metric - posted by "Hang Ruan (Jira)" <ji...@apache.org> on 2022/02/14 09:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26128) Improve Table, Expressions and related classes Javadocs/Scaladocs - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/02/14 10:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26129) Using fail method instead of kill method when yarn application deployment error occures - posted by "zlzhang0122 (Jira)" <ji...@apache.org> on 2022/02/14 11:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26130) Document why and when user would like to increase network buffer size - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2022/02/14 11:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26132) Always serialize anonymous table - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2022/02/14 13:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26131) CompiledPlan should implement Executable - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/02/14 13:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26133) Kafka Source Web Deserializer Java Code is Error - posted by "十二 (Jira)" <ji...@apache.org> on 2022/02/14 14:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26134) Document checkpoint/savepoint guarantees - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2022/02/14 16:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26135) Separate job and deployment errors in FlinkDeployment status - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/02/14 16:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26136) Implement shared validation logic for FlinkDeployment objects - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/02/14 16:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26138) Create controller test - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/02/14 16:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26137) Create webhook REST api test - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/02/14 16:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26139) Improve JobStatus tracking and handle different job states - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/02/14 16:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26140) Add basic handling mechanism to deal with job upgrade errors - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/02/14 16:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26142) Integrate flink-kubernetes-operator repo with CI/CD - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/02/14 16:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26141) Support last-state upgrade mode - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/02/14 16:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26143) FlinkKafkaProducerITCase.testFlinkKafkaProducerFailBeforeNotify hangs - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2022/02/15 07:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26144) SavepointFormatITCase did NOT fail with changelog.enabled randomized - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/02/15 08:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26145) k8s docs jobmanager-pod-template artifacts-fetcher:latest image is not exist, we can use busybox to replace it - posted by "jackylau (Jira)" <ji...@apache.org> on 2022/02/15 08:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26146) Add test coverage for native format flink upgrades (minor versions) - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2022/02/15 08:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26147) Deleting incremental savepoints directory in CLAIM mode - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2022/02/15 09:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26148) Change the format of adaptive batch scheduler config option to "jobmanager.adaptive-batch-scheduler.XXX" - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2022/02/15 09:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26149) Build ArchUnit rule for connector reference implementation after connector has been moved to the external repo - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/02/15 09:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26150) [pulsar] enable requestTimeoutMs configuration - posted by "Aiden Gong (Jira)" <ji...@apache.org> on 2022/02/15 09:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26151) inprogressfileRecoverable not be clean up after restoring the bucket - posted by "WangXiaoyong (Jira)" <ji...@apache.org> on 2022/02/15 10:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26152) Translate the page of SQL/queries/WITH clause - posted by "wenyibo (Jira)" <ji...@apache.org> on 2022/02/15 10:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26153) Add script to update README playground links for Statefun - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/02/15 10:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26154) SavepointFormatITCase fails on azure - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/02/15 10:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26155) Add playground ingress/egress for cURL interaction - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/02/15 10:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26156) Event Time Temporal Join Watermark lag - posted by "tao.yang03 (Jira)" <ji...@apache.org> on 2022/02/15 10:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26157) Containers Should Not Run As Root - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/02/15 10:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26158) Update statefun-playground examples to use playground ingress/egress - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/02/15 11:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26159) Pulsar Connector: should add description MAX_FETCH_RECORD in doc to explain slow consumption - posted by "Yufei Zhang (Jira)" <ji...@apache.org> on 2022/02/15 12:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26160) Pulsar Connector: stopCursor description should be changed. Connector only stop when auto discovery is disabled. - posted by "Yufei Zhang (Jira)" <ji...@apache.org> on 2022/02/15 12:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26161) Pulsar Connector: edge case: splits should be added to finishedSplits if was empty from beginning - posted by "Yufei Zhang (Jira)" <ji...@apache.org> on 2022/02/15 12:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26162) Revamp security section of the documentation - posted by "Daisy Tsang (Jira)" <ji...@apache.org> on 2022/02/15 14:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26163) Refactor FlinkUtils#getEffectiveConfig into smaller pieces - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/02/15 14:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26164) Document watermark alignment - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2022/02/15 15:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26165) SavepointFormatITCase fails on azure - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/02/15 16:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26166) flink-runtime-web fails to compile if newline is cr lf - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/02/15 16:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26167) Explicitly set the partitioner for the sql operators whose shuffle and sort are removed - posted by "godfrey he (Jira)" <ji...@apache.org> on 2022/02/15 16:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26168) The judgment of chainable ignores StreamExchangeMode when partitioner is ForwardForConsecutiveHashPartitioner - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2022/02/16 00:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26169) There is a typo in the annotation for the WatermarkAlignmentParams class - posted by "Echo Lee (Jira)" <ji...@apache.org> on 2022/02/16 01:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26170) checkpoint time it too long - posted by "zhangqw152 (Jira)" <ji...@apache.org> on 2022/02/16 01:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26171) pyFlink -py options has issue with path that starts with // - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2022/02/16 02:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26172) some sql in `Table API&Sql` has syntax error - posted by "backspace (Jira)" <ji...@apache.org> on 2022/02/16 03:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26173) Sink GlobalCommitter's behavior is not compatible - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/02/16 03:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26174) KinesisDataStreamsSink.restoreWriter failed due to Architecture Violation - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/16 06:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26175) Make local cleanup being called in global cleanup situations - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/02/16 07:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26176) Scala savepoint migration tests don't run as configured (not testing RocksDB savepoints) - posted by "Sebastian Mattheis (Jira)" <ji...@apache.org> on 2022/02/16 08:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26177) PulsarSourceITCase.testScaleDown fails with timeout - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/02/16 08:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26178) Use the same enum for expected and observed jobstate (JobState / JobStatus.state) - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/02/16 08:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26179) Support periodic savepointing in the operator - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/02/16 08:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26180) Update docs to introduce the compaction for FileSink - posted by "Gen Luo (Jira)" <ji...@apache.org> on 2022/02/16 08:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26181) Support manual savepoint triggering in the operator - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/02/16 08:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26182) E2E test for PulsarSink on new Flink sink testing tools - posted by "Yufan Sheng (Jira)" <ji...@apache.org> on 2022/02/16 08:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26183) Support kubernetes-operator metrics using the Flink metric system - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/02/16 08:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26184) Migrate StoreSink to Sink V2 - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/02/16 09:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26185) E2E Elasticsearch Tests should use the new Sink interface - posted by "Alexander Preuss (Jira)" <ji...@apache.org> on 2022/02/16 10:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26186) update the API_ANNOTATIONS rule - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/02/16 10:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26187) Chinese docs override english aliases - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/02/16 10:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26188) Refactor TestingHighAvailabilityServices to properly use the builder pattern. - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/02/16 12:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26189) Remove bundling of grizzled-slf4j from rpc-akka - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/02/16 12:05:00 UTC, 0 replies.
- [RESULT] [VOTE] Release 1.13.6, release candidate #1 - posted by Konstantin Knauf <kn...@apache.org> on 2022/02/16 12:45:55 UTC, 0 replies.
- [jira] [Created] (FLINK-26190) Remove TableConfig from ExecNodeConfiguration - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2022/02/16 13:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26191) Incorrect license in Elasticsearch 7 connector - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/02/16 13:02:00 UTC, 0 replies.
- [ANNOUNCE] New Flink PMC members: Igal Shilman, Konstantin Knauf and Yun Gao - posted by Robert Metzger <rm...@apache.org> on 2022/02/16 13:22:48 UTC, 24 replies.
- [ANNOUNCE] New Apache Flink Committers: Feng Wang, Zhipeng Zhang - posted by Robert Metzger <rm...@apache.org> on 2022/02/16 13:30:58 UTC, 26 replies.
- [jira] [Created] (FLINK-26192) PulsarOrderedSourceReaderTest fails with exit code 255 - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2022/02/16 14:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26193) Commit generated FlinkDeployment resource into Git repo - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/02/16 14:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26194) Deprecate nullCheck in TableConfig - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2022/02/16 15:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26195) Kafka connector tests are mixing JUnit4 and JUnit5 - posted by "Alexander Preuss (Jira)" <ji...@apache.org> on 2022/02/16 16:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26196) error when Incremental Checkpoints by RocksDb - posted by "hjw (Jira)" <ji...@apache.org> on 2022/02/16 16:54:00 UTC, 0 replies.
- [ANNOUNCE] Flink 1.15 Feature Freeze - posted by Till Rohrmann <tr...@apache.org> on 2022/02/16 18:08:38 UTC, 6 replies.
- [jira] [Created] (FLINK-26197) Allow playground egress to keep connection open and push messages - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/02/16 18:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26198) ArchitectureTest fails on AZP (table.api.StatementSet) - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/02/16 18:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26199) StatementSet.compilePlan doesn't pass the archiunit tests - posted by "David Morávek (Jira)" <ji...@apache.org> on 2022/02/16 18:56:00 UTC, 0 replies.
- question about StatefunContext in golang Statefun SDK - posted by Galen Warren <ga...@cvillewarrens.com> on 2022/02/16 22:35:04 UTC, 34 replies.
- Discussion: Kafka Consumer and client.id.prefix usage - posted by Yaroslav Tkachenko <ya...@shopify.com.INVALID> on 2022/02/16 23:17:58 UTC, 0 replies.
- [jira] [Created] (FLINK-26200) Redirect statefun directly to docs - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2022/02/16 23:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26201) FileStoreScanTest is not stable - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/02/17 02:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26202) Support Table API in Pulsar Source Connector - posted by "Yufei Zhang (Jira)" <ji...@apache.org> on 2022/02/17 02:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26203) Support Table API in Pulsar Sink Connector - posted by "Yufei Zhang (Jira)" <ji...@apache.org> on 2022/02/17 02:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26204) set table.optimizer.distinct-agg.split.enabled to true and using Window TVF CUMULATE to count users, It will appear that the value of the current step window time is greater than the value of the next step window time - posted by "Bo Huang (Jira)" <ji...@apache.org> on 2022/02/17 03:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26205) Support Online Model Save in FlinkML - posted by "weibo zhao (Jira)" <ji...@apache.org> on 2022/02/17 03:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26206) refactor web ui's service layer and app config - posted by "Junhan Yang (Jira)" <ji...@apache.org> on 2022/02/17 06:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26207) refactor web ui's components to depend on module's injected config object - posted by "Junhan Yang (Jira)" <ji...@apache.org> on 2022/02/17 06:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26208) Introduce implementation of ManagedTableFactory - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/02/17 06:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26209) Possibility of Command Injection attack - posted by "Iman Sharafaldin (Jira)" <ji...@apache.org> on 2022/02/17 06:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26210) PulsarSourceUnorderedE2ECase failed on azure due to multiple causes - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/17 08:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26211) PulsarSourceUnorderedE2ECase failed on azure due to multiple causes - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/17 08:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26212) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint failed due to java.nio.file.NoSuchFileException - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/17 08:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26213) Translate "Deduplication" page into Chinese - posted by "Edmond Wang (Jira)" <ji...@apache.org> on 2022/02/17 08:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26214) Publish Kubernetes operator to container registry - posted by "Zili Chen (Jira)" <ji...@apache.org> on 2022/02/17 09:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26215) [JUnit5 Migration] Module: flink-metrics-statsd - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/02/17 11:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26216) Make 'replicas' work in JobManager Spec - posted by "Biao Geng (Jira)" <ji...@apache.org> on 2022/02/17 11:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26217) Introduce manifest.merge-min-count in commit - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/02/17 11:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26218) Enable JUnit 5 Automatic Extension Detection - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/02/17 11:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26219) [JUnit5 Migration] Module: flink-metrics-slf4j - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/02/17 11:44:00 UTC, 0 replies.
- [DISCUSS] Disable "Automated Checks / Review Progress" GitHub integration - posted by Robert Metzger <rm...@apache.org> on 2022/02/17 12:11:10 UTC, 6 replies.
- [jira] [Created] (FLINK-26220) KafkaSourceITCase$KafkaSpecificTests.testTimestamp fails on Azure Pipelines - posted by "Alexander Preuss (Jira)" <ji...@apache.org> on 2022/02/17 12:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26221) [JUnit5 Migration] Module: flink-metrics-prometheus - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/02/17 12:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26222) Delete outdated documents in "InfluxDB" part of "Metric Reporters" page - posted by "Chengkai Yang (Jira)" <ji...@apache.org> on 2022/02/17 12:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26223) Making ZK-related logs available in tests - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/02/17 13:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26224) HAJobRunOnHadoopS3FileSystemITCase fails with UnsupportedFileSystemSchemeException - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/02/17 14:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26225) [JUnit5 Migration] Module: flink-metrics-jmx - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/02/17 14:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26226) [JUnit5 Migration] Module: flink-metrics-influxdb - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/02/17 14:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26227) [JUnit5 Migration] Module: flink-metrics-graphite - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/02/17 14:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26228) [JUnit5 Migration] Module: flink-metrics-dropwizard - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/02/17 15:00:05 UTC, 0 replies.
- [jira] [Created] (FLINK-26229) [JUnit5 Migration] Module: flink-metrics-datadog - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/02/17 15:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26230) [JUnit5 Migration] Module: flink-metrics-core - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/02/17 15:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26231) [Changelog] Incorrect MaterializationID passed to ChangelogStateBackendHandleImpl - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/02/17 16:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26232) [JUnit5 Migration] Module: flink-avro - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2022/02/17 17:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26233) FileSinkCompactionSwitchITCase.testSwitchingCompaction() fails - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2022/02/17 21:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26234) Start minikube manually to replace external github actions - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/02/18 02:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26235) CompactingFileWriter and PendingFileRecoverable should not be exposed to users. - posted by "Gen Luo (Jira)" <ji...@apache.org> on 2022/02/18 03:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26236) Track and cap retries in ReconciliationStatus - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/02/18 05:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26237) PulsarSourceOrderedE2ECase failed on azure due to timeout - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/18 06:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26238) PulsarSinkITCase.writeRecordsToPulsar failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/18 06:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26239) EventTimeWindowCheckpointingITCase.testSlidingTimeWindow failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/18 06:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26240) PulsarSinkITCase.tearDown failed in azure - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2022/02/18 07:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26241) Pulsar.RoundRobinTopicRouterTest failed due to lang.ArithmeticException - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2022/02/18 07:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26242) Pulsar connector tests fails the JVM with exit code 255 - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/18 07:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26243) RoundRobinTopicRouterTest.routeMessagesInRoundRobin failed on azure due to divide by zero - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/18 07:58:00 UTC, 0 replies.
- [NOTICE] Pulsar tests disabled - posted by Chesnay Schepler <ch...@apache.org> on 2022/02/18 07:58:41 UTC, 4 replies.
- [jira] [Created] (FLINK-26244) [JUnit5 Migration] Module: flink-runtime-web - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/02/18 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26245) flink-runtime-web submit showPlan not working - posted by "Junhan Yang (Jira)" <ji...@apache.org> on 2022/02/18 08:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26246) Setup JUnit 5 infrastructure for parallel test execution - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/02/18 08:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26247) Introduce a better expire strategy - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/02/18 08:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26248) flink job not recover from latest checkpoint on native k8s - posted by "zhisheng (Jira)" <ji...@apache.org> on 2022/02/18 09:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26249) Run BuiltInFunctionITCase tests in parallel - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/02/18 09:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26250) Document the upgrade story - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2022/02/18 09:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26251) [JUnit5 Migration] Module: flink-rpc-akka - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/02/18 11:38:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.13.6 released - posted by Konstantin Knauf <kn...@apache.org> on 2022/02/18 13:32:03 UTC, 3 replies.
- [jira] [Created] (FLINK-26252) Refactor MiniClusterExtension - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/02/18 13:50:00 UTC, 0 replies.
- [DISCUSS] Plan to externalize connectors and versioning - posted by Martijn Visser <ma...@ververica.com> on 2022/02/18 13:54:21 UTC, 9 replies.
- [jira] [Created] (FLINK-26253) Speed up detection fo dropped message in MessageSerializationTest - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/02/18 13:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26254) KafkaSink might violate order of sequence numbers and risk exactly-once processing - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2022/02/18 14:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26255) SplitAggregateITCase.testAggWithJoin failed on azure - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/02/18 14:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26256) AWS SDK Async Event Loop Group Classloader Issue - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2022/02/18 15:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26257) Document metrics configuration for Prometheus - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/02/18 16:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26258) flink test - posted by "fuqiang8 (Jira)" <ji...@apache.org> on 2022/02/19 09:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26259) Partial insert and partition insert cannot work with sql hint - posted by "Junwen Yi (Jira)" <ji...@apache.org> on 2022/02/20 01:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26260) Support watching specific namespace for FlinkDeployments - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/02/20 19:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26261) Reconciliation should try to start job when not already started or move to permanent error - posted by "Thomas Weise (Jira)" <ji...@apache.org> on 2022/02/21 00:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26262) Rest API to submit PyFlink job - posted by "Thanh Thao Huynh (Jira)" <ji...@apache.org> on 2022/02/21 01:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26263) Check data size in LogisticRegression - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2022/02/21 01:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26264) Python Test failed on its docs building phase - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2022/02/21 02:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26265) Support Java Algorithm in Python ML API - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/02/21 02:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26266) Support Vector and Matrix - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/02/21 02:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26267) Add common params interface in ML Python API - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/02/21 02:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26268) Add classfication algorithm support for LogisticRegression, KNN and NaiveBayes in ML Python API - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/02/21 03:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26269) Add clustering algorithm support for KMeans in ML Python API - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/02/21 03:00:01 UTC, 0 replies.
- [jira] [Created] (FLINK-26270) Flink SQL write data to kafka by CSV format , decimal type was converted to scientific notation - posted by "fengjk (Jira)" <ji...@apache.org> on 2022/02/21 06:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26271) TaskTest.testCancelTaskExceptionAfterTaskMarkedFailed - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/02/21 07:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26272) Elasticsearch7SinkITCase.testWriteJsonToElasticsearch fails with socket timeout - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/02/21 07:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26273) Test checkpoints restore modes & formats - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2022/02/21 07:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26274) Test local recovery works across TaskManager process restarts - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/02/21 08:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26275) Upgrade JLine 3.21.0 - posted by "Cheng Pan (Jira)" <ji...@apache.org> on 2022/02/21 08:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26276) Introduce ITCase for table store source and sink - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/02/21 08:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26277) Java docs & implementation of TimestampColumnReader are contradicting - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/02/21 09:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26278) Add Expressions.col as a synonym for $ - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2022/02/21 09:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26279) Provide mailbox delay metric - posted by "Sebastian Mattheis (Jira)" <ji...@apache.org> on 2022/02/21 10:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26280) Add a flag to disable uid generation - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2022/02/21 12:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26281) Test Elasticsearch connector End2End - posted by "Alexander Preuss (Jira)" <ji...@apache.org> on 2022/02/21 13:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26282) Deprecate MetricNames.NUM_RECORDS_OUT_ERRORS - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/02/21 13:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26283) Harden AggregateCall serialization in JSON plan - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2022/02/21 14:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26284) ZooKeeperStateHandleStore cleans the data stored in ZK before cleaning the StateHandle - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/02/21 14:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26285) ZooKeeperStateHandleStore does not handle not existing nodes properly in getAllAndLock - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/02/21 15:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26286) The KubernetesStateHandleStore cleans the metadata before cleaning the StateHandle - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/02/21 16:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26287) Add convenient TableConfig.set - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2022/02/21 16:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26288) Investigate why RetrievableStreamStateHandle.close does not call the close method of the wrapped instance - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/02/21 17:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26289) Adaptive Scheduler: Exception history can not be queried by the REST API - posted by "David Morávek (Jira)" <ji...@apache.org> on 2022/02/21 17:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26290) Revisit serviceAccount and taskSlots direct fields in CRD - posted by "Thomas Weise (Jira)" <ji...@apache.org> on 2022/02/21 21:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26291) KinesisFirehoseSinkITCase failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/22 06:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26292) FlinkKafkaProducerITCase.testScaleUpAfterScalingDown failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/22 06:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26293) Store log offsets in snapshot - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/02/22 08:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26294) Using fixed description for ArchUnit rules - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/02/22 08:36:00 UTC, 0 replies.
- [DISCUSS] CAST legacy behaviour - posted by Marios Trivyzas <ma...@gmail.com> on 2022/02/22 09:06:51 UTC, 4 replies.
- [jira] [Created] (FLINK-26295) 'HELP ;', 'QUIT ;' and other sql-client commands fail with CalciteException: Non-query expression encountered in illegal context - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/02/22 10:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26296) Add missing documentation - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/02/22 10:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26297) Introduce ExecutionNodeConfig which will be used in all Exec Nodes - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2022/02/22 10:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26298) [JUnit5 Migration] Module: flink-rpc-core - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/02/22 11:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26299) Reintroduce old JobClient#triggerSavepoint,stopWithSavepoint methods - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2022/02/22 11:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26300) KinesisFirehoseSinkITCase failed on azure IOException - posted by "Zichen Liu (Jira)" <ji...@apache.org> on 2022/02/22 12:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26301) Test AvroParquet format - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/02/22 13:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26302) Upgrat rat-plugin to 1.13 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/02/22 14:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26303) Print rat-plugin violations to the console - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/02/22 15:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26304) GlobalCommitter can receive failed committables - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2022/02/22 15:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26305) KinesisFirehoseSinkITCase writes duplicates to Localstack - posted by "Zichen Liu (Jira)" <ji...@apache.org> on 2022/02/22 15:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26306) Triggered checkpoints can be delayed by discarding shared state - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/02/22 16:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26307) 当事件时间在(Long.MIN_VALUE ,-windowsize)时,不能正确的求到开启窗口的起始时间 - posted by "郭元方 (Jira)" <ji...@apache.org> on 2022/02/22 16:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26308) Remove need for flink-operator clusterrole - posted by "Márton Balassi (Jira)" <ji...@apache.org> on 2022/02/22 17:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26309) Add a polling strategy to determine whether Localstack test container has started - posted by "Zichen Liu (Jira)" <ji...@apache.org> on 2022/02/22 17:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26310) [FLIP-171] Add AsyncSinkWriterConfig class - posted by "Ahmed Hamdy (Jira)" <ji...@apache.org> on 2022/02/22 18:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26311) Test CsvFormat - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2022/02/22 19:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26312) Doc bug - newly introduced `INITIALIZING` state doesn't appear internal docs - posted by "Madhav Kelkar (Jira)" <ji...@apache.org> on 2022/02/22 21:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26313) Support Online KMeans in Flink ML - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2022/02/23 01:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26314) StreamingCompactingFileSinkITCase.testFileSink failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/23 03:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26315) Stream job which have multily region would not recover when connection with zookeeper/hbase lost. - posted by "Janick Wu (Jira)" <ji...@apache.org> on 2022/02/23 03:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26316) Savepoint restore setting does not take effect when configured via dynamic config options - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/02/23 06:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26317) flink-yarn-tests Exit code 137 returned from process - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/23 07:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26318) ChangelogCompatibilityITCase.testRestore failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/23 07:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26319) CastFunctionITCase.testFunction failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/23 07:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26320) Update hive doc for 1 m->1 min - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2022/02/23 07:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26321) KafkaSinkITCase.testWriteRecordsToKafkaWithExactlyOnceGuarantee fails on azure - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/02/23 07:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26322) Test FileSink compaction manually - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/23 07:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26323) PerJobMiniClusterFactoryTest.testJobClient failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/23 08:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26324) Remove duplicate condition judgment - posted by "Junfan Zhang (Jira)" <ji...@apache.org> on 2022/02/23 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26325) Add test coverage for native format State Processor API - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2022/02/23 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26326) FLIP-203: Support native and incremental savepoints 1.1 - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2022/02/23 09:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26327) throw not a literal exception in callContext.getArgumentValue when getTypeInference - posted by "Spongebob (Jira)" <ji...@apache.org> on 2022/02/23 09:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26328) Control Logging Behavior in Flink Deployments - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/02/23 09:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26329) Adjust the order of var initialization in FlinkControllerConfig - posted by "Junfan Zhang (Jira)" <ji...@apache.org> on 2022/02/23 09:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26330) Test Adaptive Batch Scheduler manually - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2022/02/23 09:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26331) Make max retries configurable - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/02/23 10:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26332) Move the Operator Env to the common Utils - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/02/23 11:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26333) [Flink 1.14.3] Repeated exception with DuplicateJobSubmissionException: Job has already been submitted - posted by "Parag Somani (Jira)" <ji...@apache.org> on 2022/02/23 11:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26334) when watermark less than (0-offset) , T - posted by "realdengziqi (Jira)" <ji...@apache.org> on 2022/02/23 12:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26335) prometheus/metrics - java.lang.OutOfMemoryError: Java heap space - posted by "Marcelo Nogueira (Jira)" <ji...@apache.org> on 2022/02/23 13:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26336) Deletion should remove HA related configmaps also - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/02/23 13:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26337) Avoid load flink conf each reconcile loop - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/02/23 14:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26338) Add documentation of savepoint type on Command-Line part - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2022/02/23 14:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26339) Introduce the webhook config to free the environment options - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/02/23 14:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26340) Add ability in Golang SDK to create new statefun.Context from existing one, but with a new underlying context.Context - posted by "Galen Warren (Jira)" <ji...@apache.org> on 2022/02/23 16:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26341) ZooKeeperTestEnvironment does not allow for repeated test execution - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/02/23 17:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26342) Add missing CSV format page - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2022/02/23 23:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26343) IndexOutOfBoundsException when subquery select all field from using hive dialect - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/02/24 02:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26344) waitForClusterShutdown does not work correctly in Flink Kubernetes operator - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/02/24 03:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26345) Observer should detect flink job even if deployment status is empty - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/02/24 05:08:00 UTC, 0 replies.
- jira - posted by Simon Aries <si...@qq.com.INVALID> on 2022/02/24 08:53:34 UTC, 1 replies.
- [jira] [Created] (FLINK-26346) Add statistics collecting to sst files - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/02/24 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26347) Should use Flink system Classloader (AppClassloader) when deserializing RPC message - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2022/02/24 09:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26348) Maybe ChangelogNormalize should ignore unused columns when deduplicate - posted by "Kenyore (Jira)" <ji...@apache.org> on 2022/02/24 09:54:00 UTC, 0 replies.
- contributor - posted by 阿穆 <30...@qq.com.INVALID> on 2022/02/24 11:49:25 UTC, 1 replies.
- [jira] [Created] (FLINK-26349) AvroParquetReaders does not work with ReflectData - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2022/02/24 12:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26350) Extend ConfigOptionBuilder in a way to allow a description for the default value - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/02/24 12:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26351) After scaling a flink task running on k8s, the flink web ui graph always shows the parallelism of the first deployment. - posted by "qiunan (Jira)" <ji...@apache.org> on 2022/02/24 12:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26352) Missing license header in WebUI source files - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/02/24 13:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26353) "flink stop --help" does not list "--type" option - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2022/02/24 13:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26354) "-restoreMode" should be "--restoreMode" and should have a shorthand - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2022/02/24 13:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26355) VarCharType was not be considered in HiveTableSqlFunction - posted by "zoucao (Jira)" <ji...@apache.org> on 2022/02/24 14:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26356) Revisit the create of RestClusterClient - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/02/24 14:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26357) add @PublicEvolving to AvroParquetRecordFormat - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/02/24 15:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26358) Operator maxParallelism is lost during chaining - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2022/02/24 16:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26359) Aligning the retry mechanism for the repeatable cleanup and task restarts - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/02/24 18:33:00 UTC, 0 replies.
- possible bug in Statefun Golang SDK related to Context.Caller - posted by Galen Warren <ga...@cvillewarrens.com> on 2022/02/24 21:58:14 UTC, 3 replies.
- [jira] [Created] (FLINK-26360) [Umbrella] Improvement for Hive Query Syntax Compatibility - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/02/25 02:00:02 UTC, 0 replies.
- [jira] [Created] (FLINK-26361) "Unexpected correlate variable $cor0" when using hive dialect to write a subquery - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/02/25 02:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26362) IndexOutOfBoundsException when subquery select all field from using hive dialect - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/02/25 02:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26363) Fail to use such expression like if(1= 1, 2, 3) - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/02/25 03:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26364) Improve hive udtf - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/02/25 03:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26365) improve hive udaf - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/02/25 03:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26366) Support "insert directory" - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/02/25 04:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26367) Move sanity check in FlinkService#cancelJob to DefaultDeploymentValidator - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2022/02/25 07:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26368) Add setProperty method to KafkaSinkBuilder - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/02/25 10:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26369) Translate the part zh-page mixed with not be translated. - posted by "Aiden Gong (Jira)" <ji...@apache.org> on 2022/02/25 10:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26370) Make Flink cluster communication asynchronous - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/02/25 11:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26371) Support read hive variables using the syntax like select ${hiveconf:select_time} - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/02/25 11:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26372) Allow Changelog Storage configuration per program - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/02/25 12:16:00 UTC, 0 replies.
- [VOTE] Release 1.14.4, release candidate #1 - posted by Konstantin Knauf <kn...@apache.org> on 2022/02/25 13:30:39 UTC, 1 replies.
- [jira] [Created] (FLINK-26373) Rename flink-connector-aws-kinesis-data-streams module to flink-connector-aws-kinesis-streams - posted by "Ahmed Hamdy (Jira)" <ji...@apache.org> on 2022/02/25 13:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26374) JSON_OBJECT may throw NullPointerException on nullable column - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2022/02/25 14:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26375) Fix Statefun Golang SDK to return nil from Context.Caller when there is no caller - posted by "Galen Warren (Jira)" <ji...@apache.org> on 2022/02/25 14:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26376) Replace TableConfig with PlannerConfig in PlannerContext - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2022/02/25 16:58:00 UTC, 0 replies.
- SourceEvent Task Failure Handling - posted by Mason Chen <ma...@gmail.com> on 2022/02/25 20:50:34 UTC, 0 replies.
- [jira] [Created] (FLINK-26377) Extract Reconciler interface - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/02/25 21:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26378) caller's address isn't set to None properly when a message is coming from an ingress - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2022/02/25 21:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26379) First message produced via Flink Kafka Connector is slow - posted by "Ragu Krishnamurthy (Jira)" <ji...@apache.org> on 2022/02/25 22:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26380) Pending record count must be zero at this point: 5592 - posted by "Fangliang Liu (Jira)" <ji...@apache.org> on 2022/02/26 11:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26381) Wrong document order of Chinese version - posted by "tonny (Jira)" <ji...@apache.org> on 2022/02/26 11:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26382) Add Chinese documents for flink-training exercises - posted by "tonny (Jira)" <ji...@apache.org> on 2022/02/27 09:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26383) Create model stream sink demo - posted by "weibo zhao (Jira)" <ji...@apache.org> on 2022/02/28 01:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26384) This exception indicates that the query uses an unsupported SQL feature. - posted by "Spongebob (Jira)" <ji...@apache.org> on 2022/02/28 02:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26385) Use new Kafka source and sink in Python API - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2022/02/28 06:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26386) CassandraConnectorITCase.testCassandraTableSink failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/28 07:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26387) KafkaSourceLegacyITCase.testBrokerFailure hang on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/28 07:41:00 UTC, 0 replies.
- [DISCUSS] Flink Kubernetes Operator controller flow - posted by Gyula Fóra <gy...@apache.org> on 2022/02/28 08:00:47 UTC, 5 replies.
- [jira] [Created] (FLINK-26388) Release Testing: Repeatable Cleanup - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/02/28 08:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26389) Many operators of ”flink-end-to-end-tests“ have been deprecated and need to be updated - posted by "ChengyunZhang (Jira)" <ji...@apache.org> on 2022/02/28 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26390) InputStream is not closed at CliClient#executeFile - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/02/28 08:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26391) Release Testing: Application Mode recovery does not re-trigger a job which failed during cleanup (FLINK-11813) - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/02/28 09:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26392) Support externally induced sources in MultipleInputStreamTask - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2022/02/28 10:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26393) KafkaITCase.testBrokerFailure fails due to a topic isn't cleaned up properly - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/02/28 10:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26394) CheckpointCoordinator.isTriggering can not be reset if a checkpoint expires while the checkpointCoordinator task is queuing in the SourceCoordinator executor. - posted by "Gen Luo (Jira)" <ji...@apache.org> on 2022/02/28 10:39:00 UTC, 0 replies.
- Change of focus - posted by Till Rohrmann <tr...@apache.org> on 2022/02/28 10:59:05 UTC, 6 replies.
- [jira] [Created] (FLINK-26395) The description of RAND_INTEGER is wrong in SQL function documents - posted by "huweihua (Jira)" <ji...@apache.org> on 2022/02/28 11:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26396) [Changelog] Upload is not failed even if all attempts timeout - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/02/28 14:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26397) Chinese Translation - Add documentation for Kinesis firehose Table Api - posted by "Ahmed Hamdy (Jira)" <ji...@apache.org> on 2022/02/28 14:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26398) Add documentation for Kinesis Firehose table API. - posted by "Ahmed Hamdy (Jira)" <ji...@apache.org> on 2022/02/28 14:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26399) Make some option of operator configurable - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/02/28 14:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26400) Release Testing: Explicit shutdown signalling from TaskManager to JobManager - posted by "Niklas Semmler (Jira)" <ji...@apache.org> on 2022/02/28 15:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26401) improve the compatibility for hive catalogView - posted by "zoucao (Jira)" <ji...@apache.org> on 2022/02/28 16:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26402) MinioTestContainerTest.testS3EndpointNeedsToBeSpecifiedBeforeInitializingFileSyste failed due to Container startup failed - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/28 17:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-26403) SinkWriter should emit all the pending committables on endOfInput - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/02/28 17:35:00 UTC, 0 replies.