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

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

[GitHub] [flink] flinkbot edited a comment on pull request #19248: Update JobLeaderIdService.java

flinkbot edited a comment on pull request #19248: URL: https://github.com/apache/flink/pull/19248#issuecomment-1079581419 ## CI report: * 282c6ca968612dc277ed663dd7dba0d0f63d11a2 Azure:

[jira] [Commented] (FLINK-26868) In JobLeaderIdService.java#L36 the annotation may be " Start the service with the given job leader id actions" instead of "Start the service with the given job le

[ https://issues.apache.org/jira/browse/FLINK-26868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17512661#comment-17512661 ] Zhuang Liu commented on FLINK-26868: - I have submitted a pull request at

[GitHub] [flink] flinkbot commented on pull request #19248: Update JobLeaderIdService.java

flinkbot commented on pull request #19248: URL: https://github.com/apache/flink/pull/19248#issuecomment-1079581419 ## CI report: * 282c6ca968612dc277ed663dd7dba0d0f63d11a2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] liuzhuang2017 opened a new pull request #19248: Update JobLeaderIdService.java

liuzhuang2017 opened a new pull request #19248: URL: https://github.com/apache/flink/pull/19248 [FLINK-26868] [flink-runtime] In JobLeaderIdService.java#L36 the annotation may be " Start the service with the given job leader id actions" instead of "Start the service with the given job

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #70: [FLINK-26313] Add Transformer and Estimator of OnlineKMeans

yunfengzhou-hub commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r835704039 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/HasBatchStrategy.java ## @@ -0,0 +1,40 @@ +/* + * Licensed to the Apache

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #70: [FLINK-26313] Add Transformer and Estimator of OnlineKMeans

yunfengzhou-hub commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r835703295 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/OnlineKMeansModel.java ## @@ -0,0 +1,182 @@ +/* + * Licensed to the

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #70: [FLINK-26313] Add Transformer and Estimator of OnlineKMeans

yunfengzhou-hub commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r835702703 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/OnlineKMeans.java ## @@ -0,0 +1,437 @@ +/* + * Licensed to the

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #70: [FLINK-26313] Add Transformer and Estimator of OnlineKMeans

yunfengzhou-hub commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r835702554 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/OnlineKMeans.java ## @@ -0,0 +1,437 @@ +/* + * Licensed to the

[jira] [Created] (FLINK-26868) In JobLeaderIdService.java#L36 the annotation may be " Start the service with the given job leader id actions" instead of "Start the service with the given job lead

Zhuang Liu created FLINK-26868: --- Summary: In JobLeaderIdService.java#L36 the annotation may be " Start the service with the given job leader id actions" instead of "Start the service with the given job leader actions." Key:

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #70: [FLINK-26313] Add Transformer and Estimator of OnlineKMeans

yunfengzhou-hub commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r835697293 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/common/distance/EuclideanDistanceMeasure.java ## @@ -34,6 +35,7 @@ public static

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #70: [FLINK-26313] Add Transformer and Estimator of OnlineKMeans

yunfengzhou-hub commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r835696729 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/OnlineKMeans.java ## @@ -0,0 +1,437 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-26751) [FLIP-171] Kafka implementation of AsyncSinkBase

[ https://issues.apache.org/jira/browse/FLINK-26751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17512530#comment-17512530 ] Almog Tavor commented on FLINK-26751: - I think this raises a problematic issue with AsyncSink in

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

[ https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17512513#comment-17512513 ] Etienne Chauchot commented on FLINK-26793: -- [~bumblebee] copying what I wrote on the ML: On a

[GitHub] [flink] flinkbot edited a comment on pull request #19198: [FLINK-26783] Do not trigger global failover if failed during commiting side-effects during stop-with-savepoint

flinkbot edited a comment on pull request #19198: URL: https://github.com/apache/flink/pull/19198#issuecomment-1075044557 ## CI report: * 8af7e7a8498025a47cb1cf4d653c9dc28c893309 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19247: [FLINK-26075][table-api][table-planner] Persist and use node configuration (1.15)

flinkbot edited a comment on pull request #19247: URL: https://github.com/apache/flink/pull/19247#issuecomment-1079122462 ## CI report: * ec8e43d584054d3b9dc7783a4646f51cd81bcc10 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19232: [FLINK-26075][table-api][table-planner] Persist and use node configuration

flinkbot edited a comment on pull request #19232: URL: https://github.com/apache/flink/pull/19232#issuecomment-1077672438 ## CI report: * 691bed347a13e0a89d734045e1da1ce739483b51 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19232: [FLINK-26075][table-api][table-planner] Persist and use node configuration

flinkbot edited a comment on pull request #19232: URL: https://github.com/apache/flink/pull/19232#issuecomment-1077672438 ## CI report: * 691bed347a13e0a89d734045e1da1ce739483b51 Azure:

[GitHub] [flink] matriv commented on pull request #19232: [FLINK-26075][table-api][table-planner] Persist and use node configuration

matriv commented on pull request #19232: URL: https://github.com/apache/flink/pull/19232#issuecomment-1079248556 @flinkbot run azure -- 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

[jira] [Updated] (FLINK-26663) Pod augmentation for the operator

[ https://issues.apache.org/jira/browse/FLINK-26663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-26663: --- Parent: (was: FLINK-25963) Issue Type: New Feature (was: Sub-task) > Pod augmentation

[GitHub] [flink] flinkbot edited a comment on pull request #18345: [FLINK-25440][doc][pulsar] Both stopCursor and startCursor now uses publish time instead of event time

flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 9d6f199f94a022807e2252c805bac9f8256c7924 UNKNOWN * c52899bd7f5833f7f754c96f6b9979b1c89fdeb9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19246: [hive]support over() without order keys inside.

flinkbot edited a comment on pull request #19246: URL: https://github.com/apache/flink/pull/19246#issuecomment-1078979166 ## CI report: * d907bdeaa4892caafcde35f5d579e48734e907d3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19128: [BP-1.14][FLINK-26018][connector/common] Create per-split output on split addition in SourceOperator

flinkbot edited a comment on pull request #19128: URL: https://github.com/apache/flink/pull/19128#issuecomment-1070481828 ## CI report: * 9017d3fb7d44b1fd2ad55b44823ac4fd222ab33a Azure:

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

[ https://issues.apache.org/jira/browse/FLINK-26781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-26781. -- > Link operator doc site to Flink Website > --- > >

[jira] [Closed] (FLINK-26139) Improve JobStatus tracking and handle different job states

[ https://issues.apache.org/jira/browse/FLINK-26139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-26139. -- Resolution: Won't Fix I am closing this ticket in the current form, we should break this up into

[jira] [Closed] (FLINK-26473) Observer should support JobManager deployment crashed or deleted externally

[ https://issues.apache.org/jira/browse/FLINK-26473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-26473. -- Resolution: Fixed > Observer should support JobManager deployment crashed or deleted externally >

[jira] [Updated] (FLINK-26345) Observer should detect flink job even if deployment status is empty

[ https://issues.apache.org/jira/browse/FLINK-26345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-26345: --- Parent: (was: FLINK-25963) Issue Type: Improvement (was: Sub-task) > Observer should

[GitHub] [flink] flinkbot edited a comment on pull request #19198: [FLINK-26783] Do not trigger global failover if failed during commiting side-effects during stop-with-savepoint

flinkbot edited a comment on pull request #19198: URL: https://github.com/apache/flink/pull/19198#issuecomment-1075044557 ## CI report: * d1064620741af7f0d2de07470c92d4d024d77688 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18928: [FLINK-25545][flink-clients][JUnit5 Migration] Module: flink-clients.

flinkbot edited a comment on pull request #18928: URL: https://github.com/apache/flink/pull/18928#issuecomment-1054170977 ## CI report: * 0ca5dd0460a3a4fa370c6f11ffc412fac332cf34 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19198: [FLINK-26783] Do not trigger global failover if failed during commiting side-effects during stop-with-savepoint

flinkbot edited a comment on pull request #19198: URL: https://github.com/apache/flink/pull/19198#issuecomment-1075044557 ## CI report: * f1773556290004a8e9fe5ce53ed7ac5c12c641d7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19232: [FLINK-26075][table-api][table-planner] Persist and use node configuration

flinkbot edited a comment on pull request #19232: URL: https://github.com/apache/flink/pull/19232#issuecomment-1077672438 ## CI report: * 691bed347a13e0a89d734045e1da1ce739483b51 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19232: [FLINK-26075][table-api][table-planner] Persist and use node configuration

flinkbot edited a comment on pull request #19232: URL: https://github.com/apache/flink/pull/19232#issuecomment-1077672438 ## CI report: * 691bed347a13e0a89d734045e1da1ce739483b51 Azure:

[GitHub] [flink] matriv commented on pull request #19232: [FLINK-26075][table-api][table-planner] Persist and use node configuration

matriv commented on pull request #19232: URL: https://github.com/apache/flink/pull/19232#issuecomment-1079130422 @flinkbot run azure -- 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

[jira] [Closed] (FLINK-26867) Hybrid reading wrong because of disordered commits

[ https://issues.apache.org/jira/browse/FLINK-26867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-26867. Resolution: Fixed master: 4936d20aa61f62208185b406f10a72c8baefe3d6 > Hybrid reading wrong

[jira] [Updated] (FLINK-26863) Filter predicate does not work

[ https://issues.apache.org/jira/browse/FLINK-26863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-26863: - Parent: FLINK-26653 Issue Type: Sub-task (was: Bug) > Filter predicate does not work >

[jira] [Updated] (FLINK-26867) Hybrid reading wrong because of disordered commits

[ https://issues.apache.org/jira/browse/FLINK-26867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26867: --- Labels: pull-request-available (was: ) > Hybrid reading wrong because of disordered

[GitHub] [flink-table-store] JingsongLi merged pull request #63: [FLINK-26867] Hybrid reading wrong because of disordered commits

JingsongLi merged pull request #63: URL: https://github.com/apache/flink-table-store/pull/63 -- 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:

[GitHub] [flink] flinkbot edited a comment on pull request #19247: [FLINK-26075][table-api][table-planner] Persist and use node configuration (1.15)

flinkbot edited a comment on pull request #19247: URL: https://github.com/apache/flink/pull/19247#issuecomment-1079122462 ## CI report: * ec8e43d584054d3b9dc7783a4646f51cd81bcc10 Azure:

[jira] [Closed] (FLINK-26863) Filter predicate does not work

[ https://issues.apache.org/jira/browse/FLINK-26863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-26863. Assignee: Jane Chan Resolution: Fixed master: cc7a085d3bb10b5bb82321d2d1a79e9b1cc1acbf >

[GitHub] [flink-table-store] JingsongLi merged pull request #62: [FLINK-26863] Fix that filter predicate does not work

JingsongLi merged pull request #62: URL: https://github.com/apache/flink-table-store/pull/62 -- 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:

[GitHub] [flink] flinkbot commented on pull request #19247: [FLINK-26075][table-api][table-planner] Persist and use node configuration (1.15)

flinkbot commented on pull request #19247: URL: https://github.com/apache/flink/pull/19247#issuecomment-1079122462 ## CI report: * ec8e43d584054d3b9dc7783a4646f51cd81bcc10 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #19208: [FLINK-26814][Deployment / YARN]It reported "should only have one jar" when submitting PyFlink jobs in YARN application mode

flinkbot edited a comment on pull request #19208: URL: https://github.com/apache/flink/pull/19208#issuecomment-1075903940 ## CI report: * c2f0edcf980784a1da841c294ddee91dd2c935f9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19110: [BP-1.15][FLINK-26018][connector/common] Create per-split output on split addition in SourceOperator

flinkbot edited a comment on pull request #19110: URL: https://github.com/apache/flink/pull/19110#issuecomment-1068891311 ## CI report: * c50633193b0e57db73c55cb258af70394001a815 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19232: [FLINK-26075][table-api][table-planner] Persist and use node configuration

flinkbot edited a comment on pull request #19232: URL: https://github.com/apache/flink/pull/19232#issuecomment-1077672438 ## CI report: * 691bed347a13e0a89d734045e1da1ce739483b51 Azure:

[jira] [Updated] (FLINK-26857) Add ITCase for projection and filter predicate

[ https://issues.apache.org/jira/browse/FLINK-26857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-26857: -- Description: To cover the conditions like  * filter predicate on partition fields * filter

[jira] [Updated] (FLINK-26857) Add ITCase for projection and filter predicate

[ https://issues.apache.org/jira/browse/FLINK-26857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-26857: -- Fix Version/s: 0.1.0 > Add ITCase for projection and filter predicate >

[jira] [Updated] (FLINK-26856) Add ITCase for compound primary key and multi-partition

[ https://issues.apache.org/jira/browse/FLINK-26856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-26856: -- Fix Version/s: 0.1.0 > Add ITCase for compound primary key and multi-partition >

[GitHub] [flink] flinkbot edited a comment on pull request #19232: [FLINK-26075][table-api][table-planner] Persist and use node configuration

flinkbot edited a comment on pull request #19232: URL: https://github.com/apache/flink/pull/19232#issuecomment-1077672438 ## CI report: * Unknown: [CANCELED](TBD) * 691bed347a13e0a89d734045e1da1ce739483b51 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19243: [hotfix][task] Add task name to BufferDebloater logging

flinkbot edited a comment on pull request #19243: URL: https://github.com/apache/flink/pull/19243#issuecomment-1078815658 ## CI report: * 7d1ed24e93ed72068f58e8d68b1df28bca90c908 Azure:

[jira] [Commented] (FLINK-21752) NullPointerException on restore in PojoSerializer

[ https://issues.apache.org/jira/browse/FLINK-21752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17512372#comment-17512372 ] Bastien DINE commented on FLINK-21752: -- Hi [~dwysakowicz]  After upgrading to 1.14.4, we are

[GitHub] [flink] flinkbot edited a comment on pull request #19104: [FLINK-26395][docs] Correct the wrong description of RAND_INTEGER.

flinkbot edited a comment on pull request #19104: URL: https://github.com/apache/flink/pull/19104#issuecomment-1068655357 ## CI report: * adb6152b2361d58bf0de3108fb219e44c560a2de Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19221: [FLINK-26842][python] Remove scala-bridge dependency

flinkbot edited a comment on pull request #19221: URL: https://github.com/apache/flink/pull/19221#issuecomment-1077412156 ## CI report: * 6c7fb63d23c866327ea8f6cef4c663340fcba1c1 Azure:

[GitHub] [flink] twalthr commented on a change in pull request #19232: [FLINK-26075][table-api][table-planner] Persist and use node configuration

twalthr commented on a change in pull request #19232: URL: https://github.com/apache/flink/pull/19232#discussion_r835292202 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/utils/ExecNodeMetadataUtilTest.java ## @@ -513,4 +501,21

[GitHub] [flink] flinkbot edited a comment on pull request #19244: [FLINK-26865][python] Fix the potential failure of loading library inThread Mode

flinkbot edited a comment on pull request #19244: URL: https://github.com/apache/flink/pull/19244#issuecomment-1078865315 ## CI report: * 01fd09935e35d31147bb16e325a1c45204bf5fd0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19230: [FLINK-26849][metrics] Deduplicate metric (un)registration logic

flinkbot edited a comment on pull request #19230: URL: https://github.com/apache/flink/pull/19230#issuecomment-1077654299 ## CI report: * 9006ced5a27e90757d1035bfb1b7dbbc57c9fb35 Azure:

[jira] [Comment Edited] (FLINK-21752) NullPointerException on restore in PojoSerializer

[ https://issues.apache.org/jira/browse/FLINK-21752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17512372#comment-17512372 ] Bastien DINE edited comment on FLINK-21752 at 3/25/22, 1:23 PM: Hi

[GitHub] [flink] flinkbot edited a comment on pull request #19234: [FLINK-26851][metrics] Properly model reporter options as ConfigOptions

flinkbot edited a comment on pull request #19234: URL: https://github.com/apache/flink/pull/19234#issuecomment-1077704797 ## CI report: * c179e0010b56936f4ea7c26bd43fab28d7b26027 Azure:

[jira] [Closed] (FLINK-26866) Expired cert during Helm installation

[ https://issues.apache.org/jira/browse/FLINK-26866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matyas Orhidi closed FLINK-26866. - Resolution: Not A Problem The issue was gone after restarting the webhook pod of the

[GitHub] [flink] flinkbot edited a comment on pull request #19245: [hotfix][docs]Modify the Chinese comments to English in python datastream_tutorial.md

flinkbot edited a comment on pull request #19245: URL: https://github.com/apache/flink/pull/19245#issuecomment-1078865451 ## CI report: * 01dbb36b21c67e9c81c281eadd15448e44c529e5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19231: [FLINK-26850][metrics] Add Metric#getMetricType

flinkbot edited a comment on pull request #19231: URL: https://github.com/apache/flink/pull/19231#issuecomment-1077654466 ## CI report: * ec2536627b41ab98a7704b1b6bb5531b85af9fcf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19225: [FLINK-26799][Runtime/StateBackends] fix StateChangeFormat#read and e…

flinkbot edited a comment on pull request #19225: URL: https://github.com/apache/flink/pull/19225#issuecomment-1077559112 ## CI report: * caad8d2df8d27756fd751cc19096d8a117c8cf5a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18345: [FLINK-25440][doc][pulsar] Both stopCursor and startCursor now uses publish time instead of event time

flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 9d6f199f94a022807e2252c805bac9f8256c7924 UNKNOWN * 249f4fd16a5e5f67e59da286c4a97129d27f314a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19242: [FLINK-26728][python]Support min/max/min_by/max_by operation in KeyedStream

flinkbot edited a comment on pull request #19242: URL: https://github.com/apache/flink/pull/19242#issuecomment-1078714878 ## CI report: * abf4f22d6b36f334acee1bc5f022938129837e84 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18345: [FLINK-25440][doc][pulsar] Both stopCursor and startCursor now uses publish time instead of event time

flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 9d6f199f94a022807e2252c805bac9f8256c7924 UNKNOWN * 249f4fd16a5e5f67e59da286c4a97129d27f314a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18345: [FLINK-25440][doc][pulsar] Both stopCursor and startCursor now uses publish time instead of event time

flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 9d6f199f94a022807e2252c805bac9f8256c7924 UNKNOWN * 249f4fd16a5e5f67e59da286c4a97129d27f314a Azure:

[jira] [Closed] (FLINK-26577) Avoid state loss when switching to last-state upgrade mode

[ https://issues.apache.org/jira/browse/FLINK-26577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-26577. -- Resolution: Fixed merged to main: 760a20dd3f0c2088aeafd6613d9f486425fb55a3 > Avoid state loss when

[GitHub] [flink] flinkbot edited a comment on pull request #19246: [hive]support over() without order keys inside.

flinkbot edited a comment on pull request #19246: URL: https://github.com/apache/flink/pull/19246#issuecomment-1078979166 ## CI report: * d907bdeaa4892caafcde35f5d579e48734e907d3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18345: [FLINK-25440][doc][pulsar] Both stopCursor and startCursor now uses publish time instead of event time

flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 9d6f199f94a022807e2252c805bac9f8256c7924 UNKNOWN * 249f4fd16a5e5f67e59da286c4a97129d27f314a Azure:

[GitHub] [flink] flinkbot commented on pull request #19246: [hive]support over() without order keys inside.

flinkbot commented on pull request #19246: URL: https://github.com/apache/flink/pull/19246#issuecomment-1078979166 ## CI report: * d907bdeaa4892caafcde35f5d579e48734e907d3 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] luoyuxia opened a new pull request #19246: [hive]support over() without order keys inside.

luoyuxia opened a new pull request #19246: URL: https://github.com/apache/flink/pull/19246 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them

[GitHub] [flink] flinkbot edited a comment on pull request #19235: [FLINK-26848][JDBC]write data when disable flush-interval and max-rows

flinkbot edited a comment on pull request #19235: URL: https://github.com/apache/flink/pull/19235#issuecomment-1077732821 ## CI report: * 113821e3dad0a8cde32b8d062913cf11efa564a4 Azure:

[jira] [Assigned] (FLINK-26866) Expired cert during Helm installation

[ https://issues.apache.org/jira/browse/FLINK-26866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-26866: -- Assignee: Matyas Orhidi > Expired cert during Helm installation >

[jira] [Assigned] (FLINK-26862) Link the Github repository from Operator documentation

[ https://issues.apache.org/jira/browse/FLINK-26862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-26862: -- Assignee: Matyas Orhidi > Link the Github repository from Operator documentation >

[GitHub] [flink] MartijnVisser commented on a change in pull request #19239: Update elasticsearch.md

MartijnVisser commented on a change in pull request #19239: URL: https://github.com/apache/flink/pull/19239#discussion_r835209265 ## File path: docs/content/docs/connectors/table/elasticsearch.md ## @@ -239,7 +239,7 @@ Features ### Key Handling Elasticsearch sink can work

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #70: [FLINK-26313] Add Transformer and Estimator of OnlineKMeans

yunfengzhou-hub commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r835209014 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/clustering/OnlineKMeansTest.java ## @@ -0,0 +1,476 @@ +/* + * Licensed to the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #19198: [FLINK-26783] Do not trigger global failover if failed during commiting side-effects during stop-with-savepoint

flinkbot edited a comment on pull request #19198: URL: https://github.com/apache/flink/pull/19198#issuecomment-1075044557 ## CI report: * f1773556290004a8e9fe5ce53ed7ac5c12c641d7 Azure:

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #70: [FLINK-26313] Add Transformer and Estimator of OnlineKMeans

yunfengzhou-hub commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r835200989 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/clustering/OnlineKMeansTest.java ## @@ -0,0 +1,476 @@ +/* + * Licensed to the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #19198: [FLINK-26783] Do not trigger global failover if failed during commiting side-effects during stop-with-savepoint

flinkbot edited a comment on pull request #19198: URL: https://github.com/apache/flink/pull/19198#issuecomment-1075044557 ## CI report: * 7933101b4fcaf3a14fd0f50b1f4ccadc68b75b35 Azure:

[GitHub] [flink] zoltar9264 edited a comment on pull request #19225: [FLINK-26799][Runtime/StateBackends] fix StateChangeFormat#read and e…

zoltar9264 edited a comment on pull request #19225: URL: https://github.com/apache/flink/pull/19225#issuecomment-1078940949 Hi @rkhachatryan , thanks for approve it , need I request another committer to merge it ? -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] zoltar9264 removed a comment on pull request #19225: [FLINK-26799][Runtime/StateBackends] fix StateChangeFormat#read and e…

zoltar9264 removed a comment on pull request #19225: URL: https://github.com/apache/flink/pull/19225#issuecomment-1078940552 > Yes, you're right, I looked at the PR title instead, sorry. Thanks for updating the commit message. LGTM. -- This is an automated message from the

[GitHub] [flink] zoltar9264 commented on pull request #19225: [FLINK-26799][Runtime/StateBackends] fix StateChangeFormat#read and e…

zoltar9264 commented on pull request #19225: URL: https://github.com/apache/flink/pull/19225#issuecomment-1078940552 > Yes, you're right, I looked at the PR title instead, sorry. Thanks for updating the commit message. LGTM. -- This is an automated message from the Apache Git

[GitHub] [flink] zoltar9264 commented on pull request #19225: [FLINK-26799][Runtime/StateBackends] fix StateChangeFormat#read and e…

zoltar9264 commented on pull request #19225: URL: https://github.com/apache/flink/pull/19225#issuecomment-1078940949 ggg -- 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.

[GitHub] [flink] zoltar9264 closed pull request #19225: [FLINK-26799][Runtime/StateBackends] fix StateChangeFormat#read and e…

zoltar9264 closed pull request #19225: URL: https://github.com/apache/flink/pull/19225 -- 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:

[GitHub] [flink] flinkbot edited a comment on pull request #19232: [FLINK-26075][table-api][table-planner] Persist and use node configuration

flinkbot edited a comment on pull request #19232: URL: https://github.com/apache/flink/pull/19232#issuecomment-1077672438 ## CI report: * Unknown: [CANCELED](TBD) * 691bed347a13e0a89d734045e1da1ce739483b51 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19241: [FLINK-26788][core] Add cause when AbstractDeserializationSchema throw exception

flinkbot edited a comment on pull request #19241: URL: https://github.com/apache/flink/pull/19241#issuecomment-1078660907 ## CI report: * d5e513797e5de12c5052cebe2148f03f48f49462 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19232: [FLINK-26075][table-api][table-planner] Persist and use node configuration

flinkbot edited a comment on pull request #19232: URL: https://github.com/apache/flink/pull/19232#issuecomment-1077672438 ## CI report: * Unknown: [CANCELED](TBD) * 691bed347a13e0a89d734045e1da1ce739483b51 UNKNOWN Bot commands The @flinkbot bot supports the

[GitHub] [flink] matriv commented on pull request #19232: [FLINK-26075][table-api][table-planner] Persist and use node configuration

matriv commented on pull request #19232: URL: https://github.com/apache/flink/pull/19232#issuecomment-1078928567 @flinkbot run azure -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #19232: [FLINK-26075][table-api][table-planner] Persist and use node configuration

flinkbot edited a comment on pull request #19232: URL: https://github.com/apache/flink/pull/19232#issuecomment-1077672438 ## CI report: * 0a06035b23ab6d7af82f159bc2aff52dd816364a Azure:

[jira] [Assigned] (FLINK-26867) Hybrid reading wrong because of disordered commits

[ https://issues.apache.org/jira/browse/FLINK-26867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-26867: Assignee: Jingsong Lee > Hybrid reading wrong because of disordered commits >

[jira] [Created] (FLINK-26867) Hybrid reading wrong because of disordered commits

Jingsong Lee created FLINK-26867: Summary: Hybrid reading wrong because of disordered commits Key: FLINK-26867 URL: https://issues.apache.org/jira/browse/FLINK-26867 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on pull request #19232: [FLINK-26075][table-api][table-planner] Persist and use node configuration

flinkbot edited a comment on pull request #19232: URL: https://github.com/apache/flink/pull/19232#issuecomment-1077672438 ## CI report: * 0a06035b23ab6d7af82f159bc2aff52dd816364a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18928: [FLINK-25545][flink-clients][JUnit5 Migration] Module: flink-clients.

flinkbot edited a comment on pull request #18928: URL: https://github.com/apache/flink/pull/18928#issuecomment-1054170977 ## CI report: * 8bcb1d79c8e40b528b2139f74a007e23af1b900d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19232: [FLINK-26075][table-api][table-planner] Persist and use node configuration

flinkbot edited a comment on pull request #19232: URL: https://github.com/apache/flink/pull/19232#issuecomment-1077672438 ## CI report: * 0a06035b23ab6d7af82f159bc2aff52dd816364a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18928: [FLINK-25545][flink-clients][JUnit5 Migration] Module: flink-clients.

flinkbot edited a comment on pull request #18928: URL: https://github.com/apache/flink/pull/18928#issuecomment-1054170977 ## CI report: * 48c56a018569eb7d16fb2505facbf4ab6aa8c2ea Azure:

[jira] [Updated] (FLINK-26861) Log cannot be printed completely when use System.exit(1)

[ https://issues.apache.org/jira/browse/FLINK-26861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chenzihao updated FLINK-26861: -- Affects Version/s: 1.14.0 > Log cannot be printed completely when use System.exit(1) >

[jira] [Created] (FLINK-26866) Expired cert during Helm installation

Matyas Orhidi created FLINK-26866: - Summary: Expired cert during Helm installation Key: FLINK-26866 URL: https://issues.apache.org/jira/browse/FLINK-26866 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #19232: [FLINK-26075][table-api][table-planner] Persist and use node configuration

flinkbot edited a comment on pull request #19232: URL: https://github.com/apache/flink/pull/19232#issuecomment-1077672438 ## CI report: * a91646387a89ad9e6d96863f96484d5e63aad956 Azure:

[GitHub] [flink] matriv commented on a change in pull request #19232: [FLINK-26075][table-api][table-planner] Persist and use node configuration

matriv commented on a change in pull request #19232: URL: https://github.com/apache/flink/pull/19232#discussion_r835086867 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/utils/ExecNodeMetadataUtilTest.java ## @@ -218,7 +331,11

[jira] [Commented] (FLINK-26861) Log cannot be printed completely when use System.exit(1)

[ https://issues.apache.org/jira/browse/FLINK-26861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17512323#comment-17512323 ] chenzihao commented on FLINK-26861: --- Hi, [~martijnvisser]. I have verified this question in 1.14.0.

[GitHub] [flink] flinkbot edited a comment on pull request #19229: [FLINK-26738]Mark StateDescriptor#defaultValue as deprecated and add doc

flinkbot edited a comment on pull request #19229: URL: https://github.com/apache/flink/pull/19229#issuecomment-1077649038 ## CI report: * a87b016e0ba290b34d3da913b98f92e6ee03a61e Azure:

  1   2   3   >