Wei Zhong created FLINK-21180:
-
Summary: Move the state module from 'pyflink.common' to
'pyflink.datastream'
Key: FLINK-21180
URL: https://issues.apache.org/jira/browse/FLINK-21180
Project: Flink
KarmaGYZ commented on pull request #14647:
URL: https://github.com/apache/flink/pull/14647#issuecomment-768869214
@zentol I also glad to have a unified SlotManager. As the feature is not
stable. I tend to put it out of the scope of this PR.
flinkbot edited a comment on pull request #14783:
URL: https://github.com/apache/flink/pull/14783#issuecomment-768767423
## CI report:
* ea0fa2c3a97b2d2082b40732850ccc960ba7a09e Azure:
KarmaGYZ commented on pull request #14647:
URL: https://github.com/apache/flink/pull/14647#issuecomment-768868239
Thanks for the review @xintongsong . All your comments have been addressed.
This is an automated message from
[
https://issues.apache.org/jira/browse/FLINK-20838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17273388#comment-17273388
]
Xintong Song commented on FLINK-20838:
--
There a todo item from FLINK-20835, that should be
[
https://issues.apache.org/jira/browse/FLINK-21174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yangze Guo updated FLINK-21174:
---
Parent: FLINK-14187
Issue Type: Sub-task (was: Improvement)
> Optimize the performance of
[
https://issues.apache.org/jira/browse/FLINK-21177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yangze Guo updated FLINK-21177:
---
Parent: FLINK-14187
Issue Type: Sub-task (was: New Feature)
> Introduce the counterpart of
flinkbot edited a comment on pull request #14787:
URL: https://github.com/apache/flink/pull/14787#issuecomment-768849685
## CI report:
* 43d7e4e3c23451fd7cf18cfaa7ba91d8ee47bd60 Azure:
flinkbot commented on pull request #14787:
URL: https://github.com/apache/flink/pull/14787#issuecomment-768849685
## CI report:
* 43d7e4e3c23451fd7cf18cfaa7ba91d8ee47bd60 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #14786:
URL: https://github.com/apache/flink/pull/14786#issuecomment-768805034
## CI report:
* 0d544bd5e5eb4b7fa39a82da9aad46758d994faf Azure:
flinkbot edited a comment on pull request #14774:
URL: https://github.com/apache/flink/pull/14774#issuecomment-768234538
## CI report:
* 54a8354c03402cedbfe56f8e8e7336f2d9072e34 Azure:
[
https://issues.apache.org/jira/browse/FLINK-21179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei Zhong updated FLINK-21179:
--
Description: As the ReducingState and AggregatingState only support
non-rich functions, we need to
flinkbot commented on pull request #14787:
URL: https://github.com/apache/flink/pull/14787#issuecomment-768845020
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
leonardBang opened a new pull request #14787:
URL: https://github.com/apache/flink/pull/14787
## What is the purpose of the change
* This pull request aims to fix Blink planner does not ingest the row time
timestamp into `StreamRecord` when leaving Table/SQL
## Brief change
[
https://issues.apache.org/jira/browse/FLINK-18634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17273372#comment-17273372
]
Xintong Song commented on FLINK-18634:
--
pengkangjing edited a comment on pull request #14779:
URL: https://github.com/apache/flink/pull/14779#issuecomment-768836183
@xintongsong Another error seems to be not related to this change
[
https://issues.apache.org/jira/browse/FLINK-21138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17273371#comment-17273371
]
Maciej Prochniak commented on FLINK-21138:
--
I think using original.getClass().getClassLoader()
[
https://issues.apache.org/jira/browse/FLINK-21134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-21134:
--
Assignee: Robert Metzger
> Reactive mode: Introduce execution mode configuration key
flinkbot edited a comment on pull request #14786:
URL: https://github.com/apache/flink/pull/14786#issuecomment-768805034
## CI report:
* 0d544bd5e5eb4b7fa39a82da9aad46758d994faf Azure:
flinkbot edited a comment on pull request #14774:
URL: https://github.com/apache/flink/pull/14774#issuecomment-768234538
## CI report:
* 54a8354c03402cedbfe56f8e8e7336f2d9072e34 Azure:
Wei Zhong created FLINK-21179:
-
Summary: Split the base class of Python DataStream Function to
'Function' and 'RichFunction'
Key: FLINK-21179
URL: https://issues.apache.org/jira/browse/FLINK-21179
CPS794 commented on pull request #14786:
URL: https://github.com/apache/flink/pull/14786#issuecomment-768836986
@flinkbot run azure
This is an automated message from the Apache Git Service.
To respond to the message, please
pengkangjing commented on pull request #14779:
URL: https://github.com/apache/flink/pull/14779#issuecomment-768836183
@xintongsong Another error seem to be not related to this change
Brian Zhou created FLINK-21178:
--
Summary: Task failure will not trigger master hook's reset()
Key: FLINK-21178
URL: https://issues.apache.org/jira/browse/FLINK-21178
Project: Flink
Issue Type:
PatrickRen commented on pull request #14783:
URL: https://github.com/apache/flink/pull/14783#issuecomment-768833202
Hello @tweise and @becketqin ~ I think putting flink-connector-base JAR
under lib directory of Flink distribution might be a better choice. After
eventually all connectors
flinkbot edited a comment on pull request #14774:
URL: https://github.com/apache/flink/pull/14774#issuecomment-768234538
## CI report:
* 54a8354c03402cedbfe56f8e8e7336f2d9072e34 Azure:
KarmaGYZ commented on a change in pull request #14647:
URL: https://github.com/apache/flink/pull/14647#discussion_r565849050
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/FineGrainedSlotManager.java
##
@@ -0,0 +1,790 @@
+/*
+ *
Yangze Guo created FLINK-21177:
--
Summary: Introduce the counterpart of
slotmanager.number-of-slots.max in fine-grained resource management
Key: FLINK-21177
URL: https://issues.apache.org/jira/browse/FLINK-21177
[
https://issues.apache.org/jira/browse/FLINK-21177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yangze Guo updated FLINK-21177:
---
Issue Type: New Feature (was: Improvement)
> Introduce the counterpart of
KarmaGYZ commented on a change in pull request #14647:
URL: https://github.com/apache/flink/pull/14647#discussion_r565846698
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/ResourceAllocationResult.java
##
@@ -0,0 +1,121 @@
+/*
+
KarmaGYZ commented on a change in pull request #14647:
URL: https://github.com/apache/flink/pull/14647#discussion_r565846698
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/ResourceAllocationResult.java
##
@@ -0,0 +1,121 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-21172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-21172:
---
Assignee: Nicholas Jiang
> canal-json format include es field
> --
[
https://issues.apache.org/jira/browse/FLINK-21172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17273356#comment-17273356
]
Jark Wu commented on FLINK-21172:
-
What metadata key do you want to propose? [~nicholasjiang]
>
Jark Wu created FLINK-21176:
---
Summary: Translate updates on Confluent Avro Format page
Key: FLINK-21176
URL: https://issues.apache.org/jira/browse/FLINK-21176
Project: Flink
Issue Type: Task
KarmaGYZ commented on a change in pull request #14647:
URL: https://github.com/apache/flink/pull/14647#discussion_r565845168
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/DefaultResourceAllocationStrategy.java
##
@@ -0,0 +1,233
KarmaGYZ commented on a change in pull request #14647:
URL: https://github.com/apache/flink/pull/14647#discussion_r565845168
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/DefaultResourceAllocationStrategy.java
##
@@ -0,0 +1,233
[
https://issues.apache.org/jira/browse/FLINK-20999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-20999.
---
Resolution: Fixed
Fixed in master: 2596c12f7fe6b55bfc8708e1f61d3521703225b3
> Confluent Avro Format should
wuchong merged pull request #14764:
URL: https://github.com/apache/flink/pull/14764
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
[
https://issues.apache.org/jira/browse/FLINK-20659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17273349#comment-17273349
]
Guowei Ma commented on FLINK-20659:
---
Guowei Ma created FLINK-21175:
-
Summary: OneInputStreamTaskTest.testWatermarkMetrics:914
expected:<1> but was:<-9223372036854775808>
Key: FLINK-21175
URL: https://issues.apache.org/jira/browse/FLINK-21175
Yangze Guo created FLINK-21174:
--
Summary: Optimize the performance of ResourceAllocationStrategy
Key: FLINK-21174
URL: https://issues.apache.org/jira/browse/FLINK-21174
Project: Flink
Issue
KarmaGYZ commented on a change in pull request #14647:
URL: https://github.com/apache/flink/pull/14647#discussion_r565842059
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/DefaultResourceAllocationStrategy.java
##
@@ -0,0 +1,233
[
https://issues.apache.org/jira/browse/FLINK-21172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17273347#comment-17273347
]
Nicholas Jiang commented on FLINK-21172:
I agree with the point of [~jiabao.sun][~jark].
[
https://issues.apache.org/jira/browse/FLINK-18634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17273344#comment-17273344
]
Guowei Ma commented on FLINK-18634:
---
[
https://issues.apache.org/jira/browse/FLINK-20329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17273341#comment-17273341
]
Guowei Ma commented on FLINK-20329:
---
Guowei Ma created FLINK-21173:
-
Summary: "Streaming SQL end-to-end test (Old planner)" e2e test
failed
Key: FLINK-21173
URL: https://issues.apache.org/jira/browse/FLINK-21173
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-21173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guowei Ma updated FLINK-21173:
--
Labels: test-stability (was: )
> "Streaming SQL end-to-end test (Old planner)" e2e test failed
>
flinkbot edited a comment on pull request #14764:
URL: https://github.com/apache/flink/pull/14764#issuecomment-767576041
## CI report:
* 038ad0d6915e874ca32cce0da55184a436737a53 Azure:
[
https://issues.apache.org/jira/browse/FLINK-21104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17273339#comment-17273339
]
Guowei Ma commented on FLINK-21104:
---
flinkbot edited a comment on pull request #14786:
URL: https://github.com/apache/flink/pull/14786#issuecomment-768805034
## CI report:
* 0d544bd5e5eb4b7fa39a82da9aad46758d994faf Azure:
flinkbot commented on pull request #14786:
URL: https://github.com/apache/flink/pull/14786#issuecomment-768805034
## CI report:
* 0d544bd5e5eb4b7fa39a82da9aad46758d994faf UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #14779:
URL: https://github.com/apache/flink/pull/14779#issuecomment-768302027
## CI report:
* 9863d9e8363e2c6bf2e32394f04579ace32a88fc Azure:
flinkbot commented on pull request #14786:
URL: https://github.com/apache/flink/pull/14786#issuecomment-768802041
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
[
https://issues.apache.org/jira/browse/FLINK-19592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19592:
---
Labels: pull-request-available (was: )
> MiniBatchGroupAggFunction should emit messages to
CPS794 opened a new pull request #14786:
URL: https://github.com/apache/flink/pull/14786
… of downstream operators when state cleaning is enabled
## What is the purpose of the change
This pull request makes MiniBatchGroupAggFunction and
MiniBatchGlobalGroupAggFunction
flinkbot edited a comment on pull request #14785:
URL: https://github.com/apache/flink/pull/14785#issuecomment-768793784
## CI report:
* e101240afc9b86f44866e6ea126e3686182677e9 Azure:
flinkbot edited a comment on pull request #14764:
URL: https://github.com/apache/flink/pull/14764#issuecomment-767576041
## CI report:
* 72b7c0d03d710be89bc6e7bdcff7c6a27980323c Azure:
flinkbot commented on pull request #14785:
URL: https://github.com/apache/flink/pull/14785#issuecomment-768793784
## CI report:
* e101240afc9b86f44866e6ea126e3686182677e9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #14784:
URL: https://github.com/apache/flink/pull/14784#issuecomment-768786978
## CI report:
* c327e27872f782274cab4e10692ef1d913f85c5d Azure:
flinkbot edited a comment on pull request #14764:
URL: https://github.com/apache/flink/pull/14764#issuecomment-767576041
## CI report:
* e5106da1732cba93446aa63fc61cdf7e74b29271 Azure:
[
https://issues.apache.org/jira/browse/FLINK-21172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-21172:
Component/s: Table SQL / Ecosystem
> canal-json format include es field
>
[
https://issues.apache.org/jira/browse/FLINK-21172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17273299#comment-17273299
]
Jark Wu commented on FLINK-21172:
-
We can support this by a new metadata column. What do you think
wuchong commented on a change in pull request #14764:
URL: https://github.com/apache/flink/pull/14764#discussion_r565813102
##
File path: docs/dev/table/connectors/formats/avro-confluent.zh.md
##
@@ -52,20 +52,126 @@ Avro Schema Registry 格式只能与[Apache Kafka SQL连接器]({% link
[
https://issues.apache.org/jira/browse/FLINK-21045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17273295#comment-17273295
]
Jark Wu commented on FLINK-21045:
-
It seems that we still have many different thoughts on this topic.
sv3ndk commented on pull request #14764:
URL: https://github.com/apache/flink/pull/14764#issuecomment-768791368
Thanks for the feed-back @wuchong .
I copied the code examples to the Chinese version of the documentation,
although they contain some English sentences at the moment, which
[
https://issues.apache.org/jira/browse/FLINK-21172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jiabao sun updated FLINK-21172:
---
Description:
Canal flat message json format has an 'es' field extracted from mysql binlog
which
[
https://issues.apache.org/jira/browse/FLINK-21172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jiabao sun updated FLINK-21172:
---
Description:
Canal flat message json format has an 'es' field extracted from mysql binlog
which
[
https://issues.apache.org/jira/browse/FLINK-21172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jiabao sun updated FLINK-21172:
---
Description:
Canal flat message json format has an 'es' field extracted from mysql binlog
which
[
https://issues.apache.org/jira/browse/FLINK-21045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17273292#comment-17273292
]
Jark Wu commented on FLINK-21045:
-
Good points [~lirui], I also found it's really hard to use "load" +
jiabao sun created FLINK-21172:
--
Summary: canal-json format include es field
Key: FLINK-21172
URL: https://issues.apache.org/jira/browse/FLINK-21172
Project: Flink
Issue Type: Improvement
flinkbot commented on pull request #14785:
URL: https://github.com/apache/flink/pull/14785#issuecomment-768788506
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
[
https://issues.apache.org/jira/browse/FLINK-21013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-21013:
---
Labels: pull-request-available (was: )
> Blink planner does not ingest timestamp into
leonardBang opened a new pull request #14785:
URL: https://github.com/apache/flink/pull/14785
## What is the purpose of the change
* This pull request aims to fix Blink planner does not ingest the row time
timestamp into `StreamRecord` when leaving Table/SQL
## Brief change
wuchong commented on a change in pull request #14748:
URL: https://github.com/apache/flink/pull/14748#discussion_r565805854
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/abilities/SupportsAggregatePushDown.java
##
@@ -0,0
flinkbot commented on pull request #14784:
URL: https://github.com/apache/flink/pull/14784#issuecomment-768786978
## CI report:
* c327e27872f782274cab4e10692ef1d913f85c5d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #14779:
URL: https://github.com/apache/flink/pull/14779#issuecomment-768302027
## CI report:
* 87fab35cbddf22b2479969188eca5a9a3767c098 Azure:
sv3ndk commented on a change in pull request #14764:
URL: https://github.com/apache/flink/pull/14764#discussion_r565808097
##
File path: docs/dev/table/connectors/formats/avro-confluent.md
##
@@ -45,29 +45,132 @@ Dependencies
connector=connector
%}
-How to create a
KarmaGYZ commented on a change in pull request #14647:
URL: https://github.com/apache/flink/pull/14647#discussion_r565806651
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/DefaultSlotStatusSyncer.java
##
@@ -0,0 +1,258 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-21171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-21171:
Description:
Currently, all values being passed around via the request-reply
[
https://issues.apache.org/jira/browse/FLINK-21171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-21171:
Description:
Currently, all values being passed around via the request-reply
[
https://issues.apache.org/jira/browse/FLINK-21045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17273285#comment-17273285
]
Rui Li commented on FLINK-21045:
Thanks for looping me in. I don't have a strong opinion regarding
[
https://issues.apache.org/jira/browse/FLINK-20740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao updated FLINK-20740:
Summary: Use managed memory (network memory) to avoid direct memory OOM
error for sort-merge
flinkbot commented on pull request #14784:
URL: https://github.com/apache/flink/pull/14784#issuecomment-768782077
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 edited a comment on pull request #14779:
URL: https://github.com/apache/flink/pull/14779#issuecomment-768302027
## CI report:
* 87fab35cbddf22b2479969188eca5a9a3767c098 Azure:
[
https://issues.apache.org/jira/browse/FLINK-21160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-21160:
---
Labels: pull-request-available (was: )
> ValueDeserializerWrapper throws
wuchong commented on a change in pull request #14764:
URL: https://github.com/apache/flink/pull/14764#discussion_r565802781
##
File path: docs/dev/table/connectors/formats/avro-confluent.md
##
@@ -45,29 +45,132 @@ Dependencies
connector=connector
%}
-How to create a
KarmaGYZ commented on a change in pull request #14647:
URL: https://github.com/apache/flink/pull/14647#discussion_r565802712
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/slotmanager/FineGrainedTaskManagerTrackerTest.java
##
@@ -0,0 +1,254
PatrickRen opened a new pull request #14784:
URL: https://github.com/apache/flink/pull/14784
## What is the purpose of the change
This pull request fixes bug of referencing uninitialized deserializer in
```ValueDeserializerWrapper``` when using
Tzu-Li (Gordon) Tai created FLINK-21171:
---
Summary: Introduce TypedValue to the StateFun request-reply
protocol
Key: FLINK-21171
URL: https://issues.apache.org/jira/browse/FLINK-21171
Project:
Huang Xingbo created FLINK-21170:
Summary: Add internal state hierarchy in PyFlink
Key: FLINK-21170
URL: https://issues.apache.org/jira/browse/FLINK-21170
Project: Flink
Issue Type: Sub-task
xintongsong commented on a change in pull request #14647:
URL: https://github.com/apache/flink/pull/14647#discussion_r565798745
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/PendingTaskManagerId.java
##
@@ -0,0 +1,30 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-20416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17273279#comment-17273279
]
Rui Li commented on FLINK-20416:
[~shared_ptr] Thanks for the update. LGTM, please go ahead with the PR
flinkbot edited a comment on pull request #14783:
URL: https://github.com/apache/flink/pull/14783#issuecomment-768767423
## CI report:
* ea0fa2c3a97b2d2082b40732850ccc960ba7a09e Azure:
[
https://issues.apache.org/jira/browse/FLINK-21005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17273278#comment-17273278
]
Jark Wu commented on FLINK-21005:
-
Sure. Assigned to you [~nicholasjiang]
> Introduce new provider for
[
https://issues.apache.org/jira/browse/FLINK-21005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-21005:
---
Assignee: Nicholas Jiang (was: Huajie Wang)
> Introduce new provider for unified Sink API and
xintongsong edited a comment on pull request #14591:
URL: https://github.com/apache/flink/pull/14591#issuecomment-768770142
Sorry, closed the PR by mistake.
@blublinsky, you have not addressed my comment.
> * Why is the owner reference only set for JobManager. Are other
blublinsky opened a new pull request #14591:
URL: https://github.com/apache/flink/pull/14591
## What is the purpose of the change
Flink implementation is often a part of the larger application. As a result
a synchronized management - clean up of Flink resources, when a main
xintongsong commented on pull request #14591:
URL: https://github.com/apache/flink/pull/14591#issuecomment-768770142
@blublinsky,
This is an automated message from the Apache Git Service.
To respond to the message,
xintongsong closed pull request #14591:
URL: https://github.com/apache/flink/pull/14591
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
flinkbot commented on pull request #14783:
URL: https://github.com/apache/flink/pull/14783#issuecomment-768767423
## CI report:
* ea0fa2c3a97b2d2082b40732850ccc960ba7a09e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
1 - 100 of 415 matches
Mail list logo
