[
https://issues.apache.org/jira/browse/FLINK-32561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741871#comment-17741871
]
Xin Hao commented on FLINK-32561:
-
Agreed~
> Change the status field reconciliationTime
reswqa commented on code in PR #22960:
URL: https://github.com/apache/flink/pull/22960#discussion_r1259243213
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/TieredStorageMemoryManagerImpl.java:
##
@@ -200,6 +201,20 @@ public in
[
https://issues.apache.org/jira/browse/FLINK-32561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741865#comment-17741865
]
Gyula Fora commented on FLINK-32561:
We can only change it if we can make it non-bre
[
https://issues.apache.org/jira/browse/FLINK-29230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741864#comment-17741864
]
Guillaume Vauvert commented on FLINK-29230:
---
The corresponding blogpost is
ht
[
https://issues.apache.org/jira/browse/FLINK-32572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32572:
---
Labels: pull-request-available (was: )
> Do not collect metrics or scale finished job verti
gyfora opened a new pull request, #628:
URL: https://github.com/apache/flink-kubernetes-operator/pull/628
## What is the purpose of the change
Improve the autoscaler metric collection logic to be aware of finished
vertices and do not collect metrics from them. Simplify topology handli
Tartarus0zm commented on PR #22839:
URL: https://github.com/apache/flink/pull/22839#issuecomment-1630171905
@luoyuxia hi, the test is pass, 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 t
[
https://issues.apache.org/jira/browse/FLINK-32021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang closed FLINK-32021.
-
> Improvement the Javadoc for SpecifiedOffsetsInitializer and
> TimestampOffsetsInitializer.
>
masteryhx commented on code in PR #21835:
URL: https://github.com/apache/flink/pull/21835#discussion_r1259127175
##
flink-core/src/main/java/org/apache/flink/api/common/state/StateTtlConfig.java:
##
@@ -433,6 +461,13 @@ public static class RocksdbCompactFilterCleanupStrategy
hackergin commented on code in PR #22928:
URL: https://github.com/apache/flink/pull/22928#discussion_r1259115657
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/DefaultCatalogTable.java:
##
@@ -40,15 +40,27 @@ public class DefaultCatalogTable imple
[
https://issues.apache.org/jira/browse/FLINK-32021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-32021.
Resolution: Fixed
Resolved in flink-connector-kafka(main):
14d8462be33c25031e94da0635105f69bb8076
leonardBang merged PR #29:
URL: https://github.com/apache/flink-connector-kafka/pull/29
--
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.
[
https://issues.apache.org/jira/browse/FLINK-32523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741813#comment-17741813
]
Wencong Liu commented on FLINK-32523:
-
I think we should remove @Test(timeout = TEST
[
https://issues.apache.org/jira/browse/FLINK-32193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan updated FLINK-32193:
--
Affects Version/s: aws-connector-4.2.0
> AWS connector removes the dependency on flink-shaded
> --
[
https://issues.apache.org/jira/browse/FLINK-32193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan updated FLINK-32193:
--
Fix Version/s: (was: aws-connector-4.2.0)
> AWS connector removes the dependency on flink-shaded
>
[
https://issues.apache.org/jira/browse/FLINK-32567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
宇宙先生 closed FLINK-32567.
Resolution: Fixed
> when Flink write azure data lake storage,error occur
> ---
luoyuxia commented on code in PR #22839:
URL: https://github.com/apache/flink/pull/22839#discussion_r1259063263
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/StagedSinkModifyOperation.java:
##
@@ -0,0 +1,88 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-32573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yongping Li updated FLINK-32573:
Description:
The page url is
https://nightlies.apache.org/flink/flink-docs-master/zh/docs/dev/dat
Yongping Li created FLINK-32573:
---
Summary: Translate "Custom Serialization for Managed State" page
into Chinese
Key: FLINK-32573
URL: https://issues.apache.org/jira/browse/FLINK-32573
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-32443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741791#comment-17741791
]
YongpingLi commented on FLINK-32443:
Hi,Can you assign this Issue to me as a newcome
hanyuzheng7 commented on PR #22842:
URL: https://github.com/apache/flink/pull/22842#issuecomment-1629714547
@snuyanzin support support varargs now
--
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
Gyula Fora created FLINK-32572:
--
Summary: Do not collect metrics or scale finished job vertices
Key: FLINK-32572
URL: https://issues.apache.org/jira/browse/FLINK-32572
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-30349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741748#comment-17741748
]
Martijn Visser commented on FLINK-30349:
[~ferenc-csaky] [~chesnay] For my info,
[
https://issues.apache.org/jira/browse/FLINK-32529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-32529.
--
Resolution: Fixed
merged to main 5ebfc5e4a6c31ea0c212f187bf7f7de70dfd1c09
> Optional startup probe fo
gyfora merged PR #625:
URL: https://github.com/apache/flink-kubernetes-operator/pull/625
--
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
[
https://issues.apache.org/jira/browse/FLINK-32527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-32527.
--
Resolution: Fixed
merged to main f21426201842b5df3c9a4f13ce41973d2ae67430
> Build failure on Windows
gyfora commented on PR #627:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/627#issuecomment-1629582915
```
mvn clean install -DskipTests -Pgenerate-docs
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHu
[
https://issues.apache.org/jira/browse/FLINK-32466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-32466.
Fix Version/s: 1.18.0
Resolution: Fixed
Merged to master: 4cf2124d71a8dd0595e40f07c2dbcc4c8
twalthr closed pull request #22892: [FLINK-32466] Replace STRING with CHARACTER
for functions that don't support binary strings
URL: https://github.com/apache/flink/pull/22892
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
[
https://issues.apache.org/jira/browse/FLINK-32570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741693#comment-17741693
]
Chesnay Schepler commented on FLINK-32570:
--
Go ahead.
> Deprecate API that use
[
https://issues.apache.org/jira/browse/FLINK-32571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741675#comment-17741675
]
Chesnay Schepler commented on FLINK-32571:
--
??the only parameter is the HBase v
zentol closed pull request #5: [FLINK-30349] Sync missing HBase e2e tests to
external repo
URL: https://github.com/apache/flink-connector-hbase/pull/5
--
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
zentol commented on code in PR #12:
URL:
https://github.com/apache/flink-connector-hbase/pull/12#discussion_r1258481903
##
flink-connector-hbase-e2e-tests/src/main/java/org/apache/flink/streaming/tests/HBaseContainer.java:
##
@@ -0,0 +1,110 @@
+/*
+ * Licensed to the Apache Sof
Chesnay Schepler created FLINK-32571:
Summary: Prebuild HBase testing docker image
Key: FLINK-32571
URL: https://issues.apache.org/jira/browse/FLINK-32571
Project: Flink
Issue Type: Techn
[
https://issues.apache.org/jira/browse/FLINK-30349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-30349.
Fix Version/s: hbase-3.0.0
Resolution: Fixed
main: 8fda39b1e81f63c3db1be2295fb3efee
zentol commented on code in PR #12:
URL:
https://github.com/apache/flink-connector-hbase/pull/12#discussion_r1258479693
##
flink-connector-hbase-e2e-tests/src/main/java/org/apache/flink/streaming/tests/HBaseContainer.java:
##
@@ -0,0 +1,110 @@
+/*
+ * Licensed to the Apache Sof
[
https://issues.apache.org/jira/browse/FLINK-32241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741662#comment-17741662
]
Alexis Sarda-Espinosa edited comment on FLINK-32241 at 7/10/23 3:45 PM:
--
flinkbot commented on PR #22978:
URL: https://github.com/apache/flink/pull/22978#issuecomment-1629218303
## CI report:
* 111317089a49e9ca34f6540e1e9f586d20caae66 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
swuferhong commented on PR #22978:
URL: https://github.com/apache/flink/pull/22978#issuecomment-1629205639
Hi, @lincoln-lil. Can you help review this PR? Thank you!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
[
https://issues.apache.org/jira/browse/FLINK-32456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32456:
---
Labels: pull-request-available (was: )
> JSON_OBJECTAGG & JSON_ARRAYAGG cannot be used with
swuferhong opened a new pull request, #22978:
URL: https://github.com/apache/flink/pull/22978
## What is the purpose of the change
This pr is aims to support JSON_OBJECTAGG & JSON_ARRAYAGG use with other
aggregate functions.
## Brief change log
- Modify WrapJsonAggFu
[
https://issues.apache.org/jira/browse/FLINK-32241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741662#comment-17741662
]
Alexis Sarda-Espinosa edited comment on FLINK-32241 at 7/10/23 3:27 PM:
--
flinkbot commented on PR #22977:
URL: https://github.com/apache/flink/pull/22977#issuecomment-1629183506
## CI report:
* aef7c958ecd9aae5df4609d71491af2737271422 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741662#comment-17741662
]
Alexis Sarda-Espinosa commented on FLINK-32241:
---
[I am seeing this same is
[
https://issues.apache.org/jira/browse/FLINK-32569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32569:
---
Labels: pull-request-available (was: )
> Fix the incomplete serialization of ResolvedCatalo
hackergin opened a new pull request, #22977:
URL: https://github.com/apache/flink/pull/22977
## What is the purpose of the change
Fix the incomplete serialization of ResolvedCatalogTable caused by the newly
introduced time travel interface
In order to implement time
[
https://issues.apache.org/jira/browse/FLINK-32570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741648#comment-17741648
]
Matthias Pohl commented on FLINK-32570:
---
[~chesnay] any objections against me pick
[
https://issues.apache.org/jira/browse/FLINK-32568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741645#comment-17741645
]
Rui Fan commented on FLINK-32568:
-
Merged via 2a6e8ae (master, 1.18)
> Ensure that all
[
https://issues.apache.org/jira/browse/FLINK-32568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-32568.
-
Fix Version/s: 1.18.0
Resolution: Fixed
> Ensure that all subtasks are sorted by busy ratio at th
1996fanrui merged PR #22974:
URL: https://github.com/apache/flink/pull/22974
--
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
[
https://issues.apache.org/jira/browse/FLINK-32513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vladislav Keda updated FLINK-32513:
---
Attachment: (was: image-2023-07-10-17-23-30-472.png)
> Job in BATCH mode with a signific
[
https://issues.apache.org/jira/browse/FLINK-29319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin closed FLINK-29319.
---
> Upgrade Calcite version to 1.32
> ---
>
> Key: FLI
[
https://issues.apache.org/jira/browse/FLINK-29319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741641#comment-17741641
]
Sergey Nuyanzin commented on FLINK-29319:
-
Merged to master
[c942d0f61a044a327f
[
https://issues.apache.org/jira/browse/FLINK-29319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-29319.
-
Fix Version/s: 1.18.0
Resolution: Fixed
> Upgrade Calcite version to 1.32
> -
[
https://issues.apache.org/jira/browse/FLINK-32513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741639#comment-17741639
]
Vladislav Keda commented on FLINK-32513:
Hi [~huwh] , this job is automatically
[
https://issues.apache.org/jira/browse/FLINK-32513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vladislav Keda updated FLINK-32513:
---
Attachment: image-2023-07-10-17-26-46-544.png
> Job in BATCH mode with a significant number
[
https://issues.apache.org/jira/browse/FLINK-32513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vladislav Keda updated FLINK-32513:
---
Attachment: image-2023-07-10-17-23-30-472.png
> Job in BATCH mode with a significant number
flinkbot commented on PR #22976:
URL: https://github.com/apache/flink/pull/22976#issuecomment-1629072311
## CI report:
* b0f1e65c995771dd3a5b8028b07e6175b9731b7a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
lincoln-lil opened a new pull request, #22976:
URL: https://github.com/apache/flink/pull/22976
This is a backport pr of FLINK-32457's subtask-1
--
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-32570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-32570:
--
Priority: Blocker (was: Major)
> Deprecate API that uses Flink's Time implementation (related
[
https://issues.apache.org/jira/browse/FLINK-32570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-32570:
--
Fix Version/s: 1.18.0
> Deprecate API that uses Flink's Time implementation (related to FLINK-
Matthias Pohl created FLINK-32570:
-
Summary: Deprecate API that uses Flink's Time implementation
(related to FLINK-14638)
Key: FLINK-32570
URL: https://issues.apache.org/jira/browse/FLINK-32570
Projec
ferenc-csaky commented on code in PR #12:
URL:
https://github.com/apache/flink-connector-hbase/pull/12#discussion_r1258295870
##
flink-connector-hbase-e2e-tests/src/main/java/org/apache/flink/streaming/tests/HBaseContainer.java:
##
@@ -0,0 +1,110 @@
+/*
+ * Licensed to the Apac
[
https://issues.apache.org/jira/browse/FLINK-32527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-32527:
--
Assignee: Fangbin Sun
> Build failure on Windows
>
>
>
gyfora commented on code in PR #625:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/625#discussion_r1258236992
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/utils/FlinkUtilsTest.java:
##
@@ -86,6 +89,43 @@ public void testMergePo
gyfora commented on code in PR #620:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/620#discussion_r1258231715
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkResourceExceptionUtils.java:
##
@@ -129,26 +144,56 @@ public
zentol commented on code in PR #12:
URL:
https://github.com/apache/flink-connector-hbase/pull/12#discussion_r1258227391
##
flink-connector-hbase-e2e-tests/src/main/java/org/apache/flink/streaming/tests/HBaseContainer.java:
##
@@ -0,0 +1,110 @@
+/*
+ * Licensed to the Apache Sof
flinkbot commented on PR #22975:
URL: https://github.com/apache/flink/pull/22975#issuecomment-1628902190
## CI report:
* 3c34fdf736b934951415b6282ee7cbb69f205e4f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
WencongLiu opened a new pull request, #22975:
URL: https://github.com/apache/flink/pull/22975
## What is the purpose of the change
*Introduce the configurations for tiered storage*
## Brief change log
- *Introduce the configurations for tiered storage.*
[
https://issues.apache.org/jira/browse/FLINK-32556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-32556.
---
Fix Version/s: 1.18.0
Resolution: Fixed
master: 773feebbb2426ab1a8f7684f59b9a73db8f6a
[
https://issues.apache.org/jira/browse/FLINK-26522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-26522.
---
Fix Version/s: 1.18.0
Resolution: Fixed
> FLIP-285: Refactoring code for multiple com
TanYuxin-tyx commented on code in PR #22960:
URL: https://github.com/apache/flink/pull/22960#discussion_r1258205255
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/TieredStorageMemoryManagerImpl.java:
##
@@ -200,6 +202,22 @@ pub
luoyuxia commented on code in PR #22839:
URL: https://github.com/apache/flink/pull/22839#discussion_r1258138669
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java:
##
@@ -849,6 +858,56 @@ private ModifyOperation
getOp
[
https://issues.apache.org/jira/browse/FLINK-32376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang updated FLINK-32376:
---
Fix Version/s: 1.18.0
> [FLIP-287] Extend Sink#InitContext to expose TypeSerializer, ObjectReuse and
[
https://issues.apache.org/jira/browse/FLINK-32376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang closed FLINK-32376.
--
Resolution: Done
> [FLIP-287] Extend Sink#InitContext to expose TypeSerializer, ObjectReuse and
> Job
[
https://issues.apache.org/jira/browse/FLINK-32376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang reassigned FLINK-32376:
--
Assignee: João Boto
> [FLIP-287] Extend Sink#InitContext to expose TypeSerializer, ObjectReus
[
https://issues.apache.org/jira/browse/FLINK-32376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741596#comment-17741596
]
Lijie Wang commented on FLINK-32376:
Done via:
master(1.18): 4f5b2fb5736f5a1c098a7dc
wanglijie95 closed pull request #22840: [FLINK-32376] Extend Sink#InitContext
URL: https://github.com/apache/flink/pull/22840
--
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
[
https://issues.apache.org/jira/browse/FLINK-24024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin reassigned FLINK-24024:
---
Assignee: Sergey Nuyanzin (was: Jing Zhang)
> Support session Window TVF
> --
[
https://issues.apache.org/jira/browse/FLINK-24024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741591#comment-17741591
]
Sergey Nuyanzin commented on FLINK-24024:
-
Thanks for the response [~jingzhang]
[
https://issues.apache.org/jira/browse/FLINK-32457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee resolved FLINK-32457.
-
Resolution: Fixed
fixed in master: b4faca57038897230372458d10d14f09c2f33d4d
> update current do
[
https://issues.apache.org/jira/browse/FLINK-32457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-32457:
Fix Version/s: 1.17.2
> update current documentation of JSON_OBJECTAGG/JSON_ARRAYAGG to clarify th
lincoln-lil merged PR #22972:
URL: https://github.com/apache/flink/pull/22972
--
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.a
xintongsong commented on code in PR #22960:
URL: https://github.com/apache/flink/pull/22960#discussion_r1258144552
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/TieredStorageMemoryManagerImpl.java:
##
@@ -276,6 +294,13 @@ priv
ferenc-csaky commented on code in PR #12:
URL:
https://github.com/apache/flink-connector-hbase/pull/12#discussion_r1258130085
##
flink-connector-hbase-e2e-tests/src/main/java/org/apache/flink/streaming/tests/HBaseContainer.java:
##
@@ -0,0 +1,110 @@
+/*
+ * Licensed to the Apac
ferenc-csaky commented on code in PR #12:
URL:
https://github.com/apache/flink-connector-hbase/pull/12#discussion_r1258130085
##
flink-connector-hbase-e2e-tests/src/main/java/org/apache/flink/streaming/tests/HBaseContainer.java:
##
@@ -0,0 +1,110 @@
+/*
+ * Licensed to the Apac
chucheng92 commented on PR #38:
URL:
https://github.com/apache/flink-connector-kafka/pull/38#issuecomment-1628796627
@MartijnVisser hi, Martijn. Can you help to review it?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
reswqa merged PR #22963:
URL: https://github.com/apache/flink/pull/22963
--
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
zentol commented on code in PR #12:
URL:
https://github.com/apache/flink-connector-hbase/pull/12#discussion_r1258095765
##
flink-connector-hbase-e2e-tests/src/main/java/org/apache/flink/streaming/tests/HBaseContainer.java:
##
@@ -0,0 +1,110 @@
+/*
+ * Licensed to the Apache Sof
[
https://issues.apache.org/jira/browse/FLINK-4198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-4198.
--
Resolution: Duplicate
I'm gonna close this issue as a duplicate of FLINK-14068 because we go on
[
https://issues.apache.org/jira/browse/FLINK-32569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia reassigned FLINK-32569:
Assignee: Feng Jin
> Fix the incomplete serialization of ResolvedCatalogTable caused by the newly
luoyuxia commented on code in PR #22928:
URL: https://github.com/apache/flink/pull/22928#discussion_r1258040684
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/DefaultCatalogTable.java:
##
@@ -40,15 +40,27 @@ public class DefaultCatalogTable implem
[
https://issues.apache.org/jira/browse/FLINK-32569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Feng Jin updated FLINK-32569:
-
Description: The newly added member variables in DefaultCatalogTable are
not being serialized in Catalo
[
https://issues.apache.org/jira/browse/FLINK-32569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741533#comment-17741533
]
Feng Jin commented on FLINK-32569:
--
[~luoyuxia] I would like to fix this issue, please
Feng Jin created FLINK-32569:
Summary: Fix the incomplete serialization of ResolvedCatalogTable
caused by the newly introduced time travel interface
Key: FLINK-32569
URL: https://issues.apache.org/jira/browse/FLINK-3
1996fanrui commented on PR #22974:
URL: https://github.com/apache/flink/pull/22974#issuecomment-1628651028
@WencongLiu , thanks for the quick review!
I will merge it after the CI passes.
--
This is an automated message from the Apache Git Service.
To respond to the message, please l
WencongLiu commented on PR #22974:
URL: https://github.com/apache/flink/pull/22974#issuecomment-1628605730
@1996fanrui OK, I'll 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 go
1996fanrui commented on PR #22974:
URL: https://github.com/apache/flink/pull/22974#issuecomment-1628596068
Hi @WencongLiu , would you mind help take a look in your free time? thanks~
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
TanYuxin-tyx commented on PR #22960:
URL: https://github.com/apache/flink/pull/22960#issuecomment-1628584789
@xintongsong Thanks for helping review. Based on the offline discussions, I
have updated the change. In the new PR, the above issues no longer exist
anymore. PTAL, thanks.
The
[
https://issues.apache.org/jira/browse/FLINK-32552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabio Wanner updated FLINK-32552:
-
Description:
*Context*
In the scope of end-to-end tests we deploy all the Flink session jobs we
1 - 100 of 120 matches
Mail list logo
