[jira] [Created] (FLINK-26278) Add Expressions.col as a synonym for $

Timo Walther created FLINK-26278: Summary: Add Expressions.col as a synonym for $ Key: FLINK-26278 URL: https://issues.apache.org/jira/browse/FLINK-26278 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-26276) Introduce ITCase for table store source and sink

Jingsong Lee created FLINK-26276: Summary: Introduce ITCase for table store source and sink Key: FLINK-26276 URL: https://issues.apache.org/jira/browse/FLINK-26276 Project: Flink Issue Type:

[jira] [Created] (FLINK-26280) Add a flag to disable uid generation

Francesco Guardiani created FLINK-26280: --- Summary: Add a flag to disable uid generation Key: FLINK-26280 URL: https://issues.apache.org/jira/browse/FLINK-26280 Project: Flink Issue

[jira] [Created] (FLINK-26282) Deprecate MetricNames.NUM_RECORDS_OUT_ERRORS

Jing Ge created FLINK-26282: --- Summary: Deprecate MetricNames.NUM_RECORDS_OUT_ERRORS Key: FLINK-26282 URL: https://issues.apache.org/jira/browse/FLINK-26282 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-26283) Harden AggregateCall serialization in JSON plan

Timo Walther created FLINK-26283: Summary: Harden AggregateCall serialization in JSON plan Key: FLINK-26283 URL: https://issues.apache.org/jira/browse/FLINK-26283 Project: Flink Issue Type:

[jira] [Created] (FLINK-26277) Java docs & implementation of TimestampColumnReader are contradicting

Caizhi Weng created FLINK-26277: --- Summary: Java docs & implementation of TimestampColumnReader are contradicting Key: FLINK-26277 URL: https://issues.apache.org/jira/browse/FLINK-26277 Project: Flink

[jira] [Created] (FLINK-26279) Provide mailbox delay metric

Sebastian Mattheis created FLINK-26279: -- Summary: Provide mailbox delay metric Key: FLINK-26279 URL: https://issues.apache.org/jira/browse/FLINK-26279 Project: Flink Issue Type: New

[jira] [Created] (FLINK-26275) Upgrade JLine 3.21.0

Cheng Pan created FLINK-26275: - Summary: Upgrade JLine 3.21.0 Key: FLINK-26275 URL: https://issues.apache.org/jira/browse/FLINK-26275 Project: Flink Issue Type: Sub-task Components:

Re: [DISCUSS]Support the merge statement in FlinkSQL

Hi, Openlnx, FG and Jingsong, thanks for your attention about this issue. I am sorry for the late reply, I’ m working on the further job about the implement of merge statement, and now we support this in our internal for the basic SQL syntax. About: Implement our flink sql plugin/extensions

[jira] [Created] (FLINK-26281) Test Elasticsearch connector End2End

Alexander Preuss created FLINK-26281: Summary: Test Elasticsearch connector End2End Key: FLINK-26281 URL: https://issues.apache.org/jira/browse/FLINK-26281 Project: Flink Issue Type:

[jira] [Created] (FLINK-26285) ZooKeeperStateHandleStore does not handle not existing nodes properly in getAllAndLock

Matthias Pohl created FLINK-26285: - Summary: ZooKeeperStateHandleStore does not handle not existing nodes properly in getAllAndLock Key: FLINK-26285 URL: https://issues.apache.org/jira/browse/FLINK-26285

[jira] [Created] (FLINK-26289) Adaptive Scheduler: Exception history can not be queried by the REST API

David Morávek created FLINK-26289: - Summary: Adaptive Scheduler: Exception history can not be queried by the REST API Key: FLINK-26289 URL: https://issues.apache.org/jira/browse/FLINK-26289 Project:

[jira] [Created] (FLINK-26290) Revisit serviceAccount and taskSlots direct fields in CRD

Thomas Weise created FLINK-26290: Summary: Revisit serviceAccount and taskSlots direct fields in CRD Key: FLINK-26290 URL: https://issues.apache.org/jira/browse/FLINK-26290 Project: Flink

Re: question about StatefunContext in golang Statefun SDK

So, upon further fiddling, I think it would be possible to keep full backward compatibility and add the option for someone to use an Invoke method with a separate context.Context and statefun.Runtime, via an adapter, if direct manipulation of the context.Context is needed. So, basically, the idea

Re: question about StatefunContext in golang Statefun SDK

FWIW I received a lot of early feedback explicitly asking me to couple the statefun specific operations with the Context (why the runtime type went away). Seth On Mon, Feb 21, 2022 at 10:32 AM Galen Warren wrote: > Thanks for looking into this! > > The issue I think we'd run into with your

