[
https://issues.apache.org/jira/browse/FLINK-12514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-12514:
---
Priority: Minor (was: Major)
> Refactor the failure checkpoint counting mechanism with orde
[
https://issues.apache.org/jira/browse/FLINK-12514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-12514:
--
Assignee: (was: vinoyang)
> Refactor the failure checkpoint counting mechanism wi
[
https://issues.apache.org/jira/browse/FLINK-13861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-13861:
--
Assignee: (was: Congxian Qiu)
> No new checkpoint will be trigged when canceling
[
https://issues.apache.org/jira/browse/FLINK-22345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17330042#comment-17330042
]
Dawid Wysakowicz commented on FLINK-22345:
--
I checked logs and it seems somehow
[
https://issues.apache.org/jira/browse/FLINK-15730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-15730:
---
Priority: Major (was: Critical)
> Tables with checkpoint statistics do not scroll when wind
[
https://issues.apache.org/jira/browse/FLINK-15730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-15730:
--
Assignee: (was: Yadong Xie)
> Tables with checkpoint statistics do not scroll whe
[
https://issues.apache.org/jira/browse/FLINK-16030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-16030:
--
Assignee: (was: begginghard)
> Add heartbeat between netty server and client to d
[
https://issues.apache.org/jira/browse/FLINK-16931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-16931:
--
Assignee: (was: Lu Niu)
> Large _metadata file lead to JobManager not responding
[
https://issues.apache.org/jira/browse/FLINK-15750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-15750:
--
Assignee: (was: Piotr Nowojski)
> Execute network flushing actions in the mailbox
[
https://issues.apache.org/jira/browse/FLINK-16945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-16945:
--
Assignee: Biao Liu
> Execute CheckpointFailureManager.FailJobCallback directly in mai
[
https://issues.apache.org/jira/browse/FLINK-16945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-16945.
--
Fix Version/s: 1.12.0
Resolution: Fixed
merged commit 288750a into apache:maste
> Exec
[
https://issues.apache.org/jira/browse/FLINK-16945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-16945:
--
Assignee: (was: Biao Liu)
> Execute CheckpointFailureManager.FailJobCallback dire
[
https://issues.apache.org/jira/browse/FLINK-17972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-17972:
--
Assignee: (was: Roman Khachatryan)
> Consider restructuring channel state
> -
[
https://issues.apache.org/jira/browse/FLINK-16945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-16945:
---
Fix Version/s: (was: 1.13.0)
> Execute CheckpointFailureManager.FailJobCallback directly
[
https://issues.apache.org/jira/browse/FLINK-17860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-17860:
--
Assignee: (was: Roman Khachatryan)
> Recursively remove channel state directories
[
https://issues.apache.org/jira/browse/FLINK-17972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-17972:
---
Fix Version/s: (was: 1.13.0)
> Consider restructuring channel state
> --
[
https://issues.apache.org/jira/browse/FLINK-19487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-19487.
--
Fix Version/s: 1.12.0
Resolution: Fixed
merged to master as 1d43462cae9
> Checkpoint
[
https://issues.apache.org/jira/browse/FLINK-20743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-20743:
---
Priority: Minor (was: Major)
> Print ContainerId For RemoteTransportException
> ---
[
https://issues.apache.org/jira/browse/FLINK-20743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-20743:
--
Assignee: (was: yang gang)
> Print ContainerId For RemoteTransportException
> ---
[
https://issues.apache.org/jira/browse/FLINK-21820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17330023#comment-17330023
]
Leonard Xu commented on FLINK-21820:
I think this issue should be valuable to improv
Spongebob created FLINK-22422:
-
Summary: -ynm option doesn't effect when deploying flink on yarn
Key: FLINK-22422
URL: https://issues.apache.org/jira/browse/FLINK-22422
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-22408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-22408:
Component/s: (was: Table SQL / Planner)
(was: Table SQL / API)
Co
[
https://issues.apache.org/jira/browse/FLINK-22408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17330015#comment-17330015
]
Jark Wu commented on FLINK-22408:
-
Sorry, I was thinking this is used in default dialect
[
https://issues.apache.org/jira/browse/FLINK-22408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-22408:
Issue Type: Bug (was: New Feature)
> Flink Table Parsr Hive Drop Partitions Syntax unparse is Error
> ---
wangyang0918 commented on a change in pull request #15501:
URL: https://github.com/apache/flink/pull/15501#discussion_r618128773
##
File path:
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/highavailability/KubernetesLeaderElectionDriver.java
##
@@ -118,10 +115,8 @
flinkbot edited a comment on pull request #15729:
URL: https://github.com/apache/flink/pull/15729#issuecomment-825360063
## CI report:
* fe76de4bed646d6d3a0993ed52f4fccdfac752fb Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-22408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17330010#comment-17330010
]
Rui Li commented on FLINK-22408:
Hi [~jark], the feature is already supported:
https://
[
https://issues.apache.org/jira/browse/FLINK-22408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17330009#comment-17330009
]
Rui Li commented on FLINK-22408:
Hi [~aidenma], thanks for reporting the issue. I think
AHeise commented on a change in pull request #15716:
URL: https://github.com/apache/flink/pull/15716#discussion_r618964330
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.java
##
@@ -730,6 +730,12 @@ private Buff
[
https://issues.apache.org/jira/browse/FLINK-22356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17330008#comment-17330008
]
Timo Walther commented on FLINK-22356:
--
I understand the reasoning behind it but th
flinkbot edited a comment on pull request #15729:
URL: https://github.com/apache/flink/pull/15729#issuecomment-825360063
## CI report:
* fe76de4bed646d6d3a0993ed52f4fccdfac752fb Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #15722:
URL: https://github.com/apache/flink/pull/15722#issuecomment-824810068
## CI report:
* a739239b57579b6e408becbbe8976edfd91eaa03 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
SteNicholas commented on pull request #15729:
URL: https://github.com/apache/flink/pull/15729#issuecomment-825402972
@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 speci
SteNicholas removed a comment on pull request #15729:
URL: https://github.com/apache/flink/pull/15729#issuecomment-825402972
@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 t
flinkbot edited a comment on pull request #15561:
URL: https://github.com/apache/flink/pull/15561#issuecomment-817508957
## CI report:
* 5172b7b75cb1d1a100d9aef8804d98633621e235 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-22408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17329983#comment-17329983
]
Ma Jun edited comment on FLINK-22408 at 4/23/21, 5:08 AM:
--
I th
[
https://issues.apache.org/jira/browse/FLINK-22408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17329983#comment-17329983
]
Ma Jun commented on FLINK-22408:
I think the final Unparse result：
{code:java}
alter tab
[
https://issues.apache.org/jira/browse/FLINK-22408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17329983#comment-17329983
]
Ma Jun edited comment on FLINK-22408 at 4/23/21, 5:07 AM:
--
I th
Bhagi created FLINK-22421:
-
Summary: Does flink support multi cluster deployment with HA on
multi kubernetes clusters
Key: FLINK-22421
URL: https://issues.apache.org/jira/browse/FLINK-22421
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-22408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17329981#comment-17329981
]
Ma Jun commented on FLINK-22408:
We mainly use hive in the table environment. We find th
[
https://issues.apache.org/jira/browse/FLINK-21786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17329979#comment-17329979
]
Bhagi commented on FLINK-21786:
---
yes i fixed it myself.Thanks
> sample Job execution fail
[
https://issues.apache.org/jira/browse/FLINK-22139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17329977#comment-17329977
]
Bhagi commented on FLINK-22139:
---
Hi Till Rohrmann,
yes i deployed Flink's standalone sess
flinkbot edited a comment on pull request #15729:
URL: https://github.com/apache/flink/pull/15729#issuecomment-825360063
## CI report:
* fe76de4bed646d6d3a0993ed52f4fccdfac752fb Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-19449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17329970#comment-17329970
]
Jingsong Lee commented on FLINK-19449:
--
Hi [~laiyijie], do you want to fix this?
>
lindong28 commented on pull request #15713:
URL: https://github.com/apache/flink/pull/15713#issuecomment-825377168
Thank you @dawidwys for improving 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
lindong28 commented on a change in pull request #15713:
URL: https://github.com/apache/flink/pull/15713#discussion_r618929637
##
File path: flink-tests/src/test/java/org/apache/flink/test/util/TestUtils.java
##
@@ -18,41 +18,50 @@
package org.apache.flink.test.util;
-impor
lindong28 commented on a change in pull request #15713:
URL: https://github.com/apache/flink/pull/15713#discussion_r618929520
##
File path: flink-tests/src/test/java/org/apache/flink/test/util/TestUtils.java
##
@@ -18,41 +18,50 @@
package org.apache.flink.test.util;
-impor
[
https://issues.apache.org/jira/browse/FLINK-22408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17329965#comment-17329965
]
Jark Wu commented on FLINK-22408:
-
This is an unsupported feature and we should discuss
[
https://issues.apache.org/jira/browse/FLINK-22408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-22408:
Issue Type: New Feature (was: Bug)
> Flink Table Parsr Hive Drop Partitions Syntax unparse is Error
> ---
[
https://issues.apache.org/jira/browse/FLINK-21909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-21909:
Labels: (was: stale-major)
> Unify API and implementation for Hive and Filesystem source connector
> ---
[
https://issues.apache.org/jira/browse/FLINK-21905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-21905:
Labels: (was: stale-major)
> Hive streaming source should use FIFO FileSplitAssigner instead of LIFO
> -
[
https://issues.apache.org/jira/browse/FLINK-21908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-21908:
Labels: (was: stale-major)
> Support HiveSource to emit watermarks which is extract from partition value
[
https://issues.apache.org/jira/browse/FLINK-22401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17329961#comment-17329961
]
Yingjie Cao commented on FLINK-22401:
-
[~trohrmann] [~xintongsong] Really thanks for
flinkbot edited a comment on pull request #15729:
URL: https://github.com/apache/flink/pull/15729#issuecomment-825360063
## CI report:
* fe76de4bed646d6d3a0993ed52f4fccdfac752fb Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-22276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17329951#comment-17329951
]
Jin Xing commented on FLINK-22276:
--
Thanks [~mapohl] ~ I tried the patch and it works v
flinkbot commented on pull request #15729:
URL: https://github.com/apache/flink/pull/15729#issuecomment-825360063
## CI report:
* fe76de4bed646d6d3a0993ed52f4fccdfac752fb UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot edited a comment on pull request #15722:
URL: https://github.com/apache/flink/pull/15722#issuecomment-824810068
## CI report:
* 3e219e20b1dc429b5128159c24521586c0dcf9a5 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #15691:
URL: https://github.com/apache/flink/pull/15691#issuecomment-823715258
## CI report:
* b1233944fd7d2487e5da1284d8b39cc6712789e4 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-22420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guowei Ma updated FLINK-22420:
--
Description:
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=17052&view=logs&j=
Guowei Ma created FLINK-22420:
-
Summary: UnalignedCheckpointITCase failed
Key: FLINK-22420
URL: https://issues.apache.org/jira/browse/FLINK-22420
Project: Flink
Issue Type: Bug
Componen
[
https://issues.apache.org/jira/browse/FLINK-21513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17329947#comment-17329947
]
Steven Zhen Wu commented on FLINK-21513:
[~trohrmann] thanks for tagging me here
[
https://issues.apache.org/jira/browse/FLINK-22312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17329946#comment-17329946
]
Guowei Ma commented on FLINK-22312:
---
https://dev.azure.com/apache-flink/apache-flink/_
[
https://issues.apache.org/jira/browse/FLINK-21235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17329944#comment-17329944
]
Guowei Ma commented on FLINK-21235:
---
https://dev.azure.com/apache-flink/apache-flink/_
flinkbot commented on pull request #15729:
URL: https://github.com/apache/flink/pull/15729#issuecomment-825352699
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the pro
[
https://issues.apache.org/jira/browse/FLINK-22266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17329943#comment-17329943
]
Guowei Ma edited comment on FLINK-22266 at 4/23/21, 3:02 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-22266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guowei Ma reopened FLINK-22266:
---
I found that the case still failed.
https://dev.azure.com/apache-flink/apache-flink/_build/results?buil
[
https://issues.apache.org/jira/browse/FLINK-22234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-22234:
---
Labels: pull-request-available (was: )
> Read savepoint before creating ExecutionGraph
> --
SteNicholas opened a new pull request #15729:
URL: https://github.com/apache/flink/pull/15729
## What is the purpose of the change
*Savepoints are currently read when the `ExecutionGraph` is created. This is
causing problems when determining the (max) parallelism the job is run with,
flinkbot edited a comment on pull request #15722:
URL: https://github.com/apache/flink/pull/15722#issuecomment-824810068
## CI report:
* 3e219e20b1dc429b5128159c24521586c0dcf9a5 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #15727:
URL: https://github.com/apache/flink/pull/15727#issuecomment-824941920
## CI report:
* 77eaa9e82f48fcb3e3613d2d77e6ca17f8625ee5 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-22266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guowei Ma updated FLINK-22266:
--
Affects Version/s: 1.14.0
> Harden JobMasterStopWithSavepointITCase
>
[
https://issues.apache.org/jira/browse/FLINK-22345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guowei Ma updated FLINK-22345:
--
Affects Version/s: 1.14.0
> CoordinatorEventsExactlyOnceITCase hangs on azure
> --
[
https://issues.apache.org/jira/browse/FLINK-22345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17329941#comment-17329941
]
Guowei Ma edited comment on FLINK-22345 at 4/23/21, 2:53 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-22345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guowei Ma reopened FLINK-22345:
---
I still find the case in the master barnch
https://dev.azure.com/apache-flink/apache-flink/_build/result
[
https://issues.apache.org/jira/browse/FLINK-22418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-22418:
Fix Version/s: 1.13.0
> The currently activated tab in the same page isn't consistent
> --
Guowei Ma created FLINK-22419:
-
Summary: testScheduleRunAsync fail
Key: FLINK-22419
URL: https://issues.apache.org/jira/browse/FLINK-22419
Project: Flink
Issue Type: Bug
Components: Run
Dian Fu created FLINK-22418:
---
Summary: The currently activated tab in the same page isn't
consistent
Key: FLINK-22418
URL: https://issues.apache.org/jira/browse/FLINK-22418
Project: Flink
Issue Ty
flinkbot edited a comment on pull request #15722:
URL: https://github.com/apache/flink/pull/15722#issuecomment-824810068
## CI report:
* 3e219e20b1dc429b5128159c24521586c0dcf9a5 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
githubMJ commented on pull request #15722:
URL: https://github.com/apache/flink/pull/15722#issuecomment-825344412
@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 edited a comment on pull request #15716:
URL: https://github.com/apache/flink/pull/15716#issuecomment-82440
## CI report:
* b5559a35836d27b05b7d28d8ce85e0bbe1478372 UNKNOWN
* 24807f6df37404def669c6d2bf6f82fb3cce71e0 Azure:
[SUCCESS](https://dev.azure.com/apache-fl
flinkbot edited a comment on pull request #15561:
URL: https://github.com/apache/flink/pull/15561#issuecomment-817508957
## CI report:
* 85afc0e14a28cdf84f44a2013306e3257421 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #13459:
URL: https://github.com/apache/flink/pull/13459#issuecomment-697158140
## CI report:
* 95208be8c69642606dce41ba727db17831a0a580 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
godfreyhe commented on a change in pull request #15341:
URL: https://github.com/apache/flink/pull/15341#discussion_r618880846
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/SplitAggregateRule.scala
##
@@ -28
kanata163 commented on pull request #15705:
URL: https://github.com/apache/flink/pull/15705#issuecomment-825324955
@wuchong Could you please take a few minutes to review this? Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
flinkbot edited a comment on pull request #15691:
URL: https://github.com/apache/flink/pull/15691#issuecomment-823715258
## CI report:
* 8d4fb4f0ecc62b2cf95a9110517dd160b1de820d Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #15561:
URL: https://github.com/apache/flink/pull/15561#issuecomment-817508957
## CI report:
* 85afc0e14a28cdf84f44a2013306e3257421 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-22409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-22409.
Fix Version/s: (was: 1.13.0)
Resolution: Fixed
Fixed via
* master (1.14): 59cb0b43f867a
xintongsong closed pull request #15723:
URL: https://github.com/apache/flink/pull/15723
--
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.
For queries about this service, pl
flinkbot edited a comment on pull request #15691:
URL: https://github.com/apache/flink/pull/15691#issuecomment-823715258
## CI report:
* 8d4fb4f0ecc62b2cf95a9110517dd160b1de820d Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #15674:
URL: https://github.com/apache/flink/pull/15674#issuecomment-822428583
## CI report:
* fdb03ab25669629a5d26808e5e82360beb63a8d6 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-12491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kezhu Wang updated FLINK-12491:
---
Fix Version/s: 1.14.0
> Incorrect documentation for directory path separators of CoreOptions.TMP_DIR
[
https://issues.apache.org/jira/browse/FLINK-21564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kezhu Wang updated FLINK-21564:
---
Fix Version/s: 1.14.0
> CommonTestUtils.waitUntilCondition could fail with condition meets before
>
[
https://issues.apache.org/jira/browse/FLINK-12491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kezhu Wang updated FLINK-12491:
---
Labels: pull-request-available (was: pull-request-available stale-assigned)
> Incorrect documentati
[
https://issues.apache.org/jira/browse/FLINK-11409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kezhu Wang updated FLINK-11409:
---
Fix Version/s: 2.0.0
> Make `ProcessFunction`, `ProcessWindowFunction` and etc. pure interfaces
> --
[
https://issues.apache.org/jira/browse/FLINK-12491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17329916#comment-17329916
]
Kezhu Wang commented on FLINK-12491:
I guess it is still valid.
> Incorrect documen
[
https://issues.apache.org/jira/browse/FLINK-13734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young closed FLINK-13734.
--
Resolution: Implemented
I believe this is already supported.
> Support DDL in SQL CLI
>
[
https://issues.apache.org/jira/browse/FLINK-21317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kezhu Wang updated FLINK-21317:
---
Fix Version/s: 1.13.1
1.14.0
> Downstream keyed state not work after FlinkKafkaSh
[
https://issues.apache.org/jira/browse/FLINK-21317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17329911#comment-17329911
]
Kezhu Wang commented on FLINK-21317:
[~flink-jira-bot] Still valid. I will update fi
[
https://issues.apache.org/jira/browse/FLINK-21578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17329910#comment-17329910
]
Kezhu Wang commented on FLINK-21578:
Still valid. I will update fix version to 1.14
[
https://issues.apache.org/jira/browse/FLINK-21578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kezhu Wang updated FLINK-21578:
---
Fix Version/s: 1.14.0
> Closeable Sink Committer/GlobalCommitter were created to function in onestep
1 - 100 of 5050 matches
Mail list logo
