1996fanrui commented on PR #929:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/929#issuecomment-2611886843
> @1996fanrui It appears that MySQL/Postgresql DB restart test cases are
failing in CI with SQLTransientException. Let me update the test to ignore
transient exception
flinkbot commented on PR #26072:
URL: https://github.com/apache/flink/pull/26072#issuecomment-2611881194
## CI report:
* 89f40c939201038d90920cc1eb6625eebd3497a9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Zakelly commented on code in PR #26071:
URL: https://github.com/apache/flink/pull/26071#discussion_r1928267593
##
flink-runtime/src/main/java/org/apache/flink/streaming/api/operators/sorted/state/BatchExecutionInternalTimeServiceManager.java:
##
@@ -102,14 +113,25 @@ public stat
[
https://issues.apache.org/jira/browse/FLINK-37067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-37067:
---
Description:
In Flink 2.0, we have introduce DataStream API V2. To verify this feature, you
should
[
https://issues.apache.org/jira/browse/FLINK-37067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916582#comment-17916582
]
xuhuang edited comment on FLINK-37067 at 1/24/25 7:38 AM:
--
In F
fredia commented on code in PR #26071:
URL: https://github.com/apache/flink/pull/26071#discussion_r1928241237
##
flink-runtime/src/main/java/org/apache/flink/streaming/api/operators/sorted/state/BatchExecutionInternalTimeServiceManager.java:
##
@@ -102,14 +113,25 @@ public stati
Zakelly commented on code in PR #26035:
URL: https://github.com/apache/flink/pull/26035#discussion_r1928236747
##
flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/table/KeyedStateReader.java:
##
@@ -0,0 +1,362 @@
+/*
+ * Licensed to the Apache Soft
[
https://issues.apache.org/jira/browse/FLINK-37067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916582#comment-17916582
]
xuhuang edited comment on FLINK-37067 at 1/24/25 7:37 AM:
--
In F
[
https://issues.apache.org/jira/browse/FLINK-37148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-37148:
---
Component/s: Documentation
> Add documentation for datastream v2 api
> -
[
https://issues.apache.org/jira/browse/FLINK-37148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo resolved FLINK-37148.
Fix Version/s: 2.0.0
2.1.0
Resolution: Fixed
master(2.1.0) via ffd37cd8.
[
https://issues.apache.org/jira/browse/FLINK-36905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo resolved FLINK-36905.
Fix Version/s: 2.0.0
2.1.0
Assignee: Zhanghao Chen
Resolution: R
[
https://issues.apache.org/jira/browse/FLINK-37212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37212:
---
Labels: pull-request-available (was: )
> When hbase region move, throw "Unable to load exc
X-czh closed pull request #26074: [FLINK-36905][doc][BP] Update Chinese doc on
serialization to reflect the latest changes in Flink 2.0
URL: https://github.com/apache/flink/pull/26074
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitH
[
https://issues.apache.org/jira/browse/FLINK-36905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916612#comment-17916612
]
Weijie Guo edited comment on FLINK-36905 at 1/24/25 6:54 AM:
-
X-czh opened a new pull request, #26074:
URL: https://github.com/apache/flink/pull/26074
(cherry picked from commit 35865953e66167eb1074e2a2343ce4fb59386a37)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
[
https://issues.apache.org/jira/browse/FLINK-36905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916612#comment-17916612
]
Weijie Guo commented on FLINK-36905:
master(2.1) via 35865953e66167eb1074e2a2343ce4f
reswqa merged PR #26010:
URL: https://github.com/apache/flink/pull/26010
--
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
[
https://issues.apache.org/jira/browse/FLINK-37187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37187:
---
Labels: pull-request-available (was: )
> Add doc for Submitting Refresh Job of Materialized
boring-cyborg[bot] commented on PR #55:
URL:
https://github.com/apache/flink-connector-hbase/pull/55#issuecomment-2611717663
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is a
hackergin opened a new pull request, #26073:
URL: https://github.com/apache/flink/pull/26073
## What is the purpose of the change
*Add doc for Submitting Refresh Job of Materialized Table to Yarn/K8s*
## Brief change log
- *Add doc for Submitting Refresh Job of Mate
chunji96 opened a new pull request, #55:
URL: https://github.com/apache/flink-connector-hbase/pull/55
When Hbase Region move , will cause ' Unable to load exception received from
:xxx'. detail can see :
[FLINK-37212](https://issues.apache.org/jira/browse/FLINK-37212?jql=project%20%3D%20FLIN
JunRuiLee merged PR #26061:
URL: https://github.com/apache/flink/pull/26061
--
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.apa
reswqa merged PR #26057:
URL: https://github.com/apache/flink/pull/26057
--
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
Zakelly commented on PR #26071:
URL: https://github.com/apache/flink/pull/26071#issuecomment-2611705001
Thanks @codenohup !
--
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.
[
https://issues.apache.org/jira/browse/FLINK-37196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo resolved FLINK-37196.
Fix Version/s: 2.0.0
2.1.0
Resolution: Fixed
> Build documentation githu
[
https://issues.apache.org/jira/browse/FLINK-37196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916607#comment-17916607
]
Weijie Guo commented on FLINK-37196:
master(2.1): 479fb42f9444cf0c78b185e67949a5cc0c
[
https://issues.apache.org/jira/browse/FLINK-37212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jonasjc updated FLINK-37212:
Summary: When hbase region move, throw "Unable to load exception received
from server: XXX" (was: Hbase
[
https://issues.apache.org/jira/browse/FLINK-37218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-37218:
---
Component/s: Runtime / Network
> Avoid repeatedly reading the broadcast buffer from the sort-merge s
[
https://issues.apache.org/jira/browse/FLINK-37218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-37218:
---
Affects Version/s: 2.0.0
2.1.0
> Avoid repeatedly reading the broadcast buffe
sharath1709 commented on PR #929:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/929#issuecomment-2611698113
@1996fanrui It appears that MySQL/Postgresql DB restart test cases are
failing in CI with SQLTransientException. Let me update the test to ignore
transient exception
flinkbot commented on PR #26071:
URL: https://github.com/apache/flink/pull/26071#issuecomment-2611695877
## CI report:
* 19c8feeffed263473fa373c5e4a36e2bcc39dc99 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
ChaomingZhangCN commented on PR #3887:
URL: https://github.com/apache/flink-cdc/pull/3887#issuecomment-2611679804
@lvyanquan @leonardBang PTAL.
--
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
1996fanrui commented on PR #929:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/929#issuecomment-2611689010
> I addressed the remaining comments and added a test case for db restart to
`AbstractJdbcStateInteractorITCase`. The same could be added to
`AbstractJdbcEventInteract
bvarghese1 commented on code in PR #25753:
URL: https://github.com/apache/flink/pull/25753#discussion_r1928127583
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,482 @@
+/*
+ * L
bvarghese1 commented on code in PR #25753:
URL: https://github.com/apache/flink/pull/25753#discussion_r1928138032
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,591 @@
+/*
+ * L
bvarghese1 commented on code in PR #25753:
URL: https://github.com/apache/flink/pull/25753#discussion_r1928137538
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,482 @@
+/*
+ * L
ChaomingZhangCN commented on PR #3893:
URL: https://github.com/apache/flink-cdc/pull/3893#issuecomment-2611680202
@lvyanquan @leonardBang PTAL.
--
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
[
https://issues.apache.org/jira/browse/FLINK-37067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-37067:
---
Description:
In Flink 2.0, we have introduce DataStream API V2. To verify this feature, you
should
bvarghese1 commented on code in PR #25753:
URL: https://github.com/apache/flink/pull/25753#discussion_r1928136852
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,591 @@
+/*
+ * L
bvarghese1 commented on code in PR #25753:
URL: https://github.com/apache/flink/pull/25753#discussion_r1928136710
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,591 @@
+/*
+ * L
bvarghese1 commented on code in PR #25753:
URL: https://github.com/apache/flink/pull/25753#discussion_r1928136028
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,591 @@
+/*
+ * L
ChaomingZhangCN commented on PR #3883:
URL: https://github.com/apache/flink-cdc/pull/3883#issuecomment-2611679436
@lvyanquan @leonardBang PTAL.
--
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
bvarghese1 commented on code in PR #25753:
URL: https://github.com/apache/flink/pull/25753#discussion_r1928135793
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,591 @@
+/*
+ * L
[
https://issues.apache.org/jira/browse/FLINK-37218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37218:
---
Labels: pull-request-available (was: )
> Avoid repeatedly reading the broadcast buffer from
bvarghese1 commented on code in PR #25753:
URL: https://github.com/apache/flink/pull/25753#discussion_r1928135183
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,591 @@
+/*
+ * L
JunRuiLee opened a new pull request, #26072:
URL: https://github.com/apache/flink/pull/26072
## What is the purpose of the change
[FLINK-37218][network] Avoid repeatedly reading the broadcast buffer from
the sort-merge shuffle data file while accumulating small buffers fro
bvarghese1 commented on code in PR #25753:
URL: https://github.com/apache/flink/pull/25753#discussion_r1928134831
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,591 @@
+/*
+ * L
[
https://issues.apache.org/jira/browse/FLINK-37049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-37049:
--
Assignee: (was: xuhuang)
> Cross-team verification for "Remove all Scala APIs"
>
[
https://issues.apache.org/jira/browse/FLINK-37047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-37047:
--
Assignee: (was: xuhuang)
> Cross-team verification for "Remove DataSet API"
> ---
[
https://issues.apache.org/jira/browse/FLINK-37048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-37048:
--
Assignee: (was: xuhuang)
> Cross-team verification for "Remove Deprecated methods/fields/
[
https://issues.apache.org/jira/browse/FLINK-37067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-37067:
--
Assignee: (was: xuhuang)
> Cross-team verification for “Introduce DataStream API V2”
> --
[
https://issues.apache.org/jira/browse/FLINK-37049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-37049:
---
Description:
In Flink 2.0, we have removed all Scala APIs except for the Table APIs. To
confirm thi
[
https://issues.apache.org/jira/browse/FLINK-37048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-37048:
---
Description:
In Flink 2.0, we have removed deprecated methods/fields/classes in DataStream
API. To
[
https://issues.apache.org/jira/browse/FLINK-37047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-37047:
---
Description:
In Flink 2.0, we have removed all DataSet API. To confirm this change, please
follow t
bvarghese1 commented on code in PR #25753:
URL: https://github.com/apache/flink/pull/25753#discussion_r1928134386
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,591 @@
+/*
+ * L
bvarghese1 commented on code in PR #25753:
URL: https://github.com/apache/flink/pull/25753#discussion_r1928126475
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,482 @@
+/*
+ * L
[
https://issues.apache.org/jira/browse/FLINK-37067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-37067:
---
Description:
In Flink 2.0, we have introduce DataStream API V2. To verify this feature, you
should
bvarghese1 commented on code in PR #25753:
URL: https://github.com/apache/flink/pull/25753#discussion_r1928133258
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,482 @@
+/*
+ * L
bvarghese1 commented on code in PR #25753:
URL: https://github.com/apache/flink/pull/25753#discussion_r1928132811
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,482 @@
+/*
+ * L
bvarghese1 commented on code in PR #25753:
URL: https://github.com/apache/flink/pull/25753#discussion_r1928131810
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,482 @@
+/*
+ * L
bvarghese1 commented on code in PR #25753:
URL: https://github.com/apache/flink/pull/25753#discussion_r1928131539
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,482 @@
+/*
+ * L
bvarghese1 commented on code in PR #25753:
URL: https://github.com/apache/flink/pull/25753#discussion_r1928131044
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,482 @@
+/*
+ * L
Junrui Lee created FLINK-37218:
--
Summary: Avoid repeatedly reading the broadcast buffer from the
sort-merge shuffle data file while accumulating small buffers from multiple
sub-partitions.
Key: FLINK-37218
URL: http
[
https://issues.apache.org/jira/browse/FLINK-37212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jonasjc updated FLINK-37212:
Summary: Hbase connector "Unable to load exception received from server:
XXX" (was: Hbase connector "Unab
bvarghese1 commented on code in PR #25753:
URL: https://github.com/apache/flink/pull/25753#discussion_r1928130617
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,482 @@
+/*
+ * L
bvarghese1 commented on code in PR #25753:
URL: https://github.com/apache/flink/pull/25753#discussion_r1928130188
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,482 @@
+/*
+ * L
bvarghese1 commented on code in PR #25753:
URL: https://github.com/apache/flink/pull/25753#discussion_r1928129854
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,482 @@
+/*
+ * L
bvarghese1 commented on code in PR #25753:
URL: https://github.com/apache/flink/pull/25753#discussion_r1928129417
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,482 @@
+/*
+ * L
bvarghese1 commented on code in PR #25753:
URL: https://github.com/apache/flink/pull/25753#discussion_r1928129091
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,482 @@
+/*
+ * L
bvarghese1 commented on code in PR #25753:
URL: https://github.com/apache/flink/pull/25753#discussion_r1928128199
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,482 @@
+/*
+ * L
[
https://issues.apache.org/jira/browse/FLINK-37203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37203:
---
Labels: pull-request-available (was: )
> Support AltertableCommentEvent and AlterColumnComm
bvarghese1 commented on code in PR #25753:
URL: https://github.com/apache/flink/pull/25753#discussion_r1928128562
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,482 @@
+/*
+ * L
bvarghese1 commented on code in PR #25753:
URL: https://github.com/apache/flink/pull/25753#discussion_r1928127870
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,482 @@
+/*
+ * L
bvarghese1 commented on code in PR #25753:
URL: https://github.com/apache/flink/pull/25753#discussion_r1928127022
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,482 @@
+/*
+ * L
bvarghese1 commented on code in PR #25753:
URL: https://github.com/apache/flink/pull/25753#discussion_r1928126755
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,482 @@
+/*
+ * L
bvarghese1 commented on code in PR #25753:
URL: https://github.com/apache/flink/pull/25753#discussion_r1928125261
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,591 @@
+/*
+ * L
bvarghese1 commented on code in PR #25753:
URL: https://github.com/apache/flink/pull/25753#discussion_r1928126027
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,482 @@
+/*
+ * L
flinkbot commented on PR #26068:
URL: https://github.com/apache/flink/pull/26068#issuecomment-2611600477
## CI report:
* 3065b327dad0ca451190e0e7c501744526e72b48 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Zakelly commented on code in PR #26071:
URL: https://github.com/apache/flink/pull/26071#discussion_r1928083858
##
flink-runtime/src/main/java/org/apache/flink/streaming/api/operators/sorted/state/BatchExecutionInternalTimeServiceWithAsyncState.java:
##
@@ -0,0 +1,85 @@
+/*
+ * L
Zakelly commented on PR #26071:
URL: https://github.com/apache/flink/pull/26071#issuecomment-2611596328
@fredia @codenohup Would you please take a look?
--
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
[
https://issues.apache.org/jira/browse/FLINK-37206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37206:
---
Labels: pull-request-available (was: )
> Initialization issue of batching timer service in
Zakelly opened a new pull request, #26071:
URL: https://github.com/apache/flink/pull/26071
## What is the purpose of the change
We have ship two abstract stream operators for async state processing, where
a async timer service (manager) is introduced. Actually these operators can run
[
https://issues.apache.org/jira/browse/FLINK-37181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-37181.
--
Fix Version/s: 2.0.0
Resolution: Fixed
merged to master d95f0567c57f375719cba012df74669b921998d
gyfora merged PR #26034:
URL: https://github.com/apache/flink/pull/26034
--
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
[
https://issues.apache.org/jira/browse/FLINK-37067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916582#comment-17916582
]
xuhuang commented on FLINK-37067:
-
In Flink 2.0, we have introduce DataStream API V2. To
[
https://issues.apache.org/jira/browse/FLINK-37047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916578#comment-17916578
]
xuhuang commented on FLINK-37047:
-
In Flink 2.0, we have removed all DataSet API. To con
[
https://issues.apache.org/jira/browse/FLINK-37048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916577#comment-17916577
]
xuhuang commented on FLINK-37048:
-
In Flink 2.0, we have removed deprecated methods/fiel
[
https://issues.apache.org/jira/browse/FLINK-37049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916576#comment-17916576
]
xuhuang commented on FLINK-37049:
-
In Flink 2.0, we have removed all Scala APIs except f
Jam804 commented on PR #26039:
URL: https://github.com/apache/flink/pull/26039#issuecomment-2611494493
PTAL, Please @reswqa
--
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.
reswqa merged PR #26070:
URL: https://github.com/apache/flink/pull/26070
--
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
Jam804 commented on PR #26039:
URL: https://github.com/apache/flink/pull/26039#issuecomment-2611481984
I think there's nothing wrong with my code now. Thank you for your guidance
@davidradl
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
reswqa opened a new pull request, #26070:
URL: https://github.com/apache/flink/pull/26070
Fix the build issue:
https://github.com/apache/flink/actions/runs/12942648074/job/36100724287#step:5:3199
--
This is an automated message from the Apache Git Service.
To respond to the message, pleas
[
https://issues.apache.org/jira/browse/FLINK-37196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-37196:
--
Assignee: Weijie Guo (was: xuhuang)
> Build documentation github action can't work
> ---
[
https://issues.apache.org/jira/browse/FLINK-37196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-37196:
--
Assignee: xuhuang
> Build documentation github action can't work
> --
[
https://issues.apache.org/jira/browse/FLINK-37212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jonasjc updated FLINK-37212:
Description:
*Problem:*
when hbase region move,hbase connector throw the following exception:
{code:java}
[
https://issues.apache.org/jira/browse/FLINK-37212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jonasjc updated FLINK-37212:
Description:
*Problem:*
when hbase region move,hbase connector throw the following exception:
{code:java}
reswqa merged PR #26069:
URL: https://github.com/apache/flink/pull/26069
--
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
[
https://issues.apache.org/jira/browse/FLINK-37196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37196:
---
Labels: pull-request-available (was: )
> Build documentation github action can't work
> ---
reswqa opened a new pull request, #26069:
URL: https://github.com/apache/flink/pull/26069
## What is the purpose of the change
*Fix the build documentation pipeline issue*
Use `cp` to replace `rsync` for local docs coping.
If we persist in using rsync, should update
[
https://issues.apache.org/jira/browse/FLINK-37217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37217:
---
Labels: pull-request-available (was: )
> In `MySqlErrorHandler` TableNotFoundException Una
1 - 100 of 213 matches
Mail list logo
