[
https://issues.apache.org/jira/browse/FLINK-5791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu updated FLINK-5791:
Summary: Support an optimal matching based slot manager for flip6 yarn mode
(was: Resource should be strict
[
https://issues.apache.org/jira/browse/FLINK-6055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925685#comment-15925685
]
Fabian Hueske commented on FLINK-6055:
--
I think [~sunjincheng121] suggests this featu
[
https://issues.apache.org/jira/browse/FLINK-6036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925691#comment-15925691
]
Fabian Hueske commented on FLINK-6036:
--
Do you want to implement this by extending th
jinkuishi created FLINK-6056:
Summary: apache-rat exclude flink directory in tools
Key: FLINK-6056
URL: https://issues.apache.org/jira/browse/FLINK-6056
Project: Flink
Issue Type: Wish
GitHub user shijinkui opened a pull request:
https://github.com/apache/flink/pull/3540
[FLINK-6056] apache-rat exclude flink directory in tools
The flink* directory in the tools is temporary cloned when build
distribution.
So when build the Flink project, we should exclude the f
[
https://issues.apache.org/jira/browse/FLINK-6056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925706#comment-15925706
]
ASF GitHub Bot commented on FLINK-6056:
---
GitHub user shijinkui opened a pull request
[
https://issues.apache.org/jira/browse/FLINK-5791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu updated FLINK-5791:
Description:
In flip6, for yarn mode, it request containers from yarn according to the
resource profile in
Github user shuai-xu closed the pull request at:
https://github.com/apache/flink/pull/3304
---
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 en
[
https://issues.apache.org/jira/browse/FLINK-5791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925716#comment-15925716
]
ASF GitHub Bot commented on FLINK-5791:
---
Github user shuai-xu closed the pull reques
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3409#discussion_r106025992
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -246,6 +251,36 @@ abstract class TableEnvironm
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3409#discussion_r106024978
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -246,6 +251,36 @@ abstract class TableEnvironm
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3409#discussion_r106026297
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -353,19 +388,48 @@ abstract class TableEnviron
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3409#discussion_r106026738
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/logical/operators.scala
---
@@ -511,15 +511,15 @@ case class Join(
}
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3409#discussion_r106107064
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/batch/ExternalCatalogITCase.scala
---
@@ -0,0 +1,85 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3409#discussion_r106025824
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -99,6 +101,9 @@ abstract class TableEnvironmen
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3409#discussion_r106104033
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -353,19 +388,48 @@ abstract class TableEnviron
[
https://issues.apache.org/jira/browse/FLINK-5570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925729#comment-15925729
]
Fabian Hueske commented on FLINK-5570:
--
Hi [~wheat9], the issue is actually about add
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r106106765
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java
---
@@ -74,88 +76,233 @@
*/
@SuppressWarn
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r106108080
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java
---
@@ -74,88 +76,233 @@
*/
@SuppressWarn
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r106108841
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java
---
@@ -74,88 +76,233 @@
*/
@SuppressWarn
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r106107383
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java
---
@@ -74,88 +76,233 @@
*/
@SuppressWarn
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r106108473
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java
---
@@ -74,88 +76,233 @@
*/
@SuppressWarn
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r106109112
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/ComputationState.java
---
@@ -74,11 +80,35 @@ public long getStartTimestamp() {
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r106107521
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java
---
@@ -74,88 +76,233 @@
*/
@SuppressWarn
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3477#discussion_r106108553
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java
---
@@ -74,88 +76,233 @@
*/
@SuppressWarn
[
https://issues.apache.org/jira/browse/FLINK-6032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925762#comment-15925762
]
ASF GitHub Bot commented on FLINK-6032:
---
GitHub user kl0u opened a pull request:
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/3541
[FLINK-6032] [cep] Clean-up operator state when not needed.
The CEP operator now cleans the registered state for a key. This happens:
1) for the priority queue, when the queue is empty.
2) for t
[
https://issues.apache.org/jira/browse/FLINK-5985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925768#comment-15925768
]
ASF GitHub Bot commented on FLINK-5985:
---
Github user gyfora commented on the issue:
Github user gyfora commented on the issue:
https://github.com/apache/flink/pull/3523
@StefanRRichter It seems to work correctly locally, I am trying to see what
went wrong with my yarn tests, but this shouldnt block you
---
If your project is set up for it, you can reply to this emai
[
https://issues.apache.org/jira/browse/FLINK-6036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925770#comment-15925770
]
jingzhang commented on FLINK-6036:
--
[~fhueske], could I just add read partition methods t
Luke Hutchison created FLINK-6057:
-
Summary: Better default needed for num network buffers
Key: FLINK-6057
URL: https://issues.apache.org/jira/browse/FLINK-6057
Project: Flink
Issue Type: Bug
Github user gyfora commented on the issue:
https://github.com/apache/flink/pull/3523
Ah, the reason is probably that I didnt change my job jar, and this relies
on changes in the rocks backend
---
If your project is set up for it, you can reply to this email and have your
reply appear
[
https://issues.apache.org/jira/browse/FLINK-5985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925773#comment-15925773
]
ASF GitHub Bot commented on FLINK-5985:
---
Github user gyfora commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925776#comment-15925776
]
ASF GitHub Bot commented on FLINK-5985:
---
Github user StefanRRichter commented on the
Github user StefanRRichter closed the pull request at:
https://github.com/apache/flink/pull/3542
---
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
[
https://issues.apache.org/jira/browse/FLINK-5985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925781#comment-15925781
]
ASF GitHub Bot commented on FLINK-5985:
---
Github user StefanRRichter closed the pull
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/3523
Ok, then the mystery is finally solved :-) Thanks again for reporting this
problem and your additional testing efforts!
---
If your project is set up for it, you can reply to this email and h
[
https://issues.apache.org/jira/browse/FLINK-5985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925786#comment-15925786
]
ASF GitHub Bot commented on FLINK-5985:
---
GitHub user StefanRRichter opened a pull re
GitHub user StefanRRichter opened a pull request:
https://github.com/apache/flink/pull/3543
[FLINK-5985] [Backport for 1.2] Report no task states for stateless tasks
on checkpointing
This PR is a backport of #3523 to Flink 1.2.
You can merge this pull request into a Git repository
[
https://issues.apache.org/jira/browse/FLINK-5985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925789#comment-15925789
]
ASF GitHub Bot commented on FLINK-5985:
---
Github user StefanRRichter commented on the
[
https://issues.apache.org/jira/browse/FLINK-5985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925794#comment-15925794
]
ASF GitHub Bot commented on FLINK-5985:
---
Github user StefanRRichter commented on the
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/3523
Hm, one potential pitfall that I see is operator chaining, in case your
stateless operators are chained together with stateful ones. But then again,
you said it works locally?
---
If your pr
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/3523
Yes, it should still work because the changes on `RocksDBKeyedStateBackend`
are purely cosmetical without changing any functionality.
---
If your project is set up for it, you can reply to th
[
https://issues.apache.org/jira/browse/FLINK-6057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925799#comment-15925799
]
Fabian Hueske commented on FLINK-6057:
--
There's currently work going on the remove th
[
https://issues.apache.org/jira/browse/FLINK-5210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925807#comment-15925807
]
Tzu-Li (Gordon) Tai commented on FLINK-5210:
[~till.rohrmann] would this be a
[
https://issues.apache.org/jira/browse/FLINK-6055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-6055:
Component/s: DataStream API
> Supported setting timers on a Non-Keyed Stream
> -
[
https://issues.apache.org/jira/browse/FLINK-5048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925810#comment-15925810
]
Tzu-Li (Gordon) Tai commented on FLINK-5048:
[~uce] [~rmetzger] It seems like
[
https://issues.apache.org/jira/browse/FLINK-5754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925816#comment-15925816
]
shijinkui commented on FLINK-5754:
--
ping [~greghogan] where did you make the tag, on the
[
https://issues.apache.org/jira/browse/FLINK-5650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925824#comment-15925824
]
shijinkui commented on FLINK-5650:
--
Now I have to excute `mvn clean test -pl '!flink-libr
Aljoscha Krettek created FLINK-6058:
---
Summary: Don't read DEFAULT_PARALLELISM from GlobalConfiguration
Key: FLINK-6058
URL: https://issues.apache.org/jira/browse/FLINK-6058
Project: Flink
I
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/3509#discussion_r106125756
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamContextEnvironment.java
---
@@ -38,14 +38,10 @@
priva
[
https://issues.apache.org/jira/browse/FLINK-5808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925828#comment-15925828
]
ASF GitHub Bot commented on FLINK-5808:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925833#comment-15925833
]
shijinkui commented on FLINK-5650:
--
Also we can make PythonPlanStreamer support async exe
[
https://issues.apache.org/jira/browse/FLINK-5650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925833#comment-15925833
]
shijinkui edited comment on FLINK-5650 at 3/15/17 10:11 AM:
Al
Github user uce commented on the issue:
https://github.com/apache/flink/pull/3494
Thanks for this :-) It was interesting to follow your discussions @iemejia,
@jgrier and @patricklucas. I've tried this out and it works as expected. I'm
going to merge this later today if there are no ob
[
https://issues.apache.org/jira/browse/FLINK-4562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925836#comment-15925836
]
ASF GitHub Bot commented on FLINK-4562:
---
Github user shijinkui commented on the issu
Github user shijinkui commented on the issue:
https://github.com/apache/flink/pull/2460
ping @wuchong @fhueske @twalthr
---
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 a
[
https://issues.apache.org/jira/browse/FLINK-5635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925835#comment-15925835
]
ASF GitHub Bot commented on FLINK-5635:
---
Github user uce commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925838#comment-15925838
]
Aljoscha Krettek commented on FLINK-6055:
-
I think setting timers only makes sense
Fabian Hueske created FLINK-6059:
Summary: Reject DataSet and DataStream without
RowTypeInformation
Key: FLINK-6059
URL: https://issues.apache.org/jira/browse/FLINK-6059
Project: Flink
Issue
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/3544
[FLINK-6001] Fix ContinuousEventTimeTrigger firing without state
R: @kl0u
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aljoscha/flink jira-6
[
https://issues.apache.org/jira/browse/FLINK-6001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925844#comment-15925844
]
ASF GitHub Bot commented on FLINK-6001:
---
GitHub user aljoscha opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-6001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925861#comment-15925861
]
Vladislav Pernin commented on FLINK-6001:
-
Very nice, it works.
I was reluctant to
[
https://issues.apache.org/jira/browse/FLINK-5698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925872#comment-15925872
]
ramkrishna.s.vasudevan commented on FLINK-5698:
---
[~tonycox]
Are you still ac
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/3541#discussion_r106133141
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalWatermarkCallbackService.java
---
@@ -153,6 +153,7 @@ public
[
https://issues.apache.org/jira/browse/FLINK-6032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925881#comment-15925881
]
ASF GitHub Bot commented on FLINK-6032:
---
Github user dawidwys commented on a diff in
shijinkui created FLINK-6060:
Summary: not exist class referance in the scala function annotation
Key: FLINK-6060
URL: https://issues.apache.org/jira/browse/FLINK-6060
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-6032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925882#comment-15925882
]
ASF GitHub Bot commented on FLINK-6032:
---
Github user kl0u commented on a diff in the
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3541#discussion_r106133528
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalWatermarkCallbackService.java
---
@@ -153,6 +153,7 @@ public void
Vladislav Pernin created FLINK-6061:
---
Summary: NPE on TypeSerializer.serialize with a
RocksDBStateBackend calling state.entries in the open() function
Key: FLINK-6061
URL: https://issues.apache.org/jira/browse/F
[
https://issues.apache.org/jira/browse/FLINK-6061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vladislav Pernin updated FLINK-6061:
Summary: NPE on TypeSerializer.serialize with a RocksDBStateBackend calling
entries() on a k
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3484#discussion_r106139449
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java
---
@@ -387,18 +401,49 @@ public int getChainLength()
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3484#discussion_r106138062
--- Diff: flink-core/src/main/java/org/apache/flink/util/OutputTag.java ---
@@ -0,0 +1,115 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3484#discussion_r106139311
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java
---
@@ -326,33 +327,46 @@ public int getChainLength()
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3484#discussion_r106138342
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/SingleOutputStreamOperator.java
---
@@ -416,4 +428,26 @@ private boolean
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3484#discussion_r106139079
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java
---
@@ -567,6 +600,17 @@ protected bool
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3484#discussion_r106138895
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/SideOutputTransformation.java
---
@@ -0,0 +1,73 @@
+/*
+ *
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3484#discussion_r106138237
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/SingleOutputStreamOperator.java
---
@@ -416,4 +428,26 @@ private boolean
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3484#discussion_r106139530
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java
---
@@ -441,26 +486,53 @@ public void close() {
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3484#discussion_r106138473
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/SingleOutputStreamOperator.java
---
@@ -416,4 +428,26 @@ private boolean
[
https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925920#comment-15925920
]
ASF GitHub Bot commented on FLINK-4460:
---
Github user kl0u commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925924#comment-15925924
]
ASF GitHub Bot commented on FLINK-4460:
---
Github user kl0u commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925922#comment-15925922
]
ASF GitHub Bot commented on FLINK-4460:
---
Github user kl0u commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925919#comment-15925919
]
ASF GitHub Bot commented on FLINK-4460:
---
Github user kl0u commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925921#comment-15925921
]
ASF GitHub Bot commented on FLINK-4460:
---
Github user kl0u commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925917#comment-15925917
]
ASF GitHub Bot commented on FLINK-4460:
---
Github user kl0u commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925925#comment-15925925
]
ASF GitHub Bot commented on FLINK-4460:
---
Github user kl0u commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925915#comment-15925915
]
Chesnay Schepler commented on FLINK-6053:
-
This would break a public API so we can
[
https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925916#comment-15925916
]
ASF GitHub Bot commented on FLINK-4460:
---
Github user kl0u commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925923#comment-15925923
]
ASF GitHub Bot commented on FLINK-4460:
---
Github user kl0u commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925918#comment-15925918
]
ASF GitHub Bot commented on FLINK-4460:
---
Github user kl0u commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-6061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925929#comment-15925929
]
Stefan Richter commented on FLINK-6061:
---
Thanks for reporting this. I agree that the
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3486
Thanks, looks good modulo a mini issue that I can fix while merging...
---
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 proj
[
https://issues.apache.org/jira/browse/FLINK-5981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925930#comment-15925930
]
ASF GitHub Bot commented on FLINK-5981:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-5981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925931#comment-15925931
]
ASF GitHub Bot commented on FLINK-5981:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-6061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter reassigned FLINK-6061:
-
Assignee: Stefan Richter
> NPE on TypeSerializer.serialize with a RocksDBStateBackend cal
[
https://issues.apache.org/jira/browse/FLINK-6061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925929#comment-15925929
]
Stefan Richter edited comment on FLINK-6061 at 3/15/17 11:19 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-5210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-5210:
Assignee: (was: Till Rohrmann)
> Failing performCheckpoint method causes task to fail
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3484#discussion_r106139593
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java
---
@@ -441,26 +486,53 @@ public void close() {
[
https://issues.apache.org/jira/browse/FLINK-6010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-6010.
-
Resolution: Fixed
Fix Version/s: (was: 1.2.1)
1.3.0
Fixed via a87b52
1 - 100 of 535 matches
Mail list logo
