[
https://issues.apache.org/jira/browse/FLINK-25992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17488648#comment-17488648
]
Roman Khachatryan commented on FLINK-25992:
---
Sure [~Jiangang], I've attached the log file (you
[
https://issues.apache.org/jira/browse/FLINK-25992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
>
[
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
>
[
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
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
flinkbot edited a comment on pull request #18637:
URL: https://github.com/apache/flink/pull/18637#issuecomment-1030235273
## CI report:
* c57bc053bd614ab5fc2f4f375db37e2caf74c4ee Azure:
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
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
[
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
[
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
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
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
flinkbot edited a comment on pull request #18637:
URL: https://github.com/apache/flink/pull/18637#issuecomment-1030235273
## CI report:
* c57bc053bd614ab5fc2f4f375db37e2caf74c4ee Azure:
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
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
[
https://issues.apache.org/jira/browse/FLINK-24947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17488642#comment-17488642
]
Yuan Huang commented on FLINK-24947:
-
Yeah, I agree. And this violated the idea we want to use
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
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
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=17488640#comment-17488640
]
Yang Wang commented on FLINK-24947:
---
If we are using ClusterIP for the internal service, then we have
[
https://issues.apache.org/jira/browse/FLINK-22588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17488639#comment-17488639
]
Yao Zhang commented on FLINK-22588:
---
Hi [~jark] and [~chesnay] ,
It seems that this ticket is left
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
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
flinkbot edited a comment on pull request #18548:
URL: https://github.com/apache/flink/pull/18548#issuecomment-1023865581
## CI report:
* 1046ea53f5d166b8c64e35087b8d3c5e20f0932a Azure:
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=17488632#comment-17488632
]
Robert Metzger commented on FLINK-25998:
[~chesnay] Could this be related to loading akka using
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
[
https://issues.apache.org/jira/browse/FLINK-24947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17488631#comment-17488631
]
Yuan Huang commented on FLINK-24947:
-
Thank you for your reply. Yes, I think so. And I believe even
flinkbot edited a comment on pull request #18653:
URL: https://github.com/apache/flink/pull/18653#issuecomment-1032212433
## CI report:
* b5b8d7da0088b0918da7b33a983ac41efa2e7da5 Azure:
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
flinkbot edited a comment on pull request #18363:
URL: https://github.com/apache/flink/pull/18363#issuecomment-1012985353
## CI report:
* 674933c78081256538559fbdd1d414ee068ed7f9 Azure:
[
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=17488628#comment-17488628
]
Robert Metzger commented on FLINK-25679:
It worked (not for all tags, only for some, but I guess
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
flinkbot edited a comment on pull request #16105:
URL: https://github.com/apache/flink/pull/16105#issuecomment-856602024
## CI report:
* d968667c3ee2d1acb59ca901f7c5f4f2fec1497c Azure:
flinkbot edited a comment on pull request #16105:
URL: https://github.com/apache/flink/pull/16105#issuecomment-856602024
## CI report:
* d968667c3ee2d1acb59ca901f7c5f4f2fec1497c Azure:
flinkbot edited a comment on pull request #18360:
URL: https://github.com/apache/flink/pull/18360#issuecomment-1012981724
## CI report:
* 5d6e58afe6c78826c56e5cd802f2f3ef10a0133f Azure:
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
flinkbot edited a comment on pull request #18655:
URL: https://github.com/apache/flink/pull/18655#issuecomment-1032265310
## CI report:
* a41a95c7619f337c9fd07cdca68e572921f61de8 Azure:
flinkbot edited a comment on pull request #18360:
URL: https://github.com/apache/flink/pull/18360#issuecomment-1012981724
## CI report:
* 5d6e58afe6c78826c56e5cd802f2f3ef10a0133f Azure:
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
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=17488622#comment-17488622
]
Liu commented on FLINK-25992:
-
[~roman] Thanks for the report. Indeed, the class
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
flinkbot edited a comment on pull request #18654:
URL: https://github.com/apache/flink/pull/18654#issuecomment-1032258711
## CI report:
* 23cd7d2fe248dc4020a349bf64e7c9cc6e716c4c Azure:
[
https://issues.apache.org/jira/browse/FLINK-24947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17488620#comment-17488620
]
Yang Wang commented on FLINK-24947:
---
I believe the TaskManager pods could not be reused with host
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
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
flinkbot edited a comment on pull request #18654:
URL: https://github.com/apache/flink/pull/18654#issuecomment-1032258711
## CI report:
* 23cd7d2fe248dc4020a349bf64e7c9cc6e716c4c Azure:
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
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()
[
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
[
https://issues.apache.org/jira/browse/FLINK-25055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17488616#comment-17488616
]
Zhilong Hong commented on FLINK-25055:
--
I think this improvement will also solve FLINK-24295. In
[
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
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
[
https://issues.apache.org/jira/browse/FLINK-24307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17488608#comment-17488608
]
Yao Zhang commented on FLINK-24307:
---
Hi [~twalthr] ,
Could you please review this issue? Thanks.
>
flinkbot edited a comment on pull request #18653:
URL: https://github.com/apache/flink/pull/18653#issuecomment-1032212433
## CI report:
* b5b8d7da0088b0918da7b33a983ac41efa2e7da5 Azure:
[
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
[
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
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:
flinkbot edited a comment on pull request #18653:
URL: https://github.com/apache/flink/pull/18653#issuecomment-1032212433
## CI report:
* b5b8d7da0088b0918da7b33a983ac41efa2e7da5 Azure:
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:
flinkbot edited a comment on pull request #18653:
URL: https://github.com/apache/flink/pull/18653#issuecomment-1032212433
## CI report:
* b5b8d7da0088b0918da7b33a983ac41efa2e7da5 Azure:
flinkbot edited a comment on pull request #18653:
URL: https://github.com/apache/flink/pull/18653#issuecomment-1032212433
## CI report:
* b5b8d7da0088b0918da7b33a983ac41efa2e7da5 Azure:
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
flinkbot edited a comment on pull request #18653:
URL: https://github.com/apache/flink/pull/18653#issuecomment-1032212433
## CI report:
* b5b8d7da0088b0918da7b33a983ac41efa2e7da5 Azure:
flinkbot edited a comment on pull request #18653:
URL: https://github.com/apache/flink/pull/18653#issuecomment-1032212433
## CI report:
* b5b8d7da0088b0918da7b33a983ac41efa2e7da5 Azure:
flinkbot edited a comment on pull request #18653:
URL: https://github.com/apache/flink/pull/18653#issuecomment-1032212433
## CI report:
* b5b8d7da0088b0918da7b33a983ac41efa2e7da5 Azure:
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
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
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
flinkbot edited a comment on pull request #18548:
URL: https://github.com/apache/flink/pull/18548#issuecomment-1023865581
## CI report:
* b5a79055a0b63e26f0b4d96c1c79a87b42efec33 Azure:
flinkbot edited a comment on pull request #18548:
URL: https://github.com/apache/flink/pull/18548#issuecomment-1023865581
## CI report:
* b5a79055a0b63e26f0b4d96c1c79a87b42efec33 Azure:
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:
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-24477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17488580#comment-17488580
]
RocMarshal commented on FLINK-24477:
Thanks [~nir.tsruya] , cc [~monster#12]
> Add MongoDB sink
>
flinkbot edited a comment on pull request #18363:
URL: https://github.com/apache/flink/pull/18363#issuecomment-1012985353
## CI report:
* 023810c97360cbec41e825735054561aa9ed2dcd Azure:
flinkbot edited a comment on pull request #18363:
URL: https://github.com/apache/flink/pull/18363#issuecomment-1012985353
## CI report:
* 023810c97360cbec41e825735054561aa9ed2dcd Azure:
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:
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
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
[
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
[
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:
[
https://issues.apache.org/jira/browse/FLINK-25529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17488558#comment-17488558
]
luoyuxia commented on FLINK-25529:
--
[~straw] I think you can use hive-exec-2.2.0.jar instead. It's fine
[
https://issues.apache.org/jira/browse/FLINK-24558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17488549#comment-17488549
]
bai sui edited comment on FLINK-24558 at 2/8/22, 2:12 AM:
--
[~RocMarshal]
[
https://issues.apache.org/jira/browse/FLINK-24558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17488549#comment-17488549
]
bai sui commented on FLINK-24558:
-
[~RocMarshal] hi,@RocMarshal ,I have fix the bugs that you have
[
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
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:
[
https://issues.apache.org/jira/browse/FLINK-25916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17488481#comment-17488481
]
Corey Shaw commented on FLINK-25916:
I can confirm that `timeGMT` is always non null. As mentioned
1 - 100 of 566 matches
Mail list logo
