You are viewing a plain text version of this content. The canonical link for it is here.
- Re: [ANNOUNCE] Apache Flink 1.14.0 released - posted by Leonard Xu <xb...@gmail.com> on 2021/10/01 02:20:12 UTC, 1 replies.
- Re: [DISCUSS] Releasing Flink 1.13.3 - posted by Leonard Xu <xb...@gmail.com> on 2021/10/01 02:32:14 UTC, 3 replies.
- [jira] [Created] (FLINK-24433) "No space left on device" in Azure e2e tests - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/10/01 06:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24434) PyFlink YARN per-job on Docker test fails on Azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/10/01 06:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24435) FsStateChangelogWriter#lastAppendedSequenceNumber return different seq number with no writes - posted by "Yuan Mei (Jira)" <ji...@apache.org> on 2021/10/01 07:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24436) FsStateChangelogWriter#lastAppendedSequenceNumber return different seq number with no writes - posted by "Yuan Mei (Jira)" <ji...@apache.org> on 2021/10/01 07:14:00 UTC, 0 replies.
- Re: The Apache Flink should pay more attention to ensuring API compatibility. - posted by Jark Wu <im...@gmail.com> on 2021/10/01 07:19:14 UTC, 7 replies.
- [jira] [Created] (FLINK-24437) Remove unhandled exception handler from CuratorFramework before closing it - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/10/01 08:15:00 UTC, 0 replies.
- Re: [Flink blogs] - posted by Etienne Chauchot <ec...@apache.org> on 2021/10/01 09:15:34 UTC, 0 replies.
- [jira] [Created] (FLINK-24438) Port Kinesis Source to new Source API (FLIP-27) - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/10/01 10:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24439) Introduce a CoordinatorStore - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/10/01 15:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24440) Announce and combine latest watermarks across SourceReaders - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/10/01 15:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24441) Block SourceReader when watermarks are out of alignment - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/10/01 15:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24442) Flink Queries Docs markup does not show escape ticks - posted by "Mans Singh (Jira)" <ji...@apache.org> on 2021/10/03 23:33:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-176: Unified Iteration to Support Algorithms (Flink ML) - posted by Yun Gao <yu...@aliyun.com.INVALID> on 2021/10/04 02:42:07 UTC, 3 replies.
- [jira] [Created] (FLINK-24443) IntervalJoinITCase.testRowTimeInnerJoinWithEquiTimeAttrs fail with output mismatch - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/10/04 07:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24444) OperatorCoordinatorSchedulerTest#shutdownScheduler fails with IllegalState - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/10/04 07:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24445) Move RPC System packaging to package phase - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/10/04 09:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24446) Casting from STRING to TIMESTAMP_TZ looses fractional seconds - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/10/04 10:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24447) Bundle netty in flink-shade-zookeeper 3.5+ - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/10/04 13:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24448) Tumbling Window Not working with EPOOCH Time converted using TO_TIMESTAMP_LTZ - posted by "Mehul Batra (Jira)" <ji...@apache.org> on 2021/10/04 15:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24449) PulsarSourceITCase>SourceTestSuiteBase.testTaskManagerFailure fails with record mismatch - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/10/05 07:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24450) OuterJoinITCase fails on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/10/05 07:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24451) Replace the scattered objects with encapsulated LeaderInformation in DefaultLeaderElectionService - posted by "Aitozi (Jira)" <ji...@apache.org> on 2021/10/05 07:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24452) Move REST API state into dispatcher - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/10/05 08:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24453) StaticFileServerHandler does not redirect - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/10/05 08:23:00 UTC, 0 replies.
- Cannot run Flink tests in Azure Pipeline - S3 credentials - posted by ta...@gmail.com on 2021/10/05 11:57:21 UTC, 0 replies.
- [jira] [Created] (FLINK-24454) Consolidate all CAST related test into the new CastFunctionITCase class - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/10/05 15:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24455) FallbackAkkaRpcSystemLoader can't run through with - posted by "Aitozi (Jira)" <ji...@apache.org> on 2021/10/05 16:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24456) Support bounded offset in the Kafka table connector - posted by "Haohui Mai (Jira)" <ji...@apache.org> on 2021/10/06 03:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24457) FileSourceTextLinesITCase.testContinuousTextFileSourceWithJobManagerFailover fails with NoSuchElement - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/10/06 06:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24458) ParquetFsStreamingSinkITCase fails with time out - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/10/06 06:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24459) Performance improvement of file sink on Nexmark - posted by "Alexander Trushev (Jira)" <ji...@apache.org> on 2021/10/06 07:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24460) Rocksdb Iterator Error Handling Improvement - posted by "Victor Xu (Jira)" <ji...@apache.org> on 2021/10/06 07:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24461) TableResult#print() should use internal data types - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/10/06 13:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24462) Refactor casting rules in a similar fashion to DataStructureConverter - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/10/06 13:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24463) job_name of metric does not support Chinese - posted by "macdoor615 (Jira)" <ji...@apache.org> on 2021/10/06 14:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24464) Metrics sometimes report negative backlog - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/10/06 23:24:00 UTC, 0 replies.
- unsubscribe (退订) - posted by 18717838093 <18...@126.com> on 2021/10/07 06:23:15 UTC, 1 replies.
- [jira] [Created] (FLINK-24465) Wrong javadoc and documentation for buffer timeout - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/10/07 07:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24466) Interval Join late events handling behaviour is not consistent - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/10/07 07:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24467) Set min and max buffer size even if the difference less than threshold - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/10/07 09:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24468) NPE when notifyNewBufferSize - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/10/07 09:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24469) Incorrect calcualtion of the buffer size in case of channel data skew - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/10/07 09:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24470) EMA for buffer debloat level - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/10/07 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24471) Add microbenchmark for throughput with debloating enabled - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/10/07 10:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24472) DispatcherTest is unstable - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/10/07 11:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24473) getString value from any datatype columns - posted by "Spongebob (Jira)" <ji...@apache.org> on 2021/10/07 13:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24474) Standalone clusters should bind to localhost by default - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/10/07 13:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24475) Remove no longer used NestedMap* classes - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/10/07 13:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24476) Rename all ElasticSearch to Elasticsearch (without camel case) - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2021/10/07 13:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24477) Add MongoDB sink - posted by "Nir Tsruya (Jira)" <ji...@apache.org> on 2021/10/07 20:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24478) gradle quickstart is out-of-date - posted by "David Anderson (Jira)" <ji...@apache.org> on 2021/10/08 00:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24479) Bug fix RocksIteratorWrapper#seekToLast method - posted by "xiangqiao (Jira)" <ji...@apache.org> on 2021/10/08 06:08:00 UTC, 0 replies.
- What's the purpose of uniqueId in FileWriterBucket - posted by wu shaoj <sh...@gmail.com> on 2021/10/08 06:11:36 UTC, 3 replies.
- [jira] [Created] (FLINK-24480) EqualiserCodeGeneratorTest fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/10/08 06:13:00 UTC, 0 replies.
- 退订 - posted by 王卫光 <wa...@stevegame.cn> on 2021/10/08 06:14:28 UTC, 3 replies.
- First contribution - FLINK-24389 - posted by Nikolay Izhikov <ni...@apache.org> on 2021/10/08 08:32:11 UTC, 2 replies.
- [jira] [Created] (FLINK-24481) Translit buffer debloater documenation to chinese - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/10/08 09:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24482) KafkaShuffleTestBase.testMetrics fails on Azure - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/10/08 09:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24483) Document what is Public API and what compatibility guarantees Flink is providing - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/10/08 10:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24485) COUNT(DISTINCT) should support binary field - posted by "Haohui Mai (Jira)" <ji...@apache.org> on 2021/10/08 11:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24484) Support manual cleanup of async operation results - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/10/08 11:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24487) Add DELETE endpoint for operation results - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/10/08 11:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24486) Configurable async operation result cache timeout - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/10/08 11:30:00 UTC, 0 replies.
- Flink Cassandra sink connector doesn't support Apache Cassandra 4.0 - posted by Purushotham Pushpavanthar <pu...@gmail.com> on 2021/10/08 14:12:09 UTC, 1 replies.
- [jira] [Created] (FLINK-24488) KafkaRecordSerializationSchemaBuilder does not forward timestamp - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/10/08 14:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24489) The size of entryCache in the SharedBuffer should be defined with a threshold - posted by "Roc Marshal (Jira)" <ji...@apache.org> on 2021/10/09 03:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24490) The sample code is wrong in Apache Kafka Connector page - posted by "JasonLee (Jira)" <ji...@apache.org> on 2021/10/09 04:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24491) ExecutionGraphInfo may not be archived when the dispatcher terminates - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2021/10/09 07:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24492) incorrect implicit type conversion between numeric and (var)char - posted by "xuyangzhong (Jira)" <ji...@apache.org> on 2021/10/09 09:48:00 UTC, 0 replies.
- Re: Create a public open GitHub org for Flink ecosystem projects. - posted by Becket Qin <be...@gmail.com> on 2021/10/09 10:30:23 UTC, 0 replies.
- Custom Sink Object attribute issue - posted by Jigar Gajjar <ji...@gmail.com> on 2021/10/09 15:40:48 UTC, 1 replies.
- [jira] [Created] (FLINK-24493) Introduce DemultiplexingSink - posted by "Rion Williams (Jira)" <ji...@apache.org> on 2021/10/09 19:26:00 UTC, 0 replies.
- [NOTICE] CiBot improvements - posted by Chesnay Schepler <ch...@apache.org> on 2021/10/10 08:56:05 UTC, 14 replies.
- [jira] [Created] (FLINK-24494) Avro conluent Resigry SQL not fails to write to the topic with schema with default value for int - posted by "Mahendran Ponnusamy (Jira)" <ji...@apache.org> on 2021/10/10 23:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24495) Python installdeps hangs - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/10/11 02:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24496) Querying job details in the REST API fails - posted by "Juha (Jira)" <ji...@apache.org> on 2021/10/11 05:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24497) Kafka metrics fetching throws IllegalStateException - posted by "Juha (Jira)" <ji...@apache.org> on 2021/10/11 05:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24498) KafkaShuffleITCase fails with "The topic metadata failed to propagate to Kafka broker" - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/10/11 06:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24499) OVER IGNORE NULLS support - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/10/11 07:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24500) Move SqlDateTimeUtils to table-common - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/10/11 07:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24501) Unexpected behavior of cumulate window aggregate for late event after recover from sp/cp - posted by "JING ZHANG (Jira)" <ji...@apache.org> on 2021/10/11 08:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24502) Automate updating of `MigrationVersion` and migration tests. - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/10/11 08:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24503) Security: native kubernetes exposes REST service via LoadBalancer in default - posted by "LI Zhennan (Jira)" <ji...@apache.org> on 2021/10/11 09:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24504) Flink udf common expression elimination - posted by "Lyn Zhang (Jira)" <ji...@apache.org> on 2021/10/11 09:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24505) org.apache.flink.runtime.leaderelection.ZooKeeperLeaderRetrievalConnectionHandlingTest - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/10/11 10:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24506) checkpoint directory is not configurable through the Flink configuration passed into the StreamExecutionEnvironment - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/10/11 11:04:00 UTC, 0 replies.
- [DISCUSS] Should TableResult implement JDK's Future? - posted by Francesco Guardiani <fr...@ververica.com> on 2021/10/11 13:25:49 UTC, 3 replies.
- [jira] [Created] (FLINK-24507) Cleanup all the various date/time/timestamp utils - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/10/11 13:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24508) Add ThrottledMapper in flink-examples - posted by "LI Zhennan (Jira)" <ji...@apache.org> on 2021/10/11 14:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24509) FlinkKafkaProducer example is not compiling due to incorrect constructer signature used - posted by "Ali Bahadir Zeybek (Jira)" <ji...@apache.org> on 2021/10/11 15:17:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-182: Watermark alignment - posted by akshay padmanabhan <ak...@gmail.com> on 2021/10/11 16:23:53 UTC, 0 replies.
- [jira] [Created] (FLINK-24510) Fix the duplicate log output of libraries/connectors，when logback is used - posted by "xiangqiao (Jira)" <ji...@apache.org> on 2021/10/12 03:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24511) "sink.parallelism" doesn't work for upsert "values" sink - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/10/12 04:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24512) Allow metadata columns can also be part of primary key - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/10/12 04:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24513) AkkaRpcSystemLoader must be an ITCase - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/10/12 07:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24514) Incorrect Flink Metrics on Job-Internal-Restart: - posted by "Alok Singh (Jira)" <ji...@apache.org> on 2021/10/12 12:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24515) MailboxExecutor#submit swallows exceptions - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/10/12 13:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24516) Modernize Maven Archetype - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/10/12 17:16:00 UTC, 0 replies.
- [VOTE] Release 1.13.3, release candidate #1 - posted by Chesnay Schepler <ch...@apache.org> on 2021/10/12 17:21:44 UTC, 7 replies.
- [jira] [Created] (FLINK-24517) Streamline Flink releases - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/10/12 19:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24518) Combine deployment of staging jars and binary release creation - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/10/12 19:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24519) Add release script for uplading release to SVN - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/10/12 19:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24520) Building of WebUI failed on Ubuntu 20 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/10/12 19:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24521) Add release script for Python wheel step - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/10/12 19:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24522) Remove spaces from python wheel azure artifacts - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/10/12 19:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24523) Extend GPG setup instructions - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/10/12 19:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24524) Rework release guide and scripts to be used from the root directory - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/10/12 19:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24525) Use different names for release branch and tags - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/10/12 19:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24526) Combine all environment variables into a single section - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/10/12 19:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24527) Add SqlUseDialect and UseDialectOperation - posted by "chouc (Jira)" <ji...@apache.org> on 2021/10/13 03:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24528) Flink HBase Asyc Lookup throw NPE if rowkey is null - posted by "zhisheng (Jira)" <ji...@apache.org> on 2021/10/13 03:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24529) flink sql job cannot use custom job name - posted by "simenliuxing (Jira)" <ji...@apache.org> on 2021/10/13 03:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24530) GlobalCommitter might not commit all records on drain - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/10/13 08:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24531) CheckpointingTimeBenchmark can fail with connection timed out - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/10/13 10:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24532) Invalid deletions for time-versioned join with ChangelogNormalize - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/10/13 12:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24533) Flink SQL Upsert To Hbase Appear data loss - posted by "licp (Jira)" <ji...@apache.org> on 2021/10/13 18:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24534) Set async based transport for remote functions default - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/10/13 18:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24535) Update with the latest AWS Glue Schema Registry version - posted by "Linyu Yao (Jira)" <ji...@apache.org> on 2021/10/13 21:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24536) flink sql where condition is not supported != writing - posted by "simenliuxing (Jira)" <ji...@apache.org> on 2021/10/14 02:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24537) Array of rows containing constant strings of different length and an integer throws AssertionError - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/10/14 03:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24538) ZooKeeperLeaderElectionTest.testLeaderShouldBeCorrectedWhenOverwritten fails with NPE - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/10/14 05:08:00 UTC, 0 replies.
- [DISCUSS] Over Aggregation add supports CURRENT_TIMESTAMP as the upper boundary in RANGE intervals . - posted by 林挺滨 <li...@gmail.com> on 2021/10/14 05:33:12 UTC, 0 replies.
- [jira] [Created] (FLINK-24539) ChangelogNormalize operator tooks too long time to INITIALIZING until failed - posted by "vmaster.cc (Jira)" <ji...@apache.org> on 2021/10/14 05:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24540) Fix Resocue leak due to Files.list - posted by "lujie (Jira)" <ji...@apache.org> on 2021/10/14 05:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24541) ConfigurationUtils#assembleDynamicConfigsStr should consider special characters - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2021/10/14 06:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24542) Expose the freshness metrics for kafka connector - posted by "zlzhang0122 (Jira)" <ji...@apache.org> on 2021/10/14 08:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24543) Zookeeper connection issue causes inconsistent state in Flink - posted by "Jun Qin (Jira)" <ji...@apache.org> on 2021/10/14 08:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24544) Failure when using Kafka connector in Table API with Avro and Confluent schema registry - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/10/14 09:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24545) job that read data from hive will finished even though i set streaming mode - posted by "linqichen (Jira)" <ji...@apache.org> on 2021/10/14 10:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24546) Acknowledged description miss on Monitoring Checkpointing page - posted by "camilesing (Jira)" <ji...@apache.org> on 2021/10/14 11:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24547) A function named row_kind() can get row_kind - posted by "jocean.shi (Jira)" <ji...@apache.org> on 2021/10/14 12:10:00 UTC, 0 replies.
- [Discussion] Avoid redundancy of Javadoc @return tag comment - posted by Jing Ge <ji...@ververica.com> on 2021/10/14 12:24:48 UTC, 4 replies.
- [jira] [Created] (FLINK-24548) flink-connector-jdbc SQLException retry sleep have a problem - posted by "chenxy (Jira)" <ji...@apache.org> on 2021/10/14 12:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24549) FlinkKinesisConsumer does not work with generic types disabled - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/10/14 12:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24550) Can not access job information from a standby jobmanager UI - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/10/14 13:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24551) BUFFER_DEBLOAT_SAMPLES property is taken from the wrong configuration - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/10/14 13:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24552) Ineffective buffer debloat configuration in randomized tests - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/10/14 14:00:03 UTC, 0 replies.
- [jira] [Created] (FLINK-24553) Change buffer debloating default configuration values - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/10/14 14:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24554) Support metadata columns for format-json - posted by "WangMinChao (Jira)" <ji...@apache.org> on 2021/10/15 02:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24555) Incorrectly put empty list to flink configuration - posted by "Junfan Zhang (Jira)" <ji...@apache.org> on 2021/10/15 02:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24556) Support Logistic Regression in FlinkML - posted by "Zhipeng Zhang (Jira)" <ji...@apache.org> on 2021/10/15 04:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24557) Support Knn in FlinkML - posted by "weibo zhao (Jira)" <ji...@apache.org> on 2021/10/15 04:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24558) dataStream can not use multiple classloaders - posted by "bai sui (Jira)" <ji...@apache.org> on 2021/10/15 04:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24559) flink-rpc-akka-loader does not bundle flink-rpc-akka - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/10/15 05:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24560) flink-yarn-tests should copy examples after package phase - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/10/15 05:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24561) Build archetype jars in compile phase - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/10/15 06:05:00 UTC, 0 replies.
- [VOTE] FLIP-174: Improve the WithParam interface - posted by Dong Lin <li...@gmail.com> on 2021/10/15 06:10:33 UTC, 0 replies.
- [VOTE] FLIP-175: Compose Estimator/Model/AlgoOperator from DAG of Estimator/Model/AlgoOperator - posted by Dong Lin <li...@gmail.com> on 2021/10/15 06:10:34 UTC, 0 replies.
- [jira] [Created] (FLINK-24562) YarnResourceManagerDriverTest should not use ContainerStatusPBImpl.newInstance - posted by "Feifan Wang (Jira)" <ji...@apache.org> on 2021/10/15 06:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24563) Comparing timstamp_ltz with result of date_format with specific format throws NullPointerException - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/10/15 07:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24564) Change the default compression to snappy for parquet, orc, avro in table - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/10/15 08:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24565) Port Avro FileSystemFormatFactory to StreamFormat - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/10/15 08:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24566) Remove CsvFileSystemFormatFactory - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/10/15 08:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24567) Support create tables using CatalogView defination - posted by "Xianxun Ye (Jira)" <ji...@apache.org> on 2021/10/15 11:00:00 UTC, 0 replies.
- Re: Beam with Flink runner - Issues when writing to S3 in Parquet Format - posted by Etienne Chauchot <ec...@apache.org> on 2021/10/15 11:02:47 UTC, 1 replies.
- [DISCUSS] Creating an external connector repository - posted by Arvid Heise <ar...@apache.org> on 2021/10/15 12:47:40 UTC, 23 replies.
- [jira] [Created] (FLINK-24568) Configuration equals method does not properly check equality - posted by "Jessie Anderson (Jira)" <ji...@apache.org> on 2021/10/15 15:51:00 UTC, 0 replies.
- dataStream can not use multiple classloaders - posted by 百岁 <ba...@dingtalk.com.INVALID> on 2021/10/16 05:56:18 UTC, 2 replies.
- [jira] [Created] (FLINK-24569) Flaky Test in NFATest - posted by "Hang Xie (Jira)" <ji...@apache.org> on 2021/10/18 00:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24570) Flaky Test in NFATest - posted by "Hang Xie (Jira)" <ji...@apache.org> on 2021/10/18 00:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24571) elasticsearch dynamic index support the use of proctime - posted by "jinfeng (Jira)" <ji...@apache.org> on 2021/10/18 02:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24572) Properly set the context ClassLoader when calling OperatorCoordinator on JM side - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/10/18 03:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24573) ZooKeeperJobGraphsStoreITCase crashes JVM - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/10/18 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24574) Allow metrics to be removed in UDFs - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/10/18 11:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24575) Port TestCsvFileSystemFormatFactory to DeserializationSchema - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/10/18 12:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24576) Drop support for casting decimal numerics to boolean - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/10/18 13:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24577) Support cast from BINARY/VARBINARY/BYTES to of RAW() - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/10/18 13:52:00 UTC, 0 replies.
- [DISCUSS] Should we drop Row SerializationSchema/DeserializationSchema? - posted by Francesco Guardiani <fr...@ververica.com> on 2021/10/18 15:42:53 UTC, 4 replies.
- [jira] [Created] (FLINK-24578) Unexpected erratic load shape for channel skew load profile - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/10/18 16:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24579) FlinkSQL does not print correctly content of arrays nested into maps - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2021/10/18 16:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24580) Kinesis connect time out error is not handled as recoverable - posted by "John Karp (Jira)" <ji...@apache.org> on 2021/10/18 22:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24581) compatible uname command with multiple OS on ARM platform - posted by "zhao bo (Jira)" <ji...@apache.org> on 2021/10/19 01:05:00 UTC, 0 replies.
- 回复：dataStream can not use multiple classloaders - posted by 百岁 <ba...@dingtalk.com.INVALID> on 2021/10/19 01:45:12 UTC, 0 replies.
- [jira] [Created] (FLINK-24582) PrometheusReporterEndToEndITCase fails due to timeout - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/10/19 02:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24583) ElasticsearchWriterITCase.testWriteOnBulkIntervalFlush timeout on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/10/19 03:01:00 UTC, 0 replies.
- Multiple View Creation support - posted by "Hugar, Mahesh" <Ma...@harman.com.INVALID> on 2021/10/19 05:21:13 UTC, 1 replies.
- [jira] [Created] (FLINK-24584) ClientTest.testRequestUnavailableHost fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/10/19 05:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24585) Print the change in the size of the compacted files - posted by "Yubin Li (Jira)" <ji...@apache.org> on 2021/10/19 06:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24586) SQL functions should return STRING instead of VARCHAR(2000) - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/10/19 07:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24587) Let PubSub source support changing subscriptions - posted by "Shiao-An Yuan (Jira)" <ji...@apache.org> on 2021/10/19 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24588) Optimisation of chained cast calls can lead to unexpected behaviour - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/10/19 08:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24589) FLIP-183: Buffer debloating 1.2 - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/10/19 08:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24590) Consider removing timeout from FlinkMatchers#futureWillCompleteExceptionally - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/10/19 08:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24591) Kafka Producer fails with SecurityException when using cluster.intercept-user-system-exit - posted by "Krzysztof Dziolak (Jira)" <ji...@apache.org> on 2021/10/19 09:42:00 UTC, 0 replies.
- [RESULT][VOTE] Release 1.13.3, release candidate #1 - posted by Chesnay Schepler <ch...@apache.org> on 2021/10/19 13:03:42 UTC, 1 replies.
- [jira] [Created] (FLINK-24593) Create Table API Quickstart - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/10/19 13:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24592) FlinkSQL multiline parser improvements - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2021/10/19 13:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24594) /jobs endpoint returns same job id twice (suspended and running) until stopped - posted by "Azocan Kara (Jira)" <ji...@apache.org> on 2021/10/19 14:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24595) Programmatic configuration of S3 doesn't pass parameters to Hadoop FS - posted by "Pavel Penkov (Jira)" <ji...@apache.org> on 2021/10/19 17:37:00 UTC, 0 replies.
- One week until Flink Forward! -- Info & special announcements - posted by Caito Scherr <ca...@ververica.com> on 2021/10/20 00:45:48 UTC, 0 replies.
- [jira] [Created] (FLINK-24596) Bugs in sink.buffer-flush before upsert-kafka - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/10/20 03:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24597) RocksdbStateBackend getKeysAndNamespaces would return duplicate data when using MapState - posted by "Yue Ma (Jira)" <ji...@apache.org> on 2021/10/20 06:44:00 UTC, 0 replies.
- [DISCUSS] FLIP-187: Adaptive Batch Job Scheduler - posted by Lijie Wang <wa...@gmail.com> on 2021/10/20 06:52:32 UTC, 3 replies.
- [jira] [Created] (FLINK-24598) Current IT case do not cover fallback path for hash aggregate - posted by "Shuo Cheng (Jira)" <ji...@apache.org> on 2021/10/20 07:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24599) Make checking for type root and family less verbose - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/10/20 07:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24600) job checkpoint page has two p99 which is duplicated - posted by "donglei (Jira)" <ji...@apache.org> on 2021/10/20 08:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24601) Error in submitting the job - posted by "Shyam (Jira)" <ji...@apache.org> on 2021/10/20 08:36:00 UTC, 0 replies.
- [DISCUSS] FLIP-188: Introduce Built-in Dynamic Table Storage - posted by Jingsong Li <ji...@gmail.com> on 2021/10/20 09:13:57 UTC, 9 replies.
- [jira] [Created] (FLINK-24602) Include diffs for configuration documentation page - posted by "Zichen Liu (Jira)" <ji...@apache.org> on 2021/10/20 11:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24603) Add E2E test - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/10/20 12:03:00 UTC, 0 replies.
- Looking back at the Apache Flink 1.14 development cycle / getting better for 1.15 - posted by Johannes Moser <jo...@ververica.com> on 2021/10/20 13:51:42 UTC, 0 replies.
- [jira] [Created] (FLINK-24604) Failing tests for casting decimals to boolean - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/10/20 14:56:00 UTC, 0 replies.
- "streaming.tests.avro does not exist" - posted by Saad Ur Rahman <sa...@gmail.com> on 2021/10/20 18:16:08 UTC, 3 replies.
- [jira] [Created] (FLINK-24605) org.apache.flink.kafka.shaded.org.apache.kafka.clients.consumer.NoOffsetForPartitionException: Undefined offset with no reset policy for partitions - posted by "Abhijit Talukdar (Jira)" <ji...@apache.org> on 2021/10/20 22:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24606) AvroDeserializationSchema buffer is not clean - posted by "heyu dou (Jira)" <ji...@apache.org> on 2021/10/21 03:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24607) SourceCoordinator may miss to close SplitEnumerator when failover frequently - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/10/21 03:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24608) Sinks built with the unified sink framework do not receive timestamps when used in Table API - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/10/21 06:47:00 UTC, 0 replies.
- [VOTE] FLIP-176: Unified Iteration to Support Algorithms (Flink ML) - posted by Yun Gao <yu...@aliyun.com.INVALID> on 2021/10/21 07:57:42 UTC, 5 replies.
- [ANNOUNCE] Apache Flink 1.13.3 released - posted by Chesnay Schepler <ch...@apache.org> on 2021/10/21 08:29:45 UTC, 9 replies.
- [jira] [Created] (FLINK-24609) flink-rpc-akka uses wrong Scala version property for parser-combinators - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/10/21 08:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24610) Flink projection common expression elimination - posted by "Lyn Zhang (Jira)" <ji...@apache.org> on 2021/10/21 08:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24611) Prevent JM from discarding state on checkpoint abortion - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/10/21 12:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24612) Kafka test container creates a large amount of logs - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/10/21 13:57:00 UTC, 0 replies.
- Disable usage of TumblingEventTimeWindows when EventTime is disabled? - posted by Dario Heinisch <da...@gmail.com> on 2021/10/21 14:40:09 UTC, 2 replies.
- [jira] [Created] (FLINK-24613) Documentation on orc supported data types is outdated - posted by "sujun (Jira)" <ji...@apache.org> on 2021/10/22 02:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24614) Add array,map,row types support for parquet vectorized reader - posted by "sujun (Jira)" <ji...@apache.org> on 2021/10/22 02:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24615) Add infrastructure to support metadata in filesystem connector - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/10/22 06:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24616) Expose all metadata in FileStatus - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/10/22 06:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24617) Support partition keys through metadata - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/10/22 07:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24618) FlinkChillPackageRegistrar and PriorityQueueSerializer are located in wrong package - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/10/22 07:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24619) rabbit not support " at least once " - posted by "szd (Jira)" <ji...@apache.org> on 2021/10/22 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24620) Add partition discovery for kafka sink when `sink.partitioner`= 'fix' - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2021/10/22 09:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24621) JobManager fails to recover 1.13.1 checkpoint due to InflightDataRescalingDescriptor - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/10/22 14:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24622) Unified sources do not close scheduled threads from SplitEnumeratorContext#callAsync() - posted by "Mason Chen (Jira)" <ji...@apache.org> on 2021/10/22 15:48:00 UTC, 0 replies.
- Shading in flink-table-blink and upgrade compatibility issue - posted by Thomas Weise <th...@apache.org> on 2021/10/22 22:59:11 UTC, 2 replies.
- [jira] [Created] (FLINK-24623) Prevent usage of EventTimeWindows when EventTime is disabled - posted by "Dario Heinisch (Jira)" <ji...@apache.org> on 2021/10/23 13:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24624) Add clean up phase when kubernetes session start failed - posted by "Aitozi (Jira)" <ji...@apache.org> on 2021/10/24 09:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24625) Expose the required kubernetes permission from the shell command - posted by "Aitozi (Jira)" <ji...@apache.org> on 2021/10/24 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24626) Flink JDBC Sink may lose data in retract stream - posted by "Kenyore (Jira)" <ji...@apache.org> on 2021/10/25 02:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24627) Add some generic junit5 extensions to replace junit4 rules - posted by "Hang Ruan (Jira)" <ji...@apache.org> on 2021/10/25 03:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24628) Invalid JDBC query template when no fields are selected - posted by "Paul Lin (Jira)" <ji...@apache.org> on 2021/10/25 07:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24629) Sorting start-time/duration/end-time not working under pages of vertex taskManagers and sub-tasks - posted by "Junhan Yang (Jira)" <ji...@apache.org> on 2021/10/25 08:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24630) Implement row projection in AvroToRowDataConverters#createRowConverter - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/10/25 09:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24631) Avoiding directly use the labels as selector for deployment and service - posted by "Aitozi (Jira)" <ji...@apache.org> on 2021/10/25 10:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24632) "where ... in(..)" has wrong result - posted by "xuyang (Jira)" <ji...@apache.org> on 2021/10/25 12:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24633) JobManager pod may stuck in containerCreating status during failover - posted by "Aitozi (Jira)" <ji...@apache.org> on 2021/10/25 13:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24634) Java 11 profile should target JDK 8 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/10/25 14:48:00 UTC, 0 replies.
- [Discuss] Planning Flink 1.15 - posted by Johannes Moser <jo...@ververica.com> on 2021/10/25 15:11:44 UTC, 5 replies.
- [jira] [Created] (FLINK-24635) Clean up flink-examples - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/10/25 17:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24636) Move cluster deletion operation cache into ResourceManager - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/10/25 20:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24637) Move savepoint disposal operation cache into Dispatcher - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/10/25 20:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24638) Unknown variable or type "org.apache.flink.table.utils.DateTimeUtils" - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2021/10/25 20:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24639) Improve assignment of Kinesis shards to subtasks - posted by "John Karp (Jira)" <ji...@apache.org> on 2021/10/25 22:21:00 UTC, 0 replies.
- [NOTICE] flink-streaming-java no longer depends on Scala and lost it's suffix - posted by Chesnay Schepler <ch...@apache.org> on 2021/10/25 23:04:18 UTC, 4 replies.
- [jira] [Created] (FLINK-24640) CEIL, FLOOR built-in functions for Timestamp should respect DST - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2021/10/26 00:28:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-176: Unified Iteration to Support Algorithms (Flink ML) - posted by Yun Gao <yu...@aliyun.com.INVALID> on 2021/10/26 09:18:54 UTC, 0 replies.
- [jira] [Created] (FLINK-24641) Flink SQL FileSystem read hdfs Path, when Path's file name change, the sql will not find the file. - posted by "Hadiiiiiiiii (Jira)" <ji...@apache.org> on 2021/10/26 09:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24642) Implements unified iteration to support algorithms in flink-ml - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/10/26 09:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24643) Introduce the flink-ml-iteration module and iteration api - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/10/26 09:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24644) Introduce Add broadcast output to broadcast events to all the downstream tasks - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/10/26 09:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24645) Implements the feedback mechanism and the controller operators - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/10/26 09:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24646) Add operator wrapper for all-round iterations - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/10/26 09:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24647) ClusterUncaughtExceptionHandler does not log the exception - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/10/26 09:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24648) Ceil, floor for some timeunit return wrong results or fail with CompileException - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2021/10/26 11:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24649) Add DraftExecutionEnvironment to support wrapping operators during compile time - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/10/26 11:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24650) Support unbounded iteration. - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/10/26 11:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24651) Support bounded all-round iteration - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/10/26 11:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24652) Add operator wrapper for per-round operators - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/10/26 11:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24653) Support per-round operators inside the iteration. - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/10/26 11:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24654) NPE on RetractableTopNFunction when some records were cleared by state ttl - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2021/10/26 11:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24655) Support checkpoint for jobs using iteration - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/10/26 11:30:00 UTC, 0 replies.
- Flink sql client usability improvements - posted by Sergey Nuyanzin <sn...@gmail.com> on 2021/10/26 12:09:30 UTC, 3 replies.
- [jira] [Created] (FLINK-24656) Add user document for Window Deduplication - posted by "JING ZHANG (Jira)" <ji...@apache.org> on 2021/10/26 12:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24657) Add metric of the total real size of input/output buffers queue - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/10/26 15:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24658) Debug logs for buffer size calculation - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/10/26 15:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24659) Two active miniCluster in RemoteBenchmarkBase - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/10/26 15:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24660) Allow setting KafkaSubscriber in KafkaSourceBuilder - posted by "Mason Chen (Jira)" <ji...@apache.org> on 2021/10/27 00:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24661) ConfigOption add isSecret method to judge sensitive options - posted by "Ada Wong (Jira)" <ji...@apache.org> on 2021/10/27 02:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24662) PyFlink sphinx check failed with "node class 'meta' is already registered, its visitors will be overridden" - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/10/27 03:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24663) PyFlink failed to get the site packege path because of no quote in shell command - posted by "jackwangcs (Jira)" <ji...@apache.org> on 2021/10/27 06:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24664) Support merge for JSON_ARRAYAGG - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/10/27 06:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24665) Update Presto Hadoop dependency to latest version - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/10/27 07:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24666) The lenient option was not exposed to users on RetractableTopNFunction - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2021/10/27 08:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24667) Channel state writer would fail the task directly if meeting exception previously - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/10/27 09:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24668) Pulsar consumption data repeated output - posted by "jiayue.yu (Jira)" <ji...@apache.org> on 2021/10/27 10:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24669) Can't import all release-signing keys - posted by "Bob (Jira)" <ji...@apache.org> on 2021/10/27 10:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24670) Restructure unaligned checkpoints documentation page to "Checkpointing under back pressure" - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/10/27 14:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24671) Possible NPE in LocalInputChannel#getBuffersInUseCount before initialization of subpartitionView - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/10/27 16:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24672) [ WARN ] javax.management.InstanceAlreadyExistsException - posted by "qinghuan wang (Jira)" <ji...@apache.org> on 2021/10/27 17:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24673) Deprecate old Row SerializationSchema/DeserializationSchema - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/10/27 18:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24674) Create corresponding resouces for task manager Pods - posted by "L. C. Hsieh (Jira)" <ji...@apache.org> on 2021/10/27 19:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24675) org.apache.flink.formats.parquet.ParquetMapInputFormat the Constructor has no MessageType will throw an exception. - posted by "Hadiiiiiiiii (Jira)" <ji...@apache.org> on 2021/10/28 01:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24676) Schema does not match if explain insert statement with partial column - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/10/28 02:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24677) JdbcBatchingOutputFormat should not generate circulate chaining of exceptions when flushing fails in timer thread - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/10/28 02:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24678) Correct the metric name of map state contains latency - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/10/28 06:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24679) Configuration parsing exceptions may leak sensitive data - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/10/28 07:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24680) Expose UserCodeClassLoader in OperatorCoordinator.Context for registering release hooks - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2021/10/28 08:38:00 UTC, 0 replies.
- [DISCUSS] FLIP-189: SQL Client Usability Improvements - posted by Sergey Nuyanzin <sn...@gmail.com> on 2021/10/28 09:01:31 UTC, 3 replies.
- [jira] [Created] (FLINK-24681) org.apache.kafka.clients.consumer.NoOffsetForPartitionException: Undefined offset with no reset policy for partitions - posted by "qinghuan wang (Jira)" <ji...@apache.org> on 2021/10/28 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24682) Unify the -C option behavior in both yarn application and per-job mode - posted by "Biao Geng (Jira)" <ji...@apache.org> on 2021/10/28 11:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24683) Add Support for Azure Synapse Analytics - posted by "Israel Ekpo (Jira)" <ji...@apache.org> on 2021/10/28 14:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24684) Port to string casting rules to the new CastRule interface - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/10/28 15:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24685) Use the new casting rules in TableResult#print - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/10/28 15:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24686) Make doc clear on AsyncFunction::timeout() overriding - posted by "Jun Qin (Jira)" <ji...@apache.org> on 2021/10/28 20:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24687) flink-table uber jar should not include flink-connector-files dependency - posted by "Thomas Weise (Jira)" <ji...@apache.org> on 2021/10/28 20:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24688) yarn.application-attempt-failures-validity-interval link url is invalid - posted by "baizhendong (Jira)" <ji...@apache.org> on 2021/10/29 02:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24689) Add log file's time info in loglist - posted by "Fei Feng (Jira)" <ji...@apache.org> on 2021/10/29 05:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24690) Clarification of buffer size threshold calculation in BufferDebloater - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/10/29 06:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24691) FLINK SQL SUM() causes a precision error - posted by "Zongwen Li (Jira)" <ji...@apache.org> on 2021/10/29 06:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24692) kubernetes session mode deployment failed since slot allocation timeout - posted by "Zhou Parker (Jira)" <ji...@apache.org> on 2021/10/29 07:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24693) Update Chinese version of "Checkpoints" page - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/10/29 07:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24694) Translate "Checkpointing under backpressure" page into Chinese - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/10/29 07:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24695) Update how to configure unaligned checkpoints in the documentation - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/10/29 07:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24696) Translate how to configure unaligned checkpoints into Chinese - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/10/29 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24697) Kafka table source cannot change the auto.offset.reset setting - posted by "Hang Ruan (Jira)" <ji...@apache.org> on 2021/10/29 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24698) Unified operator used in transformation - posted by "jianzhang.yjz (Jira)" <ji...@apache.org> on 2021/10/29 08:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24699) Move scalastyle execution to validation phase - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/10/29 08:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24700) Clarify semantics of filter, projection, partition, and metadata pushdown - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/10/29 08:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24701) "late events" link in "Timely Stream Processing" document is not working - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/10/29 09:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24702) toUpperCase/toLowerCase calls may cause problems with some system locales - posted by "Mathias Fußenegger (Jira)" <ji...@apache.org> on 2021/10/29 10:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24703) Add support for reading CSV files based on StreamFormat (new file source API) - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2021/10/29 10:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24704) Exception occurs when the input record loses monotonicity on the sort key field of UpdatableTopNFunction - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2021/10/29 12:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24705) Flink blood relationship - posted by "HideOnBush (Jira)" <ji...@apache.org> on 2021/10/29 12:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24706) AkkaInvocationHandler silently ignores deserialization errors - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/10/29 12:31:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-174: Improve the WithParam interface (Flink ML) - posted by Becket Qin <be...@gmail.com> on 2021/10/29 12:49:02 UTC, 1 replies.
- [jira] [Created] (FLINK-24707) Upgrade Curator framework dependecy. - posted by "David Morávek (Jira)" <ji...@apache.org> on 2021/10/29 13:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24708) `ConvertToNotInOrInRule` has a bug which leads to wrong result - posted by "JING ZHANG (Jira)" <ji...@apache.org> on 2021/10/29 15:59:00 UTC, 0 replies.
- Issue in deploying Flink application in AKS 1.21 - posted by "Sekaran, Sreedeepa" <sr...@westpac.com.au> on 2021/10/30 03:38:54 UTC, 0 replies.
- [jira] [Created] (FLINK-24709) Fix the issue of interval join java case content in the official document case - posted by "XiaShengSheng (Jira)" <ji...@apache.org> on 2021/10/31 17:17:00 UTC, 0 replies.