flink-user mailing list archives: April 2020

Site index · List index
Message list« Previous · 1 · 2 · 3 · 4 · 5 · 6 · 7 · 8 · 9 · Next »Thread · Author · Date
forideal Re:Re: Blink SQL java.lang.ArrayIndexOutOfBoundsException Tue, 21 Apr, 05:19
Oleg Vysotsky Re: Checkpoints for kafka source sometimes get 55 GB size (instead of 2 MB) and flink job fails during restoring from such checkpoint Tue, 21 Apr, 05:53
Leonard Xu Re: How to print log in flink-streaming-java module Tue, 21 Apr, 06:32
Yun Tang Re: Checkpoints for kafka source sometimes get 55 GB size (instead of 2 MB) and flink job fails during restoring from such checkpoint Tue, 21 Apr, 07:00
Leonard Xu Re: Change to StreamingFileSink in Flink 1.10 Tue, 21 Apr, 07:23
Anil K Re: FlinkKafakaProducer with Confluent SchemaRegistry and KafkaSerializationSchema Tue, 21 Apr, 07:34
Fabian Hueske Re: FlinkKafakaProducer with Confluent SchemaRegistry and KafkaSerializationSchema Tue, 21 Apr, 07:37
Chesnay Schepler Re: Suppressing illegal Access Warnings Tue, 21 Apr, 08:04
Danny Chan Re: Flink upgrade to 1.10: function Tue, 21 Apr, 08:23
Jark Wu Re: Flink upgrade to 1.10: function Tue, 21 Apr, 08:34
Zahid Rahman Re: Suppressing illegal Access Warnings Tue, 21 Apr, 08:55
Sivaprasanna Re: Change to StreamingFileSink in Flink 1.10 Tue, 21 Apr, 08:59
Fu, Kai Unable to unmarshall response (com.ctc.wstx.stax.WstxInputFactory cannot be cast to javax.xml.stream.XMLInputFactory) Tue, 21 Apr, 09:11
Chesnay Schepler Re: Unable to unmarshall response (com.ctc.wstx.stax.WstxInputFactory cannot be cast to javax.xml.stream.XMLInputFactory) Tue, 21 Apr, 09:14
Chesnay Schepler Re: Suppressing illegal Access Warnings Tue, 21 Apr, 09:15
Fu, Kai Re: Unable to unmarshall response (com.ctc.wstx.stax.WstxInputFactory cannot be cast to javax.xml.stream.XMLInputFactory) Tue, 21 Apr, 09:21
Averell Re: Change to StreamingFileSink in Flink 1.10 Tue, 21 Apr, 09:47
Clay Teeter LookupableTableSource from kafka consumer Tue, 21 Apr, 11:43
Robert Metzger Re: Checkpoint Error Because "Could not find any valid local directory for s3ablock-0001" Tue, 21 Apr, 11:50
Arvid Heise Re: Passing checkpoint lock object to StreamSourceContexts.getSourceContext after StreamTask.getCheckpointLock deprecation Tue, 21 Apr, 11:58
Robert Metzger Re: Latency tracking together with broadcast state can cause job failure Tue, 21 Apr, 12:01
Jark Wu Re: LookupableTableSource from kafka consumer Tue, 21 Apr, 12:02
Flavio Pompermaier Enable custom REST APIs in Flink Tue, 21 Apr, 12:30
Leonard Xu Re: Change to StreamingFileSink in Flink 1.10 Tue, 21 Apr, 12:32
Shachar Carmeli Re: Flink incremental checkpointing - how long does data is kept in the share folder Tue, 21 Apr, 12:46
Flavio Pompermaier JDBC Table and parameters provider Tue, 21 Apr, 13:59
Seth Wiesman Re: Change to StreamingFileSink in Flink 1.10 Tue, 21 Apr, 14:03
Leonard Xu Re: Change to StreamingFileSink in Flink 1.10 Tue, 21 Apr, 14:15
Oytun Tez Re: Enable custom REST APIs in Flink Tue, 21 Apr, 14:17
Jeff Zhang Re: Enable custom REST APIs in Flink Tue, 21 Apr, 14:39
Flavio Pompermaier Re: Enable custom REST APIs in Flink Tue, 21 Apr, 15:06
Oytun Tez Re: Enable custom REST APIs in Flink Tue, 21 Apr, 15:10
Jeff Zhang Re: Enable custom REST APIs in Flink Tue, 21 Apr, 15:12
Hailu, Andreas [Engineering] History Server Not Showing Any Jobs - File Not Found? Tue, 21 Apr, 15:16
Oytun Tez Re: Enable custom REST APIs in Flink Tue, 21 Apr, 15:17
Cliff Resnick KeyedStream and chained forward operators Tue, 21 Apr, 15:35
Lucas Kinne How to use OpenTSDB as Source? Tue, 21 Apr, 16:55
Yun Tang Re: Latency tracking together with broadcast state can cause job failure Tue, 21 Apr, 17:43
Lu Niu Re: Checkpoint Error Because "Could not find any valid local directory for s3ablock-0001" Tue, 21 Apr, 20:46
Lu Niu Re: Debug Slowness in Async Checkpointing Tue, 21 Apr, 20:50
Stephen Connolly Two questions about Async Tue, 21 Apr, 21:06
Kaan Sancak Reading from sockets using dataset api Wed, 22 Apr, 00:58
Danny Chan Re: LookupableTableSource from kafka consumer Wed, 22 Apr, 01:52
Chesnay Schepler Re: History Server Not Showing Any Jobs - File Not Found? Wed, 22 Apr, 06:16
Jingsong Li Re: JDBC Table and parameters provider Wed, 22 Apr, 08:33
Marta Paes Moreira Re: How to use OpenTSDB as Source? Wed, 22 Apr, 08:35
Flavio Pompermaier Re: JDBC Table and parameters provider Wed, 22 Apr, 08:45
Jingsong Li Re: Re: Blink SQL java.lang.ArrayIndexOutOfBoundsException Wed, 22 Apr, 08:50
Yun Tang Re: Latency tracking together with broadcast state can cause job failure Wed, 22 Apr, 09:06
Jingsong Li Re: JDBC Table and parameters provider Wed, 22 Apr, 09:06
Jingsong Li Re: Re: Blink SQL java.lang.ArrayIndexOutOfBoundsException Wed, 22 Apr, 09:14
Flavio Pompermaier Re: JDBC Table and parameters provider Wed, 22 Apr, 09:23
Som Lima Re: How to use OpenTSDB as Source? Wed, 22 Apr, 09:50
Jingsong Li Re: JDBC Table and parameters provider Wed, 22 Apr, 09:52
seeksst Flink 1.10.0 stop command Wed, 22 Apr, 10:17
Flavio Pompermaier Re: JDBC Table and parameters provider Wed, 22 Apr, 10:49
Lasse Nedergaard Re: Latency tracking together with broadcast state can cause job failure Wed, 22 Apr, 10:54
Jingsong Li Re: JDBC Table and parameters provider Wed, 22 Apr, 11:03
Jark Wu Re: How to use OpenTSDB as Source? Wed, 22 Apr, 11:18
魏旭斌 About “distribute the function jar I submitted to all taskManager” question Wed, 22 Apr, 11:23
Averell Re: Change to StreamingFileSink in Flink 1.10 Wed, 22 Apr, 12:43
Som Lima Re: How to use OpenTSDB as Source? Wed, 22 Apr, 12:50
Yang Wang Re: About “distribute the function jar I submitted to all taskManager” question Wed, 22 Apr, 12:56
Annemarie Burger Using Stateful Functions within a Flink pipeline Wed, 22 Apr, 14:26
Jingsong Li Re: JDBC Table and parameters provider Wed, 22 Apr, 14:29
Oytun Tez Re: Using Stateful Functions within a Flink pipeline Wed, 22 Apr, 14:29
Igal Shilman Re: Using Stateful Functions within a Flink pipeline Wed, 22 Apr, 14:56
Oytun Tez Re: Using Stateful Functions within a Flink pipeline Wed, 22 Apr, 14:58
Suraj Puvvada Running 2 instances of LocalExecutionEnvironments with same consumer group.id Wed, 22 Apr, 16:08
Gary Yao Re: Two questions about Async Wed, 22 Apr, 16:22
Suraj Puvvada Re: Changing number of partitions for a topic Wed, 22 Apr, 16:25
Yun Tang Re: Flink 1.10.0 stop command Wed, 22 Apr, 17:17
tison Re: Flink 1.10.0 stop command Wed, 22 Apr, 17:20
tison Re: Flink 1.10.0 stop command Wed, 22 Apr, 17:21
Yun Tang Re: Flink incremental checkpointing - how long does data is kept in the share folder Wed, 22 Apr, 17:27
Hailu, Andreas RE: History Server Not Showing Any Jobs - File Not Found? Wed, 22 Apr, 17:32
Gary Yao Re: Running 2 instances of LocalExecutionEnvironments with same consumer group.id Wed, 22 Apr, 17:35
Som Lima Re: Running 2 instances of LocalExecutionEnvironments with same consumer group.id Wed, 22 Apr, 17:44
令狐月弦 flink couchbase sink Thu, 23 Apr, 00:33
Bajaj, Abhinav Re: RocksDB default logging configuration Thu, 23 Apr, 01:24
seeksst Re: Flink 1.10.0 stop command Thu, 23 Apr, 01:34
Benchao Li batch range sort support Thu, 23 Apr, 04:15
Jingsong Li Re: batch range sort support Thu, 23 Apr, 04:34
Navneeth Krishnan Re: Flink Thu, 23 Apr, 05:10
Navneeth Krishnan Task Assignment Thu, 23 Apr, 05:43
Chesnay Schepler Re: RocksDB default logging configuration Thu, 23 Apr, 06:17
Benchao Li Re: batch range sort support Thu, 23 Apr, 06:26
lec ssmi how to enable retract? Thu, 23 Apr, 06:57
Morgan Geldenhuys A Strategy for Capacity Testing Thu, 23 Apr, 08:34
Marta Paes Moreira Re: Task Assignment Thu, 23 Apr, 09:02
Xintong Song Re: A Strategy for Capacity Testing Thu, 23 Apr, 09:11
Őrhidi Mátyás define WATERMARKS in queries/views? Thu, 23 Apr, 09:35
Benchao Li Re: how to enable retract? Thu, 23 Apr, 09:47
Stephan Ewen Re: Flink 1.10 Out of memory Thu, 23 Apr, 10:10
Eyal Pe'er Fault tolerance in Flink file Sink Thu, 23 Apr, 10:11
izual RuntimeException: Could not instantiate generated class 'StreamExecCalc$23166' Thu, 23 Apr, 10:33
Arvid Heise Re: Processing Message after emitting to Sink Thu, 23 Apr, 11:20
Stephan Ewen Re: Streaming Job eventually begins failing during checkpointing Thu, 23 Apr, 11:23
Vinay Patil Handling stale data enrichment Thu, 23 Apr, 11:28
Arvid Heise Re: How to scale a streaming Flink pipeline without abusing parallelism for long computation tasks? Thu, 23 Apr, 11:40
Message list« Previous · 1 · 2 · 3 · 4 · 5 · 6 · 7 · 8 · 9 · Next »Thread · Author · Date
Box list
Oct 20201
Sep 2020572
Aug 2020723
Jul 2020840
Jun 2020653
May 2020766
Apr 2020849
Mar 2020795
Feb 2020690
Jan 2020652
Dec 2019530
Nov 2019527
Oct 2019542
Sep 2019534
Aug 2019627
Jul 2019635
Jun 2019413
May 2019421
Apr 2019653
Mar 2019575
Feb 2019555
Jan 2019595
Dec 2018401
Nov 2018655
Oct 2018698
Sep 2018761
Aug 2018787
Jul 2018841
Jun 2018658
May 2018580
Apr 2018612
Mar 2018634
Feb 2018533
Jan 2018597
Dec 2017525
Nov 2017474
Oct 2017527
Sep 2017645
Aug 2017737
Jul 2017476
Jun 2017670
May 2017474
Apr 2017415
Mar 2017508
Feb 2017582
Jan 2017576
Dec 2016405
Nov 2016598
Oct 2016506
Sep 2016451
Aug 2016596
Jul 2016463
Jun 2016454
May 2016701
Apr 2016741
Mar 2016614
Feb 2016655
Jan 2016443
Dec 2015322
Nov 2015487
Oct 2015330
Sep 2015401
Aug 2015252
Jul 2015433
Jun 2015446
May 2015274
Apr 2015204
Mar 2015154
Feb 2015123
Jan 201574
Dec 201488
Nov 2014243
Oct 2014124
Sep 201464