twalthr opened a new pull request #13681:
URL: https://github.com/apache/flink/pull/13681
## What is the purpose of the change
Simplifies the code base by removing the `connector-kafka-base` module. It
also updates table sources and sinks and removes base classes that are no
longer
flinkbot edited a comment on pull request #13680:
URL: https://github.com/apache/flink/pull/13680#issuecomment-711592132
## CI report:
* c4b66492f144a96a1ea793149162b2ef29441f8f Azure:
flinkbot edited a comment on pull request #13653:
URL: https://github.com/apache/flink/pull/13653#issuecomment-709337488
## CI report:
* 1fc18e75c54cb255a97bfa55f520d970460c441f Azure:
flinkbot edited a comment on pull request #13663:
URL: https://github.com/apache/flink/pull/13663#issuecomment-710009367
## CI report:
* 7c26d5ea271b81b21ea2a6249a9ca6431897282d Azure:
flinkbot edited a comment on pull request #13624:
URL: https://github.com/apache/flink/pull/13624#issuecomment-708132432
## CI report:
* 58df8007e120a6b17f11579dd59f91b6d10f5ecf Azure:
flinkbot edited a comment on pull request #13625:
URL: https://github.com/apache/flink/pull/13625#issuecomment-708152298
## CI report:
* 4c31824917199ca34801d2bde871c5d1f95d0cc2 Azure:
wangyang0918 commented on a change in pull request #13644:
URL: https://github.com/apache/flink/pull/13644#discussion_r507479524
##
File path:
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/FlinkKubeClient.java
##
@@ -104,6 +107,67 @@ KubernetesWatch
[
https://issues.apache.org/jira/browse/FLINK-19538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17216463#comment-17216463
]
Tzu-Li (Gordon) Tai commented on FLINK-19538:
-
We actually do have something like that
[
https://issues.apache.org/jira/browse/FLINK-18937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-18937.
---
Fix Version/s: 1.12.0
Resolution: Fixed
Merged to master via
dianfu merged pull request #13170:
URL: https://github.com/apache/flink/pull/13170
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
gabrywu edited a comment on pull request #13342:
URL: https://github.com/apache/flink/pull/13342#issuecomment-711605313
The feature is very useful, why close it directly? @rkhachatryan
This is an automated message from the
gabrywu commented on pull request #13342:
URL: https://github.com/apache/flink/pull/13342#issuecomment-711605313
The feature is very useful, why close it? @rkhachatryan
This is an automated message from the Apache Git
wangyang0918 commented on a change in pull request #13644:
URL: https://github.com/apache/flink/pull/13644#discussion_r506243026
##
File path:
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/Fabric8FlinkKubeClient.java
##
@@ -219,6 +230,68 @@ public
flinkbot commented on pull request #13680:
URL: https://github.com/apache/flink/pull/13680#issuecomment-711592132
## CI report:
* c4b66492f144a96a1ea793149162b2ef29441f8f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #13679:
URL: https://github.com/apache/flink/pull/13679#issuecomment-711546892
## CI report:
* 94103469ab37ce717e0a3629f28055035124a12c Azure:
flinkbot edited a comment on pull request #13555:
URL: https://github.com/apache/flink/pull/13555#issuecomment-704987370
## CI report:
* bc10bea8ed08d428bfd6f27fde295d6d8b345ac0 Azure:
flinkbot edited a comment on pull request #13307:
URL: https://github.com/apache/flink/pull/13307#issuecomment-685763264
## CI report:
* 4174635af1c0de52685df1ffb1b2adc869256d18 Azure:
wuchong commented on a change in pull request #13653:
URL: https://github.com/apache/flink/pull/13653#discussion_r507465711
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/data/util/RowDataUtil.java
##
@@ -58,7 +58,8 @@ public static
flinkbot commented on pull request #13680:
URL: https://github.com/apache/flink/pull/13680#issuecomment-711566687
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 #13679:
URL: https://github.com/apache/flink/pull/13679#issuecomment-711546892
## CI report:
* 94103469ab37ce717e0a3629f28055035124a12c Azure:
[
https://issues.apache.org/jira/browse/FLINK-19553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19553:
---
Labels: pull-request-available (was: )
> The format of checkpoint Completion Time and
pyscala opened a new pull request #13680:
URL: https://github.com/apache/flink/pull/13680
## What is the purpose of the change
The format of checkpoint Completion Time and Failure Time should be changed
from HH:mm:ss to -MM-dd HH:mm:ss
## Brief change log
flinkbot edited a comment on pull request #13577:
URL: https://github.com/apache/flink/pull/13577#issuecomment-706470705
## CI report:
* 95841cbd815bd7dc9e773e00d164f961fd9bef1e Azure:
flinkbot edited a comment on pull request #13555:
URL: https://github.com/apache/flink/pull/13555#issuecomment-704987370
## CI report:
* bc10bea8ed08d428bfd6f27fde295d6d8b345ac0 Azure:
flinkbot edited a comment on pull request #13625:
URL: https://github.com/apache/flink/pull/13625#issuecomment-708152298
## CI report:
* 4c31824917199ca34801d2bde871c5d1f95d0cc2 Azure:
flinkbot commented on pull request #13679:
URL: https://github.com/apache/flink/pull/13679#issuecomment-711546892
## CI report:
* 94103469ab37ce717e0a3629f28055035124a12c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
JingsongLi commented on a change in pull request #13653:
URL: https://github.com/apache/flink/pull/13653#discussion_r507442655
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinaryArrayData.java
##
@@ -507,7 +507,8 @@ private
flinkbot edited a comment on pull request #13670:
URL: https://github.com/apache/flink/pull/13670#issuecomment-710731909
## CI report:
* 40245c344982f2fe9f3a83bca13d9d5ee09241e0 Azure:
wuchong commented on pull request #13653:
URL: https://github.com/apache/flink/pull/13653#issuecomment-711521373
The failed e2e case is not stable recently.
This is an automated message from the Apache Git Service.
To
flinkbot edited a comment on pull request #13577:
URL: https://github.com/apache/flink/pull/13577#issuecomment-706470705
## CI report:
* 95841cbd815bd7dc9e773e00d164f961fd9bef1e Azure:
flinkbot edited a comment on pull request #13170:
URL: https://github.com/apache/flink/pull/13170#issuecomment-674757748
## CI report:
* 0e95592adb73789a0778057894ebac62e9c64be8 Azure:
flinkbot commented on pull request #13679:
URL: https://github.com/apache/flink/pull/13679#issuecomment-711512515
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
wuchong commented on pull request #13679:
URL: https://github.com/apache/flink/pull/13679#issuecomment-711510773
Could you help to review this @leonardBang ?
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/FLINK-19695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19695:
---
Labels: pull-request-available (was: )
> Writing Table with RowTime Column of type
wuchong opened a new pull request #13679:
URL: https://github.com/apache/flink/pull/13679
## What is the purpose of the change
When writing Table with rowtime column of type TIMESTAMP(3) to Kafka fails
with ClassCastException. This is because
[
https://issues.apache.org/jira/browse/FLINK-19701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17216439#comment-17216439
]
Yun Gao edited comment on FLINK-19701 at 10/19/20, 4:02 AM:
Hi [~AHeise]
[
https://issues.apache.org/jira/browse/FLINK-18373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang closed FLINK-18373.
Resolution: Fixed
> Drop performance unit tests in RocksDB state backend module
>
[
https://issues.apache.org/jira/browse/FLINK-18373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17216440#comment-17216440
]
Yun Tang commented on FLINK-18373:
--
Merged in master
a91e3c7e58bbe8d86e8e7ad997609dc2d76798c7
> Drop
[
https://issues.apache.org/jira/browse/FLINK-19701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17216439#comment-17216439
]
Yun Gao commented on FLINK-19701:
-
[~AHeise] [~pnowojski] Could you have a look at whether this is truly
[
https://issues.apache.org/jira/browse/FLINK-19398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17216436#comment-17216436
]
Yun Gao commented on FLINK-19398:
-
I'll have a look at this issue. Very sorry for the inconvenience
flinkbot edited a comment on pull request #13577:
URL: https://github.com/apache/flink/pull/13577#issuecomment-706470705
## CI report:
* 95841cbd815bd7dc9e773e00d164f961fd9bef1e Azure:
[
https://issues.apache.org/jira/browse/FLINK-19398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reassigned FLINK-19398:
Assignee: Yun Gao
> Hive connector fails with IllegalAccessError if submitted as
flinkbot edited a comment on pull request #13170:
URL: https://github.com/apache/flink/pull/13170#issuecomment-674757748
## CI report:
* 0e95592adb73789a0778057894ebac62e9c64be8 Azure:
wangyang0918 commented on a change in pull request #13644:
URL: https://github.com/apache/flink/pull/13644#discussion_r507421985
##
File path:
flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/TestingFlinkKubeClient.java
##
@@ -103,6 +121,52 @@ public
[
https://issues.apache.org/jira/browse/FLINK-19398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17216434#comment-17216434
]
Jingsong Lee commented on FLINK-19398:
--
CC: [~gaoyunhaii]
> Hive connector fails with
[
https://issues.apache.org/jira/browse/FLINK-19702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17216435#comment-17216435
]
Rui Li commented on FLINK-19702:
I think we can simply call {{addResource}} to add the user provided
[
https://issues.apache.org/jira/browse/FLINK-19701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-19701:
Description:
Current CheckpointUnaligner interacts with RemoteInputChannel to persisting the
input
Rui Li created FLINK-19702:
--
Summary: Avoid using HiveConf::hiveSiteURL
Key: FLINK-19702
URL: https://issues.apache.org/jira/browse/FLINK-19702
Project: Flink
Issue Type: Improvement
Yun Gao created FLINK-19701:
---
Summary: Unaligned Checkpoint might misuse the number of buffers
to persist from the previous barrier
Key: FLINK-19701
URL: https://issues.apache.org/jira/browse/FLINK-19701
[
https://issues.apache.org/jira/browse/FLINK-19625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he closed FLINK-19625.
--
Resolution: Implemented
master: f705f0af6ba50f6e68c22484d1daeda842518d27
> Introduce multi-input
flinkbot edited a comment on pull request #13663:
URL: https://github.com/apache/flink/pull/13663#issuecomment-710009367
## CI report:
* 0e04b3d4c2d0299e6bfde37d80a3cc7dc58abe74 Azure:
flinkbot edited a comment on pull request #13577:
URL: https://github.com/apache/flink/pull/13577#issuecomment-706470705
## CI report:
* 95841cbd815bd7dc9e773e00d164f961fd9bef1e Azure:
flinkbot edited a comment on pull request #13523:
URL: https://github.com/apache/flink/pull/13523#issuecomment-701325670
## CI report:
* b789480d93ec0006ff7c1441943611d3a1032a24 Azure:
godfreyhe merged pull request #13671:
URL: https://github.com/apache/flink/pull/13671
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
godfreyhe commented on pull request #13671:
URL: https://github.com/apache/flink/pull/13671#issuecomment-711490213
Thanks the review @TsReaper , I will merge this
This is an automated message from the Apache Git Service.
To
wangyang0918 commented on a change in pull request #13644:
URL: https://github.com/apache/flink/pull/13644#discussion_r507403885
##
File path:
flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/Fabric8FlinkKubeClientTest.java
##
@@ -249,4 +265,58 @@ public
wangyang0918 commented on a change in pull request #13644:
URL: https://github.com/apache/flink/pull/13644#discussion_r507403885
##
File path:
flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/Fabric8FlinkKubeClientTest.java
##
@@ -249,4 +265,58 @@ public
wangyang0918 commented on a change in pull request #13644:
URL: https://github.com/apache/flink/pull/13644#discussion_r507402405
##
File path:
flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/Fabric8FlinkKubeClientTest.java
##
@@ -249,4 +265,58 @@ public
wangyang0918 commented on a change in pull request #13644:
URL: https://github.com/apache/flink/pull/13644#discussion_r507402293
##
File path:
flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/Fabric8FlinkKubeClientTest.java
##
@@ -249,4 +265,58 @@ public
flinkbot edited a comment on pull request #13663:
URL: https://github.com/apache/flink/pull/13663#issuecomment-710009367
## CI report:
* 0e04b3d4c2d0299e6bfde37d80a3cc7dc58abe74 Azure:
[
https://issues.apache.org/jira/browse/FLINK-19668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17216424#comment-17216424
]
Danny Chen commented on FLINK-19668:
Another case is
danny0405 commented on a change in pull request #13577:
URL: https://github.com/apache/flink/pull/13577#discussion_r507397694
##
File path:
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/batch/sql/agg/WindowAggregateTest.xml
##
@@
danny0405 commented on a change in pull request #13577:
URL: https://github.com/apache/flink/pull/13577#discussion_r507396944
##
File path:
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/batch/sql/agg/WindowAggregateTest.xml
##
@@
flinkbot edited a comment on pull request #13523:
URL: https://github.com/apache/flink/pull/13523#issuecomment-701325670
## CI report:
* b789480d93ec0006ff7c1441943611d3a1032a24 Azure:
[
https://issues.apache.org/jira/browse/FLINK-19700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17216423#comment-17216423
]
Nicholas Jiang commented on FLINK-19700:
[~fly_in_gis], do you mean that
[
https://issues.apache.org/jira/browse/FLINK-14482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17216422#comment-17216422
]
Yu Li commented on FLINK-14482:
---
One quick update (and heads up) here:
[~yunta] has located the root
zhijiangW removed a comment on pull request #13523:
URL: https://github.com/apache/flink/pull/13523#issuecomment-708994253
@flinkbot run azure
This is an automated message from the Apache Git Service.
To respond to the
zhijiangW commented on pull request #13523:
URL: https://github.com/apache/flink/pull/13523#issuecomment-711483920
@flinkbot run azure
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/FLINK-14482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17216419#comment-17216419
]
Yu Li commented on FLINK-14482:
---
Linking more reported issues that could be (could have been) resolved by
[
https://issues.apache.org/jira/browse/FLINK-19689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-19689.
Resolution: Fixed
Fixed via:
* master: f734f59488afaa7ad984362a0dd62e99c134f062
>
wangyang0918 commented on a change in pull request #13644:
URL: https://github.com/apache/flink/pull/13644#discussion_r507384035
##
File path:
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/utils/Constants.java
##
@@ -80,4 +84,14 @@
public static final
wangyang0918 commented on a change in pull request #13644:
URL: https://github.com/apache/flink/pull/13644#discussion_r507382145
##
File path:
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/utils/KubernetesUtils.java
##
@@ -196,6 +224,16 @@ public static String
[
https://issues.apache.org/jira/browse/FLINK-15532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17216416#comment-17216416
]
Yu Li commented on FLINK-15532:
---
According to the [current
wangyang0918 commented on a change in pull request #13644:
URL: https://github.com/apache/flink/pull/13644#discussion_r507380643
##
File path:
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/utils/KubernetesUtils.java
##
@@ -106,13 +110,37 @@ public static String
xintongsong closed pull request #13673:
URL: https://github.com/apache/flink/pull/13673
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
wangyang0918 commented on a change in pull request #13644:
URL: https://github.com/apache/flink/pull/13644#discussion_r507376641
##
File path:
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/Fabric8FlinkKubeClient.java
##
@@ -219,6 +230,68 @@ public
flinkbot edited a comment on pull request #13676:
URL: https://github.com/apache/flink/pull/13676#issuecomment-711145212
## CI report:
* 0e96b1f432be1a43daee779a11fe2cf680580068 Azure:
flinkbot edited a comment on pull request #13670:
URL: https://github.com/apache/flink/pull/13670#issuecomment-710731909
## CI report:
* 66c0f3542d0f0898a2eba8013ab4a390f35c263d Azure:
flinkbot edited a comment on pull request #13307:
URL: https://github.com/apache/flink/pull/13307#issuecomment-685763264
## CI report:
* 3aae457c54d028a1c526a32e059b0836df8105c7 Azure:
Yang Wang created FLINK-19700:
-
Summary: Make Kubernetes Client in KubernetesResourceManagerDriver
use io executor
Key: FLINK-19700
URL: https://issues.apache.org/jira/browse/FLINK-19700
Project: Flink
wangyang0918 commented on a change in pull request #13644:
URL: https://github.com/apache/flink/pull/13644#discussion_r507371480
##
File path:
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/Fabric8FlinkKubeClient.java
##
@@ -219,6 +230,68 @@ public
[
https://issues.apache.org/jira/browse/FLINK-19553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17216414#comment-17216414
]
liufangliang commented on FLINK-19553:
--
[~yunta] ok, thanks.
> The format of checkpoint Completion
[
https://issues.apache.org/jira/browse/FLINK-15532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17216412#comment-17216412
]
Peidian Li commented on FLINK-15532:
[~yunta] Can we fix this now？ This problem has plagued us for a
[
https://issues.apache.org/jira/browse/FLINK-19685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-19685.
---
Resolution: Not A Problem
Close as not a problem.
> When use HBase-Connector lookupFunction, 8 hours less
[
https://issues.apache.org/jira/browse/FLINK-19685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17216405#comment-17216405
]
CaoZhen commented on FLINK-19685:
-
[~jark] Thank you,I see.
> When use HBase-Connector lookupFunction,
flinkbot edited a comment on pull request #13670:
URL: https://github.com/apache/flink/pull/13670#issuecomment-710731909
## CI report:
* 66c0f3542d0f0898a2eba8013ab4a390f35c263d Azure:
flinkbot edited a comment on pull request #13676:
URL: https://github.com/apache/flink/pull/13676#issuecomment-711145212
## CI report:
* 0e96b1f432be1a43daee779a11fe2cf680580068 Azure:
wangyang0918 commented on a change in pull request #13644:
URL: https://github.com/apache/flink/pull/13644#discussion_r507358801
##
File path:
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/FlinkKubeClient.java
##
@@ -104,6 +107,67 @@ KubernetesWatch
flinkbot edited a comment on pull request #13307:
URL: https://github.com/apache/flink/pull/13307#issuecomment-685763264
## CI report:
* 3aae457c54d028a1c526a32e059b0836df8105c7 Azure:
danny0405 commented on a change in pull request #13577:
URL: https://github.com/apache/flink/pull/13577#discussion_r507354670
##
File path:
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/functions/utils/TableSqlFunction.scala
##
@@ -40,12 +44,19 @@
KarmaGYZ commented on a change in pull request #13673:
URL: https://github.com/apache/flink/pull/13673#discussion_r507352226
##
File path: flink-yarn/src/test/resources/resource-types.xml
##
@@ -0,0 +1,28 @@
+
+
+
+
+
+
+yarn.resource-types
+
danny0405 commented on a change in pull request #13577:
URL: https://github.com/apache/flink/pull/13577#discussion_r507351265
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/functions/utils/AggSqlFunction.scala
##
@@ -165,18
[
https://issues.apache.org/jira/browse/FLINK-19655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-19655:
---
Affects Version/s: 1.11.0
> NPE when using blink planner and TemporalTableFunction after setting
>
[
https://issues.apache.org/jira/browse/FLINK-19655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17216395#comment-17216395
]
Leonard Xu commented on FLINK-19655:
[~seunjjs] I reviewed the PR, you can have a look. ^_^
> NPE
leonardBang commented on a change in pull request #13675:
URL: https://github.com/apache/flink/pull/13675#discussion_r507323519
##
File path:
Dian Fu created FLINK-19699:
---
Summary: PrometheusReporterEndToEndITCase crashes with exit code
143
Key: FLINK-19699
URL: https://issues.apache.org/jira/browse/FLINK-19699
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-19699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-19699:
Labels: test-stability (was: )
> PrometheusReporterEndToEndITCase crashes with exit code 143
>
[
https://issues.apache.org/jira/browse/FLINK-19698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17216393#comment-17216393
]
Jiangjie Qin commented on FLINK-19698:
--
[~sewen] What do you think about these two changes? I'll
Jiangjie Qin created FLINK-19698:
Summary: Add close() method and onCheckpointComplete() to the
Source.
Key: FLINK-19698
URL: https://issues.apache.org/jira/browse/FLINK-19698
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-19698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin reassigned FLINK-19698:
Assignee: Jiangjie Qin
> Add close() method and onCheckpointComplete() to the Source.
>
1 - 100 of 204 matches
Mail list logo
