Re: [VOTE] Release 1.15.0, release candidate #1

Here is the missing link to the announcement blogpost [6] [6] https://github.com/apache/flink-web/pull/526 > On 11.04.2022, at 20:12, Yun Gao wrote: > > Hi everyone, > > Please review and vote on the release candidate #1 for the version 1.15.0, as > follows: > [ ] +1, Approve the release > [

Contributing to FLINK-27195

Hi Devs, Could a committer assign me this ticket: https://issues.apache.org/jira/browse/FLINK-27195? I have been taking a deeper look into the Kafka Source and would like to contribute back a bugfix. I have a minimal test case and the fix should be simple. Thanks all! Best, Mason

[jira] [Created] (FLINK-27195) KafkaSourceReader offsetsToCommit should be mutable

Mason Chen created FLINK-27195: -- Summary: KafkaSourceReader offsetsToCommit should be mutable Key: FLINK-27195 URL: https://issues.apache.org/jira/browse/FLINK-27195 Project: Flink Issue Type: B

[jira] [Created] (FLINK-27194) Whether to consider adding the configuration of ignore when data deserialization failed.

hehuiyuan created FLINK-27194: - Summary: Whether to consider adding the configuration of ignore when data deserialization failed. Key: FLINK-27194 URL: https://issues.apache.org/jira/browse/FLINK-27194 Pr

[jira] [Created] (FLINK-27193) Kyro Serialisation and Deserialisation returns a different object

Akshay Hazari created FLINK-27193: - Summary: Kyro Serialisation and Deserialisation returns a different object Key: FLINK-27193 URL: https://issues.apache.org/jira/browse/FLINK-27193 Project: Flink

[jira] [Created] (FLINK-27192) Hi,

Karthik created FLINK-27192: --- Summary: Hi, Key: FLINK-27192 URL: https://issues.apache.org/jira/browse/FLINK-27192 Project: Flink Issue Type: Bug Reporter: Karthik -- This message

Discuss making KafkaSubscriber Public

Hi Flink Devs, I was looking to contribute to https://issues.apache.org/jira/browse/FLINK-24660, which is a ticket to track changing the KafkaSubscriber from Internal to PublicEvolving. In the PR, it seems a few of us have agreement on making the subscriber pluggable in the KafkaSource, but I'd l

Re: [DISCUSS] Flink SQL Syntax for Query/Savepoint Management

Hi Jark, Thanks a lot! I’m thinking of the 2nd approach. With this approach, the query lifecycle statements (show/stop/savepoint etc) are basically equivalent alternatives to Flink CLI from the user point of view. BTW, the completed jobs might be missing in `SHOW QUERIES`, because for applic

[jira] [Created] (FLINK-27191) Support multi kerberos-enabled Hive clusters

luoyuxia created FLINK-27191: Summary: Support multi kerberos-enabled Hive clusters Key: FLINK-27191 URL: https://issues.apache.org/jira/browse/FLINK-27191 Project: Flink Issue Type: Improvement

Supporting Collector API in Kinesis Connector

Hello, I recently submitted a pull request to support the Collector API for the Kinesis Streams Connector. The ability to use this API would save a great deal of shuttling bytes around in multiple Flink programs I've worked on. This is because to construct a stream of the desired type without Coll

FLINK-11746 work

Hi there, I would like to reboot discussion on FLINK-11746 work. Over the course of last two years, we managed to run a large number of critical flink apps (table/datastream) with underlying thrift format. It would be great if folks assign this j

[jira] [Created] (FLINK-27190) Revisit error handling in main reconcile() loop

Matyas Orhidi created FLINK-27190: - Summary: Revisit error handling in main reconcile() loop Key: FLINK-27190 URL: https://issues.apache.org/jira/browse/FLINK-27190 Project: Flink Issue Type:

[jira] [Created] (FLINK-27189) Ability for table api to always add quotes to generated csv

shameet created FLINK-27189: --- Summary: Ability for table api to always add quotes to generated csv Key: FLINK-27189 URL: https://issues.apache.org/jira/browse/FLINK-27189 Project: Flink Issue Type

[VOTE] Release 1.15.0, release candidate #1

Hi everyone, Please review and vote on the release candidate #1 for the version 1.15.0, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) The complete staging area is available for your review, which includes: * JIRA release notes [1], *

[jira] [Created] (FLINK-27188) Deprecate StreamingFileSink

