[
https://issues.apache.org/jira/browse/FLINK-6288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16010019#comment-16010019
]
ASF GitHub Bot commented on FLINK-6288:
---
Github user zjureel commented on the issue:
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/3766
@tzulitai Thank you for your suggestion, and I think you are right. I will
create a new PR from the master and cherry-pick my commits for this issue soon.
---
If your project is set up for it, you
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16010018#comment-16010018
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user hongyuhong commented on a diff
Github user hongyuhong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r116416819
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeInnerJoin.scala
---
@@ -0,0 +1,323 @@
+/*
+ * Li
[
https://issues.apache.org/jira/browse/FLINK-6492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16010006#comment-16010006
]
Huafeng Wang commented on FLINK-6492:
-
If nobody is woking on this, I'd like to take t
[
https://issues.apache.org/jira/browse/FLINK-6288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16010003#comment-16010003
]
ASF GitHub Bot commented on FLINK-6288:
---
Github user tzulitai commented on the issue
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/3766
@zjureel the rebases don't seem to be done correctly. The PR should contain
the diff commits only.
I'm not sure what went wrong, but perhaps the most easiest way right now is
cherry-pick your di
[
https://issues.apache.org/jira/browse/FLINK-6288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16010001#comment-16010001
]
ASF GitHub Bot commented on FLINK-6288:
---
Github user tzulitai commented on the issue
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/3766
@zjureel thanks. You would need a proper rebase: `git rebase master` when
you finish your feature branch, instead of merging the latest master.
Regarding timeout: doesn't the Kafka client ha
[
https://issues.apache.org/jira/browse/FLINK-6288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009993#comment-16009993
]
ASF GitHub Bot commented on FLINK-6288:
---
Github user zjureel commented on the issue:
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/3766
@tzulitai Thank you for your replay.
For 1, the `ExecutorService` is used to control timeout of fetching kafka
partitions. When fetch kafka partitions, a `Future` will be created and
execut
[
https://issues.apache.org/jira/browse/FLINK-4864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009922#comment-16009922
]
ASF GitHub Bot commented on FLINK-4864:
---
Github user wuchong closed the pull request
Github user wuchong closed the pull request at:
https://github.com/apache/flink/pull/2673
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is ena
[
https://issues.apache.org/jira/browse/FLINK-6557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009910#comment-16009910
]
Xiaogang Shi commented on FLINK-6557:
-
[~Zentol] Thanks a lot for pointing it out. As
Github user rtudoran commented on the issue:
https://github.com/apache/flink/pull/3889
@hongyuhong @stefanobortoli @shijinkui i forgot to add you to the PR
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your pro
[
https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009906#comment-16009906
]
ASF GitHub Bot commented on FLINK-6075:
---
Github user rtudoran commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009905#comment-16009905
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user rtudoran commented on a diff in
Github user rtudoran commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r116397679
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/FilterRunner.scala
---
@@ -0,0 +1,54 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009904#comment-16009904
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user rtudoran commented on a diff in
Github user rtudoran commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r116397441
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/JoinUtil.scala
---
@@ -199,31 +157,38 @@ object JoinUtil {
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009899#comment-16009899
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user rtudoran commented on a diff in
Github user rtudoran commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r116397057
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamJoin.scala
---
@@ -0,0 +1,180 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009896#comment-16009896
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user rtudoran commented on a diff in
Github user rtudoran commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r116396723
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeInnerJoin.scala
---
@@ -0,0 +1,323 @@
+/*
+ * Lice
[
https://issues.apache.org/jira/browse/FLINK-3620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009855#comment-16009855
]
ASF GitHub Bot commented on FLINK-3620:
---
Github user xhook commented on the issue:
Github user xhook commented on the issue:
https://github.com/apache/flink/pull/1800
Hi @gyfora,
in https://issues.apache.org/jira/browse/FLINK-3620 it's said that it's
decided to make DbStateBackend and external library. Unfortunately I can't find
it anywhere. Does it exist?
T
[
https://issues.apache.org/jira/browse/FLINK-6551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-6551:
Summary: OutputTag name should not be allowed to be empty (was: OutputTag
name should not b
[
https://issues.apache.org/jira/browse/FLINK-6440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009838#comment-16009838
]
Chesnay Schepler edited comment on FLINK-6440 at 5/14/17 8:23 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-6440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009838#comment-16009838
]
Chesnay Schepler commented on FLINK-6440:
-
I'm wondering what our options are here
[
https://issues.apache.org/jira/browse/FLINK-6370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009832#comment-16009832
]
ASF GitHub Bot commented on FLINK-6370:
---
GitHub user zentol opened a pull request:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/3896
[FLINK-6370] [webUI] Handle races for single file in FileServerHandler
This PR prevents a race between multiple requests trying to create the same
file, which previously would cause one request to fa
[
https://issues.apache.org/jira/browse/FLINK-6370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-6370:
---
Assignee: Chesnay Schepler
> FileAlreadyExistsException on startup
>
Kostas Kloudas created FLINK-6578:
-
Summary: SharedBuffer creates self-loops when having elements with
same value/timestamp.
Key: FLINK-6578
URL: https://issues.apache.org/jira/browse/FLINK-6578
Proje
[
https://issues.apache.org/jira/browse/FLINK-6537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-6537:
--
Priority: Major (was: Blocker)
> Umbrella issue for fixes to incremental snapshots
> --
[
https://issues.apache.org/jira/browse/FLINK-6505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-6505:
--
Priority: Major (was: Blocker)
> Proactively cleanup local FS for RocksDBKeyedStateBackend on s
[
https://issues.apache.org/jira/browse/FLINK-6540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-6540:
--
Priority: Major (was: Blocker)
> Add more thorough tests for RocksDB and incremental checkpoint
[
https://issues.apache.org/jira/browse/FLINK-6545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-6545.
-
Resolution: Fixed
fixed in 098e46f2d2
> Make incremental checkpoints externalizable
> ---
[
https://issues.apache.org/jira/browse/FLINK-6535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-6535.
-
Resolution: Fixed
fixed in 4745d0c082
> JobID should not be part of the registration key to the S
[
https://issues.apache.org/jira/browse/FLINK-6534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-6534.
-
Resolution: Fixed
fixed in 44fb035e02.
> SharedStateRegistry is disposing state handles from main
[
https://issues.apache.org/jira/browse/FLINK-6533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-6533.
-
Resolution: Fixed
fixed in 4745d0c082
> Duplicated registration of new shared state when checkpoi
[
https://issues.apache.org/jira/browse/FLINK-6527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-6527.
-
Resolution: Fixed
fixed in efbb41bc63
> OperatorSubtaskState has empty implementations of (un)/re
[
https://issues.apache.org/jira/browse/FLINK-6504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-6504.
-
Resolution: Fixed
fixed in 958773b71c
> Lack of synchronization on materializedSstFiles in RocksD
[
https://issues.apache.org/jira/browse/FLINK-6535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009707#comment-16009707
]
ASF GitHub Bot commented on FLINK-6535:
---
Github user StefanRRichter closed the pull
Github user StefanRRichter closed the pull request at:
https://github.com/apache/flink/pull/3870
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/3870
Thanks @rmetzger ! Merged.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled an
[
https://issues.apache.org/jira/browse/FLINK-6569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009685#comment-16009685
]
ASF GitHub Bot commented on FLINK-6569:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/3890
Thank you for addressing this so quickly.
+1 from my side.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does no
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/3870
+1 to merge
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if th
[
https://issues.apache.org/jira/browse/FLINK-6221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009658#comment-16009658
]
ASF GitHub Bot commented on FLINK-6221:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3833
Yu can find an example on how to shade here:
https://github.com/apache/flink/blob/master/flink-metrics/flink-metrics-datadog/pom.xml.
Shading dependencies in reporters/connectors has become a
[
https://issues.apache.org/jira/browse/FLINK-6221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009654#comment-16009654
]
ASF GitHub Bot commented on FLINK-6221:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3833#discussion_r116377143
--- Diff:
flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metrics/prometheus/PrometheusReporter.java
---
@@ -133,61 +136,58 @@ public v
[
https://issues.apache.org/jira/browse/FLINK-6221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009649#comment-16009649
]
ASF GitHub Bot commented on FLINK-6221:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3833#discussion_r116376926
--- Diff:
flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metrics/prometheus/PrometheusReporter.java
---
@@ -0,0 +1,256 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-6221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009646#comment-16009646
]
ASF GitHub Bot commented on FLINK-6221:
---
Github user mbode commented on the issue:
Github user mbode commented on the issue:
https://github.com/apache/flink/pull/3833
Okay, guava is not used anymore. I am not sure about the shading part.
Would you expect either prometheus clients or nanohttpd to be used in Flink
user code? Or are there other advantages to shading? I
[
https://issues.apache.org/jira/browse/FLINK-6221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009643#comment-16009643
]
ASF GitHub Bot commented on FLINK-6221:
---
Github user mbode commented on a diff in th
Github user mbode commented on a diff in the pull request:
https://github.com/apache/flink/pull/3833#discussion_r116376242
--- Diff:
flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metrics/prometheus/PrometheusReporter.java
---
@@ -0,0 +1,256 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-6221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009639#comment-16009639
]
ASF GitHub Bot commented on FLINK-6221:
---
Github user mbode commented on a diff in th
Github user mbode commented on a diff in the pull request:
https://github.com/apache/flink/pull/3833#discussion_r116375209
--- Diff:
flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metrics/prometheus/PrometheusReporter.java
---
@@ -0,0 +1,256 @@
+/*
+
60 matches
Mail list logo
