[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

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

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

[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:

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

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

[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

[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

[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

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

[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

[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

[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

[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

[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

[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

[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:

[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

[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:

[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

[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

[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

[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

[jira] [Created] (FLINK-27162) RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState failed on azure

Yun Gao created FLINK-27162: --- Summary: RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState failed on azure Key: FLINK-27162 URL: https://issues.apache.org/jira/browse/FLINK-27162 Project:

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

Hi Paul, I grant the permission to you. Regarding the "SHOW QUERIES", how will you bookkeep and persist the running and complete queries? Or will you retrieve the queries information from the cluster every time when you receive the command? Best, Jark On Wed, 6 Apr 2022 at 11:23, Paul Lam