[jira] [Created] (FLINK-26793) Flink Cassandra connector performance issue

Jay Ghiya created FLINK-26793: - Summary: Flink Cassandra connector performance issue Key: FLINK-26793 URL: https://issues.apache.org/jira/browse/FLINK-26793 Project: Flink Issue Type: Improvemen

Flink cassandra connector performance issue

Hi @dev@flink.apache.org, Greetings from gehc. This is regarding flink Cassandra connector implementation that could be causing the performance issue that we are facing. The summary of the error is "Insertions into scylla might be suffering. Expect performance prob

[jira] [Created] (FLINK-26792) BufferedMutator failed when insert and update with a flush in Hbase Sink

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

[jira] [Created] (FLINK-26791) Finish projection push down for table store

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: Sub-t

Re:[DISCUSS] FLIP-214 Support Advanced Function DDL

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 startu

[jira] [Created] (FLINK-26790) Description image about Unaligned Checkpointing maybe incorrect.

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

Re: [DISCUSS] Support the session job management in kubernetes operator

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 b

Re: [DISCUSS] Support the session job management in kubernetes operator

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 discussion

Weekly 1.15 Sync tomorrow cancelled

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

[jira] [Created] (FLINK-26789) RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState failed

Matthias Pohl created FLINK-26789: - Summary: RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState failed Key: FLINK-26789 URL: https://issues.apache.org/jira/browse/FLINK-26789 Project:

Re: [ANNOUNCE] release-1.15 branch cut

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

[jira] [Created] (FLINK-26788) AbstractDeserializationSchema should add cause when thow a FlinkRuntimeException

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 Projec

[jira] [Created] (FLINK-26787) Implement FlinkSessionJobController and Reconciler

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

[jira] [Created] (FLINK-26786) Add default container annotation to the operator deployment

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 Type

[jira] [Created] (FLINK-26785) Add FlinkSessionJob CRD

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

[jira] [Created] (FLINK-26784) FLIP-215: Introduce FlinkSessionJob CRD in the kubernetes operator

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 Issue

Re: [VOTE]FLIP-215: Introduce FlinkSessionJob CRD in the kubernetes operator

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, > shuiqi

[jira] [Created] (FLINK-26783) Restore from a stop-with-savepoint if failed during committing

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

[jira] [Created] (FLINK-26782) Remove PlannerExpression and related

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 Type

[jira] [Created] (FLINK-26781) Link operator doc site to Flink Website

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

[jira] [Created] (FLINK-26780) Add an option to force serialization for rpc invocations

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

[jira] [Created] (FLINK-26779) StopWithSavepoint fails when called from standby JM

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 I

[jira] [Created] (FLINK-26778) Introduce snapshot latest and earliest hint files

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

[jira] [Created] (FLINK-26777) Remove PlannerConfig

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 Com

[jira] [Created] (FLINK-26776) The LocalBufferPoolDestroyTest#isInBlockingBufferRequest is fragile in different JDK environment

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

Re: [ANNOUNCE] release-1.15 branch cut

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.,

[jira] [Created] (FLINK-26775) PyFlink WindowOperator#process_element register wrong cleanup timer

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

[jira] [Created] (FLINK-26774) Flink UI freezes on Safari

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 Comp

[jira] [Created] (FLINK-26773) ResourceManager leader election can a reconnect while shutting down the JobMaster

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 P

[jira] [Created] (FLINK-26772) Kubernetes Native in HA Application Mode does not retry resource cleanup

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

[jira] [Created] (FLINK-26771) Hive dialect supports to compare boolean type with numeric type

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 Issu

[jira] [Created] (FLINK-26770) Nullable ArrayData should not be Object[]

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 A

[jira] [Created] (FLINK-26769) Individual upgradeMode

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

[jira] [Created] (FLINK-26768) reconciliationStatus.error could not be cleared properly

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 Type

[jira] [Created] (FLINK-26767) Replace TableConfig.getConfiguration().get(Option) with TableConfig.get(Option) (python)

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

[jira] [Created] (FLINK-26766) Mistake in ChangelogStateHandleStreamImpl#getIntersection

Feifan Wang created FLINK-26766: --- Summary: Mistake in ChangelogStateHandleStreamImpl#getIntersection Key: FLINK-26766 URL: https://issues.apache.org/jira/browse/FLINK-26766 Project: Flink Issue

[jira] [Created] (FLINK-26765) Document RBAC model

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 Report

[jira] [Created] (FLINK-26764) Support RESPECT NULLS for FIRST_VALUE/LAST_VALUE

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 Fea

[jira] [Created] (FLINK-26763) PyFlink support using system conda when running checks and tests

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 I

[jira] [Created] (FLINK-26762) Add the overdraft buffer in BufferPool to reduce unaligned checkpoint being blocked

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