[jira] [Commented] (FLINK-28965) Should create empty partition when it's for dynamic partition

[ https://issues.apache.org/jira/browse/FLINK-28965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17579551#comment-17579551 ] luoyuxia commented on FLINK-28965: -- [~tartarus] Could you please have a look? > Should

[GitHub] [flink] WencongLiu opened a new pull request, #20574: [FLINK-28963][sql-gateway]Add API compatibility test for sql gateway rest endpoint

WencongLiu opened a new pull request, #20574: URL: https://github.com/apache/flink/pull/20574 ## What is the purpose of the change *Introduce the API compatibility test for sql gateway rest endpoint* ## Brief change log - *Reuse the compatibility test of fli

[jira] [Updated] (FLINK-28963) Add API compatibility test for sql gateway rest endpoint

[ https://issues.apache.org/jira/browse/FLINK-28963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28963: --- Labels: pull-request-available (was: ) > Add API compatibility test for sql gateway rest en

[GitHub] [flink] flinkbot commented on pull request #20574: [FLINK-28963][sql-gateway]Add API compatibility test for sql gateway rest endpoint

flinkbot commented on PR #20574: URL: https://github.com/apache/flink/pull/20574#issuecomment-1214675646 ## CI report: * 53095894e313fd8db4070d094189b5a600657299 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] lindong28 commented on a diff in pull request #20454: [FLINK-28639][Runtime/Checkpointing] Preserve consistency of events from subtask to OC

lindong28 commented on code in PR #20454: URL: https://github.com/apache/flink/pull/20454#discussion_r945439037 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/OperatorEventDispatcherImplTest.java: ## @@ -0,0 +1,260 @@ +/* + * Licensed to the Apach

[jira] [Commented] (FLINK-27171) Add periodic kerberos delegation token obtain possibility to DelegationTokenManager

[ https://issues.apache.org/jira/browse/FLINK-27171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17579336#comment-17579336 ] Feifan Wang commented on FLINK-27171: - Thinks [~gaborgsomogyi] ! > Add periodic ker

[jira] [Commented] (FLINK-28927) Can not clean up the uploaded shared files when the checkpoint times out

[ https://issues.apache.org/jira/browse/FLINK-28927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17579351#comment-17579351 ] Yun Tang commented on FLINK-28927: -- [~ChangjiGuo] could you share the design of how to

[jira] [Closed] (FLINK-28912) Add Part of "Who Use Flink" In ReadMe file and https://flink.apache.org/

[ https://issues.apache.org/jira/browse/FLINK-28912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang closed FLINK-28912. Resolution: Information Provided I think the "powered by flink" page already shows this. https://flink.ap

[GitHub] [flink] maxCodeVector opened a new pull request, #20566: [FLINK-27449][Table] fix: The comment is lost when creating a Table from Datastream and Schema

maxCodeVector opened a new pull request, #20566: URL: https://github.com/apache/flink/pull/20566 ## What is the purpose of the change This pull request solves the issue that the comment was lost when creating a Table from Datastream and Schema. Previously, the method `StreamTableEnvi

[jira] [Updated] (FLINK-27449) The comment is lost when creating a Table from Datastream and Schema

[ https://issues.apache.org/jira/browse/FLINK-27449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27449: --- Labels: pull-request-available (was: ) > The comment is lost when creating a Table from Dat

[GitHub] [flink] flinkbot commented on pull request #20566: [FLINK-27449][Table] fix: The comment is lost when creating a Table from Datastream and Schema

flinkbot commented on PR #20566: URL: https://github.com/apache/flink/pull/20566#issuecomment-1214339614 ## CI report: * 9692915fd56acc4e9d09bcf9c41a9afd143004a3 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] syhily opened a new pull request, #20567: [FLINK-27917][Connector/Pulsar] Fix message assert error in PulsarUnorderedPartitionSplitReaderTest

syhily opened a new pull request, #20567: URL: https://github.com/apache/flink/pull/20567 ## What is the purpose of the change Pulsar's client provides a `Consumer.seek()` method for setting the start position. This method would cause the race condition sometimes, which may lead to d

[jira] [Updated] (FLINK-27917) PulsarUnorderedPartitionSplitReaderTest.consumeMessageCreatedBeforeHandleSplitsChangesAndResetToEarliestPosition failed with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-27917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27917: --- Labels: pull-request-available test-stability (was: test-stability) > PulsarUnorderedPartit

[jira] [Commented] (FLINK-27917) PulsarUnorderedPartitionSplitReaderTest.consumeMessageCreatedBeforeHandleSplitsChangesAndResetToEarliestPosition failed with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-27917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17579401#comment-17579401 ] Yufan Sheng commented on FLINK-27917: - [~tison] Can you assign this issue to me? And

[GitHub] [flink] flinkbot commented on pull request #20567: [FLINK-27917][Connector/Pulsar] Fix message assert error in PulsarUnorderedPartitionSplitReaderTest

flinkbot commented on PR #20567: URL: https://github.com/apache/flink/pull/20567#issuecomment-1214391433 ## CI report: * 6fe35970dd039eb6b3e6b69a98f826be42df01cc UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Assigned] (FLINK-27917) PulsarUnorderedPartitionSplitReaderTest.consumeMessageCreatedBeforeHandleSplitsChangesAndResetToEarliestPosition failed with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-27917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-27917: - Assignee: Yufan Sheng > PulsarUnorderedPartitionSplitReaderTest.consumeMessageCreatedBeforeHand

[GitHub] [flink] tisonkun merged pull request #20565: [BP-1.14][FLINK-27399][Connector/Pulsar] [Connector/Pulsar] Change initial consuming position setting logic for better handle the checkpoint.

tisonkun merged PR #20565: URL: https://github.com/apache/flink/pull/20565 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apac

[GitHub] [flink] tisonkun commented on pull request #20564: [BP-1.15][FLINK-27399][Connector/Pulsar] [Connector/Pulsar] Change initial consuming position setting logic for better handle the checkpoint

tisonkun commented on PR #20564: URL: https://github.com/apache/flink/pull/20564#issuecomment-1214394131 Merging... Anyone can leave a review comment after merge. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] tisonkun merged pull request #20564: [BP-1.15][FLINK-27399][Connector/Pulsar] [Connector/Pulsar] Change initial consuming position setting logic for better handle the checkpoint.

tisonkun merged PR #20564: URL: https://github.com/apache/flink/pull/20564 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apac

[jira] [Commented] (FLINK-25884) PulsarSourceITCase.testTaskManagerFailure failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17579411#comment-17579411 ] Zili Chen commented on FLINK-25884: --- master via 18d21a0618f2195d4279828f610094ffccd052

[jira] [Closed] (FLINK-25884) PulsarSourceITCase.testTaskManagerFailure failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-25884. - Fix Version/s: 1.16.0 1.15.2 1.14.6 Resolution: Fixed > Pul

[jira] [Assigned] (FLINK-25815) PulsarSourceITCase.testTaskManagerFailure failed on azure due to timeout

[ https://issues.apache.org/jira/browse/FLINK-25815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-25815: - Assignee: Yufan Sheng > PulsarSourceITCase.testTaskManagerFailure failed on azure due to timeou

[jira] [Closed] (FLINK-25815) PulsarSourceITCase.testTaskManagerFailure failed on azure due to timeout

[ https://issues.apache.org/jira/browse/FLINK-25815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-25815. - Fix Version/s: 1.16.0 1.15.2 1.14.6 Resolution: Fixed maste

[jira] [Closed] (FLINK-24872) PulsarSourceITCase.testMultipleSplits failed on AZP

[ https://issues.apache.org/jira/browse/FLINK-24872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-24872. - Fix Version/s: 1.16.0 1.15.2 1.14.6 Resolution: Fixed maste

[jira] [Closed] (FLINK-27833) PulsarSourceITCase.testTaskManagerFailure failed with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-27833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-27833. - Fix Version/s: 1.16.0 1.15.2 1.14.6 Resolution: Fixed maste

[jira] [Closed] (FLINK-26177) PulsarSourceITCase.testScaleDown fails with timeout

[ https://issues.apache.org/jira/browse/FLINK-26177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-26177. - Fix Version/s: 1.16.0 1.15.2 1.14.6 Resolution: Fixed maste

[jira] [Assigned] (FLINK-27833) PulsarSourceITCase.testTaskManagerFailure failed with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-27833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-27833: - Assignee: Yufan Sheng > PulsarSourceITCase.testTaskManagerFailure failed with AssertionError >

[jira] [Closed] (FLINK-23944) PulsarSourceITCase.testTaskManagerFailure is instable

[ https://issues.apache.org/jira/browse/FLINK-23944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-23944. - Fix Version/s: 1.15.2 Resolution: Fixed master via 18d21a0618f2195d4279828f610094ffccd052b3 1.15

[jira] [Closed] (FLINK-26721) PulsarSourceITCase.testSavepoint failed on azure pipeline

[ https://issues.apache.org/jira/browse/FLINK-26721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-26721. - Fix Version/s: 1.15.2 1.14.6 Resolution: Fixed master via 18d21a0618f2195d4279

[jira] [Closed] (FLINK-27399) Pulsar connector didn't set start consuming position correctly

[ https://issues.apache.org/jira/browse/FLINK-27399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-27399. - Resolution: Fixed master via 18d21a0618f2195d4279828f610094ffccd052b3 1.15 via 5f842cb8665e831d6acb978a5

[jira] [Commented] (FLINK-27399) Pulsar connector didn't set start consuming position correctly

[ https://issues.apache.org/jira/browse/FLINK-27399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17579420#comment-17579420 ] Zili Chen commented on FLINK-27399: --- [~syhily] Thanks for your contribution! > Pulsar

[jira] [Updated] (FLINK-27399) Pulsar connector didn't set start consuming position correctly

[ https://issues.apache.org/jira/browse/FLINK-27399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yufan Sheng updated FLINK-27399: Description: The Pulsar connector didn't use the consuming position from the checkpoint. They jus

[jira] [Commented] (FLINK-27199) Bump Pulsar to 2.10.0 for fixing the unstable Pulsar test environment.

[ https://issues.apache.org/jira/browse/FLINK-27199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17579424#comment-17579424 ] Zili Chen commented on FLINK-27199: --- [~martijnvisser][~syhily] can we close this issue

[GitHub] [flink] maxCodeVector commented on pull request #20566: [FLINK-27449][Table] fix: The comment is lost when creating a Table from Datastream and Schema

maxCodeVector commented on PR #20566: URL: https://github.com/apache/flink/pull/20566#issuecomment-1214407452 > ## CI report: > * [9692915](https://github.com/apache/flink/commit/9692915fd56acc4e9d09bcf9c41a9afd143004a3) Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-

[jira] [Commented] (FLINK-28947) Curator framework fails with NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-28947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17579431#comment-17579431 ] DavidLiu commented on FLINK-28947: -- It seems Curator has bug.  I can help fix it. > Cu

[jira] (FLINK-28947) Curator framework fails with NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-28947 ] DavidLiu deleted comment on FLINK-28947: -- was (Author: JIRAUSER289843): It seems Curator has bug.  I can help fix it. > Curator framework fails with NullPointerException > -

[jira] [Commented] (FLINK-27817) TaskManager metaspace OOM for session cluster

[ https://issues.apache.org/jira/browse/FLINK-27817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17579432#comment-17579432 ] Yuan Huang commented on FLINK-27817: - There are many duplicate codes generated for

[GitHub] [flink] snuyanzin commented on a diff in pull request #17649: [FLINK-24742][table][docs] Add info about SQL client key strokes to docs

snuyanzin commented on code in PR #17649: URL: https://github.com/apache/flink/pull/17649#discussion_r945351068 ## docs/content/docs/dev/table/sqlClient.md: ## @@ -91,6 +91,40 @@ The `SET` command allows you to tune the job execution and the sql client behavi After a query is

[GitHub] [flink] snuyanzin commented on pull request #17649: [FLINK-24742][table][docs] Add info about SQL client key strokes to docs

snuyanzin commented on PR #17649: URL: https://github.com/apache/flink/pull/17649#issuecomment-1214462417 Added for Mac (tested on 2 relatively old Macs (before M1)) Please let me know in case I need to rebase -- This is an automated message from the Apache Git Service. To respond to th

[jira] [Updated] (FLINK-27928) External Resource Framework: 'external-resources' name delimitation not working as expected

[ https://issues.apache.org/jira/browse/FLINK-27928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-27928: --- Labels: auto-deprioritized-major external-resources (was: external-resources stale-major)

[jira] [Updated] (FLINK-28567) Introduce predicate inference from one side of join to the other

[ https://issues.apache.org/jira/browse/FLINK-28567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-28567: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-28398) CheckpointCoordinatorTriggeringTest.discardingTriggeringCheckpointWillExecuteNextCheckpointRequest( gets stuck

[ https://issues.apache.org/jira/browse/FLINK-28398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-28398: --- Labels: stale-assigned test-stability (was: test-stability) I am the [Flink Jira Bot|https:

[jira] [Updated] (FLINK-28034) ClassCastException occurred in creating a checkpoint with merge windows

[ https://issues.apache.org/jira/browse/FLINK-28034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-28034: --- Labels: pull-request-available stale-major (was: pull-request-available) I am the [Flink Ji

[jira] [Created] (FLINK-28951) Header in janino generated java files can merge with line numbers

Sergey Nuyanzin created FLINK-28951: --- Summary: Header in janino generated java files can merge with line numbers Key: FLINK-28951 URL: https://issues.apache.org/jira/browse/FLINK-28951 Project: Flin

[GitHub] [flink] snuyanzin opened a new pull request, #20568: [FLINK-28951][table] Make header with one line comments

snuyanzin opened a new pull request, #20568: URL: https://github.com/apache/flink/pull/20568 ## What is the purpose of the change The PR changes multiline comments for headers in for janino generated java files to one line to prevent merging with line numbers and to keep class compil

[jira] [Updated] (FLINK-28951) Header in janino generated java files can merge with line numbers

[ https://issues.apache.org/jira/browse/FLINK-28951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28951: --- Labels: pull-request-available (was: ) > Header in janino generated java files can merge wi

[GitHub] [flink] flinkbot commented on pull request #20568: [FLINK-28951][table] Make header with one line comments

flinkbot commented on PR #20568: URL: https://github.com/apache/flink/pull/20568#issuecomment-1214464725 ## CI report: * b8bec5c9388a411187fc96b836aa05bae702a92d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-28034) ClassCastException occurred in creating a checkpoint with merge windows

[ https://issues.apache.org/jira/browse/FLINK-28034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Takayuki Eimizu updated FLINK-28034: Labels: pull-request-available (was: pull-request-available stale-major) > ClassCastExcep

[jira] [Commented] (FLINK-28034) ClassCastException occurred in creating a checkpoint with merge windows

[ https://issues.apache.org/jira/browse/FLINK-28034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17579468#comment-17579468 ] Takayuki Eimizu commented on FLINK-28034: - Can someone please review this issue

[GitHub] [flink] tweise commented on a diff in pull request #20215: [FLINK-27479] [Connectors / Common] introduce availability helper to manage future for hybr…

tweise commented on code in PR #20215: URL: https://github.com/apache/flink/pull/20215#discussion_r945367610 ## flink-connectors/flink-connector-base/pom.xml: ## @@ -37,7 +37,7 @@ org.apache.flink - flink-co

[GitHub] [flink-ml] yunfengzhou-hub commented on pull request #140: [FLINK-28894] Add Transformer for Interaction

yunfengzhou-hub commented on PR #140: URL: https://github.com/apache/flink-ml/pull/140#issuecomment-1214497136 Thanks for updating the PR. The correctness and the APIs LGTM. @zhipeng93 could you please take a look at this PR? -- This is an automated message from the Apache Git Service. To

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #142: [FLINK-28943] Add Transformer and Estimator for MaxAbsScaler

yunfengzhou-hub commented on code in PR #142: URL: https://github.com/apache/flink-ml/pull/142#discussion_r945371997 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/maxabsscaler/MaxAbsScaler.java: ## @@ -0,0 +1,201 @@ +/* + * Licensed to the Apache Software Foundation

[jira] [Created] (FLINK-28952) Release Testing: Veify Hive dialect

luoyuxia created FLINK-28952: Summary: Release Testing: Veify Hive dialect Key: FLINK-28952 URL: https://issues.apache.org/jira/browse/FLINK-28952 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-28952) Release Testing: Veify Hive dialect

[ https://issues.apache.org/jira/browse/FLINK-28952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28952: - Component/s: Connectors / Hive Table SQL / API > Release Testing: Veify Hive dialect >

[jira] [Updated] (FLINK-28952) Release Testing: Veify Hive dialect

[ https://issues.apache.org/jira/browse/FLINK-28952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28952: - Fix Version/s: 1.16.0 > Release Testing: Veify Hive dialect > > >

[jira] [Updated] (FLINK-28952) Release Testing: Veify Hive dialect

[ https://issues.apache.org/jira/browse/FLINK-28952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-28952: - Labels: release-testing (was: ) > Release Testing: Veify Hive dialect > --

[jira] [Updated] (FLINK-28952) Release Testing: Veify Hive dialect

[ https://issues.apache.org/jira/browse/FLINK-28952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-28952: - Priority: Blocker (was: Major) > Release Testing: Veify Hive dialect > ---

[jira] [Updated] (FLINK-28952) Release Testing: Veify Hive dialect

[ https://issues.apache.org/jira/browse/FLINK-28952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-28952: - Affects Version/s: 1.16.0 > Release Testing: Veify Hive dialect > -

[jira] [Commented] (FLINK-28795) Unstable test for HiveDialectQueryITCase#testInsertDirectory

[ https://issues.apache.org/jira/browse/FLINK-28795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17579475#comment-17579475 ] Huang Xingbo commented on FLINK-28795: -- https://dev.azure.com/apache-flink/apache-f

<    1   2