yuxiqian commented on code in PR #2944:
URL: https://github.com/apache/flink-cdc/pull/2944#discussion_r1639295066
##
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/schema/PhysicalColumnSerializer.java:
##
Review Comment:
Seems this is a breaking
[
https://issues.apache.org/jira/browse/FLINK-35600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Di Wu updated FLINK-35600:
--
Description:
Assume that the table has been split into 3 Chunks
Timeline
t1: chunk1 is read
t2: a piece of
1996fanrui commented on PR #24936:
URL: https://github.com/apache/flink/pull/24936#issuecomment-2167246199
> @1996fanrui @GOODBOY008 Thanks for your attention, I found that CI e2e
tests have stucked for hours, As the code is about to be frozen, could you help
cancel some tasks? For
[
https://issues.apache.org/jira/browse/FLINK-35600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35600:
---
Labels: pull-request-available (was: )
> Data read duplication during the
Di Wu created FLINK-35600:
-
Summary: Data read duplication during the full-to-incremental
conversion phase
Key: FLINK-35600
URL: https://issues.apache.org/jira/browse/FLINK-35600
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854929#comment-17854929
]
Yufan Sheng commented on FLINK-35564:
-
Hi, thanks for mention this. I think this bug has been fixed
liyubin117 commented on PR #24936:
URL: https://github.com/apache/flink/pull/24936#issuecomment-2167237003
@1996fanrui @GOODBOY008 Thanks for your attention, I found that CI e2e tests
have stucked for hours, As the code is about to be frozen, could you help
cancel some tasks? For example,
[
https://issues.apache.org/jira/browse/FLINK-35593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35593:
---
Labels: pull-request-available (was: )
> Apache Kubernetes Operator Docker image does not
anupamaggarwal opened a new pull request, #839:
URL: https://github.com/apache/flink-kubernetes-operator/pull/839
## What is the purpose of the change
Adds Apache 2 LICENSE to Apache Kubernetes Operator Docker image
## Brief change log
- Adds LICENSE file to docker stage image
liyubin117 commented on code in PR #24934:
URL: https://github.com/apache/flink/pull/24934#discussion_r1639245472
##
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/CatalogManagerTest.java:
##
@@ -367,14 +368,28 @@ void testCatalogStore() throws
liyubin117 commented on code in PR #24934:
URL: https://github.com/apache/flink/pull/24934#discussion_r1639245307
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java:
##
@@ -295,31 +295,42 @@ public DataTypeFactory
liyubin117 commented on code in PR #24934:
URL: https://github.com/apache/flink/pull/24934#discussion_r1639244971
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/SqlCreateCatalogConverter.java:
##
@@ -41,6 +43,10 @@ public
liyubin117 commented on code in PR #24934:
URL: https://github.com/apache/flink/pull/24934#discussion_r1639244453
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ddl/CreateCatalogOperation.java:
##
@@ -39,10 +41,18 @@
public class
liyubin117 commented on code in PR #24934:
URL: https://github.com/apache/flink/pull/24934#discussion_r1639243865
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/CatalogDescriptor.java:
##
@@ -48,18 +55,34 @@ public Configuration
liyubin117 commented on code in PR #24934:
URL: https://github.com/apache/flink/pull/24934#discussion_r1639240721
##
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlCreateCatalog.java:
##
@@ -45,11 +48,18 @@ public class SqlCreateCatalog extends
Jiabao-Sun closed pull request #3318: Out of use
URL: https://github.com/apache/flink-cdc/pull/3318
--
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:
[
https://issues.apache.org/jira/browse/FLINK-35121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiabao Sun resolved FLINK-35121.
Assignee: yux
Resolution: Implemented
Implemented by flink-cdc master:
Jiabao-Sun commented on PR #3412:
URL: https://github.com/apache/flink-cdc/pull/3412#issuecomment-2167182112
Closed by #3382
--
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
Jiabao-Sun closed pull request #3412:
[FLINK-35121][pipeline-connector][cdc-base] CDC pipeline connector provide
ability to verify requiredOptions and optionalOptions
URL: https://github.com/apache/flink-cdc/pull/3412
--
This is an automated message from the Apache Git Service.
To respond
Jiabao-Sun merged PR #3382:
URL: https://github.com/apache/flink-cdc/pull/3382
--
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:
[
https://issues.apache.org/jira/browse/FLINK-35599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ZhengJunZhou updated FLINK-35599:
-
Component/s: Flink CDC
Affects Version/s: cdc-3.2.0
Description: TODO
wzx140 commented on PR #24937:
URL: https://github.com/apache/flink/pull/24937#issuecomment-2167176948
@1996fanrui Could you please review it? Really thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
ZhengJunZhou created FLINK-35599:
Summary: test
Key: FLINK-35599
URL: https://issues.apache.org/jira/browse/FLINK-35599
Project: Flink
Issue Type: Bug
Reporter: ZhengJunZhou
[
https://issues.apache.org/jira/browse/FLINK-35598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35598:
---
Labels: pull-request-available pull_request_available (was:
pull_request_available)
> Fix
flinkbot commented on PR #24937:
URL: https://github.com/apache/flink/pull/24937#issuecomment-2167173883
## CI report:
* 0438cd927e430131c07b0555265696e34e1606a0 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35598:
---
Labels: pull-request-available (was: )
> Fix error comparison type
[
https://issues.apache.org/jira/browse/FLINK-35598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Frank Wong updated FLINK-35598:
---
Labels: pull_request_available (was: pull-request-available)
> Fix error comparison type
Frank Wong created FLINK-35598:
--
Summary: Fix error comparison type
ExtendedSqlRowTypeNameSpec#equalsDeep
Key: FLINK-35598
URL: https://issues.apache.org/jira/browse/FLINK-35598
Project: Flink
lvyanquan commented on code in PR #3414:
URL: https://github.com/apache/flink-cdc/pull/3414#discussion_r1639192510
##
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/HashFunction.java:
##
@@ -0,0 +1,28 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
pan3793 commented on PR #24905:
URL: https://github.com/apache/flink/pull/24905#issuecomment-2167155520
thank you, @1996fanrui
--
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
fredia commented on PR #24922:
URL: https://github.com/apache/flink/pull/24922#issuecomment-2167153534
> Thanks for the PR! Overall LGTM. How about adding some docs under
`docs/ops/metrics#checkpointing`?
@Zakelly Thanks for the review, added into `docs/ops/metrics#checkpointing`
[
https://issues.apache.org/jira/browse/FLINK-35543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854919#comment-17854919
]
Rui Fan commented on FLINK-35543:
-
Merged to master(1.20.0) via :
[
https://issues.apache.org/jira/browse/FLINK-35543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-35543.
-
Fix Version/s: 1.20.0
Resolution: Fixed
> Upgrade Hive 2.3 connector to version 2.3.10
>
[
https://issues.apache.org/jira/browse/FLINK-35543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan reassigned FLINK-35543:
---
Assignee: Cheng Pan
> Upgrade Hive 2.3 connector to version 2.3.10
>
1996fanrui merged PR #24905:
URL: https://github.com/apache/flink/pull/24905
--
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:
lvyanquan commented on code in PR #3414:
URL: https://github.com/apache/flink-cdc/pull/3414#discussion_r1639176999
##
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/HashFunction.java:
##
@@ -0,0 +1,28 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
lvyanquan commented on code in PR #3414:
URL: https://github.com/apache/flink-cdc/pull/3414#discussion_r1639176999
##
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/HashFunction.java:
##
@@ -0,0 +1,28 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
LadyForest commented on code in PR #24934:
URL: https://github.com/apache/flink/pull/24934#discussion_r1639160703
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ddl/CreateCatalogOperation.java:
##
@@ -39,10 +41,18 @@
public class
caicancai commented on PR #830:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/830#issuecomment-2167139959
@1996fanrui @RocMarshal Thank you for your review and patient reply
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
dingxin-tech commented on code in PR #3254:
URL: https://github.com/apache/flink-cdc/pull/3254#discussion_r1639174241
##
[
https://issues.apache.org/jira/browse/FLINK-35448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-35448.
-
Fix Version/s: kubernetes-operator-1.9.0
Assignee: Caican Cai
Resolution: Fixed
>
[
https://issues.apache.org/jira/browse/FLINK-33463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854916#comment-17854916
]
RocMarshal commented on FLINK-33463:
Hi, [~fanrui] [~eskabetxe]
Should we split the Jira as a
[
https://issues.apache.org/jira/browse/FLINK-35448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854915#comment-17854915
]
Rui Fan commented on FLINK-35448:
-
Merged to main(1.9.0) via: d920a235a3357311b96e3c087d5918d83da27853
1996fanrui merged PR #830:
URL: https://github.com/apache/flink-kubernetes-operator/pull/830
--
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:
[
https://issues.apache.org/jira/browse/FLINK-35157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854914#comment-17854914
]
elon_X commented on FLINK-35157:
[~fanrui] Sure, I will backport this fix to 1.17, 1.18, and 1.19. Thank
dingxin-tech commented on code in PR #3254:
URL: https://github.com/apache/flink-cdc/pull/3254#discussion_r1639171927
##
yuanoOo commented on code in PR #3360:
URL: https://github.com/apache/flink-cdc/pull/3360#discussion_r1639167796
##
docs/content/docs/connectors/pipeline-connectors/oceanbase.md:
##
@@ -0,0 +1,343 @@
+---
+title: "OceanBase"
+weight: 7
+type: docs
+aliases:
+-
GOODBOY008 commented on PR #24936:
URL: https://github.com/apache/flink/pull/24936#issuecomment-2167128712
@1996fanrui It's indeed my mistake. @liyubin117 Great catch.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
RocMarshal commented on PR #119:
URL:
https://github.com/apache/flink-connector-jdbc/pull/119#issuecomment-2167128684
Thank you @1996fanrui @eskabetxe very much for your review and attention
for the feature !
--
This is an automated message from the Apache Git Service.
To respond
caicancai commented on PR #830:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/830#issuecomment-2167127192
@1996fanrui cli fail, but it doesn't seem to be caused by my pr
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
[
https://issues.apache.org/jira/browse/FLINK-35237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35237:
---
Labels: pull-request-available (was: )
> Allow Sink to Choose HashFunction in
[
https://issues.apache.org/jira/browse/FLINK-34914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854911#comment-17854911
]
Weijie Guo edited comment on FLINK-34914 at 6/14/24 2:16 AM:
-
I'm glad to
[
https://issues.apache.org/jira/browse/FLINK-34914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854911#comment-17854911
]
Weijie Guo commented on FLINK-34914:
I'm glad to hear that, but with a friendly remind: The feature
[
https://issues.apache.org/jira/browse/FLINK-35597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubin Li updated FLINK-35597:
-
Description: To ensure at least one fraction of hosts to be local, it
should be
[
https://issues.apache.org/jira/browse/FLINK-35597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854910#comment-17854910
]
Jane Chan commented on FLINK-35597:
---
caicancai commented on code in PR #830:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/830#discussion_r1639121989
##
docs/content/docs/custom-resource/pod-template.md:
##
@@ -125,4 +124,4 @@ arr1: [{name: a, p2: v2}, {name: c, p2: v2}]
merged: [{name: a, p1:
whhe commented on code in PR #3360:
URL: https://github.com/apache/flink-cdc/pull/3360#discussion_r1639119977
##
docs/content/docs/connectors/pipeline-connectors/oceanbase.md:
##
@@ -0,0 +1,343 @@
+---
+title: "OceanBase"
+weight: 7
+type: docs
+aliases:
+-
[
https://issues.apache.org/jira/browse/FLINK-35591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-35591.
--
Fix Version/s: 1.20.0
Resolution: Fixed
> Azure Pipelines not running for master since
[
https://issues.apache.org/jira/browse/FLINK-35591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854907#comment-17854907
]
Weijie Guo commented on FLINK-35591:
Thanks [~lorenzo.affetti]! I have checked it works now.
>
[
https://issues.apache.org/jira/browse/FLINK-35591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-35591:
--
Assignee: Lorenzo Affetti
> Azure Pipelines not running for master since c9def981
>
flinkbot commented on PR #24936:
URL: https://github.com/apache/flink/pull/24936#issuecomment-2167073330
## CI report:
* 971edbe445dc16987a149bda399cf235f2ed5554 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854906#comment-17854906
]
Rui Fan commented on FLINK-33461:
-
Merged to main(jdbc-3.3.0) via
[
https://issues.apache.org/jira/browse/FLINK-33461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-33461.
-
Fix Version/s: jdbc-3.3.0
Resolution: Fixed
> Support streaming related semantics for the new
[
https://issues.apache.org/jira/browse/FLINK-33462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854905#comment-17854905
]
Rui Fan commented on FLINK-33462:
-
Merged to main(jdbc-3.3.0) via
[
https://issues.apache.org/jira/browse/FLINK-33462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-33462:
Fix Version/s: jdbc-3.3.0
> Sort out the document page about the new Jdbc source.
>
[
https://issues.apache.org/jira/browse/FLINK-33462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-33462.
-
Resolution: Fixed
> Sort out the document page about the new Jdbc source.
>
HuangXingBo commented on code in PR #24426:
URL: https://github.com/apache/flink/pull/24426#discussion_r1639115041
##
.github/workflows/nightly.yml:
##
@@ -28,69 +28,131 @@ jobs:
name: "Pre-compile Checks"
uses: ./.github/workflows/template.pre-compile-checks.yml
-
1996fanrui merged PR #119:
URL: https://github.com/apache/flink-connector-jdbc/pull/119
--
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:
HuangXingBo commented on PR #24426:
URL: https://github.com/apache/flink/pull/24426#issuecomment-2167064115
Thanks @morazow for the update.
I downloaded the wheel package and found that the wheel package after repair
is manylinux_2_5. It may be related to not using
[
https://issues.apache.org/jira/browse/FLINK-35597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35597:
---
Labels: pull-request-available (was: )
> Fix unstable
>
liyubin117 opened a new pull request, #24936:
URL: https://github.com/apache/flink/pull/24936
## Brief change log
* it should be ia.getNumberOfLocalAssignments() as before
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
Jiabao-Sun commented on code in PR #3382:
URL: https://github.com/apache/flink-cdc/pull/3382#discussion_r1639108698
##
flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/definition/PipelineValidationTest.java:
##
@@ -0,0 +1,85 @@
+/*
+ * Licensed to the Apache
1996fanrui commented on code in PR #830:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/830#discussion_r1639108031
##
docs/content/docs/custom-resource/pod-template.md:
##
@@ -125,4 +124,4 @@ arr1: [{name: a, p2: v2}, {name: c, p2: v2}]
merged: [{name: a, p1:
1996fanrui commented on code in PR #830:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/830#discussion_r1639106337
##
docs/content/docs/custom-resource/pod-template.md:
##
@@ -93,16 +90,18 @@ spec:
```
{{< hint info >}}
-When using the operator with Flink
1996fanrui commented on code in PR #830:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/830#discussion_r1639106337
##
docs/content/docs/custom-resource/pod-template.md:
##
@@ -93,16 +90,18 @@ spec:
```
{{< hint info >}}
-When using the operator with Flink
Yubin Li created FLINK-35597:
Summary: Fix unstable
LocatableSplitAssignerTest#testConcurrentSplitAssignmentForMultipleHosts
Key: FLINK-35597
URL: https://issues.apache.org/jira/browse/FLINK-35597
[
https://issues.apache.org/jira/browse/FLINK-35157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-35157:
Fix Version/s: 1.20.0
> Sources with watermark alignment get stuck once some subtasks finish
>
[
https://issues.apache.org/jira/browse/FLINK-35157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854902#comment-17854902
]
Rui Fan commented on FLINK-35157:
-
Hi [~elon] , would you mind backporting this fix to 1.17, 1.18 and
[
https://issues.apache.org/jira/browse/FLINK-35157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854901#comment-17854901
]
Rui Fan commented on FLINK-35157:
-
Merged to master(1.20.0) via:
1996fanrui merged PR #24757:
URL: https://github.com/apache/flink/pull/24757
--
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:
flinkbot commented on PR #24935:
URL: https://github.com/apache/flink/pull/24935#issuecomment-2167007574
## CI report:
* 8c396c54eeda5bc8f8f656847a372b3421c25a7f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
venkata91 commented on PR #24935:
URL: https://github.com/apache/flink/pull/24935#issuecomment-2167003430
cc @becketqin
--
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-35596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35596:
---
Labels: pull-request-available (was: )
> Flink application fails with The implementation
venkata91 opened a new pull request, #24935:
URL: https://github.com/apache/flink/pull/24935
## 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
[
https://issues.apache.org/jira/browse/FLINK-35596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854896#comment-17854896
]
Venkata krishnan Sowrirajan commented on FLINK-35596:
-
Most likely the
[
https://issues.apache.org/jira/browse/FLINK-35596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Venkata krishnan Sowrirajan updated FLINK-35596:
Affects Version/s: 1.19.0
> Flink application fails with The
Venkata krishnan Sowrirajan created FLINK-35596:
---
Summary: Flink application fails with The implementation of the
BlockElement is not serializable
Key: FLINK-35596
URL:
mattayes commented on PR #838:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/838#issuecomment-2166971750
@gyfora Here's a rework of #837.
--
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
mattayes opened a new pull request, #838:
URL: https://github.com/apache/flink-kubernetes-operator/pull/838
## What is the purpose of the change
Add missing documentation for `FlinkSessionJob` CRD.
## Brief change log
Add docs for `FlinkSessionJob` CRD.
[
https://issues.apache.org/jira/browse/FLINK-35485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854891#comment-17854891
]
Xingcan Cui commented on FLINK-35485:
-
Hi [~mapohl], I hit the exception again today and it caused
David Schlosnagle created FLINK-35595:
-
Summary: MailboxProcessor#processMailsWhenDefaultActionUnavailable
is allocation intensive
Key: FLINK-35595
URL: https://issues.apache.org/jira/browse/FLINK-35595
venkata91 commented on code in PR #24736:
URL: https://github.com/apache/flink/pull/24736#discussion_r1638672737
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptivebatch/AdaptiveBatchSchedulerTest.java:
##
Review Comment:
Addressed it.
--
This is
[
https://issues.apache.org/jira/browse/FLINK-35594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-35594.
--
Resolution: Duplicate
> Downscaling doesn't release TaskManagers.
>
[
https://issues.apache.org/jira/browse/FLINK-33977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-33977:
---
Affects Version/s: 1.19.0
1.20.0
> Adaptive scheduler may not minimize the
venkata91 commented on PR #24736:
URL: https://github.com/apache/flink/pull/24736#issuecomment-2166456519
> > > Thanks, @venkata91, for your contribution! After reviewing this PR,
I'm concerned that it entirely removes limit that source parallelism should
lower than source jobVertex's max
liyubin117 opened a new pull request, #24934:
URL: https://github.com/apache/flink/pull/24934
## What is the purpose of the change
Introduce comment for CatalogStore and Support enhanced `CREATE CATALOG`
syntax
## Brief change log
* add comment instance in
jnh5y commented on code in PR #24929:
URL: https://github.com/apache/flink/pull/24929#discussion_r1638447342
##
docs/content/docs/dev/table/sql/create.md:
##
@@ -406,6 +413,14 @@ Flink will assume correctness of the primary key by
assuming that the columns nu
Partition the
jnh5y commented on code in PR #24929:
URL: https://github.com/apache/flink/pull/24929#discussion_r1638444015
##
docs/content/docs/dev/table/sql/create.md:
##
@@ -465,6 +480,7 @@ You can control the merging behavior of:
* GENERATED - computed columns
* METADATA - metadata
LadyForest commented on code in PR #24932:
URL: https://github.com/apache/flink/pull/24932#discussion_r1638477886
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java:
##
@@ -327,11 +328,15 @@ public void createCatalog(String
flinkbot commented on PR #24934:
URL: https://github.com/apache/flink/pull/24934#issuecomment-2166393201
## CI report:
* d31c5b45069430fcdd04727df1aebde7dd111d97 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
1 - 100 of 199 matches
Mail list logo
