Zhenqiu Huang created FLINK-34007:
-
Summary: Flink Job stuck in suspend state after recovery from
failure in HA Mode
Key: FLINK-34007
URL: https://issues.apache.org/jira/browse/FLINK-34007
Project:
snuyanzin commented on code in PR #79:
URL:
https://github.com/apache/flink-connector-jdbc/pull/79#discussion_r1443547398
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/ParameterizedPredicate.java:
##
@@ -52,8 +69,26 @@ public void
snuyanzin commented on code in PR #79:
URL:
https://github.com/apache/flink-connector-jdbc/pull/79#discussion_r1443523454
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/ParameterizedPredicate.java:
##
@@ -52,8 +69,26 @@ public void
flinkbot commented on PR #24035:
URL: https://github.com/apache/flink/pull/24035#issuecomment-1879438867
## CI report:
* a0672a71f647609a9a4790943070cc56f7da1d10 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33817:
---
Labels: pull-request-available (was: )
> Allow ReadDefaultValues = False for non primitive
sharath1709 opened a new pull request, #24035:
URL: https://github.com/apache/flink/pull/24035
## 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
snuyanzin commented on code in PR #79:
URL:
https://github.com/apache/flink-connector-jdbc/pull/79#discussion_r1443527603
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableSource.java:
##
@@ -94,30 +97,76 @@ public
snuyanzin commented on code in PR #79:
URL:
https://github.com/apache/flink-connector-jdbc/pull/79#discussion_r1443526792
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableSource.java:
##
@@ -94,30 +97,76 @@ public
snuyanzin commented on code in PR #79:
URL:
https://github.com/apache/flink-connector-jdbc/pull/79#discussion_r1443521093
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcFilterPushdownPreparedStatementVisitor.java:
##
@@ -97,12 +147,14 @@
Sophia created FLINK-34006:
--
Summary: Flink terminates the execution of an application when
there is a network problem between TaskManagers
Key: FLINK-34006
URL: https://issues.apache.org/jira/browse/FLINK-34006
rkhachatryan commented on code in PR #24031:
URL: https://github.com/apache/flink/pull/24031#discussion_r1443459209
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/restore/RocksDBIncrementalRestoreOperation.java:
##
@@
rkhachatryan commented on code in PR #24031:
URL: https://github.com/apache/flink/pull/24031#discussion_r1443422130
##
flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksIncrementalCheckpointRescalingTest.java:
##
@@
rkhachatryan commented on code in PR #24031:
URL: https://github.com/apache/flink/pull/24031#discussion_r1443421426
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBIncrementalCheckpointUtils.java:
##
@@ -154,6
rkhachatryan commented on code in PR #24031:
URL: https://github.com/apache/flink/pull/24031#discussion_r1443420860
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/EmbeddedRocksDBStateBackend.java:
##
@@ -305,6 +311,11
jeyhunkarimov commented on PR #24033:
URL: https://github.com/apache/flink/pull/24033#issuecomment-1879333784
@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
sharath1709 commented on PR #23937:
URL: https://github.com/apache/flink/pull/23937#issuecomment-1879310386
@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
jeyhunkarimov commented on PR #24033:
URL: https://github.com/apache/flink/pull/24033#issuecomment-1879308733
@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
flinkbot commented on PR #24034:
URL: https://github.com/apache/flink/pull/24034#issuecomment-1879185905
## CI report:
* a671536a73ceee8b2fb8ec1cef69f342f979cd1e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34005:
---
Labels: pull-request-available (was: )
> Implement restore tests for MiniBatchAssigner
bvarghese1 opened a new pull request, #24034:
URL: https://github.com/apache/flink/pull/24034
## What is the purpose of the change
*Add restore tests for MiniBatchAssigner node*
## Verifying this change
This change added tests and can be verified as follows:
Bonnie Varghese created FLINK-34005:
---
Summary: Implement restore tests for MiniBatchAssigner node
Key: FLINK-34005
URL: https://issues.apache.org/jira/browse/FLINK-34005
Project: Flink
snuyanzin commented on PR #4:
URL:
https://github.com/apache/flink-connector-hive/pull/4#issuecomment-1879126027
superceded by https://github.com/apache/flink-connector-hive/pull/6
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
snuyanzin closed pull request #4: [hotfix] Update NOTICE files to reflect year
2023
URL: https://github.com/apache/flink-connector-hive/pull/4
--
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
snuyanzin commented on PR #86:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/86#issuecomment-1879122467
I submitted a PR to your branch to make it passing tests with jdk17+
https://github.com/MartijnVisser/flink-connector-elasticsearch/pull/3
--
This is an
[
https://issues.apache.org/jira/browse/FLINK-33925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17803629#comment-17803629
]
Peter Schulz edited comment on FLINK-33925 at 1/5/24 5:13 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-33925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17803629#comment-17803629
]
Peter Schulz edited comment on FLINK-33925 at 1/5/24 5:12 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-33925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17803629#comment-17803629
]
Peter Schulz commented on FLINK-33925:
--
[~martijnvisser], this PR seems stuck. I'm not sure how to
[
https://issues.apache.org/jira/browse/FLINK-33996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17803626#comment-17803626
]
Jeyhun Karimov commented on FLINK-33996:
Thanks for reporting the issue [~hackergin] and thanks
flinkbot commented on PR #24033:
URL: https://github.com/apache/flink/pull/24033#issuecomment-1878973201
## CI report:
* d687103dabf6ac2a0af763e8a3b845ef9629c7ba UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33996:
---
Labels: pull-request-available (was: )
> Support disabling project rewrite when multiple
jeyhunkarimov opened a new pull request, #24033:
URL: https://github.com/apache/flink/pull/24033
## What is the purpose of the change
The current optimizer/planner merges two Projection/Calc nodes if they are
deterministic.
In some scenarios, this check is not enough.
[
https://issues.apache.org/jira/browse/FLINK-33775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-33775.
--
Fix Version/s: 1.19.0
Resolution: Fixed
merged commit 793a66b into apache:master
>
[
https://issues.apache.org/jira/browse/FLINK-33695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-33695.
--
Resolution: Fixed
> FLIP-384: Introduce TraceReporter and use it to create checkpointing and
pnowojski merged PR #23908:
URL: https://github.com/apache/flink/pull/23908
--
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:
alpinegizmo commented on PR #23975:
URL: https://github.com/apache/flink/pull/23975#issuecomment-1878877745
We should add appropriate content to the UDF docs as part of implementing
this FLIP.
https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/functions/udfs/
is
[
https://issues.apache.org/jira/browse/FLINK-33978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33978:
---
Labels: pull-request-available (was: )
> FLIP-400: AsyncScalarFunction for asynchronous
twalthr commented on code in PR #23975:
URL: https://github.com/apache/flink/pull/23975#discussion_r1442740953
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/ExecutionConfigOptions.java:
##
@@ -692,6 +734,14 @@ public enum AsyncOutputMode {
flinkbot commented on PR #24032:
URL: https://github.com/apache/flink/pull/24032#issuecomment-1878827522
## CI report:
* 9a8406e252f89c78bcd4c9beb36e967c18a83045 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34004:
---
Labels: pull-request-available (was: )
> TestingCheckpointIDCounter can easily lead to
Chesnay Schepler created FLINK-34004:
Summary: TestingCheckpointIDCounter can easily lead to NPEs
Key: FLINK-34004
URL: https://issues.apache.org/jira/browse/FLINK-34004
Project: Flink
MartijnVisser opened a new pull request, #708:
URL: https://github.com/apache/flink-web/pull/708
(no comment)
--
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-32571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-32571:
---
Fix Version/s: (was: hbase-3.0.1)
> Prebuild HBase testing docker image
>
[
https://issues.apache.org/jira/browse/FLINK-34003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34003:
---
Labels: pull-request-available (was: )
> Bump CI flink version on flink-connector-hbase
>
Martijn Visser created FLINK-34003:
--
Summary: Bump CI flink version on flink-connector-hbase
Key: FLINK-34003
URL: https://issues.apache.org/jira/browse/FLINK-34003
Project: Flink
Issue
flinkbot commented on PR #24031:
URL: https://github.com/apache/flink/pull/24031#issuecomment-1878781250
## CI report:
* 056b9af12d0795dadabde47e50dfb040e14ad71d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
StefanRRichter commented on code in PR #24031:
URL: https://github.com/apache/flink/pull/24031#discussion_r1442957056
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/restore/RocksDBIncrementalRestoreOperation.java:
##
@@
[
https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17803557#comment-17803557
]
Sergey Nuyanzin commented on FLINK-33365:
-
marked as a blocker as mentioned at
[
https://issues.apache.org/jira/browse/FLINK-34002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34002:
---
Labels: pull-request-available (was: )
> Bump CI flink version on
Martijn Visser created FLINK-34002:
--
Summary: Bump CI flink version on flink-connector-elasticsearch
Key: FLINK-34002
URL: https://issues.apache.org/jira/browse/FLINK-34002
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-33365:
Priority: Blocker (was: Critical)
> Missing filter condition in execution plan
davidradl closed pull request #79: [FLINK-33365] include filters with Lookup
joins
URL: https://github.com/apache/flink-connector-jdbc/pull/79
--
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
dependabot[bot] opened a new pull request, #38:
URL: https://github.com/apache/flink-connector-hbase/pull/38
Bumps org.apache.commons:commons-compress from 1.23.0 to 1.24.0.
[![Dependabot compatibility
dependabot[bot] opened a new pull request, #37:
URL: https://github.com/apache/flink-connector-hbase/pull/37
Bumps org.apache.zookeeper:zookeeper from 3.4.14 to 3.7.2.
[![Dependabot compatibility
davidradl commented on PR #79:
URL:
https://github.com/apache/flink-connector-jdbc/pull/79#issuecomment-1878726394
Fixed the test failures
--
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
davidradl closed pull request #79: [FLINK-33365] include filters with Lookup
joins
URL: https://github.com/apache/flink-connector-jdbc/pull/79
--
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
davidradl closed pull request #79: [FLINK-33365] include filters with Lookup
joins
URL: https://github.com/apache/flink-connector-jdbc/pull/79
--
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
davidradl closed pull request #79: [FLINK-33365] include filters with Lookup
joins
URL: https://github.com/apache/flink-connector-jdbc/pull/79
--
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
davidradl closed pull request #79: [FLINK-33365] include filters with Lookup
joins
URL: https://github.com/apache/flink-connector-jdbc/pull/79
--
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
MartijnVisser opened a new pull request, #707:
URL: https://github.com/apache/flink-web/pull/707
(no comment)
--
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
davidradl closed pull request #79: [FLINK-33365] include filters with Lookup
joins
URL: https://github.com/apache/flink-connector-jdbc/pull/79
--
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-33897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17803535#comment-17803535
]
Piotr Nowojski commented on FLINK-33897:
By real world motivation, I meant if that really is an
GOODBOY008 commented on PR #88:
URL:
https://github.com/apache/flink-connector-jdbc/pull/88#issuecomment-1878625591
@MartijnVisser I want to fix dead link in document first. And I also want to
add dead link check into
https://github.com/apache/flink-connector-shared-utils/tree/ci_utils
davidradl commented on PR #79:
URL:
https://github.com/apache/flink-connector-jdbc/pull/79#issuecomment-1878620080
I see there are some test failures - I will look into them
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
GOODBOY008 opened a new pull request, #32:
URL: https://github.com/apache/flink-connector-shared-utils/pull/32
Add docs check dead links.
--
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
tagarr commented on code in PR #749:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/749#discussion_r1442824067
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/controller/FlinkDeploymentController.java:
##
@@ -227,4 +235,28 @@
tagarr commented on code in PR #749:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/749#discussion_r1442824067
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/controller/FlinkDeploymentController.java:
##
@@ -227,4 +235,28 @@
MartijnVisser merged PR #591:
URL: https://github.com/apache/flink-web/pull/591
--
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-33996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17803524#comment-17803524
]
Feng Jin commented on FLINK-33996:
--
[~xuyangzhong] Introducing a new rule may be a better way,
[
https://issues.apache.org/jira/browse/FLINK-33996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Feng Jin updated FLINK-33996:
-
Description:
When multiple top projects reference the same bottom project, project rewrite
rules may
pnowojski commented on code in PR #23908:
URL: https://github.com/apache/flink/pull/23908#discussion_r1442770858
##
docs/content/docs/ops/traces.md:
##
@@ -97,7 +97,7 @@ Flink reports a single span trace for the whole checkpoint
once checkpoint reach
-
pnowojski commented on code in PR #23908:
URL: https://github.com/apache/flink/pull/23908#discussion_r1442749273
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointStatsTracker.java:
##
@@ -155,7 +167,12 @@ public CheckpointStatsSnapshot
[
https://issues.apache.org/jira/browse/FLINK-34001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-34001:
---
Component/s: Documentation
Table SQL / API
(was: API /
davidradl commented on code in PR #79:
URL:
https://github.com/apache/flink-connector-jdbc/pull/79#discussion_r1442730232
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableSource.java:
##
@@ -96,28 +97,115 @@ public
RocMarshal commented on code in PR #2:
URL:
https://github.com/apache/flink-connector-jdbc/pull/2#discussion_r1442655533
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/datasource/statements/JdbcQueryStatement.java:
##
@@ -0,0 +1,34 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-28915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17803501#comment-17803501
]
Márton Balassi commented on FLINK-28915:
Due to the
davidradl closed pull request #79: [FLINK-33365] include filters with Lookup
joins
URL: https://github.com/apache/flink-connector-jdbc/pull/79
--
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
JunRuiLee commented on code in PR #24025:
URL: https://github.com/apache/flink/pull/24025#discussion_r1442718242
##
flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java:
##
@@ -1201,6 +1212,9 @@ public void configure(ReadableConfig configuration,
RocMarshal commented on code in PR #2:
URL:
https://github.com/apache/flink-connector-jdbc/pull/2#discussion_r1442712519
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/datasource/statements/JdbcQueryStatement.java:
##
@@ -0,0 +1,34 @@
+/*
+ * Licensed to
flinkbot commented on PR #24030:
URL: https://github.com/apache/flink/pull/24030#issuecomment-1878444332
## CI report:
* fa4675861793c8cd42d7ece15334879b2ec54953 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
xuyangzhong opened a new pull request, #24030:
URL: https://github.com/apache/flink/pull/24030
## What is the purpose of the change
Currently, window aggregation doesn't support to consume a changelog stream.
See more at
[
https://issues.apache.org/jira/browse/FLINK-20281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-20281:
---
Labels: auto-deprioritized-major auto-deprioritized-minor
pull-request-available (was:
1996fanrui commented on code in PR #24025:
URL: https://github.com/apache/flink/pull/24025#discussion_r1442706214
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java:
##
@@ -453,7 +440,10 @@ public
1996fanrui commented on code in PR #24025:
URL: https://github.com/apache/flink/pull/24025#discussion_r1442704443
##
flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java:
##
@@ -1201,6 +1212,9 @@ public void configure(ReadableConfig configuration,
mbalassi commented on PR #20779:
URL: https://github.com/apache/flink/pull/20779#issuecomment-1878422305
Hi @SwimSweet, given your lack of response @ferenc-csaky offered to build on
your work and take it forward based on my comments above. Hope that is OK, he
is planning to post an updated
[
https://issues.apache.org/jira/browse/FLINK-33856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17803484#comment-17803484
]
Rui Fan commented on FLINK-33856:
-
{quote}I would suggest that both of yo chat offline about the scope
[
https://issues.apache.org/jira/browse/FLINK-34001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yong yang updated FLINK-34001:
--
Summary: doc of "Configure Operator-level State TTL" error (was: doc diff
from code)
> doc of
[
https://issues.apache.org/jira/browse/FLINK-34001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17803483#comment-17803483
]
yong yang commented on FLINK-34001:
---
{code:java}
//代码占位符
// plan1.json
{
"flinkVersion" : "1.18",
[
https://issues.apache.org/jira/browse/FLINK-34001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17803482#comment-17803482
]
yong yang commented on FLINK-34001:
---
{code:java}
//代码占位符
package com.yy.state.OperatorStateTTL
import
yong yang created FLINK-34001:
-
Summary: doc diff from code
Key: FLINK-34001
URL: https://issues.apache.org/jira/browse/FLINK-34001
Project: Flink
Issue Type: Bug
Components: API /
[
https://issues.apache.org/jira/browse/FLINK-33993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-33993.
--
Resolution: Fixed
> Ineffective scaling detection events are misleading
>
mxm commented on PR #748:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/748#issuecomment-1878408347
Thanks for the quick review Rui!
--
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
[
https://issues.apache.org/jira/browse/FLINK-33856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17803478#comment-17803478
]
Piotr Nowojski edited comment on FLINK-33856 at 1/5/24 9:58 AM:
{quote}
mxm merged PR #748:
URL: https://github.com/apache/flink-kubernetes-operator/pull/748
--
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-33856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17803478#comment-17803478
]
Piotr Nowojski edited comment on FLINK-33856 at 1/5/24 9:56 AM:
{quote}
[
https://issues.apache.org/jira/browse/FLINK-33856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17803478#comment-17803478
]
Piotr Nowojski commented on FLINK-33856:
{quote}
Maybe a new flip that supports task-level trace
StefanRRichter commented on code in PR #23908:
URL: https://github.com/apache/flink/pull/23908#discussion_r1442679306
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java:
##
@@ -730,57 +739,87 @@ void restoreInternal() throws Exception
JunRuiLee commented on PR #24025:
URL: https://github.com/apache/flink/pull/24025#issuecomment-1878390963
Thanks @1996fanrui for the quick 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
StefanRRichter commented on code in PR #23908:
URL: https://github.com/apache/flink/pull/23908#discussion_r1442676217
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointStatsTracker.java:
##
@@ -155,7 +167,12 @@ public CheckpointStatsSnapshot
JunRuiLee commented on code in PR #24025:
URL: https://github.com/apache/flink/pull/24025#discussion_r1442675488
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java:
##
@@ -453,7 +440,10 @@ public
xintongsong commented on code in PR #23905:
URL: https://github.com/apache/flink/pull/23905#discussion_r1442654920
##
pom.xml:
##
@@ -2301,6 +2301,8 @@ under the License.
1 - 100 of 114 matches
Mail list logo
