Fabian Paul created FLINK-24382:
---
Summary: RecordsOut metric for sinks is inaccurate
Key: FLINK-24382
URL: https://issues.apache.org/jira/browse/FLINK-24382
Project: Flink
Issue Type: Improveme
Ada Wong created FLINK-24381:
Summary: Hidden password value when Flink SQL connector throw
exception.
Key: FLINK-24381
URL: https://issues.apache.org/jira/browse/FLINK-24381
Project: Flink
Issu
[
https://issues.apache.org/jira/browse/FLINK-24379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17420507#comment-17420507
]
Martijn Visser commented on FLINK-24379:
[~dannycranmer] Do you want to have a l
[
https://issues.apache.org/jira/browse/FLINK-24379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-24379:
--
Assignee: Brad Davis
> AWS Glue Schema Registry support doesn't work for table API
>
[
https://issues.apache.org/jira/browse/FLINK-24207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17420493#comment-17420493
]
Arvid Heise commented on FLINK-24207:
-
I double checked and the new {{SinkOperator}}
[
https://issues.apache.org/jira/browse/FLINK-24207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17420492#comment-17420492
]
Arvid Heise commented on FLINK-24207:
-
I'm a bit torn on this one. It sounds like a
[
https://issues.apache.org/jira/browse/FLINK-24207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17420492#comment-17420492
]
Arvid Heise edited comment on FLINK-24207 at 9/27/21, 6:06 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-20370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17420489#comment-17420489
]
Jingsong Lee commented on FLINK-20370:
--
4.primary key contains unique key , in this
[
https://issues.apache.org/jira/browse/FLINK-24379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17420479#comment-17420479
]
Brad Davis commented on FLINK-24379:
[https://github.com/apache/flink/pull/17360]
[
https://issues.apache.org/jira/browse/FLINK-24379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-24379:
---
Labels: pull-request-available (was: )
> AWS Glue Schema Registry support doesn't work for
jherico opened a new pull request #17360:
URL: https://github.com/apache/flink/pull/17360
Fix for https://issues.apache.org/jira/browse/FLINK-24379
## What is the purpose of the change
Add missing components required to use the AWS Glue Schema registry in Table
connectors.
[
https://issues.apache.org/jira/browse/FLINK-23493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17420478#comment-17420478
]
Xintong Song commented on FLINK-23493:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-24117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17420468#comment-17420468
]
Aitozi commented on FLINK-24117:
Hi [~trohrmann], some other thoughts come to my mind th
flinkbot edited a comment on pull request #17357:
URL: https://github.com/apache/flink/pull/17357#issuecomment-927321538
## CI report:
* c615e2152cf0168c53e4712c7d4125de65ae126f Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17357:
URL: https://github.com/apache/flink/pull/17357#issuecomment-927321538
## CI report:
* c615e2152cf0168c53e4712c7d4125de65ae126f Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-24380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang reassigned FLINK-24380:
-
Assignee: Yangze Guo
> Flink should handle the state transition of the pod from Pending to Fail
[
https://issues.apache.org/jira/browse/FLINK-24380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17420462#comment-17420462
]
Yang Wang commented on FLINK-24380:
---
Thanks for creating this ticket. I have assigned
[
https://issues.apache.org/jira/browse/FLINK-21032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17420460#comment-17420460
]
Xintong Song commented on FLINK-21032:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-20928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17420459#comment-17420459
]
Xintong Song commented on FLINK-20928:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-24380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17420458#comment-17420458
]
Yangze Guo commented on FLINK-24380:
[~wangyang0918] Would you assign this to me?
>
Yangze Guo created FLINK-24380:
--
Summary: Flink should handle the state transition of the pod from
Pending to Failed
Key: FLINK-24380
URL: https://issues.apache.org/jira/browse/FLINK-24380
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-24358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song reopened FLINK-24358:
--
Reopen for the same problem in e2e test modules.
> flink-avro-glue-schema-registry fails compilin
[
https://issues.apache.org/jira/browse/FLINK-24374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17420454#comment-17420454
]
Xintong Song edited comment on FLINK-24374 at 9/27/21, 3:03 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-24374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17420454#comment-17420454
]
Xintong Song commented on FLINK-24374:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-24374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-24374:
-
Priority: Critical (was: Major)
> ManualCheckpointITCase.testTriggeringWhenPeriodicDisabled fai
Brad Davis created FLINK-24379:
--
Summary: AWS Glue Schema Registry support doesn't work for table
API
Key: FLINK-24379
URL: https://issues.apache.org/jira/browse/FLINK-24379
Project: Flink
Issu
[
https://issues.apache.org/jira/browse/FLINK-13247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17420436#comment-17420436
]
LI Mingkun commented on FLINK-13247:
Is there any related MR or design doc? [~maguow
[
https://issues.apache.org/jira/browse/FLINK-22585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-22585:
---
Labels: auto-unassigned pull-request-available stale-assigned (was:
auto-unassigned pull-re
[
https://issues.apache.org/jira/browse/FLINK-18822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-18822:
---
Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned
stale-major)
P
[
https://issues.apache.org/jira/browse/FLINK-23595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-23595:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the [Flink
[
https://issues.apache.org/jira/browse/FLINK-23526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-23526:
---
Labels: stale-major test-stability (was: test-stability)
I am the [Flink Jira Bot|https://g
[
https://issues.apache.org/jira/browse/FLINK-23604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-23604:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the [Flink
[
https://issues.apache.org/jira/browse/FLINK-23995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-23995:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the [Flink
flinkbot edited a comment on pull request #17358:
URL: https://github.com/apache/flink/pull/17358#issuecomment-927338621
## CI report:
* 981f572c4deb0346b935b8eda2720ee18b67d9c0 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17357:
URL: https://github.com/apache/flink/pull/17357#issuecomment-927321538
## CI report:
* c615e2152cf0168c53e4712c7d4125de65ae126f Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17358:
URL: https://github.com/apache/flink/pull/17358#issuecomment-927338621
## CI report:
* 981f572c4deb0346b935b8eda2720ee18b67d9c0 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot commented on pull request #17358:
URL: https://github.com/apache/flink/pull/17358#issuecomment-927338621
## CI report:
* 981f572c4deb0346b935b8eda2720ee18b67d9c0 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot commented on pull request #17358:
URL: https://github.com/apache/flink/pull/17358#issuecomment-927334955
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
qianchutao opened a new pull request #17358:
URL: https://github.com/apache/flink/pull/17358
## What is the purpose of the change
This pull request fixTypo 'Kakfa' corrected to 'Kafka'
--
This is an automated message from the Apache Git Service.
To respond to t
rkhachatryan commented on a change in pull request #16606:
URL: https://github.com/apache/flink/pull/16606#discussion_r716222670
##
File path:
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/PeriodicMaterializationManager.java
#
rkhachatryan commented on a change in pull request #16606:
URL: https://github.com/apache/flink/pull/16606#discussion_r716222836
##
File path:
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/PeriodicMaterializationManager.java
#
rkhachatryan commented on a change in pull request #16606:
URL: https://github.com/apache/flink/pull/16606#discussion_r71628
##
File path:
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java
##
@@
flinkbot edited a comment on pull request #17357:
URL: https://github.com/apache/flink/pull/17357#issuecomment-927321538
## CI report:
* c615e2152cf0168c53e4712c7d4125de65ae126f Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot commented on pull request #17357:
URL: https://github.com/apache/flink/pull/17357#issuecomment-927321538
## CI report:
* c615e2152cf0168c53e4712c7d4125de65ae126f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot commented on pull request #17357:
URL: https://github.com/apache/flink/pull/17357#issuecomment-927314315
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-24375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-24375:
---
Labels: pull-request-available (was: )
> The name of flush thread in RecordWriter should co
wanglijie95 opened a new pull request #17357:
URL: https://github.com/apache/flink/pull/17357
## What is the purpose of the change
Let name of flush thread in RecordWriter contain subtask index.
## Brief change log
Let name of flush thread in RecordWriter contain subtask
flinkbot edited a comment on pull request #16606:
URL: https://github.com/apache/flink/pull/16606#issuecomment-887431748
## CI report:
* 264be5cc6a0485171413099e8b64b9e917d06e85 UNKNOWN
* 1b7da8565a2ab9560f1aad65007930c91945087f UNKNOWN
* f77f6bd12ea5a6b1cf8f698c8b36bfab394d
lindong28 commented on a change in pull request #7:
URL: https://github.com/apache/flink-ml/pull/7#discussion_r716198679
##
File path:
flink-ml-iteration/src/main/java/org/apache/flink/ml/iteration/IterationRecord.java
##
@@ -0,0 +1,145 @@
+/*
+ * Licensed to the Apache Softwa
lindong28 commented on pull request #6:
URL: https://github.com/apache/flink-ml/pull/6#issuecomment-927299201
Thanks for the PR @gaoyunhaii. It is not clear why FLIP-176 needs this
`BroadcastOutput`. Can you explain it? And is there any existing end-to-end
test that shows how to support an
flinkbot edited a comment on pull request #17355:
URL: https://github.com/apache/flink/pull/17355#issuecomment-927260249
## CI report:
* 5c3a63f96646705c4f9ecd232908cad53a8ea2eb Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
RocMarshal edited a comment on pull request #16962:
URL: https://github.com/apache/flink/pull/16962#issuecomment-925446816
Hi, @MartijnVisser @Airblader @wuchong @twalthr @libenchao , I made some
changes based on your suggestions. Could you help me to review it ? Thank you
so much for yo
[
https://issues.apache.org/jira/browse/FLINK-24377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17420282#comment-17420282
]
zlzhang0122 commented on FLINK-24377:
-
We also have encountered this situation too.
[
https://issues.apache.org/jira/browse/FLINK-24378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ranqiqiang updated FLINK-24378:
---
Description:
hello:
If binlog source table-A data is : \{id : 1 , name:'king' }
[
https://issues.apache.org/jira/browse/FLINK-24378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ranqiqiang updated FLINK-24378:
---
Description:
hello:
If binlog source table-A data is : \{id : 1 , name:'king' }
[
https://issues.apache.org/jira/browse/FLINK-24375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17420272#comment-17420272
]
Lijie Wang commented on FLINK-24375:
Thanks [~zhuzh], I will prepare a pr for this s
flinkbot edited a comment on pull request #17356:
URL: https://github.com/apache/flink/pull/17356#issuecomment-927266300
## CI report:
* 7e9dc5baa8fac341a8f5131bbcd4b3ab1a68b8fb Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-24293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17420270#comment-17420270
]
Zhu Zhu commented on FLINK-24293:
-
I think "yarn.provided.lib.dirs" can be used for user
ranqiqiang created FLINK-24378:
--
Summary: Dim table join operator Push down
Key: FLINK-24378
URL: https://issues.apache.org/jira/browse/FLINK-24378
Project: Flink
Issue Type: Improvement
flinkbot edited a comment on pull request #16606:
URL: https://github.com/apache/flink/pull/16606#issuecomment-887431748
## CI report:
* 264be5cc6a0485171413099e8b64b9e917d06e85 UNKNOWN
* 1b7da8565a2ab9560f1aad65007930c91945087f UNKNOWN
* f77f6bd12ea5a6b1cf8f698c8b36bfab394d
[
https://issues.apache.org/jira/browse/FLINK-22915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin resolved FLINK-22915.
--
Resolution: Implemented
Merged to master: 5ff346ea1a508a00b89759492f09e7330e69baef
> FLIP-173
[
https://issues.apache.org/jira/browse/FLINK-22915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated FLINK-22915:
-
Fix Version/s: 0.1.0
> FLIP-173: Support DAG of algorithms
> ---
[
https://issues.apache.org/jira/browse/FLINK-22915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin reassigned FLINK-22915:
Assignee: Dong Lin
> FLIP-173: Support DAG of algorithms
> --
becketqin merged pull request #4:
URL: https://github.com/apache/flink-ml/pull/4
--
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..
becketqin commented on pull request #4:
URL: https://github.com/apache/flink-ml/pull/4#issuecomment-927271574
Thanks for the patch. LGTM.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the spec
flinkbot edited a comment on pull request #17356:
URL: https://github.com/apache/flink/pull/17356#issuecomment-927266300
## CI report:
* 7e9dc5baa8fac341a8f5131bbcd4b3ab1a68b8fb Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #16606:
URL: https://github.com/apache/flink/pull/16606#issuecomment-887431748
## CI report:
* 264be5cc6a0485171413099e8b64b9e917d06e85 UNKNOWN
* 1b7da8565a2ab9560f1aad65007930c91945087f UNKNOWN
* f77f6bd12ea5a6b1cf8f698c8b36bfab394d
[
https://issues.apache.org/jira/browse/FLINK-24274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17420239#comment-17420239
]
Feifan Wang commented on FLINK-24274:
-
Hi [~sjwiesman] , please help me review this
[
https://issues.apache.org/jira/browse/FLINK-24375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-24375:
Fix Version/s: 1.15.0
> The name of flush thread in RecordWriter should contain subtask index
> --
[
https://issues.apache.org/jira/browse/FLINK-24375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17420235#comment-17420235
]
Zhu Zhu commented on FLINK-24375:
-
Thanks for reporting this! [~wanglijie95]
I think it'
[
https://issues.apache.org/jira/browse/FLINK-24375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-24375:
Priority: Major (was: Minor)
> The name of flush thread in RecordWriter should contain subtask index
> --
flinkbot commented on pull request #17356:
URL: https://github.com/apache/flink/pull/17356#issuecomment-927266300
## CI report:
* 7e9dc5baa8fac341a8f5131bbcd4b3ab1a68b8fb UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot edited a comment on pull request #17355:
URL: https://github.com/apache/flink/pull/17355#issuecomment-927260249
## CI report:
* 5c3a63f96646705c4f9ecd232908cad53a8ea2eb Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-24375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-24375:
---
Assignee: Lijie Wang
> The name of flush thread in RecordWriter should contain subtask index
>
lindong28 commented on a change in pull request #5:
URL: https://github.com/apache/flink-ml/pull/5#discussion_r716167186
##
File path:
flink-ml-iteration/src/main/java/org/apache/flink/ml/iteration/IterationBody.java
##
@@ -0,0 +1,35 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-24293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17420228#comment-17420228
]
huntercc commented on FLINK-24293:
--
Thanks for your reply, [~zhuzh]. I agree with your
flinkbot commented on pull request #17355:
URL: https://github.com/apache/flink/pull/17355#issuecomment-927260249
## CI report:
* 5c3a63f96646705c4f9ecd232908cad53a8ea2eb UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot commented on pull request #17356:
URL: https://github.com/apache/flink/pull/17356#issuecomment-927259603
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
leonardBang commented on pull request #17356:
URL: https://github.com/apache/flink/pull/17356#issuecomment-927259493
cc: @wuchong @sjwiesman, Could you help review this doc change?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
[
https://issues.apache.org/jira/browse/FLINK-23313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-23313:
---
Labels: pull-request-available (was: )
> Reintroduce temporal table function documentation
leonardBang opened a new pull request #17356:
URL: https://github.com/apache/flink/pull/17356
## What is the purpose of the change
* This pull request reintroduce the temporal table function documentation,
the temporal table function feature has never been deprecated but the
docume
lindong28 commented on pull request #5:
URL: https://github.com/apache/flink-ml/pull/5#issuecomment-927258280
Thanks for the PR @gaoyunhaii. Could you create JIRA for FLIP-176 and add
JIRA to the PR title as appropriate?
And it seems that the CI build has failed. Could you take a loo
lindong28 commented on pull request #7:
URL: https://github.com/apache/flink-ml/pull/7#issuecomment-927258237
Thanks for the PR @gaoyunhaii. Could you create JIRA for FLIP-176 and add
JIRA to the PR title as appropriate?
And it seems that the CI build has failed. Could you take a loo
flinkbot edited a comment on pull request #17311:
URL: https://github.com/apache/flink/pull/17311#issuecomment-921772935
## CI report:
* c0a29893bdaa662e2fa2ce1bb4f0398440c72fb5 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #16606:
URL: https://github.com/apache/flink/pull/16606#issuecomment-887431748
## CI report:
* 264be5cc6a0485171413099e8b64b9e917d06e85 UNKNOWN
* 1b7da8565a2ab9560f1aad65007930c91945087f UNKNOWN
* f77f6bd12ea5a6b1cf8f698c8b36bfab394d
Xintong Song created FLINK-24377:
Summary: TM resource may not be properly released after heartbeat
timeout
Key: FLINK-24377
URL: https://issues.apache.org/jira/browse/FLINK-24377
Project: Flink
flinkbot commented on pull request #17355:
URL: https://github.com/apache/flink/pull/17355#issuecomment-927254690
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-3?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-3:
---
Labels: github-import pull-request-available (was: github-import)
> [GitHub] Implement JobGraph Generat
gaoyunhaii opened a new pull request #7:
URL: https://github.com/apache/flink-ml/pull/7
This PR implements the feedback mechanism and the controller operators.
For feedback mechanism, we will rely on the feedback edge implemented in the
Flink Statefun project, which wrap the feedback
[
https://issues.apache.org/jira/browse/FLINK-24376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-24376:
---
Labels: pull-request-available (was: )
> Operator name in OperatorCoordinator should not us
PatrickRen opened a new pull request #17355:
URL: https://github.com/apache/flink/pull/17355
## What is the purpose of the change
This pull request uses operator name for constructing
OperatorCoordinatorProvider instead of chained name
## Brief change log
- Use operator
Qingsheng Ren created FLINK-24376:
-
Summary: Operator name in OperatorCoordinator should not use
chained name
Key: FLINK-24376
URL: https://issues.apache.org/jira/browse/FLINK-24376
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-2?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-2:
---
Labels: github-import pull-request-available (was: github-import)
> [GitHub] Implement Post Pass Phase
gaoyunhaii opened a new pull request #6:
URL: https://github.com/apache/flink-ml/pull/6
Iteration requires to broadcast the epoch-watermark inside iteration no
matter what partitioner is used.
Currently the functionality is implementation via reflection. As a whole,
the output of t
[
https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-1:
---
Labels: github github-import import pull-request-available (was: github
github-import import)
> [GitHu
[
https://issues.apache.org/jira/browse/FLINK-24293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17420222#comment-17420222
]
Zhu Zhu commented on FLINK-24293:
-
Hi [~huntercc],
I agree that it's not ideal to downl
gaoyunhaii opened a new pull request #5:
URL: https://github.com/apache/flink-ml/pull/5
This PR initializes the module structure for the iteration.
This PR also increases the relied flink version to 1.13.2, which is the
latest stable version. We would further change it to 1.14.0 afte
flinkbot edited a comment on pull request #16606:
URL: https://github.com/apache/flink/pull/16606#issuecomment-887431748
## CI report:
* 264be5cc6a0485171413099e8b64b9e917d06e85 UNKNOWN
* 1b7da8565a2ab9560f1aad65007930c91945087f UNKNOWN
* f77f6bd12ea5a6b1cf8f698c8b36bfab394d
98 matches
Mail list logo
