[
https://issues.apache.org/jira/browse/FLINK-10304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16618567#comment-16618567
]
ASF GitHub Bot commented on FLINK-10304:
TisonKun commented on issue #6673: [FLI
TisonKun commented on issue #6673: [FLINK-10304] [client] Remove deprecated
AbstractYarnClusterDescriptor field
URL: https://github.com/apache/flink/pull/6673#issuecomment-422276992
cc @tillrohrmann @GJL @StefanRRichter
This
TisonKun commented on issue #6701: [FLINK-10349] Unify stopActor utils
URL: https://github.com/apache/flink/pull/6701#issuecomment-422276954
cc @tillrohrmann @GJL @StefanRRichter
This is an automated message from the Apache Gi
TisonKun commented on issue #6680: [FLINK-10319] [runtime] Too many
requestPartitionState would crash JM
URL: https://github.com/apache/flink/pull/6680#issuecomment-422276930
cc @tillrohrmann @GJL @StefanRRichter
This is an
[
https://issues.apache.org/jira/browse/FLINK-10319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16618564#comment-16618564
]
ASF GitHub Bot commented on FLINK-10319:
TisonKun commented on issue #6680: [FLI
[
https://issues.apache.org/jira/browse/FLINK-10349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16618565#comment-16618565
]
ASF GitHub Bot commented on FLINK-10349:
TisonKun commented on issue #6701: [FLI
[
https://issues.apache.org/jira/browse/FLINK-6962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16618562#comment-16618562
]
Kurt Young commented on FLINK-6962:
---
Hi [~suez1224], do you have your DDL design doc ye
[
https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16618515#comment-16618515
]
xuqianjin commented on FLINK-10134:
---
I'm trying to repair this bug. What's wrong with
[
https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16618513#comment-16618513
]
ASF GitHub Bot commented on FLINK-10134:
XuQianJin-Stars commented on issue #671
XuQianJin-Stars commented on issue #6710: [FLINK-10134] UTF-16 support for
TextInputFormat bug fixed
URL: https://github.com/apache/flink/pull/6710#issuecomment-422263671
1. I add file bom charset check in FileInputFormat.java
2. I add the bomCharsetName variable in DelimitedInputForma
[
https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16618506#comment-16618506
]
ASF GitHub Bot commented on FLINK-10134:
XuQianJin-Stars opened a new pull reque
[
https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10134:
---
Labels: pull-request-available (was: )
> UTF-16 support for TextInputFormat
> -
XuQianJin-Stars opened a new pull request #6710: [FLINK-10134] UTF-16 support
for TextInputFormat bug fixed
URL: https://github.com/apache/flink/pull/6710
*Thank you very much for contributing to Apache Flink - we are happy that
you want to help us improve Flink. To help the community revi
GJL commented on issue #6709: Release 1.6
URL: https://github.com/apache/flink/pull/6709#issuecomment-422256884
@zrjnike Pull requests are not for questions. Can you post your question on
the user mailing list, and close this PR?
[
https://issues.apache.org/jira/browse/FLINK-10310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16618447#comment-16618447
]
Jayant Ameta commented on FLINK-10310:
--
Hey [~till.rohrmann], do you want to discus
tragicjun edited a comment on issue #6508: [Flink-10079] [table] Support
external sink table in the INSERT INTO clause
URL: https://github.com/apache/flink/pull/6508#issuecomment-422247049
Thanks @fhueske , looks like `var` in scala is not recommended, sorry that
I'm still getting used to
tragicjun edited a comment on issue #6508: [Flink-10079] [table] Support
external sink table in the INSERT INTO clause
URL: https://github.com/apache/flink/pull/6508#issuecomment-422247049
Thanks @fhueske , looks like `var` in scala is not recommended, sorry that
I'm still getting used to
tragicjun edited a comment on issue #6508: [Flink-10079] [table] Support
external sink table in the INSERT INTO clause
URL: https://github.com/apache/flink/pull/6508#issuecomment-422247049
Thanks @fhueske , looks like `var` in scala is not recommended, sorry that
I'm still getting used to
tragicjun edited a comment on issue #6508: [Flink-10079] [table] Support
external sink table in the INSERT INTO clause
URL: https://github.com/apache/flink/pull/6508#issuecomment-422247049
Thanks @fhueske , looks like `var` in scala is not recommended, sorry that
I'm still getting used to
tragicjun commented on issue #6508: [Flink-10079] [table] Support external sink
table in the INSERT INTO clause
URL: https://github.com/apache/flink/pull/6508#issuecomment-422247049
Thanks @fhueske , looks like `var` in scala is not recommended, sorry that
I'm still getting used to scala
zrjnike commented on issue #6709: Release 1.6
URL: https://github.com/apache/flink/pull/6709#issuecomment-422238495
> I’m not sure I can help with this. Did you mean someone else ?
This is about user-defined functions and SQL clients，please tell me who can
help？
zitterbewegung commented on issue #6709: Release 1.6
URL: https://github.com/apache/flink/pull/6709#issuecomment-422235090
I’m not sure I can help with this. Did you mean someone else ?
This is an automated message from the Ap
zrjnike opened a new pull request #6709: Release 1.6
URL: https://github.com/apache/flink/pull/6709
When I define a user-defined function，When I use the sql client, I get an
error (flink version 1.6.0).
```
Exception in thread "main" org.apache.flink.table.client.SqlClientExceptio
[
https://issues.apache.org/jira/browse/FLINK-10245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16618399#comment-16618399
]
yuan commented on FLINK-10245:
--
Hi, will support hbase increment operate, just like the Cou
[
https://issues.apache.org/jira/browse/FLINK-10355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16618371#comment-16618371
]
Hequn Cheng commented on FLINK-10355:
-
Hi [~lihongli], thanks for reporting this iss
[
https://issues.apache.org/jira/browse/FLINK-10259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16618355#comment-16618355
]
ASF GitHub Bot commented on FLINK-10259:
hequn8128 commented on issue #6641: [FL
hequn8128 commented on issue #6641: [FLINK-10259] [table] Fix key extraction
for GroupWindows.
URL: https://github.com/apache/flink/pull/6641#issuecomment-40796
Thanks for the update @fhueske . Looks good to me. +1 to merge
--
[
https://issues.apache.org/jira/browse/FLINK-10358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16618350#comment-16618350
]
ASF GitHub Bot commented on FLINK-10358:
yxu-valleytider edited a comment on iss
yxu-valleytider edited a comment on issue #6708:
[FLINK-10358][Kinesis-connector] fix NPE in case millisBehindLatest is null
URL: https://github.com/apache/flink/pull/6708#issuecomment-422219148
PTAL @tweise @tzulitai
This i
[
https://issues.apache.org/jira/browse/FLINK-10358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16618349#comment-16618349
]
ASF GitHub Bot commented on FLINK-10358:
yxu-valleytider commented on issue #670
yxu-valleytider commented on issue #6708: [FLINK-10358][Kinesis-connector] fix
NPE in case millisBehindLatest is null
URL: https://github.com/apache/flink/pull/6708#issuecomment-422219148
meow @tweise @tzulitai
This is an au
[
https://issues.apache.org/jira/browse/FLINK-10358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16618348#comment-16618348
]
ASF GitHub Bot commented on FLINK-10358:
yxu-valleytider opened a new pull reque
yxu-valleytider opened a new pull request #6708:
[FLINK-10358][Kinesis-connector] fix NPE in case millisBehindLatest is null
URL: https://github.com/apache/flink/pull/6708
## What is the purpose of the change
This PR fixes the NPE described in
[Flink-10358](https://issues.apache.org
[
https://issues.apache.org/jira/browse/FLINK-10358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ying Xu reassigned FLINK-10358:
---
Assignee: Ying Xu
> Flink kinesis connector could throw NPE during getRecords() call
> ---
[
https://issues.apache.org/jira/browse/FLINK-10355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-10355:
-
Comment: was deleted
(was: Hi, [~lihongli] Thanks for opening this jira. I would not think so si
[
https://issues.apache.org/jira/browse/FLINK-10358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ying Xu updated FLINK-10358:
Description:
When extending the flink kinesis connector to consume from a dynamodb stream,
it was found N
[
https://issues.apache.org/jira/browse/FLINK-10358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ying Xu updated FLINK-10358:
Description:
When extending the flink kinesis connector to consume from a dynamodb stream,
it was found N
[
https://issues.apache.org/jira/browse/FLINK-10358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ying Xu updated FLINK-10358:
Description:
When extending the flink kinesis connector to consume from a dynamodb stream,
it was found N
[
https://issues.apache.org/jira/browse/FLINK-10358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ying Xu updated FLINK-10358:
Description:
When extending the flink kinesis connector to consume from a dynamodb stream,
it was found N
Steven Zhen Wu created FLINK-10360:
--
Summary: support timeout in savepoint REST api
Key: FLINK-10360
URL: https://issues.apache.org/jira/browse/FLINK-10360
Project: Flink
Issue Type: Improve
[
https://issues.apache.org/jira/browse/FLINK-7642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16433258#comment-16433258
]
Ted Yu edited comment on FLINK-7642 at 9/17/18 10:38 PM:
-
SUREFIR
Fabian Hueske created FLINK-10359:
-
Summary: Scala example in DataSet docs is broken
Key: FLINK-10359
URL: https://issues.apache.org/jira/browse/FLINK-10359
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-10157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16618165#comment-16618165
]
ASF GitHub Bot commented on FLINK-10157:
azagrebin commented on issue #6707: [FL
azagrebin commented on issue #6707: [FLINK-10157] [State TTL] Allow `null` user
values in map state with TTL
URL: https://github.com/apache/flink/pull/6707#issuecomment-422176532
cc @StefanRRichter
This is an automated messa
[
https://issues.apache.org/jira/browse/FLINK-10157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10157:
---
Labels: pull-request-available (was: )
> Allow `null` user values in map state with TTL
> -
[
https://issues.apache.org/jira/browse/FLINK-10157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16618162#comment-16618162
]
ASF GitHub Bot commented on FLINK-10157:
azagrebin opened a new pull request #67
azagrebin opened a new pull request #6707: [FLINK-10157] [State TTL] Allow
`null` user values in map state with TTL
URL: https://github.com/apache/flink/pull/6707
## What is the purpose of the change
This change allows to store null values with TTL and aligns the semantics of
map st
fhueske commented on a change in pull request #6508: [Flink-10079] [table]
Support external sink table in the INSERT INTO clause
URL: https://github.com/apache/flink/pull/6508#discussion_r218205054
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api
fhueske commented on a change in pull request #6508: [Flink-10079] [table]
Support external sink table in the INSERT INTO clause
URL: https://github.com/apache/flink/pull/6508#discussion_r218205252
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api
fhueske commented on a change in pull request #6508: [Flink-10079] [table]
Support external sink table in the INSERT INTO clause
URL: https://github.com/apache/flink/pull/6508#discussion_r218205508
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api
satybald opened a new pull request #6706: [hotfix][doc] Fix curl example in
upload jar example
URL: https://github.com/apache/flink/pull/6706
Fix example with `curl` in upload jar doc.
```
curl -X POST -F
"jarfile=@target/match-maker-1.0-SNAPSHOT.jar;type=application/x-java-archi
[
https://issues.apache.org/jira/browse/FLINK-10352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao reassigned FLINK-10352:
--
Assignee: Jiayi Liao
> Bind Task's URLClassLoader to TaskExecutor's slot
> --
[
https://issues.apache.org/jira/browse/FLINK-9812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber reassigned FLINK-9812:
--
Assignee: Nico Kruber
> SpanningRecordSerializationTest fails on travis
>
[
https://issues.apache.org/jira/browse/FLINK-9812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16617982#comment-16617982
]
Nico Kruber commented on FLINK-9812:
please find my additions in the linked PR
> Spa
[
https://issues.apache.org/jira/browse/FLINK-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10356:
---
Labels: pull-request-available (was: )
> Add sanity checks to SpillingAdaptiveSpanningRecor
[
https://issues.apache.org/jira/browse/FLINK-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16617980#comment-16617980
]
ASF GitHub Bot commented on FLINK-10356:
NicoK opened a new pull request #6705:
NicoK opened a new pull request #6705: [FLINK-10356][network] add sanity checks
to SpillingAdaptiveSpanningRecordDeserializer
URL: https://github.com/apache/flink/pull/6705
## What is the purpose of the change
`SpillingAdaptiveSpanningRecordDeserializer` doesn't have too many
consis
Ying Xu created FLINK-10358:
---
Summary: Flink kinesis connector could throw NPE during
getRecords() call
Key: FLINK-10358
URL: https://issues.apache.org/jira/browse/FLINK-10358
Project: Flink
Issu
[
https://issues.apache.org/jira/browse/FLINK-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-10356:
Description:
{{SpillingAdaptiveSpanningRecordDeserializer}} doesn't have any consistency
checks f
[
https://issues.apache.org/jira/browse/FLINK-10348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16617952#comment-16617952
]
Jiayi Liao commented on FLINK-10348:
[~elevy]
Ok, what you said makes more sense to
[
https://issues.apache.org/jira/browse/FLINK-10348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16617899#comment-16617899
]
Elias Levy commented on FLINK-10348:
[~wind_ljy]
Re: 1. The problem is timestamp a
[
https://issues.apache.org/jira/browse/FLINK-10348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16617899#comment-16617899
]
Elias Levy edited comment on FLINK-10348 at 9/17/18 5:48 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-10355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-10355:
-
Component/s: (was: Java API)
Table API & SQL
> The order of the column shou
[
https://issues.apache.org/jira/browse/FLINK-10355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-10355:
-
Labels: easyfix (was: )
> The order of the column should start from 1.
> --
[
https://issues.apache.org/jira/browse/FLINK-10355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16617741#comment-16617741
]
zhangminglei commented on FLINK-10355:
--
Hi, [~lihongli] Thanks for opening this jir
[
https://issues.apache.org/jira/browse/FLINK-9761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16617710#comment-16617710
]
aitozi commented on FLINK-9761:
---
Hi，[~NicoK]
why does the stagedMessagesHandler still shou
[
https://issues.apache.org/jira/browse/FLINK-8247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16617706#comment-16617706
]
ASF GitHub Bot commented on FLINK-8247:
---
jaredstehler commented on issue #6689: [FL
jaredstehler commented on issue #6689: [FLINK-8247] [Mesos] Support case where
hadoop is not on classpath
URL: https://github.com/apache/flink/pull/6689#issuecomment-422063454
also, @EronWright / @yanghua I wasn't sure if I was supposed to open this PR
against the `release-1.6` branch or `
[
https://issues.apache.org/jira/browse/FLINK-8247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16617702#comment-16617702
]
ASF GitHub Bot commented on FLINK-8247:
---
jaredstehler commented on a change in pull
jaredstehler commented on a change in pull request #6689: [FLINK-8247] [Mesos]
Support case where hadoop is not on classpath
URL: https://github.com/apache/flink/pull/6689#discussion_r218115898
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/over
[
https://issues.apache.org/jira/browse/FLINK-8247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16617700#comment-16617700
]
ASF GitHub Bot commented on FLINK-8247:
---
jaredstehler commented on issue #6689: [FL
jaredstehler commented on issue #6689: [FLINK-8247] [Mesos] Support case where
hadoop is not on classpath
URL: https://github.com/apache/flink/pull/6689#issuecomment-422062032
@EronWright Yeah, I was going for the least invasive change. With regard to
the classloading issue: I was surpris
Till Rohrmann created FLINK-10357:
-
Summary: Streaming File Sink end-to-end test failed with mismatch
Key: FLINK-10357
URL: https://issues.apache.org/jira/browse/FLINK-10357
Project: Flink
Is
[
https://issues.apache.org/jira/browse/FLINK-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-10356:
Description:
{{SpillingAdaptiveSpanningRecordDeserializer}} doesn't have any consistency
checks f
Nico Kruber created FLINK-10356:
---
Summary: Add sanity checks to
SpillingAdaptiveSpanningRecordDeserializer
Key: FLINK-10356
URL: https://issues.apache.org/jira/browse/FLINK-10356
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16617593#comment-16617593
]
Nico Kruber commented on FLINK-9812:
Nice find [~yanghua].
Actually, setting {{spilli
[
https://issues.apache.org/jira/browse/FLINK-10355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lihongli updated FLINK-10355:
-
Attachment: B0C32FD9-47FE-4F63-921F-A9E49C0CB5CD.png
> The order of the column should start from 1.
> --
[
https://issues.apache.org/jira/browse/FLINK-10355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lihongli updated FLINK-10355:
-
Description: When I register an external Table using a CsvTableSource.It
throws an exception :"Parsing
lihongli created FLINK-10355:
Summary: The order of the column should start from 1.
Key: FLINK-10355
URL: https://issues.apache.org/jira/browse/FLINK-10355
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-10354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16617571#comment-16617571
]
ASF GitHub Bot commented on FLINK-10354:
dawidwys commented on issue #6704: [FLI
dawidwys commented on issue #6704: [FLINK-10354] Revert "[FLINK-6328] [chkPts]
Don't add savepoints to CompletedCheckpointStore"
URL: https://github.com/apache/flink/pull/6704#issuecomment-422030744
In the long term, the plan is to differentiate between two kinds of
savepoints: with(cancel
[
https://issues.apache.org/jira/browse/FLINK-9912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16617553#comment-16617553
]
ASF GitHub Bot commented on FLINK-9912:
---
asfgit closed pull request #6394: [FLINK-9
[
https://issues.apache.org/jira/browse/FLINK-9917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16617552#comment-16617552
]
ASF GitHub Bot commented on FLINK-9917:
---
asfgit closed pull request #6389: [FLINK-9
[
https://issues.apache.org/jira/browse/FLINK-10354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16617551#comment-16617551
]
ASF GitHub Bot commented on FLINK-10354:
dawidwys commented on issue #6704: [FLI
dawidwys commented on issue #6704: [FLINK-10354] Revert "[FLINK-6328] [chkPts]
Don't add savepoints to CompletedCheckpointStore"
URL: https://github.com/apache/flink/pull/6704#issuecomment-422025668
Unfortunately we will fail the recovery in this situation , but as discussed
with @aljoscha
[
https://issues.apache.org/jira/browse/FLINK-9917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-9917.
Resolution: Fixed
Fix Version/s: 1.7.0
Fixed via d2bd39e361c53da99ae7383a51695cc896ec2bbe
>
asfgit closed pull request #6389: [FLINK-9917][JM] Remove superfluous lock from
SlotSharingManager
URL: https://github.com/apache/flink/pull/6389
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As
asfgit closed pull request #6394: [FLINK-9912][JM] Release TaskExecutors if
they have no slots registered at SlotPool
URL: https://github.com/apache/flink/pull/6394
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake
[
https://issues.apache.org/jira/browse/FLINK-9912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-9912.
Resolution: Fixed
Fix Version/s: 1.7.0
Fixed via e3c98f05d3544d0165c2d97d2d00fcd295cef8c8
>
[
https://issues.apache.org/jira/browse/FLINK-10354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16617542#comment-16617542
]
ASF GitHub Bot commented on FLINK-10354:
tillrohrmann commented on issue #6704:
tillrohrmann commented on issue #6704: [FLINK-10354] Revert "[FLINK-6328]
[chkPts] Don't add savepoints to CompletedCheckpointStore"
URL: https://github.com/apache/flink/pull/6704#issuecomment-422023140
How do we handle the situation when a savepoint is moved and cannot be
recovered from a
[
https://issues.apache.org/jira/browse/FLINK-10346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16617533#comment-16617533
]
Stefan Richter commented on FLINK-10346:
I think the checkpoint directory is the
[
https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16617503#comment-16617503
]
ASF GitHub Bot commented on FLINK-9697:
---
yanghua commented on issue #6703: [FLINK-9
yanghua commented on issue #6703: [FLINK-9697] Provide connector for Kafka 2.0.0
URL: https://github.com/apache/flink/pull/6703#issuecomment-422008333
I have already read the comment for this method, yes, it will cause the test
program to become unresponsive. But each PR will verify this te
[
https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16617459#comment-16617459
]
ASF GitHub Bot commented on FLINK-9697:
---
pnowojski commented on issue #6703: [FLINK
pnowojski commented on issue #6703: [FLINK-9697] Provide connector for Kafka
2.0.0
URL: https://github.com/apache/flink/pull/6703#issuecomment-422001108
In existing `Kafka011ProducerExactlyOnceITCase`, at least once tests are not
passing. Please check the comment in
`Kafka011ProducerExact
[
https://issues.apache.org/jira/browse/FLINK-10354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10354:
---
Labels: pull-request-available (was: )
> Savepoints should be counted as retained checkpoin
[
https://issues.apache.org/jira/browse/FLINK-10354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16617458#comment-16617458
]
ASF GitHub Bot commented on FLINK-10354:
dawidwys opened a new pull request #670
dawidwys opened a new pull request #6704: [FLINK-10354] Revert "[FLINK-6328]
[chkPts] Don't add savepoints to CompletedCheckpointStore"
URL: https://github.com/apache/flink/pull/6704
## What is the purpose of the change
This reverts commit 6f570e7b6810e1645a4f7094f17ab9e8559fa139.
[
https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16617452#comment-16617452
]
ASF GitHub Bot commented on FLINK-9697:
---
yanghua commented on issue #6703: [FLINK-9
1 - 100 of 157 matches
Mail list logo
