[
https://issues.apache.org/jira/browse/FLINK-34115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812183#comment-17812183
]
Matthias Pohl commented on FLINK-34115:
---
[
https://issues.apache.org/jira/browse/FLINK-34272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812181#comment-17812181
]
Matthias Pohl edited comment on FLINK-34272 at 1/30/24 7:57 AM:
[
https://issues.apache.org/jira/browse/FLINK-34233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-34233:
--
Fix Version/s: 1.19.0
> HybridShuffleITCase.testHybridSelectiveExchangesRestart failed due to
LadyForest merged PR #24222:
URL: https://github.com/apache/flink/pull/24222
--
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-34272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812181#comment-17812181
]
Matthias Pohl commented on FLINK-34272:
---
[
https://issues.apache.org/jira/browse/FLINK-34272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-34272:
--
Priority: Critical (was: Major)
> AdaptiveSchedulerClusterITCase failure due to MiniCluster
Matthias Pohl created FLINK-34272:
-
Summary: AdaptiveSchedulerClusterITCase failure due to MiniCluster
not running
Key: FLINK-34272
URL: https://issues.apache.org/jira/browse/FLINK-34272
Project:
[
https://issues.apache.org/jira/browse/FLINK-34233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-34233.
--
Resolution: Fixed
master(1.19): 973190e8ca5b7225f18b5c176726ef8680faffca
>
[
https://issues.apache.org/jira/browse/FLINK-34233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-34233:
--
Assignee: Yunfeng Zhou
> HybridShuffleITCase.testHybridSelectiveExchangesRestart failed due
reswqa merged PR #24151:
URL: https://github.com/apache/flink/pull/24151
--
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 #24224:
URL: https://github.com/apache/flink/pull/24224#issuecomment-1916214463
## CI report:
* acacbd8c148dce82070657c05bd76f6114d13e1f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34094:
---
Labels: pull-request-available (was: )
> Document new AsyncScalarFunction
>
AlanConfluent opened a new pull request, #24224:
URL: https://github.com/apache/flink/pull/24224
## What is the purpose of the change
Adds documentation for `AsyncScalarFunction`.
## Brief change log
*(for example:)*
- *The TaskInfo is stored in the blob
[
https://issues.apache.org/jira/browse/FLINK-26760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812169#comment-17812169
]
Yao Zhang commented on FLINK-26760:
---
Hi community,
I submitted a PR and could someone help review it?
caicancai commented on PR #24217:
URL: https://github.com/apache/flink/pull/24217#issuecomment-1916187788
@libenchao Hello, if you have time, can you help look at it? Thank you. This
part of conversion is also reported wrong by default in calcite, which I have
tested
--
This is an
flinkbot commented on PR #24223:
URL: https://github.com/apache/flink/pull/24223#issuecomment-1916174584
## CI report:
* bab2fcf6ec28856c7ca3bd849e2e7176d6fb28c0 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812164#comment-17812164
]
lincoln lee commented on FLINK-33265:
-
[~sudewei.sdw] I'm not sure if [~Zhanghao Chen] has started
SinBex opened a new pull request, #24223:
URL: https://github.com/apache/flink/pull/24223
## What is the purpose of the change
*Fix potential job failure with simultaneous global failover and task finish
in adaptive batch scheduler.*
## Brief change log
- *Check
[
https://issues.apache.org/jira/browse/FLINK-33265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812161#comment-17812161
]
SuDewei commented on FLINK-33265:
-
Hi [~lincoln.86xy] , I’m willing to doing this, shall I have a try ?
[
https://issues.apache.org/jira/browse/FLINK-34271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan reassigned FLINK-34271:
-
Assignee: xuyang
> Fix the unstable test about
[
https://issues.apache.org/jira/browse/FLINK-33375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812153#comment-17812153
]
Jane Chan edited comment on FLINK-33375 at 1/30/24 6:04 AM:
Hi
[
https://issues.apache.org/jira/browse/FLINK-33375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812153#comment-17812153
]
Jane Chan commented on FLINK-33375:
---
Hi [~dwysakowicz], recently, we found an issue in some tests([a
xuyang created FLINK-34271:
--
Summary: Fix the unstable test about
GroupAggregateRestoreTest#AGG_WITH_STATE_TTL_HINT
Key: FLINK-34271
URL: https://issues.apache.org/jira/browse/FLINK-34271
Project: Flink
1996fanrui commented on code in PR #759:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/759#discussion_r1470625450
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingMetricCollector.java:
##
@@ -104,17 +106,18 @@ public CollectedMetricHistory
LadyForest commented on PR #24179:
URL: https://github.com/apache/flink/pull/24179#issuecomment-1916128105
> Hi, @LadyForest. After rebasing onto master, the test for
GroupAggregateRestoreTest#AGG_WITH_STATE_TTL_HINT failed due to an unknown
reason. It succeeded after the savepoint
[
https://issues.apache.org/jira/browse/FLINK-34270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-34270:
--
Fix Version/s: 1.19.0
> Update connector developer-facing doc
>
[
https://issues.apache.org/jira/browse/FLINK-34270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-34270:
--
Description: Update the 'extension points' on User-defined Sources & Sinks
page
Zhanghao Chen created FLINK-34270:
-
Summary: Update connector developer-facing doc
Key: FLINK-34270
URL: https://issues.apache.org/jira/browse/FLINK-34270
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-33265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-33265:
--
Description: The kafka connector adaptation work for [FLIP-367: Support
Setting Parallelism
1996fanrui commented on code in PR #759:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/759#discussion_r1470619716
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingMetricCollector.java:
##
@@ -181,9 +186,12 @@ private static Instant
[
https://issues.apache.org/jira/browse/FLINK-33261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-33261:
Fix Version/s: 1.19.0
> FLIP-367: Support Setting Parallelism for Table/SQL Sources
>
[
https://issues.apache.org/jira/browse/FLINK-33261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812149#comment-17812149
]
lincoln lee commented on FLINK-33261:
-
[~Zhanghao Chen] Thank you for the quick reply! For the
[
https://issues.apache.org/jira/browse/FLINK-33265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-33265:
--
Parent: (was: FLINK-33261)
Issue Type: New Feature (was: Sub-task)
> Support
[
https://issues.apache.org/jira/browse/FLINK-33261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812146#comment-17812146
]
Zhanghao Chen commented on FLINK-33261:
---
[~lincoln.86xy] Thanks for the attention. I'll transfer
[
https://issues.apache.org/jira/browse/FLINK-34252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812081#comment-17812081
]
David Christle edited comment on FLINK-34252 at 1/30/24 5:05 AM:
-
jinsuichen commented on PR #83:
URL:
https://github.com/apache/flink-connector-kafka/pull/83#issuecomment-1916057190
Hi, @MartijnVisser. All CI jobs have been passed in my own repo forked from
here. [PR link](https://github.com/jinsuichen/flink-connector-kafka/pull/1)
Could you help
[
https://issues.apache.org/jira/browse/FLINK-34229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812138#comment-17812138
]
lincoln lee commented on FLINK-34229:
-
[~FrankZou] Any updates on this issue?
> Duplicate entry in
[
https://issues.apache.org/jira/browse/FLINK-34016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812134#comment-17812134
]
xuyang edited comment on FLINK-34016 at 1/30/24 3:38 AM:
-
Hi, [~wczhu] . +1
[
https://issues.apache.org/jira/browse/FLINK-34016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812134#comment-17812134
]
xuyang commented on FLINK-34016:
Hi, [~wczhu] . +1 Could not reproduce it on my local env.
Can you try
[
https://issues.apache.org/jira/browse/FLINK-33261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812132#comment-17812132
]
lincoln lee commented on FLINK-33261:
-
[~Zhanghao Chen] IIUC, the work on the table/sql part of
[
https://issues.apache.org/jira/browse/FLINK-33963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812127#comment-17812127
]
lifengchao commented on FLINK-33963:
I think it's quite common to add constant parameters to
[
https://issues.apache.org/jira/browse/FLINK-33989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812125#comment-17812125
]
xuyang commented on FLINK-33989:
I speculate that even if the Upsert Kafka sink can accept upsert
xiangforever2014 commented on PR #24058:
URL: https://github.com/apache/flink/pull/24058#issuecomment-1915983655
@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
[
https://issues.apache.org/jira/browse/FLINK-34105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812123#comment-17812123
]
Zhu Zhu commented on FLINK-34105:
-
Thanks for the updates! [~guoyangze]
> Akka timeout happens in
[
https://issues.apache.org/jira/browse/FLINK-33989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812122#comment-17812122
]
xuyang commented on FLINK-33989:
Hi, [~flaviu.cicio] . Could you help use `EXPLAIN PLAN_ADVICE` to print
Jiabao-Sun commented on code in PR #707:
URL: https://github.com/apache/flink-web/pull/707#discussion_r1470527820
##
docs/data/release_archive.yml:
##
@@ -545,6 +545,11 @@ release_archive:
version: 4.1.0
release_date: 2023-12-28
filename: "pulsar"
+-
[
https://issues.apache.org/jira/browse/FLINK-34105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812121#comment-17812121
]
Yangze Guo commented on FLINK-34105:
[~lsdy] has some personal affairs and will back this Thursday.
[
https://issues.apache.org/jira/browse/FLINK-33963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812120#comment-17812120
]
lifengchao commented on FLINK-33963:
I think the cost of function serialization and its memory usage
flinkbot commented on PR #24222:
URL: https://github.com/apache/flink/pull/24222#issuecomment-1915952938
## CI report:
* 02d118d2ea4afd98116ceabd94d7f1866e9d43d6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812115#comment-17812115
]
xuyang commented on FLINK-33963:
>From my personal perspective, the method of adding class member
[
https://issues.apache.org/jira/browse/FLINK-34104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812114#comment-17812114
]
Rui Fan commented on FLINK-34104:
-
Merged to main(1.8.0) via : 66808eb9f2d7d26dcd755fec7fdab5ccaf75f8bc
[
https://issues.apache.org/jira/browse/FLINK-34104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-34104:
Description:
Currently, the scaling report format is
{color:#6a8759} Vertex ID %s | Parallelism %d ->
1996fanrui merged PR #757:
URL: https://github.com/apache/flink-kubernetes-operator/pull/757
--
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-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812113#comment-17812113
]
Mason Chen commented on FLINK-33545:
[~yang] yup that's what I'm proposing. We could track an
LadyForest merged PR #24214:
URL: https://github.com/apache/flink/pull/24214
--
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:
LadyForest opened a new pull request, #24222:
URL: https://github.com/apache/flink/pull/24222
## What is the purpose of the change
This PR tries to fix the unstable ITCase `TableAggregateITCase`.
## Brief change log
Replace table source.
## Verifying this
flinkbot commented on PR #24221:
URL: https://github.com/apache/flink/pull/24221#issuecomment-1915942484
## CI report:
* 65e4a1b1ed687c2c98622fb5e753cf079f0e49c7 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-26760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-26760:
---
Labels: pull-request-available (was: )
> The new CSV source (file system source + CSV
paul8263 opened a new pull request, #24221:
URL: https://github.com/apache/flink/pull/24221
… format) does not support reading files whose file encoding is not UTF-8
## What is the purpose of the change
Added charset configuration support for csv format with file system
flinkbot commented on PR #24220:
URL: https://github.com/apache/flink/pull/24220#issuecomment-1915925467
## CI report:
* e83e62b94aae829bb91f00bd5b82feb883d68338 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-34257.
---
Resolution: Fixed
Fixed via 081051a2cacaddf6dfe613da061f15f28a015a41
> Update Flink YAML Parser to
[
https://issues.apache.org/jira/browse/FLINK-34257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-34257:
Affects Version/s: 1.19.0
> Update Flink YAML Parser to Support YAML 1.2 Specification
>
zhuzhurk closed pull request #24213: [FLINK-34257][core] Update Flink YAML
Parser to Support YAML 1.2 Specification.
URL: https://github.com/apache/flink/pull/24213
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
leonardBang merged PR #82:
URL: https://github.com/apache/flink-connector-kafka/pull/82
--
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-34095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34095:
---
Labels: pull-request-available (was: )
> Add a restore test for StreamExecAsyncCalc
>
AlanConfluent opened a new pull request, #24220:
URL: https://github.com/apache/flink/pull/24220
## What is the purpose of the change
Adds some restore tests for StreamExecAsyncCalc, which is utilized by using
`AsyncScalarFunction`.
## Brief change log
*(for
leonardBang merged PR #125:
URL: https://github.com/apache/flink-connector-aws/pull/125
--
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:
leonardBang commented on code in PR #719:
URL: https://github.com/apache/flink-web/pull/719#discussion_r1470484027
##
docs/data/flink_connectors.yml:
##
@@ -93,8 +93,8 @@ rabbitmq:
compatibility: ["1.16.x", "1.17.x"]
mongodb:
- name: "Apache Flink MongoDB Connector
[
https://issues.apache.org/jira/browse/FLINK-34103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-34103.
--
Fix Version/s: 1.19.0
Resolution: Fixed
master(1.19):
reswqa merged PR #24207:
URL: https://github.com/apache/flink/pull/24207
--
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-34059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812101#comment-17812101
]
Jane Chan commented on FLINK-34059:
---
Fixed in master a1200ff6ad78146076a5d3b304abd383f1677c29
> Add
[
https://issues.apache.org/jira/browse/FLINK-34059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan closed FLINK-34059.
-
> Add documentation on how to use state TTL hint
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-33397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan closed FLINK-33397.
-
> FLIP-373: Support Configuring Different State TTLs using SQL Hint
>
[
https://issues.apache.org/jira/browse/FLINK-33397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan resolved FLINK-33397.
---
Resolution: Fixed
> FLIP-373: Support Configuring Different State TTLs using SQL Hint
>
[
https://issues.apache.org/jira/browse/FLINK-34059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan resolved FLINK-34059.
---
Fix Version/s: 1.19.0
Resolution: Fixed
> Add documentation on how to use state TTL hint
>
[
https://issues.apache.org/jira/browse/FLINK-34053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan closed FLINK-34053.
-
> Support state TTL hint for group aggregate
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-34053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812100#comment-17812100
]
Jane Chan commented on FLINK-34053:
---
Fixed in master f32b2a9e347d7539819a88252e4e32deba247515
>
[
https://issues.apache.org/jira/browse/FLINK-34053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan resolved FLINK-34053.
---
Fix Version/s: 1.19.0
Resolution: Fixed
> Support state TTL hint for group aggregate
>
LadyForest merged PR #24198:
URL: https://github.com/apache/flink/pull/24198
--
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:
LadyForest merged PR #24179:
URL: https://github.com/apache/flink/pull/24179
--
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:
snuyanzin commented on code in PR #24139:
URL: https://github.com/apache/flink/pull/24139#discussion_r1470450435
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkLimit0RemoveRule.java:
##
@@ -0,0 +1,70 @@
+/*
+ * Licensed
snuyanzin commented on code in PR #24139:
URL: https://github.com/apache/flink/pull/24139#discussion_r1470438555
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkLimit0RemoveRule.java:
##
@@ -0,0 +1,70 @@
+/*
+ * Licensed
snuyanzin commented on code in PR #24140:
URL: https://github.com/apache/flink/pull/24140#discussion_r1470433205
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/WindowAggregateReduceFunctionsRule.java:
##
@@ -0,0 +1,90 @@
+/*
+
snuyanzin commented on code in PR #24140:
URL: https://github.com/apache/flink/pull/24140#discussion_r1470432426
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/WindowAggregateReduceFunctionsRule.java:
##
@@ -0,0 +1,90 @@
+/*
+
snuyanzin commented on code in PR #24140:
URL: https://github.com/apache/flink/pull/24140#discussion_r1470432177
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/rules/FlinkBatchRuleSets.scala:
##
@@ -268,7 +268,7 @@ object
jnh5y commented on code in PR #24155:
URL: https://github.com/apache/flink/pull/24155#discussion_r1470425266
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/CatalogTable.java:
##
@@ -82,7 +85,29 @@ static CatalogTable of(
List
jnh5y commented on code in PR #24155:
URL: https://github.com/apache/flink/pull/24155#discussion_r1470423299
##
flink-table/flink-sql-parser/src/main/codegen/data/Parser.tdd:
##
@@ -520,6 +526,7 @@
# Please keep the keyword in alphabetical order if new keyword is added.
jnh5y commented on code in PR #24155:
URL: https://github.com/apache/flink/pull/24155#discussion_r1470422724
##
flink-table/flink-sql-parser/src/main/codegen/data/Parser.tdd:
##
@@ -147,11 +149,14 @@
"COMPILE"
"COLUMNS"
"DATABASES"
+"DISTRIBUTED"
+
snuyanzin commented on PR #19873:
URL: https://github.com/apache/flink/pull/19873#issuecomment-1915823827
@MartijnVisser since there is a feature freeze do you think it makes sense
to add it in 1.19?
Otherwise I'm going to add it when a new release starts
--
This is an automated
snuyanzin commented on code in PR #136:
URL: https://github.com/apache/flink-shaded/pull/136#discussion_r1470407309
##
pom.xml:
##
@@ -65,6 +65,7 @@ under the License.
4.1.100.Final
2.15.3
32.1.3-jre
+true
Review Comment:
yep, sure
[
https://issues.apache.org/jira/browse/FLINK-34269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-34269:
Description: Currently every module uses it's own version
> Sync maven-shade-plugin
Sergey Nuyanzin created FLINK-34269:
---
Summary: Sync maven-shade-plugin across modules in flink-shaded
Key: FLINK-34269
URL: https://issues.apache.org/jira/browse/FLINK-34269
Project: Flink
flinkbot commented on PR #24219:
URL: https://github.com/apache/flink/pull/24219#issuecomment-1915813265
## CI report:
* 3c4ff603e348c1fc4b728afe8b684c174bf55d2e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
mas-chen commented on code in PR #76:
URL:
https://github.com/apache/flink-connector-kafka/pull/76#discussion_r1470402476
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java:
##
@@ -350,6 +352,26 @@ public KafkaSourceBuilder
[
https://issues.apache.org/jira/browse/FLINK-34268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34268:
---
Labels: pull-request-available (was: )
> Add a test to verify if restore test exists for
bvarghese1 opened a new pull request, #24219:
URL: https://github.com/apache/flink/pull/24219
## What is the purpose of the change
*Add a test to verify if restore test exists for ExecNode. This is as part
of the Restore test completeness*
## Verifying this change
Bonnie Varghese created FLINK-34268:
---
Summary: Add a test to verify if restore test exists for ExecNode
Key: FLINK-34268
URL: https://issues.apache.org/jira/browse/FLINK-34268
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-34252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812081#comment-17812081
]
David Christle edited comment on FLINK-34252 at 1/29/24 11:12 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-34252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812081#comment-17812081
]
David Christle edited comment on FLINK-34252 at 1/29/24 11:11 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-34252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812081#comment-17812081
]
David Christle edited comment on FLINK-34252 at 1/29/24 11:08 PM:
--
1 - 100 of 243 matches
Mail list logo
