haoxins commented on code in PR #292:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/292#discussion_r913449561
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/validation/DefaultValidator.java:
##
@@ -178,7 +178,7 @@ private Optiona
deadwind4 opened a new pull request, #20161:
URL: https://github.com/apache/flink/pull/20161
## What is the purpose of the change
Support instr and locate built-in functions in Table API.
## Brief change log
- *Support FROM_UNIXTIME built-in functions in Table API.*
[
https://issues.apache.org/jira/browse/FLINK-28015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28015:
---
Labels: pull-request-available (was: )
> FROM_UNIXTIME could not be used in Table API
> ---
zentol commented on PR #20155:
URL: https://github.com/apache/flink/pull/20155#issuecomment-1174696001
@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.
T
[
https://issues.apache.org/jira/browse/FLINK-28010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562403#comment-17562403
]
ming li commented on FLINK-28010:
-
hi, [~yunta], do you think this optimization is feasi
flinkbot commented on PR #20161:
URL: https://github.com/apache/flink/pull/20161#issuecomment-1174698601
## CI report:
* 146dadc066d67d4c30b52866b2b6d0a26b32cedd UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
gaoyunhaii commented on PR #20108:
URL: https://github.com/apache/flink/pull/20108#issuecomment-1174698823
Merged
--
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 unsubsc
gaoyunhaii closed pull request #20108: [FLINK-28240][network] Fix the bug that
NetworkBufferPool#getRequestedSegmentsUsage may throw ArithmeticException.
URL: https://github.com/apache/flink/pull/20108
--
This is an automated message from the Apache Git Service.
To respond to the message, ple
[
https://issues.apache.org/jira/browse/FLINK-28357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562404#comment-17562404
]
James commented on FLINK-28357:
---
Great - thanks for the feedback. Understood about the sou
Márton Balassi created FLINK-28388:
--
Summary: Python doc build breaking nightly docs
Key: FLINK-28388
URL: https://issues.apache.org/jira/browse/FLINK-28388
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-28357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562405#comment-17562405
]
James commented on FLINK-28357:
---
Also - you say "non-chained map" but {+}I believe this pr
[
https://issues.apache.org/jira/browse/FLINK-28240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562407#comment-17562407
]
Yun Gao commented on FLINK-28240:
-
Merged on master via c6b3a8aa25607fb62d51b92f11f72778
[
https://issues.apache.org/jira/browse/FLINK-28240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao closed FLINK-28240.
---
Fix Version/s: 1.16.0
1.15.2
Assignee: Gen Luo
Resolution: Fixed
> NettyS
[
https://issues.apache.org/jira/browse/FLINK-28388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562408#comment-17562408
]
Márton Balassi commented on FLINK-28388:
cc [~dianfu] [~ana4]
> Python doc buil
[
https://issues.apache.org/jira/browse/FLINK-28388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-28388:
-
Component/s: API / Python
> Python doc build breaking nightly docs
> ---
JingsongLi commented on code in PR #193:
URL: https://github.com/apache/flink-table-store/pull/193#discussion_r913460665
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/schema/TableSchema.java:
##
@@ -129,6 +134,33 @@ public Map options() {
ret
Matyas Orhidi created FLINK-28389:
-
Summary: Correct spec and status updates in
FlinkDeploymentControllerTest
Key: FLINK-28389
URL: https://issues.apache.org/jira/browse/FLINK-28389
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-28389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-28389:
--
Assignee: Matyas Orhidi
> Correct spec and status updates in FlinkDeploymentControllerTest
>
JingsongLi merged PR #194:
URL: https://github.com/apache/flink-table-store/pull/194
--
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...@
[
https://issues.apache.org/jira/browse/FLINK-28381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-28381.
Resolution: Fixed
master: e2612c0cfb8e14e5d1c33df280e827f3f67c0426
> Add Spark Reader documentati
[
https://issues.apache.org/jira/browse/FLINK-28352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-28352:
--
Assignee: Yufan Sheng (was: Yufei Zhang)
> [Umbrella] Make Pulsar connector stable
>
[
https://issues.apache.org/jira/browse/FLINK-28352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-28352:
--
Assignee: Yufei Zhang
> [Umbrella] Make Pulsar connector stable
> ---
[
https://issues.apache.org/jira/browse/FLINK-26721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-26721:
--
Assignee: Yufan Sheng (was: Martijn Visser)
> PulsarSourceITCase.testSavepoint faile
[
https://issues.apache.org/jira/browse/FLINK-26402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-26402:
---
Priority: Major (was: Critical)
> MinioTestContainerTest.testS3EndpointNeedsToBeSpecifiedBe
JingsongLi commented on code in PR #195:
URL: https://github.com/apache/flink-table-store/pull/195#discussion_r913466400
##
docs/content/docs/development/configuration.md:
##
@@ -0,0 +1,53 @@
+---
+title: "Configuration"
+weight: 6
+type: docs
+aliases:
+- /development/configura
[
https://issues.apache.org/jira/browse/FLINK-26402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-26402:
---
Priority: Critical (was: Major)
> MinioTestContainerTest.testS3EndpointNeedsToBeSpecifiedBe
[
https://issues.apache.org/jira/browse/FLINK-26600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-26600:
Assignee: Chesnay Schepler
> PerJobMiniClusterFactoryTest.testJobClientSavepoint
MartijnVisser commented on code in PR #20014:
URL: https://github.com/apache/flink/pull/20014#discussion_r913466628
##
flink-core/src/main/java/org/apache/flink/api/dag/Transformation.java:
##
@@ -108,11 +109,10 @@
public static final int UPPER_BOUND_MAX_PARALLELISM = 1 <<
echauchot commented on PR #19935:
URL: https://github.com/apache/flink/pull/19935#issuecomment-1174709407
@zentol friendly ping
--
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 commen
[
https://issues.apache.org/jira/browse/FLINK-24960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562414#comment-17562414
]
Martijn Visser commented on FLINK-24960:
[~mapohl] What's the current status of
[
https://issues.apache.org/jira/browse/FLINK-27691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562415#comment-17562415
]
Martijn Visser commented on FLINK-27691:
Downgrading to Major due to lack of occ
[
https://issues.apache.org/jira/browse/FLINK-27691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-27691:
---
Priority: Major (was: Critical)
> RankHarnessTest. testUpdateRankWithRowNumberSortKeyDropsT
JingsongLi commented on code in PR #195:
URL: https://github.com/apache/flink-table-store/pull/195#discussion_r913468538
##
docs/layouts/shortcodes/generated/core_configuration.html:
##
@@ -0,0 +1,204 @@
+
+
+
+Key
+Default
+Type
+
[
https://issues.apache.org/jira/browse/FLINK-25233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562416#comment-17562416
]
Martijn Visser commented on FLINK-25233:
Downgrading to Major due to lack of occ
[
https://issues.apache.org/jira/browse/FLINK-25233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-25233:
---
Priority: Major (was: Critical)
> UpsertKafkaTableITCase.testAggregate fails on AZP
> -
echauchot commented on PR #19944:
URL: https://github.com/apache/flink/pull/19944#issuecomment-1174710605
@MartijnVisser @zentol friendly ping
--
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-25233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-25233:
---
Fix Version/s: (was: 1.16.0)
> UpsertKafkaTableITCase.testAggregate fails on AZP
> -
MartijnVisser commented on PR #19944:
URL: https://github.com/apache/flink/pull/19944#issuecomment-1174712127
@echauchot Sorry, I'll have a look today :)
--
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
ming li created FLINK-28390:
---
Summary: Allows RocksDB to configure FIFO Compaction to reduce CPU
overhead.
Key: FLINK-28390
URL: https://issues.apache.org/jira/browse/FLINK-28390
Project: Flink
Is
HeChuanXUPT commented on PR #18310:
URL: https://github.com/apache/flink/pull/18310#issuecomment-1174717088
Does anyone have any suggestions ? or some one has another progress ?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
[
https://issues.apache.org/jira/browse/FLINK-24960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562417#comment-17562417
]
Matthias Pohl commented on FLINK-24960:
---
[~nsemmler] provided a workaround where w
[
https://issues.apache.org/jira/browse/FLINK-28274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562419#comment-17562419
]
zl commented on FLINK-28274:
-- Does this problem only occur for \{ContinuousFileMonitoringF
[
https://issues.apache.org/jira/browse/FLINK-24960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562424#comment-17562424
]
Martijn Visser commented on FLINK-24960:
Are we OK with downgrading this to a Ma
[
https://issues.apache.org/jira/browse/FLINK-28274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562423#comment-17562423
]
Martijn Visser commented on FLINK-28274:
-- The legacy source are still widely u
morhidi commented on PR #293:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/293#issuecomment-1174725973
@gyfora addressed your comments, 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 abo
[
https://issues.apache.org/jira/browse/FLINK-26621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-26621:
---
Priority: Critical (was: Blocker)
> flink-tests failed on azure due to Error occurred in st
[
https://issues.apache.org/jira/browse/FLINK-27009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562425#comment-17562425
]
Gyula Fora commented on FLINK-27009:
In the meantime I will work on adding an exampl
[
https://issues.apache.org/jira/browse/FLINK-23391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-23391:
---
Fix Version/s: (was: 1.16.0)
> KafkaSourceReaderTest.testKafkaSourceMetrics fails on azu
[
https://issues.apache.org/jira/browse/FLINK-23391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-23391:
---
Priority: Major (was: Critical)
> KafkaSourceReaderTest.testKafkaSourceMetrics fails on azu
[
https://issues.apache.org/jira/browse/FLINK-23391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562426#comment-17562426
]
Martijn Visser commented on FLINK-23391:
Downgrading to major due to lack of occ
[
https://issues.apache.org/jira/browse/FLINK-23740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-23740:
---
Affects Version/s: 1.14.5
1.13.6
1.15.0
[
https://issues.apache.org/jira/browse/FLINK-23740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-23740:
---
Fix Version/s: (was: 1.16.0)
> SQL Full Outer Join bug
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-23740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-23740:
---
Priority: Major (was: Critical)
> SQL Full Outer Join bug
> ---
>
>
Paul Lin created FLINK-28391:
Summary: DefaultBlocklistHandlerTest unstable
Key: FLINK-28391
URL: https://issues.apache.org/jira/browse/FLINK-28391
Project: Flink
Issue Type: Bug
Compon
JingsongLi merged PR #191:
URL: https://github.com/apache/flink-table-store/pull/191
--
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...@
[
https://issues.apache.org/jira/browse/FLINK-23740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562427#comment-17562427
]
Martijn Visser commented on FLINK-23740:
Downgraded to major due to lack of acti
JingsongLi merged PR #193:
URL: https://github.com/apache/flink-table-store/pull/193
--
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...@
[
https://issues.apache.org/jira/browse/FLINK-28159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562428#comment-17562428
]
Jingsong Lee commented on FLINK-28159:
--
[~liliwei] Thanks for your attention. This
[
https://issues.apache.org/jira/browse/FLINK-26439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-26439.
Resolution: Fixed
master: 9f243ed8e6b8dc361b73f1dcafb4f8c13cb11263
> Introduce sequence.field to
[
https://issues.apache.org/jira/browse/FLINK-28017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-28017.
Resolution: Fixed
master: 907747d3e37b7edb5c1bec5209e47bd4ff9f737b
> Introduce bucket-key to tabl
[
https://issues.apache.org/jira/browse/FLINK-28274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562433#comment-17562433
]
zl commented on FLINK-28274:
`Without an incentive for users to migrate, they will never do
gyfora merged PR #293:
URL: https://github.com/apache/flink-kubernetes-operator/pull/293
--
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
[
https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-24119:
---
Fix Version/s: (was: 1.16.0)
> KafkaITCase.testTimestamps fails due to "Topic xxx alread
[
https://issues.apache.org/jira/browse/FLINK-24241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-24241:
---
Priority: Major (was: Critical)
> test_table_environment_api.py fail with NPE
> ---
[
https://issues.apache.org/jira/browse/FLINK-24241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-24241:
---
Fix Version/s: (was: 1.16.0)
> test_table_environment_api.py fail with NPE
> ---
[
https://issues.apache.org/jira/browse/FLINK-28348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-28348.
--
Resolution: Fixed
merged to main 17723ffc09b6813006044f50165bb6cf15427df7
> Add configurable flag to
[
https://issues.apache.org/jira/browse/FLINK-24241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562435#comment-17562435
]
Martijn Visser commented on FLINK-24241:
Downgraded to major due to lack of acti
[
https://issues.apache.org/jira/browse/FLINK-24744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-24744:
---
Fix Version/s: (was: 1.16.0)
> FlinkKafkaProducerITCase.testMigrateFromAtLeastOnceToExac
[
https://issues.apache.org/jira/browse/FLINK-24743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-24743:
---
Fix Version/s: (was: 1.16.0)
> New File Sink end-to-end test fails on Azure
> --
[
https://issues.apache.org/jira/browse/FLINK-24743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-24743:
---
Priority: Major (was: Critical)
> New File Sink end-to-end test fails on Azure
> --
[
https://issues.apache.org/jira/browse/FLINK-24744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-24744:
---
Priority: Major (was: Critical)
> FlinkKafkaProducerITCase.testMigrateFromAtLeastOnceToExac
[
https://issues.apache.org/jira/browse/FLINK-24795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-24795.
--
Fix Version/s: (was: 1.16.0)
Resolution: Cannot Reproduce
> FlinkKafkaProducerITCas
[
https://issues.apache.org/jira/browse/FLINK-24960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-24960:
---
Priority: Major (was: Critical)
> YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrec
[
https://issues.apache.org/jira/browse/FLINK-24960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-24960:
---
Fix Version/s: (was: 1.16.0)
(was: 1.15.1)
> YARNSessionCapacityS
[
https://issues.apache.org/jira/browse/FLINK-25214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-25214.
--
Fix Version/s: (was: 1.16.0)
Resolution: Cannot Reproduce
> FlinkKafkaProducerITCas
[
https://issues.apache.org/jira/browse/FLINK-28221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reassigned FLINK-28221:
Assignee: Caizhi Weng
> Savepoint may corrupt file metas by repeat commit
> -
[
https://issues.apache.org/jira/browse/FLINK-28108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reassigned FLINK-28108:
Assignee: Jane Chan
> Support compaction for append-only table
>
MartijnVisser commented on PR #20158:
URL: https://github.com/apache/flink/pull/20158#issuecomment-1174738789
@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 comm
[
https://issues.apache.org/jira/browse/FLINK-28159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reassigned FLINK-28159:
Assignee: Jingsong Lee
> Table Store: Bucket pruning based on primary key filter
> --
[
https://issues.apache.org/jira/browse/FLINK-26764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562047#comment-17562047
]
Jark Wu edited comment on FLINK-26764 at 7/5/22 7:57 AM:
-
I chec
[
https://issues.apache.org/jira/browse/FLINK-28159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562397#comment-17562397
]
liwei li commented on FLINK-28159:
--
Not sure I can handle it, but I'd like to try, may
fsk119 commented on code in PR #19846:
URL: https://github.com/apache/flink/pull/19846#discussion_r913501319
##
flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/service/utils/SqlGatewayServiceExtension.java:
##
@@ -43,6 +47,15 @@ public class SqlGateway
[
https://issues.apache.org/jira/browse/FLINK-26548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-26548:
---
Fix Version/s: (was: 1.16.0)
> the source parallelism is not set correctly with Adaptive
chucheng92 commented on PR #19827:
URL: https://github.com/apache/flink/pull/19827#issuecomment-1174745279
@PatrickRen hi, qingsheng, can u help me to review this pr?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
[
https://issues.apache.org/jira/browse/FLINK-26912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-26912:
---
Fix Version/s: (was: 1.16.0)
> EventTimeWindowCheckpointingITCase.testTumblingTimeWindow
[
https://issues.apache.org/jira/browse/FLINK-26912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-26912:
---
Fix Version/s: 1.16.0
> EventTimeWindowCheckpointingITCase.testTumblingTimeWindow failed on
[
https://issues.apache.org/jira/browse/FLINK-27074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562443#comment-17562443
]
Martijn Visser commented on FLINK-27074:
[~hxbks2ks] Can you have a look at this
[
https://issues.apache.org/jira/browse/FLINK-27074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-27074:
--
Assignee: Thomas Thornton
> python_job.py should write to TEST_DATA_DIR
> ---
MartijnVisser commented on PR #19734:
URL: https://github.com/apache/flink/pull/19734#issuecomment-1174747313
@twalthr Do you have time to finalize this one?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
[
https://issues.apache.org/jira/browse/FLINK-27944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-27944:
---
Priority: Major (was: Critical)
> IO metrics collision happens if a task has union inputs
>
[
https://issues.apache.org/jira/browse/FLINK-27944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-27944:
--
Assignee: xiaogang zhou
> IO metrics collision happens if a task has union inputs
> -
[
https://issues.apache.org/jira/browse/FLINK-27944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-27944:
---
Fix Version/s: (was: 1.16.0)
(was: 1.15.2)
> IO metrics collision
[
https://issues.apache.org/jira/browse/FLINK-24872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-24872:
---
Fix Version/s: (was: 1.16.0)
> PulsarSourceITCase.testMultipleSplits failed on AZP
> ---
[
https://issues.apache.org/jira/browse/FLINK-28183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562444#comment-17562444
]
Martijn Visser commented on FLINK-28183:
[~hxbks2ks] Is this something that you
[
https://issues.apache.org/jira/browse/FLINK-28391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562446#comment-17562446
]
Lijie Wang commented on FLINK-28391:
I will take a look.
> DefaultBlocklistHandlerT
[
https://issues.apache.org/jira/browse/FLINK-26979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-26979:
---
Fix Version/s: 1.16.0
> JsonFunctionsITCase.test failed on azure
> -
[
https://issues.apache.org/jira/browse/FLINK-28198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-28198:
---
Fix Version/s: 1.16.0
> CassandraConnectorITCase fails with timeout
> --
[
https://issues.apache.org/jira/browse/FLINK-28176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-28176:
---
Fix Version/s: 1.16.0
> test_es_sink_dynamic failed in jdk11
> -
[
https://issues.apache.org/jira/browse/FLINK-27745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-27745:
---
Fix Version/s: 1.16.0
> ClientUtilsTest.uploadAndSetUserArtifacts failed with NoClassDefFoun
[
https://issues.apache.org/jira/browse/FLINK-28379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-28379:
---
Fix Version/s: 1.16.0
> KerberosLoginProviderTest static UGI mock leaks into other tests
> -
1 - 100 of 641 matches
Mail list logo