You are viewing a plain text version of this content. The canonical link for it is here.
- OutOfMemory Failure on Savepoint - posted by Abhishek SP <ab...@gmail.com> on 2021/07/01 03:01:26 UTC, 1 replies.
- Re: Jobmanagers are in a crash loop after upgrade from 1.12.2 to 1.13.1 - posted by Zhu Zhu <re...@gmail.com> on 2021/07/01 03:14:07 UTC, 2 replies.
- Re: Converting Table API query to Datastream API - posted by JING ZHANG <be...@gmail.com> on 2021/07/01 03:14:08 UTC, 1 replies.
- Re: Regarding state access in UDF - posted by Kai Fu <zz...@gmail.com> on 2021/07/01 03:16:50 UTC, 2 replies.
- How to calculate how long an event stays in flink? - posted by xm lian <li...@gmail.com> on 2021/07/01 06:06:12 UTC, 2 replies.
- specify number of TM; how stream app use state of batch app; orc / parquet file format have different impact on tpcds performance benchmark. - posted by vtygoss <vt...@126.com> on 2021/07/01 07:49:12 UTC, 1 replies.
- Re: Exception in snapshotState suppresses subsequent checkpoints - posted by Matthias Pohl <ma...@ververica.com> on 2021/07/01 08:41:04 UTC, 2 replies.
- Re: Job Recovery Time on TM Lost - posted by Till Rohrmann <tr...@apache.org> on 2021/07/01 08:49:05 UTC, 17 replies.
- Re: [DISCUSS] Better user experience in the WindowAggregate upon Changelog (contains update message) - posted by Jark Wu <im...@gmail.com> on 2021/07/01 13:20:37 UTC, 2 replies.
- Re: Recommended way to submit a SQL job via code without getting tied to a Flink version? - posted by Sonam Mandal <so...@linkedin.com> on 2021/07/01 14:35:26 UTC, 0 replies.
- Using Flink's Kubernetes API inside Java - posted by Alexis Sarda-Espinosa <al...@microfocus.com> on 2021/07/01 17:48:27 UTC, 5 replies.
- Memory usage UI - posted by Sudharsan R <su...@gmail.com> on 2021/07/01 18:34:17 UTC, 3 replies.
- owasp-dependency-check is flagging flink 1.13 for scala 2.12.7 - posted by Debraj Manna <su...@gmail.com> on 2021/07/02 12:10:38 UTC, 4 replies.
- Memory Usage - Total Memory Usage on UI and Metric - posted by bat man <ti...@gmail.com> on 2021/07/02 15:36:50 UTC, 2 replies.
- Re: Flink State Processor API Example - Java - posted by Sandeep khanzode <sa...@shiftright.ai> on 2021/07/02 16:42:03 UTC, 1 replies.
- Understanding recovering from savepoint / checkpoint with additional operators when chaining - posted by Jiahui Jiang <qz...@hotmail.com> on 2021/07/02 17:51:50 UTC, 5 replies.
- Re: Corrupted unaligned checkpoints in Flink 1.11.1 - posted by Alexander Filipchik <af...@gmail.com> on 2021/07/03 21:38:43 UTC, 1 replies.
- Flink Issues facing while connecting to Azure Blob Storage - posted by "Singh Simarpreet (SX/EAA2)" <Si...@bosch.com> on 2021/07/04 18:03:31 UTC, 2 replies.
- Flink 1.13 fails to load log4j2 yaml configuration file via jackson-dataformat-yaml - posted by Yuval Itzchakov <yu...@gmail.com> on 2021/07/04 19:44:50 UTC, 12 replies.
- Unsubscribe - posted by Dan Pettersson <da...@gmail.com> on 2021/07/05 06:18:30 UTC, 2 replies.
- RE: Suspected SPAM - RE: FW: Hadoop3 with Flink - posted by "V N, Suchithra (Nokia - IN/Bangalore)" <su...@nokia.com> on 2021/07/05 06:29:04 UTC, 1 replies.
- The best way to read historical data in a stream - posted by Lasse Nedergaard <la...@gmail.com> on 2021/07/05 11:46:07 UTC, 0 replies.
- 答复: WELCOME to user@flink.apache.org - posted by "Wanghui (HiCampus)" <wa...@huawei.com> on 2021/07/05 13:44:48 UTC, 0 replies.
- Savepoints with bootstraping a datastream function - posted by Rakshit Ramesh <ra...@datakaveri.org> on 2021/07/05 15:55:47 UTC, 9 replies.
- Yarn doesn't deploy multple TMs; -yn option missing in newer versions - posted by Marzi K <ma...@gmail.com> on 2021/07/06 00:40:30 UTC, 1 replies.
- How Do I Specify the Encryption Algorithm Suite of the Flink REST Service? - posted by "Wanghui (HiCampus)" <wa...@huawei.com> on 2021/07/06 01:46:19 UTC, 2 replies.
- kerberos token expire - posted by 谢扬成 <ya...@126.com> on 2021/07/06 02:02:21 UTC, 2 replies.
- Flink + Kafka Dynamic Table - posted by vtygoss <vt...@126.com> on 2021/07/06 02:53:02 UTC, 1 replies.
- Re: Flink cep checkpoint size - posted by Li Jim <li...@126.com> on 2021/07/06 07:11:46 UTC, 2 replies.
- Flink CEP checkpoint size - posted by Li Jim <li...@126.com> on 2021/07/06 07:43:57 UTC, 0 replies.
- PyFlink performance and deployment issues - posted by Wouter Zorgdrager <zo...@gmail.com> on 2021/07/06 08:58:20 UTC, 6 replies.
- - posted by Maciek Bry��ski <ma...@brynski.pl> on 2021/07/06 13:25:38 UTC, 4 replies.
- Bug in MATCH_RECOGNIZE ? - posted by Maciej Bryński <ma...@brynski.pl> on 2021/07/06 13:28:14 UTC, 1 replies.
- Re: WELCOME to user@flink.apache.org - posted by Nicolaus Weidner <ni...@data-artisans.com> on 2021/07/06 15:51:56 UTC, 0 replies.
- Apache Flink - How to use/invoke LookupTableSource/Function - posted by M Singh <ma...@yahoo.com> on 2021/07/07 00:22:55 UTC, 4 replies.
- Re: Flink CEP checkpoint size - posted by Aeden Jameson <ae...@gmail.com> on 2021/07/07 01:47:00 UTC, 2 replies.
- Issue while using parallelism.default in flink-conf.yaml file - posted by Mahima Agarwal <ma...@gmail.com> on 2021/07/07 06:17:58 UTC, 1 replies.
- Re: The best way to read historical data in a stream - posted by Arvid Heise <ar...@apache.org> on 2021/07/07 08:33:10 UTC, 1 replies.
- RE: State Processor API and existing state - posted by "Tan, Min" <mi...@ubs.com> on 2021/07/07 18:56:54 UTC, 2 replies.
- Question about POJO rules - why fields should be public or have public setter/getter? - posted by Naehee Kim <ty...@gmail.com> on 2021/07/07 22:09:09 UTC, 3 replies.
- Flink Metric Reporting from Job Manager - posted by Mason Chen <ma...@apple.com> on 2021/07/07 22:12:44 UTC, 1 replies.
- OOM Metaspace after multiple jobs - posted by Alexis Sarda-Espinosa <al...@microfocus.com> on 2021/07/07 22:14:57 UTC, 3 replies.
- More detail information in sql validate exception - posted by 纳兰清风 <ho...@163.com> on 2021/07/08 04:00:24 UTC, 1 replies.
- 关于服务器参数设置请教 - posted by hbdrawn <hb...@vip.qq.com> on 2021/07/08 10:03:04 UTC, 0 replies.
- Re: How to read large amount of data from hive and write to redis, in a batch manner? - posted by Yik San Chan <ev...@gmail.com> on 2021/07/08 11:34:24 UTC, 2 replies.
- How to register custormize serializer for flink kafka format type - posted by "Chenzhiyuan(HR)" <zh...@huawei.com> on 2021/07/08 12:14:05 UTC, 1 replies.
- Lot of java.util.zip.ZipFile$Source in JobManager's Heap - posted by Pranjul Ahuja <ah...@gmail.com> on 2021/07/08 12:31:40 UTC, 1 replies.
- My batch source doesn't emit MAX_WATERMARK when it finishes - why? - posted by Yik San Chan <ev...@gmail.com> on 2021/07/08 12:51:05 UTC, 1 replies.
- Error when trying to setup and run wordcount example on dataproc - posted by Joey Tran <jo...@schrodinger.com> on 2021/07/08 16:10:12 UTC, 2 replies.
- Running Flink Dataset jobs Sequentially - posted by Jason Liu <ja...@ucla.edu> on 2021/07/08 21:19:07 UTC, 2 replies.
- Apache Flink - Reading Avro messages from Kafka with schema in schema registry - posted by M Singh <ma...@yahoo.com> on 2021/07/09 01:09:55 UTC, 4 replies.
- flink hudi parquet file reader read unknown parquet header type, and throw NPE - posted by vtygoss <vt...@126.com> on 2021/07/09 08:57:01 UTC, 1 replies.
- Kafka Consumer Retries Failing - posted by Rahul Patwari <ra...@gmail.com> on 2021/07/09 10:29:42 UTC, 9 replies.
- Ho to convert flat json to nested complex json in Flink sql? - posted by "1095193290@qq.com" <10...@qq.com> on 2021/07/09 11:08:11 UTC, 1 replies.
- Subpar performance of temporal joins with RocksDB backend - posted by Adrian Bednarz <ad...@gmail.com> on 2021/07/09 17:08:37 UTC, 5 replies.
- ValueState is null; checkpointing issues - posted by Marzi K <ma...@gmail.com> on 2021/07/10 22:35:47 UTC, 3 replies.
- Re: Flink SQL as DSL for flink CEP - posted by Dipanjan Mazumder <ja...@yahoo.com> on 2021/07/11 04:25:20 UTC, 0 replies.
- Flink 1.13 Native Kubernetes - Custom Pod Templates - posted by bat man <ti...@gmail.com> on 2021/07/11 09:27:01 UTC, 4 replies.
- Re: Stream processing into single sink to multiple DB Schemas - posted by Tamir Sagi <Ta...@niceactimize.com> on 2021/07/11 12:13:08 UTC, 0 replies.
- Custom type for env.readCsvFile - posted by Mason Chan <ma...@gmail.com> on 2021/07/11 21:36:39 UTC, 1 replies.
- Flink job always keeps failing state. - posted by tian tian <li...@gmail.com> on 2021/07/12 03:20:34 UTC, 2 replies.
- key_by problem in Pyflink - posted by 赵飞 <em...@gmail.com> on 2021/07/12 08:47:34 UTC, 5 replies.
- Process finite stream and notify upon completion - posted by Tamir Sagi <Ta...@niceactimize.com> on 2021/07/12 10:44:28 UTC, 7 replies.
- Enforce stricter back pressure for upstream nodes in Flink DAG - posted by Yuval Itzchakov <yu...@gmail.com> on 2021/07/12 19:47:11 UTC, 5 replies.
- Re: Jobmanager Crashes with Kubernetes HA When Restart Kubernetes Master Node - posted by Jerome Li <li...@vmware.com> on 2021/07/12 20:10:28 UTC, 0 replies.
- [DISCUSS] FLIP-184: Refine ShuffleMaster lifecycle management for pluggable shuffle service framework - posted by Yingjie Cao <ke...@gmail.com> on 2021/07/13 08:59:36 UTC, 0 replies.
- Running two versions of Flink with testcontainers - posted by Farouk <fa...@gmail.com> on 2021/07/13 11:21:06 UTC, 3 replies.
- Flink UDF Scalar Function called only once for all rows of select SQL in case of no parameter passed - posted by shamit jain <ja...@gmail.com> on 2021/07/13 18:56:50 UTC, 3 replies.
- Re: savepoint failure - posted by Dan Hill <qu...@gmail.com> on 2021/07/13 19:11:51 UTC, 5 replies.
- How to examine Flink state in RocksDB with sst_dump - posted by Eleanore Jin <el...@gmail.com> on 2021/07/13 19:15:46 UTC, 0 replies.
- Stateful Functions PersistentTable duration - posted by Ammon Diether <ad...@gmail.com> on 2021/07/13 21:17:17 UTC, 4 replies.
- User Classpath from Plugin - posted by Mason Chen <ma...@gmail.com> on 2021/07/13 21:54:53 UTC, 2 replies.
- Kafka Consumer stop consuming data - posted by Jerome Li <li...@vmware.com> on 2021/07/13 21:59:21 UTC, 3 replies.
- java.lang.Exception: Could not complete the stream element: Record @ 1626200691540 : - posted by Ragini Manjaiah <ra...@gmail.com> on 2021/07/14 03:59:17 UTC, 3 replies.
- [External] NullPointerException on accumulator after Checkpointing - posted by Clemens Valiente <cl...@grab.com> on 2021/07/14 04:33:13 UTC, 2 replies.
- RE: Upsert Kafka SQL Connector used as a sink does not generate an upsert stream - posted by "Sanabria, Carlos" <ca...@accenture.com> on 2021/07/14 06:21:08 UTC, 1 replies.
- High DirectByteBuffer Usage - posted by bat man <ti...@gmail.com> on 2021/07/14 06:46:13 UTC, 6 replies.
- Flink 1.13.1 PartitionNotFoundException - posted by Debraj Manna <su...@gmail.com> on 2021/07/14 12:51:17 UTC, 3 replies.
- Dead Letter Queue for JdbcSink - posted by Rion Williams <ri...@gmail.com> on 2021/07/14 14:21:00 UTC, 3 replies.
- Big data architecture - posted by Aissa Elaffani <ai...@gmail.com> on 2021/07/15 10:56:41 UTC, 0 replies.
- Registering custom metrics on the JobManager - posted by Jeff Charles <je...@shopify.com> on 2021/07/15 19:16:35 UTC, 2 replies.
- Flink sql-connector-elasticsearch7 http dependency - posted by tian tian <li...@gmail.com> on 2021/07/16 01:57:52 UTC, 0 replies.
- Set job specific resources in one StreamTableEnvironment - posted by Paul Lam <pa...@gmail.com> on 2021/07/16 04:20:47 UTC, 2 replies.
- Flink RocksDB Performance - posted by Li Jim <li...@126.com> on 2021/07/16 07:19:27 UTC, 3 replies.
- Flink 1.13.1 - Vulnerabilities CVE-2019-12900 for librocksdbjni - posted by Debraj Manna <su...@gmail.com> on 2021/07/16 09:52:46 UTC, 1 replies.
- [DISCUSS] FLIP-185: Shorter heartbeat timeout and interval default values - posted by Till Rohrmann <tr...@apache.org> on 2021/07/16 17:04:50 UTC, 10 replies.
- Delay data elements in pipeline by X minutes - posted by Dario Heinisch <da...@gmail.com> on 2021/07/17 16:47:06 UTC, 5 replies.
- Watermark UI after checkpoint failure - posted by Dan Hill <qu...@gmail.com> on 2021/07/19 05:41:20 UTC, 3 replies.
- Datastream api implementation of a third party pyflink connector - posted by "Wang, Zhongle" <Zh...@dell.com> on 2021/07/19 09:43:36 UTC, 0 replies.
- Apache Flink Kafka Connector not found Error - posted by Taimoor Bhatti <ta...@outlook.com> on 2021/07/19 10:43:07 UTC, 4 replies.
- Can we share state between different keys in the same window? - posted by Sweta Kalakuntla <sk...@bandwidth.com> on 2021/07/19 21:03:41 UTC, 3 replies.
- Stateful Functions Status - posted by Omid Bakhshandeh <om...@gmail.com> on 2021/07/20 01:07:07 UTC, 3 replies.
- Re: Datastream api implementation of a third party pyflink connector - posted by Xingbo Huang <hx...@gmail.com> on 2021/07/20 01:57:40 UTC, 1 replies.
- Some question of RocksDB state backend on ARM os - posted by "Wanghui (HiCampus)" <wa...@huawei.com> on 2021/07/20 03:26:10 UTC, 3 replies.
- Topic assignment across Flink Kafka Consumer - posted by Prasanna kumar <pr...@gmail.com> on 2021/07/20 05:53:03 UTC, 1 replies.
- connect to schema registry kafka SSL with flink 1.11.2 - posted by tkg_cangkul <yu...@gmail.com> on 2021/07/20 16:05:56 UTC, 1 replies.
- Re: Failure running Flink locally with flink-s3-fs-hadoop + AWS SDK v2 as a dependency - posted by Yaroslav Tkachenko <ya...@shopify.com> on 2021/07/20 18:15:44 UTC, 0 replies.
- Kafka data sources, multiple interval joins and backfilling - posted by Dan Hill <qu...@gmail.com> on 2021/07/20 20:18:52 UTC, 4 replies.
- Recover from savepoints with Kubernetes HA - posted by Thms Hmm <th...@gmail.com> on 2021/07/21 08:05:21 UTC, 5 replies.
- Questions about keyed streams - posted by Dan Hill <qu...@gmail.com> on 2021/07/21 23:32:52 UTC, 4 replies.
- Re: confirm subscribe to user@flink.apache.org - posted by Dhiru <us...@yahoo.com> on 2021/07/22 03:24:58 UTC, 0 replies.
- Need help of deploying Flink HA on kubernetes cluster - posted by Dhiru <us...@yahoo.com> on 2021/07/22 03:33:24 UTC, 4 replies.
- Flink TaskManager container got restarted by K8S very frequently - posted by Fan Xie <fx...@linkedin.com> on 2021/07/22 03:42:10 UTC, 3 replies.
- Issue with Flink jobs after upgrading to Flink 1.13.1/Ververica 2.5 - java.lang.NoClassDefFoundError: org/apache/hadoop/conf/Configuration - posted by Natu Lauchande <nl...@gmail.com> on 2021/07/22 10:22:09 UTC, 6 replies.
- Observability around Flink Pipeline/stateful functions - posted by Deepak Sharma <de...@gmail.com> on 2021/07/22 19:03:19 UTC, 0 replies.
- YarnTaskExecutorRunner should contains MapReduce classes - posted by chenkaibit <ch...@163.com> on 2021/07/23 06:58:09 UTC, 1 replies.
- Flink user subscription request - posted by Samir Vasani <sa...@gmail.com> on 2021/07/23 07:00:50 UTC, 1 replies.
- Move already processed file from one folder to another folder in flink - posted by Samir Vasani <sa...@gmail.com> on 2021/07/23 07:22:36 UTC, 6 replies.
- ClassNotFoundException: org.apache.kafka.clients.consumer.ConsumerRecord - posted by igyu <ig...@21cn.com> on 2021/07/23 15:41:46 UTC, 1 replies.
- Queryable State Lookup Failure - posted by Sandeep khanzode <sa...@shiftright.ai> on 2021/07/23 22:49:15 UTC, 1 replies.
- FlinkKinesis consumer - posted by Vijayendra Yadav <co...@gmail.com> on 2021/07/24 01:15:02 UTC, 2 replies.
- How to keep flink batch job running continously on local - posted by Samir Vasani <sa...@gmail.com> on 2021/07/24 13:31:26 UTC, 1 replies.
- Migrating Kafka Sources (major version change) - posted by Dan Hill <qu...@gmail.com> on 2021/07/24 19:55:14 UTC, 5 replies.
- Finding matched state - posted by Abu Bakar Siddiqur Rahman Rocky <ba...@gmail.com> on 2021/07/25 08:15:23 UTC, 1 replies.
- Issue with Flink SQL using RocksDB backend - posted by Yuval Itzchakov <yu...@gmail.com> on 2021/07/26 16:29:12 UTC, 3 replies.
- as-variable configuration for state ac - posted by Mason Chen <ma...@gmail.com> on 2021/07/26 20:24:38 UTC, 4 replies.
- TaskManager crash after cancelling a job - posted by Ivan Yang <iv...@gmail.com> on 2021/07/27 01:40:07 UTC, 5 replies.
- ImportError: No module named pyflink - posted by Curt Buechter <tr...@gmail.com> on 2021/07/27 07:40:00 UTC, 1 replies.
- Need help when using kubernetes.jobmanager.annotations - posted by Manong Karl <ab...@gmail.com> on 2021/07/27 07:46:50 UTC, 1 replies.
- foreach exec sql - posted by igyu <ig...@21cn.com> on 2021/07/27 08:37:57 UTC, 2 replies.
- Re: recover from svaepoint - posted by Schwalbe Matthias <Ma...@viseca.ch> on 2021/07/27 14:42:48 UTC, 0 replies.
- Unable to read state Witten by Beam application with Flink runner using Flink's State Processor API - posted by "Kathula, Sandeep" <Sa...@intuit.com> on 2021/07/27 15:37:34 UTC, 1 replies.
- [External] naming table stages - posted by Clemens Valiente <cl...@grab.com> on 2021/07/28 04:15:53 UTC, 3 replies.
- IllegalArgumentException: The configured managed memory fraction for Python worker process must be within (0, 1], was: %s - posted by Curt Buechter <tr...@gmail.com> on 2021/07/28 06:42:54 UTC, 1 replies.
- Session Windows should have a max size - posted by Prashant Deva <pr...@astradot.com> on 2021/07/28 08:08:35 UTC, 1 replies.
- Calling a stateful fuction from Flink Job - DataStream Integration - posted by Deniz Koçak <le...@gmail.com> on 2021/07/28 10:04:27 UTC, 0 replies.
- Checkpoints question - posted by Kirill Kosenko <ki...@transportexchangegroup.com> on 2021/07/28 14:09:33 UTC, 1 replies.
- Table Aggregate - Flink SQL - posted by Pranav Patil <pr...@salesforce.com> on 2021/07/28 17:26:50 UTC, 1 replies.
- Flink CDC job getting failed due to G1 old gc - posted by Ayush Chauhan <ay...@zomato.com> on 2021/07/29 10:57:39 UTC, 1 replies.
- Cleaning old incremental checkpoint files - posted by Robin Cassan <ro...@contentsquare.com> on 2021/07/29 12:31:29 UTC, 0 replies.
- when scalarfunction return treemap,the next operator is out of order - posted by 张颖 <qu...@163.com> on 2021/07/29 12:57:46 UTC, 0 replies.
- Unable to use custom AWS credentials provider - 1.9.2 - posted by "Hailu, Andreas [Engineering]" <An...@gs.com> on 2021/07/29 15:37:44 UTC, 4 replies.
- Error using KafkaProducer EXACTLY_ONCE semantic + TaskManager Failure - posted by Kevin Lam <ke...@shopify.com> on 2021/07/29 17:31:34 UTC, 0 replies.
- Obtain JobManager Web Interface URL - posted by "Hailu, Andreas [Engineering]" <An...@gs.com> on 2021/07/29 17:41:03 UTC, 2 replies.
- How can I declare BigDecimal precision and scale in user-defined aggregate function? - posted by LIU Xiao <li...@gmail.com> on 2021/07/30 03:04:53 UTC, 3 replies.
- Over Window Aggregation Tuning - posted by "Wanghui (HiCampus)" <wa...@huawei.com> on 2021/07/30 07:59:21 UTC, 0 replies.
- Issue with writing to Azure blob storage using StreamingFileSink and FileSink - posted by Sudhanva Purushothama <su...@coffeebeans.io> on 2021/07/30 08:28:42 UTC, 0 replies.
- Savepoint class refactor in 1.11 causing restore from 1.9 savepoint to fail - posted by Weston Woods <WW...@spireon.com> on 2021/07/30 21:52:41 UTC, 0 replies.
- Checkpoints fail when trying to copy from Kafka to S3 since "some tasks have been finished" - posted by Svend <st...@svend.xyz> on 2021/07/31 09:22:26 UTC, 0 replies.
- Extremely low performance of state operations upon large quantities of state when using RocksDBstateBackend - posted by 刘首维 <jo...@qq.com> on 2021/07/31 17:14:27 UTC, 0 replies.