Daisy Tsang created FLINK-27188: --- Summary: Deprecate StreamingFileSink Key: FLINK-27188 URL: https://issues.apache.org/jira/browse/FLINK-27188 Project: Flink Issue Type: Improvement C

Apache Flink Statefun - broadcast state

Hi: I am working with Stateful Functions 3.2.0 using Java SDK. I wanted to find out if there is a broadcast to all functions feature available in Stateful Functions just like broadcast process and keyed broadcast processing in Apache Flink. Please let me know if there is any example/documentation

[jira] [Created] (FLINK-27187) The attemptsPerUpload metric may be lower than it actually is

Feifan Wang created FLINK-27187: --- Summary: The attemptsPerUpload metric may be lower than it actually is Key: FLINK-27187 URL: https://issues.apache.org/jira/browse/FLINK-27187 Project: Flink

[jira] [Created] (FLINK-27186) support ElasticSearch 8

macdoor615 created FLINK-27186: -- Summary: support ElasticSearch 8 Key: FLINK-27186 URL: https://issues.apache.org/jira/browse/FLINK-27186 Project: Flink Issue Type: Improvement Compone

[jira] [Created] (FLINK-27185) Run the assertj conversion script to convert assertions in connectors and formats

Francesco Guardiani created FLINK-27185: --- Summary: Run the assertj conversion script to convert assertions in connectors and formats Key: FLINK-27185 URL: https://issues.apache.org/jira/browse/FLINK-27185

[DISCUSS] FLIP-220: Temporal State

Greetings, Flink developers. I would like to open up a discussion of a proposal [1] to add a new kind of state to Flink. The goal here is to optimize a fairly common pattern, which is using MapState> to store lists of events associated with timestamps. This pattern is used internally in quite a

[jira] [Created] (FLINK-27184) Optimize IntervalJoinOperator by using temporal state

David Anderson created FLINK-27184: -- Summary: Optimize IntervalJoinOperator by using temporal state Key: FLINK-27184 URL: https://issues.apache.org/jira/browse/FLINK-27184 Project: Flink Iss

[jira] [Created] (FLINK-27183) Optimize CepOperator by using temporal state

David Anderson created FLINK-27183: -- Summary: Optimize CepOperator by using temporal state Key: FLINK-27183 URL: https://issues.apache.org/jira/browse/FLINK-27183 Project: Flink Issue Type:

[jira] [Created] (FLINK-27182) Optimize RowTimeSortOperator by using temporal state

David Anderson created FLINK-27182: -- Summary: Optimize RowTimeSortOperator by using temporal state Key: FLINK-27182 URL: https://issues.apache.org/jira/browse/FLINK-27182 Project: Flink Issu

[jira] [Created] (FLINK-27181) Optimize TemporalRowTimeJoinOperator by using temporal state

David Anderson created FLINK-27181: -- Summary: Optimize TemporalRowTimeJoinOperator by using temporal state Key: FLINK-27181 URL: https://issues.apache.org/jira/browse/FLINK-27181 Project: Flink

[jira] [Created] (FLINK-27180) Docs for temporal state

David Anderson created FLINK-27180: -- Summary: Docs for temporal state Key: FLINK-27180 URL: https://issues.apache.org/jira/browse/FLINK-27180 Project: Flink Issue Type: Sub-task Co

[jira] [Created] (FLINK-27179) Update training example to use temporal state

David Anderson created FLINK-27179: -- Summary: Update training example to use temporal state Key: FLINK-27179 URL: https://issues.apache.org/jira/browse/FLINK-27179 Project: Flink Issue Type:

[jira] [Created] (FLINK-27178) create examples that use temporal state

David Anderson created FLINK-27178: -- Summary: create examples that use temporal state Key: FLINK-27178 URL: https://issues.apache.org/jira/browse/FLINK-27178 Project: Flink Issue Type: Sub-t

[jira] [Created] (FLINK-27177) Implement Temporal State

David Anderson created FLINK-27177: -- Summary: Implement Temporal State Key: FLINK-27177 URL: https://issues.apache.org/jira/browse/FLINK-27177 Project: Flink Issue Type: Sub-task C

[jira] [Created] (FLINK-27176) FLIP-220: Temporal State

