You are viewing a plain text version of this content. The canonical link for it is here.
- Re: FlinkKafkaProducerXX - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2017/12/01 04:16:24 UTC, 2 replies.
- Re: [EXTERNAL] difference between checkpoints & savepoints - posted by Hao Sun <ha...@zendesk.com> on 2017/12/01 06:21:33 UTC, 0 replies.
- ElasticSearch Connector for version 6.x and scala 2.11 - posted by Rahul Raj <ra...@gmail.com> on 2017/12/01 06:22:36 UTC, 2 replies.
- Re: Questions about checkpoints/savepoints - posted by Hao Sun <ha...@zendesk.com> on 2017/12/01 06:35:32 UTC, 0 replies.
- Checkpoint expired before completing - posted by Steven Wu <st...@gmail.com> on 2017/12/01 06:36:05 UTC, 6 replies.
- Re: flink local & interactive development - posted by Fabian Hueske <fh...@gmail.com> on 2017/12/01 09:10:52 UTC, 1 replies.
- Re: Non-intrusive way to detect which type is using kryo ? - posted by Kien Truong <du...@gmail.com> on 2017/12/01 12:42:54 UTC, 1 replies.
- Re: Kafka consumer to sync topics by event time? - posted by Juho Autio <ju...@rovio.com> on 2017/12/01 12:43:55 UTC, 3 replies.
- Incremental RocksDB checkpointing - posted by vijayakumar palaniappan <vi...@gmail.com> on 2017/12/01 15:34:19 UTC, 3 replies.
- aggregate does not allow RichAggregateFunction ? - posted by Vishal Santoshi <vi...@gmail.com> on 2017/12/01 18:38:13 UTC, 8 replies.
- non-shared TaskManager-specific config file - posted by Hao Sun <ha...@zendesk.com> on 2017/12/01 22:14:44 UTC, 5 replies.
- Trace jar file name from jobId, is that possible? - posted by Hao Sun <ha...@zendesk.com> on 2017/12/01 23:28:08 UTC, 7 replies.
- using regular expression to specify Kafka topics - posted by Soheil Pourbafrani <so...@gmail.com> on 2017/12/02 21:28:47 UTC, 4 replies.
- Blob server not working with 1.4.0.RC2 - posted by Be...@Dev.Helaba.de on 2017/12/04 09:03:37 UTC, 4 replies.
- TaskManager HA on YARN - posted by "Marchant, Hayden " <ha...@citi.com> on 2017/12/04 10:31:54 UTC, 1 replies.
- Re: Maintain heavy hitters in Flink application - posted by Fabian Hueske <fh...@gmail.com> on 2017/12/04 10:51:17 UTC, 4 replies.
- Re: Flik typesafe configuration - posted by Fabian Hueske <fh...@gmail.com> on 2017/12/04 11:11:09 UTC, 0 replies.
- Window function support on SQL - posted by Tao Xia <ta...@udacity.com> on 2017/12/04 21:17:36 UTC, 3 replies.
- CPU Cores of JobManager - posted by Yuta Morisawa <yu...@kddi-research.jp> on 2017/12/05 04:13:26 UTC, 10 replies.
- subscribe - posted by Xin Wang <da...@gmail.com> on 2017/12/05 07:21:20 UTC, 1 replies.
- Share state across operators - posted by Shailesh Jain <sh...@stellapps.com> on 2017/12/05 10:58:14 UTC, 3 replies.
- Flink with Ceph as the persistent storage - posted by Jayant Ameta <wi...@gmail.com> on 2017/12/05 11:00:29 UTC, 3 replies.
- slot group indication per operator - posted by "Sofer, Tovi " <to...@citi.com> on 2017/12/05 15:25:03 UTC, 2 replies.
- Re: S3 Write Execption - posted by vinay patil <vi...@gmail.com> on 2017/12/05 17:18:58 UTC, 1 replies.
- Flink Batch Performance degradation at scale - posted by Garrett Barton <ga...@gmail.com> on 2017/12/05 21:03:47 UTC, 12 replies.
- Re: How to perform efficient DataSet reuse between iterations - posted by Miguel Coimbra <mi...@gmail.com> on 2017/12/06 02:01:43 UTC, 5 replies.
- Performance of docker-flink - posted by Jayant Ameta <wi...@gmail.com> on 2017/12/06 08:43:21 UTC, 2 replies.
- the location of JsonRowDeserializationSchema.java - posted by Sendoh <un...@gmail.com> on 2017/12/06 16:35:13 UTC, 4 replies.
- save points through REST API not supported ? - posted by Vishal Santoshi <vi...@gmail.com> on 2017/12/06 18:56:11 UTC, 13 replies.
- Data loss in Flink Kafka Pipeline - posted by Nishu <ni...@gmail.com> on 2017/12/07 08:43:30 UTC, 9 replies.
- ClassNotFoundException in custom SourceFunction - posted by "romain.jln" <ro...@gmail.com> on 2017/12/07 09:35:16 UTC, 8 replies.
- Re: Taskmanagers are quarantined - posted by T Obi <t....@geniee.co.jp> on 2017/12/07 12:06:48 UTC, 0 replies.
- Hardware Reference Architecture - posted by "Marchant, Hayden " <ha...@citi.com> on 2017/12/07 12:53:35 UTC, 2 replies.
- Flink 1.4.0 RC3 and Avro objects with maps have null values - posted by Joern Kottmann <ko...@gmail.com> on 2017/12/07 14:19:39 UTC, 6 replies.
- Testing CoFlatMap correctness - posted by "Sofer, Tovi " <to...@citi.com> on 2017/12/07 16:54:25 UTC, 3 replies.
- Re: specify user name when connecting to hdfs - posted by Edward <eg...@hotmail.com> on 2017/12/07 20:49:53 UTC, 1 replies.
- does the flink sink only support bio? - posted by Jinhua Luo <lu...@gmail.com> on 2017/12/08 07:11:02 UTC, 3 replies.
- Problem with runGatherSumApplyIteration - posted by ro...@informatik.uni-leipzig.de on 2017/12/08 09:23:08 UTC, 2 replies.
- TableException: GenericTypeInfo cannot be converted to Table - posted by Sendoh <un...@gmail.com> on 2017/12/08 10:19:19 UTC, 4 replies.
- Manual Classloading on the job does not work - posted by Be...@Dev.Helaba.de on 2017/12/08 10:38:24 UTC, 1 replies.
- deserilize nested json - posted by Sendoh <un...@gmail.com> on 2017/12/08 11:33:03 UTC, 1 replies.
- Can not resolve org.apache.hadoop.fs.Path in 1.4.0 - posted by shashank agarwal <sh...@gmail.com> on 2017/12/08 13:10:28 UTC, 20 replies.
- Re: REST api: how to upload jar? - posted by Edward <eg...@hotmail.com> on 2017/12/08 16:10:13 UTC, 4 replies.
- Exception when using the time attribute in table API - posted by Sendoh <un...@gmail.com> on 2017/12/08 16:36:35 UTC, 3 replies.
- Parallelizing a tumbling group window - posted by Colin Williams <co...@gmail.com> on 2017/12/09 02:06:49 UTC, 2 replies.
- ayncIO & TM akka response - posted by Chen Qin <qi...@gmail.com> on 2017/12/09 19:35:24 UTC, 1 replies.
- Custom Metrics - posted by Navneeth Krishnan <re...@gmail.com> on 2017/12/10 17:51:54 UTC, 5 replies.
- The timing operation is similar to storm’s tick - posted by Marvin777 <xy...@gmail.com> on 2017/12/11 08:03:31 UTC, 2 replies.
- How to deal with dynamic types - posted by madan <ma...@gmail.com> on 2017/12/11 15:13:20 UTC, 1 replies.
- Flink-Kafka connector - partition offsets for a given timestamp? - posted by "Yang, Connie" <cy...@ebay.com> on 2017/12/11 19:53:05 UTC, 2 replies.
- ProgramInvocationException: Could not upload the jar files to the job manager / No space left on device - posted by "Chan, Regina" <Re...@gs.com> on 2017/12/12 06:55:37 UTC, 2 replies.
- when does the timed window ends? - posted by Jinhua Luo <lu...@gmail.com> on 2017/12/12 06:57:42 UTC, 6 replies.
- could I chain two timed window? - posted by Jinhua Luo <lu...@gmail.com> on 2017/12/12 07:10:23 UTC, 1 replies.
- what's the best practice to determine event-time watermark for unordered stream? - posted by Jinhua Luo <lu...@gmail.com> on 2017/12/12 09:16:48 UTC, 7 replies.
- [ANNOUNCE] Apache Flink 1.4.0 released - posted by Aljoscha Krettek <al...@apache.org> on 2017/12/12 11:46:09 UTC, 1 replies.
- Re: [ANNOUNCE] Apache Flink 1.4.0 released - posted by Fabian Hueske <fh...@gmail.com> on 2017/12/12 12:39:48 UTC, 5 replies.
- Re: Kafka topic partition skewness causes watermark not being emitted - posted by gerardg <ge...@talaia.io> on 2017/12/12 13:28:37 UTC, 2 replies.
- Re: Off heap memory issue - posted by Javier Lopez <ja...@zalando.de> on 2017/12/12 13:47:09 UTC, 1 replies.
- Flink Kafka Producer Exception - posted by Navneeth Krishnan <re...@gmail.com> on 2017/12/12 18:21:23 UTC, 2 replies.
- hadoop error with flink mesos on startup - posted by Jared Stehler <ja...@intellifylearning.com> on 2017/12/12 18:28:07 UTC, 4 replies.
- Calling an operator serially - posted by Philip Doctor <ph...@physiq.com> on 2017/12/12 23:49:58 UTC, 2 replies.
- Could not flush and close the file system output stream to s3a, is this fixed? - posted by Hao Sun <ha...@zendesk.com> on 2017/12/13 04:28:48 UTC, 3 replies.
- Cannot load user classes - posted by Soheil Pourbafrani <so...@gmail.com> on 2017/12/13 07:25:56 UTC, 1 replies.
- netty conflict using lettuce redis client - posted by Jinhua Luo <lu...@gmail.com> on 2017/12/13 12:58:57 UTC, 1 replies.
- ClassCastException when using RowTypeInfo - posted by madan <ma...@gmail.com> on 2017/12/13 15:16:18 UTC, 1 replies.
- Watermark in broadcast - posted by Seth Wiesman <sw...@mediamath.com> on 2017/12/13 16:10:19 UTC, 5 replies.
- how does time-windowed join and Over-Window Aggregation implemented in flink SQL? - posted by "Yan Zhou [FDS Science]" <yz...@coupang.com> on 2017/12/13 23:09:21 UTC, 2 replies.
- FlinkKafkaProducer011 and Flink 1.4.0 Kafka docs - posted by Elias Levy <fe...@gmail.com> on 2017/12/14 00:07:26 UTC, 1 replies.
- Re: Flink flick cancel vs stop - posted by Elias Levy <fe...@gmail.com> on 2017/12/14 00:43:29 UTC, 1 replies.
- Flink State monitoring - posted by "Netzer, Liron " <li...@citi.com> on 2017/12/14 09:55:55 UTC, 2 replies.
- Fwd: Replace classes at runtime - posted by Jayant Ameta <wi...@gmail.com> on 2017/12/14 11:22:29 UTC, 1 replies.
- Flink 1.4.0 can not override JAVA_HOME for single-job deployment on YARN - posted by 杨光 <la...@gmail.com> on 2017/12/14 11:35:13 UTC, 5 replies.
- [Docs] Can't add metrics to RichFilterFunction - posted by Julio Biason <ju...@azion.com> on 2017/12/14 12:56:41 UTC, 3 replies.
- streamin Table API - strange behavior - posted by Plamen Paskov <pl...@next-stream.com> on 2017/12/14 15:30:06 UTC, 3 replies.
- Service discovery for flink-metrics-prometheus - posted by Kien Truong <du...@gmail.com> on 2017/12/14 15:55:36 UTC, 0 replies.
- Flink long-running streaming job, Keytab authentication - posted by Oleksandr Nitavskyi <o....@criteo.com> on 2017/12/14 16:17:17 UTC, 1 replies.
- Fenzo NoClassDefFoundError: ObjectMapper - posted by Jared Stehler <ja...@intellifylearning.com> on 2017/12/14 20:05:23 UTC, 4 replies.
- Consecutive windowed operations - posted by Ron Crocker <rc...@newrelic.com> on 2017/12/15 00:14:06 UTC, 1 replies.
- docker-flink images and CI - posted by Colin Williams <co...@gmail.com> on 2017/12/15 01:31:02 UTC, 2 replies.
- Can flink aggregate in local TM,then aggregate in global TM? - posted by zhaifengwei <zh...@163.com> on 2017/12/15 07:04:45 UTC, 2 replies.
- Python API not working - posted by Yassine MARZOUGUI <y....@mindlytix.com> on 2017/12/15 10:05:09 UTC, 2 replies.
- Flink 1.4.0 keytab is unreadable - posted by 杨光 <la...@gmail.com> on 2017/12/15 10:34:59 UTC, 2 replies.
- consecutive stream aggregations - posted by Plamen Paskov <pl...@next-stream.com> on 2017/12/15 10:55:21 UTC, 7 replies.
- SANSA 0.3 (Scalable Semantic Analytics Stack) Released - posted by Jens Lehmann <je...@cs.uni-bonn.de> on 2017/12/15 13:09:58 UTC, 0 replies.
- Setting jar file directory for Apache Flink - posted by Soheil Pourbafrani <so...@gmail.com> on 2017/12/15 18:55:19 UTC, 2 replies.
- Why did you pick Scala/Java for your project? - posted by Julio Biason <ju...@azion.com> on 2017/12/15 19:02:22 UTC, 0 replies.
- Job-level close()? - posted by Andrew Roberts <ar...@fuze.com> on 2017/12/15 21:23:01 UTC, 2 replies.
- Flink CEP state store - posted by mahesh dhabade <ma...@gmail.com> on 2017/12/16 07:53:07 UTC, 1 replies.
- how flink extracts timestamp from transformed elements? - posted by Jinhua Luo <lu...@gmail.com> on 2017/12/16 08:01:57 UTC, 5 replies.
- org.apache.flink.streaming.runtime.tasks.StreamTaskException: Cannot load user class: FlinkStreaming - posted by Soheil Pourbafrani <so...@gmail.com> on 2017/12/16 08:19:16 UTC, 1 replies.
- No configuration found for key 'akka.version' after upgrade to Flink 1.4 - posted by Fritz Budiyanto <fb...@icloud.com> on 2017/12/16 15:49:34 UTC, 0 replies.
- flink eventTime, lateness, maxoutoforderness - posted by chen <er...@126.com> on 2017/12/16 16:07:06 UTC, 0 replies.
- Re: flink eventTime, lateness, maxoutoforderness - posted by Eron Wright <er...@gmail.com> on 2017/12/16 18:52:55 UTC, 4 replies.
- Re: Flink vs Spark streaming benchmark - posted by Fabian Hueske <fh...@gmail.com> on 2017/12/16 22:59:46 UTC, 3 replies.
- context in OnElement of Trigger - posted by Vishal Santoshi <vi...@gmail.com> on 2017/12/17 02:06:08 UTC, 3 replies.
- A question about Triggers - posted by Vishal Santoshi <vi...@gmail.com> on 2017/12/17 06:52:20 UTC, 13 replies.
- JVM crash - SIGSEGV in ZIP_GetEntry - posted by Dawid Wysakowicz <wy...@gmail.com> on 2017/12/17 14:03:51 UTC, 3 replies.
- About serialization - When and What - posted by madan <ma...@gmail.com> on 2017/12/18 12:15:31 UTC, 1 replies.
- How flink assigns task slots to the streams of the same app? - posted by Jinhua Luo <lu...@gmail.com> on 2017/12/18 13:11:40 UTC, 1 replies.
- Flink 1.4 with cassandra-connector: Shading error - posted by do...@dbruhn.de on 2017/12/18 14:07:43 UTC, 3 replies.
- Re: custom writer fail to recover - posted by xiatao123 <ta...@udacity.com> on 2017/12/18 23:40:00 UTC, 0 replies.
- Pending parquet file with Bucking Sink - posted by Tao Xia <ta...@udacity.com> on 2017/12/19 00:30:33 UTC, 2 replies.
- 回复:does flink support yarn/hdfs HA? - posted by 邓俊华 <de...@startdt.com> on 2017/12/19 06:28:45 UTC, 1 replies.
- Flink support for Microsoft Windows - posted by avivros <av...@iqpiot.com> on 2017/12/19 08:02:10 UTC, 0 replies.
- How to apply patterns from a source onto another datastream? - posted by Jayant Ameta <wi...@gmail.com> on 2017/12/19 09:10:39 UTC, 5 replies.
- Cassandra POJO sink flink 1.4.0 in scala - posted by shashank agarwal <sh...@gmail.com> on 2017/12/19 10:04:10 UTC, 9 replies.
- state.checkpoints.dir not configured - posted by Plamen Paskov <pl...@next-stream.com> on 2017/12/19 14:45:51 UTC, 4 replies.
- Triggers in Flink CEP - posted by Shailesh Jain <sh...@stellapps.com> on 2017/12/19 16:27:54 UTC, 2 replies.
- Static Variables - posted by Navneeth Krishnan <re...@gmail.com> on 2017/12/19 23:29:41 UTC, 1 replies.
- flink jobmanager HA zookeeper leadership election - RECEIVED SIGNAL 15: SIGTERM. Shutting down as requested. - posted by Colin Williams <co...@gmail.com> on 2017/12/20 03:29:05 UTC, 2 replies.
- NullPointerException with Avro Serializer - posted by Kien Truong <du...@gmail.com> on 2017/12/20 07:09:48 UTC, 2 replies.
- Add new slave to running cluster? - posted by Jinhua Luo <lu...@gmail.com> on 2017/12/20 07:22:32 UTC, 1 replies.
- Metric reporters with non-static ports - posted by Jared Stehler <ja...@intellifylearning.com> on 2017/12/20 16:57:51 UTC, 1 replies.
- Apache Flink - Difference between operator and function - posted by M Singh <ma...@yahoo.com> on 2017/12/20 18:05:39 UTC, 2 replies.
- Restroring from a SP - posted by Vishal Santoshi <vi...@gmail.com> on 2017/12/20 21:27:51 UTC, 1 replies.
- Flink upgrade compatibility table - posted by Colin Williams <co...@gmail.com> on 2017/12/21 02:06:29 UTC, 2 replies.
- entrypoint for executing job in task manager - posted by Steven Wu <st...@gmail.com> on 2017/12/21 06:53:38 UTC, 3 replies.
- - posted by chris snow <ch...@gmail.com> on 2017/12/21 07:15:25 UTC, 0 replies.
- periodic trigger - posted by Plamen Paskov <pl...@next-stream.com> on 2017/12/21 12:29:15 UTC, 4 replies.
- Flink on K8s job submission best practices - posted by Maximilian Bode <ma...@tngtech.com> on 2017/12/22 13:56:13 UTC, 1 replies.
- Flink network access control documentation - posted by Elias Levy <fe...@gmail.com> on 2017/12/22 19:36:53 UTC, 1 replies.
- CSV writer/parser inconsistency when using the Table API? - posted by Cliff Resnick <cr...@gmail.com> on 2017/12/22 20:34:01 UTC, 1 replies.
- How to stop FlinkKafkaConsumer and make job finished? - posted by Jaxon Hu <hu...@gmail.com> on 2017/12/25 07:59:55 UTC, 4 replies.
- flink yarn-cluster run job --files - posted by ri...@sina.cn on 2017/12/25 13:13:54 UTC, 1 replies.
- Apache Flink - broadcasting DataStream - posted by M Singh <ma...@yahoo.com> on 2017/12/25 18:12:44 UTC, 2 replies.
- merging window - posted by aitozi <gj...@gmail.com> on 2017/12/26 03:54:44 UTC, 0 replies.
- Mergingwindow - posted by aitozi <gj...@gmail.com> on 2017/12/26 03:56:16 UTC, 0 replies.
- MergingWindow - posted by aitozi <gj...@gmail.com> on 2017/12/26 03:58:23 UTC, 2 replies.
- Re: Using latency markers - posted by Marvin777 <xy...@gmail.com> on 2017/12/26 07:00:13 UTC, 2 replies.
- Fetching TaskManager log failed - posted by ri...@sina.cn on 2017/12/26 07:50:07 UTC, 1 replies.
- org.apache.zookeeper.ClientCnxn, Client session timed out - posted by Hao Sun <ha...@zendesk.com> on 2017/12/27 15:41:29 UTC, 4 replies.
- keyby() issue - posted by Jinhua Luo <lu...@gmail.com> on 2017/12/28 08:57:36 UTC, 6 replies.
- RichAsyncFunction in scala - posted by Antoine Philippot <an...@teads.tv> on 2017/12/28 15:37:51 UTC, 2 replies.
- queryable state and maintaining all time counts - posted by jelmer <jk...@gmail.com> on 2017/12/29 16:45:15 UTC, 0 replies.
- Parquet Format Read and Write - posted by Imran Tariq <im...@northbaysolutions.net> on 2017/12/29 17:13:52 UTC, 0 replies.
- Testing Flink 1.4 unable to write to s3 locally - posted by Kyle Hamlin <ha...@gmail.com> on 2017/12/31 16:10:25 UTC, 0 replies.
- Separate checkpoint directories - posted by Kyle Hamlin <ha...@gmail.com> on 2017/12/31 16:10:48 UTC, 0 replies.
- Apache Flink - Question about rolling window function on KeyedStream - posted by M Singh <ma...@yahoo.com> on 2017/12/31 21:28:38 UTC, 0 replies.
- Apache Flink - Connected Stream with different number of partitions - posted by M Singh <ma...@yahoo.com> on 2017/12/31 21:38:44 UTC, 0 replies.