[
https://issues.apache.org/jira/browse/FLINK-35430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LvYanquan updated FLINK-35430:
--
Fix Version/s: cdc-3.1.1
(was: cdc-3.2.0)
> ZoneId is not passed to DebeziumJso
[
https://issues.apache.org/jira/browse/FLINK-35430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LvYanquan updated FLINK-35430:
--
Affects Version/s: cdc-3.1.1
(was: cdc-3.2.0)
> ZoneId is not passed to Deb
[
https://issues.apache.org/jira/browse/FLINK-35325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LvYanquan updated FLINK-35325:
--
Affects Version/s: cdc-3.1.1
(was: cdc-3.2.0)
> Paimon connector miss the p
[
https://issues.apache.org/jira/browse/FLINK-35461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35461:
---
Labels: pull-request-available (was: )
> Improve Runtime Configuration for Flink 2.0
>
[
https://issues.apache.org/jira/browse/FLINK-35325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LvYanquan updated FLINK-35325:
--
Fix Version/s: cdc-3.1.1
(was: cdc-3.2.0)
> Paimon connector miss the position
Sxnan opened a new pull request, #24853:
URL: https://github.com/apache/flink/pull/24853
## 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 on e
drymatini commented on PR #24822:
URL: https://github.com/apache/flink/pull/24822#issuecomment-2134467693
HI,@reswqa , I have finished the translation of the page.Could you please
verify my pull request?
--
This is an automated message from the Apache Git Service.
To respond to the messag
[
https://issues.apache.org/jira/browse/FLINK-35470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-35470.
--
Resolution: Invalid
Please post user questions to the User mailing list, Stackoverflow or Slac
Rui Fan created FLINK-35471:
---
Summary: Kubernetes operator bumps the flink version to 1.19
Key: FLINK-35471
URL: https://issues.apache.org/jira/browse/FLINK-35471
Project: Flink
Issue Type: Improve
Rajat Pratap Singh created FLINK-35470:
--
Summary: Flink 1.18.1 and 1.19.0 having build jdk 1.8 and causing
incompatibilities with Java 17
Key: FLINK-35470
URL: https://issues.apache.org/jira/browse/FLINK-3547
lsyldliu commented on code in PR #24844:
URL: https://github.com/apache/flink/pull/24844#discussion_r1616634968
##
flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/service/MaterializedTableStatementITCase.java:
##
@@ -909,47 +697,240 @@ void testDropMat
[
https://issues.apache.org/jira/browse/FLINK-35446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849894#comment-17849894
]
Zakelly Lan commented on FLINK-35446:
-
Thanks for the reminder [~rskraba] , actually
masteryhx commented on code in PR #24374:
URL: https://github.com/apache/flink/pull/24374#discussion_r1616642658
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/ExecutionCheckpointingOptions.java:
##
@@ -38,8 +38,11 @@
* Execution {@link Config
[
https://issues.apache.org/jira/browse/FLINK-35469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-35469:
---
Labels: JDBC (was: )
> Unstable test case 'testProject' of JdbcDynamicTableSourceITCase
> -
RocMarshal commented on code in PR #119:
URL:
https://github.com/apache/flink-connector-jdbc/pull/119#discussion_r1616638179
##
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/source/JdbcSourceStreamRelatedITCase.java:
##
@@ -0,0 +1,368 @@
+/*
+ * Licensed to
X-czh commented on PR #24845:
URL: https://github.com/apache/flink/pull/24845#issuecomment-2134366106
@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 comment.
To
RocMarshal created FLINK-35469:
--
Summary: Unstable test case 'testProject' of
JdbcDynamicTableSourceITCase
Key: FLINK-35469
URL: https://issues.apache.org/jira/browse/FLINK-35469
Project: Flink
flinkbot commented on PR #24852:
URL: https://github.com/apache/flink/pull/24852#issuecomment-2134328506
## CI report:
* 35c1fce18fa24f0232edb86eee232482804795d2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849874#comment-17849874
]
Luke Chen commented on FLINK-33607:
---
[~mapohl] , I've opened a PR to improve it. Pleas
[
https://issues.apache.org/jira/browse/FLINK-33607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849873#comment-17849873
]
Luke Chen commented on FLINK-33607:
---
PR: [https://github.com/apache/flink/pull/24852]
[
https://issues.apache.org/jira/browse/FLINK-33607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33607:
---
Labels: pull-request-available (was: )
> Add checksum verification for Maven wrapper as wel
showuon opened a new pull request, #24852:
URL: https://github.com/apache/flink/pull/24852
## 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 on
[
https://issues.apache.org/jira/browse/FLINK-35468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35468:
---
Labels: pull-request-available (was: )
> [Connectors/Pulsar] update isEnableAutoAcknowledge
boring-cyborg[bot] commented on PR #93:
URL:
https://github.com/apache/flink-connector-pulsar/pull/93#issuecomment-2134308720
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is
geniusjoe opened a new pull request, #93:
URL: https://github.com/apache/flink-connector-pulsar/pull/93
## Purpose of the change
Since we [deleted shared and key-shared subscription
type](https://issues.apache.org/jira/browse/FLINK-30413) in pulsar source
connector, I thi
zhou zhuohan created FLINK-35468:
Summary: [Connectors/Pulsar] update isEnableAutoAcknowledgeMessage
config comment
Key: FLINK-35468
URL: https://issues.apache.org/jira/browse/FLINK-35468
Project: Fli
[
https://issues.apache.org/jira/browse/FLINK-35438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849850#comment-17849850
]
Rob Young edited comment on FLINK-35438 at 5/28/24 3:45 AM:
yuxiqian commented on PR #3352:
URL: https://github.com/apache/flink-cdc/pull/3352#issuecomment-2134293705
> @yuxiqian can you help me trigger cicd?
Sorry I do not have such privilege, either. You may create a PR to your fork
repository (e.g. from `hk-lrzy:FLINK-35432` to `hk-lrzy:mas
X-czh closed pull request #24851: [hotfix] Fix incompatible type of
JobManagerOptions.SLOT_REQUEST_OUT value
URL: https://github.com/apache/flink/pull/24851
--
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
JunRuiLee commented on PR #24851:
URL: https://github.com/apache/flink/pull/24851#issuecomment-2134282190
@X-czh Thank you very much for the reminder. Another fix has been merged
(https://github.com/apache/flink/pull/24850), you can try to rebase onto master.
--
This is an automated messa
hk-lrzy commented on PR #3352:
URL: https://github.com/apache/flink-cdc/pull/3352#issuecomment-2134282172
@yuxiqian can you help me trigger cicd?
--
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
flinkbot commented on PR #24851:
URL: https://github.com/apache/flink/pull/24851#issuecomment-2134281847
## CI report:
* e672a30887809c13a14c4103076f560ebbcee092 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
X-czh commented on PR #24851:
URL: https://github.com/apache/flink/pull/24851#issuecomment-2134279139
@JunRuiLee Hi, a recent change (FLINK-35359) changes the type of
JobManagerOptions.SLOT_REQUEST_OUT to Duration, which conflicts with your
recent change in FLINK-35465, leading to compilati
X-czh opened a new pull request, #24851:
URL: https://github.com/apache/flink/pull/24851
## What is the purpose of the change
Fix incompatible type of JobManagerOptions.SLOT_REQUEST_OUT value.
## Verifying this change
This change is a trivial rework / code cleanup
lsyldliu commented on code in PR #24849:
URL: https://github.com/apache/flink/pull/24849#discussion_r1616527538
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/IntervalFreshness.java:
##
@@ -0,0 +1,88 @@
+/*
+ * Licensed to the Apache Software Foun
lsyldliu commented on code in PR #24849:
URL: https://github.com/apache/flink/pull/24849#discussion_r1616527538
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/IntervalFreshness.java:
##
@@ -0,0 +1,88 @@
+/*
+ * Licensed to the Apache Software Foun
zhuzhurk commented on PR #24850:
URL: https://github.com/apache/flink/pull/24850#issuecomment-2134275369
The change is trivial. Will merge it right now to unblock others.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
[
https://issues.apache.org/jira/browse/FLINK-35457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei resolved FLINK-35457.
Resolution: Fixed
> EventTimeWindowCheckpointingITCase fails on AZP as NPE
> -
zhuzhurk merged PR #24850:
URL: https://github.com/apache/flink/pull/24850
--
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.apac
[
https://issues.apache.org/jira/browse/FLINK-35457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei reassigned FLINK-35457:
--
Assignee: Yanfei Lei
> EventTimeWindowCheckpointingITCase fails on AZP as NPE
> -
[
https://issues.apache.org/jira/browse/FLINK-35457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849864#comment-17849864
]
Yanfei Lei commented on FLINK-35457:
Merged into master via 1e996b8
> EventTimeWind
lsyldliu commented on code in PR #24849:
URL: https://github.com/apache/flink/pull/24849#discussion_r1616524117
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/IntervalFreshness.java:
##
@@ -0,0 +1,88 @@
+/*
+ * Licensed to the Apache Software Foun
fredia merged PR #24846:
URL: https://github.com/apache/flink/pull/24846
--
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
flinkbot commented on PR #24850:
URL: https://github.com/apache/flink/pull/24850#issuecomment-2134269337
## CI report:
* 90c1170d07dea3e1373a34fe245e4ec7ccdab592 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849862#comment-17849862
]
Leonard Xu edited comment on FLINK-35447 at 5/28/24 2:58 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-35447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-35447.
Resolution: Implemented
> Flink CDC Document document file had removed but website can access
> --
leonardBang merged PR #3367:
URL: https://github.com/apache/flink-cdc/pull/3367
--
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
leonardBang merged PR #3368:
URL: https://github.com/apache/flink-cdc/pull/3368
--
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
[
https://issues.apache.org/jira/browse/FLINK-35447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849862#comment-17849862
]
Leonard Xu commented on FLINK-35447:
master: d97124fb9f531193d8b232862af44e6bcca0327
[
https://issues.apache.org/jira/browse/FLINK-35447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35447:
---
Fix Version/s: cdc-3.2.0
cdc-3.1.1
> Flink CDC Document document file had removed
[
https://issues.apache.org/jira/browse/FLINK-35447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35447:
---
Affects Version/s: cdc-3.1.0
> Flink CDC Document document file had removed but website can access
>
hackergin commented on code in PR #24844:
URL: https://github.com/apache/flink/pull/24844#discussion_r1616519135
##
flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/rest/SqlGatewayRestEndpointMaterializedTableITCase.java:
##
@@ -0,0 +1,129 @@
+/*
+ * Li
[
https://issues.apache.org/jira/browse/FLINK-35447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-35447:
--
Assignee: Zhongqiang Gong
> Flink CDC Document document file had removed but website can acce
leonardBang merged PR #3362:
URL: https://github.com/apache/flink-cdc/pull/3362
--
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
zoltar9264 opened a new pull request, #24850:
URL: https://github.com/apache/flink/pull/24850
## What is the purpose of the change
As title said, fix the compile error cause by modification conflict between
FLINK-35465 and FLINK-35359.
## Verifying this change
This chang
hackergin commented on code in PR #24844:
URL: https://github.com/apache/flink/pull/24844#discussion_r1616517183
##
flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/service/MaterializedTableStatementITCase.java:
##
@@ -909,47 +694,172 @@ void testDropMa
loserwang1024 commented on PR #3349:
URL: https://github.com/apache/flink-cdc/pull/3349#issuecomment-2134261272
LGTM! @leonardBang @ruanhang1993 , CC, WDYT of the option name
`checkpoint.cycle`
--
This is an automated message from the Apache Git Service.
To respond to the message, please
hackergin commented on code in PR #24849:
URL: https://github.com/apache/flink/pull/24849#discussion_r161654
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/IntervalFreshness.java:
##
@@ -0,0 +1,88 @@
+/*
+ * Licensed to the Apache Software Fou
[
https://issues.apache.org/jira/browse/FLINK-35360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849856#comment-17849856
]
wangjunbo edited comment on FLINK-35360 at 5/28/24 2:38 AM:
[
https://issues.apache.org/jira/browse/FLINK-34904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849860#comment-17849860
]
wangjunbo edited comment on FLINK-34904 at 5/28/24 2:37 AM:
[
https://issues.apache.org/jira/browse/FLINK-34904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849860#comment-17849860
]
wangjunbo edited comment on FLINK-34904 at 5/28/24 2:36 AM:
[
https://issues.apache.org/jira/browse/FLINK-34904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849860#comment-17849860
]
wangjunbo edited comment on FLINK-34904 at 5/28/24 2:35 AM:
[
https://issues.apache.org/jira/browse/FLINK-34904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849860#comment-17849860
]
wangjunbo commented on FLINK-34904:
---
[~czy006] Looking forward to the realization of t
fredia commented on code in PR #24846:
URL: https://github.com/apache/flink/pull/24846#discussion_r1616500402
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/FileMergingSnapshotManagerBase.java:
##
@@ -131,19 +131,22 @@ public abstract class FileMe
spoon-lz commented on PR #24374:
URL: https://github.com/apache/flink/pull/24374#issuecomment-2134232797
@Zakelly @masteryhx Sorry I made the mistake of committing to the wrong
branch, the code has been updated.
--
This is an automated message from the Apache Git Service.
To respond to th
[
https://issues.apache.org/jira/browse/FLINK-35360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849856#comment-17849856
]
wangjunbo edited comment on FLINK-35360 at 5/28/24 2:04 AM:
beryllw commented on PR #3366:
URL: https://github.com/apache/flink-cdc/pull/3366#issuecomment-2134231318
k8s application mode pr: https://github.com/apache/flink-cdc/pull/3093/files
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
[
https://issues.apache.org/jira/browse/FLINK-35360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849856#comment-17849856
]
wangjunbo commented on FLINK-35360:
---
discuss in FLINK-34853 and FLINK-34904
> [Featur
[
https://issues.apache.org/jira/browse/FLINK-35460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu resolved FLINK-35460.
--
Fix Version/s: 1.20.0
Resolution: Fixed
Merged 9fbe9f30 into master.
> Check file size
masteryhx closed pull request #24847: [FLINK-35460][state] Adjust read size
when ByteBuffer size is larger than file size for ForSt
URL: https://github.com/apache/flink/pull/24847
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
[
https://issues.apache.org/jira/browse/FLINK-35121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849854#comment-17849854
]
wangjunbo commented on FLINK-35121:
---
[~loserwang1024] I'm willing to take this.
> CDC
[
https://issues.apache.org/jira/browse/FLINK-34595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849852#comment-17849852
]
wangjunbo edited comment on FLINK-34595 at 5/28/24 1:54 AM:
[
https://issues.apache.org/jira/browse/FLINK-35465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-35465.
---
Resolution: Done
master:
b8173eb662ee5823de40de356869d0064de2c22a
3206659db5b7c4ce645072f11f091e0e9e92b0ce
e
[
https://issues.apache.org/jira/browse/FLINK-35465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-35465:
Fix Version/s: 1.20.0
> Introduce BatchJobRecoveryHandler for recovery of batch jobs from JobMaster
> fai
[
https://issues.apache.org/jira/browse/FLINK-34595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849852#comment-17849852
]
wangjunbo commented on FLINK-34595:
---
Looks like closed by https://github.com/apache/fl
[
https://issues.apache.org/jira/browse/FLINK-35465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35465:
---
Labels: pull-request-available (was: )
> Introduce BatchJobRecoveryHandler for recovery of
zhuzhurk merged PR #24771:
URL: https://github.com/apache/flink/pull/24771
--
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.apac
[
https://issues.apache.org/jira/browse/FLINK-35465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-35465:
---
Assignee: Junrui Li
> Introduce BatchJobRecoveryHandler for recovery of batch jobs from JobMaster
RocMarshal commented on code in PR #830:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/830#discussion_r1616483112
##
docs/content/docs/custom-resource/pod-template.md:
##
@@ -93,16 +90,18 @@ spec:
```
{{< hint info >}}
-When using the operator with Flink nat
RocMarshal commented on code in PR #830:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/830#discussion_r1616482602
##
docs/content/docs/custom-resource/pod-template.md:
##
@@ -26,21 +26,18 @@ under the License.
# Pod template
-The operator CRD is designed to
[
https://issues.apache.org/jira/browse/FLINK-35464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35464:
---
Labels: pull-request-available (was: )
> Flink CDC 3.1 breaks operator state compatiblity
>
X-czh commented on PR #24845:
URL: https://github.com/apache/flink/pull/24845#issuecomment-2134201750
@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 comment.
To
yuxiqian opened a new pull request, #3369:
URL: https://github.com/apache/flink-cdc/pull/3369
This closes FLINK-35441 and FLINK-35464.
Flink CDC 3.1 changes how SchemaRegistry [de]serializes state data, which
causes any checkpoint states saved with earlier version could not be restore
[
https://issues.apache.org/jira/browse/FLINK-35438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849850#comment-17849850
]
Rob Young commented on FLINK-35438:
---
I agree there's a race that's hard to reproduce,
Justin.Liu created FLINK-35467:
--
Summary: The flink-cdc.sh script of flink-cdc-3.1.0 cannot read
the correct Flink configuration information specified by the flink-conf.yaml
through the FLINK_CONF_DIR environment variable.
Key: FLIN
[
https://issues.apache.org/jira/browse/FLINK-35418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849841#comment-17849841
]
Rob Young commented on FLINK-35418:
---
looks like the same issue as https://issues.apach
[
https://issues.apache.org/jira/browse/FLINK-33759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge resolved FLINK-33759.
-
Fix Version/s: 1.20.0
Resolution: Fixed
> flink parquet writer support write nested array or map
[
https://issues.apache.org/jira/browse/FLINK-33759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge updated FLINK-33759:
Affects Version/s: 1.19.0
> flink parquet writer support write nested array or map type
>
[
https://issues.apache.org/jira/browse/FLINK-33759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849837#comment-17849837
]
Jing Ge commented on FLINK-33759:
-
master:
https://github.com/apache/flink/commit/57b20
JingGe merged PR #24795:
URL: https://github.com/apache/flink/pull/24795
--
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
SamBarker commented on PR #90:
URL: https://github.com/apache/flink-benchmarks/pull/90#issuecomment-2134019437
> AFAIU, by default profiling is not turned on. One has to activate
enable-async-profiler profile?
Yes that's almost right. The profile is enabled automatically by specifying
SamBarker commented on code in PR #90:
URL: https://github.com/apache/flink-benchmarks/pull/90#discussion_r1616369948
##
pom.xml:
##
@@ -290,25 +291,31 @@ under the License.
hackergin commented on code in PR #24844:
URL: https://github.com/apache/flink/pull/24844#discussion_r1616305580
##
flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/service/MaterializedTableStatementITCase.java:
##
@@ -909,47 +694,172 @@ void testDropMa
hackergin commented on code in PR #24844:
URL: https://github.com/apache/flink/pull/24844#discussion_r1616304880
##
flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/rest/SqlGatewayRestEndpointMaterializedTableITCase.java:
##
@@ -0,0 +1,129 @@
+/*
+ * Li
XComp commented on code in PR #24426:
URL: https://github.com/apache/flink/pull/24426#discussion_r1616244045
##
.github/workflows/nightly.yml:
##
@@ -94,3 +94,46 @@ jobs:
s3_bucket: ${{ secrets.IT_CASE_S3_BUCKET }}
s3_access_key: ${{ secrets.IT_CASE_S3_ACCESS_KEY }
XComp commented on code in PR #24471:
URL: https://github.com/apache/flink/pull/24471#discussion_r1616241149
##
flink-end-to-end-tests/flink-batch-sql-test/src/test/java/org/apache/flink/sql/tests/Generator.java:
##
@@ -0,0 +1,120 @@
+/*
+ * Licensed to the Apache Software Found
pnowojski commented on code in PR #90:
URL: https://github.com/apache/flink-benchmarks/pull/90#discussion_r1616223910
##
benchmark.sh:
##
@@ -0,0 +1,54 @@
+#!/usr/bin/env bash
Review Comment:
I would mark this as executable.
##
benchmark.sh:
##
@@ -0,0 +1,
morazow commented on code in PR #24426:
URL: https://github.com/apache/flink/pull/24426#discussion_r1616229933
##
.github/workflows/nightly.yml:
##
@@ -94,3 +94,46 @@ jobs:
s3_bucket: ${{ secrets.IT_CASE_S3_BUCKET }}
s3_access_key: ${{ secrets.IT_CASE_S3_ACCESS_KEY
[
https://issues.apache.org/jira/browse/FLINK-35446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849767#comment-17849767
]
Ryan Skraba commented on FLINK-35446:
-
Thanks for the fix! There were a bunch of fa
XComp commented on code in PR #24426:
URL: https://github.com/apache/flink/pull/24426#discussion_r1616177599
##
.github/workflows/nightly.yml:
##
@@ -94,3 +94,46 @@ jobs:
s3_bucket: ${{ secrets.IT_CASE_S3_BUCKET }}
s3_access_key: ${{ secrets.IT_CASE_S3_ACCESS_KEY }
1 - 100 of 221 matches
Mail list logo