David Anderson created FLINK-27176: -- Summary: FLIP-220: Temporal State Key: FLINK-27176 URL: https://issues.apache.org/jira/browse/FLINK-27176 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-27175) Fail to call Hive UDAF when the UDAF is with only one parameter with array type

luoyuxia created FLINK-27175: Summary: Fail to call Hive UDAF when the UDAF is with only one parameter with array type Key: FLINK-27175 URL: https://issues.apache.org/jira/browse/FLINK-27175 Project: Flin

[jira] [Created] (FLINK-27174) Non-null check for bootstrapServers field is incorrect in KafkaSink

Zhengqi Zhang created FLINK-27174: - Summary: Non-null check for bootstrapServers field is incorrect in KafkaSink Key: FLINK-27174 URL: https://issues.apache.org/jira/browse/FLINK-27174 Project: Flink

[jira] [Created] (FLINK-27173) CoGroupedStreams$TaggedUnion cannot be used as a POJO type

Jun Qin created FLINK-27173: --- Summary: CoGroupedStreams$TaggedUnion cannot be used as a POJO type Key: FLINK-27173 URL: https://issues.apache.org/jira/browse/FLINK-27173 Project: Flink Issue Type:

[jira] [Created] (FLINK-27172) Support bulk based format provided by Flink

Yubin Li created FLINK-27172: Summary: Support bulk based format provided by Flink Key: FLINK-27172 URL: https://issues.apache.org/jira/browse/FLINK-27172 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27171) Add periodic kerberos delegation token obtain possibility to DelegationTokenManager

Gabor Somogyi created FLINK-27171: - Summary: Add periodic kerberos delegation token obtain possibility to DelegationTokenManager Key: FLINK-27171 URL: https://issues.apache.org/jira/browse/FLINK-27171

[jira] [Created] (FLINK-27170) Support Ftrl in FlinkML

weibo zhao created FLINK-27170: -- Summary: Support Ftrl in FlinkML Key: FLINK-27170 URL: https://issues.apache.org/jira/browse/FLINK-27170 Project: Flink Issue Type: New Feature Compone

[jira] [Created] (FLINK-27169) PartiallyFinishedSourcesITCase.test hangs on azure

Yun Gao created FLINK-27169: --- Summary: PartiallyFinishedSourcesITCase.test hangs on azure Key: FLINK-27169 URL: https://issues.apache.org/jira/browse/FLINK-27169 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-27168) Add continuousprocessingtimetrigger and continuouseventtimetrigger triggers

zhangjingcun created FLINK-27168: Summary: Add continuousprocessingtimetrigger and continuouseventtimetrigger triggers Key: FLINK-27168 URL: https://issues.apache.org/jira/browse/FLINK-27168 Project:

[jira] [Created] (FLINK-27167) Deploying master snapshot failed due to generating javadoc failed

Yun Gao created FLINK-27167: --- Summary: Deploying master snapshot failed due to generating javadoc failed Key: FLINK-27167 URL: https://issues.apache.org/jira/browse/FLINK-27167 Project: Flink Issu

[jira] [Created] (FLINK-27166) Introduce file structure document for table store

Jingsong Lee created FLINK-27166: Summary: Introduce file structure document for table store Key: FLINK-27166 URL: https://issues.apache.org/jira/browse/FLINK-27166 Project: Flink Issue Type:

[jira] [Created] (FLINK-27165) Benchmark test SerializationFrameworkMiniBenchmarks#serializerHeavyString became unstable

Matthias Pohl created FLINK-27165: - Summary: Benchmark test SerializationFrameworkMiniBenchmarks#serializerHeavyString became unstable Key: FLINK-27165 URL: https://issues.apache.org/jira/browse/FLINK-27165

[jira] [Created] (FLINK-27164) ResumeCheckpointManuallyITCase.testExternalizedFSCheckpointsWithLocalRecoveryZookeeper failed on azure

Yun Gao created FLINK-27164: --- Summary: ResumeCheckpointManuallyITCase.testExternalizedFSCheckpointsWithLocalRecoveryZookeeper failed on azure Key: FLINK-27164 URL: https://issues.apache.org/jira/browse/FLINK-27164

[jira] [Created] (FLINK-27163) Fix typo issue in Flink Metrics documentation

hao wang created FLINK-27163: Summary: Fix typo issue in Flink Metrics documentation Key: FLINK-27163 URL: https://issues.apache.org/jira/browse/FLINK-27163 Project: Flink Issue Type: Bug