zhuzhurk commented on code in PR #24194:
URL: https://github.com/apache/flink/pull/24194#discussion_r1466072601
##
flink-dist/src/main/flink-bin/bin/config-parser-utils.sh:
##
@@ -23,6 +23,42 @@ if [ "$#" -lt 3 ]; then
echo "$USAGE"
exit 1
fi
+
[
https://issues.apache.org/jira/browse/FLINK-34048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810771#comment-17810771
]
dalongliu commented on FLINK-34048:
---
Merged in master: de7322112cbf594ae4b74163b5e58892e6cdf4ca
>
[
https://issues.apache.org/jira/browse/FLINK-34048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu resolved FLINK-34048.
---
Fix Version/s: 1.19.0
Resolution: Fixed
> Support session window agg in table runtime
[
https://issues.apache.org/jira/browse/FLINK-34048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu reassigned FLINK-34048:
-
Assignee: xuyang
> Support session window agg in table runtime instead of using legacy group
reswqa commented on code in PR #24193:
URL: https://github.com/apache/flink/pull/24193#discussion_r1466089942
##
flink-core/src/main/java/org/apache/flink/api/common/serialization/SerializerConfig.java:
##
@@ -185,16 +205,25 @@ public void registerPojoType(Class type) {
*
[
https://issues.apache.org/jira/browse/FLINK-34206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810799#comment-17810799
]
Matthias Pohl commented on FLINK-34206:
---
I'm not able to pinpoint the cause of this test failure.
[
https://issues.apache.org/jira/browse/FLINK-34233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810801#comment-17810801
]
Matthias Pohl commented on FLINK-34233:
---
[
https://issues.apache.org/jira/browse/FLINK-34218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl closed FLINK-34218.
-
Resolution: Duplicate
I'm gonna close this issue in favor of FLINK-34200. There are two other
[
https://issues.apache.org/jira/browse/FLINK-34200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810818#comment-17810818
]
Matthias Pohl commented on FLINK-34200:
---
Copied over from FLINK-34218:
[
https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810827#comment-17810827
]
Matthias Pohl commented on FLINK-28440:
---
1.18:
[
https://issues.apache.org/jira/browse/FLINK-22765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810832#comment-17810832
]
Matthias Pohl commented on FLINK-22765:
---
flinkbot commented on PR #24195:
URL: https://github.com/apache/flink/pull/24195#issuecomment-1910007779
## CI report:
* 8f961e6a303b035426ada6374c14cf952cebde27 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
snuyanzin commented on code in PR #136:
URL: https://github.com/apache/flink-shaded/pull/136#discussion_r1466287619
##
.github/workflows/ci.yml:
##
@@ -49,8 +50,18 @@ jobs:
-Plicense-check \
| tee ${{ env.MVN_BUILD_OUTPUT_FILE }}
+ mvn
JunRuiLee commented on PR #24185:
URL: https://github.com/apache/flink/pull/24185#issuecomment-1910097113
Squashed this PR and rebased it onto
https://github.com/apache/flink/pull/24194 to includes the latest fixes.
--
This is an automated message from the Apache Git Service.
To respond
luoyuxia merged PR #24192:
URL: https://github.com/apache/flink/pull/24192
--
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-34220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu resolved FLINK-34220.
---
Assignee: Shuai Xu
Resolution: Fixed
> introduce buffer bundle for minibatch join
>
[
https://issues.apache.org/jira/browse/FLINK-34219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu reassigned FLINK-34219:
-
Assignee: Shuai Xu
> Introduce a new join operator to support minibatch
>
[
https://issues.apache.org/jira/browse/FLINK-32074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan reassigned FLINK-32074:
---
Assignee: Zakelly Lan (was: Han Yin)
> Support file merging across checkpoints
>
slankka commented on PR #24037:
URL: https://github.com/apache/flink/pull/24037#issuecomment-1909782465
https://issues.apache.org/jira/browse/FLINK-33997
Closed for duplicates.
https://github.com/apache/flink/pull/24052
--
This is an automated message from the Apache Git
slankka closed pull request #24037: [hotfix][docs] fix typo in classloading
option in Debugging Classloading
URL: https://github.com/apache/flink/pull/24037
--
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
[
https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810811#comment-17810811
]
Matthias Pohl commented on FLINK-34202:
---
[
https://issues.apache.org/jira/browse/FLINK-26644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810831#comment-17810831
]
Matthias Pohl edited comment on FLINK-26644 at 1/25/24 11:02 AM:
-
Twice
zhuzhurk commented on code in PR #24185:
URL: https://github.com/apache/flink/pull/24185#discussion_r1466215828
##
flink-core/src/main/java/org/apache/flink/api/common/cache/DistributedCache.java:
##
@@ -244,6 +244,21 @@ public static List parseStringFromCachedFiles(
JunRuiLee commented on PR #24177:
URL: https://github.com/apache/flink/pull/24177#issuecomment-1910014658
Thanks @HuangXingBo for reviews, I've updated this pr follow your comments,
PTAL.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
snuyanzin commented on code in PR #136:
URL: https://github.com/apache/flink-shaded/pull/136#discussion_r1466288220
##
flink-shaded-asm-9/pom.xml:
##
@@ -43,24 +43,28 @@ under the License.
org.ow2.asm
asm
${asm.version}
+
[
https://issues.apache.org/jira/browse/FLINK-34234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34234:
---
Labels: pull-request-available (was: )
> Apply ShadeOptionalChecker for flink-shaded
>
fsk119 merged PR #24106:
URL: https://github.com/apache/flink/pull/24106
--
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:
XComp commented on code in PR #136:
URL: https://github.com/apache/flink-shaded/pull/136#discussion_r1466310753
##
.github/workflows/ci.yml:
##
@@ -49,8 +50,18 @@ jobs:
-Plicense-check \
| tee ${{ env.MVN_BUILD_OUTPUT_FILE }}
+ mvn
davidradl commented on PR #79:
URL:
https://github.com/apache/flink-connector-jdbc/pull/79#issuecomment-1909799398
@snuyanzin @libenchao I have squashed the commit. Thank you both for all
your help and support on this. Are you OK to merge?
--
This is an automated message from the
[
https://issues.apache.org/jira/browse/FLINK-34206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-34206:
--
Priority: Blocker (was: Critical)
> CacheITCase.testRetryOnCorruptedClusterDataset(Path)
[
https://issues.apache.org/jira/browse/FLINK-34206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810812#comment-17810812
]
Matthias Pohl edited comment on FLINK-34206 at 1/25/24 10:42 AM:
-
Same
[
https://issues.apache.org/jira/browse/FLINK-34206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810812#comment-17810812
]
Matthias Pohl commented on FLINK-34206:
---
[
https://issues.apache.org/jira/browse/FLINK-26644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810836#comment-17810836
]
Matthias Pohl commented on FLINK-26644:
---
xishuaidelin commented on code in PR #24161:
URL: https://github.com/apache/flink/pull/24161#discussion_r1466230805
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/JoinUtil.scala:
##
@@ -95,6 +105,18 @@ object JoinUtil {
}
}
xuyangzhong commented on code in PR #24162:
URL: https://github.com/apache/flink/pull/24162#discussion_r1466230991
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecWindowTableFunction.java:
##
@@ -103,4 +111,67 @@
zhuzhurk commented on code in PR #24185:
URL: https://github.com/apache/flink/pull/24185#discussion_r1466251588
##
flink-dist/src/main/flink-bin/bin/migrate-config-file.sh:
##
@@ -0,0 +1,65 @@
+#!/usr/bin/env bash
snuyanzin commented on PR #79:
URL:
https://github.com/apache/flink-connector-jdbc/pull/79#issuecomment-1910277677
yes, backport would make sense, i guess it could be cherry-picked
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/FLINK-34206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810805#comment-17810805
]
Matthias Pohl commented on FLINK-34206:
---
[
https://issues.apache.org/jira/browse/FLINK-26644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810831#comment-17810831
]
Matthias Pohl commented on FLINK-26644:
---
xuyangzhong commented on code in PR #24162:
URL: https://github.com/apache/flink/pull/24162#discussion_r1466223510
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/window/tvf/operator/WindowTableFunctionOperatorBase.java:
##
@@ -91,28
davidradl commented on PR #79:
URL:
https://github.com/apache/flink-connector-jdbc/pull/79#issuecomment-1909958760
> for future: it is better not to squash commits unless it was requested
explicitely by reviewer. The reason is that since there is no tool in GitHub
confirming that the set
xuyangzhong commented on code in PR #24162:
URL: https://github.com/apache/flink/pull/24162#discussion_r1466235244
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/aggregate/window/WindowAggOperatorBuilder.java:
##
@@ -170,4 +202,17 @@
xuyang created FLINK-34235:
--
Summary: Not using Optional as input arguments in
QueryHintsResolver
Key: FLINK-34235
URL: https://issues.apache.org/jira/browse/FLINK-34235
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-21126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810859#comment-17810859
]
Junrui Li commented on FLINK-21126:
---
After reviewing the considerations for deprecating the
[
https://issues.apache.org/jira/browse/FLINK-34206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810860#comment-17810860
]
lincoln lee commented on FLINK-34206:
-
[~xiasun] Can you take a look at this? The stack trace seems
xuyangzhong commented on code in PR #24179:
URL: https://github.com/apache/flink/pull/24179#discussion_r1466284522
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/optimize/QueryHintsResolver.java:
##
@@ -83,21 +85,50 @@ final List
X-czh commented on PR #24129:
URL: https://github.com/apache/flink/pull/24129#issuecomment-1910213715
Thanks for the contribution. LGTM
--
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
reswqa commented on code in PR #24187:
URL: https://github.com/apache/flink/pull/24187#discussion_r1466393637
##
flink-core/src/main/java/org/apache/flink/api/common/state/StateDescriptor.java:
##
@@ -320,7 +320,10 @@ public void initializeSerializerUnlessSet(ExecutionConfig
davidradl commented on PR #79:
URL:
https://github.com/apache/flink-connector-jdbc/pull/79#issuecomment-1910329090
> yes, backport would make sense, i guess it could be cherry-picked
@snuyanzin once this pr is merged - I assume I raise a second pr against
this issue, would you be ok
[
https://issues.apache.org/jira/browse/FLINK-34232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34232:
---
Labels: pull-request-available (was: )
> Config file unexpectedly lacks support for
[
https://issues.apache.org/jira/browse/FLINK-34115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810802#comment-17810802
]
Matthias Pohl commented on FLINK-34115:
---
1.18 build that didn't include the fix, yet:
JunRuiLee commented on PR #24194:
URL: https://github.com/apache/flink/pull/24194#issuecomment-1909862013
Thanks @zhuzhurk for reviews, I've updated this pr follow your comment, PTAL.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17809780#comment-17809780
]
Matthias Pohl edited comment on FLINK-34202 at 1/25/24 10:48 AM:
-
1.18:
[
https://issues.apache.org/jira/browse/FLINK-34206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810820#comment-17810820
]
Matthias Pohl commented on FLINK-34206:
---
[
https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17809774#comment-17809774
]
Matthias Pohl edited comment on FLINK-34202 at 1/25/24 10:48 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-34117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810848#comment-17810848
]
Alexander Fedulov commented on FLINK-34117:
---
[~leonard] thanks! Here is the backport PR
JunRuiLee commented on PR #24185:
URL: https://github.com/apache/flink/pull/24185#issuecomment-1910041516
Thanks @zhuzhurk for reviews, I've updated this pr. PTAL
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
xuyangzhong commented on code in PR #24179:
URL: https://github.com/apache/flink/pull/24179#discussion_r1466282357
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/hint/FlinkHints.java:
##
@@ -52,10 +52,13 @@ public abstract class FlinkHints {
[
https://issues.apache.org/jira/browse/FLINK-33856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810877#comment-17810877
]
Jufang He commented on FLINK-33856:
---
[~martijnvisser] I tried to signup for
[
https://issues.apache.org/jira/browse/FLINK-34220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810773#comment-17810773
]
dalongliu commented on FLINK-34220:
---
Merged in master: 1bf27c6362413709226cd5d6f3dc5ae9223cc37c
>
[
https://issues.apache.org/jira/browse/FLINK-34222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuai Xu updated FLINK-34222:
-
Description: Get minibatch join operator involved in which includes both
plan and operator. Implement
[
https://issues.apache.org/jira/browse/FLINK-33856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810783#comment-17810783
]
Jufang He commented on FLINK-33856:
---
[~pnowojski] I wrote a draft of a flip, but found I didn't have
[
https://issues.apache.org/jira/browse/FLINK-34206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810786#comment-17810786
]
Matthias Pohl commented on FLINK-34206:
---
[
https://issues.apache.org/jira/browse/FLINK-34115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reopened FLINK-34115:
---
[~qingyue]
Unfortunately, the following build is based on
jiangxin369 commented on code in PR #23851:
URL: https://github.com/apache/flink/pull/23851#discussion_r1466154957
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/TieredStorageMemoryManagerImpl.java:
##
@@ -335,19 +338,21 @@
[
https://issues.apache.org/jira/browse/FLINK-33186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810806#comment-17810806
]
Matthias Pohl commented on FLINK-33186:
---
[
https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810819#comment-17810819
]
Matthias Pohl commented on FLINK-34202:
---
[
https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810819#comment-17810819
]
Matthias Pohl edited comment on FLINK-34202 at 1/25/24 10:47 AM:
-
1.17:
[
https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810811#comment-17810811
]
Matthias Pohl edited comment on FLINK-34202 at 1/25/24 10:47 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-34202:
--
Affects Version/s: 1.19.0
> python tests take suspiciously long in some of the cases
>
[
https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-34202:
--
Affects Version/s: 1.17.2
> python tests take suspiciously long in some of the cases
>
SinBex commented on PR #24186:
URL: https://github.com/apache/flink/pull/24186#issuecomment-1909902429
@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.
[
https://issues.apache.org/jira/browse/FLINK-33595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810826#comment-17810826
]
Matthias Pohl commented on FLINK-33595:
---
nicusX commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-prometheus/pull/1#discussion_r1466256133
##
prometheus-connector/src/main/java/org/apache/flink/connector/prometheus/sink/PrometheusRemoteWriteHttpRequestBuilder.java:
##
@@ -0,0 +1,70 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-34055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang reassigned FLINK-34055:
-
Assignee: Feng Jin
> Introduce a new annotation for named parameters
>
[
https://issues.apache.org/jira/browse/FLINK-34234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-34234:
--
Priority: Blocker (was: Major)
> Apply ShadeOptionalChecker for flink-shaded
>
[
https://issues.apache.org/jira/browse/FLINK-34055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810863#comment-17810863
]
Shengkai Fang commented on FLINK-34055:
---
Merged into master:
snuyanzin commented on code in PR #136:
URL: https://github.com/apache/flink-shaded/pull/136#discussion_r1466289100
##
pom.xml:
##
@@ -341,21 +342,41 @@ under the License.
java
+
+
reswqa commented on code in PR #24129:
URL: https://github.com/apache/flink/pull/24129#discussion_r1466302040
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/DataTypeFactoryImpl.java:
##
@@ -141,6 +141,16 @@ private static Supplier
xuyangzhong commented on code in PR #24179:
URL: https://github.com/apache/flink/pull/24179#discussion_r1466314159
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/hint/StateTtlHint.java:
##
@@ -87,4 +91,28 @@ public static Map
xuyangzhong commented on code in PR #24179:
URL: https://github.com/apache/flink/pull/24179#discussion_r1466324477
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamPhysicalGlobalGroupAggregate.scala:
##
@@ -123,6
[
https://issues.apache.org/jira/browse/FLINK-34236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge reassigned FLINK-34236:
---
Assignee: Jeyhun Karimov
> Evaluate strange unstable build after cleaning up CI machines
>
[
https://issues.apache.org/jira/browse/FLINK-34209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-34209.
--
Fix Version/s: 1.19.0
Assignee: Peter Vary
Resolution: Fixed
merged to master
lsyldliu closed pull request #24150: [FLINK-34048][table] Support session
window agg in table runtime instead of using legacy group window agg op
URL: https://github.com/apache/flink/pull/24150
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
[
https://issues.apache.org/jira/browse/FLINK-32080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan reassigned FLINK-32080:
---
Assignee: Jinzhong Li (was: Zakelly Lan)
> Restoration of FileMergingSnapshotManager
>
[
https://issues.apache.org/jira/browse/FLINK-33856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810785#comment-17810785
]
Martijn Visser commented on FLINK-33856:
[~hejufang001] What's your Confluence ID? I'll add you
[
https://issues.apache.org/jira/browse/FLINK-18476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810784#comment-17810784
]
Matthias Pohl commented on FLINK-18476:
---
[
https://issues.apache.org/jira/browse/FLINK-33186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810247#comment-17810247
]
Matthias Pohl edited comment on FLINK-33186 at 1/25/24 10:40 AM:
-
1.18:
[
https://issues.apache.org/jira/browse/FLINK-33186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810247#comment-17810247
]
Matthias Pohl edited comment on FLINK-33186 at 1/25/24 10:40 AM:
-
1.18:
[
https://issues.apache.org/jira/browse/FLINK-33186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-33186:
--
Affects Version/s: 1.18.1
>
[
https://issues.apache.org/jira/browse/FLINK-31472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810822#comment-17810822
]
Matthias Pohl commented on FLINK-31472:
---
1.18:
[
https://issues.apache.org/jira/browse/FLINK-34225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810828#comment-17810828
]
Matthias Pohl commented on FLINK-34225:
---
[
https://issues.apache.org/jira/browse/FLINK-34229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810847#comment-17810847
]
dalongliu commented on FLINK-34229:
---
[~xiasun]Thanks for double-checking. [~FrankZou] Can you help to
afedulov opened a new pull request, #24195:
URL: https://github.com/apache/flink/pull/24195
`CompactCoordinator` accumulates data in `currentInputFiles` and only rolls
them into `inputFiles` when `snapshotState()` gets called. At the same time it
relies on separately receiving checkpoint
nicusX commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-prometheus/pull/1#discussion_r1466268497
##
prometheus-connector/src/main/java/org/apache/flink/connector/prometheus/sink/PrometheusSinkBuilder.java:
##
@@ -0,0 +1,203 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-34229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810856#comment-17810856
]
Zhu Zhu commented on FLINK-34229:
-
[~FrankZou] the query plan can be different between q35 of
Sergey Nuyanzin created FLINK-34234:
---
Summary: Apply ShadeOptionalChecker for flink-shaded
Key: FLINK-34234
URL: https://issues.apache.org/jira/browse/FLINK-34234
Project: Flink
Issue
X-czh commented on code in PR #24187:
URL: https://github.com/apache/flink/pull/24187#discussion_r1466307183
##
tools/ci/test_controller.sh:
##
@@ -105,7 +105,7 @@ if [ $STAGE == $STAGE_PYTHON ]; then
run_with_watchdog "./flink-python/dev/lint-python.sh"
snuyanzin commented on code in PR #136:
URL: https://github.com/apache/flink-shaded/pull/136#discussion_r1466332128
##
pom.xml:
##
@@ -341,21 +341,41 @@ under the License.
java
+
+
xuyangzhong commented on code in PR #24179:
URL: https://github.com/apache/flink/pull/24179#discussion_r1466362809
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/optimize/QueryHintsResolver.java:
##
@@ -83,21 +85,50 @@ final List
1 - 100 of 305 matches
Mail list logo
