Github user xueyumusic commented on the issue:
https://github.com/apache/flink/pull/6204
Thank you for review, @tillrohrmann , it may also need to modify the
`quickstart.sh` script which is in another flink-web git project, so I opened
another PR at https://github.com/apache/flink-web
[
https://issues.apache.org/jira/browse/FLINK-4301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16528966#comment-16528966
]
ASF GitHub Bot commented on FLINK-4301:
---
Github user xueyumusic commented on the is
[
https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-9697:
Description:
Kafka 2.0.0 would be released soon.
Here is vote thread:
[http://search-hadoop.com/m/Kafka/u
[
https://issues.apache.org/jira/browse/FLINK-9693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-9693:
Summary: Possible memory leak in jobmanager retaining archived checkpoints
(was: possible memory link in j
[
https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-9697:
---
Assignee: vinoyang
> Provide connector for Kafka 2.0.0
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-6469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16528954#comment-16528954
]
ASF GitHub Bot commented on FLINK-6469:
---
Github user yanghua commented on the issue
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5448
cc @dawidwys introduced `MemoryUnit` and refactor `MemorySize`, please
review~
---
[
https://issues.apache.org/jira/browse/FLINK-8785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16528914#comment-16528914
]
ASF GitHub Bot commented on FLINK-8785:
---
Github user tillrohrmann commented on a di
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6222#discussion_r199333683
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobSubmitHandler.java
---
@@ -66,6 +67,9 @@ public JobSubmitHandler(
[
https://issues.apache.org/jira/browse/FLINK-9280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16528913#comment-16528913
]
ASF GitHub Bot commented on FLINK-9280:
---
Github user tillrohrmann commented on a di
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6203#discussion_r199333574
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobSubmitHandler.java
---
@@ -34,38 +40,137 @@
import javax.
Ted Yu created FLINK-9697:
-
Summary: Provide connector for Kafka 2.0.0
Key: FLINK-9697
URL: https://issues.apache.org/jira/browse/FLINK-9697
Project: Flink
Issue Type: Improvement
Reporte
[
https://issues.apache.org/jira/browse/FLINK-9693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16528903#comment-16528903
]
Till Rohrmann commented on FLINK-9693:
--
As [~stefanrichte...@gmail.com] suggested, t
[
https://issues.apache.org/jira/browse/FLINK-9693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9693:
-
Affects Version/s: 1.6.0
1.5.0
> possible memory link in jobmanager retain
[
https://issues.apache.org/jira/browse/FLINK-9660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16528901#comment-16528901
]
ASF GitHub Bot commented on FLINK-9660:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6207
---
[
https://issues.apache.org/jira/browse/FLINK-9660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-9660.
--
Resolution: Fixed
Fixed via d2de75e4587b005914eac3489cd96929cde73cfc
> Allow passing custom ar
[
https://issues.apache.org/jira/browse/FLINK-9660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-9660:
Assignee: Leonid Ishimnikov
> Allow passing custom artifacts to Mesos workers
> --
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6219
---
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6219#discussion_r199332279
--- Diff: docs/monitoring/metrics.md ---
@@ -426,7 +426,7 @@ class MyMapper extends RichMapFunction[Long,Long] {
Every metric is assigned an i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/6219
Thanks for fixing the typo @elbaulp. Merging this PR.
---
[
https://issues.apache.org/jira/browse/FLINK-9686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-9686:
Assignee: Franz Thoma
> Flink Kinesis Producer: Enable Kinesis authentication via AssumeRo
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/commit/8c89f3c6b5ebd0334176d9e7e57b38b4d39a594a#commitcomment-29555488
The Flink JIRA issue seems to be incorrect. @aljoscha could you please
point me to the correct JIRA issue?
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6225
---
[
https://issues.apache.org/jira/browse/FLINK-9684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9684:
--
Labels: pull-request-available (was: )
> HistoryServerArchiveFetcher not working properly with
[
https://issues.apache.org/jira/browse/FLINK-9684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16528890#comment-16528890
]
ASF GitHub Bot commented on FLINK-9684:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-9684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-9684.
--
Resolution: Fixed
Fix Version/s: 1.5.1
1.6.0
Fixed via
1.6.0: c280898
[
https://issues.apache.org/jira/browse/FLINK-9684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-9684:
Assignee: Ethan Li
> HistoryServerArchiveFetcher not working properly with secure hdfs clu
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6229
---
[
https://issues.apache.org/jira/browse/FLINK-9695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16528881#comment-16528881
]
ASF GitHub Bot commented on FLINK-9695:
---
Github user tillrohrmann commented on a di
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6232#discussion_r199331211
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosTaskManagerParameters.java
---
@@ -101,6 +101,12 @@
[
https://issues.apache.org/jira/browse/FLINK-9695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-9695:
Assignee: Leonid Ishimnikov
> Add option for Mesos executor to forcefully pull Docker imag
[
https://issues.apache.org/jira/browse/FLINK-9669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16528835#comment-16528835
]
ASF GitHub Bot commented on FLINK-9669:
---
Github user tillrohrmann commented on the
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/6214
For what do we need the assignment store interface if we go with the tag
based scheduling solution @liurenjie1024?
---
[
https://issues.apache.org/jira/browse/FLINK-9532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16528830#comment-16528830
]
ASF GitHub Bot commented on FLINK-9532:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6125
---
[
https://issues.apache.org/jira/browse/FLINK-9532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-9532.
--
Resolution: Fixed
Fix Version/s: 1.6.0
Fixed via a1b6153dd5858489031e7776e8e4dc43ea52e48
[
https://issues.apache.org/jira/browse/FLINK-9696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9696:
--
Labels: pull-request-available (was: )
> Deep toString for arrays/map in SQL client
> ---
[
https://issues.apache.org/jira/browse/FLINK-9696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16528812#comment-16528812
]
ASF GitHub Bot commented on FLINK-9696:
---
GitHub user snuyanzin opened a pull reques
GitHub user snuyanzin opened a pull request:
https://github.com/apache/flink/pull/6233
[FLINK-9696] Deep toString for array/map sql types
*Thank you very much for contributing to Apache Flink - we are happy that
you want to help us improve Flink. To help the community review your
c
[
https://issues.apache.org/jira/browse/FLINK-9491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16528800#comment-16528800
]
ASF GitHub Bot commented on FLINK-9491:
---
Github user sihuazhou commented on the iss
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/6228
@StefanRRichter very nice PR, I only had some very minor comments.
---
[
https://issues.apache.org/jira/browse/FLINK-9696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-9696:
---
Component/s: Table API & SQL
> Deep toString for arrays/map in SQL client
>
Sergey Nuyanzin created FLINK-9696:
--
Summary: Deep toString for arrays/map in SQL client
Key: FLINK-9696
URL: https://issues.apache.org/jira/browse/FLINK-9696
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-9491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16528787#comment-16528787
]
ASF GitHub Bot commented on FLINK-9491:
---
Github user sihuazhou commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-9491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16528786#comment-16528786
]
ASF GitHub Bot commented on FLINK-9491:
---
Github user sihuazhou commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-9491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16528783#comment-16528783
]
ASF GitHub Bot commented on FLINK-9491:
---
Github user sihuazhou commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-9491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16528785#comment-16528785
]
ASF GitHub Bot commented on FLINK-9491:
---
Github user sihuazhou commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-9491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16528784#comment-16528784
]
ASF GitHub Bot commented on FLINK-9491:
---
Github user sihuazhou commented on a diff
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/6228#discussion_r199325112
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/InternalPriorityQueue.java
---
@@ -0,0 +1,99 @@
+/*
+ * Licensed to the Apach
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/6228#discussion_r199325523
--- Diff:
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBOrderedStore.java
---
@@ -0,0 +1,2
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/6228#discussion_r199325117
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/InternalPriorityQueue.java
---
@@ -0,0 +1,99 @@
+/*
+ * Licensed to the Apach
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/6228#discussion_r199325172
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/KeyGroupPartitionedPriorityQueue.java
---
@@ -0,0 +1,277 @@
+/*
+ * Lice
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/6228#discussion_r199325190
--- Diff:
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBOrderedStore.java
---
@@ -0,0 +1,2
[
https://issues.apache.org/jira/browse/FLINK-9695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16528772#comment-16528772
]
ASF GitHub Bot commented on FLINK-9695:
---
GitHub user lishim opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-9695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9695:
--
Labels: pull-request-available (was: )
> Add option for Mesos executor to forcefully pull Dock
GitHub user lishim opened a pull request:
https://github.com/apache/flink/pull/6232
[FLINK-9695] [mesos] Add option for Mesos executor to forcefully pull
Docker images
## What is the purpose of the change
* This pull request introduces an option for Mesos executor to forcef
Leonid Ishimnikov created FLINK-9695:
Summary: Add option for Mesos executor to forcefully pull Docker
images
Key: FLINK-9695
URL: https://issues.apache.org/jira/browse/FLINK-9695
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16528700#comment-16528700
]
Chunhui Shi commented on FLINK-7593:
This seems was fixed in 1.5.
> Generated plan
[
https://issues.apache.org/jira/browse/FLINK-9491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16528667#comment-16528667
]
ASF GitHub Bot commented on FLINK-9491:
---
Github user sihuazhou commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-9491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16528668#comment-16528668
]
ASF GitHub Bot commented on FLINK-9491:
---
Github user sihuazhou commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-9491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16528666#comment-16528666
]
ASF GitHub Bot commented on FLINK-9491:
---
Github user sihuazhou commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-9491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16528665#comment-16528665
]
ASF GitHub Bot commented on FLINK-9491:
---
Github user sihuazhou commented on a diff
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/6228#discussion_r199320135
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/CachingInternalPriorityQueueSet.java
---
@@ -0,0 +1,288 @@
+/*
+ * Licen
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/6228#discussion_r199320321
--- Diff:
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBOrderedStore.java
---
@@ -0,0 +1,2
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/6228#discussion_r199320254
--- Diff:
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBOrderedStore.java
---
@@ -0,0 +1,2
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/6228#discussion_r199320146
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/CachingInternalPriorityQueueSet.java
---
@@ -0,0 +1,288 @@
+/*
+ * Licen
[
https://issues.apache.org/jira/browse/FLINK-4301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16528633#comment-16528633
]
ASF GitHub Bot commented on FLINK-4301:
---
Github user yanghua commented on the issue
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/6204
@xueyumusic looks good from my side~
---
[
https://issues.apache.org/jira/browse/FLINK-9694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16528616#comment-16528616
]
ASF GitHub Bot commented on FLINK-9694:
---
Github user yanghua commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-9532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16528615#comment-16528615
]
ASF GitHub Bot commented on FLINK-9532:
---
Github user yanghua commented on the issue
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/6125
@GJL can you review this?
---
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/6231
cc @twalthr and @fhueske
---
[
https://issues.apache.org/jira/browse/FLINK-9649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16528614#comment-16528614
]
Gary Yao commented on FLINK-9649:
-
[~lishim] Actually, the config key \{{mesos.initial-ta
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6219#discussion_r199316517
--- Diff: docs/monitoring/metrics.md ---
@@ -426,7 +426,7 @@ class MyMapper extends RichMapFunction[Long,Long] {
Every metric is assigned an identi
[
https://issues.apache.org/jira/browse/FLINK-8785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16528609#comment-16528609
]
ASF GitHub Bot commented on FLINK-8785:
---
Github user yanghua commented on the issue
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/6229
Hi @satybald thanks for your contribution, based on [Flink's contribution
guide](http://flink.apache.org/how-to-contribute.html) you'd better open an
issue in
[JIRA](https://issues.apache.org/jira/p
[
https://issues.apache.org/jira/browse/FLINK-9694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16528608#comment-16528608
]
ASF GitHub Bot commented on FLINK-9694:
---
Github user zhangminglei commented on the
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/6231
Looks good from my side @yanghua :)
---
[
https://issues.apache.org/jira/browse/FLINK-9532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16528592#comment-16528592
]
ASF GitHub Bot commented on FLINK-9532:
---
Github user sihuazhou commented on the iss
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/6125
@yanghua sorry I'm not a native english speaker, so I think I'm not
suitable to review this...
---
[
https://issues.apache.org/jira/browse/FLINK-9456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16528590#comment-16528590
]
ASF GitHub Bot commented on FLINK-9456:
---
Github user sihuazhou commented on the iss
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/6132
Hi @tillrohrmann I updated the PR could you please have a look again?
---
[
https://issues.apache.org/jira/browse/FLINK-9456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16528585#comment-16528585
]
ASF GitHub Bot commented on FLINK-9456:
---
Github user sihuazhou commented on a diff
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/6132#discussion_r199315500
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -984,6 +985,15 @@ private void startCheckpointScheduler(fin
85 matches
Mail list logo