[no subject]

Unsubscribe >From Vishnu I P

[no subject]

退订 王立壮 2720627...@qq.com

[no subject]

Hi Flink Community, I hope you're doing well. I'm currently working on a simple Flink project where I read a file using `env.readTextFile("/opt/input.txt")`, process transactions per user, and write the results to an output CSV file. However, I keep encountering this error during execution: De

[no subject]

Unsubscribe

[no subject]

[no subject]

[no subject]

[no subject]

Hello to all users, contributors and Committers! The Travel Assistance Committee (TAC) are pleased to announce that travel assistance applications for Community over Code EU 2024 are now open! We will be supporting Community over Code EU, Bratislava, Slovakia, June 3th - 5th, 2024. TAC exists to

[no subject]

[no subject]

(this is issue from Flink 1.14) Hello, I've set up following logic to consume messages from kafka, and produce them to another kafka broker. For producer, I've configured `Semantics.EXACTLY_ONCE` to send messages exactly once. (also setup 'StreamExecutionEnvironment::enableCheckpointing' as 'Chec

[no subject]

Hello! I have deployed the flink kubernetes operator 1.4.0 on minikube and I enabled the autoscaler. However, I get this error "2023-05-22 14:54:25,494 o.a.f.k.o.a.m.ScalingMetrics [ERROR][default/example] Cannot compute true processing/output rate without busyTimeMsPerSecond " on logs of the ope

[no subject]

Hello! I have deployed the flink kubernetes operator 1.4.0 on minikube and I enabled the autoscaler. However, I get this error "2023-05-22 14:54:25,494 o.a.f.k.o.a.m.ScalingMetrics [ERROR][default/example] Cannot compute true processing/output rate without busyTimeMsPerSecond " on logs of the ope

[no subject]

sharif.k...@selise.ch -- SELISE Group Zürich: The Circle 37, 8058 Zürich-Airport, Switzerland Munich: Tal 44, 80331 München, Germany Dubai: Building 3, 3rd Floor, Dubai Design District, Dubai, United Arab Emirates Dhaka: Midas Center, Road 16, Dhanmondi, Dhaka 1209, Bangladesh Thimphu

[no subject]

Hi Community, I am trying to use flink-parquet for reading and writing parquet files from the Flink filesystem connectors. In File source, I would be decoding parquet files and converting them to avro records and similarly in file sink i would be encoding avro records to parquet files. For col

[no subject]

Hello, I am new to even-time processing and need some help. We have a kafka source with very low qps and multiple topic partitions have no data for long periods of time. Additionally, data from the source can come out of order (within bounds) and the application needs to process the events in o

[no subject]

unsubscribe 退订 chenshu...@foxmail.com

[no subject]

退订 获取 Outlook for iOS

[no subject]

退订

[no subject]

Unsubscribe

[no subject]

Unsubscribe

[no subject]

Unsubscribe

[no subject]

Hello, I'm trying to use HiveCatalog with Kerberos. Our Hadoop cluster, our Hive Metastore, and our Hive Server are kerberized. I can successfully submit Flink jobs to Yarn authenticated as my users using a cached ticket, as well as using a keytab. However, I can't seem to register a HiveCatalo

[no subject]

unsubscribe

[no subject]

[no subject]

[no subject]

Hi, I have a very strange bug when using MATCH_RECOGNIZE. I'm using some joins and unions to create event stream. Sample event stream (for one user) looks like this: uuidcif event_type v balance ts 621456e9-389b-409b-aaca-bca99eeb43b30004091386 trx 4294.38000

[no subject]

unsubscribe

[no subject]

[no subject]

Hi, I have below use case Insert bounded data into dynamic table(upsert-kafka) using Flink 1.12 on yarn, but yarn application is still running when insert job finished, and yarn container is not released. I try to use BatchTableEnvironment, but “Primary key and unique key are not supporte

[no subject]

[no subject]

[no subject]

Hello everyone! I'm new to Apache Flink and I would like to get some opinions on how I should deploy my Flink jobs. Let's say I want to do sentiment analysis for Slack workspaces. I have 10 companies each having 2 slack workspaces. How should I deploy Flink jobs if I'd like to efficiently utiliz

[no subject]

Hi, I have a coProcessFunction which emits data to same side output from processElement1 method and on timer method.But, data is not getting emitted to sideoutput from onTimer. Is it like to the same sideoutput, we can not emit data from onTimer and processElement methods? Get Outlook for Andr

[no subject]

Hi, I try to use the confluent schema registry in an interactive Flink Scala shell. My problem is trying to initialize the serializer from the ConfluentRegistryAvroDeserializationSchema fails: ```scala val serializer = ConfluentRegistryAvroDeserializationSchema.forSpecific[Tweet](classOf[Tweet],

[no subject]

Hi， all some error occurred when I run flink in minicluster, flink-version:1.11、scala-version:2.12.0. Error:(33, 41) could not find implicit value for evidence parameter of type org.apache.flink.api.common.typeinfo.TypeInformation[(Int, String)] val solutionInput = env.fromElements((1, "1

[no subject]

[no subject]

[no subject]

[no subject]

The following is the environment I use： 1. flink.version: 1.9.0 2. java version "1.8.0_212" 3. scala version: 2.11.12 When I wrote the following code in the scala programming language, I found the following error： // set up the batch execution environment val bbSettings = EnvironmentSettings.newI

[no subject]

Hello, I am trying to use HashMap In my window function of flink job. if the parallelism change, is this hashmap still a singleton? Shouldn’t I do something similar here? 发送自 Windows 10 版邮件应用

[no subject]

Hi Flink experts, I am prototyping a real time system that reads from Kafka source with Flink and calls out to an external system as part of the event processing. One of the most important requirements are read from Kafka should NEVER stall, even in face of some async external calls slowness while

[no subject]

> Q2: after a, map(A), and map(B) would work fine. Assign watermarks > immediatedly after a keyBy() is not a good idea, because 1) the records are > shuffled and it's hard to reasoning about ordering, and 2) you lose the > KeyedStream property and would have to keyBy() again (unless you use > inter

[no subject]

You are right, thanks. But something is still not totally clear to me. I'll reuse your diagram with a little modification: DataStream a = ... a.map(A).map(B).keyBy().timeWindow(C) and execute this with parallelism 2. However, keyBy only generates one single key value, and assume they all go

[no subject]

user@flink.apache.org -- *Cheers * *Puneet Kinra* *Mobile:+918800167808 | Skype : puneet.ki...@customercentria.com * *e-mail :puneet.ki...@customercentria.com *

[no subject]

Hi, Is there a way to get table's metadata in flink? if I emit a table to kafka, then how can I know the table columns when I subscribe the kafka topic and restore the table using *tableEnv.registerDataStream("t1", source, "field1, field2 ...") *in another flink program? Flink should provide some

[no subject]

Well, hopefully the last problem with this project. Any thoughts would be appreciated = java.lang.RuntimeException: Exception occurred while processing valve output watermark: at org.apache.flink.streaming.runtime.io.StreamInputProcessor$Forwardin

[no subject]

Regards, Vinod Gavhane

[no subject]

[no subject]

Hello All, I have an in-memory cache created inside a user function and I need to assign the max capacity for it. Since the program can be run on any hardware, I'm thinking if I cloud assign based on flink's allocated managed memory. Is there a way to get the flink managed memory size inside a us

[no subject]

-- Yours Sincerely, Aniket S Deshpande.

[no subject]

I am running a standalone flink cluster (1.1.2) and I have a stateful streaming job that uses RocksDB as a state manager. I have two stateful operators that are using ValueState<> and ListState<>. Every now and then my job fails with the following exception Caused by: AsynchronousException{java.io

[no subject]

Hello, I'm trying to assign a unique (and deterministic) ID to a globally sorted DataSet. Given a DataSet of String, I can compute the frequency of each label as follows: val env = ExecutionEnvironment.getExecutionEnvironment val data = env.fromCollection(List("a","b","c","a","a","d","a","a","

[no subject]

Hi, I Need some assistance - I’m trying to globally register arguments from my main function for further extraction on stream processing nodes. My code base is Scala: val env = StreamExecutionEnvironment.getExecutionEnvironment val parameterTool = ParameterTool.fromArgs(args) env.getConfig.set

[no subject]

Hello, I'm new to flink so this might seem a basic question. I added flink to an existing project using maven and can run the program locally with StreamExecutionEnvironment with no problems, however i want to know how can I submit jobs for that project and be able to view these jobs from flink's w

[no subject]

Hi - I typically use the Chrome browser on OS X, and notice that with 1.0.0-rc0 the job graph visualization displays the nodes in the graph, but not any of the edges. Also the graph does not move around when dragging the mouse. The job graph visualization seems to work perfectly in Safari and Fire

[no subject]

Hello, We are running into a strange problem with Direct Memory buffers. From what I know, we are not using any direct memory buffers inside our code. This is pretty trivial streaming application just doing some dedupliction and union some kafka streams. /Jakob 2015-10-19 13:27:59,064 INFO or

[no subject]

user-sc.1429880470. oeiopbmoofcapkjibfab-paul.roewer1990=googlemail@flink.apache.org