[
https://issues.apache.org/jira/browse/FLINK-34128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807694#comment-17807694
]
blackpighe commented on FLINK-34128:
[~martijnvisser] this test case is not pass，Thi
swuferhong commented on PR #24096:
URL: https://github.com/apache/flink/pull/24096#issuecomment-1895584274
@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-34121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-34121:
--
Affects Version/s: 2.0.0
(was: 1.19.0)
Summary: 2.0: I
[
https://issues.apache.org/jira/browse/FLINK-34121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-34121:
--
Summary: Flink 2.0: Introduce pipeline.force-kryo-avro to control whether
to force registratio
flinkbot commented on PR #24116:
URL: https://github.com/apache/flink/pull/24116#issuecomment-1895565951
## CI report:
* d1ca86e4935685416b3df92b78906b23742b2f96 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-34098:
--
Description: CI takes longer than usual. There might be an issue with the
runner pool (on the
[
https://issues.apache.org/jira/browse/FLINK-34098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-34098:
--
Description: CI takes longer than usual. There might be an issue with the
amount of runners (o
[
https://issues.apache.org/jira/browse/FLINK-33998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807687#comment-17807687
]
Matthias Pohl edited comment on FLINK-33998 at 1/17/24 10:49 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-33998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-33998.
---
Resolution: Not A Problem
Unfortunately, I don't have the capacity to help you with the inve
jiangxin369 commented on code in PR #24082:
URL: https://github.com/apache/flink/pull/24082#discussion_r1455228971
##
tools/azure-pipelines/build-apache-repo.yml:
##
@@ -73,6 +73,17 @@ stages:
run_end_to_end: false
container: flink-build-container
MartijnVisser commented on PR #79:
URL:
https://github.com/apache/flink-connector-kafka/pull/79#issuecomment-1895549968
> Can we put this under the original JIRA issue? I think that should be ok
since we haven't release in the meantime.
Yeah that makes sense for me too, as a follow-u
1996fanrui opened a new pull request, #24116:
URL: https://github.com/apache/flink/pull/24116
## What is the purpose of the change
[FLINK-34080](https://issues.apache.org/jira/browse/FLINK-34080) deprecate
some methods of Configuration, we should refactor all callers of deprecated
me
[
https://issues.apache.org/jira/browse/FLINK-34081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34081:
---
Labels: pull-request-available (was: )
> Refactor all callers that using the public Xxx get
XComp commented on code in PR #24003:
URL: https://github.com/apache/flink/pull/24003#discussion_r1455102444
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/exceptionhistory/RootExceptionHistoryEntry.java:
##
@@ -170,11 +176,15 @@ public RootExceptionHistoryEnt
davidradl commented on PR #79:
URL:
https://github.com/apache/flink-connector-jdbc/pull/79#issuecomment-1895544871
@libenchao cloned your repo. I like the idea behind this fix, avoiding
String manipulation. I added in all the table plan junits from the pr 79 and
they work. The junit testi
[
https://issues.apache.org/jira/browse/FLINK-34128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-34128:
---
Fix Version/s: (was: jdbc-3.0.0)
(was: jdbc-3.1.1)
> oracle jdbc
Jiabao-Sun commented on code in PR #23411:
URL: https://github.com/apache/flink/pull/23411#discussion_r1455187450
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/ArrayAggFunctionITCase.java:
##
@@ -0,0 +1,95 @@
+/*
+ * Licensed to the Ap
Sxnan commented on PR #24088:
URL: https://github.com/apache/flink/pull/24088#issuecomment-1895529022
@1996fanrui Thanks for the update. 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
mxm commented on PR #79:
URL:
https://github.com/apache/flink-connector-kafka/pull/79#issuecomment-1895529046
Can we put this under the original JIRA issue? I think that should be ok
since we haven't release in the meantime.
--
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/FLINK-33735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-33735:
Release Note: Flink 1.19 makes a series of improvements to
exponential-delay restart-strategy, including:
Jiabao-Sun commented on code in PR #23411:
URL: https://github.com/apache/flink/pull/23411#discussion_r1455190307
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/ArrayAggFunctionITCase.java:
##
@@ -0,0 +1,95 @@
+/*
+ * Licensed to the Ap
Jiabao-Sun commented on code in PR #23411:
URL: https://github.com/apache/flink/pull/23411#discussion_r1455187450
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/ArrayAggFunctionITCase.java:
##
@@ -0,0 +1,95 @@
+/*
+ * Licensed to the Ap
[
https://issues.apache.org/jira/browse/FLINK-33865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807675#comment-17807675
]
Rui Fan edited comment on FLINK-33865 at 1/17/24 10:17 AM:
---
FL
[
https://issues.apache.org/jira/browse/FLINK-33865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807675#comment-17807675
]
Rui Fan commented on FLINK-33865:
-
FLINK-33980 fixed this bug: attempts doesn't take eff
MartijnVisser commented on PR #70:
URL:
https://github.com/apache/flink-connector-kafka/pull/70#issuecomment-1895500575
@hhktseng Can you rebase your PR?
--
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 t
flinkbot commented on PR #24115:
URL: https://github.com/apache/flink/pull/24115#issuecomment-1895494968
## CI report:
* eb2969bc8b6265550fbcb22a0b96d60d88f884e1 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
pnowojski commented on code in PR #24072:
URL: https://github.com/apache/flink/pull/24072#discussion_r1455150026
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBConfigurableOptions.java:
##
@@ -149,24 +144,42 @@ pu
[
https://issues.apache.org/jira/browse/FLINK-34132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prabhu Joseph updated FLINK-34132:
--
Description:
Batch WordCount job fails when run with AdaptiveBatch scheduler.
*Repro Steps*
{
caodizhou opened a new pull request, #24115:
URL: https://github.com/apache/flink/pull/24115
…thread pool
## 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 r
[
https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807671#comment-17807671
]
Martijn Visser commented on FLINK-31275:
Looking at the discussions happening he
pnowojski commented on code in PR #24072:
URL: https://github.com/apache/flink/pull/24072#discussion_r1455138026
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBConfigurableOptions.java:
##
@@ -139,6 +149,25 @@ pub
Nicolas Fraison created FLINK-34131:
---
Summary: Checkpoint check window should take in account checkpoint
job configuration
Key: FLINK-34131
URL: https://issues.apache.org/jira/browse/FLINK-34131
Pro
MartijnVisser commented on PR #36:
URL:
https://github.com/apache/flink-connector-hbase/pull/36#issuecomment-1895471345
> So I think is better to have a discussion on this topic in the dev mailing
list.
+1
--
This is an automated message from the Apache Git Service.
To respond to
Prabhu Joseph created FLINK-34132:
-
Summary: Batch WordCount job fails when run with AdaptiveBatch
scheduler
Key: FLINK-34132
URL: https://issues.apache.org/jira/browse/FLINK-34132
Project: Flink
MartijnVisser commented on PR #79:
URL:
https://github.com/apache/flink-connector-kafka/pull/79#issuecomment-1895470098
The only thing I'm wondering about is that we actually should file a Jira
for this; otherwise LGTM
--
This is an automated message from the Apache Git Service.
To respo
mayuehappy commented on code in PR #24072:
URL: https://github.com/apache/flink/pull/24072#discussion_r1455112632
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBConfigurableOptions.java:
##
@@ -139,6 +149,25 @@ pu
dmvk commented on PR #24079:
URL: https://github.com/apache/flink/pull/24079#issuecomment-1895445564
There might actually be something more fancy going on, need to read up on it
at some point :D https://en.wikipedia.org/wiki/Snappy_(compression)
--
This is an automated message from the Ap
XComp commented on code in PR #22931:
URL: https://github.com/apache/flink/pull/22931#discussion_r1455086469
##
flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinatorHolder.java:
##
@@ -143,12 +144,14 @@ private OperatorCoordinatorHolder(
dmvk commented on PR #24079:
URL: https://github.com/apache/flink/pull/24079#issuecomment-1895414707
> it also solves the the compressed representation might actually end up
being bigger than uncompressed one problem.
Not completely, since we're doing per-value compression for list s
davidradl commented on PR #79:
URL:
https://github.com/apache/flink-connector-jdbc/pull/79#issuecomment-1895411935
> @davidradl @snuyanzin I did a POC of the idea proposed above, the branch
is here:
https://github.com/libenchao/flink-connector-jdbc/tree/pushdown-predidates-to-lookup-functi
zentol commented on code in PR #23970:
URL: https://github.com/apache/flink/pull/23970#discussion_r1455049190
##
tools/ci/maven-utils.sh:
##
@@ -17,6 +17,7 @@
# Utility for invoking Maven in CI
function run_mvn {
if [[ "$MVN_RUN_VERBOSE" != "false" ]]; then
+ $
[
https://issues.apache.org/jira/browse/FLINK-34097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-34097.
Resolution: Fixed
master: 1ffb48f658b699702357921a48e914d13caf
> Remove unused JobMas
zentol merged PR #24097:
URL: https://github.com/apache/flink/pull/24097
--
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
1996fanrui commented on code in PR #23635:
URL: https://github.com/apache/flink/pull/23635#discussion_r1455029438
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/loading/LoadingWeight.java:
##
@@ -0,0 +1,69 @@
+/*
+ * Licensed to the Apache Software Foundation
1996fanrui commented on code in PR #23635:
URL: https://github.com/apache/flink/pull/23635#discussion_r1455025025
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/loading/LoadingWeight.java:
##
@@ -0,0 +1,69 @@
+/*
+ * Licensed to the Apache Software Foundation
RocMarshal commented on code in PR #23635:
URL: https://github.com/apache/flink/pull/23635#discussion_r1455014315
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/loading/LoadingWeight.java:
##
@@ -0,0 +1,69 @@
+/*
+ * Licensed to the Apache Software Foundation
1996fanrui commented on code in PR #24088:
URL: https://github.com/apache/flink/pull/24088#discussion_r1455012446
##
flink-core/src/main/java/org/apache/flink/configuration/Configuration.java:
##
Review Comment:
I created FLINK-34130 to follow it.
--
This is an automate
Rui Fan created FLINK-34130:
---
Summary: Mark setBytes and getBytes of Configuration as @Internal
Key: FLINK-34130
URL: https://issues.apache.org/jira/browse/FLINK-34130
Project: Flink
Issue Type: S
[
https://issues.apache.org/jira/browse/FLINK-34129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-34129:
--
Description:
Take sum for example:
When state is expired, then an update operation from source
[
https://issues.apache.org/jira/browse/FLINK-34129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-34129:
--
Description:
Take sum for example:
When state is expired, then an update operation from source
[
https://issues.apache.org/jira/browse/FLINK-34129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-34129:
--
Issue Type: Bug (was: Improvement)
> MiniBatchGlobalGroupAggFunction will make -D as +I then
Sxnan commented on code in PR #24089:
URL: https://github.com/apache/flink/pull/24089#discussion_r1454983956
##
flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java:
##
@@ -496,7 +503,12 @@ public final class ConfigConstants {
*/
@Deprecated pu
[
https://issues.apache.org/jira/browse/FLINK-34129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-34129:
--
Summary: MiniBatchGlobalGroupAggFunction will make -D as +I then make +I as
-U when state expi
[
https://issues.apache.org/jira/browse/FLINK-34084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-34084.
Resolution: Done
master (1.19): 4559b851b22d6ffa197aa311adbea15b21a43c66
> Deprecate unused confi
Hongshun Wang created FLINK-34129:
-
Summary: correct writing: MiniBatchGlobalGroupAggFunction will
make -D as +I then make +I as -U when state expired
Key: FLINK-34129
URL: https://issues.apache.org/jira/browse/F
xintongsong closed pull request #24090: [FLINK-34084][config] Deprecate unused
configuration in BinaryInput/OutputFormat and FileInput/OutputFormat
URL: https://github.com/apache/flink/pull/24090
--
This is an automated message from the Apache Git Service.
To respond to the message, please lo
Sxnan commented on code in PR #24088:
URL: https://github.com/apache/flink/pull/24088#discussion_r1454945796
##
flink-core/src/main/java/org/apache/flink/configuration/Configuration.java:
##
Review Comment:
That makes sense. However,
[FLINK-34082](https://issues.apache.org
[
https://issues.apache.org/jira/browse/FLINK-34098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge reassigned FLINK-34098:
---
Assignee: Jeyhun Karimov
> Not enough Azure Pipeline CI runners available?
> --
1996fanrui commented on code in PR #23635:
URL: https://github.com/apache/flink/pull/23635#discussion_r1454932673
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/loading/LoadingWeight.java:
##
@@ -0,0 +1,69 @@
+/*
+ * Licensed to the Apache Software Foundation
zhilinli123 commented on PR #87:
URL:
https://github.com/apache/flink-connector-jdbc/pull/87#issuecomment-1895310895
PTALA: @libenchao hi, could you please help review this function? I would
like to express my heartfelt thanks
--
This is an automated message from the Apache Git Serv
zhuzhurk commented on code in PR #24087:
URL: https://github.com/apache/flink/pull/24087#discussion_r1453369184
##
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionJobVertex.java:
##
@@ -408,6 +410,27 @@ public Collection
getOperatorCoordinators() {
1996fanrui commented on PR #24003:
URL: https://github.com/apache/flink/pull/24003#issuecomment-1895296744
Hi @XComp , sorry for bother you again due to the 1.19 will be freeze next
week.
--
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-33842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge updated FLINK-33842:
Description:
Note: the official Dockerfiles fetch the binary distribution of the target
Flink version fro
201 - 263 of 263 matches
Mail list logo
