You are viewing a plain text version of this content. The canonical link for it is here.
- Re: [ANNOUNCE] Open source of remote shuffle project for Flink batch data processing - posted by Yun Tang <ta...@apache.org> on 2021/12/01 02:51:39 UTC, 5 replies.
- Re: REST API for detached minicluster based integration test - posted by Caizhi Weng <ts...@gmail.com> on 2021/12/01 03:24:05 UTC, 1 replies.
- Does Flink ever delete any sink S3 files? - posted by Dan Hill <qu...@gmail.com> on 2021/12/01 05:44:34 UTC, 1 replies.
- Re: How do you configure setCommitOffsetsOnCheckpoints in Flink 1.12 when using KafkaSourceBuilder? - posted by Hang Ruan <ru...@gmail.com> on 2021/12/01 07:06:29 UTC, 2 replies.
- RE: Windows and data loss. - posted by Schwalbe Matthias <Ma...@viseca.ch> on 2021/12/01 08:00:06 UTC, 1 replies.
- Watermark behavior when connecting streams - posted by Alexis Sarda-Espinosa <al...@microfocus.com> on 2021/12/01 08:43:25 UTC, 3 replies.
- Re: how to run streaming process after batch process is completed? - posted by vtygoss <vt...@126.com> on 2021/12/01 09:51:32 UTC, 5 replies.
- Re: [DISCUSS] Deprecate Java 8 support - posted by Gavin Lee <ga...@gmail.com> on 2021/12/01 10:12:43 UTC, 4 replies.
- Regarding DataStream Api - posted by Jessy Ping <te...@gmail.com> on 2021/12/01 11:24:12 UTC, 1 replies.
- Issues in Batch Jobs Submission for a Session Cluster - posted by "Ghiya, Jay (GE Healthcare)" <Ja...@ge.com> on 2021/12/02 06:48:43 UTC, 4 replies.
- Buffering when connecting streams - posted by Alexis Sarda-Espinosa <al...@microfocus.com> on 2021/12/02 11:16:44 UTC, 10 replies.
- KafkaSink.builder setDeliveryGuarantee is not a member - posted by Lars Skjærven <la...@gmail.com> on 2021/12/02 11:34:36 UTC, 2 replies.
- Re: REST service for flinkSQL - posted by Martijn Visser <ma...@ververica.com> on 2021/12/02 12:16:59 UTC, 0 replies.
- Question about relationship between operator instances and keys - posted by haocheng <hi...@icloud.com> on 2021/12/02 12:20:17 UTC, 1 replies.
- Stateful functions module configurations (module.yaml) per deployment environment - posted by Deniz Koçak <le...@gmail.com> on 2021/12/02 14:28:33 UTC, 7 replies.
- Unable to create new native thread error - posted by Ilan Huchansky <il...@start.io> on 2021/12/02 14:50:49 UTC, 9 replies.
- Broadcast and watermark - posted by Sweta Kalakuntla <sk...@bandwidth.com> on 2021/12/02 15:11:28 UTC, 2 replies.
- GCS/Object Storage Rate Limiting - posted by Kevin Lam <ke...@shopify.com> on 2021/12/02 15:28:30 UTC, 5 replies.
- custom metrics in elasticsearch ActionRequestFailureHandler - posted by la...@posteo.de on 2021/12/02 16:51:45 UTC, 4 replies.
- Cannot consum from Kinesalite using FlinkKinesisConsumer - posted by jonas eyob <jo...@gmail.com> on 2021/12/02 23:05:01 UTC, 2 replies.
- Pyflink/Flink Java parquet streaming file sink for a dynamic schema stream - posted by Kamil ty <ka...@gmail.com> on 2021/12/02 23:11:50 UTC, 2 replies.
- flink hang : es_rejected_execution_exception导致的flink 假死问题 - posted by 淘宝龙安 <re...@gmail.com> on 2021/12/03 06:26:30 UTC, 1 replies.
- [DISCUSS] Change some default config values of blocking shuffle - posted by Yingjie Cao <ke...@gmail.com> on 2021/12/03 09:02:05 UTC, 12 replies.
- PyFlink import internal packages - posted by Королькевич Михаил <mk...@yandex.ru> on 2021/12/03 09:22:39 UTC, 2 replies.
- Re: Stateful function endpoint self-signed certificate problem - posted by Igal Shilman <ig...@apache.org> on 2021/12/03 15:14:49 UTC, 1 replies.
- Re: Parquet schema per bucket in Streaming File Sink - posted by Zack Loebel <zl...@gmail.com> on 2021/12/03 18:04:20 UTC, 0 replies.
- enable.auto.commit=true and checkpointing turned on - posted by Vishal Santoshi <vi...@gmail.com> on 2021/12/03 18:11:22 UTC, 2 replies.
- Order of events in Broadcast State - posted by Alexey Trenikhun <ye...@msn.com> on 2021/12/04 00:33:00 UTC, 3 replies.
- Log level for insufficient task slots message - posted by Mason Chen <ma...@apple.com> on 2021/12/04 00:49:00 UTC, 0 replies.
- Flinks DispatcherRestEndpoint Thread stuck even though TaskManager failed to execute job - posted by Yuval Itzchakov <yu...@gmail.com> on 2021/12/05 18:13:02 UTC, 1 replies.
- Any way to require .uid(...) calls? - posted by Dan Hill <qu...@gmail.com> on 2021/12/05 20:43:02 UTC, 3 replies.
- Converting DataStream of Avro SpecificRecord to Table - posted by Dongwon Kim <ea...@gmail.com> on 2021/12/06 10:46:28 UTC, 0 replies.
- use of Scala versions >= 2.13 in Flink 1.15 - posted by "guenterh.lists" <gu...@bluewin.ch> on 2021/12/06 10:47:43 UTC, 5 replies.
- [DISCUSS] Strong read-after-write consistency of Flink FileSystems - posted by David Morávek <dm...@apache.org> on 2021/12/06 11:27:53 UTC, 3 replies.
- Re: [DISCUSS] Drop Zookeeper 3.4 - posted by Chesnay Schepler <ch...@apache.org> on 2021/12/06 13:00:35 UTC, 6 replies.
- Re: Table DataStream Conversion Lost Watermark - posted by Timo Walther <tw...@apache.org> on 2021/12/06 16:42:07 UTC, 1 replies.
- Re: GenericWriteAheadSink, declined checkpoint for a finished source - posted by James Sandys-Lumsdaine <ja...@hotmail.com> on 2021/12/06 17:24:37 UTC, 1 replies.
- Issue with incremental checkpointing size - posted by Vidya Sagar Mula <mu...@gmail.com> on 2021/12/07 00:03:30 UTC, 3 replies.
- Re: 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/12/07 05:23:22 UTC, 2 replies.
- Unsubscribe - posted by ri...@sina.cn on 2021/12/07 08:24:49 UTC, 3 replies.
- Scala Case Class Serialization - posted by Lars Skjærven <la...@gmail.com> on 2021/12/07 09:03:10 UTC, 4 replies.
- Alternatives of KafkaDeserializationSchema.isEndOfStream() - posted by Ayush Chauhan <ay...@zomato.com> on 2021/12/07 09:39:57 UTC, 13 replies.
- Running a flink job with Yarn per-job mode from application code. - posted by Kamil ty <ka...@gmail.com> on 2021/12/07 11:15:54 UTC, 3 replies.
- Job operator state grows unreasonably causing job to OOM - posted by Yuval Itzchakov <yu...@gmail.com> on 2021/12/07 14:06:15 UTC, 4 replies.
- Customize Kafka client (module.yaml) - posted by Jérémy Albrecht <ja...@skapane.ai> on 2021/12/07 15:31:23 UTC, 2 replies.
- Creating custom connector lib - dependency scope - posted by Krzysztof Chmielewski <kr...@gmail.com> on 2021/12/07 21:31:03 UTC, 1 replies.
- How to write from Flink to a write throttled database? - posted by Jing Lu <aj...@gmail.com> on 2021/12/07 21:51:30 UTC, 5 replies.
- Which issue or commit should i merge in flink-1.13.3 for buffer debloating? - posted by vtygoss <vt...@126.com> on 2021/12/08 03:06:03 UTC, 1 replies.
- Job Listener not working as expected - posted by Puneet Duggal <pu...@gmail.com> on 2021/12/08 03:55:12 UTC, 1 replies.
- flinkSQL lost data - posted by pass <ly...@163.com> on 2021/12/08 03:56:03 UTC, 0 replies.
- Weird operator ID check restore from checkpoint fails - posted by Dan Hill <qu...@gmail.com> on 2021/12/08 04:48:18 UTC, 5 replies.
- Stateful functions - egress question - posted by Gigio Topo <ma...@yahoo.com> on 2021/12/08 11:32:35 UTC, 2 replies.
- PyFlink convert data from ds to table - posted by Королькевич Михаил <mk...@yandex.ru> on 2021/12/08 13:11:31 UTC, 1 replies.
- Re: FileSink in Apache Flink not generating logs in output folder - posted by Fabian Paul <fp...@apache.org> on 2021/12/08 15:58:59 UTC, 0 replies.
- [DISCUSS] Deprecate MapR FS - posted by Martijn Visser <ma...@ververica.com> on 2021/12/08 16:03:35 UTC, 3 replies.
- How to select an event that has max attribute - posted by Guoqin Zheng <la...@gmail.com> on 2021/12/08 18:53:41 UTC, 8 replies.
- FileSource with Parquet Format - parallelism level - posted by Krzysztof Chmielewski <kr...@gmail.com> on 2021/12/09 11:02:28 UTC, 4 replies.
- Hybrid Source with Parquet Files from GCS + KafkaSource - posted by Meghajit Mazumdar <me...@gojek.com> on 2021/12/09 12:03:05 UTC, 3 replies.
- CVE-2021-44228 - Log4j2 vulnerability - posted by Richard Deurwaarder <ri...@xeli.eu> on 2021/12/10 09:21:43 UTC, 24 replies.
- Re: broadcast() without arguments - posted by Roman Khachatryan <ro...@apache.org> on 2021/12/10 09:48:08 UTC, 1 replies.
- PyFlink accumulate streaming data - posted by Королькевич Михаил <mk...@yandex.ru> on 2021/12/10 10:09:59 UTC, 0 replies.
- Regarding the size of Flink cluster - posted by Jessy Ping <te...@gmail.com> on 2021/12/10 10:46:32 UTC, 1 replies.
- WindowOperator TestHarness - posted by Lars Skjærven <la...@gmail.com> on 2021/12/10 14:46:17 UTC, 4 replies.
- Advise on Apache Log4j Zero Day (CVE-2021-44228) - posted by Konstantin Knauf <kn...@apache.org> on 2021/12/10 16:39:59 UTC, 0 replies.
- Confusion about rebalance bytes sent metric in Flink UI - posted by tao xiao <xi...@gmail.com> on 2021/12/10 17:10:58 UTC, 6 replies.
- Latency monitoring in Flink 1.14.0 - posted by "Geldenhuys, Morgan Karl" <mo...@tu-berlin.de> on 2021/12/10 17:31:51 UTC, 4 replies.
- Passing arbitrary Hadoop s3a properties from FileSystem SQL Connector options - posted by Timothy James <ti...@decodable.co> on 2021/12/10 22:48:55 UTC, 3 replies.
- Re: Random checkpoint failures with timeouts - posted by Dineth Kariyawasam <di...@zilingo.com> on 2021/12/11 03:32:17 UTC, 0 replies.
- Flink 1.13.3, k8s HA - ResourceManager was revoked leadership - posted by Alexey Trenikhun <ye...@msn.com> on 2021/12/11 05:46:42 UTC, 4 replies.
- Re: Flink application mode using k8S HA. - posted by mejri houssem <me...@gmail.com> on 2021/12/12 11:24:50 UTC, 7 replies.
- CoGroupedStreams and disableAutoGeneratedUIDs - posted by Dan Hill <qu...@gmail.com> on 2021/12/13 05:29:43 UTC, 3 replies.
- IOException/StacklessClosedChannelException on flink-connector-kinesis trigger job to restart - posted by Leon Xu <lx...@attentivemobile.com> on 2021/12/13 06:13:37 UTC, 2 replies.
- using flink retract stream and rockdb, too many intermediate result of values cause checkpoint too heavy to finish - posted by vtygoss <vt...@126.com> on 2021/12/13 09:10:50 UTC, 2 replies.
- IOException or StacklessClosedChannelException on flink-connector-kinesis triggers job to restart - posted by Leon Xu <lx...@attentivemobile.com> on 2021/12/13 15:52:31 UTC, 0 replies.
- Flink SQL IntervalJoin using parallelism different than job parallelism - posted by Yuval Itzchakov <yu...@gmail.com> on 2021/12/13 17:00:40 UTC, 1 replies.
- Sending an Alert to Slack, AWS sns, mattermost - posted by Robert Cullen <ci...@gmail.com> on 2021/12/13 20:07:58 UTC, 4 replies.
- Java dependencies management in Pyflink - posted by Paul Lam <pa...@gmail.com> on 2021/12/14 09:43:55 UTC, 2 replies.
- reading gz files - posted by Egor Ryashin <ri...@gmail.com> on 2021/12/14 18:33:41 UTC, 1 replies.
- unaligned checkpoint for job with large start delay - posted by Mason Chen <ma...@gmail.com> on 2021/12/14 21:03:34 UTC, 8 replies.
- Python Interop with Java defined org.apache.flink.api.common.functions.Function classes? - posted by Kevin Lam <ke...@shopify.com> on 2021/12/14 21:41:00 UTC, 1 replies.
- UDF and Broadcast State Pattern - posted by Krzysztof Chmielewski <kr...@gmail.com> on 2021/12/14 21:46:59 UTC, 4 replies.
- Direct buffer memory in job with hbase client - posted by Anton <an...@yandex.ru> on 2021/12/15 05:40:07 UTC, 3 replies.
- Looking for MultipleLinearRegression in Flink - posted by thekingofcity <ki...@protonmail.com> on 2021/12/15 07:34:57 UTC, 1 replies.
- Re: stateSerializer(1.14.0) not compatible with previous stateSerializer(1.13.1) - posted by 李诗君 <li...@126.com> on 2021/12/15 10:26:13 UTC, 0 replies.
- Periodic Job Failure - posted by Julian Cardarelli <ju...@thentia.com> on 2021/12/15 14:47:02 UTC, 1 replies.
- Information request: Reactive mode and Rescaling - posted by "Geldenhuys, Morgan Karl" <mo...@tu-berlin.de> on 2021/12/15 21:24:34 UTC, 1 replies.
- Rescaling feature disabled for Flink 1.14 - posted by "Geldenhuys, Morgan Karl" <mo...@tu-berlin.de> on 2021/12/15 22:47:27 UTC, 2 replies.
- unexpected result of interval join when using sql - posted by cy <ca...@126.com> on 2021/12/16 05:55:04 UTC, 3 replies.
- unexpected result when using sql interval join ability - posted by cy <ca...@126.com> on 2021/12/16 08:25:54 UTC, 0 replies.
- Re: using flink retract stream and rockdb, too many intermediateresult of values cause checkpoint too heavy to finish - posted by vtygoss <vt...@126.com> on 2021/12/16 09:26:44 UTC, 0 replies.
- pyFlink + asyncio - posted by Королькевич Михаил <mk...@yandex.ru> on 2021/12/16 11:45:48 UTC, 1 replies.
- How do I determine which hardware device and software has log4j zero-day security vulnerability? - posted by Turritopsis Dohrnii Teo En Ming <ce...@gmail.com> on 2021/12/16 14:50:38 UTC, 4 replies.
- [ANNOUNCE] Apache Flink 1.14.2 / 1.13.5 / 1.12.7 / 1.11.6 released - posted by Chesnay Schepler <ch...@apache.org> on 2021/12/16 17:26:19 UTC, 6 replies.
- Re: [EXTERNAL] Re: Periodic Job Failure - posted by Julian Cardarelli <ju...@thentia.com> on 2021/12/16 18:09:16 UTC, 2 replies.
- Flink fails to load class from configured classpath using PipelineOptions - posted by Pouria Pirzadeh <po...@gmail.com> on 2021/12/16 19:42:45 UTC, 3 replies.
- Antlr usage in FLink - posted by Krzysztof Chmielewski <kr...@gmail.com> on 2021/12/16 22:21:42 UTC, 1 replies.
- Unified Source Interface in flink 1.12 - posted by Krzysztof Chmielewski <kr...@gmail.com> on 2021/12/16 22:55:55 UTC, 1 replies.
- [state.checkpoints.num-retained ]The default value does not take effect - posted by chenqizhu <qi...@163.com> on 2021/12/17 07:56:07 UTC, 1 replies.
- Read parquet data from S3 with Flink 1.12 - posted by Alexandre Montecucco <al...@grabtaxi.com> on 2021/12/17 09:09:32 UTC, 7 replies.
- Defining a RowType for FileSource - Parquet - posted by Krzysztof Chmielewski <kr...@gmail.com> on 2021/12/17 10:00:13 UTC, 1 replies.
- fraud detection example fails - posted by HG <ha...@gmail.com> on 2021/12/17 12:03:41 UTC, 2 replies.
- Prometheus labels in metrics / counters - posted by Witold Baryluk <wi...@gmail.com> on 2021/12/17 13:02:13 UTC, 1 replies.
- Re: [ANNOUNCE] Berlin Buzzwords 2019 - Call for Presentations open until Febr. 17th - posted by Nastaran Motavali <N....@son.ir> on 2021/12/17 16:12:48 UTC, 0 replies.
- org.apache.flink.connector.jdbc.internal.JdbcBatchingOutputFormat class missing from Flink 1.14 ? - posted by Tuomas Pystynen <tu...@deepbase.com> on 2021/12/18 11:30:42 UTC, 2 replies.
- RE: Suspected SPAM - RE: CVE-2021-44228 - Log4j2 vulnerability - posted by "V N, Suchithra (Nokia - IN/Bangalore)" <su...@nokia.com> on 2021/12/18 17:27:41 UTC, 0 replies.
- How to know if Job nodes are registered in cluster? - posted by John Smith <ja...@gmail.com> on 2021/12/19 05:36:21 UTC, 2 replies.
- question on jar compatibility - log4j related - posted by "Colletta, Edward" <Ed...@FMR.COM> on 2021/12/19 15:41:33 UTC, 1 replies.
- Kryo EOFException: No more bytes left - posted by Dan Hill <qu...@gmail.com> on 2021/12/19 23:18:17 UTC, 4 replies.
- Predicate pushdown for user defined functions fails due to UDF name change before lookup - posted by Yuval Itzchakov <yu...@gmail.com> on 2021/12/20 07:30:23 UTC, 1 replies.
- 回复:Re: Will Flink loss some old Keyed State when changing the parallelism - posted by 杨浩 <ya...@163.com> on 2021/12/20 08:27:53 UTC, 0 replies.
- flink-playground docker/mvn clean install Unknown host repo.maven.apache.org: Name or service not known - posted by HG <ha...@gmail.com> on 2021/12/20 14:38:59 UTC, 5 replies.
- Re: Re: Will Flink loss some old Keyed State when changing the parallelism - posted by Seth Wiesman <sj...@gmail.com> on 2021/12/20 14:44:22 UTC, 0 replies.
- Avoiding Dynamic Classloading for User Code - posted by Lior Liviev <Li...@earnix.com> on 2021/12/21 14:47:59 UTC, 15 replies.
- Class loader - posted by Lior Liviev <Li...@earnix.com> on 2021/12/21 14:53:25 UTC, 3 replies.
- Re: [DISCUSS] Changing the minimal supported version of Hadoop - posted by David Morávek <dm...@apache.org> on 2021/12/21 16:51:25 UTC, 3 replies.
- Waiting on streaming job with StatementSet.execute() when using Web Submission - posted by Yuval Itzchakov <yu...@gmail.com> on 2021/12/21 18:35:37 UTC, 8 replies.
- Flink Checkpoint Duration/Job Throughput - posted by Terry Heathcote <te...@gmail.com> on 2021/12/21 18:53:08 UTC, 3 replies.
- Overwriting Flink Core InputStreamFactory - posted by AG <go...@gmail.com> on 2021/12/21 19:37:42 UTC, 1 replies.
- Re: PyFlink Perfomance - posted by Francis Conroy <fr...@switchdin.com> on 2021/12/22 03:30:45 UTC, 2 replies.
- Re: FlinkKafkaProducer deprecated in 1.14 but pyflink binding still present? - posted by Francis Conroy <fr...@switchdin.com> on 2021/12/22 03:33:58 UTC, 0 replies.
- JsonRowSerializationSchema unable to parse TIMESTAMP_LTZ fields - posted by Surendra Lalwani <su...@swiggy.in> on 2021/12/22 08:50:51 UTC, 0 replies.
- log4j2 upgrade requirement - posted by Puneet Duggal <pu...@gmail.com> on 2021/12/22 11:57:09 UTC, 0 replies.
- [ANNOUNCE] Apache Flink Stateful Functions 3.1.1 released - posted by Igal Shilman <ig...@apache.org> on 2021/12/22 16:40:14 UTC, 1 replies.
- Operator state in New Source API - posted by Krzysztof Chmielewski <kr...@gmail.com> on 2021/12/22 22:32:22 UTC, 4 replies.
- Window Aggregation and Window Join ability not work properly - posted by cy <ca...@126.com> on 2021/12/23 01:51:34 UTC, 13 replies.
- Window Top N for Flink 1.12 - posted by Jing <aj...@gmail.com> on 2021/12/23 08:11:46 UTC, 4 replies.
- Using venv in Pyflink - posted by Paul Lam <pa...@gmail.com> on 2021/12/23 09:15:48 UTC, 3 replies.
- Flink On Native K8s hostAliases in Pod-template - posted by 黄剑文 <ji...@gmail.com> on 2021/12/23 14:58:12 UTC, 1 replies.
- Uploading jar on multiple flink job managers - posted by Puneet Duggal <pu...@gmail.com> on 2021/12/25 07:59:20 UTC, 1 replies.
- flink-table-api-scala-bridge missing source files - posted by Yuval Itzchakov <yu...@gmail.com> on 2021/12/26 07:17:47 UTC, 2 replies.
- How to handle java.lang.OutOfMemoryError: Metaspace - posted by John Smith <ja...@gmail.com> on 2021/12/27 00:46:11 UTC, 5 replies.
- Remove stackTrace from error response - posted by "Koffman, Noa (Nokia - IL/Kfar Sava)" <no...@nokia.com> on 2021/12/27 11:54:54 UTC, 1 replies.
- Parquet files in streaming mode - posted by Mathieu D <ma...@gmail.com> on 2021/12/27 14:43:16 UTC, 2 replies.
- How to reduce interval between Uptime Metric meaasurements? - posted by "Geldenhuys, Morgan Karl" <mo...@tu-berlin.de> on 2021/12/27 18:43:33 UTC, 2 replies.
- Anyone trying to adopt Scotty on the recent Flink versions? - posted by Dongwon Kim <ea...@gmail.com> on 2021/12/28 03:14:30 UTC, 2 replies.
- Mapstate got wrong UK when restored. - posted by Joshua Fan <jo...@gmail.com> on 2021/12/28 09:02:46 UTC, 4 replies.
- Flink job backpressure and TM network buffer memory - posted by Yuval Itzchakov <yu...@gmail.com> on 2021/12/28 13:32:17 UTC, 1 replies.
- TypeInformation | Flink - posted by Siddhesh Kalgaonkar <ka...@gmail.com> on 2021/12/28 20:21:01 UTC, 9 replies.
- Error while deploying from snapshot after adding new column in existing table - posted by shamit jain <ja...@gmail.com> on 2021/12/29 03:10:03 UTC, 3 replies.
- Unable to read S3 data using the filesystem connector - posted by Rohan Kumar <ro...@gmail.com> on 2021/12/29 07:48:42 UTC, 2 replies.
- Flink and Datadog metrics question - posted by Adrian Schtivelmager <Ad...@niceactimize.com> on 2021/12/29 13:54:46 UTC, 1 replies.
- Unable to update logback configuration in Flink Native Kubernetes - posted by Raghavendar T S <ra...@gmail.com> on 2021/12/29 15:04:25 UTC, 2 replies.
- Flink Kinesis Producer con't connect with AWS credentials - posted by Daniel Vol <vo...@gmail.com> on 2021/12/31 12:05:58 UTC, 0 replies.