[jira] [Created] (FLINK-26379) First message produced via Flink Kafka Connector is slow

Ragu Krishnamurthy created FLINK-26379: -- Summary: First message produced via Flink Kafka Connector is slow Key: FLINK-26379 URL: https://issues.apache.org/jira/browse/FLINK-26379 Project: Flink

[jira] [Created] (FLINK-26378) caller's address isn't set to None properly when a message is coming from an ingress

Igal Shilman created FLINK-26378: Summary: caller's address isn't set to None properly when a message is coming from an ingress Key: FLINK-26378 URL: https://issues.apache.org/jira/browse/FLINK-26378

[jira] [Created] (FLINK-26377) Extract Reconciler interface

Gyula Fora created FLINK-26377: -- Summary: Extract Reconciler interface Key: FLINK-26377 URL: https://issues.apache.org/jira/browse/FLINK-26377 Project: Flink Issue Type: Sub-task Compo

SourceEvent Task Failure Handling

Hi Devs, I am implementing a custom connector with the FLIP27 interface and I have a question about how source events are handled with respect to task/taskmanager failure. In my implementation, the enumerator sends source events to readers so that readers can react to split changes detected by the

Re: MetricRegistryTestUtils java class (flink-runtime/metrics) not found in source code version 1.14.3

Hi Prasanna, Why do you need histograms vs summaries? I'm curious about the change and want to see if it applies to my usage of the PrometheusReporter. Best, Mason On Mon, Jan 31, 2022 at 11:51 PM Martijn Visser wrote: > Hi Prasanna, > > Just a quick note that the Github links are all pointing

Re: [DISCUSS] Disable "Automated Checks / Review Progress" GitHub integration

Thank you all for your feedback. I've disabled the bot. On Fri, Feb 18, 2022 at 5:41 AM Jingsong Li wrote: > +1 to remove it. > > Thanks for driving. > > Best, > Jingsong > > On Thu, Feb 17, 2022 at 8:44 PM Till Rohrmann > wrote: > > > > +1 to remove it. > > > > Cheers, > > Till > > > > On Thu,

[jira] [Created] (FLINK-26376) Replace TableConfig with PlannerConfig in PlannerContext

Marios Trivyzas created FLINK-26376: --- Summary: Replace TableConfig with PlannerConfig in PlannerContext Key: FLINK-26376 URL: https://issues.apache.org/jira/browse/FLINK-26376 Project: Flink

Re: possible bug in Statefun Golang SDK related to Context.Caller

PR created: [FLINK-26375][statefun-golang-sdk] Fix Statefun Golang SDK to return nil from Context.Caller when there is no caller by galenwarren · Pull Request #304 · apache/flink-statefun (github.com) On Fri, Feb 25, 2022 at 9:53 AM Galen Warren

[jira] [Created] (FLINK-26375) Fix Statefun Golang SDK to return nil from Context.Caller when there is no caller

Galen Warren created FLINK-26375: Summary: Fix Statefun Golang SDK to return nil from Context.Caller when there is no caller Key: FLINK-26375 URL: https://issues.apache.org/jira/browse/FLINK-26375 Pro

Re: possible bug in Statefun Golang SDK related to Context.Caller

Thanks! I created a JIRA: [FLINK-26375] Fix Statefun Golang SDK to return nil from Context.Caller when there is no caller - ASF JIRA (apache.org) ... and will update soon with the PR. On Fri, Feb 25, 2022 at 3:01 AM Igal Shilman wrote: > Hi Ga

[jira] [Created] (FLINK-26374) JSON_OBJECT may throw NullPointerException on nullable column

Seth Wiesman created FLINK-26374: Summary: JSON_OBJECT may throw NullPointerException on nullable column Key: FLINK-26374 URL: https://issues.apache.org/jira/browse/FLINK-26374 Project: Flink

[jira] [Created] (FLINK-26373) Rename flink-connector-aws-kinesis-data-streams module to flink-connector-aws-kinesis-streams

Ahmed Hamdy created FLINK-26373: --- Summary: Rename flink-connector-aws-kinesis-data-streams module to flink-connector-aws-kinesis-streams Key: FLINK-26373 URL: https://issues.apache.org/jira/browse/FLINK-26373

[VOTE] Release 1.14.4, release candidate #1

Hi everyone, Please review and vote on the release candidate #1 for the version 1.14.4, 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-26372) Allow Changelog Storage configuration per program

Roman Khachatryan created FLINK-26372: - Summary: Allow Changelog Storage configuration per program Key: FLINK-26372 URL: https://issues.apache.org/jira/browse/FLINK-26372 Project: Flink I

[jira] [Created] (FLINK-26371) Support read hive variables using the syntax like select ${hiveconf:select_time}

luoyuxia created FLINK-26371: Summary: Support read hive variables using the syntax like select ${hiveconf:select_time} Key: FLINK-26371 URL: https://issues.apache.org/jira/browse/FLINK-26371 Project: Fli

[jira] [Created] (FLINK-26370) Make Flink cluster communication asynchronous

Gyula Fora created FLINK-26370: -- Summary: Make Flink cluster communication asynchronous Key: FLINK-26370 URL: https://issues.apache.org/jira/browse/FLINK-26370 Project: Flink Issue Type: Sub-tas

Re: [DISCUSS] Release Flink 1.14.4

Hi Qingsheng, Hi everyone, Thanks for the update. Sounds good to move FLINK-26018 to Flink 1.14.5. Since FLINK-26018 is the only Critical bug left, I will create an RC 1 soon. Best, Konstantin On Fri, Feb 25, 2022 at 9:49 AM Qingsheng Ren wrote: > Thanks Konstantin for the effort on the rele

[jira] [Created] (FLINK-26369) Translate the part zh-page mixed with not be translated.

Aiden Gong created FLINK-26369: -- Summary: Translate the part zh-page mixed with not be translated. Key: FLINK-26369 URL: https://issues.apache.org/jira/browse/FLINK-26369 Project: Flink Issue T

[jira] [Created] (FLINK-26368) Add setProperty method to KafkaSinkBuilder

Gyula Fora created FLINK-26368: -- Summary: Add setProperty method to KafkaSinkBuilder Key: FLINK-26368 URL: https://issues.apache.org/jira/browse/FLINK-26368 Project: Flink Issue Type: Improvemen

Re: [DISCUSS] Release Flink 1.14.4

Thanks Konstantin for the effort on the release! For FLINK-26018 [1] I share the same opinion with Fabian that it looks like we need a new feature to completely fix the issue. Considering we don’t have enough capacity to resolve it quickly for now, is it OK to postpone this issue to the next re

Re: possible bug in Statefun Golang SDK related to Context.Caller

Hi Galen, I think that you are right this does seem like a bug, looking at the Java SDK, we replace an empty address with a null value.[1] We should do the same here. I've also checked the Python SDK[2], and the JS SDK[3] and they have the same problem. Looking forward to your contribution! Than