[
https://issues.apache.org/jira/browse/FLINK-9694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9694:
--
Labels: pull-request-available (was: )
> Potentially NPE in
[
https://issues.apache.org/jira/browse/FLINK-9694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16528575#comment-16528575
]
ASF GitHub Bot commented on FLINK-9694:
---
GitHub user yanghua opened a pull request:
GitHub user yanghua opened a pull request:
https://github.com/apache/flink/pull/6231
[FLINK-9694] Potentially NPE in CompositeTypeSerializerConfigSnapshot
constructor
## What is the purpose of the change
*This pull request fixed a NPE in
[
https://issues.apache.org/jira/browse/FLINK-9456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16528585#comment-16528585
]
ASF GitHub Bot commented on FLINK-9456:
---
Github user sihuazhou commented on a diff in the pull
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
[
https://issues.apache.org/jira/browse/FLINK-9532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16528592#comment-16528592
]
ASF GitHub Bot commented on FLINK-9532:
---
Github user sihuazhou commented on the issue:
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-9649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16528614#comment-16528614
]
Gary Yao commented on FLINK-9649:
-
[~lishim] Actually, the config key \{{mesos.initial-tasks}} is not
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
---
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
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:
[
https://issues.apache.org/jira/browse/FLINK-9491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16528800#comment-16528800
]
ASF GitHub Bot commented on FLINK-9491:
---
Github user sihuazhou commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16528812#comment-16528812
]
ASF GitHub Bot commented on FLINK-9696:
---
GitHub user snuyanzin opened a pull request:
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
[
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
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6125
---
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
[
https://issues.apache.org/jira/browse/FLINK-9491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16528784#comment-16528784
]
ASF GitHub Bot commented on FLINK-9491:
---
Github user sihuazhou commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16528787#comment-16528787
]
ASF GitHub Bot commented on FLINK-9491:
---
Github user sihuazhou commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16528786#comment-16528786
]
ASF GitHub Bot commented on FLINK-9491:
---
Github user sihuazhou commented on a diff in the pull
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
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 @@
+/*
+ *
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
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
[
https://issues.apache.org/jira/browse/FLINK-9491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16528783#comment-16528783
]
ASF GitHub Bot commented on FLINK-9491:
---
Github user sihuazhou commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16528785#comment-16528785
]
ASF GitHub Bot commented on FLINK-9491:
---
Github user sihuazhou commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16528830#comment-16528830
]
ASF GitHub Bot commented on FLINK-9532:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-9669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16528835#comment-16528835
]
ASF GitHub Bot commented on FLINK-9669:
---
Github user tillrohrmann commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
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
[
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
>
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?
---
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-9694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16528608#comment-16528608
]
ASF GitHub Bot commented on FLINK-9694:
---
Github user zhangminglei commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-9694:
Description:
the partial specific exception stack trace :
{code:java}
Caused by:
[
https://issues.apache.org/jira/browse/FLINK-9694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-9694:
Summary: Potentially NPE in CompositeTypeSerializerConfigSnapshot
constructor (was: potentially NPE in
vinoyang created FLINK-9694:
---
Summary: potentially NPE in CompositeTypeSerializerConfigSnapshot
constructor
Key: FLINK-9694
URL: https://issues.apache.org/jira/browse/FLINK-9694
Project: Flink
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=16528590#comment-16528590
]
ASF GitHub Bot commented on FLINK-9456:
---
Github user sihuazhou commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16528609#comment-16528609
]
ASF GitHub Bot commented on FLINK-8785:
---
Github user yanghua commented on the issue:
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
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 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-9681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng updated FLINK-9681:
---
Description:
Currently, for a group by(or other operators), if minRetentionTime equals to
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
[
https://issues.apache.org/jira/browse/FLINK-9491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16528666#comment-16528666
]
ASF GitHub Bot commented on FLINK-9491:
---
Github user sihuazhou commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16528665#comment-16528665
]
ASF GitHub Bot commented on FLINK-9491:
---
Github user sihuazhou commented on a diff in the pull
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
[
https://issues.apache.org/jira/browse/FLINK-9491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16528667#comment-16528667
]
ASF GitHub Bot commented on FLINK-9491:
---
Github user sihuazhou commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16528668#comment-16528668
]
ASF GitHub Bot commented on FLINK-9491:
---
Github user sihuazhou commented on a diff in the pull
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 @@
+/*
+ *
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
[
https://issues.apache.org/jira/browse/FLINK-9694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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=16528615#comment-16528615
]
ASF GitHub Bot commented on FLINK-9532:
---
Github user yanghua commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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-7593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16528700#comment-16528700
]
Chunhui Shi commented on FLINK-7593:
This seems was fixed in 1.5.
> Generated plan does not create
[
https://issues.apache.org/jira/browse/FLINK-9695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16528881#comment-16528881
]
ASF GitHub Bot commented on FLINK-9695:
---
Github user tillrohrmann commented on a diff in the pull
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-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
[
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:
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
[
https://issues.apache.org/jira/browse/FLINK-9684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16528890#comment-16528890
]
ASF GitHub Bot commented on FLINK-9684:
---
Github user asfgit closed the pull request at:
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 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
[
https://issues.apache.org/jira/browse/FLINK-8785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16528914#comment-16528914
]
ASF GitHub Bot commented on FLINK-8785:
---
Github user tillrohrmann commented on a diff in the pull
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-9660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16528901#comment-16528901
]
ASF GitHub Bot commented on FLINK-9660:
---
Github user asfgit closed the pull request at:
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
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
[
https://issues.apache.org/jira/browse/FLINK-9280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16528913#comment-16528913
]
ASF GitHub Bot commented on FLINK-9280:
---
Github user tillrohrmann commented on a diff in the pull
[
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
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6219
---
[
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
>
[
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
[
https://issues.apache.org/jira/browse/FLINK-9693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16528903#comment-16528903
]
Till Rohrmann commented on FLINK-9693:
--
As [~stefanrichte...@gmail.com] suggested, the problem could
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-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
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6229
---
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
[
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
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://issues.apache.org/jira/browse/FLINK-4301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16528966#comment-16528966
]
ASF GitHub Bot commented on FLINK-4301:
---
Github user xueyumusic commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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-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-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:
92 matches
Mail list logo
