user@flink.apache.org, 2020-07

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

- Flink Training - why cannot keyBy hour? - posted by Eleanore Jin <el...@gmail.com> on 2020/07/01 00:25:39 UTC, 2 replies.
- Purpose of starting LeaderRetrievalService in DefaultDispatcherResourceManagerComponentFactory#create - posted by Linlin Zhou <li...@163.com> on 2020/07/01 01:18:34 UTC, 1 replies.
- the group key is retracted - posted by lec ssmi <sh...@gmail.com> on 2020/07/01 01:53:39 UTC, 5 replies.
- Re: Is Flink HIPAA certified - posted by Marta Paes Moreira <ma...@ververica.com> on 2020/07/01 06:05:14 UTC, 2 replies.
- Re: Avro from avrohugger still invalid - posted by Till Rohrmann <tr...@apache.org> on 2020/07/01 07:11:11 UTC, 5 replies.
- Re: Reading and updating rule-sets from a file - posted by Till Rohrmann <tr...@apache.org> on 2020/07/01 07:21:28 UTC, 1 replies.
- Re: Re: Flip-105 can the debezium/canal SQL sink to database directly? - posted by "wanglei2@geekplus.com.cn" <wa...@geekplus.com.cn> on 2020/07/01 09:55:39 UTC, 2 replies.
- Re: Dynamic source and sink. - posted by Danny Chan <yu...@gmail.com> on 2020/07/01 11:54:40 UTC, 4 replies.
- Re: Heartbeat of TaskManager timed out. - posted by Ori Popowski <or...@gmail.com> on 2020/07/01 12:10:49 UTC, 10 replies.
- Checkpoint failed because of TimeWindow cannot be cast to VoidNamespace - posted by Si-li Liu <un...@gmail.com> on 2020/07/02 08:51:48 UTC, 12 replies.
- Dockerised Flink 1.8 with Hadoop S3 FS support - posted by Lorenzo Nicora <lo...@gmail.com> on 2020/07/02 10:05:09 UTC, 1 replies.
- Re: Flink Kafka connector in Python - posted by Manas Kale <ma...@gmail.com> on 2020/07/02 11:59:29 UTC, 4 replies.
- Re: Filter function in flink - posted by Jaswin Shah <ja...@outlook.com> on 2020/07/02 16:26:42 UTC, 1 replies.
- Flink Logging on EMR - posted by mars <sk...@yahoo.com> on 2020/07/02 16:29:50 UTC, 1 replies.
- Stateful Functions: Routing to remote functions - posted by Jan Brusch <ja...@neuland-bfi.de> on 2020/07/02 17:29:06 UTC, 5 replies.
- Flink AskTimeoutException killing the jobs - posted by M Singh <ma...@yahoo.com> on 2020/07/02 19:51:19 UTC, 4 replies.
- Parquet data stream group converter error - posted by Jesse Lord <jl...@vectra.ai> on 2020/07/02 21:36:34 UTC, 2 replies.
- How to dynamically initialize flink metrics in invoke method and then reuse it？ - posted by "wanglei2@geekplus.com.cn" <wa...@geekplus.com.cn> on 2020/07/03 03:50:31 UTC, 4 replies.
- Question about RocksDB performance tunning - posted by Peter Huang <hu...@gmail.com> on 2020/07/03 05:31:17 UTC, 2 replies.
- Checkpoint is disable, will history data in rocksdb be leak when job restart? - posted by SmileSmile <a5...@163.com> on 2020/07/03 06:01:52 UTC, 1 replies.
- Re: Timeout when using RockDB to handle large state in a stream app - posted by Yun Tang <my...@live.com> on 2020/07/03 06:26:59 UTC, 5 replies.
- Re: Checkpoint is disable, will history data in rocksdb be leak when job restart? - posted by SmileSmile <a5...@163.com> on 2020/07/03 06:30:36 UTC, 2 replies.
- Re: [DISCUSS] Drop connectors for 5.x and restart the flink es source connector - posted by Robert Metzger <rm...@apache.org> on 2020/07/03 06:57:28 UTC, 0 replies.
- flink interval join后按窗口聚组问题 - posted by "元始(Bob Hu)" <65...@qq.com> on 2020/07/03 07:28:38 UTC, 1 replies.
- Integrating prometheus - posted by Manish G <ma...@gmail.com> on 2020/07/03 07:35:19 UTC, 5 replies.
- Re: Task recovery? - posted by Robert Metzger <rm...@apache.org> on 2020/07/03 08:25:39 UTC, 5 replies.
- Custom service configs in flink - posted by Jaswin Shah <ja...@outlook.com> on 2020/07/03 10:05:53 UTC, 1 replies.
- Re: Issue with job status - posted by Robert Metzger <rm...@apache.org> on 2020/07/03 11:04:16 UTC, 0 replies.
- Re: Dynamic partitioner for Flink based on incoming load - posted by Robert Metzger <rm...@apache.org> on 2020/07/03 11:32:40 UTC, 0 replies.
- Re: datadog failed to send report - posted by Robert Metzger <rm...@apache.org> on 2020/07/03 11:43:32 UTC, 0 replies.
- Re: - posted by Robert Metzger <rm...@apache.org> on 2020/07/03 11:48:23 UTC, 0 replies.
- [Table API] how to configure a nested timestamp field - posted by Dongwon Kim <ea...@gmail.com> on 2020/07/04 13:21:57 UTC, 6 replies.
- Fwd: Asynchronous I/O poor performance - posted by Mark Zitnik <ma...@gmail.com> on 2020/07/04 19:48:06 UTC, 8 replies.
- can't exectue query when table type is datagen - posted by xin Destiny <nj...@gmail.com> on 2020/07/05 02:51:48 UTC, 2 replies.
- Prometheus not showing custom metrics for flink - posted by Manish G <ma...@gmail.com> on 2020/07/05 05:22:58 UTC, 0 replies.
- Re: StreamingFileSink Not Flushing All Data - posted by hubertchen <hu...@reddit.com> on 2020/07/06 00:11:32 UTC, 0 replies.
- Does savepoint reset the base for incremental checkpoint - posted by Steven Wu <st...@gmail.com> on 2020/07/06 03:08:03 UTC, 2 replies.
- HELP ! ! ! When using Flink1.10 to define table with the string type, the query result is null - posted by Jim Chen <ch...@gmail.com> on 2020/07/06 05:28:10 UTC, 1 replies.
- How to ensure that job is restored from savepoint when using Flink SQL - posted by shadowell <sh...@126.com> on 2020/07/06 08:50:15 UTC, 4 replies.
- Stateful Functions: Deploying to existing Cluster - posted by Jan Brusch <ja...@neuland-bfi.de> on 2020/07/06 10:39:04 UTC, 3 replies.
- [ANNOUNCE] Weekly Community Update 2020/26-27 - posted by Konstantin Knauf <kn...@apache.org> on 2020/07/06 11:12:21 UTC, 0 replies.
- Logging Flink metrics - posted by Manish G <ma...@gmail.com> on 2020/07/06 11:49:16 UTC, 15 replies.
- Kafka Rate Limit in FlinkConsumer ? - posted by David Magalhães <sp...@gmail.com> on 2020/07/06 14:43:14 UTC, 3 replies.
- Flink Parallelism for various type of transformation - posted by Prasanna kumar <pr...@gmail.com> on 2020/07/06 17:01:36 UTC, 1 replies.
- SSL for QueryableStateClient - posted by "mail2souma@yahoo.co.in" <ma...@yahoo.co.in> on 2020/07/06 20:42:37 UTC, 1 replies.
- Decompressing Tar Files for Batch Processing - posted by Austin Cawley-Edwards <au...@gmail.com> on 2020/07/06 23:30:44 UTC, 3 replies.
- Any idea for data skew in hash join - posted by faaron zheng <fa...@gmail.com> on 2020/07/07 08:58:03 UTC, 0 replies.
- Manual allocation of slot usage - posted by Mu Kong <ko...@gmail.com> on 2020/07/07 09:43:50 UTC, 6 replies.
- Check pointing for simple pipeline - posted by Prasanna kumar <pr...@gmail.com> on 2020/07/07 12:43:42 UTC, 2 replies.
- Heterogeneous or Dynamic Stream Processing - posted by Rob Shepherd <rg...@gmail.com> on 2020/07/07 14:01:08 UTC, 6 replies.
- [ANNOUNCE] Apache Flink 1.11.0 released - posted by Zhijiang <wa...@aliyun.com> on 2020/07/07 14:06:05 UTC, 15 replies.
- FlinkKinesisProducer blocking ? - posted by Vijay Balakrishnan <bv...@gmail.com> on 2020/07/07 16:22:45 UTC, 5 replies.
- TaskManager docker image for Beam WordCount failing with ClassNotFound Exception - posted by Avijit Saha <av...@gmail.com> on 2020/07/07 19:23:08 UTC, 1 replies.
- Re: [Third-party Tool] Flink memory calculator - posted by Yangze Guo <ka...@gmail.com> on 2020/07/08 02:18:36 UTC, 0 replies.
- Chaining the creation of a WatermarkStrategy doesn't work? - posted by Niels Basjes <Ni...@basjes.nl> on 2020/07/08 06:54:05 UTC, 4 replies.
- Savepoint fails due to RocksDB 2GiB limit - posted by Ori Popowski <or...@gmail.com> on 2020/07/08 12:21:59 UTC, 4 replies.
- Limiting metrics logs to custom metric - posted by Manish G <ma...@gmail.com> on 2020/07/08 15:19:32 UTC, 3 replies.
- Use state problem - posted by ゞ野蠻遊戲χ <zh...@vip.qq.com> on 2020/07/09 01:58:28 UTC, 1 replies.
- A query on Flink metrics in kubernetes - posted by Manish G <ma...@gmail.com> on 2020/07/09 09:39:28 UTC, 1 replies.
- Implications of taskmanager.memory.process.size - posted by Vishal Santoshi <vi...@gmail.com> on 2020/07/09 13:25:54 UTC, 3 replies.
- AsyncFunction retries - posted by Gadi Katsovich <ga...@gmail.com> on 2020/07/09 14:42:57 UTC, 1 replies.
- Fwd: Avro and Kafka Schema Registry Client versions out of date - posted by Lucas Heimberg <lu...@gmail.com> on 2020/07/09 14:50:59 UTC, 2 replies.
- flink take single element from stream - posted by Georg Heiler <ge...@gmail.com> on 2020/07/09 15:53:25 UTC, 1 replies.
- map JSON to scala case class & off-heap optimization - posted by Georg Heiler <ge...@gmail.com> on 2020/07/09 16:23:45 UTC, 9 replies.
- Validating my understanding of SHARD_DISCOVERY_INTERVAL_MILLIS - posted by Vijay Balakrishnan <bv...@gmail.com> on 2020/07/09 18:35:19 UTC, 1 replies.
- MalformedClassName for scala case class - posted by Georg Heiler <ge...@gmail.com> on 2020/07/09 20:44:21 UTC, 1 replies.
- Does Flink support TFRecordFileOutputFormat? - posted by 殿李 <li...@gmail.com> on 2020/07/10 09:28:07 UTC, 4 replies.
- Table API jobs migration to Flink 1.11 - posted by Flavio Pompermaier <po...@okkam.it> on 2020/07/10 09:48:13 UTC, 15 replies.
- Possible bug clean up savepoint dump into filesystem and low network IO starting from savepoint - posted by David Magalhães <sp...@gmail.com> on 2020/07/10 11:36:52 UTC, 7 replies.
- Customised RESTful trigger - posted by Jacek Grzebyta <gr...@gmail.com> on 2020/07/10 16:48:49 UTC, 1 replies.
- Saving file to the ftp server - posted by Paweł Goliszewski <pa...@gmail.com> on 2020/07/10 16:59:08 UTC, 1 replies.
- Table API throws "No FileSystem for scheme: file" when loading local parquet - posted by Lian Jiang <ji...@gmail.com> on 2020/07/11 00:06:46 UTC, 2 replies.
- Flink 1.11 Table API cannot process Avro - posted by Lian Jiang <ji...@gmail.com> on 2020/07/11 02:16:20 UTC, 9 replies.
- RE: History Server Not Showing Any Jobs - File Not Found? - posted by "Hailu, Andreas" <An...@gs.com> on 2020/07/11 15:57:57 UTC, 1 replies.
- Error --GC Cleaner Provider -- Flink 1.11.0 - posted by Murali Krishna Pusala <mu...@icloud.com> on 2020/07/13 02:42:13 UTC, 5 replies.
- PyFlink Table API - "A group window expects a time attribute for grouping in a stream environment." - posted by Manas Kale <ma...@gmail.com> on 2020/07/13 09:16:19 UTC, 4 replies.
- IllegalAccessError when writing to hive orc table - posted by Paul Lam <pa...@gmail.com> on 2020/07/13 09:47:33 UTC, 3 replies.
- [ANNOUNCE] Weekly Community Update 2020/28 - posted by Konstantin Knauf <kn...@apache.org> on 2020/07/13 11:03:20 UTC, 0 replies.
- Flink DataSet Iterate updating additional variable - posted by Antonio Martínez Carratalá <am...@alto-analytics.com> on 2020/07/13 13:49:20 UTC, 3 replies.
- RequiredParameters in Flink 1.11 - posted by Flavio Pompermaier <po...@okkam.it> on 2020/07/13 15:24:43 UTC, 2 replies.
- Clear state problem - posted by ゞ野蠻遊戲χ <zh...@vip.qq.com> on 2020/07/13 15:40:52 UTC, 1 replies.
- Flink Pojo Serialization for Map Values - posted by KristoffSC <kr...@gmail.com> on 2020/07/13 21:06:20 UTC, 4 replies.
- deployin a flink app on a server; - posted by Aissa Elaffani <ai...@gmail.com> on 2020/07/13 22:49:16 UTC, 1 replies.
- Beam Word Cound on Flink/kubernetes Issue with task manager ot getting picked up - posted by Avijit Saha <av...@gmail.com> on 2020/07/13 23:12:39 UTC, 1 replies.
- stop job problem and ddl problem - posted by "元始(Bob Hu)" <65...@qq.com> on 2020/07/14 01:41:42 UTC, 1 replies.
- 回复： Clear state problem - posted by ゞ野蠻遊戲χ <zh...@vip.qq.com> on 2020/07/14 02:04:38 UTC, 1 replies.
- pyFlink 1.11 streaming job example - posted by Manas Kale <ma...@gmail.com> on 2020/07/14 07:30:41 UTC, 4 replies.
- DDL TIMESTAMP(3) parsing issue - posted by Manas Kale <ma...@gmail.com> on 2020/07/14 10:07:24 UTC, 4 replies.
- Key group is not in KeyGroupRange - posted by Ori Popowski <or...@gmail.com> on 2020/07/14 11:03:33 UTC, 3 replies.
- Flink 1.11 test Parquet sink - posted by Flavio Pompermaier <po...@okkam.it> on 2020/07/14 14:48:59 UTC, 7 replies.
- Missing jars - posted by Daves Open <op...@gmail.com> on 2020/07/14 15:41:28 UTC, 2 replies.
- Backpressure on Window step - posted by Nelson Steven <Ne...@JohnDeere.com> on 2020/07/14 20:12:35 UTC, 3 replies.
- Map type param escaping : - posted by "Bohinski, Kevin" <Ke...@comcast.com> on 2020/07/14 20:56:16 UTC, 2 replies.
- Pyflink JavaPackage Error - posted by Jesse Lord <jl...@vectra.ai> on 2020/07/14 21:09:10 UTC, 1 replies.
- RestartStrategy failure count when losing a Task Manager - posted by Jiahui Jiang <qz...@hotmail.com> on 2020/07/14 22:16:40 UTC, 1 replies.
- ERROR submmiting a flink job - posted by Aissa Elaffani <ai...@gmail.com> on 2020/07/14 23:29:34 UTC, 1 replies.
- Mongodb_sink - posted by C DINESH <di...@gmail.com> on 2020/07/15 01:27:47 UTC, 1 replies.
- How to debug window states - posted by Paul Lam <pa...@gmail.com> on 2020/07/15 05:13:56 UTC, 2 replies.
- Communicating with my operators - posted by Tom Wells <to...@tomwells.org> on 2020/07/15 08:00:37 UTC, 1 replies.
- Pravega connector cannot recover from the checkpoint due to "Failure to finalize checkpoint" - posted by B....@dell.com on 2020/07/15 10:25:55 UTC, 3 replies.
- pyFlink UDTF function registration - posted by Manas Kale <ma...@gmail.com> on 2020/07/15 11:31:14 UTC, 2 replies.
- Parquet format in Flink 1.11 - posted by Flavio Pompermaier <po...@okkam.it> on 2020/07/15 12:44:24 UTC, 2 replies.
- Is there a way to access the number of 'keys' that have been used for partioning? - posted by orionemail <or...@protonmail.com> on 2020/07/15 15:11:25 UTC, 2 replies.
- Pyflink sink rowtime field - posted by Jesse Lord <jl...@vectra.ai> on 2020/07/15 15:41:25 UTC, 1 replies.
- Status of a job when a kafka source dies - posted by Nick Bendtner <bu...@gmail.com> on 2020/07/15 15:42:55 UTC, 1 replies.
- Print table content in Flink 1.11 - posted by Flavio Pompermaier <po...@okkam.it> on 2020/07/15 16:19:42 UTC, 4 replies.
- flink app crashed - posted by Rainie Li <ra...@pinterest.com> on 2020/07/15 17:54:10 UTC, 4 replies.
- Performance test Flink vs Storm - posted by Prasanna kumar <pr...@gmail.com> on 2020/07/15 17:57:27 UTC, 10 replies.
- How to write junit testcases for KeyedBroadCastProcess Function - posted by bujjirahul45 <ra...@gmail.com> on 2020/07/15 18:32:19 UTC, 1 replies.
- Using md5 hash while sinking files to s3 - posted by nikita Balakrishnan <ni...@gmail.com> on 2020/07/16 01:11:03 UTC, 3 replies.
- HELP!!! Flink1.10 sql insert into HBase, error like validateSchemaAndApplyImplicitCast - posted by Jim Chen <ch...@gmail.com> on 2020/07/16 02:29:12 UTC, 2 replies.
- ElasticSearch_Sink - posted by C DINESH <di...@gmail.com> on 2020/07/16 03:01:02 UTC, 1 replies.
- Accumulators in Table API - posted by Flavio Pompermaier <po...@okkam.it> on 2020/07/16 07:36:44 UTC, 1 replies.
- Hadoop FS when running standalone - posted by Lorenzo Nicora <lo...@gmail.com> on 2020/07/16 10:58:35 UTC, 2 replies.
- Byte arrays in Avro - posted by Lasse Nedergaard <la...@gmail.com> on 2020/07/16 11:28:28 UTC, 2 replies.
- AllwindowStream and RichReduceFunction - posted by Flavio Pompermaier <po...@okkam.it> on 2020/07/16 14:28:34 UTC, 6 replies.
- UnsupportedOperatorException with TensorFlow on checkpointing - posted by Sung Gon Yi <sk...@mac.com> on 2020/07/16 15:00:50 UTC, 1 replies.
- Flink Jobs are failing for running testcases when trying to build in Jenkins server - posted by bujjirahul45 <ra...@gmail.com> on 2020/07/16 15:40:53 UTC, 1 replies.
- backup configuration in Flink doc - posted by Steven Wu <st...@gmail.com> on 2020/07/16 16:01:56 UTC, 1 replies.
- Question on Pattern Matching - posted by Basanth Gowda <ba...@gmail.com> on 2020/07/16 18:23:29 UTC, 3 replies.
- Beam flink runner job not keeping up with input rate after downscaling - posted by "Kathula, Sandeep" <Sa...@intuit.com> on 2020/07/16 20:07:53 UTC, 1 replies.
- Flink 1.11 throws Unrecognized field "error_code" - posted by Lian Jiang <ji...@gmail.com> on 2020/07/17 00:42:44 UTC, 2 replies.
- CEP use case ? - posted by Aissa Elaffani <ai...@gmail.com> on 2020/07/17 01:05:26 UTC, 1 replies.
- Is there a way to use stream API with this program? - posted by Flavio Pompermaier <po...@okkam.it> on 2020/07/17 08:30:11 UTC, 5 replies.
- Flink FsStatebackend is giving better performance than RocksDB - posted by Vijay Bhaskar <bh...@gmail.com> on 2020/07/17 11:52:55 UTC, 2 replies.
- org.aspectj.lang.annotation annotation not working with flink - posted by Manish G <ma...@gmail.com> on 2020/07/17 15:03:22 UTC, 0 replies.
- DynamoDB sink - posted by Lorenzo Nicora <lo...@gmail.com> on 2020/07/17 15:39:44 UTC, 1 replies.
- Parquet batch table sink in Flink 1.11 - posted by Flavio Pompermaier <po...@okkam.it> on 2020/07/17 15:59:06 UTC, 4 replies.
- Global Hashmap & global static variable. - posted by Annemarie Burger <an...@campus.tu-berlin.de> on 2020/07/17 19:22:26 UTC, 1 replies.
- Flink Sinks - posted by Prasanna kumar <pr...@gmail.com> on 2020/07/17 19:55:05 UTC, 1 replies.
- Are files in savepoint still needed after restoring if turning on incremental checkpointing - posted by Lu Niu <qq...@gmail.com> on 2020/07/17 21:48:24 UTC, 2 replies.
- Flink 1.11 Sql client environment yaml - posted by Lian Jiang <ji...@gmail.com> on 2020/07/17 22:20:57 UTC, 1 replies.
- How do I trigger clear custom state in ProcessWindowsFunction - posted by ゞ野蠻遊戲χ <zh...@vip.qq.com> on 2020/07/18 12:30:00 UTC, 1 replies.
- Custom metrics output - posted by Joris Geer <jo...@oracle.com> on 2020/07/19 23:26:54 UTC, 1 replies.
- DashBoard Name - posted by C DINESH <di...@gmail.com> on 2020/07/20 04:43:09 UTC, 1 replies.
- Flink rest api cancel job - posted by snack white <am...@gmail.com> on 2020/07/20 06:41:28 UTC, 0 replies.
- Kafka Consumer consuming rate suddenly dropped - posted by Mu Kong <ko...@gmail.com> on 2020/07/20 09:45:07 UTC, 6 replies.
- Flink Cluster Java 11 support - posted by Pedro Cardoso <pe...@feedzai.com> on 2020/07/20 11:23:58 UTC, 1 replies.
- How to get flink JobId in runtime - posted by Si-li Liu <un...@gmail.com> on 2020/07/20 11:38:06 UTC, 3 replies.
- Simple MDC logs don't show up - posted by Manish G <ma...@gmail.com> on 2020/07/20 13:27:57 UTC, 1 replies.
- Encoding problem in WHERE LIKE - posted by Dongwon Kim <ea...@gmail.com> on 2020/07/20 13:49:29 UTC, 3 replies.
- records-lag-max - posted by "Chen, Mason" <ma...@sony.com> on 2020/07/20 19:34:09 UTC, 1 replies.
- Flink SQL - Join Lookup Table - posted by Kelly Smith <ke...@zillowgroup.com> on 2020/07/20 22:31:20 UTC, 7 replies.
- Re: How does TaskManager announce JobManager about available ResultPartitions? - posted by Zhu Zhu <re...@gmail.com> on 2020/07/21 03:33:58 UTC, 0 replies.
- Handle idle kafka source in Flink 1.9 - posted by bat man <ti...@gmail.com> on 2020/07/21 06:00:13 UTC, 4 replies.
- FileNotFoundException when writting Hive orc tables - posted by Paul Lam <pa...@gmail.com> on 2020/07/21 08:02:17 UTC, 7 replies.
- How to use a nested column for CREATE TABLE PARTITIONED BY - posted by Dongwon Kim <ea...@gmail.com> on 2020/07/21 08:54:53 UTC, 5 replies.
- Checkpoint not maintaining minimum pause duration between checkpoints - posted by Ravi Bhushan Ratnakar <ra...@gmail.com> on 2020/07/21 09:24:46 UTC, 4 replies.
- Re: Flink rest api cancel job - posted by Fabian Hueske <fh...@gmail.com> on 2020/07/21 09:41:40 UTC, 0 replies.
- Unsubscribe - posted by Harshvardhan Agrawal <ha...@gmail.com> on 2020/07/21 11:09:22 UTC, 1 replies.
- MaxConnections understanding on FlinkKinesisProducer via KPL - posted by Vijay Balakrishnan <bv...@gmail.com> on 2020/07/21 21:19:36 UTC, 3 replies.
- Strange stack when job encounter back pressure - posted by aitozi <gj...@gmail.com> on 2020/07/22 02:26:41 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.11.1 released - posted by Dian Fu <di...@apache.org> on 2020/07/22 06:52:44 UTC, 0 replies.
- Re: [ANNOUNCE] Apache Flink 1.11.1 released - posted by Leonard Xu <xb...@gmail.com> on 2020/07/22 07:09:25 UTC, 10 replies.
- Changing watermark in the middle of a flow - posted by Lorenzo Nicora <lo...@gmail.com> on 2020/07/22 07:27:45 UTC, 1 replies.
- Flink app cannot restart - posted by Rainie Li <ra...@pinterest.com> on 2020/07/22 07:41:40 UTC, 3 replies.
- Recommended pattern for implementing a DLQ with Flink+Kafka - posted by Tom Fennelly <tf...@cloudbees.com> on 2020/07/22 11:07:05 UTC, 6 replies.
- Is it possible to do state migration with checkpoints? - posted by Sivaprasanna <si...@gmail.com> on 2020/07/22 14:02:37 UTC, 6 replies.
- Re: Docker Taskmanager unable to connect to Flink JpbManager...Connection RefusedHi, - posted by Avijit Saha <av...@gmail.com> on 2020/07/22 16:57:00 UTC, 2 replies.
- Rolling update of flink cluster in kubernetes - posted by Suraj Puvvada <su...@traceable.ai> on 2020/07/22 17:18:44 UTC, 1 replies.
- NotSerializableException: org.apache.flink.runtime.rest.messages.ResourceProfileInfo - posted by Peter Westermann <no...@genesys.com> on 2020/07/22 18:03:15 UTC, 9 replies.
- Flink failed to resume from checkpoint stored on S3 - posted by Xiaolong Wang <xi...@smartnews.com> on 2020/07/23 02:01:53 UTC, 1 replies.
- Kafka connector with PyFlink - posted by Wojciech Korczyński <wo...@alphamoon.ai> on 2020/07/23 08:55:43 UTC, 15 replies.
- Flink state reconciliation - posted by Александр Сергеенко <al...@gmail.com> on 2020/07/23 10:07:56 UTC, 4 replies.
- REST API randomly returns Not Found for an existing job - posted by Tomasz Dudziak <t....@mwam.com> on 2020/07/23 10:59:01 UTC, 6 replies.
- Flink 1.11 Simple pipeline (data stream -> table with egg -> data stream) failed - posted by Dmytro Dragan <dd...@softserveinc.com> on 2020/07/23 13:14:56 UTC, 3 replies.
- GenericData cannot be cast to type scala.Product - posted by Georg Heiler <ge...@gmail.com> on 2020/07/23 13:32:02 UTC, 1 replies.
- Count of records coming into the Flink App from KDS and at each step through Execution Graph - posted by Vijay Balakrishnan <bv...@gmail.com> on 2020/07/23 22:57:29 UTC, 6 replies.
- Flink 1.11 job stop with save point timeout error - posted by Ivan Yang <iv...@gmail.com> on 2020/07/24 02:02:29 UTC, 3 replies.
- How to start flink standalone session on windows ？ - posted by "wanglei2@geekplus.com.cn" <wa...@geekplus.com.cn> on 2020/07/24 02:27:22 UTC, 1 replies.
- Flink DataStream[String] kafkacosumer avro streaming file sink - posted by Vijayendra Yadav <co...@gmail.com> on 2020/07/24 03:06:18 UTC, 1 replies.
- Reading/writing Kafka message keys using DDL pyFlink - posted by Manas Kale <ma...@gmail.com> on 2020/07/24 07:01:01 UTC, 2 replies.
- Printing effective config for flint 1.11 cli - posted by Senthil Kumar <se...@vmware.com> on 2020/07/24 14:06:05 UTC, 1 replies.
- Flink Session TM Logs - posted by Richard Moorhead <ri...@gmail.com> on 2020/07/24 15:54:58 UTC, 4 replies.
- SourceReaderBase not part of flink-core 1.11.1 - posted by Yuval Itzchakov <yu...@gmail.com> on 2020/07/24 15:55:47 UTC, 1 replies.
- Flink 1.11.1 - job manager exists with exit code 0 - posted by Alexey Trenikhun <ye...@msn.com> on 2020/07/25 04:42:15 UTC, 0 replies.
- Is outputting from components other than sinks or side outputs a no-no ? - posted by Tom Fennelly <tf...@cloudbees.com> on 2020/07/26 09:06:41 UTC, 4 replies.
- Unable to deduce RocksDB api calls in streaming. - posted by Aviral Srivastava <av...@gmail.com> on 2020/07/26 22:02:41 UTC, 1 replies.
- Pyflink 1.10.0 issue on cluster - posted by rookieCOder <Da...@126.com> on 2020/07/27 09:47:56 UTC, 5 replies.
- problem with build from source flink 1.11 - posted by Felipe Lolas <fl...@icloud.com> on 2020/07/27 10:09:40 UTC, 5 replies.
- How to get CLI parameters when deploy on yarn cluster - posted by 范超 <fa...@mgtv.com> on 2020/07/27 10:19:17 UTC, 1 replies.
- 答复: How to get CLI parameters when deploy on yarn cluster - posted by 范超 <fa...@mgtv.com> on 2020/07/27 10:51:44 UTC, 0 replies.
- 来自kandy.wang的邮件 - posted by "kandy.wang" <ka...@163.com> on 2020/07/27 12:52:40 UTC, 0 replies.
- Flink 1.11.0 UDAF fails with "No match found for function signature fun()" - posted by Dmytro Dragan <dd...@softserveinc.com> on 2020/07/27 14:35:15 UTC, 4 replies.
- How to stream CSV from S3? - posted by John Smith <ja...@gmail.com> on 2020/07/27 14:53:06 UTC, 8 replies.
- [ANNOUNCE] Weekly Community Update 2020/29-30 - posted by Konstantin Knauf <kn...@apache.org> on 2020/07/27 16:29:27 UTC, 0 replies.
- JobManager refusing connections when running many jobs in parallel? - posted by "Hailu, Andreas" <An...@gs.com> on 2020/07/27 16:29:48 UTC, 1 replies.
- Unable to submit high parallelism job in cluster - posted by Annemarie Burger <an...@campus.tu-berlin.de> on 2020/07/27 19:50:22 UTC, 3 replies.
- 答复: Flink Session TM Logs - posted by 范超 <fa...@mgtv.com> on 2020/07/28 03:09:41 UTC, 0 replies.
- improve the performance of flink sql job which lookup 40+ table - posted by snack white <am...@gmail.com> on 2020/07/28 03:42:53 UTC, 0 replies.
- Re: improve the performance of flink sql job which lookup 40+ table - posted by Jark Wu <im...@gmail.com> on 2020/07/28 06:50:26 UTC, 0 replies.
- Customization of execution environment - posted by Flavio Pompermaier <po...@okkam.it> on 2020/07/28 08:13:05 UTC, 4 replies.
- Job Cluster on Kubernetes with PyFlink - posted by Wojciech Korczyński <wo...@alphamoon.ai> on 2020/07/28 08:26:23 UTC, 2 replies.
- How to retain the column'name when convert a Table to DataStream - posted by izual <iz...@163.com> on 2020/07/28 08:26:34 UTC, 3 replies.
- PyFlink DDL UDTF join error - posted by Manas Kale <ma...@gmail.com> on 2020/07/28 10:33:16 UTC, 3 replies.
- Removing stream in a job having state - posted by ApoorvK <ap...@razorpay.com> on 2020/07/28 14:11:26 UTC, 1 replies.
- Flink Deployment on Kubernetes session Cluster - posted by Vinay Patil <vi...@gmail.com> on 2020/07/28 16:08:34 UTC, 2 replies.
- Compression Streamingfilesink ROW-encoded format - posted by Vijayendra Yadav <co...@gmail.com> on 2020/07/28 18:01:43 UTC, 6 replies.
- [DISCUSS] add a '--filename' parameter for sql-client - posted by Jun Zhang <zh...@gmail.com> on 2020/07/29 01:20:57 UTC, 3 replies.
- Re: Flink 1.11.1 - job manager exists with exit code 0 - posted by Robert Metzger <rm...@apache.org> on 2020/07/29 05:38:42 UTC, 3 replies.
- State Restoration issue with flink 1.10.1 - posted by ApoorvK <ap...@razorpay.com> on 2020/07/29 10:00:59 UTC, 1 replies.
- [DISCUSS] FLIP-131: Consolidate the user-facing Dataflow SDKs/APIs (and deprecate the DataSet API) - posted by Aljoscha Krettek <al...@apache.org> on 2020/07/29 10:45:51 UTC, 9 replies.
- Colocating Compute - posted by Satyam Shekhar <sa...@gmail.com> on 2020/07/29 11:53:24 UTC, 3 replies.
- Making sense of Meter metrics graph on Grafana - posted by Manish G <ma...@gmail.com> on 2020/07/29 13:13:50 UTC, 2 replies.
- Memory reclaim problem on Flink Kubernetes pods - posted by Vinay Patil <vi...@gmail.com> on 2020/07/29 13:25:02 UTC, 4 replies.
- Flink jobs getting finished because of "Could not allocate the required slot within slot request timeout" - posted by mars <sk...@yahoo.com> on 2020/07/29 14:51:58 UTC, 1 replies.
- unsubscribe - posted by Maatary Okouya <ma...@gmail.com> on 2020/07/29 16:08:35 UTC, 1 replies.
- Matching largest event pattern without duplicates - posted by James Buchan <ja...@googlemail.com> on 2020/07/29 17:03:03 UTC, 0 replies.
- [Compression] Flink DataStream[GenericRecord] Avrowriters - posted by Vijayendra Yadav <co...@gmail.com> on 2020/07/29 17:33:01 UTC, 6 replies.
- Flink Kafka EXACTLY_ONCE causing KafkaException ByteArraySerializer is not an instance of Serializer - posted by Vikash Dat <da...@gmail.com> on 2020/07/30 01:30:57 UTC, 3 replies.
- Re: Checkpointing under backpressure - posted by Arvid Heise <ar...@ververica.com> on 2020/07/30 09:04:47 UTC, 1 replies.
- Unable to recover from checkpoint - posted by Sivaprasanna <si...@gmail.com> on 2020/07/30 12:45:12 UTC, 1 replies.
- Flink streaming job logging reserves space - posted by Maxim Parkachov <la...@gmail.com> on 2020/07/30 13:59:52 UTC, 0 replies.
- Options for limiting state size in TableAPI&SQL - posted by "Sofya T. Irwin" <so...@gmail.com> on 2020/07/30 14:42:48 UTC, 0 replies.
- BucketingSink & StreamingFileSink - posted by Mariano González Núñez <ma...@hotmail.com> on 2020/07/30 15:30:33 UTC, 0 replies.
- Count of records in the Stream for a time window of 5s - posted by Vijay Balakrishnan <bv...@gmail.com> on 2020/07/30 18:29:43 UTC, 0 replies.
- Does Flink automatically apply any backpressure ? - posted by Suraj Puvvada <su...@traceable.ai> on 2020/07/30 18:48:31 UTC, 1 replies.
- Does Flink automatically apply the rebalance operator ? - posted by Suraj Puvvada <su...@traceable.ai> on 2020/07/30 18:52:34 UTC, 0 replies.
- StreamingFileSink: any risk parallelizing active buckets checkpointing? - posted by Paul Bernier <pb...@splunk.com> on 2020/07/30 18:55:50 UTC, 0 replies.
- [DISCUSS] FLIP-133: Rework PyFlink Documentation - posted by jincheng sun <su...@gmail.com> on 2020/07/31 02:14:58 UTC, 3 replies.
- is it possible one task manager stuck and still fetching data from Kinesis? - posted by Terry Chia-Wei Wu <te...@gmail.com> on 2020/07/31 02:40:40 UTC, 0 replies.
- EMR Saving CheckPoint into to S3 and 403 Access Denied - posted by mars <sk...@yahoo.com> on 2020/07/31 03:20:19 UTC, 0 replies.
- Support for Event time clock specific to each stream in parallel streams - posted by Sush Bankapura <su...@man-es.com> on 2020/07/31 11:42:09 UTC, 1 replies.
- JDBCOutputFormat dependency loading error - posted by Flavio Pompermaier <po...@okkam.it> on 2020/07/31 14:53:31 UTC, 0 replies.
- Is there a way to get file "metadata" as part of stream? - posted by John Smith <ja...@gmail.com> on 2020/07/31 15:53:14 UTC, 0 replies.
- Behavior for flink job running on K8S failed after restart strategy exhausted - posted by Eleanore Jin <el...@gmail.com> on 2020/07/31 16:20:55 UTC, 0 replies.
- How long it took a Flink Job to start up ? - posted by Vijay Balakrishnan <bv...@gmail.com> on 2020/07/31 17:55:49 UTC, 0 replies.
- [Flink Unit Tests] Unit test for Flink streaming codes - posted by Vijayendra Yadav <co...@gmail.com> on 2020/07/31 18:19:43 UTC, 2 replies.
- Kafka source, committing and retries - posted by Jack Phelan <ja...@broadcom.com> on 2020/07/31 18:54:43 UTC, 0 replies.
- sporadic "Insufficient no of network buffers" issue - posted by Rahul Patwari <ra...@gmail.com> on 2020/07/31 21:02:46 UTC, 0 replies.
- allowNonRestoredState: metadata file in checkpoint dir missing - posted by "Deshpande, Omkar" <Om...@intuit.com> on 2020/07/31 22:14:39 UTC, 0 replies.