[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17698227#comment-17698227
]
Yue Ma edited comment on FLINK-31238 at 3/9/23 7:55 AM:
[~yunta] Thanks for
zhuzhurk commented on code in PR #22098:
URL: https://github.com/apache/flink/pull/22098#discussion_r1130607703
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/DefaultPreferredLocationsRetrieverTest.java:
##
@@ -81,16 +81,6 @@ void testInputLocations() {
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17698227#comment-17698227
]
Yue Ma commented on FLINK-31238:
[~yunta] Thanks for replying ~
Yes, in the current implementation both
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yue Ma updated FLINK-31238:
---
Attachment: image-2023-03-09-15-50-04-281.png
> Use IngestDB to speed up Rocksdb rescaling recovery
>
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yue Ma updated FLINK-31238:
---
Attachment: image-2023-03-09-15-46-01-176.png
> Use IngestDB to speed up Rocksdb rescaling recovery
>
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yue Ma updated FLINK-31238:
---
Attachment: image-2023-03-09-15-45-56-081.png
> Use IngestDB to speed up Rocksdb rescaling recovery
>
flinkbot commented on PR #22136:
URL: https://github.com/apache/flink/pull/22136#issuecomment-1461493973
## CI report:
* c7160f860d0960a5186c3472dbb6bd3d22dbdf71 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yue Ma updated FLINK-31238:
---
Attachment: image-2023-03-09-15-41-08-379.png
> Use IngestDB to speed up Rocksdb rescaling recovery
>
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yue Ma updated FLINK-31238:
---
Attachment: image-2023-03-09-15-41-03-074.png
> Use IngestDB to speed up Rocksdb rescaling recovery
>
ramkrishna.s.vasudevan created FLINK-31376:
--
Summary: CSVReader for streaming does not support splittable
Key: FLINK-31376
URL: https://issues.apache.org/jira/browse/FLINK-31376
Project:
cshuo opened a new pull request, #22136:
URL: https://github.com/apache/flink/pull/22136
## 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-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yue Ma updated FLINK-31238:
---
Attachment: image-2023-03-09-15-28-32-363.png
> Use IngestDB to speed up Rocksdb rescaling recovery
>
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yue Ma updated FLINK-31238:
---
Attachment: image-2023-03-09-15-26-12-314.png
> Use IngestDB to speed up Rocksdb rescaling recovery
>
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17698215#comment-17698215
]
Yue Ma commented on FLINK-31238:
[~masteryhx] Thanks for the reply, I understand your concerns. It's a
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yue Ma updated FLINK-31238:
---
Attachment: image-2023-03-09-15-23-30-581.png
> Use IngestDB to speed up Rocksdb rescaling recovery
>
PatrickRen commented on PR #22100:
URL: https://github.com/apache/flink/pull/22100#issuecomment-1461451782
Thanks for the patch @loserwang1024 ! 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
[
https://issues.apache.org/jira/browse/FLINK-31240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned FLINK-31240:
Assignee: Jiang Xin
> Reduce the overhead of conversion between DataStream and Table
>
[
https://issues.apache.org/jira/browse/FLINK-31375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jeff-zou updated FLINK-31375:
-
Description:
the values of map are truncated by the CASE WHEN function.
{code:java}
// sql
create table
[
https://issues.apache.org/jira/browse/FLINK-31375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jeff-zou updated FLINK-31375:
-
Description:
the values of map are truncated by the CASE WHEN function.
{code:java}
// sql
create table
[
https://issues.apache.org/jira/browse/FLINK-31375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jeff-zou updated FLINK-31375:
-
Description:
the values of map are truncated by the CASE WHEN function.
{code:java}
// sql
create table
[
https://issues.apache.org/jira/browse/FLINK-31375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jeff-zou updated FLINK-31375:
-
Description:
the values of map are truncated by the CASE WHEN function.
{code:java}
// sql
create table
jeff-zou created FLINK-31375:
Summary: the values of map are truncated by the
CASE WHEN function.
Key: FLINK-31375
URL: https://issues.apache.org/jira/browse/FLINK-31375
Project: Flink
Issue
Aitozi commented on code in PR #21522:
URL: https://github.com/apache/flink/pull/21522#discussion_r1130546283
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/Schema.java:
##
@@ -611,7 +611,9 @@ private void addResolvedColumns(List columns) {
LadyForest commented on PR #21452:
URL: https://github.com/apache/flink/pull/21452#issuecomment-1461375359
One concern is that for a nullable row type, does it make sense to let the
inner field not be null?
In other words, should we not support `ROW`?
WDYT @snuyanzin
--
This is
[
https://issues.apache.org/jira/browse/FLINK-27018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jeff-zou updated FLINK-27018:
-
Description:
the bug is described as follows:
{code:java}
data in source:
2022-04-02 03:34:21.260
felixzh2020 commented on PR #22118:
URL: https://github.com/apache/flink/pull/22118#issuecomment-1461344401
@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
[
https://issues.apache.org/jira/browse/FLINK-30513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17698192#comment-17698192
]
Weijie Guo commented on FLINK-30513:
master(1.18) via 13779ab8e4f5539ca311d9f233d031d818af6450.
>
[
https://issues.apache.org/jira/browse/FLINK-30513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17698192#comment-17698192
]
Weijie Guo edited comment on FLINK-30513 at 3/9/23 6:08 AM:
master(1.18) via
reswqa commented on PR #21673:
URL: https://github.com/apache/flink/pull/21673#issuecomment-1461341895
@X-czh merged. Could you open a backport pr to release-1.17?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
reswqa closed pull request #21673: [FLINK-30513] Cleanup HA storage path on
cluster termination
URL: https://github.com/apache/flink/pull/21673
--
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-31298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31298:
---
Fix Version/s: 1.17.0
1.16.2
>
[
https://issues.apache.org/jira/browse/FLINK-31298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-31298.
--
Resolution: Fixed
> ConnectionUtilsTest.testFindConnectingAddressWhenGetLocalHostThrows swallows
>
[
https://issues.apache.org/jira/browse/FLINK-31298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17697743#comment-17697743
]
Weijie Guo edited comment on FLINK-31298 at 3/9/23 6:00 AM:
master(1.18) via
reswqa merged PR #22129:
URL: https://github.com/apache/flink/pull/22129
--
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:
reswqa merged PR #22128:
URL: https://github.com/apache/flink/pull/22128
--
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:
lightzhao commented on PR #22126:
URL: https://github.com/apache/flink/pull/22126#issuecomment-1461330269
@fapaul @AHeise PTAL.
--
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
lindong28 commented on code in PR #218:
URL: https://github.com/apache/flink-ml/pull/218#discussion_r1130375623
##
flink-ml-core/src/test/java/org/apache/flink/ml/api/ExampleStages.java:
##
@@ -110,6 +111,10 @@ public static SumModel load(StreamTableEnvironment tEnv,
String
X-czh commented on PR #21673:
URL: https://github.com/apache/flink/pull/21673#issuecomment-1461279033
@reswqa Kindly remind. Could you help merge the 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
[
https://issues.apache.org/jira/browse/FLINK-31346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17697402#comment-17697402
]
Weijie Guo edited comment on FLINK-31346 at 3/9/23 4:21 AM:
master(1.18) via
[
https://issues.apache.org/jira/browse/FLINK-31346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-31346.
--
Fix Version/s: 1.16.2
Resolution: Fixed
> Batch shuffle IO scheduler does not throw
[
https://issues.apache.org/jira/browse/FLINK-31346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31346:
---
Affects Version/s: 1.17.0
> Batch shuffle IO scheduler does not throw TimeoutException if
>
reswqa merged PR #22123:
URL: https://github.com/apache/flink/pull/22123
--
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-31351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17697859#comment-17697859
]
Shengkai Fang edited comment on FLINK-31351 at 3/9/23 3:16 AM:
---
Merged
[
https://issues.apache.org/jira/browse/FLINK-31351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang closed FLINK-31351.
-
Resolution: Fixed
>
[
https://issues.apache.org/jira/browse/FLINK-31351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17697859#comment-17697859
]
Shengkai Fang edited comment on FLINK-31351 at 3/9/23 3:15 AM:
---
Merged
fsk119 merged PR #22133:
URL: https://github.com/apache/flink/pull/22133
--
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:
fsk119 merged PR #22132:
URL: https://github.com/apache/flink/pull/22132
--
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:
zhipeng93 commented on code in PR #220:
URL: https://github.com/apache/flink-ml/pull/220#discussion_r1130294319
##
flink-ml-lib/src/test/java/org/apache/flink/ml/recommendation/SwingTest.java:
##
@@ -140,6 +141,7 @@ public void testParam() {
assertEquals(5,
LadyForest commented on code in PR #21452:
URL: https://github.com/apache/flink/pull/21452#discussion_r1130310752
##
flink-table/flink-sql-client/src/test/resources/sql/table.q:
##
@@ -964,7 +998,7 @@ CREATE TABLE IF NOT EXISTS daily_orders (
PRIMARY KEY(dt, `user`) NOT
liuyongvs commented on PR #21993:
URL: https://github.com/apache/flink/pull/21993#issuecomment-1461165977
hi @snuyanzin ,thanks for your review and i learned a lot
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
liuyongvs commented on code in PR #21993:
URL: https://github.com/apache/flink/pull/21993#discussion_r1130305597
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/CollectionFunctionsITCase.java:
##
@@ -102,6 +105,16 @@ Stream
liuyongvs commented on code in PR #21993:
URL: https://github.com/apache/flink/pull/21993#discussion_r1130306112
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ArrayElementArgumentTypeStrategy.java:
##
@@ -42,9 +42,14 @@ public
ruanhang1993 closed pull request #17815: [FLINK-22702][tests] Add test data
supplier which provide null timestamp field to kafka connector tests
URL: https://github.com/apache/flink/pull/17815
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
ruanhang1993 closed pull request #18497: [FLINK-25290][tests] add table tests
for connector testframe
URL: https://github.com/apache/flink/pull/18497
--
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
zhangjun0x01 commented on PR #584:
URL:
https://github.com/apache/flink-table-store/pull/584#issuecomment-1461145922
> @zhangjun0x01 Can we consider to use bucket number as streaming default
parallelism? And use parallelism inference only for batch source.
I updated it, and disabled
zhangjun0x01 commented on PR #584:
URL:
https://github.com/apache/flink-table-store/pull/584#issuecomment-1461142959
> The same problem of E2E test I have met before. I've pushed some commits
to try to solve the problem. You can rebase master.
yeah，I resubmitted
--
Zhipeng Zhang created FLINK-31374:
-
Summary: ProxyStreamPartitioner should implement
ConfigurableStreamPartitioner
Key: FLINK-31374
URL: https://issues.apache.org/jira/browse/FLINK-31374
Project:
[
https://issues.apache.org/jira/browse/FLINK-31373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhipeng Zhang updated FLINK-31373:
--
Description:
Currently we use PerRoundWrapperOperator to wrap the normal flink operators
Zhipeng Zhang created FLINK-31373:
-
Summary: PerRoundWrapperOperator should carry epoch information in
watermark
Key: FLINK-31373
URL: https://issues.apache.org/jira/browse/FLINK-31373
Project: Flink
snuyanzin commented on code in PR #21993:
URL: https://github.com/apache/flink/pull/21993#discussion_r1130032947
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/CollectionFunctionsITCase.java:
##
@@ -102,6 +105,16 @@ Stream
snuyanzin commented on code in PR #21993:
URL: https://github.com/apache/flink/pull/21993#discussion_r1130031361
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ArrayElementArgumentTypeStrategy.java:
##
@@ -42,9 +42,14 @@ public
flinkbot commented on PR #22135:
URL: https://github.com/apache/flink/pull/22135#issuecomment-1460876245
## CI report:
* 7c1d6079a4ba2323b410cf4209695b468ec735fd UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31369:
---
Labels: pull-request-available (was: )
> Harden modifiers for sql-gateway module
>
snuyanzin opened a new pull request, #22135:
URL: https://github.com/apache/flink/pull/22135
## What is the purpose of the change
The PR hardens modifiers for junit5 tests
as a follow up for
https://github.com/apache/flink/pull/22127#discussion_r1129192778
## Verifying
[
https://issues.apache.org/jira/browse/FLINK-31133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-31133:
--
Fix Version/s: 1.15.4
(was: 1.15.5)
> PartiallyFinishedSourcesITCase
[
https://issues.apache.org/jira/browse/FLINK-27169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-27169:
--
Fix Version/s: 1.15.4
(was: 1.15.5)
>
[
https://issues.apache.org/jira/browse/FLINK-29729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-29729:
--
Fix Version/s: 1.18.0
> Fix credential info configured in flink-conf.yaml is lost during
[
https://issues.apache.org/jira/browse/FLINK-31272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-31272:
--
Fix Version/s: 1.15.4
(was: 1.15.5)
> Duplicate operators appear in
[
https://issues.apache.org/jira/browse/FLINK-29729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-29729:
--
Fix Version/s: 1.15.4
(was: 1.18.0)
(was:
[
https://issues.apache.org/jira/browse/FLINK-31286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-31286:
--
Fix Version/s: 1.15.4
(was: 1.15.5)
> Python processes are still alive
[
https://issues.apache.org/jira/browse/FLINK-31372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Krzysztof Dziolak updated FLINK-31372:
--
Summary: Memory Leak in prometheus HTTPMetricHandler when reporting fails
(was:
[
https://issues.apache.org/jira/browse/FLINK-31372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Krzysztof Dziolak updated FLINK-31372:
--
Description:
We've identified a memory leak, that occurs when any of the metric
[
https://issues.apache.org/jira/browse/FLINK-31372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Krzysztof Dziolak updated FLINK-31372:
--
Affects Version/s: 1.16.1
1.15.4
1.17.1
Krzysztof Dziolak created FLINK-31372:
-
Summary: Memory Leak in HTTPMetricHandler when reporting fails
Key: FLINK-31372
URL: https://issues.apache.org/jira/browse/FLINK-31372
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-31372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Krzysztof Dziolak updated FLINK-31372:
--
Priority: Minor (was: Major)
> Memory Leak in HTTPMetricHandler when reporting fails
[
https://issues.apache.org/jira/browse/FLINK-31371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Enzo Dechaene updated FLINK-31371:
--
Description:
*Describe the bug*
With a Pulsar 2.8.4 server, a Flink stream containing Pulsar
Enzo Dechaene created FLINK-31371:
-
Summary: Stream failure if the topic doesn't exist
Key: FLINK-31371
URL: https://issues.apache.org/jira/browse/FLINK-31371
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-31345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-31345.
--
Resolution: Fixed
Merged to main:
f88cbf3fd1b99a574a1ed8b8a2869b96d932e521
gyfora merged PR #547:
URL: https://github.com/apache/flink-kubernetes-operator/pull/547
--
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:
dmvk commented on PR #22134:
URL: https://github.com/apache/flink/pull/22134#issuecomment-1460402364
Thanks for the review, @pnowojski! I've added the same logic for the
processing time timers. It would be super helpful if you could verify the
change against benchmarks.
--
This is an
snuyanzin commented on code in PR #21452:
URL: https://github.com/apache/flink/pull/21452#discussion_r1129506976
##
flink-table/flink-sql-client/src/test/resources/sql/table.q:
##
@@ -964,7 +998,7 @@ CREATE TABLE IF NOT EXISTS daily_orders (
PRIMARY KEY(dt, `user`) NOT
RyanSkraba commented on code in PR #22082:
URL: https://github.com/apache/flink/pull/22082#discussion_r1129649372
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/CastRule.java:
##
@@ -46,7 +46,9 @@ CastExecutor create(
liuyongvs commented on code in PR #21993:
URL: https://github.com/apache/flink/pull/21993#discussion_r1129607127
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ArrayElementArgumentTypeStrategy.java:
##
@@ -42,7 +42,7 @@ public
Aitozi commented on code in PR #21522:
URL: https://github.com/apache/flink/pull/21522#discussion_r1129605975
##
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/parse/HiveParserDDLSemanticAnalyzer.java:
##
@@ -1966,61 +1982,60
pnowojski commented on code in PR #22134:
URL: https://github.com/apache/flink/pull/22134#discussion_r1129592490
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerServiceImpl.java:
##
@@ -296,7 +302,9 @@ public void
Aitozi commented on code in PR #21522:
URL: https://github.com/apache/flink/pull/21522#discussion_r1129582760
##
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/copy/HiveParserBaseSemanticAnalyzer.java:
##
@@ -2106,7 +2111,7 @@
echauchot commented on PR #22124:
URL: https://github.com/apache/flink/pull/22124#issuecomment-1460260004
@MartijnVisser CI tests pass
--
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-30805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17697925#comment-17697925
]
Etienne Chauchot commented on FLINK-30805:
--
[~MartijnVisser] can you assign this ticket to me ?
snuyanzin commented on code in PR #21452:
URL: https://github.com/apache/flink/pull/21452#discussion_r1129506976
##
flink-table/flink-sql-client/src/test/resources/sql/table.q:
##
@@ -964,7 +998,7 @@ CREATE TABLE IF NOT EXISTS daily_orders (
PRIMARY KEY(dt, `user`) NOT
snuyanzin commented on code in PR #21993:
URL: https://github.com/apache/flink/pull/21993#discussion_r1129483531
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ArrayElementArgumentTypeStrategy.java:
##
@@ -42,7 +42,7 @@ public
flinkbot commented on PR #22134:
URL: https://github.com/apache/flink/pull/22134#issuecomment-1460212176
## CI report:
* 4eac832e73fb0a8ca8ee44338f9ff30ca0dcfe34 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
snuyanzin commented on code in PR #21993:
URL: https://github.com/apache/flink/pull/21993#discussion_r1129483531
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ArrayElementArgumentTypeStrategy.java:
##
@@ -42,7 +42,7 @@ public
[
https://issues.apache.org/jira/browse/FLINK-31370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31370:
---
Labels: pull-request-available (was: )
> Cancellation of the StreamTask should prevent
dmvk opened a new pull request, #22134:
URL: https://github.com/apache/flink/pull/22134
https://issues.apache.org/jira/browse/FLINK-31370
If the task is canceled while the watermark progresses, it may be stuck in
the Cancelling state for a long time (e.g., when many windows are
[
https://issues.apache.org/jira/browse/FLINK-31370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Morávek updated FLINK-31370:
--
Description:
If the task is canceled while the watermark progresses, it may be stuck in the
[
https://issues.apache.org/jira/browse/FLINK-31370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Morávek updated FLINK-31370:
--
Description: If the task is being canceled while the watermark is
progressing, it may be
David Morávek created FLINK-31370:
-
Summary: Cancellation of the StreamTask should prevent more timers
from being fired
Key: FLINK-31370
URL: https://issues.apache.org/jira/browse/FLINK-31370
echauchot commented on PR #22124:
URL: https://github.com/apache/flink/pull/22124#issuecomment-1460166102
@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
LadyForest commented on PR #21452:
URL: https://github.com/apache/flink/pull/21452#issuecomment-1460103874
Hi @snuyanzin, could you mind taking a look?
--
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
[
https://issues.apache.org/jira/browse/FLINK-31368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17697868#comment-17697868
]
lincoln lee commented on FLINK-31368:
-
[~jark] +1 for this refactoring, it will prevent the
1 - 100 of 166 matches
Mail list logo
