[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #648: [FLINK-32700] Support job drain for Savepoint upgrade mode

gyfora commented on code in PR #648: URL: https://github.com/apache/flink-kubernetes-operator/pull/648#discussion_r1290964118 ## flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/reconciler/deployment/ApplicationReconcilerTest.java: ## @@ -1070,4 +107

[jira] [Assigned] (FLINK-32164) LifecycleState count metrics are not reported correctly by namespace

[ https://issues.apache.org/jira/browse/FLINK-32164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-32164: -- Assignee: Nicholas Jiang > LifecycleState count metrics are not reported correctly by namespa

[jira] [Closed] (FLINK-32772) Add support of SET statements in the SQL Runner example

[ https://issues.apache.org/jira/browse/FLINK-32772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-32772. -- Fix Version/s: kubernetes-operator-1.7.0 Assignee: Mehdi Resolution: Fixed merged to m

[jira] [Closed] (FLINK-32164) LifecycleState count metrics are not reported correctly by namespace

[ https://issues.apache.org/jira/browse/FLINK-32164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-32164. -- Fix Version/s: kubernetes-operator-1.7.0 Resolution: Fixed merged to main 2e8bc6fa2c9d78764c8e5

[jira] [Commented] (FLINK-25540) [JUnit5 Migration] Module: flink-runtime

[ https://issues.apache.org/jira/browse/FLINK-25540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17753071#comment-17753071 ] Matthias Pohl commented on FLINK-25540: --- That makes sense to have the efforts refl

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #643: [FLINK-32164] LifecycleState count metrics are not reported correctly by namespace

gyfora merged PR #643: URL: https://github.com/apache/flink-kubernetes-operator/pull/643 -- 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

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #643: [FLINK-32164] LifecycleState count metrics are not reported correctly by namespace

gyfora commented on PR #643: URL: https://github.com/apache/flink-kubernetes-operator/pull/643#issuecomment-1674286041 looks good! Thank you @SteNicholas -- 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

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #645: [FLINK-32773] Support PEM certificates in the SQL Runner example

gyfora commented on PR #645: URL: https://github.com/apache/flink-kubernetes-operator/pull/645#issuecomment-1674284529 after merging your other PR, there is a conflict -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use t

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #644: [FLINK-32772] Add support of SET statements in the SQL Runner example

gyfora merged PR #644: URL: https://github.com/apache/flink-kubernetes-operator/pull/644 -- 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

[jira] [Commented] (FLINK-26585) State Processor API: Loading a state set buffers the whole state set in memory before starting to process

[ https://issues.apache.org/jira/browse/FLINK-26585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17753068#comment-17753068 ] Matthias Schwalbe commented on FLINK-26585: --- Hello [~zhangyy91] : thanks for p

[jira] [Commented] (FLINK-32608) Improve source reusing with projection push down

[ https://issues.apache.org/jira/browse/FLINK-32608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17753066#comment-17753066 ] Aitozi commented on FLINK-32608: I think this issue is duplicated of https://issues.apa

[jira] [Updated] (FLINK-32832) Row对象不兼容scala int

[ https://issues.apache.org/jira/browse/FLINK-32832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yong yang updated FLINK-32832: -- Issue Type: Improvement (was: Bug) > Row对象不兼容scala int > - > > Key: F

[jira] [Commented] (FLINK-32832) Row对象不兼容scala int

[ https://issues.apache.org/jira/browse/FLINK-32832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17753064#comment-17753064 ] yong yang commented on FLINK-32832: --- 不兼容 我使用 java Integer就可以,这个我理解. 但是为什么第一个int字段就不需要I

[jira] [Created] (FLINK-32832) Row对象不兼容scala int

yong yang created FLINK-32832: - Summary: Row对象不兼容scala int Key: FLINK-32832 URL: https://issues.apache.org/jira/browse/FLINK-32832 Project: Flink Issue Type: Bug Components: Table SQL /

[jira] [Commented] (FLINK-25540) [JUnit5 Migration] Module: flink-runtime

[ https://issues.apache.org/jira/browse/FLINK-25540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17753062#comment-17753062 ] Ferenc Csaky commented on FLINK-25540: -- Thanks for the quick response folks, I agre

[jira] [Updated] (FLINK-32701) Potential Memory Leak in Flink CEP due to Persistent Starting States in NFAState

[ https://issues.apache.org/jira/browse/FLINK-32701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Puneet Duggal updated FLINK-32701: -- Affects Version/s: 1.16.2 1.16.1 > Potential Memory Leak in Flink CEP d

[jira] [Commented] (FLINK-32809) YarnClusterDescriptor.isarchiveonlyincludedinShipArchiveFiles dose not work as expected

[ https://issues.apache.org/jira/browse/FLINK-32809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17753044#comment-17753044 ] Rui Fan commented on FLINK-32809: - Thanks for the contribution! :) Merged via ac859459

[jira] [Resolved] (FLINK-32809) YarnClusterDescriptor.isarchiveonlyincludedinShipArchiveFiles dose not work as expected

[ https://issues.apache.org/jira/browse/FLINK-32809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-32809. - Fix Version/s: 1.18.0 Resolution: Fixed > YarnClusterDescriptor.isarchiveonlyincludedinShipArchiv

[GitHub] [flink] 1996fanrui merged pull request #23191: [FLINK-32809][yarn] Fixes YarnClusterDescriptor#isArchiveOnlyIncluded…

1996fanrui merged PR #23191: URL: https://github.com/apache/flink/pull/23191 -- 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.ap

[jira] [Updated] (FLINK-32809) YarnClusterDescriptor.isarchiveonlyincludedinShipArchiveFiles dose not work as expected

[ https://issues.apache.org/jira/browse/FLINK-32809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32809: Affects Version/s: (was: 1.16.2) (was: 1.17.1) > YarnClusterDescriptor.isar

[GitHub] [flink] 1996fanrui commented on pull request #23191: [FLINK-32809][yarn] Fixes YarnClusterDescriptor#isArchiveOnlyIncluded…

1996fanrui commented on PR #23191: URL: https://github.com/apache/flink/pull/23191#issuecomment-1674209284 Thanks @RocMarshal for the review, merging~ -- 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

[jira] [Assigned] (FLINK-32831) RuntimeFilterProgram should aware join type when looking for the build side

[ https://issues.apache.org/jira/browse/FLINK-32831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang reassigned FLINK-32831: -- Assignee: Lijie Wang > RuntimeFilterProgram should aware join type when looking for the build

[GitHub] [flink] qinf commented on a diff in pull request #23191: [FLINK-32809][yarn] Fixes YarnClusterDescriptor#isArchiveOnlyIncluded…

qinf commented on code in PR #23191: URL: https://github.com/apache/flink/pull/23191#discussion_r1290869793 ## flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java: ## @@ -305,23 +305,26 @@ public void addShipFiles(List shipFiles) { private void addShip

[jira] [Updated] (FLINK-32831) RuntimeFilterProgram should aware join type when looking for the build side

[ https://issues.apache.org/jira/browse/FLINK-32831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang updated FLINK-32831: --- Description: Currently, runtime filter program will try to look for an {{Exchange}} as build side t

[jira] [Created] (FLINK-32831) RuntimeFilterProgram should aware join type when looking for the build side

Lijie Wang created FLINK-32831: -- Summary: RuntimeFilterProgram should aware join type when looking for the build side Key: FLINK-32831 URL: https://issues.apache.org/jira/browse/FLINK-32831 Project: Flin

[GitHub] [flink] lincoln-lil commented on a diff in pull request #23192: [FLINK-32730][table-planner] Fix the bug of Scan reuse after projection pushdown without considering the dpp pattern

lincoln-lil commented on code in PR #23192: URL: https://github.com/apache/flink/pull/23192#discussion_r1290858921 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/reuse/ReplaceScanWithCalcShuttle.java: ## @@ -57,4 +61,12 @@ public RelNode vis

[GitHub] [flink] swuferhong commented on a diff in pull request #23192: [FLINK-32730][table-planner] Fix the bug of Scan reuse after projection pushdown without considering the dpp pattern

swuferhong commented on code in PR #23192: URL: https://github.com/apache/flink/pull/23192#discussion_r1290855481 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/reuse/ScanReuserUtils.java: ## @@ -329,6 +329,12 @@ public static String getDig

[GitHub] [flink] FangYongs commented on pull request #23063: [FLINK-32660][table] Introduce external FS compatible FileCatalogStore implementation

FangYongs commented on PR #23063: URL: https://github.com/apache/flink/pull/23063#issuecomment-1674165313 Thanks @ferenc-csaky for updating this PR, it LGTM overall, please fix the failed ci -- This is an automated message from the Apache Git Service. To respond to the message, please log

[jira] [Commented] (FLINK-32712) Record with RowKind of type -U should not be sent downstream when the before field is empty in ogg-json which op_type is U .

[ https://issues.apache.org/jira/browse/FLINK-32712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17753033#comment-17753033 ] yuan commented on FLINK-32712: -- [~lsy] Hi, thanks for the advice. I have added a more deta

[jira] [Updated] (FLINK-32712) Record with RowKind of type -U should not be sent downstream when the before field is empty in ogg-json which op_type is U .

[ https://issues.apache.org/jira/browse/FLINK-32712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuan updated FLINK-32712: - Description: The BEFORE field in ogg-json can be configured to contain no table fields, as in the ogg-json exam

[jira] [Updated] (FLINK-32712) Record with RowKind of type -U should not be sent downstream when the before field is empty in ogg-json which op_type is U .

[ https://issues.apache.org/jira/browse/FLINK-32712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuan updated FLINK-32712: - Description: The BEFORE field in ogg-json can be configured to contain no table fields, as in the ogg-json exam

[jira] [Updated] (FLINK-32712) Record with RowKind of type -U should not be sent downstream when the before field is empty in ogg-json which op_type is U .

[ https://issues.apache.org/jira/browse/FLINK-32712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuan updated FLINK-32712: - Summary: Record with RowKind of type -U should not be sent downstream when the before field is empty in ogg-json

[jira] [Closed] (FLINK-32709) Fix the bug of low memory utilization for Hybrid Shuffle

[ https://issues.apache.org/jira/browse/FLINK-32709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-32709. -- Resolution: Fixed > Fix the bug of low memory utilization for Hybrid Shuffle > ---

[jira] [Updated] (FLINK-32709) Fix the bug of low memory utilization for Hybrid Shuffle

[ https://issues.apache.org/jira/browse/FLINK-32709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-32709: --- Fix Version/s: 1.18.0 > Fix the bug of low memory utilization for Hybrid Shuffle > -

[jira] [Commented] (FLINK-32709) Fix the bug of low memory utilization for Hybrid Shuffle

[ https://issues.apache.org/jira/browse/FLINK-32709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17753025#comment-17753025 ] Weijie Guo commented on FLINK-32709: Master(1.18) via 0f841624a388be9ad551ec1ccbc15a

[GitHub] [flink] reswqa merged pull request #23095: [FLINK-32709][network] Fix the bug of low memory utilization for Hybrid Shuffle

reswqa merged PR #23095: URL: https://github.com/apache/flink/pull/23095 -- 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.apache

[GitHub] [flink] reswqa commented on a diff in pull request #23179: [FLINK-32770][network] Fix the inaccurate backlog number of Hybrid Shuffle

reswqa commented on code in PR #23179: URL: https://github.com/apache/flink/pull/23179#discussion_r1290831536 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/netty/TieredStorageResultSubpartitionViewTest.java: ## @@ -115,18 +113,18 @@ v

[jira] [Commented] (FLINK-32344) MongoDB connector support unbounded streaming read via ChangeStream feature

[ https://issues.apache.org/jira/browse/FLINK-32344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17753018#comment-17753018 ] Jiabao Sun commented on FLINK-32344: This PR has been open for a long time. Is there

[jira] [Updated] (FLINK-32344) MongoDB connector support unbounded streaming read via ChangeStream feature

[ https://issues.apache.org/jira/browse/FLINK-32344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun updated FLINK-32344: --- Labels: pull-request-available (was: pull-request-available stale-assigned) > MongoDB connector sup

[GitHub] [flink] RocMarshal commented on a diff in pull request #23191: [FLINK-32809][yarn] Fixes YarnClusterDescriptor#isArchiveOnlyIncluded…

RocMarshal commented on code in PR #23191: URL: https://github.com/apache/flink/pull/23191#discussion_r1290829384 ## flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java: ## @@ -305,23 +305,26 @@ public void addShipFiles(List shipFiles) { private void a

[GitHub] [flink] reswqa merged pull request #23140: [hotfix][javadocs] Fix some typo in java doc and comments

reswqa merged PR #23140: URL: https://github.com/apache/flink/pull/23140 -- 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.apache

[jira] [Comment Edited] (FLINK-32821) Streaming examples failed to execute due to error in packaging

[ https://issues.apache.org/jira/browse/FLINK-32821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17753000#comment-17753000 ] Zhanghao Chen edited comment on FLINK-32821 at 8/11/23 12:43 AM: -

[jira] [Commented] (FLINK-32821) Streaming examples failed to execute due to error in packaging

[ https://issues.apache.org/jira/browse/FLINK-32821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17753000#comment-17753000 ] Zhanghao Chen commented on FLINK-32821: --- Hi [~afedulov] , I execute them using the

[jira] [Comment Edited] (FLINK-32821) Streaming examples failed to execute due to error in packaging

[ https://issues.apache.org/jira/browse/FLINK-32821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17753000#comment-17753000 ] Zhanghao Chen edited comment on FLINK-32821 at 8/11/23 12:42 AM: -

[jira] [Updated] (FLINK-32830) Support Histogram function

[ https://issues.apache.org/jira/browse/FLINK-32830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hanyu Zheng updated FLINK-32830: Description: This is an implementation of HISTOGRAM Returns a map containing the distinct values

[GitHub] [flink] flinkbot commented on pull request #23194: [BP-1.17]historgram

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

[jira] [Updated] (FLINK-32830) Support Histogram function

[ https://issues.apache.org/jira/browse/FLINK-32830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hanyu Zheng updated FLINK-32830: Description: This is an implementation of HISTOGRAM Returns a map containing the distinct values

[jira] [Updated] (FLINK-32830) Support Histogram function

[ https://issues.apache.org/jira/browse/FLINK-32830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hanyu Zheng updated FLINK-32830: Description: ### What is the purpose of the change This is an implementation of HISTOGRAM Returns

[jira] [Created] (FLINK-32830) Support Histogram function

Hanyu Zheng created FLINK-32830: --- Summary: Support Histogram function Key: FLINK-32830 URL: https://issues.apache.org/jira/browse/FLINK-32830 Project: Flink Issue Type: Improvement

[GitHub] [flink] hanyuzheng7 opened a new pull request, #23194: [BP-1.17]historgram

hanyuzheng7 opened a new pull request, #23194: URL: https://github.com/apache/flink/pull/23194 ### What is the purpose of the change This is an implementation of HISTOGRAM Returns a map containing the distinct values of col1 mapped to the number of times each one occurs for the giv

[jira] [Updated] (FLINK-29789) Fix flaky tests in CheckpointCoordinatorTest

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

[jira] [Updated] (FLINK-32151) 'Run kubernetes pyflink application test' fails while pulling image

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

[jira] [Updated] (FLINK-32239) Unify TestJvmProcess and TestProcessBuilder

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

[jira] [Updated] (FLINK-27922) Flink SQL unique key lost when set table.exec.mini-batch.enabled=true

[ https://issues.apache.org/jira/browse/FLINK-27922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-27922: --- Labels: auto-deprioritized-major pull-request-available (was: pull-request-available stal

[jira] [Updated] (FLINK-32188) Support to "where" query with a fixed-value array and simplify condition for an array-type filed.

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

[jira] [Updated] (FLINK-31755) ROW function can not work with RewriteIntersectAllRule

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

[jira] [Updated] (FLINK-31862) KafkaSinkITCase.testStartFromSavepoint is unstable

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

[jira] [Updated] (FLINK-31493) helm upgrade does not work, because repo path does not follow helm standards

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

[jira] [Updated] (FLINK-32156) Int2AdaptiveHashJoinOperatorTest produced no output for 900s on AZP

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

[jira] [Updated] (FLINK-31567) Promote release 1.17

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

[jira] [Updated] (FLINK-32036) TableEnvironmentTest.test_explain is unstable on azure ci

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

[jira] [Updated] (FLINK-32159) Hudi Source throws NPE

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

[jira] [Updated] (FLINK-26514) YARNSessionFIFOITCase.testDetachedMode failed on azure

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

[jira] [Updated] (FLINK-28358) when debug in local ,throw out "The system time period specification expects Timestamp type but is 'TIMESTAMP_WITH_LOCAL_TIME_ZONE' " exception

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

[jira] [Updated] (FLINK-28750) Whether to add field comment for hive table

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

[jira] [Updated] (FLINK-32393) NettyClientServerSslTest.testSslPinningForInvalidFingerprint fails with Address already in use

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

[jira] [Updated] (FLINK-32353) Update Cassandra connector archunit violations with Flink 1.18 rules

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

[jira] [Updated] (FLINK-31877) StreamExecutionEnvironmentTests.test_from_collection_with_data_types is unstable

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

[jira] [Updated] (FLINK-31595) MiniBatchLocalGroupAggFunction produces wrong aggregate results with state clean up

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

[jira] [Updated] (FLINK-31756) KafkaTableITCase.testStartFromGroupOffsetsNone fails due to UnknownTopicOrPartitionException

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

[jira] [Updated] (FLINK-28839) Incorrect english sentence in docs/content/docs/dev/dataset/iterations.md

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

[jira] [Updated] (FLINK-30743) Improve Kubernetes HA Services docs

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

[jira] [Updated] (FLINK-31525) JdbcExactlyOnceSinkE2eTest.testInsert times out

[ https://issues.apache.org/jira/browse/FLINK-31525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-31525: --- Labels: pull-request-available stale-critical test-stability (was: pull-request-available t

[jira] [Updated] (FLINK-28291) Add kerberos delegation token renewer feature instead of logged from keytab individually

[ https://issues.apache.org/jira/browse/FLINK-28291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-28291: --- Labels: PatchAvailable patch-available stale-minor (was: PatchAvailable patch-available) I

[jira] [Updated] (FLINK-32269) CreateTableAsITCase.testCreateTableAsInStatementSet fails on AZP

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

[jira] [Updated] (FLINK-32113) TtlMapStateAllEntriesTestContext failure in generic types

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

[jira] [Updated] (FLINK-27986) Refactor the name of finish method for JdbcOutputFormatBuilder

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

[jira] [Updated] (FLINK-32553) ClusterEntrypointTest.testCloseAsyncShouldNotDeregisterApp failed on AZP

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

[jira] [Updated] (FLINK-32483) RescaleCheckpointManuallyITCase.testCheckpointRescalingOutKeyedState fails on AZP

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

[jira] [Updated] (FLINK-32661) OperationRelatedITCase.testOperationRelatedApis fails on AZP

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

[jira] [Updated] (FLINK-31379) ZooKeeperMultipleComponentLeaderElectionDriverTest.testLeaderElectionWithMultipleDrivers runs into timeout

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

[jira] [Updated] (FLINK-31526) Various test failures in PyFlink

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

[jira] [Updated] (FLINK-31928) flink-kubernetes works not properly in k8s with IPv6 stack

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

[jira] [Updated] (FLINK-31828) List field in a POJO data stream results in table program compilation failure

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

[jira] [Updated] (FLINK-32155) Multiple CIs jobs failed due to "Could not connect to azure.archive.ubuntu.com"

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

[jira] [Updated] (FLINK-32138) SQLClientSchemaRegistryITCase fails with timeout on AZP

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

[jira] [Updated] (FLINK-31992) FlinkKafkaConsumer API is suggested to use as part of documentation, when that API is deprecated for flink version 1.14

[ https://issues.apache.org/jira/browse/FLINK-31992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-31992: --- Labels: documentation documentation-update good-first-issue newbie stale-major (was: docume

[jira] [Updated] (FLINK-32101) FlinkKafkaInternalProducerITCase.testInitTransactionId test failed

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

[jira] [Updated] (FLINK-28837) Translate "Hybrid Source" page of "DataStream Connectors" into Chinese

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

[jira] [Updated] (FLINK-28847) Typo in FileSinkProgram.java in file-sink-file-test module

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

[jira] [Updated] (FLINK-30782) Use https for schemaLocations

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

[jira] [Updated] (FLINK-32422) EmbeddedLeaderService doesn't handle the leader events properly in edge cases

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

[jira] [Updated] (FLINK-25413) Use append dfs.nameservices hadoop config to replace override

[ https://issues.apache.org/jira/browse/FLINK-25413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25413: --- Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available (was: au

[jira] [Updated] (FLINK-32440) Introduce file merging configuration

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

[jira] [Updated] (FLINK-32435) Merge testing implementations of LeaderContender

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

[jira] [Updated] (FLINK-32253) Blocklist unblockResources does not update the pending resource request

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

[jira] [Updated] (FLINK-25448) TaskManagerRunnerTest.testShouldShutdownIfRegistrationWithJobManagerFails failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25448: --- Labels: auto-deprioritized-major auto-deprioritized-minor test-stability (was: auto-depri

[jira] [Updated] (FLINK-26470) [Java][TypeExtractor] Missing type information in POJO types of some types (List, Map, UUID)

[ https://issues.apache.org/jira/browse/FLINK-26470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26470: --- Labels: auto-deprioritized-minor pojo (was: pojo stale-minor) Priority: Not a Priority

[jira] [Updated] (FLINK-6757) Investigate Apache Atlas integration

[ https://issues.apache.org/jira/browse/FLINK-6757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6757: -- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned (was: auto-deprior

[jira] [Updated] (FLINK-32344) MongoDB connector support unbounded streaming read via ChangeStream feature

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

  1   2   >