You are viewing a plain text version of this content. The canonical link for it is here.
- Re: [DISCUSS] FLIP-188: Introduce Built-in Dynamic Table Storage - posted by Kurt Young <yk...@gmail.com> on 2021/11/01 01:38:48 UTC, 14 replies.
- [jira] [Created] (FLINK-24710) Kafka header support for ingress and egress - posted by "Hady Willi (Jira)" <ji...@apache.org> on 2021/11/01 03:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24711) Typed ID support - posted by "Hady Willi (Jira)" <ji...@apache.org> on 2021/11/01 03:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24712) NFATest#testSimpleNFA: fix test flaxiness - posted by "Alexander Ronald Altman (Jira)" <ji...@apache.org> on 2021/11/01 05:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24713) Postpone resourceManager serving after the recovery phase has finished - posted by "Aitozi (Jira)" <ji...@apache.org> on 2021/11/01 05:45:00 UTC, 0 replies.
- Re: [DISCUSS] Over Aggregation add supports CURRENT_TIMESTAMP as the upper boundary in RANGE intervals . - posted by 林挺滨 <li...@gmail.com> on 2021/11/01 07:22:41 UTC, 2 replies.
- [jira] [Created] (FLINK-24714) Validate partition columns for ResolvedCatalogTable - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/11/01 08:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24715) Update Jackson to latest version - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/11/01 09:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24716) Non-equality predicates on partition columns lead to incorrect plans - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/11/01 11:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24717) Push partitions before filters - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/11/01 11:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24718) Update AVRO dependency to latest version - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/11/01 12:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24719) Update Postgres and Postgress test dependencies to latest version - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/11/01 12:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24720) Remove flink-runtime-web dependency from flink-tests - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/01 14:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24721) Update the based on the Maven official indication - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2021/11/01 15:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24722) Only set keyContext for the normal records - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/11/01 15:50:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-189: SQL Client Usability Improvements - posted by Sergey Nuyanzin <sn...@gmail.com> on 2021/11/01 16:15:02 UTC, 20 replies.
- [jira] [Created] (FLINK-24723) Add ServicesResourceTransformer to the quickstart project - posted by "Ali Bahadir Zeybek (Jira)" <ji...@apache.org> on 2021/11/01 16:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24724) Update Sun XML Bind dependencies to latest minor version - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/11/01 17:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24725) Update Cython to the latest version - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/11/01 22:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24726) Hive Lookup Join SQL: decimal type UnsupportedOperationException - posted by "Zongwen Li (Jira)" <ji...@apache.org> on 2021/11/02 06:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24727) Running Kerberized YARN per-job on Docker test (no fat-jar) fails on Azure - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/11/02 07:34:00 UTC, 0 replies.
- Re: [Discuss] Planning Flink 1.15 - posted by David Morávek <dm...@apache.org> on 2021/11/02 07:53:08 UTC, 0 replies.
- [jira] [Created] (FLINK-24728) Batch SQL file sink forgets to close the output stream - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/11/02 07:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24729) Support IterationBody with mixed per-round and all-round operators - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/11/02 08:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24731) Add a blank space for TransitiveClosureNaive - posted by "liyunchao (Jira)" <ji...@apache.org> on 2021/11/02 08:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24730) Support prompt in SqlCli - posted by "Yubin Li (Jira)" <ji...@apache.org> on 2021/11/02 08:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24732) Remove scala suffix from respective benchmarks dependencies - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/11/02 08:54:00 UTC, 0 replies.
- Reactive mode in 1.13 - posted by Ravi Sankar Reddy Sangana <Ra...@radware.com> on 2021/11/02 09:22:01 UTC, 0 replies.
- [jira] [Created] (FLINK-24733) Data loss in pulsar source when using shared mode - posted by "wang shengzhi (Jira)" <ji...@apache.org> on 2021/11/02 11:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24734) testSecretOption fails due to missing required options - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/11/02 11:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24735) SQL client crashes with `Cannot add expression of different type to set` - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/11/02 11:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24736) Non vulenerable jar files for Apache Flink 1.14.0 - posted by "Parag Somani (Jira)" <ji...@apache.org> on 2021/11/02 11:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24737) Update outdated web dependencies in flink-runtime-web - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/11/02 13:29:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-187: Adaptive Batch Job Scheduler - posted by David Morávek <dm...@apache.org> on 2021/11/02 13:43:03 UTC, 4 replies.
- [jira] [Created] (FLINK-24738) Fail during announcing buffer size to released local channel - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/11/02 14:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24739) State requirements for Flink's application mode in the documentation - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/11/02 14:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24740) Update testcontainers dependency to the latest version - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/11/02 15:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24741) Deprecate FileRecordFormat, use StreamFormat instead - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2021/11/02 15:36:00 UTC, 0 replies.
- [DISCUSS] FLIP-191: Extend unified Sink interface to support small file compaction - posted by Fabian Paul <fa...@ververica.com> on 2021/11/02 16:44:07 UTC, 19 replies.
- [jira] [Created] (FLINK-24742) SQL client add info about key strokes to docs - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2021/11/02 22:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24743) New File Sink end-to-end test fails on Azure - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/11/03 08:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24744) FlinkKafkaProducerITCase.testMigrateFromAtLeastOnceToExactlyOnce fails on Azure because org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/11/03 08:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24745) Add support for Oracle OGG json parser in flink-json module - posted by "Steven (Jira)" <ji...@apache.org> on 2021/11/03 08:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24746) Alibaba maven mirror is unstable - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/03 08:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24747) Add producedDataType to SupportsProjectionPushDown.applyProjection - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/11/03 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24748) Remove CheckpointStatsTracker#getJobCheckpointingConfiguration - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/03 10:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24749) Reuse CheckpointStatsTracker across rescaling - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/03 11:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24750) Single quotes converted to left/right single quotes during docs generation - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2021/11/03 12:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24751) flink SQL comile failed cause by: java.lang.StackOverflowError - posted by "tao.yang03 (Jira)" <ji...@apache.org> on 2021/11/03 13:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24752) Cleanup ScalarOperatorGens#generateCast - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/11/03 13:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24753) Enforce CHAR/VARCHAR precision when outputing to a Sink - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/11/03 14:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24754) PushDownSepcs are better to be print by a clear order. - posted by "xuyang (Jira)" <ji...@apache.org> on 2021/11/03 14:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24755) sun.misc doesn't exist - posted by "Aitozi (Jira)" <ji...@apache.org> on 2021/11/03 15:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24756) Flink metric identifiers contain group variables. - posted by "Frederic Hemery (Jira)" <ji...@apache.org> on 2021/11/03 18:31:00 UTC, 0 replies.
- [VOTE] FLIP-189: SQL Client Usability Improvements - posted by Sergey Nuyanzin <sn...@gmail.com> on 2021/11/03 22:04:25 UTC, 11 replies.
- [jira] [Created] (FLINK-24757) Yarn application is not terminated after the job finishes when submitting a yarn-per-job insert job with SQL client - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/11/04 04:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24758) partition.time-extractor.kind support "yyyyMMdd" - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/11/04 04:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24759) Metrics on web UI is not correct in a filesystem source to filesystem sink streaming job - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/11/04 04:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24760) Update user document for batch window tvf - posted by "JING ZHANG (Jira)" <ji...@apache.org> on 2021/11/04 07:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24761) Fix PartitionPruner code gen compile fail - posted by "tartarus (Jira)" <ji...@apache.org> on 2021/11/04 07:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24762) Remove agg function: INCR_SUM - posted by "Shuo Cheng (Jira)" <ji...@apache.org> on 2021/11/04 08:02:00 UTC, 0 replies.
- Contributor - posted by 浩海紫冰 <hu...@foxmail.com> on 2021/11/04 09:09:10 UTC, 0 replies.
- [jira] [Created] (FLINK-24763) ParquetFileSystemITCase.testLimitableBulkFormat failed on Azure - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/11/04 09:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24764) pyflink/table/tests/test_udf.py hang on Azure - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/11/04 09:24:00 UTC, 0 replies.
- Re: Contributor - posted by Till Rohrmann <tr...@apache.org> on 2021/11/04 09:40:26 UTC, 0 replies.
- [jira] [Created] (FLINK-24765) Upgrade Kafka dependency - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/11/04 09:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24766) Ceiling/flooring dates to day return wrong resuls - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2021/11/04 09:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24767) A keyBy following countWindow does not preserve order within the same partition - posted by "Lee Y S (Jira)" <ji...@apache.org> on 2021/11/04 09:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24768) Upgrade Web Frontend to Angular v13 and NG-Zorro v13 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/11/04 10:41:02 UTC, 0 replies.
- [jira] [Created] (FLINK-24769) FlameGraphs in 1.14 do not aggregate subtasks' stack traces anymore - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/11/04 12:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24770) Remove error cause from JobStatusListener interface - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/04 12:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24771) Update JDBC test dependencies to latest version - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/11/04 12:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24772) Update user document for individual window table-valued function - posted by "JING ZHANG (Jira)" <ji...@apache.org> on 2021/11/04 14:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24773) KafkaCommitter should fail on unknown Exception - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/11/04 14:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24774) AdaptiveScheduler should inform job status listener of all state changes - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/04 14:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24775) Move JobStatus-related metrics out of ExecutionGraph - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/04 14:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24776) Clarify DecodingFormat - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/11/04 16:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24777) Processed (persisted) in-flight data description miss on Monitoring Checkpointing page - posted by "camilesing (Jira)" <ji...@apache.org> on 2021/11/04 16:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24778) Add DataTypes#ROW(List) - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/11/04 16:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24779) Port Numeric casting logic to CastRule - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/11/04 17:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24780) Port time to time casting logic to CastRule - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/11/04 17:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24781) Port from string casting logic to CastRule - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/11/04 17:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24782) Create 1.14 release branch for training repo - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/11/04 20:57:00 UTC, 0 replies.
- Re: [ANNOUNCE] Documentation now available at nightlies.apache.org - posted by Yun Tang <my...@live.com> on 2021/11/05 03:44:01 UTC, 8 replies.
- [jira] [Created] (FLINK-24783) Improve state backend monitoring experience and usability - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/11/05 07:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24784) Enable state.backend.latency-track.state-name-as-variable by default - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/11/05 07:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24785) Relocate RocksDB's log under flink log directory by default - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/11/05 07:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24786) Introduce metrics of RocksDB's statistis - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/11/05 07:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24787) Add more details of state latency tracking documentation - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/11/05 07:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24788) Report RocksDB statistics as metrics - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/11/05 07:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24789) IllegalStateException with CheckpointCleaner being closed already - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/11/05 08:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24790) DATE_FORMAT: some formats are handled in a wrong way or fail - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2021/11/05 09:31:00 UTC, 0 replies.
- Re: [VOTE] FLIP-174: Improve the WithParam interface - posted by Becket Qin <be...@gmail.com> on 2021/11/05 10:15:11 UTC, 4 replies.
- [jira] [Created] (FLINK-24791) py37-cython failed on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/11/05 10:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24792) OperatorCoordinatorSchedulerTest crashed JVM on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/11/05 10:40:01 UTC, 0 replies.
- [jira] [Created] (FLINK-24793) DefaultSchedulerLocalRecoveryITCase fails on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/11/05 10:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24794) pyflink/datastream/tests/test_data_stream.py fails on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/11/05 11:19:00 UTC, 0 replies.
- I want to contribute to Apache Flink - posted by shiyuquan <ch...@163.com> on 2021/11/05 11:22:10 UTC, 1 replies.
- [jira] [Created] (FLINK-24795) FlinkKafkaProducerITCase.testRunOutOfProducersInThePool times out on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/11/05 11:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24796) Reduce size of compile CI artifact - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/05 11:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24797) GlobalWindow.Serializer#getLength() provides a wrong length. - posted by "bx123 (Jira)" <ji...@apache.org> on 2021/11/05 12:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24798) Bump commons-cli to v1.5.0 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/11/05 12:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24799) KafkaDynamicTableFactoryTest.testTableSourceWithKeyValueAndMetadata fails on Azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/11/05 13:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24800) BufferTimeoutITCase.testDisablingBufferTimeout failed on Azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/11/05 14:00:07 UTC, 0 replies.
- [jira] [Created] (FLINK-24801) "Post-job: Cache Maven local repo" failed on Azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/11/05 14:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24802) Improve cast ROW to STRING - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/11/05 14:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24803) Fix cast BINARY/VARBINARY to STRING - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/11/05 14:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24804) Upgrade oshi-core from v3.4.0 to v.5.8.3 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/11/05 15:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24805) Metrics documentation missing numBytes metrics reported by tasks - posted by "Mason Chen (Jira)" <ji...@apache.org> on 2021/11/05 18:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24806) RMQSourceITCase.testStopWithSavepoint failed on azure due to connection error - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/11/06 03:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24807) Fix the issues in checkpoints with iteration - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/11/06 04:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24808) Support IterationListener for per-round operators - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/11/06 04:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24809) Check & possible fix decimal precision and scale for all Aggregate functions - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/11/06 10:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24810) Add Estimator and Model for the k-means clustering algorithm - posted by "Dong Lin (Jira)" <ji...@apache.org> on 2021/11/06 15:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24811) KafkaSourceITCase#testRedundantParallelism and testBasicRead failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/11/07 15:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24812) compile_cron_python_wheels failed to execute on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/11/07 15:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24813) Improve ImplicitTypeConversionITCase - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/11/08 03:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24814) Cannot update accumulators for job - posted by "mo.wu (Jira)" <ji...@apache.org> on 2021/11/08 04:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24815) Reduce the cpu cost of calculating stateSize during state allocation - posted by "ming li (Jira)" <ji...@apache.org> on 2021/11/08 06:44:00 UTC, 0 replies.
- [VOTE] FLIP-187: Adaptive Batch Job Scheduler - posted by Lijie Wang <wa...@gmail.com> on 2021/11/08 06:46:52 UTC, 7 replies.
- [jira] [Created] (FLINK-24816) Bump com.rabbitmq:amqp-client to v5.13.1 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/11/08 08:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24817) Support Naive Bayes algorithm in Flink ML - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2021/11/08 08:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24818) Incorrect comment of ttlConfig field in StateDescriptor - posted by "jianzhang.yjz (Jira)" <ji...@apache.org> on 2021/11/08 09:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24819) Higher cpu load after using SharedIndexInformer replaced naked Kubernetes watch - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2021/11/08 09:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24820) Examples in documentation for value1 IS DISTINCT FROM value2 are wrong - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2021/11/08 09:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24821) FlinkKafkaProducerMigrationOperatorTest.testRestoreProducer fails on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/11/08 10:19:00 UTC, 0 replies.
- Elasticsearch6 connector in flink stand alone - posted by Ravi Sankar Reddy Sangana <Ra...@radware.com> on 2021/11/08 11:25:50 UTC, 1 replies.
- [jira] [Created] (FLINK-24822) Improve CatalogTableSpecBase and its subclass method parameter - posted by "dalongliu (Jira)" <ji...@apache.org> on 2021/11/08 11:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24823) Yarn-session report metrics error - posted by "douyongpeng (Jira)" <ji...@apache.org> on 2021/11/08 11:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24824) AdaptiveScheduler#getJobStatus never returns CREATED - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/08 13:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24825) Update nifi-site-to-site-client to v1.14.0 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/11/08 14:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24826) Performance regression in HeapState benchmarks on Nov 8 2021 - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/11/08 15:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24827) Bump maven-dependency-plugin to v3.2.0 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/11/08 15:33:00 UTC, 0 replies.
- [NOTICE] Please keep flink-examples up to date - posted by Seth Wiesman <sj...@gmail.com> on 2021/11/08 15:34:42 UTC, 5 replies.
- [jira] [Created] (FLINK-24828) Bump Powermock to v2.0.9 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/11/08 15:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24829) Rename example directories based on API - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/11/08 15:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24830) Update DataStream WordCount example - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/11/08 15:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24831) Upgrade DataStream Window examples - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/11/08 15:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24832) Update JUnit5 to v5.8.1 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/11/08 15:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24833) Prevent use of deprecated APIs in flink-examples - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/11/08 19:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24834) Add typed builders to DefaultRollingPolicy - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/11/08 20:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24835) "group by" in the interval join will throw a exception - posted by "xuyang (Jira)" <ji...@apache.org> on 2021/11/09 03:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24836) Over window in month time calculated an incorrect aggregation result. - posted by "Carl (Jira)" <ji...@apache.org> on 2021/11/09 04:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24837) submit flink job failed via restapi - posted by "Spongebob (Jira)" <ji...@apache.org> on 2021/11/09 05:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24838) Add BaseAlgoImpl class to support link() and linkFrom() - posted by "Zhipeng Zhang (Jira)" <ji...@apache.org> on 2021/11/09 07:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24839) CsvFilesystemStreamSinkITCase.testPart times out on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/11/09 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24840) JobManagerHAProcessFailureRecoveryITCase crashed on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/11/09 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24841) ChainOrderTest.testMigrationAndRestore fails on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/11/09 08:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24842) Make outputs depends on tails for the iteration body - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/11/09 08:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24843) DynamicTableFactory.Context.getCatalogTable().getPartitionKeys() should return indexes - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/11/09 08:49:00 UTC, 0 replies.
- [DISCUSS] Should we go only with DateTimeFormatter in DateTimeUtils for DATE_FORMAT - posted by Sergey Nuyanzin <sn...@gmail.com> on 2021/11/09 08:57:45 UTC, 0 replies.
- [jira] [Created] (FLINK-24844) CassandraConnectorITCase.testCassandraBatchPojoFormat fails on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/11/09 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24845) Add allreduce utility function in FlinkML - posted by "Zhipeng Zhang (Jira)" <ji...@apache.org> on 2021/11/09 10:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24846) AsyncWaitOperator fails during stop-with-savepoint - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/11/09 11:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24847) Decide the overflows behaviour - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/11/09 11:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24848) Improve error codes for savepoint handlers - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/09 13:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24849) Only return stacktrace if RestHandlerException has a cause - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/09 14:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24850) KafkaSinkBuilder: NullPointerException if bootstrap.servers are defined via properties - posted by "Arseniy Tashoyan (Jira)" <ji...@apache.org> on 2021/11/09 19:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24851) KafkaSourceBuilder: auto.offset.reset is ignored - posted by "Arseniy Tashoyan (Jira)" <ji...@apache.org> on 2021/11/09 21:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24852) Cleanup of Orphaned Incremental State Artifacts - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2021/11/09 23:01:00 UTC, 0 replies.
- [VOTE] FLIP-188 Introduce Built-in Dynamic Table Storage - posted by Jingsong Li <ji...@gmail.com> on 2021/11/10 02:51:55 UTC, 15 replies.
- [jira] [Created] (FLINK-24853) Report errors if jobs using iteration has runtime mode set to BATCH - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/11/10 08:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24854) StateHandleSerializationTest unit test error - posted by "zlzhang0122 (Jira)" <ji...@apache.org> on 2021/11/10 08:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24855) Source Coordinator Thread already exists. There should never be more than one thread driving the actions of a Source Coordinator. - posted by "WangMinChao (Jira)" <ji...@apache.org> on 2021/11/10 09:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24856) Upgrade SourceReaderTestBase to Use Junit 5 - posted by "Yufei Zhang (Jira)" <ji...@apache.org> on 2021/11/10 09:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24857) Upgrade SourceReaderTestBase to Use Junit 5 - posted by "Yufei Zhang (Jira)" <ji...@apache.org> on 2021/11/10 09:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24858) TypeSerializer version mismatch during eagerly restore - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/11/10 10:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24859) Document new File formats - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2021/11/10 11:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24860) Fix the wrong position mappings in the Python UDTF - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/11/10 11:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24861) Flink MySQL Look cache update for empty hit - posted by "Gaurav Miglani (Jira)" <ji...@apache.org> on 2021/11/10 11:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24862) The user-defined hive udaf/udtf cannot be used normally in hive dialect - posted by "xiangqiao (Jira)" <ji...@apache.org> on 2021/11/10 12:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24863) Azure agents fail git checkout after agent update - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/10 13:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24864) Release TaskManagerJobMetricGroup with the last slot rather than task - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/11/10 14:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24865) Support MATCH_RECOGNIZE in Batch mode - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/11/10 15:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24866) AZP crashed in Post-job: Cache Maven local repo - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/11/10 15:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24867) E2e tests take longer than the maximum 310 minutes on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/11/10 15:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24868) Use custom serialization for storing checkpoint metadata in CompletedCheckpointStore - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/11/10 16:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24869) flink-core should be provided in flink-file-sink-common - posted by "Konstantin Gribov (Jira)" <ji...@apache.org> on 2021/11/11 00:18:00 UTC, 0 replies.
- [subscribe] - posted by Yufei Zhang <af...@gmail.com> on 2021/11/11 01:26:07 UTC, 1 replies.
- [jira] [Created] (FLINK-24870) Cannot cast "java.util.Date" to "java.time.Instant" - posted by "wangbaohua (Jira)" <ji...@apache.org> on 2021/11/11 02:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24871) Flink SQL hive reports IndexOutOfBoundsException when using trim in where clause - posted by "Liu (Jira)" <ji...@apache.org> on 2021/11/11 03:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24872) PulsarSourceITCase.testMultipleSplits failed on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/11/11 08:54:00 UTC, 0 replies.
- [DISCUSS] Improve the name and structure of job vertex and operator name for job - posted by "wenlong.lwl" <we...@gmail.com> on 2021/11/11 09:02:50 UTC, 27 replies.
- [jira] [Created] (FLINK-24873) 1.9 docs lack warning of being out-dated - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/11 09:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24874) Dropdown menu is not properly shown in UI - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/11/11 11:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24875) Distributed e2e tests across 2 profiles - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/11 11:56:00 UTC, 0 replies.
- [DISCUSS] Update Policy for old releases - posted by Piotr Nowojski <pn...@apache.org> on 2021/11/11 13:00:53 UTC, 12 replies.
- [jira] [Created] (FLINK-24876) Update documentation - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/11 13:34:00 UTC, 0 replies.
- Reserve FLIP numbers - posted by Dawid Wysakowicz <dw...@apache.org> on 2021/11/11 15:02:16 UTC, 1 replies.
- [jira] [Created] (FLINK-24877) Implicitly add time attributes for VALUES clause - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/11/11 15:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24878) Flink entropy injection not working - posted by "Kenny Ma (Jira)" <ji...@apache.org> on 2021/11/11 18:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24879) ReducingStateDescriptor Constructor forgets to check ReduceFunction instanceof RichFunction - posted by "bx123 (Jira)" <ji...@apache.org> on 2021/11/12 00:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24880) pyflink 官网demo运行报错OverflowError: timeout value is too large - posted by "wangdonglin (Jira)" <ji...@apache.org> on 2021/11/12 02:05:00 UTC, 0 replies.
- [ANNOUNCE] New Apache Flink Committer - Yangze Guo - posted by Xintong Song <to...@gmail.com> on 2021/11/12 02:10:43 UTC, 30 replies.
- [jira] [Created] (FLINK-24881) When the Source is back pressured, the checkpoint interval may not take effect - posted by "Zongwen Li (Jira)" <ji...@apache.org> on 2021/11/12 03:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24882) Make SQL format identifier NOT case-sensitive. - posted by "Moses (Jira)" <ji...@apache.org> on 2021/11/12 03:27:00 UTC, 0 replies.
- [ANNOUNCE] New Apache Flink Committer - Leonard Xu - posted by Jark Wu <im...@gmail.com> on 2021/11/12 04:12:21 UTC, 33 replies.
- [jira] [Created] (FLINK-24883) Use flink web ui to submit the jar throw Job client must be a CoordinationRequestGateway. This is a bug. - posted by "aresyhzhang (Jira)" <ji...@apache.org> on 2021/11/12 06:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24884) flink flame graph webui bug - posted by "jackylau (Jira)" <ji...@apache.org> on 2021/11/12 07:50:00 UTC, 0 replies.
- [DISCUSS] Conventions on assertions to use in tests - posted by Francesco Guardiani <fr...@ververica.com> on 2021/11/12 09:02:52 UTC, 12 replies.
- [jira] [Created] (FLINK-24885) ProcessElement Interface parameter Collector : java.lang.NullPointerException - posted by "wangbaohua (Jira)" <ji...@apache.org> on 2021/11/12 09:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24886) flink flame args bug, may we need to modify TimeUtils to supports m - posted by "jackylau (Jira)" <ji...@apache.org> on 2021/11/12 09:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24887) Retrying savepoints may cause early cluster shutdown - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/12 11:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24888) Run jobgraph deserialization in separate thread - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/12 13:54:00 UTC, 0 replies.
- Re: [DISCUSS] Creating an external connector repository - posted by Arvid Heise <ar...@apache.org> on 2021/11/12 14:39:01 UTC, 5 replies.
- [jira] [Created] (FLINK-24889) Flink SQL Client should print corrently multisets - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2021/11/12 18:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24890) FLIP-189: SQL Client Usability Improvements - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2021/11/12 21:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24891) PrometheusPushGatewayReporter support filter label keys - posted by "Echo Lee (Jira)" <ji...@apache.org> on 2021/11/15 00:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24892) FLIP-187: Adaptive Batch Job Scheduler - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2021/11/15 04:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24893) SQL Client prompt customisation - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2021/11/15 07:59:00 UTC, 0 replies.
- Re: Re: [VOTE] FLIP-173: Support DAG of algorithms - posted by Dong Lin <li...@gmail.com> on 2021/11/15 08:09:23 UTC, 0 replies.
- [jira] [Created] (FLINK-24894) Flink on k8s, open the HA mode based on KubernetesHaServicesFactory ,When I deleted the job, the config map created under the HA mechanism was not deleted. - posted by "john (Jira)" <ji...@apache.org> on 2021/11/15 08:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24895) SqlTimestampSerializer#deserialize forgets to fully read from source when the record is null. - posted by "bx123 (Jira)" <ji...@apache.org> on 2021/11/15 08:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24896) Failed to execute goal com.github.siom79.japicmp:japicmp-maven-plugin:0.11.0:cmp (default) on project flink-metrics-core - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/11/15 08:59:00 UTC, 0 replies.
- [DISCUSS] Allow user to unsubscribe by sending "Unsubscribe" directly to user mailing list - posted by Caizhi Weng <ts...@gmail.com> on 2021/11/15 09:07:39 UTC, 0 replies.
- [jira] [Created] (FLINK-24897) Enable application mode on YARN to use usrlib - posted by "Biao Geng (Jira)" <ji...@apache.org> on 2021/11/15 09:16:00 UTC, 0 replies.
- Re: Flink support for OrderedListState - posted by Jan Lukavský <je...@seznam.cz> on 2021/11/15 09:49:01 UTC, 2 replies.
- [jira] [Created] (FLINK-24898) Some further improvements of sort-shuffle - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2021/11/15 10:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24899) Enable data compression for blocking shuffle by default - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2021/11/15 10:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24900) Support to run multiple shuffle plugins in one session cluster - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2021/11/15 11:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24901) Some further improvements of the pluggable shuffle framework - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2021/11/15 11:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24902) Port boolean <-> numeric casting logic to CastRule - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/11/15 11:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24903) AdaptiveSchedulerTest.testJobStatusListenerNotifiedOfJobStatusChanges unstable - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/11/15 13:16:00 UTC, 0 replies.
- [ANNOUNCE] New Apache Flink Committer - Fabian Paul - posted by Arvid Heise <ar...@apache.org> on 2021/11/15 13:17:13 UTC, 26 replies.
- [jira] [Created] (FLINK-24904) Add documentation for KDS Async Sink - posted by "Zichen Liu (Jira)" <ji...@apache.org> on 2021/11/15 13:31:00 UTC, 0 replies.
- [ANNOUNCE] New Apache Flink Committer - Jing Zhang - posted by Timo Walther <tw...@apache.org> on 2021/11/15 13:39:47 UTC, 29 replies.
- [jira] [Created] (FLINK-24905) KDS implementation of Async Sink Table API - posted by "Zichen Liu (Jira)" <ji...@apache.org> on 2021/11/15 14:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24906) Improve CSV format handling and support - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/11/15 15:07:00 UTC, 0 replies.
- [DISCUSS] Definition of Done for Apache Flink - posted by Johannes Moser <jo...@ververica.com> on 2021/11/15 21:36:06 UTC, 11 replies.
- 1.15 release cycle feature overview - posted by Johannes Moser <jo...@ververica.com> on 2021/11/15 21:48:02 UTC, 0 replies.
- [jira] [Created] (FLINK-24907) Enable Side Output for late events on IntervalJoins - posted by "Andrew Straussman (Jira)" <ji...@apache.org> on 2021/11/15 22:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24908) Improve SQL Error description for SQL Client - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2021/11/15 22:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24909) SQL syntax highlighting in SQL Client - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2021/11/15 23:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24910) Propagate the Calcite parser config to SQL Client - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2021/11/15 23:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24911) Enable line numbers in SQL Client - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2021/11/15 23:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24912) Migrate state processor API to DataStream API - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/11/15 23:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24913) Upgrade KPL version in flink-connector-kinesis to support ARM - posted by "Melody (Jira)" <ji...@apache.org> on 2021/11/16 00:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24914) Support implicit type conversion in SQL like "select int_field = varchar_field" - posted by "xuyang (Jira)" <ji...@apache.org> on 2021/11/16 02:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24915) StreamElementSerializer#deserialize(StreamElement reuse, DataInputView source) forgets to handle tag == TAG_STREAM_STATUS - posted by "bx123 (Jira)" <ji...@apache.org> on 2021/11/16 05:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24916) AvroExternalJarProgramITCase JVM crash on Azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/11/16 06:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24917) YARNSessionFIFOSecuredITCase hangs on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/11/16 07:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24918) Support to specify the data dir for state benchmark - posted by "Aitozi (Jira)" <ji...@apache.org> on 2021/11/16 07:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24919) UnalignedCheckpointITCase hangs on Azure - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/11/16 08:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24920) Update README - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/11/16 08:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24921) FileSourceSplit should not be visible in the user API in ParquetColumnarRowInputFormat - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2021/11/16 08:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24922) Fix spelling errors in the word "parallism" - posted by "xiangqiao (Jira)" <ji...@apache.org> on 2021/11/16 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24923) Flink v1.13.2 restarts itself while Tenable Nessus Vulnerability scans the machines - posted by "ozan (Jira)" <ji...@apache.org> on 2021/11/16 11:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24924) TO_TIMESTAMP and TO_DATE should fail - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/11/16 12:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24925) SingleThreadAccessCheckingTypeSerializer#equals() evaluates wrong field. - posted by "bx123 (Jira)" <ji...@apache.org> on 2021/11/16 17:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24926) Key group is not in KeyGroupRange when joining two streams with table API - posted by "Hongbo (Jira)" <ji...@apache.org> on 2021/11/16 17:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24927) [Umbrella] Improvements for Flink UI - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/11/16 19:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24928) Improve type-safety in Flink UI - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/11/16 19:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24929) Kerberized YARN per-job on Docker test fails on Azure because of building image - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2021/11/17 02:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24930) Print Sink should also print the table identifier when output data - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/11/17 03:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24931) Remove deprecated/unused class files in flink-scala module. - posted by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2021/11/17 04:00:02 UTC, 0 replies.
- [ANNOUNCE] New Apache Flink Committer - Yingjie Cao - posted by Guowei Ma <gu...@gmail.com> on 2021/11/17 04:55:29 UTC, 16 replies.
- [jira] [Created] (FLINK-24932) Frocksdb cannot run on Apple M1 - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/11/17 06:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24933) Support ML Python API - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/11/17 07:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24934) Python CI job fails with exit code 143 - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/11/17 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24935) Python module failed to compile due to "Could not create local repository" - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/11/17 08:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24936) Python test_data_stream.py hangs on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/11/17 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24937) "kubernetes application HA test" hangs on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/11/17 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24938) Checkpoint cleaner is closed before checkpoints are discarded - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/11/17 09:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24939) Support 'SHOW CREATE CATALOG' syntax - posted by "Yubin Li (Jira)" <ji...@apache.org> on 2021/11/17 10:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24940) Docs about create Hive catalog via SQL CLI is out of date - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2021/11/17 11:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24941) Cannot report backpressure with DatadogReporter - posted by "Ori Popowski (Jira)" <ji...@apache.org> on 2021/11/17 12:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24942) Could not find any factory for identifier 'hive' that implements 'org.apache.flink.table.factories.DynamicTableFactory' in the classpath - posted by "JasonLee (Jira)" <ji...@apache.org> on 2021/11/17 13:21:00 UTC, 0 replies.
- [DISCUSS] FLIP-194: Introduce the JobResultStore - posted by David Morávek <dm...@apache.org> on 2021/11/17 17:04:29 UTC, 11 replies.
- [jira] [Created] (FLINK-24943) SequenceNumber class is not POJO type - posted by "Alexander Egorov (Jira)" <ji...@apache.org> on 2021/11/18 01:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24944) Flink job on k8s mode supports pod scheduling according to priority - posted by "john (Jira)" <ji...@apache.org> on 2021/11/18 01:50:00 UTC, 0 replies.
- [DISCUSS] Shall casting functions return null or throw exceptions for invalid input - posted by Caizhi Weng <ts...@gmail.com> on 2021/11/18 02:16:44 UTC, 13 replies.
- [jira] [Created] (FLINK-24945) The exception location on the WebUI should contain TM's ResourceID - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2021/11/18 06:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24946) KafkaSourceLegacyITCase.testBigRecordJob fails on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/11/18 07:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24947) Flink on k8s support HostNetWork model - posted by "liuzhuo (Jira)" <ji...@apache.org> on 2021/11/18 07:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24948) Special character in column names breaks JDBC statement parsing - posted by "Paul Lin (Jira)" <ji...@apache.org> on 2021/11/18 07:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24949) KafkaITCase.testBigRecordJob fails on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/11/18 07:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24950) Use Hive Dialect execute Hive DDL, But throw a NullPointerException - posted by "xiaojunchen (Jira)" <ji...@apache.org> on 2021/11/18 07:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24951) Allow watch bookmarks to mitigate frequent watcher rebuilding - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2021/11/18 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24952) Rowtime attributes must not be in the input rows of a regular join. As a workaround you can cast the time attributes of input tables to TIMESTAMP before - posted by "wangbaohua (Jira)" <ji...@apache.org> on 2021/11/18 09:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24953) Optime hive parallelism inference - posted by "xiangqiao (Jira)" <ji...@apache.org> on 2021/11/18 10:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24954) Reset read buffer request timeout on buffer recycling for sort-shuffle - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2021/11/18 10:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24955) Add One-hot Encoder to Flink ML - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2021/11/18 11:34:00 UTC, 0 replies.
- [GitHub] [flink-connectors] AHeise closed pull request #1: Fix tests - posted by GitBox <gi...@apache.org> on 2021/11/18 12:37:02 UTC, 0 replies.
- [jira] [Created] (FLINK-24956) SqlSnapshot throws NullPointerException when used in conjunction with CTE - posted by "Yuval Itzchakov (Jira)" <ji...@apache.org> on 2021/11/18 17:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24957) show `host:port` information in `subtasks` tab - posted by "Xianxun Ye (Jira)" <ji...@apache.org> on 2021/11/19 03:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24958) correct the example and link for temporal table function documentation - posted by "zoucao (Jira)" <ji...@apache.org> on 2021/11/19 03:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24959) Add a BitMap function to FlinkSQL - posted by "ZhuoYu Chen (Jira)" <ji...@apache.org> on 2021/11/19 06:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24960) YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots hangs on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/11/19 06:50:00 UTC, 0 replies.
- [DISCUSS] FLIP-193: Snapshots ownership - posted by Dawid Wysakowicz <dw...@apache.org> on 2021/11/19 07:19:49 UTC, 21 replies.
- [jira] [Created] (FLINK-24961) When the DDL statement is different from the actual schema in the database, ArrayIndexOutOfBoundsException will be reported - posted by "Fangliang Liu (Jira)" <ji...@apache.org> on 2021/11/19 08:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24962) The root cause of a failed job was hidden in certain cases - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/11/19 09:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24963) Remove the tail separator when outputting yarn queue names - posted by "Junfan Zhang (Jira)" <ji...@apache.org> on 2021/11/19 09:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24964) Upgrade frontend-maven-plugin to 1.11.0 - posted by "Maciej Bryński (Jira)" <ji...@apache.org> on 2021/11/19 09:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24965) Improper usage of Map.Entry after Entry Iterator.remove in TaskLocaStateStoreImpl#pruneCheckpoints - posted by "Gen Luo (Jira)" <ji...@apache.org> on 2021/11/19 09:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24966) Typo fix - posted by "jakevin (Jira)" <ji...@apache.org> on 2021/11/19 16:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24967) Make the IO pattern configureable in state benchmarks - posted by "Aitozi (Jira)" <ji...@apache.org> on 2021/11/21 09:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24968) "Flink over NAT end-to-end test" failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/11/21 11:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24969) pyflink/table/tests/test_pandas_udf.py hangs on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/11/21 11:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24970) FlinkKafkaProducerITCase testScaleUpAfterScalingDown Timeout expired after 60000 milliseconds while awaiting InitProducerId - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/11/21 11:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24971) Streaming File Sink s3 end-to-end test stalled on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/11/21 11:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24972) FlinkKafkaProducerITCase testScaleUpAfterScalingDown Timeout due to failed to complete checkpoint - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/11/21 11:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24973) flink registercachedfile example no effect - posted by "anigkus (Jira)" <ji...@apache.org> on 2021/11/21 12:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24974) test - posted by "Zunyao Mao (Jira)" <ji...@apache.org> on 2021/11/21 14:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24975) Add hooks and extension points to FlinkSQL - posted by "junbiao chen (Jira)" <ji...@apache.org> on 2021/11/22 03:33:00 UTC, 0 replies.
- Re: [VOTE] FLIP-175: Compose Estimator/Model/AlgoOperator from DAG of Estimator/Model/AlgoOperator - posted by Becket Qin <be...@gmail.com> on 2021/11/22 03:44:56 UTC, 3 replies.
- [DISCUSS] FLIP-190: Support Version Upgrades for Table API & SQL Programs - posted by Timo Walther <tw...@apache.org> on 2021/11/22 07:22:37 UTC, 9 replies.
- [jira] [Created] (FLINK-24976) sink utils not check the schema info between query and sink table - posted by "xiaodao (Jira)" <ji...@apache.org> on 2021/11/22 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24977) validatePKConstraints in KafkaDynamicTableFactory throws wrong exception message - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/11/22 09:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24978) Upgrade Asm to 9.2 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/22 10:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24979) Remove MaxPermSize configuration in HBase surefire config - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/22 10:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24980) Collect sizes of result partitions when tasks finish - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2021/11/22 10:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24981) Fix JDK12+ profile activations - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/22 10:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24982) File leak in AbstractRecoverableWriterTest - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/22 10:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24983) Upgrade surefire to 3.0.0-M5 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/22 10:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24984) Rename MAVEN_OPTS variable in azure yaml - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/22 10:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24985) LocalBufferPoolDestroyTest#isInBlockingBufferRequest does not work on Java 17 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/22 10:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24986) StateHandleSerializationTest fails on Java 17 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/22 10:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24987) Enhance ExternalizedCheckpointCleanup enum - posted by "Nicolaus Weidner (Jira)" <ji...@apache.org> on 2021/11/22 11:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24988) Upgrade lombok to 1.18.22 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/22 11:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24989) Upgrade shade-plugin to 3.2.4 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/22 11:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24990) LookupJoinITCase fails on Java 17 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/22 12:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24991) FlinkStatistic does not compile on later Scala versions - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/22 12:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24992) StreamingWithStateTestBase does not compile on later Scala versions - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/22 12:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24993) ExceptionUtils#isDirectOutOfMemoryError doesn't work on Java 17 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/22 13:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24994) WindowedStream#reduce(ReduceFunction function) gives useless suggestion when reducefunction is richfunction. - posted by "bx123 (Jira)" <ji...@apache.org> on 2021/11/22 13:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24995) EnumValueSerializerCompatibilityTest fails to compile on later Scala versions - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/22 13:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24996) Update CI image to contain Java 17 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/22 13:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24997) count(null) not supported in flink sql query - posted by "zouyunhe (Jira)" <ji...@apache.org> on 2021/11/22 13:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24998) SIGSEGV in Kryo / C2 CompilerThread on Java 17 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/22 13:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24999) flink-python doesn't work on Java 17 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/22 13:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25000) Scala 2.12.7 doesn't compile on Java 17 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/22 13:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25001) Zookeeper 3.4 fails on Java 17 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/22 13:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25002) Setup required --add-opens/--add-exports - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/22 14:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25003) RestClientTest#testConnectionTimeout fails on Java 17 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/22 14:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25004) Disable spotless on Java 17 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/22 14:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25005) Add java17-target profile - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/22 14:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25006) Investigate memory issues on CI - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/22 14:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25007) Session window with dynamic gap doesn't work - posted by "Ori Popowski (Jira)" <ji...@apache.org> on 2021/11/22 15:21:00 UTC, 0 replies.
- [DISCUSS] Deprecate Java 8 support - posted by Chesnay Schepler <ch...@apache.org> on 2021/11/22 15:28:04 UTC, 15 replies.
- [jira] [Created] (FLINK-25008) Improve behaviour of NotNullEnforcer when dropping records - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/11/22 17:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25009) Output slotSharingGroup as part of JsonGraph - posted by "Xinbin Huang (Jira)" <ji...@apache.org> on 2021/11/22 21:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25010) Speed up hive's createMRSplits by multi thread - posted by "Liu (Jira)" <ji...@apache.org> on 2021/11/23 04:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25011) Introduce VertexParallelismDecider - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2021/11/23 04:35:00 UTC, 0 replies.
- [VOTE][FLIP-195] Improve the name and structure of vertex and operator name for job - posted by "wenlong.lwl" <we...@gmail.com> on 2021/11/23 07:59:52 UTC, 13 replies.
- Re: [DISCUSS] FLIP-182: Watermark alignment - posted by Piotr Nowojski <pn...@apache.org> on 2021/11/23 08:31:25 UTC, 0 replies.
- [jira] [Created] (FLINK-25012) Cannot join hive tables with different column types - posted by "xiangqiao (Jira)" <ji...@apache.org> on 2021/11/23 09:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25013) flink pulsar connector cannot consume deferred messages - posted by "zhangjg (Jira)" <ji...@apache.org> on 2021/11/23 10:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25014) Table to DataStream conversion, wrong field order - posted by "Oliver Moser (Jira)" <ji...@apache.org> on 2021/11/23 11:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25015) job name should not always be `collect` submitted by sql client - posted by "KevinyhZou (Jira)" <ji...@apache.org> on 2021/11/23 12:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25016) Bump netty to 4.1.70 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/23 12:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25017) Drop Zookeeper 3.4 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/23 13:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25018) Upgrade Curator to 5.2.0 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/23 13:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25019) Incorrect netty shading prefix - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/23 13:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25020) FlinkSecurityManager can swallow exception - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/23 14:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25021) Source/Sink for Azure Data Explorer (ADX) - posted by "Xue Wang (Jira)" <ji...@apache.org> on 2021/11/23 16:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25022) ClassLoader leak with ThreadLocals on the JM when submitting a job through the REST API - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/11/23 16:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25023) ClassLoader leak on JM/TM through indirectly-started Hadoop threads out of user code - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/11/23 17:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25024) Add ChangelogBackend documentation - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/11/23 17:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25025) BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount failed on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/11/23 18:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25026) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/11/23 18:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25027) Allow GC of a finished job's JobMaster before the slot timeout is reached - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/11/23 19:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25028) java.lang.OutOfMemoryError: Java heap space - posted by "wangbaohua (Jira)" <ji...@apache.org> on 2021/11/24 02:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25029) Hadoop Caller Context Setting In Flink - posted by "刘方奇 (Jira)" <ji...@apache.org> on 2021/11/24 06:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25030) Unexpected record in KafkaSourceITCase$IntegrationTests.testMultipleSplits - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/11/24 08:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25031) Job finishes iff all job vertices finish - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2021/11/24 08:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25032) Allow to create execution vertices and execution edges lazily - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2021/11/24 08:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25033) Let some scheduler components updatable. - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2021/11/24 08:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25034) Support flexible number of subpartitions in IntermediateResultPartition - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2021/11/24 09:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25035) Shuffle Service Supports Consuming Subpartition Range - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2021/11/24 09:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25036) Introduce stage-wised scheduling strategy - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2021/11/24 09:13:00 UTC, 0 replies.
- [DISCUSS] Drop Zookeeper 3.4 - posted by Chesnay Schepler <ch...@apache.org> on 2021/11/24 09:18:27 UTC, 4 replies.
- Re: [DISCUSS] Automated architectural tests - posted by Ingo Bürk <in...@ververica.com> on 2021/11/24 09:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25037) Compilation of compile_cron_python_wheels failed on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/11/24 09:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25038) Refactor FlinkContainer to split JM and TMs into different containers and supports HA - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2021/11/24 09:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25039) AZP fails with license check - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/11/24 10:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25040) FlinkKafkaInternalProducerITCase.testInitTransactionId failed on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/11/24 11:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25041) E2E tar ball cache fails without error message if target directory not specified - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/11/24 11:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25042) Allow calls to @VisibleForTesting from inner classes - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/24 11:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25043) Allow calls to public @VisibleForTesting from the same package - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/24 12:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25044) Add More Unit Test For Pulsar Source - posted by "Yufei Zhang (Jira)" <ji...@apache.org> on 2021/11/24 12:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25045) Introduce AdaptiveBatchScheduler - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2021/11/24 12:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25046) Convert forward edge to rescale when using adapive batch scheduler - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2021/11/24 12:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25047) Resolve most (trivial) architectural violations in flink-table - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/11/24 15:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25048) 在某个option后设置watermark,如果这个option里面有 outputTag,则此outputTag 不会有数据输出,只会在主流输出数据 - posted by "xinli liang (Jira)" <ji...@apache.org> on 2021/11/24 16:22:00 UTC, 0 replies.
- [DISCUSS] Releasing Flink 1.14.1 - posted by Martijn Visser <ma...@ververica.com> on 2021/11/24 18:40:11 UTC, 6 replies.
- [jira] [Created] (FLINK-25049) sql-client.sh execute batch job in async mode failed with java.io.FileNotFoundException - posted by "macdoor615 (Jira)" <ji...@apache.org> on 2021/11/25 06:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25050) Translate "Metrics" page of "Operations" into Chinese - posted by "ZhiJie Yang (Jira)" <ji...@apache.org> on 2021/11/25 06:50:00 UTC, 0 replies.
- RocksDBMapState get the binary key bytes - posted by Zen4YYDS <ga...@163.com> on 2021/11/25 07:30:37 UTC, 1 replies.
- [jira] [Created] (FLINK-25051) Port raw <-> binary logic to CastRule - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/11/25 08:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25052) Port row to row cast logic to CastRule - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/11/25 08:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25053) Document how to use the usrlib to load code in the user code class loader - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/11/25 08:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25054) flink sql System (Built-in) Functions 【SHA2】,hashLength validation Unsurpport - posted by "chenbowen (Jira)" <ji...@apache.org> on 2021/11/25 09:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25055) Support listen and notify mechanism for PartitionRequest - posted by "Shammon (Jira)" <ji...@apache.org> on 2021/11/25 09:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25056) Modify Flink dashboard task manager page, "Path, ID" column,to support sorting by id. - posted by "john (Jira)" <ji...@apache.org> on 2021/11/25 10:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25057) Streaming File Sink writing to the HDFS - posted by "hanjie (Jira)" <ji...@apache.org> on 2021/11/25 10:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25058) Declared exceptions should be considered in architectural tests - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/11/25 10:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25059) Update code style guide to encourage usage of AssertJ - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/25 11:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25060) Replace DataType.projectFields with Projection type - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/11/25 11:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25061) Add assertj as dependency in flink-parent - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/11/25 11:24:00 UTC, 0 replies.
- 回复: RocksDBMapState get the binary key bytes - posted by Zen4YYDS <ga...@163.com> on 2021/11/25 12:52:01 UTC, 0 replies.
- [jira] [Created] (FLINK-25062) Implement all catalog methods for PostgresCatalog - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/11/25 13:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25063) Allow calls to @VisibleForTesting from enclosing class - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/25 15:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25064) Remove @VisibleForTesting from RestServerEndpoint#createUploadDir - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/25 15:09:00 UTC, 0 replies.
- [DISCUSS] PR component labeling - posted by Nicolaus Weidner <ni...@ververica.com> on 2021/11/25 15:12:26 UTC, 3 replies.
- [jira] [Created] (FLINK-25065) Update lookup document for mysql-connector - posted by "Gaurav Miglani (Jira)" <ji...@apache.org> on 2021/11/25 23:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25066) Support using multi hdfs namenode to resolved dependences when submitting job to yarn - posted by "jocean.shi (Jira)" <ji...@apache.org> on 2021/11/26 03:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25067) Correct the description of RocksDB's background threads - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/11/26 04:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25068) Show the maximum parallelism (number of key groups) of a job in Web UI - posted by "zlzhang0122 (Jira)" <ji...@apache.org> on 2021/11/26 07:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25069) YARNHighAvailabilityITCase.testJobRecoversAfterKillingTaskManager failed on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/11/26 08:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25070) FLIP-195: Improve the name and structure of vertex and operator name for job - posted by "Wenlong Lyu (Jira)" <ji...@apache.org> on 2021/11/26 08:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25071) Enable ParquetFileSystemITCase.testLimitableBulkFormat - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/11/26 08:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25072) Introduce description for operator - posted by "Wenlong Lyu (Jira)" <ji...@apache.org> on 2021/11/26 09:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25073) Introduce Tree Mode - posted by "Wenlong Lyu (Jira)" <ji...@apache.org> on 2021/11/26 09:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25075) Remove reflection to instantiate PlannerExpressionParser - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/11/26 09:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25074) Simplify name of window operators in DS by moving details to description - posted by "Wenlong Lyu (Jira)" <ji...@apache.org> on 2021/11/26 09:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25076) Simplify name of SQL operators - posted by "Wenlong Lyu (Jira)" <ji...@apache.org> on 2021/11/26 09:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25077) Postgresql connector fails in case column with nested arrays - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2021/11/26 09:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25078) An error is reported when the flink SQL connects to Phoenix - posted by "xinli liang (Jira)" <ji...@apache.org> on 2021/11/26 10:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25079) Add assertj assertions for table types - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/11/26 10:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25080) FutureUtils is located in flink-core whereas the corresponding test is still located in flink-runtime - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/11/26 11:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25081) When chaining an operator of a side output stream, the num records sent displayed on the dashboard is incorrect - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2021/11/26 12:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25082) RMQSource is not parallel - posted by "Mike Lynch (Jira)" <ji...@apache.org> on 2021/11/27 01:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25083) Flaky Test in RowTest - posted by "Minyang Ye (Jira)" <ji...@apache.org> on 2021/11/27 06:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25084) Field names must be unique. Found duplicates - posted by "Ivan Budanaev (Jira)" <ji...@apache.org> on 2021/11/28 11:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25085) Add a scheduled thread pool in JM and close it when job terminates - posted by "Shammon (Jira)" <ji...@apache.org> on 2021/11/29 03:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25086) Move resource timeout checkers in JM from akka executors to the dedicated thread pool - posted by "Shammon (Jira)" <ji...@apache.org> on 2021/11/29 04:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25087) Move heartbeats from akka to the dedicated thread pool in JM - posted by "Shammon (Jira)" <ji...@apache.org> on 2021/11/29 04:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25088) KafkaSinkITCase failed on azure due to Container did not start correctly - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/11/29 05:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25089) KafkaSourceITCase.testBasicRead hangs on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/11/29 05:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25090) Run the assertj conversion script to convert assertions - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/11/29 08:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25091) Official website document FileSink orc compression attribute reference error - posted by "XiangQianLiu (Jira)" <ji...@apache.org> on 2021/11/29 08:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25092) Implement retry function for Bash bashed Elasticsearch test - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/11/29 09:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25093) Implement retry function for Bash based Docker setup - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/11/29 09:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25094) The verify code in LatencyTrackingMapStateTest#verifyIterator is not actually executed - posted by "Jinzhong Li (Jira)" <ji...@apache.org> on 2021/11/29 09:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25095) org.apache.flink.table.planner.codegen.CodeGenException: Mismatch of function's argument data type 'BOOLEAN NOT NULL' and actual argument type 'BOOLEAN'. - posted by "xiangqiao (Jira)" <ji...@apache.org> on 2021/11/29 11:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25096) Issue in exceptions API(/jobs/:jobid/exceptions) in flink 1.13.2 - posted by "Mahima (Jira)" <ji...@apache.org> on 2021/11/29 13:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25097) Bug in inner join when the filter condition is boolean type - posted by "Chu Xue (Jira)" <ji...@apache.org> on 2021/11/29 14:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25098) Jobmanager CrashLoopBackOff in HA configuration - posted by "Adrian Vasiliu (Jira)" <ji...@apache.org> on 2021/11/29 20:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25099) flink on yarn Accessing two HDFS Clusters - posted by "chenqizhu (Jira)" <ji...@apache.org> on 2021/11/30 02:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25100) RMQSourceITCase failed on azure due to java.io.EOFException - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/11/30 05:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25101) FlinkKafkaProducerITCase.testMigrateFromAtLeastOnceToExactlyOnce failed due to - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/11/30 05:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25102) ParquetFileSystemITCase.testPartialDynamicPartition failed on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/11/30 06:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25103) KeyedBroadcastProcessFunction run set 6, parallelism ValueState variables A, could you tell me how to store in the six tasks A - posted by "wangbaohua (Jira)" <ji...@apache.org> on 2021/11/30 06:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25104) Kafka table source cannot be used as bounded - posted by "Hang Ruan (Jira)" <ji...@apache.org> on 2021/11/30 06:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25105) Enables final checkpoint by default - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/11/30 06:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25106) Support tombstone messages in FLINK's "kafka" connector - posted by "Varun Yeligar (Jira)" <ji...@apache.org> on 2021/11/30 08:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25107) GlueSchemaRegistryAvroKinesisITCase and GlueSchemaRegistryJsonKinesisITCase are skipped on AzureCI but fail when enabled - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/11/30 08:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25108) When the environment variable HADOOP_CONF_DIR flink kerberos authentication error is set - posted by "aresyhzhang (Jira)" <ji...@apache.org> on 2021/11/30 08:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25109) Update jline3 to 3.21.0 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2021/11/30 11:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25110) Flink SQL consumes Kafka up to a certain point in time - posted by "sky (Jira)" <ji...@apache.org> on 2021/11/30 11:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25111) Introduce config option, to keep previous behaviour - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/11/30 11:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25112) Remove TTL from e2e cache - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/11/30 13:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25113) Cleanup from Parquet and Orc the partition key handling logic - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/11/30 13:16:00 UTC, 0 replies.
- [ANNOUNCE] Open source of remote shuffle project for Flink batch data processing - posted by Yingjie Cao <ke...@gmail.com> on 2021/11/30 13:32:20 UTC, 2 replies.
- [jira] [Created] (FLINK-25114) Remove flink-scala dependency from flink-table-runtime - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/11/30 13:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-25115) Why Flink Sink operator metric numRecordsOut and numRecordsOutPerSecond always equal 0 - posted by "hjw (Jira)" <ji...@apache.org> on 2021/11/30 16:01:00 UTC, 0 replies.