[
https://issues.apache.org/jira/browse/FLINK-25992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17488648#comment-17488648
]
Roman Khachatryan commented on FLINK-25992:
---
Sure [~Jiangang], I've attached t
[
https://issues.apache.org/jira/browse/FLINK-25992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17488648#comment-17488648
]
Roman Khachatryan edited comment on FLINK-25992 at 2/8/22, 7:56 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-25992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan updated FLINK-25992:
--
Attachment: mvn-2.log
> JobDispatcherITCase.testRecoverFromCheckpointAfterLosingAndReg
[
https://issues.apache.org/jira/browse/FLINK-23240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-23240:
--
Component/s: Runtime / Coordination
> ResumeCheckpointManuallyITCase.testExternalizedFSCheckpo
[
https://issues.apache.org/jira/browse/FLINK-25992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-25992:
--
Summary:
JobDispatcherITCase.testRecoverFromCheckpointAfterLosingAndRegainingLeadership
fails
wangyang0918 commented on a change in pull request #18531:
URL: https://github.com/apache/flink/pull/18531#discussion_r801344011
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnApplicationFileUploader.java
##
@@ -335,7 +335,7 @@ public YarnLocalResourceDescrip
flinkbot edited a comment on pull request #18637:
URL: https://github.com/apache/flink/pull/18637#issuecomment-1030235273
## CI report:
* c57bc053bd614ab5fc2f4f375db37e2caf74c4ee Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
XComp commented on a change in pull request #18637:
URL: https://github.com/apache/flink/pull/18637#discussion_r801341748
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/cleanup/DefaultResourceCleanerTest.java
##
@@ -19,50 +19,52 @@
package org.a
XComp commented on a change in pull request #18637:
URL: https://github.com/apache/flink/pull/18637#discussion_r801341748
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/cleanup/DefaultResourceCleanerTest.java
##
@@ -19,50 +19,52 @@
package org.a
[
https://issues.apache.org/jira/browse/FLINK-25664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cai Liuyang updated FLINK-25664:
Affects Version/s: 1.14.3
> Notify will be not triggered for PipelinedSubpartition if more than on
[
https://issues.apache.org/jira/browse/FLINK-25982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-25982:
---
Description: In the PoC idleness is ignored. What it means that even if all
splits are idle,
wangyang0918 commented on a change in pull request #18531:
URL: https://github.com/apache/flink/pull/18531#discussion_r801341361
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java
##
@@ -910,14 +910,28 @@ private ApplicationReport startAppM
wangyang0918 commented on a change in pull request #18531:
URL: https://github.com/apache/flink/pull/18531#discussion_r801340286
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java
##
@@ -1685,6 +1699,35 @@ void addLibFoldersToShipFiles(Coll
flinkbot edited a comment on pull request #18637:
URL: https://github.com/apache/flink/pull/18637#issuecomment-1030235273
## CI report:
* c57bc053bd614ab5fc2f4f375db37e2caf74c4ee Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
wangyang0918 commented on a change in pull request #18531:
URL: https://github.com/apache/flink/pull/18531#discussion_r801340286
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java
##
@@ -1685,6 +1699,35 @@ void addLibFoldersToShipFiles(Coll
wangyang0918 commented on a change in pull request #18531:
URL: https://github.com/apache/flink/pull/18531#discussion_r801340286
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java
##
@@ -1685,6 +1699,35 @@ void addLibFoldersToShipFiles(Coll
[
https://issues.apache.org/jira/browse/FLINK-24947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17488642#comment-17488642
]
Yuan Huang commented on FLINK-24947:
-
Yeah, I agree. And this violated the idea we
KarmaGYZ commented on a change in pull request #18360:
URL: https://github.com/apache/flink/pull/18360#discussion_r801322086
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/MemoryExecutionGraphInfoStore.java
##
@@ -20,36 +20,87 @@
import org.ap
wangyang0918 commented on a change in pull request #18531:
URL: https://github.com/apache/flink/pull/18531#discussion_r801299045
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnApplicationFileUploader.java
##
@@ -438,6 +446,18 @@ private static boolean isPlugi
bgeng777 commented on a change in pull request #18531:
URL: https://github.com/apache/flink/pull/18531#discussion_r801334847
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnApplicationFileUploader.java
##
@@ -335,7 +335,7 @@ public YarnLocalResourceDescriptor
[
https://issues.apache.org/jira/browse/FLINK-24947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17488640#comment-17488640
]
Yang Wang commented on FLINK-24947:
---
If we are using ClusterIP for the internal servic
[
https://issues.apache.org/jira/browse/FLINK-22588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17488639#comment-17488639
]
Yao Zhang commented on FLINK-22588:
---
Hi [~jark] and [~chesnay] ,
It seems that this t
bgeng777 commented on a change in pull request #18531:
URL: https://github.com/apache/flink/pull/18531#discussion_r801326923
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java
##
@@ -1799,4 +1842,27 @@ public static void logDetachedClusterI
bgeng777 commented on a change in pull request #18531:
URL: https://github.com/apache/flink/pull/18531#discussion_r801326773
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java
##
@@ -910,14 +910,28 @@ private ApplicationReport startAppMaste
flinkbot edited a comment on pull request #18548:
URL: https://github.com/apache/flink/pull/18548#issuecomment-1023865581
## CI report:
* 1046ea53f5d166b8c64e35087b8d3c5e20f0932a Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
bgeng777 commented on a change in pull request #18531:
URL: https://github.com/apache/flink/pull/18531#discussion_r801324145
##
File path: flink-yarn/pom.xml
##
@@ -130,6 +130,11 @@ under the License.
+
[
https://issues.apache.org/jira/browse/FLINK-25998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17488632#comment-17488632
]
Robert Metzger commented on FLINK-25998:
[~chesnay] Could this be related to loa
Robert Metzger created FLINK-25998:
--
Summary: Flink akka runs into NoClassDefFoundError on shutdown
Key: FLINK-25998
URL: https://issues.apache.org/jira/browse/FLINK-25998
Project: Flink
Iss
[
https://issues.apache.org/jira/browse/FLINK-24947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17488631#comment-17488631
]
Yuan Huang commented on FLINK-24947:
-
Thank you for your reply. Yes, I think so. An
flinkbot edited a comment on pull request #18653:
URL: https://github.com/apache/flink/pull/18653#issuecomment-1032212433
## CI report:
* b5b8d7da0088b0918da7b33a983ac41efa2e7da5 Azure:
[CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu
bgeng777 commented on a change in pull request #18531:
URL: https://github.com/apache/flink/pull/18531#discussion_r801320099
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java
##
@@ -1685,6 +1699,35 @@ void addLibFoldersToShipFiles(Collecti
flinkbot edited a comment on pull request #18363:
URL: https://github.com/apache/flink/pull/18363#issuecomment-1012985353
## CI report:
* 674933c78081256538559fbdd1d414ee068ed7f9 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
[
https://issues.apache.org/jira/browse/FLINK-25679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger closed FLINK-25679.
--
Fix Version/s: 1.15.0
Resolution: Fixed
> Build arm64 Linux images for Apache Flink
> -
[
https://issues.apache.org/jira/browse/FLINK-25679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17488628#comment-17488628
]
Robert Metzger commented on FLINK-25679:
It worked (not for all tags, only for s
MrWhiteSike commented on pull request #18655:
URL: https://github.com/apache/flink/pull/18655#issuecomment-1032274801
Hi, [@wuchong](https://github.com/wuchong) Would you mind helping to check
this pr?
--
This is an automated message from the Apache Git Service.
To respond to the message
flinkbot edited a comment on pull request #16105:
URL: https://github.com/apache/flink/pull/16105#issuecomment-856602024
## CI report:
* d968667c3ee2d1acb59ca901f7c5f4f2fec1497c Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #16105:
URL: https://github.com/apache/flink/pull/16105#issuecomment-856602024
## CI report:
* d968667c3ee2d1acb59ca901f7c5f4f2fec1497c Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #18360:
URL: https://github.com/apache/flink/pull/18360#issuecomment-1012981724
## CI report:
* 5d6e58afe6c78826c56e5cd802f2f3ef10a0133f Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
zjureel commented on pull request #18360:
URL: https://github.com/apache/flink/pull/18360#issuecomment-1032267886
Thanks @KarmaGYZ , use cache in `MemoryExecutionGraphInfoStore` instead of
queue and hashmap sounds good to me. I have update the code in
`MemoryExecutionGraphInfoStore` and th
flinkbot edited a comment on pull request #18655:
URL: https://github.com/apache/flink/pull/18655#issuecomment-1032265310
## CI report:
* a41a95c7619f337c9fd07cdca68e572921f61de8 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18360:
URL: https://github.com/apache/flink/pull/18360#issuecomment-1012981724
## CI report:
* 5d6e58afe6c78826c56e5cd802f2f3ef10a0133f Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot commented on pull request #18655:
URL: https://github.com/apache/flink/pull/18655#issuecomment-1032266881
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 pr
flinkbot commented on pull request #18655:
URL: https://github.com/apache/flink/pull/18655#issuecomment-1032265310
## CI report:
* a41a95c7619f337c9fd07cdca68e572921f61de8 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
[
https://issues.apache.org/jira/browse/FLINK-25799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-25799:
---
Labels: chinese-translation pull-request-available (was:
chinese-translation)
> Translate
[
https://issues.apache.org/jira/browse/FLINK-25992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17488622#comment-17488622
]
Liu commented on FLINK-25992:
-
[~roman] Thanks for the report. Indeed, the class AtLeastOneC
MrWhiteSike opened a new pull request #18655:
URL: https://github.com/apache/flink/pull/18655
## 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 the
flinkbot edited a comment on pull request #18654:
URL: https://github.com/apache/flink/pull/18654#issuecomment-1032258711
## CI report:
* 23cd7d2fe248dc4020a349bf64e7c9cc6e716c4c Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
[
https://issues.apache.org/jira/browse/FLINK-24947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17488620#comment-17488620
]
Yang Wang commented on FLINK-24947:
---
I believe the TaskManager pods could not be reuse
flinkbot commented on pull request #18654:
URL: https://github.com/apache/flink/pull/18654#issuecomment-1032260570
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 pr
masteryhx commented on pull request #18654:
URL: https://github.com/apache/flink/pull/18654#issuecomment-1032260411
@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 specif
flinkbot edited a comment on pull request #18654:
URL: https://github.com/apache/flink/pull/18654#issuecomment-1032258711
## CI report:
* 23cd7d2fe248dc4020a349bf64e7c9cc6e716c4c Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot commented on pull request #18654:
URL: https://github.com/apache/flink/pull/18654#issuecomment-1032258711
## CI report:
* 23cd7d2fe248dc4020a349bf64e7c9cc6e716c4c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
[
https://issues.apache.org/jira/browse/FLINK-25997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-25997:
---
Labels: pull-request-available (was: )
> FsStateChangelogWriter cannot work well when there
masteryhx opened a new pull request #18654:
URL: https://github.com/apache/flink/pull/18654
## What is the purpose of the change
This pull request modifies the way ChangelogKeyedStateBackend uses the sqn
maintained by FsStateChangelogWriter.
Avoid always using sqn.next() t
[
https://issues.apache.org/jira/browse/FLINK-24295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhilong Hong updated FLINK-24295:
-
Component/s: Runtime / Network
(was: Runtime / Coordination)
> Too many req
[
https://issues.apache.org/jira/browse/FLINK-25055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17488616#comment-17488616
]
Zhilong Hong commented on FLINK-25055:
--
I think this improvement will also solve FL
[
https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-24897:
--
Summary: Make usrlib could work for YARN application and per-job (was:
Enable application mode on YAR
wangyang0918 commented on a change in pull request #18531:
URL: https://github.com/apache/flink/pull/18531#discussion_r801282398
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java
##
@@ -1685,6 +1699,35 @@ void addLibFoldersToShipFiles(Coll
[
https://issues.apache.org/jira/browse/FLINK-24307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17488608#comment-17488608
]
Yao Zhang commented on FLINK-24307:
---
Hi [~twalthr] ,
Could you please review this iss
flinkbot edited a comment on pull request #18653:
URL: https://github.com/apache/flink/pull/18653#issuecomment-1032212433
## CI report:
* b5b8d7da0088b0918da7b33a983ac41efa2e7da5 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
[
https://issues.apache.org/jira/browse/FLINK-25997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu updated FLINK-25997:
-
Description: For FsStateChangelogWriter, If there is no change appended, we
should use the old s
[
https://issues.apache.org/jira/browse/FLINK-25995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-25995:
Description:
If there are multiple consecutive the same groupBy(i.e. keyBy), SQL planner
will change them
paul8263 closed pull request #16017:
URL: https://github.com/apache/flink/pull/16017
--
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-unsubs
flinkbot edited a comment on pull request #18653:
URL: https://github.com/apache/flink/pull/18653#issuecomment-1032212433
## CI report:
* b5b8d7da0088b0918da7b33a983ac41efa2e7da5 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
Hangxiang Yu created FLINK-25997:
Summary: FsStateChangelogWriter cannot work well when there is no
change appended
Key: FLINK-25997
URL: https://issues.apache.org/jira/browse/FLINK-25997
Project: Fli
flinkbot edited a comment on pull request #18653:
URL: https://github.com/apache/flink/pull/18653#issuecomment-1032212433
## CI report:
* b5b8d7da0088b0918da7b33a983ac41efa2e7da5 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18653:
URL: https://github.com/apache/flink/pull/18653#issuecomment-1032212433
## CI report:
* b5b8d7da0088b0918da7b33a983ac41efa2e7da5 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
gaoyunhaii commented on a change in pull request #18642:
URL: https://github.com/apache/flink/pull/18642#discussion_r801283600
##
File path:
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/sink/committer/FileCommitter.java
##
@@ -48,9 +47,1
flinkbot edited a comment on pull request #18653:
URL: https://github.com/apache/flink/pull/18653#issuecomment-1032212433
## CI report:
* b5b8d7da0088b0918da7b33a983ac41efa2e7da5 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18653:
URL: https://github.com/apache/flink/pull/18653#issuecomment-1032212433
## CI report:
* b5b8d7da0088b0918da7b33a983ac41efa2e7da5 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18653:
URL: https://github.com/apache/flink/pull/18653#issuecomment-1032212433
## CI report:
* b5b8d7da0088b0918da7b33a983ac41efa2e7da5 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot commented on pull request #18653:
URL: https://github.com/apache/flink/pull/18653#issuecomment-1032213135
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 pr
flinkbot commented on pull request #18653:
URL: https://github.com/apache/flink/pull/18653#issuecomment-1032212433
## CI report:
* b5b8d7da0088b0918da7b33a983ac41efa2e7da5 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
[
https://issues.apache.org/jira/browse/FLINK-25825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-25825:
---
Labels: pull-request-available test-stability (was: test-stability)
> MySqlCatalogITCase fa
RocMarshal opened a new pull request #18653:
URL: https://github.com/apache/flink/pull/18653
## What is the purpose of the change
*Fix `MySqlCatalogITCase` fails on azure*
## Brief change log
**connector-jdbc module**
- *Use test-container to refactor `Unsig
flinkbot edited a comment on pull request #18548:
URL: https://github.com/apache/flink/pull/18548#issuecomment-1023865581
## CI report:
* b5a79055a0b63e26f0b4d96c1c79a87b42efec33 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18548:
URL: https://github.com/apache/flink/pull/18548#issuecomment-1023865581
## CI report:
* b5a79055a0b63e26f0b4d96c1c79a87b42efec33 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
pltbkd commented on a change in pull request #18642:
URL: https://github.com/apache/flink/pull/18642#discussion_r801253773
##
File path:
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/sink/committer/FileCommitter.java
##
@@ -48,9 +47,10 @@
flinkbot edited a comment on pull request #18548:
URL: https://github.com/apache/flink/pull/18548#issuecomment-1023865581
## CI report:
* b5a79055a0b63e26f0b4d96c1c79a87b42efec33 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
[
https://issues.apache.org/jira/browse/FLINK-25940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo reassigned FLINK-25940:
Assignee: Huang Xingbo
> pyflink/datastream/tests/test_data_stream.py::StreamingModeDataS
[
https://issues.apache.org/jira/browse/FLINK-24477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17488580#comment-17488580
]
RocMarshal commented on FLINK-24477:
Thanks [~nir.tsruya] , cc [~monster#12]
> Add
flinkbot edited a comment on pull request #18363:
URL: https://github.com/apache/flink/pull/18363#issuecomment-1012985353
## CI report:
* 023810c97360cbec41e825735054561aa9ed2dcd Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18363:
URL: https://github.com/apache/flink/pull/18363#issuecomment-1012985353
## CI report:
* 023810c97360cbec41e825735054561aa9ed2dcd Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
Zhu Zhu created FLINK-25996:
---
Summary: Introduce job property isDynamicGraph to ExecutionConfig
Key: FLINK-25996
URL: https://issues.apache.org/jira/browse/FLINK-25996
Project: Flink
Issue Type: Su
zjureel commented on pull request #18303:
URL: https://github.com/apache/flink/pull/18303#issuecomment-1032181406
Thanks @XComp @dmvk @KarmaGYZ , I have run this PR in my devops after rebase
the commits from master in 20220207.1-20220207.8 in
https://dev.azure.com/zjureel/flink/_build?defi
Zhu Zhu created FLINK-25995:
---
Summary: Make implicit assumption of SQL local keyBy/groupBy
explicit
Key: FLINK-25995
URL: https://issues.apache.org/jira/browse/FLINK-25995
Project: Flink
Issue Typ
[
https://issues.apache.org/jira/browse/FLINK-25994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-25994:
---
Labels: pull-request-available (was: )
> Implement FileStoreExpire
> --
tsreaper opened a new pull request #17:
URL: https://github.com/apache/flink-table-store/pull/17
Currently FileStoreExpire does not have an implementation. We need an
implementation to clean up old snapshots and related files.
--
This is an automated message from the Apache Git Service.
Caizhi Weng created FLINK-25994:
---
Summary: Implement FileStoreExpire
Key: FLINK-25994
URL: https://issues.apache.org/jira/browse/FLINK-25994
Project: Flink
Issue Type: Sub-task
Compon
[
https://issues.apache.org/jira/browse/FLINK-25152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng updated FLINK-25152:
Labels: (was: pull-request-available)
> FLIP-188: Introduce Built-in Dynamic Table Storage
> ---
martin-liu commented on pull request #18561:
URL: https://github.com/apache/flink/pull/18561#issuecomment-1032150418
@dianfu The CI check is finished successfully, anything else do we need?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
flinkbot edited a comment on pull request #18643:
URL: https://github.com/apache/flink/pull/18643#issuecomment-1031337336
## CI report:
* ccbf0ea3c22de75e75a10f517c606d83f8c9543c Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
[
https://issues.apache.org/jira/browse/FLINK-25529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17488558#comment-17488558
]
luoyuxia commented on FLINK-25529:
--
[~straw] I think you can use hive-exec-2.2.0.jar in
[
https://issues.apache.org/jira/browse/FLINK-24558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17488549#comment-17488549
]
bai sui edited comment on FLINK-24558 at 2/8/22, 2:12 AM:
--
[~Ro
[
https://issues.apache.org/jira/browse/FLINK-24558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17488549#comment-17488549
]
bai sui commented on FLINK-24558:
-
[~RocMarshal] hi,@RocMarshal ,I have fix the bugs th
[
https://issues.apache.org/jira/browse/FLINK-24558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
bai sui updated FLINK-24558:
Labels: pull-request-available (was: pull-request-available stale-assigned)
> dataStream can not use mult
mans2singh commented on pull request #18576:
URL: https://github.com/apache/flink/pull/18576#issuecomment-1032129266
@wuchong - Can you please review this PR ? Thanks
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
[
https://issues.apache.org/jira/browse/FLINK-25801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
王俊博 updated FLINK-25801:
Priority: Major (was: Minor)
> add cpu processor metric of taskmanager
> ---
flint-stone closed pull request #299:
URL: https://github.com/apache/flink-statefun/pull/299
--
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: issue
[
https://issues.apache.org/jira/browse/FLINK-25916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17488481#comment-17488481
]
Corey Shaw commented on FLINK-25916:
I can confirm that `timeGMT` is always non null
1 - 100 of 566 matches
Mail list logo
