You are viewing a plain text version of this content. The canonical link for it is here.
- Re: Low Performance in High Cardinality Big Window Application - posted by Ning Shi <ni...@gmail.com> on 2018/09/01 01:55:11 UTC, 0 replies.
- Does Flink plan to support JDK 9 recently? - posted by 陈梓立 <wa...@gmail.com> on 2018/09/01 02:50:38 UTC, 1 replies.
- multiple input streams - posted by Eric L Goodman <Er...@colorado.edu> on 2018/09/01 03:46:45 UTC, 1 replies.
- Re: API for delayed/scheduled interval input source for integration tests - posted by Yee-Ning Cheng <ye...@gmail.com> on 2018/09/01 04:20:45 UTC, 1 replies.
- ODP: API for delayed/scheduled interval input source for integrationtests - posted by Dominik Wosiński <wo...@gmail.com> on 2018/09/01 16:01:01 UTC, 2 replies.
- RocksDB Number of Keys Metric - posted by Ahmed <aa...@gmail.com> on 2018/09/01 18:31:10 UTC, 2 replies.
- Re: WriteTimeoutException in Cassandra sink kill the job - posted by Yee-Ning Cheng <ye...@gmail.com> on 2018/09/01 19:56:24 UTC, 3 replies.
- Re: FoldFunction accumulator checkpointing - posted by Mar_zieh <m....@gmail.com> on 2018/09/02 05:56:18 UTC, 1 replies.
- flink use hdfs DistributedCache - posted by 何春平 <24...@qq.com> on 2018/09/02 09:07:34 UTC, 0 replies.
- Re: Cannot compile Wikipedia Edit Stream example - posted by Rong Rong <wa...@gmail.com> on 2018/09/02 15:49:05 UTC, 0 replies.
- Re: flink use hdfs DistributedCache - posted by Rong Rong <wa...@gmail.com> on 2018/09/02 16:02:44 UTC, 0 replies.
- KafkaTopicPartition internal class treated as generic type serialization - posted by Yee-Ning Cheng <ye...@gmail.com> on 2018/09/02 22:00:39 UTC, 0 replies.
- 回复： flink use hdfs DistributedCache - posted by 何春平 <24...@qq.com> on 2018/09/03 02:34:35 UTC, 0 replies.
- Promethus - custom metrics at job level - posted by Averell <lv...@gmail.com> on 2018/09/03 06:22:55 UTC, 2 replies.
- Flink on Yarn, restart job will not destroy original task manager - posted by "James (Jian Wu) [FDS Data Platform]" <ja...@coupang.com> on 2018/09/03 07:20:27 UTC, 0 replies.
- Rolling File Sink Exception - posted by clay4444 <cl...@gmail.com> on 2018/09/03 07:30:42 UTC, 1 replies.
- Re: Flink on Yarn, restart job will not destroy original task manager - posted by Gary Yao <ga...@data-artisans.com> on 2018/09/03 07:57:37 UTC, 3 replies.
- Flink on kubernetes - posted by 祁明良 <mq...@xiaohongshu.com> on 2018/09/03 08:08:55 UTC, 3 replies.
- Re: CompletedCheckpoints are getting Stale ( Flink 1.4.2 ) - posted by Stephan Ewen <se...@apache.org> on 2018/09/03 09:37:18 UTC, 0 replies.
- Re: Can't access Flink Dashboard at 8081, running Flink program using Eclipse - posted by Mar_zieh <m....@gmail.com> on 2018/09/03 10:12:33 UTC, 1 replies.
- Flink 1.5.2 query - posted by Parth Sarathy <pa...@microfocus.com> on 2018/09/03 12:37:52 UTC, 3 replies.
- Why FlinkKafkaConsumer doesn't subscribe to topics? - posted by Julio Biason <ju...@azion.com> on 2018/09/03 19:08:55 UTC, 4 replies.
- JAXB Classloading errors when using PMML Library (AWS EMR Flink 1.4.2) - posted by Sameer W <sa...@axiomine.com> on 2018/09/04 01:24:17 UTC, 1 replies.
- Re: Get stream of rejected data from Elasticsearch6 sink - posted by vino yang <ya...@gmail.com> on 2018/09/04 03:42:39 UTC, 0 replies.
- Re: This server is not the leader for that topic-partition - posted by Jayant Ameta <wi...@gmail.com> on 2018/09/04 04:32:16 UTC, 3 replies.
- Queryable State - posted by Darshan Singh <da...@gmail.com> on 2018/09/04 08:44:38 UTC, 2 replies.
- Failed to trigger savepoint - posted by Paul Lam <pa...@gmail.com> on 2018/09/04 10:02:41 UTC, 1 replies.
- Cancel flink job occur exception. - posted by "devinduan (段丁瑞)" <de...@tencent.com> on 2018/09/04 12:18:37 UTC, 0 replies.
- Cancel flink job occur exception - posted by "rileyli (李瑞亮)" <ri...@tencent.com> on 2018/09/04 12:21:55 UTC, 1 replies.
- Ask about running multiple jars for different stream jobs - posted by Rad Rad <ra...@gmail.com> on 2018/09/04 13:11:03 UTC, 6 replies.
- org.apache.flink.util.FlinkException: Could not cancel job - posted by Chang Liu <fl...@gmail.com> on 2018/09/04 13:48:51 UTC, 2 replies.
- Flink1.6.0 submit job and got "No content to map due to end-of-input" Error - posted by ? ?? <pa...@hotmail.com> on 2018/09/04 14:06:46 UTC, 1 replies.
- Re: akka.ask.timeout setting not honored - posted by Greg Finch <fi...@gmail.com> on 2018/09/04 21:47:00 UTC, 0 replies.
- flink list and flink run commands timeout - posted by Jason Kania <ja...@ymail.com> on 2018/09/04 22:53:37 UTC, 3 replies.
- cannot catch flink runtime exception - posted by 孙森 <se...@creditease.cn> on 2018/09/05 03:56:43 UTC, 4 replies.
- Re: Taskmanager process memory increasing always - posted by "Yan Zhou [FDS Science]" <yz...@coupang.com> on 2018/09/05 05:22:16 UTC, 1 replies.
- 答复: Flink1.6.0 submit job and got "No content to map due to end-of-input" Error - posted by 潘 功森 <pa...@hotmail.com> on 2018/09/05 05:27:26 UTC, 2 replies.
- Does Flink support keyed watermarks? If not, is there any plan of implementing it soon? What are my alternatives? - posted by HarshithBolar <hk...@arity.com> on 2018/09/05 07:50:24 UTC, 0 replies.
- Does Flink support keyed watermarks? If not, is there any plan of implementing it in future versions? What are my alternatives? - posted by HarshithBolar <hk...@arity.com> on 2018/09/05 07:57:19 UTC, 0 replies.
- 答复: 答复: Flink1.6.0 submit job and got "No content to map due to end-of-input" Error - posted by 潘 功森 <pa...@hotmail.com> on 2018/09/05 08:00:02 UTC, 0 replies.
- Does Flink support keyed watermarks? - posted by HarshithBolar <hk...@arity.com> on 2018/09/05 08:06:32 UTC, 0 replies.
- How to add jvm Options when using Flink dashboard? - posted by zpp <z_...@163.com> on 2018/09/05 09:41:19 UTC, 2 replies.
- Missing Calcite SQL functions in table API - posted by françois lacombe <fr...@dcbrain.com> on 2018/09/05 10:22:16 UTC, 2 replies.
- AskTimeoutException when canceling job with savepoint on flink 1.6.0 - posted by jelmer <jk...@gmail.com> on 2018/09/05 12:48:10 UTC, 2 replies.
- Re: Flink parquet read.write performance - posted by clay4444 <cl...@gmail.com> on 2018/09/05 14:06:04 UTC, 0 replies.
- REST: reading completed jobs' details - posted by Miguel Coimbra <mi...@gmail.com> on 2018/09/05 15:39:01 UTC, 6 replies.
- numRunningJobs metric - posted by Bryant Baltes <br...@gmail.com> on 2018/09/05 17:58:51 UTC, 2 replies.
- Increased Size of Incremental Checkpoint - posted by burgesschen <tc...@bloomberg.net> on 2018/09/05 20:29:24 UTC, 2 replies.
- How to simulate a blocking (sink) node? - posted by 陈梓立 <wa...@gmail.com> on 2018/09/06 02:30:26 UTC, 0 replies.
- ListState - elements order - posted by Alexey Trenikhun <ye...@msn.com> on 2018/09/06 02:55:11 UTC, 1 replies.
- Re: Job goes down after 1/145 TMs is lost (NoResourceAvailableException) - posted by Subramanya Suresh <ss...@salesforce.com> on 2018/09/06 02:58:06 UTC, 5 replies.
- Re: ListState - elements order - posted by vino yang <ya...@gmail.com> on 2018/09/06 06:19:33 UTC, 8 replies.
- Flink failure recovery tooks very long time - posted by trung kien <ki...@gmail.com> on 2018/09/06 10:50:37 UTC, 6 replies.
- Behaviour of Process Window Function - posted by Harshvardhan Agrawal <ha...@gmail.com> on 2018/09/06 14:10:07 UTC, 3 replies.
- Cannot set classpath which can be used before job is submitted to yarn. - posted by bupt_ljy <bu...@163.com> on 2018/09/06 15:01:12 UTC, 2 replies.
- After OutOfMemoryError State can not be readed - posted by Edward Rojas <ed...@gmail.com> on 2018/09/06 17:22:07 UTC, 3 replies.
- Setting Flink Monitoring API Port on YARN Cluster - posted by Austin Cawley-Edwards <au...@gmail.com> on 2018/09/06 22:33:39 UTC, 3 replies.
- How to customize schedule mode and result partition type? - posted by 陈梓立 <wa...@gmail.com> on 2018/09/07 00:59:44 UTC, 2 replies.
- Flink 1.6 Job fails with IllegalStateException: Buffer pool is destroyed. - posted by 杨力 <bi...@gmail.com> on 2018/09/07 05:08:20 UTC, 2 replies.
- 回复：Flink 1.6 Job fails with IllegalStateException: Buffer pool is destroyed. - posted by "Zhijiang(wangzhijiang999)" <wa...@aliyun.com> on 2018/09/07 07:22:07 UTC, 0 replies.
- Re: Operator metrics do not get unregistered after job finishes - posted by Helmut Zechmann <he...@adeven.com> on 2018/09/07 11:11:13 UTC, 0 replies.
- Flink Failing to Connect to Kafka org.apache.kafka.common.protocol.types.SchemaException: Error computing size for field 'topics': java.lang.NullPointerException - posted by Oliver Buckley-Salmon <ol...@db.com> on 2018/09/07 14:04:00 UTC, 1 replies.
- maxOutOfOrderness - posted by Nicos Maris <ni...@gmail.com> on 2018/09/07 15:17:15 UTC, 1 replies.
- Flink RMQSource Consumer: How I get the RabbitMQ UserId - posted by Marke Builder <ma...@gmail.com> on 2018/09/08 07:44:07 UTC, 3 replies.
- replacing WindowFunction with AggregateFunction - posted by Nicos Maris <ni...@gmail.com> on 2018/09/09 01:40:41 UTC, 2 replies.
- Re: test windows - posted by Nicos Maris <ni...@gmail.com> on 2018/09/09 02:29:11 UTC, 1 replies.
- Question about akka configuration for FLIP-6 - posted by Tony Wei <to...@gmail.com> on 2018/09/10 02:24:13 UTC, 4 replies.
- Exception when run flink-storm-example - posted by jing <ha...@163.com> on 2018/09/10 03:00:04 UTC, 16 replies.
- Re: Facing Issues while migrating to S3A - posted by "yinhua.dai" <yi...@outlook.com> on 2018/09/10 03:07:04 UTC, 0 replies.
- Aggregator State in Keyed Windowed Stream - posted by Ning Shi <ni...@gmail.com> on 2018/09/10 03:28:06 UTC, 6 replies.
- [ANNOUNCE] Weekly community update #37 - posted by Till Rohrmann <tr...@apache.org> on 2018/09/10 06:32:11 UTC, 0 replies.
- UnsatisfiedLinkError when using flink-s3-fs-hadoop - posted by "yinhua.dai" <yi...@outlook.com> on 2018/09/10 07:43:40 UTC, 0 replies.
- JobManager container is running beyond physical memory limits - posted by eSKa <es...@gmail.com> on 2018/09/10 09:18:54 UTC, 4 replies.
- Re: Problem with querying state on Flink 1.6. - posted by Kostas Kloudas <k....@data-artisans.com> on 2018/09/10 12:13:31 UTC, 5 replies.
- Hashjoin implementation - posted by Benjamin Burkhardt <be...@cs.tu-darmstadt.de> on 2018/09/10 14:08:22 UTC, 3 replies.
- Acknowledging Pubsub messages in Flink Runner - posted by Encho Mishinev <en...@gmail.com> on 2018/09/10 15:24:33 UTC, 1 replies.
- Flink JMX Metrics - posted by PedroMrChaves <pe...@gmail.com> on 2018/09/10 18:19:22 UTC, 1 replies.
- Triggering Savepoints with the Monitoring API - posted by Austin Cawley-Edwards <au...@gmail.com> on 2018/09/10 23:27:08 UTC, 2 replies.
- metrics displays on and off when integrate Flink metrics with graphite/Grafana - posted by "James (Jian Wu) [FDS Data Platform]" <ja...@coupang.com> on 2018/09/11 05:42:01 UTC, 2 replies.
- Server side error: Cannot find required BLOB at /tmp/blobStore - posted by "Raja.Aravapalli" <Ra...@target.com> on 2018/09/11 07:01:15 UTC, 2 replies.
- Re: [EXTERNAL] Re: Server side error: Cannot find required BLOB at /tmp/blobStore - posted by "Raja.Aravapalli" <Ra...@target.com> on 2018/09/11 07:18:04 UTC, 1 replies.
- [Kerberos] JAAS module content not generated? javax.security.auth.callback.UnsupportedCallbackException: Could not login: the client is being asked for a password, but the Kafka client code does not currently support obtaining a password from the user. - posted by Sebastien Pereira <sp...@parigo.com> on 2018/09/11 08:08:26 UTC, 3 replies.
- Create a file in parquet format - posted by jose farfan <jo...@gmail.com> on 2018/09/11 09:59:52 UTC, 2 replies.
- How to get Cluster metrics in FLIP-6 mode - posted by Tony Wei <to...@gmail.com> on 2018/09/11 10:19:50 UTC, 2 replies.
- ElasticSearch Checkpointing taking too much time - posted by shashank734 <sh...@gmail.com> on 2018/09/11 13:43:27 UTC, 6 replies.
- Deadlock in SafetyNetCloseableRegistry? - posted by bupt_ljy <bu...@163.com> on 2018/09/11 14:22:14 UTC, 1 replies.
- Between Checkpoints in Kafka 11 - posted by Harshvardhan Agrawal <ha...@gmail.com> on 2018/09/11 14:54:12 UTC, 4 replies.
- Speakers needed for Apache DC Roadshow - posted by Rich Bowen <rb...@apache.org> on 2018/09/11 15:05:52 UTC, 0 replies.
- How does flink read a DataSet? - posted by Taher Koitawala <ta...@gslab.com> on 2018/09/11 17:48:51 UTC, 6 replies.
- What is the right way to add classpath? - posted by bupt_ljy <bu...@163.com> on 2018/09/12 08:34:17 UTC, 2 replies.
- Flink Checkpointing in production - posted by Ahmad Hassan <ah...@gmail.com> on 2018/09/12 08:38:49 UTC, 1 replies.
- Re: aggregate does not allow RichAggregateFunction ? - posted by chiggi_dev <ch...@yahoo.in> on 2018/09/12 09:09:56 UTC, 0 replies.
- How to clear keyed states periodically? - posted by Paul Lam <pa...@gmail.com> on 2018/09/12 10:06:10 UTC, 7 replies.
- Custom metrics in Watermark Assigner - posted by Oleksandr Nitavskyi <o....@criteo.com> on 2018/09/12 13:47:58 UTC, 1 replies.
- Task managers run on separate nodes in a cluster - posted by Martin Eden <ma...@gmail.com> on 2018/09/12 15:21:22 UTC, 7 replies.
- Weird behaviour after change sources in a job. - posted by Juan Gentile <j....@criteo.com> on 2018/09/12 16:03:49 UTC, 5 replies.
- Question regarding Streaming Resources - posted by on 2018/09/12 16:55:09 UTC, 5 replies.
- Broadcast managed state - posted by Deepya <md...@gmail.com> on 2018/09/12 20:39:13 UTC, 1 replies.
- Test harness for validating proper checkpointing of custom SourceFunction - posted by Ken Krugler <kk...@transpac.com> on 2018/09/12 21:37:03 UTC, 1 replies.
- Logging metrics from within Elasticsearch ActionRequestFailureHandler - posted by Averell <lv...@gmail.com> on 2018/09/13 01:50:35 UTC, 2 replies.
- How to get taskmanager hostname and port on runtime - posted by 郑舒力 <ne...@gmail.com> on 2018/09/13 04:07:49 UTC, 2 replies.
- Flink application down due to RpcTimeout exception - posted by 徐涛 <ha...@gmail.com> on 2018/09/13 06:10:37 UTC, 0 replies.
- 回复：Flink application down due to RpcTimeout exception - posted by "Zhijiang(wangzhijiang999)" <wa...@aliyun.com> on 2018/09/13 06:37:18 UTC, 0 replies.
- How to handle exceptions in Kafka sink? - posted by HarshithBolar <hk...@arity.com> on 2018/09/13 07:48:38 UTC, 0 replies.
- How to add flink table jar to classpath via bin/flink - posted by Jeff Zhang <zj...@gmail.com> on 2018/09/13 08:44:53 UTC, 1 replies.
- Orc Sink Table - posted by jose farfan <jo...@gmail.com> on 2018/09/13 09:50:01 UTC, 3 replies.
- StreamingFileSink with PrestoFS? - posted by Jared Stehler <ja...@intellifylearning.com> on 2018/09/13 12:40:49 UTC, 2 replies.
- Re: Filescheme GS not found sometimes - inconsistent exceptions for reading from GCS - posted by Nico Kruber <ni...@data-artisans.com> on 2018/09/13 12:41:27 UTC, 2 replies.
- Question Regarding Streaming pipeline - posted by on 2018/09/13 16:04:44 UTC, 1 replies.
- Can rocksDBBackend handle rescaling? - posted by 廖嘉逸 <bu...@163.com> on 2018/09/13 17:50:40 UTC, 3 replies.
- Watermarks in Event Time windowing - posted by Taher Koitawala <ta...@gslab.com> on 2018/09/13 18:06:52 UTC, 3 replies.
- Client failed to get cancel with savepoint response - posted by Paul Lam <pa...@gmail.com> on 2018/09/14 02:41:07 UTC, 1 replies.
- 回复: Client failed to get cancel with savepoint response(Internet mail) - posted by "devinduan (段丁瑞)" <de...@tencent.com> on 2018/09/14 02:49:25 UTC, 0 replies.
- Re: Client failed to get cancel with savepoint response(Internet mail) - posted by Paul Lam <pa...@gmail.com> on 2018/09/14 03:12:05 UTC, 3 replies.
- Window operator schema evolution - savepoint deserialization fail - posted by tisonet <ti...@seznam.cz> on 2018/09/14 07:48:09 UTC, 3 replies.
- Conversion to relational algebra failed to preserve datatypes - posted by "Yuan,Youjun" <yu...@baidu.com> on 2018/09/14 08:49:47 UTC, 1 replies.
- Compute Symmetrical Uncertainty in parallel - posted by Alejandro <al...@gmail.com> on 2018/09/14 10:55:59 UTC, 0 replies.
- Unit / Integration Test Timer - posted by ashish pok <as...@yahoo.com> on 2018/09/14 13:35:50 UTC, 5 replies.
- Question regarding state cleaning using timer - posted by on 2018/09/14 14:29:23 UTC, 4 replies.
- CombinableGroupReducer says The Iterable can be iterated over only once - posted by Alejandro Alcalde <al...@gmail.com> on 2018/09/14 14:53:09 UTC, 3 replies.
- 答复: Conversion to relational algebra failed to preserve datatypes - posted by "Yuan,Youjun" <yu...@baidu.com> on 2018/09/14 14:55:35 UTC, 0 replies.
- Setting a custom Kryo serializer in Flink-Python - posted by Joe Malt <jm...@yelp.com> on 2018/09/14 17:30:59 UTC, 1 replies.
- LocalEnvironment and Python streaming - posted by Joe Malt <jm...@yelp.com> on 2018/09/14 17:51:44 UTC, 2 replies.
- Trying to figure out why a slot takes a long time to checkpoint - posted by Julio Biason <ju...@azion.com> on 2018/09/14 23:00:17 UTC, 14 replies.
- why same Sliding ProcessTime TimeWindow triggered twice - posted by 远远 <zh...@gmail.com> on 2018/09/16 07:19:19 UTC, 3 replies.
- twitter source is shutting down after successfull connect - posted by Björn Ebbinghaus <bj...@gmail.com> on 2018/09/16 15:43:13 UTC, 1 replies.
- Utilising EMR's master node - posted by Averell <lv...@gmail.com> on 2018/09/17 03:22:38 UTC, 6 replies.
- Flink 1.6.0 not allocating specified TMs in Yarn - posted by Subramanya Suresh <ss...@salesforce.com> on 2018/09/17 07:15:36 UTC, 5 replies.
- Re: 1.5.1 - posted by Juho Autio <ju...@rovio.com> on 2018/09/17 09:01:42 UTC, 0 replies.
- Flink 1.3.2 RocksDB map segment fail if configured as state backend - posted by Andrea Spina <an...@radicalbit.io> on 2018/09/17 09:37:36 UTC, 3 replies.
- Lookup from state - posted by Taher Koitawala <ta...@gslab.com> on 2018/09/17 13:15:28 UTC, 1 replies.
- questions about YARN deployment and HDFS integration - posted by Chang Liu <fl...@gmail.com> on 2018/09/17 13:47:45 UTC, 2 replies.
- [ANNOUNCE] Weekly community update #38 - posted by Till Rohrmann <tr...@apache.org> on 2018/09/17 14:46:41 UTC, 0 replies.
- Potential bug in Flink SQL HOP and TUMBLE operators - posted by John Stone <el...@gmail.com> on 2018/09/17 15:21:54 UTC, 9 replies.
- Writer has already been opened on BucketingSink to S3 - posted by Chengzhi Zhao <w....@gmail.com> on 2018/09/17 16:01:19 UTC, 3 replies.
- Expire records in FLINK dynamic tables? - posted by burgesschen <tc...@bloomberg.net> on 2018/09/17 18:10:31 UTC, 1 replies.
- In which case the StreamNode has multiple output edges? - posted by 徐涛 <ha...@gmail.com> on 2018/09/18 02:34:41 UTC, 3 replies.
- Migration to Flink 1.6.0, issues with StreamExecutionEnvironment.registerCachedFile - posted by Subramanya Suresh <ss...@salesforce.com> on 2018/09/18 04:10:59 UTC, 3 replies.
- InpoolUsage & InpoolBuffers inconsistence - posted by aitozi <gj...@gmail.com> on 2018/09/18 04:49:52 UTC, 1 replies.
- 回复：InpoolUsage & InpoolBuffers inconsistence - posted by "Zhijiang(wangzhijiang999)" <wa...@aliyun.com> on 2018/09/18 06:29:25 UTC, 1 replies.
- 回复：回复：InpoolUsage & InpoolBuffers inconsistence - posted by "Zhijiang(wangzhijiang999)" <wa...@aliyun.com> on 2018/09/18 09:39:05 UTC, 0 replies.
- Add operator ids for an already running job - posted by Paul Lam <pa...@gmail.com> on 2018/09/18 11:11:29 UTC, 5 replies.
- 2 Broadcast streams to a Single Keyed Stream....how to? - posted by Vishal Santoshi <vi...@gmail.com> on 2018/09/18 12:59:27 UTC, 6 replies.
- Re: [External] Re: Setting a custom Kryo serializer in Flink-Python - posted by Joe Malt <jm...@yelp.com> on 2018/09/18 18:05:42 UTC, 1 replies.
- job submitting hanging - posted by Jason Chang <ja...@gotinder.com> on 2018/09/19 00:31:08 UTC, 1 replies.
- Checkpointing not working - posted by yuvraj singh <19...@gmail.com> on 2018/09/19 06:25:00 UTC, 3 replies.
- ***UNCHECKED*** Re: Checkpointing not working - posted by yuvraj singh <19...@gmail.com> on 2018/09/19 06:51:32 UTC, 1 replies.
- ***UNCHECKED*** Re: Standalone cluster instability - posted by Shailesh Jain <sh...@stellapps.com> on 2018/09/19 07:35:33 UTC, 1 replies.
- S3 connector Hadoop class mismatch - posted by Paul Lam <pa...@gmail.com> on 2018/09/19 07:54:28 UTC, 5 replies.
- ***UNCHECKED*** Error while confirming Checkpoint - posted by PedroMrChaves <pe...@gmail.com> on 2018/09/19 08:04:06 UTC, 5 replies.
- Question about Window Tigger - posted by Chang Liu <fl...@gmail.com> on 2018/09/19 08:36:15 UTC, 5 replies.
- HA failing for 1.6.0 job cluster with docker-compose - posted by Tzanko Matev <ts...@gmail.com> on 2018/09/19 09:47:38 UTC, 4 replies.
- How to use checkpoint in flink1.5.3 - posted by spoon_lz <97...@qq.com> on 2018/09/19 12:03:35 UTC, 3 replies.
- Flink 1.5.2 process keeps reference to deleted blob files. - posted by Piotr Szczepanek <pi...@gmail.com> on 2018/09/19 14:04:27 UTC, 1 replies.
- Accessing Global State when processing KeyedStreams - posted by Scott Sue <sc...@celer-tech.com> on 2018/09/19 14:11:03 UTC, 2 replies.
- Errors in QueryableState sample code? - posted by Ken Krugler <kk...@transpac.com> on 2018/09/19 22:27:32 UTC, 1 replies.
- Which mode to choose flink on Yarn. - posted by weilongxing <we...@aicaigroup.com> on 2018/09/20 02:26:53 UTC, 5 replies.
- multiple flink applications on yarn are shown in one application. - posted by weilongxing <we...@aicaigroup.com> on 2018/09/20 08:29:57 UTC, 4 replies.
- Why FlinkKafkaConsumer08 does not support exactly once or at least once semantic? - posted by 徐涛 <ha...@gmail.com> on 2018/09/20 08:48:19 UTC, 2 replies.
- How to get the location of keytab when using flink on yarn - posted by 杨光 <la...@gmail.com> on 2018/09/20 09:20:23 UTC, 5 replies.
- Unit/Integration test for stateful source - posted by Darshan Singh <da...@gmail.com> on 2018/09/20 13:29:54 UTC, 1 replies.
- Re: Data loss when restoring from savepoint - posted by Juho Autio <ju...@rovio.com> on 2018/09/20 13:37:53 UTC, 2 replies.
- Flink takes 40ms ~ 100ms to proceed from one operator to another? - posted by James Yu <cy...@gmail.com> on 2018/09/20 13:59:40 UTC, 8 replies.
- [ANNOUNCE] Apache Flink 1.5.4 released - posted by Till Rohrmann <tr...@apache.org> on 2018/09/20 14:36:22 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.6.1 released - posted by Till Rohrmann <tr...@apache.org> on 2018/09/20 14:37:48 UTC, 0 replies.
- Strange behaviour with checkpointing and custom FilePathFilter - posted by Averell <lv...@gmail.com> on 2018/09/20 22:51:46 UTC, 10 replies.
- Flink can't initialize operator state backend when starting from checkpoint - posted by Marvin777 <xy...@gmail.com> on 2018/09/21 07:20:50 UTC, 3 replies.
- How to join stream and batch data in Flink? - posted by 徐涛 <ha...@gmail.com> on 2018/09/21 08:43:29 UTC, 11 replies.
- How does flink read data from kafka number of TM's are more than topic partitions - posted by Taher Koitawala <ta...@gslab.com> on 2018/09/21 11:25:17 UTC, 3 replies.
- Re: Running Flink in Google Cloud Platform (GCP) - can Flink be truly elastic? - posted by Dawid Wysakowicz <dw...@apache.org> on 2018/09/21 15:41:58 UTC, 2 replies.
- Flink 1.5.4 -- issues w/ TaskManager connecting to ResourceManager - posted by Jamie Grier <jg...@lyft.com> on 2018/09/22 00:33:21 UTC, 8 replies.
- Flink not running properly. - posted by Sarabjyotsingh Multani <ii...@iiita.ac.in> on 2018/09/23 13:50:10 UTC, 2 replies.
- error closing kafka - posted by yuvraj singh <19...@gmail.com> on 2018/09/24 06:22:34 UTC, 3 replies.
- [ANNOUNCE] Weekly community update #39 - posted by Till Rohrmann <tr...@apache.org> on 2018/09/24 10:11:58 UTC, 0 replies.
- Flink TaskManagers do not start until job is submitted in YARN - posted by suraj7 <su...@amagi.com> on 2018/09/24 10:24:58 UTC, 5 replies.
- Information required regarding SSL algorithms for Flink 1.5.x - posted by "V N, Suchithra (Nokia - IN/Bangalore)" <su...@nokia.com> on 2018/09/24 10:29:11 UTC, 3 replies.
- JMX Configuration: Missing Job Related Beans - posted by Sayat Satybaldiyev <sa...@gmail.com> on 2018/09/24 10:37:57 UTC, 2 replies.
- error with session window - posted by yuvraj singh <19...@gmail.com> on 2018/09/24 11:26:16 UTC, 2 replies.
- 1.5 Checkpoint metadata location - posted by Bryant Baltes <br...@gmail.com> on 2018/09/24 16:29:10 UTC, 3 replies.
- When should the RETAIN_ON_CANCELLATION option be used? - posted by 徐涛 <ha...@gmail.com> on 2018/09/25 02:41:28 UTC, 6 replies.
- Scheduling sources - posted by Averell <lv...@gmail.com> on 2018/09/25 06:16:16 UTC, 6 replies.
- Strange behavior of FsStateBackend checkpoint when local executing - posted by 徐涛 <ha...@gmail.com> on 2018/09/25 06:43:52 UTC, 1 replies.
- "405 HTTP method POST is not supported by this URL" is returned when POST a REST url on Flink on yarn - posted by 徐涛 <ha...@gmail.com> on 2018/09/25 07:43:32 UTC, 3 replies.
- Flink - Process datastream in a bounded context (like Dataset) - Unifying stream & batch - posted by bastien dine <ba...@gmail.com> on 2018/09/25 08:14:23 UTC, 3 replies.
- Could not find a suitable table factory for 'org.apache.flink.table.factories.DeserializationSchemaFactory' in the classpath. - posted by clay4444 <cl...@gmail.com> on 2018/09/25 10:02:18 UTC, 4 replies.
- Re: Could not retrieve the redirect address - No REST endpoint has been started - posted by PedroMrChaves <pe...@gmail.com> on 2018/09/25 10:36:49 UTC, 0 replies.
- Get last element of a DataSe - posted by Alejandro Alcalde <al...@gmail.com> on 2018/09/25 10:55:42 UTC, 2 replies.
- timewindowall and aggregate(count): count 0 when no event in the window - posted by Luigi Sgaglione <lu...@gmail.com> on 2018/09/25 10:59:31 UTC, 0 replies.
- Should Queryable State Server be listening on 127.0.1.1? - posted by Andrew Kowpak <an...@ssimwave.com> on 2018/09/25 12:13:27 UTC, 1 replies.
- Null Flink State - posted by Taher Koitawala <ta...@gslab.com> on 2018/09/25 13:07:45 UTC, 2 replies.
- ArrayIndexOutOfBoundsException - posted by Alexander Smirnov <al...@gmail.com> on 2018/09/25 14:37:18 UTC, 4 replies.
- Rocksdb Metrics - posted by Sayat Satybaldiyev <sa...@gmail.com> on 2018/09/25 15:51:15 UTC, 4 replies.
- Intermittent issue with GCS storage - posted by Heath Albritton <ha...@harm.org> on 2018/09/26 02:58:06 UTC, 0 replies.
- RocksDB Read IOPs - posted by Ning Shi <ni...@gmail.com> on 2018/09/26 03:25:43 UTC, 3 replies.
- Measure task execution time - posted by Alejandro <al...@gmail.com> on 2018/09/26 08:16:54 UTC, 1 replies.
- Re: Help: how to get latency value comfortable in Flink1.5? - posted by Till Rohrmann <tr...@apache.org> on 2018/09/26 09:42:50 UTC, 2 replies.
- Re: FlinkCEP, circular references and checkpointing failures - posted by Shailesh Jain <sh...@stellapps.com> on 2018/09/26 11:50:24 UTC, 4 replies.
- OpenSSL use in Flink - posted by "V N, Suchithra (Nokia - IN/Bangalore)" <su...@nokia.com> on 2018/09/26 12:08:55 UTC, 1 replies.
- Question about sharing resource among slots with a TM - posted by Vishal Santoshi <vi...@gmail.com> on 2018/09/26 13:15:05 UTC, 5 replies.
- Can't get the FlinkKinesisProducer to work against Kinesalite for tests - posted by Bruno Aranda <ba...@apache.org> on 2018/09/26 13:59:41 UTC, 1 replies.
- Metrics: (1) Histogram in prometheus and (2) meter by event_time - posted by Averell <lv...@gmail.com> on 2018/09/27 06:45:36 UTC, 4 replies.
- Avro serialization problem after updating to flink 1.6.0 - posted by Mark Harris <ma...@hivehome.com> on 2018/09/27 08:03:29 UTC, 0 replies.
- New received containers silently lost during job auto restarts - posted by Paul Lam <pa...@gmail.com> on 2018/09/27 11:24:25 UTC, 5 replies.
- LIMIT and ORDER BY in hop window is not supported? - posted by 徐涛 <ha...@gmail.com> on 2018/09/27 13:05:35 UTC, 3 replies.
- JobManager in HA with a single node loses leadership - posted by Julio Biason <ju...@azion.com> on 2018/09/27 19:56:14 UTC, 3 replies.
- Flink design questions - parallel processing and state management - posted by "lgfmt@yahoo.com" <lg...@yahoo.com> on 2018/09/27 22:21:03 UTC, 0 replies.
- In-Memory Lookup in Flink Operators - posted by Chirag Dewan <ch...@yahoo.in> on 2018/09/28 04:28:01 UTC, 3 replies.
- Regarding implementation of aggregate function using a ProcessFunction - posted by Gaurav Luthra <ga...@gmail.com> on 2018/09/28 05:38:42 UTC, 8 replies.
- flink-1.6.1-bin-scala_2.11.tgz fails signture and hash verification - posted by Gianluca Ortelli <gi...@mediadistillery.com> on 2018/09/28 08:02:02 UTC, 1 replies.
- Does Flink SQL "in" operation has length limit? - posted by 徐涛 <ha...@gmail.com> on 2018/09/28 08:22:56 UTC, 4 replies.
- [DISCUSS] Dropping flink-storm? - posted by Till Rohrmann <tr...@apache.org> on 2018/09/28 13:22:24 UTC, 7 replies.
- Job failing during restore in different cluster - posted by shashank734 <sh...@gmail.com> on 2018/09/28 14:21:09 UTC, 1 replies.
- Streaming to Parquet Files in HDFS - posted by William Speirs <ws...@apache.org> on 2018/09/28 20:57:21 UTC, 1 replies.
- Deserialization of serializer errored - posted by Elias Levy <fe...@gmail.com> on 2018/09/29 00:23:38 UTC, 0 replies.
- Flink standalone cluster load average is too high. - posted by weilongxing <we...@aicaigroup.com> on 2018/09/29 05:43:19 UTC, 0 replies.
- 回复：[DISCUSS] Dropping flink-storm? - posted by "Zhijiang(wangzhijiang999)" <wa...@aliyun.com> on 2018/09/29 05:53:34 UTC, 0 replies.
- Re: Flink standalone cluster load average is too high. - posted by Congxian Qiu <qc...@gmail.com> on 2018/09/29 06:14:32 UTC, 1 replies.
- About the retract of the calculation result of flink sql - posted by clay4444 <cl...@gmail.com> on 2018/09/29 07:42:33 UTC, 2 replies.
- Superstep-like synchronization of streaming iteration - posted by Christian Lehner <ch...@gmail.com> on 2018/09/29 18:51:26 UTC, 0 replies.
- Flink Scheduler Customization - posted by Ananth Durai <va...@gmail.com> on 2018/09/29 19:11:38 UTC, 0 replies.
- Re: I want run flink program in ubuntu x64 Mult Node Cluster what is configuration? - posted by Mar_zieh <m....@gmail.com> on 2018/09/30 09:31:36 UTC, 3 replies.