lothar created FLINK-26792:
--
Summary: BufferedMutator failed when insert and update with a
flush in Hbase Sink
Key: FLINK-26792
URL: https://issues.apache.org/jira/browse/FLINK-26792
Project: Flink
Jingsong Lee created FLINK-26791:
Summary: Finish projection push down for table store
Key: FLINK-26791
URL: https://issues.apache.org/jira/browse/FLINK-26791
Project: Flink
Issue Type:
Hi Ron, Thank you so much for this suggestion, this is so good.
In our company, when users use custom UDF, it is very inconvenient, and the
code needs to be packaged into the job jar,
and cannot refer to the existing udf jar through the existing udf jar.
Or pass in the jar reference in the
jinghaihang created FLINK-26790:
---
Summary: Description image about Unaligned Checkpointing maybe
incorrect.
Key: FLINK-26790
URL: https://issues.apache.org/jira/browse/FLINK-26790
Project: Flink
I think the session cluster could not be deleted unless all the running
jobs have finished or cancelled. I agree this should be clarified in the
FLIP.
Best,
Yang
Thomas Weise 于2022年3月22日周二 09:26写道：
> Hi Aitozi,
>
> Thanks for the proposal. Can you please clarify in the FLIP the
> relationship
Hi Aitozi,
Thanks for the proposal. Can you please clarify in the FLIP the
relationship between the session deployment and the jobs that depend on it?
Will, for example, the operator ensure that the individual jobs are
deleted when the underlying cluster is deleted?
Side note: When the
Hello,
As all relevant issues are assigned and worked on there’s no need to sync
tomorrow.
Therefor we decided to cancel the sync.
Best,
Joe
Matthias Pohl created FLINK-26789:
-
Summary:
RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState failed
Key: FLINK-26789
URL: https://issues.apache.org/jira/browse/FLINK-26789
Hi Piotr,
Very thanks for the information and very sorry for the missing!
Now I updated the flink.version property of the benchmark library
and also update it to the checklist in the releasing introduction
document~
Best,
Yun Gao
zlzhang0122 created FLINK-26788:
---
Summary: AbstractDeserializationSchema should add cause when thow
a FlinkRuntimeException
Key: FLINK-26788
URL: https://issues.apache.org/jira/browse/FLINK-26788
Aitozi created FLINK-26787:
--
Summary: Implement FlinkSessionJobController and Reconciler
Key: FLINK-26787
URL: https://issues.apache.org/jira/browse/FLINK-26787
Project: Flink
Issue Type: Sub-task
Xin Hao created FLINK-26786:
---
Summary: Add default container annotation to the operator
deployment
Key: FLINK-26786
URL: https://issues.apache.org/jira/browse/FLINK-26786
Project: Flink
Issue
Aitozi created FLINK-26785:
--
Summary: Add FlinkSessionJob CRD
Key: FLINK-26785
URL: https://issues.apache.org/jira/browse/FLINK-26785
Project: Flink
Issue Type: Sub-task
Components:
Aitozi created FLINK-26784:
--
Summary: FLIP-215: Introduce FlinkSessionJob CRD in the kubernetes
operator
Key: FLINK-26784
URL: https://issues.apache.org/jira/browse/FLINK-26784
Project: Flink
Hi everyone,
The vote finished with 3 binding votes and 3 non-binding votes, there
are no disapproving votes. I will begin the work ASAP.
Best,
Aitozi
Shuiqiang Chen 于2022年3月21日周一 14:58写道：
> +1 (non-binding)
> It will make job management more convenient in session mode.
>
> Best,
>
Dawid Wysakowicz created FLINK-26783:
Summary: Restore from a stop-with-savepoint if failed during
committing
Key: FLINK-26783
URL: https://issues.apache.org/jira/browse/FLINK-26783
Project:
Francesco Guardiani created FLINK-26782:
---
Summary: Remove PlannerExpression and related
Key: FLINK-26782
URL: https://issues.apache.org/jira/browse/FLINK-26782
Project: Flink
Issue
Gyula Fora created FLINK-26781:
--
Summary: Link operator doc site to Flink Website
Key: FLINK-26781
URL: https://issues.apache.org/jira/browse/FLINK-26781
Project: Flink
Issue Type: Sub-task
Chesnay Schepler created FLINK-26780:
Summary: Add an option to force serialization for rpc invocations
Key: FLINK-26780
URL: https://issues.apache.org/jira/browse/FLINK-26780
Project: Flink
Chesnay Schepler created FLINK-26779:
Summary: StopWithSavepoint fails when called from standby JM
Key: FLINK-26779
URL: https://issues.apache.org/jira/browse/FLINK-26779
Project: Flink
Jingsong Lee created FLINK-26778:
Summary: Introduce snapshot latest and earliest hint files
Key: FLINK-26778
URL: https://issues.apache.org/jira/browse/FLINK-26778
Project: Flink
Issue
Marios Trivyzas created FLINK-26777:
---
Summary: Remove PlannerConfig
Key: FLINK-26777
URL: https://issues.apache.org/jira/browse/FLINK-26777
Project: Flink
Issue Type: Sub-task
Aitozi created FLINK-26776:
--
Summary: The LocalBufferPoolDestroyTest#isInBlockingBufferRequest
is fragile in different JDK environment
Key: FLINK-26776
URL: https://issues.apache.org/jira/browse/FLINK-26776
Hey Yun Gao,
I think you have missed the step of updating the flink-benchmarks
repository after forking the release-1.15 branch.
https://cwiki.apache.org/confluence/display/FLINK/Creating+a+Flink+Release
Prepare for the release -> Major release -> Flink Benchmarks repository
Best,
Piotrek
wt.,
Juntao Hu created FLINK-26775:
-
Summary: PyFlink WindowOperator#process_element register wrong
cleanup timer
Key: FLINK-26775
URL: https://issues.apache.org/jira/browse/FLINK-26775
Project: Flink
Maciej Bryński created FLINK-26774:
--
Summary: Flink UI freezes on Safari
Key: FLINK-26774
URL: https://issues.apache.org/jira/browse/FLINK-26774
Project: Flink
Issue Type: Bug
Matthias Pohl created FLINK-26773:
-
Summary: ResourceManager leader election can a reconnect while
shutting down the JobMaster
Key: FLINK-26773
URL: https://issues.apache.org/jira/browse/FLINK-26773
Mika Naylor created FLINK-26772:
---
Summary: Kubernetes Native in HA Application Mode does not retry
resource cleanup
Key: FLINK-26772
URL: https://issues.apache.org/jira/browse/FLINK-26772
Project:
luoyuxia created FLINK-26771:
Summary: Hive dialect supports to compare boolean type with
numeric type
Key: FLINK-26771
URL: https://issues.apache.org/jira/browse/FLINK-26771
Project: Flink
Wenlong Lyu created FLINK-26770:
---
Summary: Nullable ArrayData should not be Object[]
Key: FLINK-26770
URL: https://issues.apache.org/jira/browse/FLINK-26770
Project: Flink
Issue Type: Bug
Yang Wang created FLINK-26769:
-
Summary: Individual upgradeMode
Key: FLINK-26769
URL: https://issues.apache.org/jira/browse/FLINK-26769
Project: Flink
Issue Type: Sub-task
Reporter:
Yang Wang created FLINK-26768:
-
Summary: reconciliationStatus.error could not be cleared properly
Key: FLINK-26768
URL: https://issues.apache.org/jira/browse/FLINK-26768
Project: Flink
Issue
Marios Trivyzas created FLINK-26767:
---
Summary: Replace TableConfig.getConfiguration().get(Option) with
TableConfig.get(Option) (python)
Key: FLINK-26767
URL: https://issues.apache.org/jira/browse/FLINK-26767
Feifan Wang created FLINK-26766:
---
Summary: Mistake in ChangelogStateHandleStreamImpl#getIntersection
Key: FLINK-26766
URL: https://issues.apache.org/jira/browse/FLINK-26766
Project: Flink
Matyas Orhidi created FLINK-26765:
-
Summary: Document RBAC model
Key: FLINK-26765
URL: https://issues.apache.org/jira/browse/FLINK-26765
Project: Flink
Issue Type: Sub-task
luoyuxia created FLINK-26764:
Summary: Support RESPECT NULLS for FIRST_VALUE/LAST_VALUE
Key: FLINK-26764
URL: https://issues.apache.org/jira/browse/FLINK-26764
Project: Flink
Issue Type: New
Juntao Hu created FLINK-26763:
-
Summary: PyFlink support using system conda when running checks
and tests
Key: FLINK-26763
URL: https://issues.apache.org/jira/browse/FLINK-26763
Project: Flink
fanrui created FLINK-26762:
--
Summary: Add the overdraft buffer in BufferPool to reduce
unaligned checkpoint being blocked
Key: FLINK-26762
URL: https://issues.apache.org/jira/browse/FLINK-26762
Project:
+1 (non-binding)
It will make job management more convenient in session mode.
Best,
shuiqiang
Xintong Song 于2022年3月21日周一 09:57写道：
> Thanks Aitozi, the FLIP LGTM.
>
> +1 (binding)
>
> Thank you~
>
> Xintong Song
>
>
>
> On Fri, Mar 18, 2022 at 10:36 PM Őrhidi Mátyás
> wrote:
>
> > +1
Hi, everyone
I would like to open a discussion for support advanced Function DDL, this
proposal is a continuation of FLIP-79 in which Flink Function DDL is defined.
Until now it is partially released as the Flink function DDL with user defined
resources is not clearly discussed and
zoucao created FLINK-26761:
--
Summary: Fix the cast exception thrown by PreValidateReWriter when
insert into/overwrite a partitioned table.
Key: FLINK-26761
URL: https://issues.apache.org/jira/browse/FLINK-26761
Lijie Wang created FLINK-26760:
--
Summary: The new CSV source (file system source + CSV format) does
not support reading files whose file encoding is not UTF-8
Key: FLINK-26760
URL:
42 matches
Mail list logo
