Gyula Fora created FLINK-26345:
--
Summary: Observer should detect flink job even if deployment
status is empty
Key: FLINK-26345
URL: https://issues.apache.org/jira/browse/FLINK-26345
Project: Flink
Yang Wang created FLINK-26344:
-
Summary: waitForClusterShutdown does not work correctly in Flink
Kubernetes operator
Key: FLINK-26344
URL: https://issues.apache.org/jira/browse/FLINK-26344
Project:
luoyuxia created FLINK-26343:
Summary: IndexOutOfBoundsException when subquery select all field
from using hive dialect
Key: FLINK-26343
URL: https://issues.apache.org/jira/browse/FLINK-26343
Project:
This plan LGTM.
Thanks,
Thomas
On Wed, Feb 23, 2022 at 4:28 AM Chesnay Schepler wrote:
>
> That sounds fine to me.
>
> On 23/02/2022 10:49, Konstantin Knauf wrote:
> > Hi Chesnay, Hi everyone,
> >
> > I think the idea for the migration is the following (with the example of
> > ElasticSearch). I
Alexander Fedulov created FLINK-26342:
-
Summary: Add missing CSV format page
Key: FLINK-26342
URL: https://issues.apache.org/jira/browse/FLINK-26342
Project: Flink
Issue Type:
Matthias Pohl created FLINK-26341:
-
Summary: ZooKeeperTestEnvironment does not allow for repeated test
execution
Key: FLINK-26341
URL: https://issues.apache.org/jira/browse/FLINK-26341
Project: Flink
Great -- thanks for your help!
PR created: [FLINK-26340][statefun-golang-sdk] Add ability in Golang SDK to
create new statefun.Context from existing one, but with a new underlying
context.Context by galenwarren · Pull Request #303 · apache/flink-statefun
(github.com)
I agree with you Galen, adding a default implementation would not be so
natural here. We could eventually change this from being an interface to
just a struct (like http.Request) if there is no use case for custom
implementations.
Thanks for the nice discussion here + contribution :)
Austin
On
Thanks, Till.
> Is it possible in Go to provide a default implementation for a method?
> Maybe that way the introduction of the new method would not be breaking.
>
I can't think of a way to do this that would be seamless to someone who had
chosen to create a custom struct implementing
Galen Warren created FLINK-26340:
Summary: Add ability in Golang SDK to create new statefun.Context
from existing one, but with a new underlying context.Context
Key: FLINK-26340
URL:
Aitozi created FLINK-26339:
--
Summary: Introduce the webhook config to free the environment
options
Key: FLINK-26339
URL: https://issues.apache.org/jira/browse/FLINK-26339
Project: Flink
Issue
Yun Tang created FLINK-26338:
Summary: Add documentation of savepoint type on Command-Line part
Key: FLINK-26338
URL: https://issues.apache.org/jira/browse/FLINK-26338
Project: Flink
Issue Type:
Aitozi created FLINK-26337:
--
Summary: Avoid load flink conf each reconcile loop
Key: FLINK-26337
URL: https://issues.apache.org/jira/browse/FLINK-26337
Project: Flink
Issue Type: Sub-task
Gyula Fora created FLINK-26336:
--
Summary: Deletion should remove HA related configmaps also
Key: FLINK-26336
URL: https://issues.apache.org/jira/browse/FLINK-26336
Project: Flink
Issue Type:
Marcelo Nogueira created FLINK-26335:
Summary: prometheus/metrics - java.lang.OutOfMemoryError: Java
heap space
Key: FLINK-26335
URL: https://issues.apache.org/jira/browse/FLINK-26335
Project:
realdengziqi created FLINK-26334:
Summary: when watermark less than (0-offset) , T
Key: FLINK-26334
URL: https://issues.apache.org/jira/browse/FLINK-26334
Project: Flink
Issue Type: Bug
That sounds fine to me.
On 23/02/2022 10:49, Konstantin Knauf wrote:
Hi Chesnay, Hi everyone,
I think the idea for the migration is the following (with the example of
ElasticSearch). I talked to Martijn offline.
1. ElasticSearch Connector is released from the core repository with the
Flink
Parag Somani created FLINK-26333:
Summary: [Flink 1.14.3] Repeated exception with
DuplicateJobSubmissionException: Job has already been submitted
Key: FLINK-26333
URL:
Aitozi created FLINK-26332:
--
Summary: Move the Operator Env to the common Utils
Key: FLINK-26332
URL: https://issues.apache.org/jira/browse/FLINK-26332
Project: Flink
Issue Type: Improvement
Hi Fabian,
Thanks for letting us know. I believe that it should be ok to merge this PR
since it is only affecting the ES connector.
Cheers,
Till
On Wed, Feb 23, 2022 at 10:54 AM Fabian Paul wrote:
> Hi all,
>
> I would like to merge the following PR [1]. It has been approved
> before the
Matthias Pohl created FLINK-26331:
-
Summary: Make max retries configurable
Key: FLINK-26331
URL: https://issues.apache.org/jira/browse/FLINK-26331
Project: Flink
Issue Type: Sub-task
Hi all,
I would like to merge the following PR [1]. It has been approved
before the feature freeze but no one had time to merge it,
unfortunately. The feature is very contained and only adds a simple
capability to the Elastic connector when used with Flink SQL. If there
are no concerns until end
Lijie Wang created FLINK-26330:
--
Summary: Test Adaptive Batch Scheduler manually
Key: FLINK-26330
URL: https://issues.apache.org/jira/browse/FLINK-26330
Project: Flink
Issue Type: Sub-task
Hi Chesnay, Hi everyone,
I think the idea for the migration is the following (with the example of
ElasticSearch). I talked to Martijn offline.
1. ElasticSearch Connector is released from the core repository with the
Flink 1.15.0 release. No changes.
2. At the beginning of the Flink 1.16 release
Junfan Zhang created FLINK-26329:
Summary: Adjust the order of var initialization in
FlinkControllerConfig
Key: FLINK-26329
URL: https://issues.apache.org/jira/browse/FLINK-26329
Project: Flink
Matyas Orhidi created FLINK-26328:
-
Summary: Control Logging Behavior in Flink Deployments
Key: FLINK-26328
URL: https://issues.apache.org/jira/browse/FLINK-26328
Project: Flink
Issue Type:
Spongebob created FLINK-26327:
-
Summary: throw not a literal exception in
callContext.getArgumentValue when getTypeInference
Key: FLINK-26327
URL: https://issues.apache.org/jira/browse/FLINK-26327
Anton Kalashnikov created FLINK-26326:
-
Summary: FLIP-203: Support native and incremental savepoints 1.1
Key: FLINK-26326
URL: https://issues.apache.org/jira/browse/FLINK-26326
Project: Flink
Anton Kalashnikov created FLINK-26325:
-
Summary: Add test coverage for native format State Processor API
Key: FLINK-26325
URL: https://issues.apache.org/jira/browse/FLINK-26325
Project: Flink
Junfan Zhang created FLINK-26324:
Summary: Remove duplicate condition judgment
Key: FLINK-26324
URL: https://issues.apache.org/jira/browse/FLINK-26324
Project: Flink
Issue Type: Improvement
Thanks a lot for the discussion Austin and Galen. I think it would be fine
to break the API at this point in time. Moreover, I don't assume that many
people have their own statefun.Context implementations. Is it possible in
Go to provide a default implementation for a method? Maybe that way the
Congrats!!!
On Tue, Feb 22, 2022, 05:12 Yun Gao wrote:
> 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
Yun Gao created FLINK-26323:
---
Summary: PerJobMiniClusterFactoryTest.testJobClient failed on azure
Key: FLINK-26323
URL: https://issues.apache.org/jira/browse/FLINK-26323
Project: Flink
Issue Type:
33 matches
Mail list logo