Re: question about StatefunContext in golang Statefun SDK

Was the reason to combine them the desire to have two parameters vs. three, or was there another motivation? On Mon, Feb 21, 2022 at 12:02 PM Seth Wiesman wrote: > FWIW I received a lot of early feedback explicitly asking me to couple the > statefun specific operations with the Context (why the

[jira] [Created] (FLINK-26284) ZooKeeperStateHandleStore cleans the data stored in ZK before cleaning the StateHandle

Matthias Pohl created FLINK-26284: - Summary: ZooKeeperStateHandleStore cleans the data stored in ZK before cleaning the StateHandle Key: FLINK-26284 URL: https://issues.apache.org/jira/browse/FLINK-26284

Re: question about StatefunContext in golang Statefun SDK

Thanks for looking into this! The issue I think we'd run into with your proposal is that, often, libraries use non-exported types for context keys. Here is an example ; in this case, the non-exported loggerKey{} is used as

[jira] [Created] (FLINK-26288) Investigate why RetrievableStreamStateHandle.close does not call the close method of the wrapped instance

Matthias Pohl created FLINK-26288: - Summary: Investigate why RetrievableStreamStateHandle.close does not call the close method of the wrapped instance Key: FLINK-26288 URL:

[jira] [Created] (FLINK-26286) The KubernetesStateHandleStore cleans the metadata before cleaning the StateHandle

Matthias Pohl created FLINK-26286: - Summary: The KubernetesStateHandleStore cleans the metadata before cleaning the StateHandle Key: FLINK-26286 URL: https://issues.apache.org/jira/browse/FLINK-26286

[jira] [Created] (FLINK-26287) Add convenient TableConfig.set

Timo Walther created FLINK-26287: Summary: Add convenient TableConfig.set Key: FLINK-26287 URL: https://issues.apache.org/jira/browse/FLINK-26287 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-26292) FlinkKafkaProducerITCase.testScaleUpAfterScalingDown failed on azure

Yun Gao created FLINK-26292: --- Summary: FlinkKafkaProducerITCase.testScaleUpAfterScalingDown failed on azure Key: FLINK-26292 URL: https://issues.apache.org/jira/browse/FLINK-26292 Project: Flink

Re: [DISCUSS]Support the merge statement in FlinkSQL

> Could you list some needs from your point of view ? I know the typical requirements about extending the native flink sql for iceberg tables are: 1. There are many table management operations in apache iceberg which can be friendly if we can express in SQL for end users. such as: expire

[jira] [Created] (FLINK-26291) KinesisFirehoseSinkITCase failed on azure

Yun Gao created FLINK-26291: --- Summary: KinesisFirehoseSinkITCase failed on azure Key: FLINK-26291 URL: https://issues.apache.org/jira/browse/FLINK-26291 Project: Flink Issue Type: Bug

Re: Re: [ANNOUNCE] New Apache Flink Committers: Feng Wang, Zhipeng Zhang

Congratulations Feng and Zhipeng! Best, Yun -- From:Jing Zhang Send Time:2022 Feb. 18 (Fri.) 22:22 To:dev Subject:Re: Re: [ANNOUNCE] New Apache Flink Committers: Feng Wang, Zhipeng Zhang Congratulations! Best, Jing Zhang

Re: [ANNOUNCE] New Flink PMC members: Igal Shilman, Konstantin Knauf and Yun Gao

Congratulations Igal and Konstantin! Very thanks everyone for the warm greeting and help all the way, its really my honor and pleasure to work together with everyone in the community! Best, Yun -- From:Jing Zhang Send Time:2022

Re: [DISCUSS] Release Flink 1.14.4

Hi everyone, We still have two more critical issues for Flink 1.14. I'd like to understand if it makes sense to push one of these to the next release. https://issues.apache.org/jira/browse/FLINK-24607 @Becket: this seems to be missing the backport, correct?

Re: question about StatefunContext in golang Statefun SDK

Thanks a lot for clarifying the problem. I think I now understand the problem. As you've probably figured out, I have no clue about Go and its usage of the Context type. After looking into it a bit I was wondering whether we can't follow a similar route as it is done for the Context type. By

[jira] [Created] (FLINK-26274) Test local recovery works across TaskManager process restarts

Till Rohrmann created FLINK-26274: - Summary: Test local recovery works across TaskManager process restarts Key: FLINK-26274 URL: https://issues.apache.org/jira/browse/FLINK-26274 Project: Flink