TisonKun commented on a change in pull request #7302: [FLINK-11156] [tests]
Reconcile ZooKeeperCompletedCheckpointStoreMockitoTest with JDK 9
URL: https://github.com/apache/flink/pull/7302#discussion_r243508511
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/chec
suez1224 commented on a change in pull request #7078: [FLINK-10848][YARN]
properly remove YARN ContainerRequest upon container allocation success
URL: https://github.com/apache/flink/pull/7078#discussion_r243507859
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnFl
[
https://issues.apache.org/jira/browse/FLINK-10848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16726502#comment-16726502
]
Shuyi Chen commented on FLINK-10848:
[~xinpu], the ContainerRequests are sent during
link3280 commented on issue #7294: [FLINK-11126][YARN][security] Filter out
AMRMToken in TaskManager‘s credentials
URL: https://github.com/apache/flink/pull/7294#issuecomment-449278889
@zentol @tzulitai Please have a look. ✋
[
https://issues.apache.org/jira/browse/FLINK-10473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16726464#comment-16726464
]
Yangze Guo commented on FLINK-10473:
Hi, [~azagrebin] and [~hequn8128] . Thanks for
TisonKun commented on issue #6917: [FLINK-10665] [tests] Port
YARNSessionFIFOITCase#testJavaAPI to new c…
URL: https://github.com/apache/flink/pull/6917#issuecomment-449256460
cc @GJL would you like to give a glance at this thread? it's not quite
complex imo.
-
TisonKun removed a comment on issue #6917: [FLINK-10665] [tests] Port
YARNSessionFIFOITCase#testJavaAPI to new c…
URL: https://github.com/apache/flink/pull/6917#issuecomment-445164746
ping @tillrohrmann as a reminder
This is
TisonKun commented on issue #6872: [FLINK-10436] Add
ConfigOption#withFallbackKeys
URL: https://github.com/apache/flink/pull/6872#issuecomment-449255233
kindly ping @tillrohrmann as a reminder, since we have reached a consensus
:-)
-
[
https://issues.apache.org/jira/browse/FLINK-11202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chauncy updated FLINK-11202:
Comment: was deleted
(was: can i join)
> Split log file per job
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-11202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16726437#comment-16726437
]
chauncy commented on FLINK-11202:
-
[~yanghua] design document put here ?
> Split log
hequn8128 commented on a change in pull request #7188: [FLINK-10473][State TTL]
TTL state incremental cleanup for heap backend
URL: https://github.com/apache/flink/pull/7188#discussion_r243473440
##
File path: docs/dev/stream/state/state.md
##
@@ -394,6 +396,47 @@ val ttlC
tweise commented on a change in pull request #6968: [FLINK-4582] [kinesis]
Consuming data from DynamoDB streams to flink
URL: https://github.com/apache/flink/pull/6968#discussion_r243472949
##
File path:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/stream
tweise commented on a change in pull request #6968: [FLINK-4582] [kinesis]
Consuming data from DynamoDB streams to flink
URL: https://github.com/apache/flink/pull/6968#discussion_r243472774
##
File path:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/stream
tweise commented on a change in pull request #6968: [FLINK-4582] [kinesis]
Consuming data from DynamoDB streams to flink
URL: https://github.com/apache/flink/pull/6968#discussion_r243472494
##
File path:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/stream
tweise commented on a change in pull request #6968: [FLINK-4582] [kinesis]
Consuming data from DynamoDB streams to flink
URL: https://github.com/apache/flink/pull/6968#discussion_r243472320
##
File path:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/stream
tweise commented on issue #6968: [FLINK-4582] [kinesis] Consuming data from
DynamoDB streams to flink
URL: https://github.com/apache/flink/pull/6968#issuecomment-449215051
Does the PR need to be rebased?
This is an automated
[
https://issues.apache.org/jira/browse/FLINK-7689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16726371#comment-16726371
]
Martin Eden commented on FLINK-7689:
This should ready for merging now!
> Instrument
tweise commented on a change in pull request #6968: [FLINK-4582] [kinesis]
Consuming data from DynamoDB streams to flink
URL: https://github.com/apache/flink/pull/6968#discussion_r243471372
##
File path:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/stream
tweise commented on a change in pull request #6968: [FLINK-4582] [kinesis]
Consuming data from DynamoDB streams to flink
URL: https://github.com/apache/flink/pull/6968#discussion_r243470195
##
File path:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/stream
tweise commented on a change in pull request #6968: [FLINK-4582] [kinesis]
Consuming data from DynamoDB streams to flink
URL: https://github.com/apache/flink/pull/6968#discussion_r243470709
##
File path:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/stream
tweise commented on a change in pull request #6968: [FLINK-4582] [kinesis]
Consuming data from DynamoDB streams to flink
URL: https://github.com/apache/flink/pull/6968#discussion_r243469816
##
File path:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/stream
yxu-valleytider commented on issue #6968: [FLINK-4582] [kinesis] Consuming data
from DynamoDB streams to flink
URL: https://github.com/apache/flink/pull/6968#issuecomment-449208910
PTAL @tweise
This is an automated message f
[
https://issues.apache.org/jira/browse/FLINK-11048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise resolved FLINK-11048.
--
Resolution: Fixed
Fix Version/s: 1.8.0
> Ability to programmatically execute streaming
tweise closed pull request #7249: [FLINK-11048] Ability to programmatically
execute streaming pipeline with savepoint restore
URL: https://github.com/apache/flink/pull/7249
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
tweise commented on issue #7249: [FLINK-11048] Ability to programmatically
execute streaming pipeline with savepoint restore
URL: https://github.com/apache/flink/pull/7249#issuecomment-449118180
@mxm Let's leave it as is. The main point was addition of the static method,
which effectively
zentol commented on issue #7348: [FLINK-11207][core] update commons-compress to
1.18
URL: https://github.com/apache/flink/pull/7348#issuecomment-449112197
You also have to update the NOTICE files (src/main/resources/META-INF) in
* flink-dist
* flink-swift-fs-hadoop
* flink-shaded-h
mxm commented on issue #7249: [FLINK-11048] Ability to programmatically execute
streaming pipeline with savepoint restore
URL: https://github.com/apache/flink/pull/7249#issuecomment-449092016
@tweise What if we removed the execute method with the snapshot settings?
The usual work flow is t
[
https://issues.apache.org/jira/browse/FLINK-11201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-11201.
---
Resolution: Fixed
Fix Version/s: 1.8.0
1.7.2
Fixed via
1.8.0: eadf
tweise commented on issue #7249: [FLINK-11048] Ability to programmatically
execute streaming pipeline with savepoint restore
URL: https://github.com/apache/flink/pull/7249#issuecomment-449083100
@mxm the contract requires us to call this method (we could also not modify
the existing execut
mxm commented on issue #7249: [FLINK-11048] Ability to programmatically execute
streaming pipeline with savepoint restore
URL: https://github.com/apache/flink/pull/7249#issuecomment-449080141
>I would also prefer the execute method with the savepoint restore settings
(the previous version
mxm commented on a change in pull request #7249: [FLINK-11048] Ability to
programmatically execute streaming pipeline with savepoint restore
URL: https://github.com/apache/flink/pull/7249#discussion_r243359061
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/stream
tweise commented on issue #7249: [FLINK-11048] Ability to programmatically
execute streaming pipeline with savepoint restore
URL: https://github.com/apache/flink/pull/7249#issuecomment-449078240
> Just to sum up my review.
>
> * Personally would prefer method `execute(String jobName,
[
https://issues.apache.org/jira/browse/FLINK-11201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16726071#comment-16726071
]
Till Rohrmann commented on FLINK-11201:
---
Thanks for reporting this issue [~eyushin
tweise commented on a change in pull request #7249: [FLINK-11048] Ability to
programmatically execute streaming pipeline with savepoint restore
URL: https://github.com/apache/flink/pull/7249#discussion_r243355968
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/str
tweise commented on a change in pull request #7249: [FLINK-11048] Ability to
programmatically execute streaming pipeline with savepoint restore
URL: https://github.com/apache/flink/pull/7249#discussion_r243355508
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/str
tweise commented on a change in pull request #7249: [FLINK-11048] Ability to
programmatically execute streaming pipeline with savepoint restore
URL: https://github.com/apache/flink/pull/7249#discussion_r243355508
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/str
[
https://issues.apache.org/jira/browse/FLINK-10748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-10748.
---
Resolution: Fixed
Fix Version/s: 1.8.0
Fixed via
https://github.com/apache/flink/com
tillrohrmann commented on issue #7295: [FLINK-10748] Decouple
RestServerEndpoint from Dispatcher
URL: https://github.com/apache/flink/pull/7295#issuecomment-449072617
Thanks for the review @zentol. Merging this PR.
This is an
Till Rohrmann created FLINK-11208:
-
Summary: Decrease build/testing time of modules
Key: FLINK-11208
URL: https://issues.apache.org/jira/browse/FLINK-11208
Project: Flink
Issue Type: Improvem
[
https://issues.apache.org/jira/browse/FLINK-11202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16726029#comment-16726029
]
chauncy commented on FLINK-11202:
-
can i join
> Split log file per job
> --
[
https://issues.apache.org/jira/browse/FLINK-11207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11207:
---
Labels: pull-request-available (was: )
> Update Apache commons-compress from 1.4.1 to 1.18
NicoK opened a new pull request #7348: [FLINK-11207][core] update
commons-compress to 1.18
URL: https://github.com/apache/flink/pull/7348
## What is the purpose of the change
Our current version of Apache commons-compress (1.4.1) is affected by at
least one security vulnerability an
[
https://issues.apache.org/jira/browse/FLINK-5334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-5334:
Affects Version/s: 1.7.0
> outdated scala SBT quickstart example
>
[
https://issues.apache.org/jira/browse/FLINK-5334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725972#comment-16725972
]
Timo Walther commented on FLINK-5334:
-
The SBT quickstart needs an update. Also the F
[
https://issues.apache.org/jira/browse/FLINK-11187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725942#comment-16725942
]
Steve Loughran commented on FLINK-11187:
There's limits to how well you can buff
[
https://issues.apache.org/jira/browse/FLINK-10317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725939#comment-16725939
]
Nico Kruber commented on FLINK-10317:
-
Actually limiting metaspace will also trigger
zentol closed pull request #7338: Fixed comment about scala versions.
URL: https://github.com/apache/flink/pull/7338
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 this is a foreign pull reques
zentol opened a new pull request #7347: [FLINK-10761][metrics] Do not acquire
lock for getAllVariables()
URL: https://github.com/apache/flink/pull/7347
## What is the purpose of the change
With this PR we no longer acquire a lock in
`AbstractMetricGroup#getAllVariables`. Doing this
[
https://issues.apache.org/jira/browse/FLINK-10761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10761:
---
Labels: pull-request-available (was: )
> MetricGroup#getAllVariables can deadlock
> ---
Nico Kruber created FLINK-11207:
---
Summary: Update Apache commons-compress from 1.4.1 to 1.18
Key: FLINK-11207
URL: https://issues.apache.org/jira/browse/FLINK-11207
Project: Flink
Issue Type: B
[
https://issues.apache.org/jira/browse/FLINK-11134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11134:
---
Labels: pull-request-available (was: )
> Invalid REST API request should not log the full e
[
https://issues.apache.org/jira/browse/FLINK-10473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725897#comment-16725897
]
Hequn Cheng commented on FLINK-10473:
-
Hi [~karmagyz] The problem raised in FLINK-11
zentol opened a new pull request #7346: [FLINK-11134][rest] Do not log
stacktrace handled exceptions
URL: https://github.com/apache/flink/pull/7346
## What is the purpose of the change
With this PR we do not log the full stacktrace for REST exception, under the
conditions that
1.
[
https://issues.apache.org/jira/browse/FLINK-11205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725872#comment-16725872
]
Nawaid Shamim edited comment on FLINK-11205 at 12/20/18 2:13 PM:
-
joerg84 commented on issue #7338: Fixed comment about scala versions.
URL: https://github.com/apache/flink/pull/7338#issuecomment-449014423
@zentol PTAL.
This is an automated message from the Apache Git Service.
To respond to
[
https://issues.apache.org/jira/browse/FLINK-11205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725872#comment-16725872
]
Nawaid Shamim commented on FLINK-11205:
---
[~till.rohrmann] I just replied on FLINK-
[
https://issues.apache.org/jira/browse/FLINK-11205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725872#comment-16725872
]
Nawaid Shamim edited comment on FLINK-11205 at 12/20/18 2:09 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-10317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725870#comment-16725870
]
Nawaid Shamim edited comment on FLINK-10317 at 12/20/18 2:13 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-10317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725870#comment-16725870
]
Nawaid Shamim commented on FLINK-10317:
---
I guess the root cause is memory leak due
[
https://issues.apache.org/jira/browse/FLINK-9080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725121#comment-16725121
]
Nawaid Shamim edited comment on FLINK-9080 at 12/20/18 1:37 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-11134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-11134:
Assignee: Chesnay Schepler
> Invalid REST API request should not log the full exc
[
https://issues.apache.org/jira/browse/FLINK-11163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11163:
---
Labels: pull-request-available test-stability (was: test-stability)
> RestClusterClientTest
zentol opened a new pull request #7345: [FLINK-11163][tests] Use random port in
RestClusterClientTest
URL: https://github.com/apache/flink/pull/7345
## What is the purpose of the change
This PR fixes a port conflict in the `RestClusterClientTest`. The test was
starting a rest serve
FaxianZhao opened a new pull request #7344: [FLINK-4369] Optimize evict
performance for the TriggerResult.FIRE_AND_PURGE
URL: https://github.com/apache/flink/pull/7344
## What is the purpose of the change
Due to the previous work around fix FLINK-4369.
It will clear windowState, t
[
https://issues.apache.org/jira/browse/FLINK-11163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-11163:
Assignee: Chesnay Schepler
> RestClusterClientTest#testSendIsNotRetriableIfHttpNo
[
https://issues.apache.org/jira/browse/FLINK-11079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11079:
---
Labels: pull-request-available (was: )
> Skip deployment for flnk-storm-examples
>
zentol opened a new pull request #7343: [FLINK-11079][storm] Skip deployment of
storm-examples
URL: https://github.com/apache/flink/pull/7343
## What is the purpose of the change
This PR disables the deployment of `flink-storm-examples`. These examples
are not bundled with flink-dis
[
https://issues.apache.org/jira/browse/FLINK-11079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11079:
-
Summary: Skip deployment for flnk-storm-examples (was: Update LICENSE and
NOTICE files
[
https://issues.apache.org/jira/browse/FLINK-11159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725777#comment-16725777
]
Chesnay Schepler commented on FLINK-11159:
--
Have we ever considered to also cre
[
https://issues.apache.org/jira/browse/FLINK-10317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725768#comment-16725768
]
Nico Kruber edited comment on FLINK-10317 at 12/20/18 11:01 AM:
--
zentol commented on a change in pull request #7260: [hotfix][docs] Fix typo and
make improvement in Kafka Connectors doc
URL: https://github.com/apache/flink/pull/7260#discussion_r243231943
##
File path: docs/dev/connectors/kafka.md
##
@@ -713,14 +713,14 @@ the consumers u
zentol commented on a change in pull request #7260: [hotfix][docs] Fix typo and
make improvement in Kafka Connectors doc
URL: https://github.com/apache/flink/pull/7260#discussion_r243232818
##
File path: docs/dev/connectors/kafka.md
##
@@ -713,14 +713,14 @@ the consumers u
zentol commented on a change in pull request #7260: [hotfix][docs] Fix typo and
make improvement in Kafka Connectors doc
URL: https://github.com/apache/flink/pull/7260#discussion_r243232094
##
File path: docs/dev/connectors/kafka.md
##
@@ -713,14 +713,14 @@ the consumers u
[
https://issues.apache.org/jira/browse/FLINK-10317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725768#comment-16725768
]
Nico Kruber commented on FLINK-10317:
-
Can you try to limit the metaspace as describ
[
https://issues.apache.org/jira/browse/FLINK-11159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725767#comment-16725767
]
Nico Kruber commented on FLINK-11159:
-
It would help a bit, but still, restoring fro
[
https://issues.apache.org/jira/browse/FLINK-10473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725757#comment-16725757
]
Andrey Zagrebin commented on FLINK-10473:
-
Hi [~karmagyz], I have couple of ques
TisonKun commented on a change in pull request #7302: [FLINK-11156] [tests]
Reconcile ZooKeeperCompletedCheckpointStoreMockitoTest with JDK 9
URL: https://github.com/apache/flink/pull/7302#discussion_r243229630
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/chec
zentol commented on a change in pull request #7302: [FLINK-11156] [tests]
Reconcile ZooKeeperCompletedCheckpointStoreMockitoTest with JDK 9
URL: https://github.com/apache/flink/pull/7302#discussion_r243225330
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/checkp
zentol commented on a change in pull request #7302: [FLINK-11156] [tests]
Reconcile ZooKeeperCompletedCheckpointStoreMockitoTest with JDK 9
URL: https://github.com/apache/flink/pull/7302#discussion_r243225353
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/checkp
zentol opened a new pull request #7342: [FLINK-11023][ES] Add NOTICE file
URL: https://github.com/apache/flink/pull/7342
## What is the purpose of the change
This PR adds a NOTCE file to the ES6 connector.
## Verifying this change
Manually verified.
For a given mo
[
https://issues.apache.org/jira/browse/FLINK-10461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-10461:
-
Issue Type: New Feature (was: Improvement)
> Speed up RocksDB download file procedure w
[
https://issues.apache.org/jira/browse/FLINK-11183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725735#comment-16725735
]
Mario Georgiev commented on FLINK-11183:
-
Hello,
Using the System Metrics woul
[
https://issues.apache.org/jira/browse/FLINK-11183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725734#comment-16725734
]
Chesnay Schepler commented on FLINK-11183:
--
In a similar vein you can also chec
[
https://issues.apache.org/jira/browse/FLINK-10461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-10461:
-
Summary: Speed up RocksDB download file procedure when restoring (was:
Speed up downloa
[
https://issues.apache.org/jira/browse/FLINK-10461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-10461.
Resolution: Fixed
master: 6431b7e2ebd7f9eb770de54fc853970845586e44
> Speed up RocksDB dow
[
https://issues.apache.org/jira/browse/FLINK-10461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-10461.
Resolution: Fixed
Fix Version/s: 1.8.0
master: 6431b7e2ebd7f9eb770de54fc85397084558
[
https://issues.apache.org/jira/browse/FLINK-10461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reopened FLINK-10461:
--
> Speed up RocksDB download file procedure when restoring
> --
zentol closed pull request #6777: [FLINK-10461] [State Backends, Checkpointing]
Speed up download files when restore from DFS
URL: https://github.com/apache/flink/pull/6777
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
[
https://issues.apache.org/jira/browse/FLINK-9083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-9083.
---
Resolution: Fixed
Fix Version/s: 1.8.0
master: 42f5f778468097151e1e7bf75854b3f592b8435
zentol closed pull request #6782: [FLINK-9083][Cassandra Connector] Add async
backpressure support to Cassandra Connector
URL: https://github.com/apache/flink/pull/6782
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the
zentol opened a new pull request #7341: [FLINK-11026][kafka][SQL] Rework kafka
sql-client jar creation
URL: https://github.com/apache/flink/pull/7341
## What is the purpose of the change
This PR reworks the the generation of sql-client jars for the kafka
connectors, similar to #725
[
https://issues.apache.org/jira/browse/FLINK-11159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725719#comment-16725719
]
Till Rohrmann commented on FLINK-11159:
---
Wouldn't the problem be solved if Flink w
[
https://issues.apache.org/jira/browse/FLINK-11163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-11163:
--
Priority: Critical (was: Major)
> RestClusterClientTest#testSendIsNotRetriableIfHttpNotFound
[
https://issues.apache.org/jira/browse/FLINK-11163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-11163:
--
Labels: test-stability (was: )
> RestClusterClientTest#testSendIsNotRetriableIfHttpNotFound w
[
https://issues.apache.org/jira/browse/FLINK-11183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725716#comment-16725716
]
Chesnay Schepler commented on FLINK-11183:
--
The graph you showed, is that the m
[
https://issues.apache.org/jira/browse/FLINK-11182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-11182.
-
Resolution: Won't Do
> JobManagerHACheckpointRecoveryITCase need be improved
> -
[
https://issues.apache.org/jira/browse/FLINK-3404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-3404.
---
Resolution: Won't Fix
Subsumed by newer work on the new source interface
> Extend Kafka cons
[
https://issues.apache.org/jira/browse/FLINK-11185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-11185:
--
Labels: test-stability (was: )
> StreamSourceOperatorWatermarksTest failed with InterruptedEx
[
https://issues.apache.org/jira/browse/FLINK-11185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-11185:
--
Priority: Critical (was: Minor)
> StreamSourceOperatorWatermarksTest failed with InterruptedE
[
https://issues.apache.org/jira/browse/FLINK-11206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725707#comment-16725707
]
ambition commented on FLINK-11206:
--
sorry, I just see this doc
https://docs.google.co
1 - 100 of 116 matches
Mail list logo
