Github user zentol commented on the issue:
https://github.com/apache/flink/pull/6211
@lamber-ken If you are referring to the added test, it covers the case of 2
jobs (`TaskManager>>Job<
[
https://issues.apache.org/jira/browse/FLINK-9665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-9665:
---
Assignee: Jelmer Kuperus (was: Chesnay Schepler)
> PrometheusReporter does not prop
[
https://issues.apache.org/jira/browse/FLINK-9674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524924#comment-16524924
]
ASF GitHub Bot commented on FLINK-9674:
---
GitHub user zentol opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-9674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9674:
--
Labels: pull-request-available (was: )
> Remove 65s sleep in QueryableState E2E test
> ---
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/6216
[FLINK-9674][tests] Replace hard-coded sleeps in QS E2E test
## What is the purpose of the change
This PR replaces a hard-coded sleep in a QueryableState end-to-end test.
The test was sleep
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6208#discussion_r198453459
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/LocationPreferenceSchedulingStrategy.java
---
@@ -0,0 +1,119 @@
[
https://issues.apache.org/jira/browse/FLINK-9634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524908#comment-16524908
]
ASF GitHub Bot commented on FLINK-9634:
---
Github user StefanRRichter commented on a
[
https://issues.apache.org/jira/browse/FLINK-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524873#comment-16524873
]
zhijiang commented on FLINK-9676:
-
[~NicoK], I think this is a bug in credit-based mode.
[
https://issues.apache.org/jira/browse/FLINK-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-9676:
Description:
It may cause deadlock between task canceler thread and task thread.
The detail is as follows:
[
https://issues.apache.org/jira/browse/FLINK-9662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524871#comment-16524871
]
James Z.M. Gao commented on FLINK-9662:
---
[~till.rohrmann]
In a tagged scheduling s
[
https://issues.apache.org/jira/browse/FLINK-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-9676:
Description:
It may cause deadlock between task canceler thread and task thread.
The detail is as follows:
[
https://issues.apache.org/jira/browse/FLINK-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-9676:
Description:
It may cause deadlock between task canceler thread and task thread.
The detail is as follows:
[
https://issues.apache.org/jira/browse/FLINK-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-9676:
Description:
It may cause deadlock between task canceler thread and task thread.
The detail is as follows:
[
https://issues.apache.org/jira/browse/FLINK-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-9676:
Description:
It may cause deadlock between task canceler thread and task thread.
The detail is as follows:
[
https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524864#comment-16524864
]
ASF GitHub Bot commented on FLINK-9514:
---
Github user azagrebin commented on a diff
Github user azagrebin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6186#discussion_r198439894
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/AbstractTtlDecorator.java
---
@@ -0,0 +1,99 @@
+/*
+ * Licensed to the Ap
[
https://issues.apache.org/jira/browse/FLINK-9674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-9674:
---
Assignee: Chesnay Schepler
> Remove 65s sleep in QueryableState E2E test
> -
[
https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524863#comment-16524863
]
ASF GitHub Bot commented on FLINK-9514:
---
Github user azagrebin commented on a diff
Github user azagrebin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6186#discussion_r198439148
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlStateVisibility.java
---
@@ -0,0 +1,29 @@
+/*
+ * Licensed to the Apac
[
https://issues.apache.org/jira/browse/FLINK-9675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524850#comment-16524850
]
zhangminglei edited comment on FLINK-9675 at 6/27/18 10:09 AM:
[
https://issues.apache.org/jira/browse/FLINK-9643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9643:
-
Affects Version/s: (was: 1.6.0)
(was: 1.4.2)
[
https://issues.apache.org/jira/browse/FLINK-9643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524861#comment-16524861
]
Till Rohrmann commented on FLINK-9643:
--
I did not test it and assumed that it would
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6215#discussion_r198437450
--- Diff:
flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka010ITCase.java
---
@@ -168,8 +168,
[
https://issues.apache.org/jira/browse/FLINK-9675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524850#comment-16524850
]
Chesnay Schepler edited comment on FLINK-9675 at 6/27/18 10:01 AM:
[
https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524855#comment-16524855
]
ASF GitHub Bot commented on FLINK-9514:
---
Github user azagrebin commented on a diff
Github user azagrebin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6186#discussion_r198436490
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlUpdateType.java
---
@@ -0,0 +1,31 @@
+/*
+ * Licensed to the Apache So
[
https://issues.apache.org/jira/browse/FLINK-9662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524851#comment-16524851
]
Till Rohrmann commented on FLINK-9662:
--
Thanks for drafting the design document [~li
[
https://issues.apache.org/jira/browse/FLINK-9675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524850#comment-16524850
]
zhangminglei commented on FLINK-9675:
-
+1,
There have been similar problems in hdfs
[
https://issues.apache.org/jira/browse/FLINK-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-9676:
Description:
It may cause deadlock between task canceler thread and task thread.
The detail is as follows:
[
https://issues.apache.org/jira/browse/FLINK-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-9676:
Description:
It may cause deadlock between task canceler thread and task thread.
The detail is as follows:
[
https://issues.apache.org/jira/browse/FLINK-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-9676:
Description:
It may cause deadlock between task canceler thread and task thread.
The detail is as follows:
[
https://issues.apache.org/jira/browse/FLINK-9662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9662:
-
Fix Version/s: (was: 1.5.1)
1.6.0
> Task manager isolation for jobs
>
[
https://issues.apache.org/jira/browse/FLINK-9675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei reassigned FLINK-9675:
---
Assignee: zhangminglei
> Avoid FileInputStream/FileOutputStream
> --
[
https://issues.apache.org/jira/browse/FLINK-9662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9662:
-
Affects Version/s: 1.6.0
> Task manager isolation for jobs
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524835#comment-16524835
]
ASF GitHub Bot commented on FLINK-9514:
---
Github user azagrebin commented on a diff
Github user azagrebin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6186#discussion_r198431042
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/AbstractTtlDecorator.java
---
@@ -0,0 +1,99 @@
+/*
+ * Licensed to the Ap
[
https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524834#comment-16524834
]
ASF GitHub Bot commented on FLINK-9514:
---
Github user azagrebin commented on a diff
zhijiang created FLINK-9676:
---
Summary: Deadlock during canceling task and recycling exclusive
buffer
Key: FLINK-9676
URL: https://issues.apache.org/jira/browse/FLINK-9676
Project: Flink
Issue Type
Github user azagrebin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6186#discussion_r198430741
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlConfig.java
---
@@ -0,0 +1,66 @@
+/*
+ * Licensed to the Apache Softwa
Ted Yu created FLINK-9675:
-
Summary: Avoid FileInputStream/FileOutputStream
Key: FLINK-9675
URL: https://issues.apache.org/jira/browse/FLINK-9675
Project: Flink
Issue Type: Improvement
Re
[
https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524830#comment-16524830
]
ASF GitHub Bot commented on FLINK-8863:
---
Github user twalthr commented on a diff in
GitHub user pnowojski opened a pull request:
https://github.com/apache/flink/pull/6215
[FLINK-9217][kafka-tests] Disable testTimestamps for Kafka 0.10
This test was deadlocking someimtes and for some reasons it appears not
failing in Kafka 0.11.
Disabling it for now, since this
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6090#discussion_r198430280
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/PrimitiveTypeValidator.scala
---
@@ -0,0 +1,72 @@
+/*
+ * Li
[
https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524829#comment-16524829
]
ASF GitHub Bot commented on FLINK-8863:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6090#discussion_r198429917
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/PrimitiveTypeDescriptor.scala
---
@@ -0,0 +1,56 @@
+/*
+ * L
[
https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524827#comment-16524827
]
ASF GitHub Bot commented on FLINK-8863:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6090#discussion_r198428514
--- Diff:
flink-libraries/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/utils/UserDefinedFunctions.java
---
@@ -0,0 +1,105 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524822#comment-16524822
]
ASF GitHub Bot commented on FLINK-8863:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524823#comment-16524823
]
ASF GitHub Bot commented on FLINK-9666:
---
Github user lamber-ken commented on the is
Chesnay Schepler created FLINK-9674:
---
Summary: Remove 65s sleep in QueryableState E2E test
Key: FLINK-9674
URL: https://issues.apache.org/jira/browse/FLINK-9674
Project: Flink
Issue Type: I
Github user lamber-ken commented on the issue:
https://github.com/apache/flink/pull/6212
hi, @StephanEwen, cc, thx
---
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6090#discussion_r198427940
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/ExecutionContext.java
---
@@ -187,6 +206,7 @@ private s
[
https://issues.apache.org/jira/browse/FLINK-9565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524814#comment-16524814
]
Fabian Hueske commented on FLINK-9565:
--
I agree, we should follow a consistent style
[
https://issues.apache.org/jira/browse/FLINK-9665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524816#comment-16524816
]
ASF GitHub Bot commented on FLINK-9665:
---
Github user lamber-ken commented on the is
Github user lamber-ken commented on the issue:
https://github.com/apache/flink/pull/6211
Hi, @jelmerk, I have a question that when will there be two taskmanager
registered in the same registry?
---
[
https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524813#comment-16524813
]
ASF GitHub Bot commented on FLINK-8863:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6090#discussion_r198426083
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/UDFDescriptor.java
---
@@ -0,0 +1,153 @@
+/*
+ * Licen
[
https://issues.apache.org/jira/browse/FLINK-9673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-9673:
-
Description:
Currently, the implementations of bounded OVER window aggregations store the
comple
Fabian Hueske created FLINK-9673:
Summary: Improve State efficiency of bounded OVER window operators
Key: FLINK-9673
URL: https://issues.apache.org/jira/browse/FLINK-9673
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524805#comment-16524805
]
ASF GitHub Bot commented on FLINK-8863:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6090#discussion_r198424133
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/UDFDescriptor.java
---
@@ -0,0 +1,153 @@
+/*
+ * Licen
[
https://issues.apache.org/jira/browse/FLINK-9565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524798#comment-16524798
]
Timo Walther commented on FLINK-9565:
-
We don't need a new eval function for it. I wo
[
https://issues.apache.org/jira/browse/FLINK-9634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524799#comment-16524799
]
ASF GitHub Bot commented on FLINK-9634:
---
Github user tillrohrmann commented on the
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/6208
Thanks for the review @StefanRRichter and @sihuazhou. I've addressed your
comments. Merging this PR once Travis gives green light.
---
[
https://issues.apache.org/jira/browse/FLINK-9634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524797#comment-16524797
]
ASF GitHub Bot commented on FLINK-9634:
---
Github user tillrohrmann commented on a di
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6208#discussion_r198421923
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SchedulingStrategy.java
---
@@ -0,0 +1,60 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-9634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524796#comment-16524796
]
ASF GitHub Bot commented on FLINK-9634:
---
Github user tillrohrmann commented on a di
[
https://issues.apache.org/jira/browse/FLINK-9669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9669:
--
Labels: pull-request-available (was: )
> Introduce task manager assignment store
> ---
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6208#discussion_r198421635
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/LocationPreferenceSchedulingStrategy.java
---
@@ -0,0 +1,119 @@
+
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6208#discussion_r198421680
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/PreviousAllocationSchedulingStrategy.java
---
@@ -0,0 +1,85 @@
+/
[
https://issues.apache.org/jira/browse/FLINK-9634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524795#comment-16524795
]
ASF GitHub Bot commented on FLINK-9634:
---
Github user tillrohrmann commented on a di
[
https://issues.apache.org/jira/browse/FLINK-9669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524794#comment-16524794
]
ASF GitHub Bot commented on FLINK-9669:
---
GitHub user liurenjie1024 opened a pull re
GitHub user liurenjie1024 opened a pull request:
https://github.com/apache/flink/pull/6214
[FLINK-9669] Add assignment store interface.
## What is the purpose of the change
This pull requests is part of process to enable task manager isolation in
flink 1.5 session mode.
[
https://issues.apache.org/jira/browse/FLINK-9634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524790#comment-16524790
]
ASF GitHub Bot commented on FLINK-9634:
---
Github user tillrohrmann commented on a di
[
https://issues.apache.org/jira/browse/FLINK-9634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524791#comment-16524791
]
ASF GitHub Bot commented on FLINK-9634:
---
Github user tillrohrmann commented on a di
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6208#discussion_r198421252
--- Diff: flink-tests/src/test/resources/log4j-test.properties ---
@@ -18,7 +18,7 @@
# Set root logger level to OFF to not flood build logs
[
https://issues.apache.org/jira/browse/FLINK-9634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524789#comment-16524789
]
ASF GitHub Bot commented on FLINK-9634:
---
Github user tillrohrmann commented on a di
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6208#discussion_r198421151
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/DefaultSlotPoolFactory.java
---
@@ -75,10 +82,21 @@ public static Def
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6208#discussion_r198420806
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -280,12 +281,7 @@ public JobMaster(
[
https://issues.apache.org/jira/browse/FLINK-9672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524786#comment-16524786
]
ASF GitHub Bot commented on FLINK-9672:
---
GitHub user tillrohrmann opened a pull req
[
https://issues.apache.org/jira/browse/FLINK-9672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9672:
--
Labels: pull-request-available (was: )
> Fail fatally if we cannot submit job on added JobGrap
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/6213
[FLINK-9672] Fail fatally if job submission fails on added JobGraph signal
## What is the purpose of the change
Fail fatally if we cannot recover the job on the `onAddedJobGraph` signal
[
https://issues.apache.org/jira/browse/FLINK-9667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524773#comment-16524773
]
Chesnay Schepler commented on FLINK-9667:
-
The core issue here is to aggregate th
[
https://issues.apache.org/jira/browse/FLINK-9645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-9645.
Resolution: Later
> DispatcherTest.testSubmittedJobGraphListener fails on Travis
>
[
https://issues.apache.org/jira/browse/FLINK-9645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reopened FLINK-9645:
--
> DispatcherTest.testSubmittedJobGraphListener fails on Travis
> --
[
https://issues.apache.org/jira/browse/FLINK-9645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524770#comment-16524770
]
Till Rohrmann commented on FLINK-9645:
--
I think the problem is that {{submitJob}} fa
[
https://issues.apache.org/jira/browse/FLINK-9645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-9645.
Resolution: Later
> DispatcherTest.testSubmittedJobGraphListener fails on Travis
>
[
https://issues.apache.org/jira/browse/FLINK-9645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9645:
-
Fix Version/s: (was: 1.6.0)
> DispatcherTest.testSubmittedJobGraphListener fails on Travis
>
Till Rohrmann created FLINK-9672:
Summary: Fail fatally if we cannot submit job on added JobGraph
signal
Key: FLINK-9672
URL: https://issues.apache.org/jira/browse/FLINK-9672
Project: Flink
Renjie Liu created FLINK-9671:
-
Summary: Add configuration to enable task manager isolation.
Key: FLINK-9671
URL: https://issues.apache.org/jira/browse/FLINK-9671
Project: Flink
Issue Type: New F
[
https://issues.apache.org/jira/browse/FLINK-9645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-9645:
Assignee: Till Rohrmann
> DispatcherTest.testSubmittedJobGraphListener fails on Travis
> -
Renjie Liu created FLINK-9670:
-
Summary: Introduce slot manager factory
Key: FLINK-9670
URL: https://issues.apache.org/jira/browse/FLINK-9670
Project: Flink
Issue Type: New Feature
Comp
Renjie Liu created FLINK-9669:
-
Summary: Introduce task manager assignment store
Key: FLINK-9669
URL: https://issues.apache.org/jira/browse/FLINK-9669
Project: Flink
Issue Type: New Feature
GitHub user lamber-ken opened a pull request:
https://github.com/apache/flink/pull/6212
[FLINK-9666] short-circuit logic should be used in boolean contexts
## What is the purpose of the change
- short-circuit logic should be used in boolean contexts, | -> ||, & -> &&
#
[
https://issues.apache.org/jira/browse/FLINK-9666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9666:
--
Labels: pull-request-available (was: )
> short-circuit logic should be used in boolean context
[
https://issues.apache.org/jira/browse/FLINK-9666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524752#comment-16524752
]
ASF GitHub Bot commented on FLINK-9666:
---
GitHub user lamber-ken opened a pull reque
[
https://issues.apache.org/jira/browse/FLINK-9668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
qi quan updated FLINK-9668:
---
Description:
For example, I would like to achieve a statistical window of one day, and I
want to output the
qi quan created FLINK-9668:
--
Summary: In some case Trigger.onProcessingTime don't exectue
Key: FLINK-9668
URL: https://issues.apache.org/jira/browse/FLINK-9668
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-6962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524748#comment-16524748
]
Fabian Hueske commented on FLINK-6962:
--
Hi,
[~suez1224] and [~walterddr] are workin
[
https://issues.apache.org/jira/browse/FLINK-9667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-9667:
Component/s: Table API & SQL
> Scala docs are only generated for flink-scala
>
101 - 200 of 205 matches
Mail list logo
