[
https://issues.apache.org/jira/browse/FLINK-6846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520954#comment-16520954
]
ASF GitHub Bot commented on FLINK-6846:
---
Github user hequn8128 commented on the iss
Github user hequn8128 commented on the issue:
https://github.com/apache/flink/pull/6188
@xueyumusic Great that you step out to contribute to flink, I will take a
look this weekend :-)
---
[
https://issues.apache.org/jira/browse/FLINK-9648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-9648:
---
Assignee: vinoyang
> Do not store distributed cache entries in ExecutionConfig
> ---
[
https://issues.apache.org/jira/browse/FLINK-9649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520739#comment-16520739
]
Leonid Ishimnikov edited comment on FLINK-9649 at 6/22/18 8:05 PM:
[
https://issues.apache.org/jira/browse/FLINK-9649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520739#comment-16520739
]
Leonid Ishimnikov commented on FLINK-9649:
--
After submitting a job, the framewor
[
https://issues.apache.org/jira/browse/FLINK-9649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520689#comment-16520689
]
Chesnay Schepler commented on FLINK-9649:
-
What happens when you submit a job?
>
Leonid Ishimnikov created FLINK-9649:
Summary: TaskManagers are not scheduled on Mesos
Key: FLINK-9649
URL: https://issues.apache.org/jira/browse/FLINK-9649
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520577#comment-16520577
]
ASF GitHub Bot commented on FLINK-9514:
---
Github user StefanRRichter commented on a
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6186#discussion_r197503773
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlAggregatingState.java
---
@@ -0,0 +1,80 @@
+/*
+ * Licensed to th
[
https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520570#comment-16520570
]
ASF GitHub Bot commented on FLINK-9514:
---
Github user StefanRRichter commented on a
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6186#discussion_r197502165
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlFoldFunction.java
---
@@ -0,0 +1,43 @@
+/*
+ * Licensed to the Ap
[
https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520566#comment-16520566
]
ASF GitHub Bot commented on FLINK-9514:
---
Github user StefanRRichter commented on a
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6186#discussion_r197501902
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlFoldFunction.java
---
@@ -0,0 +1,43 @@
+/*
+ * Licensed to the Ap
[
https://issues.apache.org/jira/browse/FLINK-9513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520552#comment-16520552
]
ASF GitHub Bot commented on FLINK-9513:
---
Github user azagrebin commented on a diff
Github user azagrebin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6196#discussion_r197498439
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlStateFactory.java
---
@@ -0,0 +1,207 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520549#comment-16520549
]
ASF GitHub Bot commented on FLINK-9514:
---
Github user StefanRRichter commented on a
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6186#discussion_r197498126
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlMapState.java
---
@@ -0,0 +1,132 @@
+/*
+ * Licensed to the Apach
Chesnay Schepler created FLINK-9648:
---
Summary: Do not store distributed cache entries in ExecutionConfig
Key: FLINK-9648
URL: https://issues.apache.org/jira/browse/FLINK-9648
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520543#comment-16520543
]
ASF GitHub Bot commented on FLINK-9624:
---
Github user zentol commented on a diff in
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6199#discussion_r197496529
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobGraph.java ---
@@ -552,96 +550,33 @@ public boolean hasUsercodeJarFiles() {
[
https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520540#comment-16520540
]
ASF GitHub Bot commented on FLINK-9514:
---
Github user StefanRRichter commented on a
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6186#discussion_r197494851
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlMapState.java
---
@@ -0,0 +1,132 @@
+/*
+ * Licensed to the Apach
[
https://issues.apache.org/jira/browse/FLINK-9280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520539#comment-16520539
]
ASF GitHub Bot commented on FLINK-9280:
---
Github user zentol commented on a diff in
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6203#discussion_r197493894
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobSubmitHandler.java
---
@@ -54,18 +69,89 @@ public JobSubmitHandler(
Chesnay Schepler created FLINK-9647:
---
Summary: Files uploaded to blobservice during job submission
aren't rmeoved on failure
Key: FLINK-9647
URL: https://issues.apache.org/jira/browse/FLINK-9647
Pro
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520538#comment-16520538
]
ASF GitHub Bot commented on FLINK-8983:
---
Github user medcv commented on a diff in t
Github user medcv commented on a diff in the pull request:
https://github.com/apache/flink/pull/6083#discussion_r197493383
--- Diff: flink-end-to-end-tests/flink-confluent-schema-registry/pom.xml ---
@@ -0,0 +1,155 @@
+
+http://maven.apache.org/POM/4.0.0";
+x
[
https://issues.apache.org/jira/browse/FLINK-9280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520535#comment-16520535
]
ASF GitHub Bot commented on FLINK-9280:
---
Github user zentol commented on a diff in
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6203#discussion_r197492045
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobSubmitHandler.java
---
@@ -54,18 +69,89 @@ public JobSubmitHandler(
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520532#comment-16520532
]
ASF GitHub Bot commented on FLINK-8983:
---
Github user tillrohrmann commented on a di
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520531#comment-16520531
]
ASF GitHub Bot commented on FLINK-8983:
---
Github user tillrohrmann commented on a di
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520529#comment-16520529
]
ASF GitHub Bot commented on FLINK-8983:
---
Github user tillrohrmann commented on a di
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520530#comment-16520530
]
ASF GitHub Bot commented on FLINK-8983:
---
Github user tillrohrmann commented on a di
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6083#discussion_r197490677
--- Diff:
flink-end-to-end-tests/test-scripts/test-confluent-schema-registry.sh ---
@@ -0,0 +1,106 @@
+#!/usr/bin/env bash
+###
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6083#discussion_r197490378
--- Diff: flink-end-to-end-tests/flink-confluent-schema-registry/pom.xml ---
@@ -0,0 +1,155 @@
+
+http://maven.apache.org/POM/4.0.0";
+
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6083#discussion_r197490130
--- Diff: flink-end-to-end-tests/flink-confluent-schema-registry/pom.xml ---
@@ -0,0 +1,228 @@
+
+http://maven.apache.org/POM/4.0.0";
+
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6083#discussion_r197490461
--- Diff: flink-end-to-end-tests/flink-confluent-schema-registry/pom.xml ---
@@ -0,0 +1,155 @@
+
+http://maven.apache.org/POM/4.0.0";
+
[
https://issues.apache.org/jira/browse/FLINK-9493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-9493.
Resolution: Fixed
Fixed via
1.6.0: 537281323adcbcf71cddfd824c56677e66c718ff
1.5.1: 022704a79ffb9ad3
[
https://issues.apache.org/jira/browse/FLINK-9646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-9646.
Resolution: Fixed
Fixed via
1.6.0: 8561f4cce47bda416d7c09071ea18515ab2c75e1
1.5.1: 20830527bf35f67a
[
https://issues.apache.org/jira/browse/FLINK-9646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9646:
-
Fix Version/s: 1.5.1
> ExecutionGraphCoLocationRestartTest.testConstraintsAfterRestart
>
[
https://issues.apache.org/jira/browse/FLINK-9493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520518#comment-16520518
]
ASF GitHub Bot commented on FLINK-9493:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-9646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9646:
-
Affects Version/s: 1.5.0
> ExecutionGraphCoLocationRestartTest.testConstraintsAfterRestart
>
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6202
---
[
https://issues.apache.org/jira/browse/FLINK-9280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520513#comment-16520513
]
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/6199#discussion_r197487498
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobGraph.java ---
@@ -552,96 +550,33 @@ public boolean hasUsercodeJarFiles() {
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6203#discussion_r197487718
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobSubmitHandler.java
---
@@ -54,18 +69,89 @@ public JobSubmitHandler(
[
https://issues.apache.org/jira/browse/FLINK-9624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520512#comment-16520512
]
ASF GitHub Bot commented on FLINK-9624:
---
Github user tillrohrmann commented on a di
[
https://issues.apache.org/jira/browse/FLINK-9646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-9646:
Assignee: Till Rohrmann
> ExecutionGraphCoLocationRestartTest.testConstraintsAfterRestart
[
https://issues.apache.org/jira/browse/FLINK-9588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520499#comment-16520499
]
ASF GitHub Bot commented on FLINK-9588:
---
Github user Aitozi commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520498#comment-16520498
]
ASF GitHub Bot commented on FLINK-9514:
---
Github user StefanRRichter commented on a
Github user Aitozi commented on a diff in the pull request:
https://github.com/apache/flink/pull/6168#discussion_r197482701
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -609,7 +611,7 @@ public void close() throws Exception {
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6186#discussion_r197482482
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/AbstractTtlDecorator.java
---
@@ -0,0 +1,99 @@
+/*
+ * Licensed to t
[
https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520492#comment-16520492
]
ASF GitHub Bot commented on FLINK-9514:
---
Github user StefanRRichter commented on a
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6186#discussion_r197480035
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/AbstractTtlDecorator.java
---
@@ -0,0 +1,99 @@
+/*
+ * Licensed to t
[
https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520486#comment-16520486
]
ASF GitHub Bot commented on FLINK-9514:
---
Github user StefanRRichter commented on a
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6186#discussion_r197477831
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlStateVisibility.java
---
@@ -0,0 +1,29 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-9280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520484#comment-16520484
]
ASF GitHub Bot commented on FLINK-9280:
---
Github user zentol commented on a diff in
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6203#discussion_r197477484
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobSubmitHandler.java
---
@@ -54,18 +69,89 @@ public JobSubmitHandler(
[
https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520477#comment-16520477
]
ASF GitHub Bot commented on FLINK-9514:
---
Github user StefanRRichter commented on a
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6186#discussion_r197476858
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlStateVisibility.java
---
@@ -0,0 +1,29 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520478#comment-16520478
]
ASF GitHub Bot commented on FLINK-9514:
---
Github user StefanRRichter commented on a
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6186#discussion_r197476710
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlStateVisibility.java
---
@@ -0,0 +1,29 @@
+/*
+ * Licensed to the
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6186#discussion_r197475873
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlUpdateType.java
---
@@ -0,0 +1,31 @@
+/*
+ * Licensed to the Apac
[
https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520474#comment-16520474
]
ASF GitHub Bot commented on FLINK-9514:
---
Github user StefanRRichter commented on a
[
https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520469#comment-16520469
]
ASF GitHub Bot commented on FLINK-9514:
---
Github user StefanRRichter commented on a
[
https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520471#comment-16520471
]
ASF GitHub Bot commented on FLINK-9514:
---
Github user StefanRRichter commented on a
[
https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520470#comment-16520470
]
ASF GitHub Bot commented on FLINK-9514:
---
Github user StefanRRichter commented on a
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6186#discussion_r197475080
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlUpdateType.java
---
@@ -0,0 +1,31 @@
+/*
+ * Licensed to the Apac
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6186#discussion_r197475154
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlStateVisibility.java
---
@@ -0,0 +1,29 @@
+/*
+ * Licensed to the
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6186#discussion_r197475245
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlTimeCharacteristic.java
---
@@ -0,0 +1,27 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520464#comment-16520464
]
ASF GitHub Bot commented on FLINK-9514:
---
Github user StefanRRichter commented on a
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6186#discussion_r197474567
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlConfig.java
---
@@ -0,0 +1,66 @@
+/*
+ * Licensed to the Apache S
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6199#discussion_r197472732
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobGraph.java ---
@@ -552,96 +550,33 @@ public boolean hasUsercodeJarFiles() {
[
https://issues.apache.org/jira/browse/FLINK-9624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520454#comment-16520454
]
ASF GitHub Bot commented on FLINK-9624:
---
Github user zentol commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520442#comment-16520442
]
ASF GitHub Bot commented on FLINK-9624:
---
Github user zentol commented on a diff in
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6199#discussion_r197467939
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/client/ClientUtilsTest.java
---
@@ -0,0 +1,138 @@
+/*
+ * Licensed to the Apache Softw
[
https://issues.apache.org/jira/browse/FLINK-8255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520422#comment-16520422
]
ASF GitHub Bot commented on FLINK-8255:
---
Github user snuyanzin commented on the iss
[
https://issues.apache.org/jira/browse/FLINK-8255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-8255:
--
Labels: pull-request-available (was: )
> Key expressions on named row types do not work
>
Github user snuyanzin commented on the issue:
https://github.com/apache/flink/pull/5961
commits squashed into one
---
[
https://issues.apache.org/jira/browse/FLINK-9588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9588:
--
Labels: pull-request-available (was: )
> Reuse the same conditionContext with in a same comput
[
https://issues.apache.org/jira/browse/FLINK-9280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520412#comment-16520412
]
ASF GitHub Bot commented on FLINK-9280:
---
Github user tillrohrmann commented on a di
[
https://issues.apache.org/jira/browse/FLINK-9588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520411#comment-16520411
]
ASF GitHub Bot commented on FLINK-9588:
---
Github user dawidwys commented on a diff i
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/6168#discussion_r197461704
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -609,7 +611,7 @@ public void close() throws Exception {
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6203#discussion_r197461746
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobSubmitHandler.java
---
@@ -54,18 +69,89 @@ public JobSubmitHandler(
[
https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520409#comment-16520409
]
ASF GitHub Bot commented on FLINK-9514:
---
Github user StefanRRichter commented on a
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6186#discussion_r197460522
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/AbstractTtlDecorator.java
---
@@ -0,0 +1,99 @@
+/*
+ * Licensed to t
[
https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520406#comment-16520406
]
ASF GitHub Bot commented on FLINK-9514:
---
Github user StefanRRichter commented on a
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/6163
Thanks for the PR @kisimple
+1 to merge.
Best, Fabian
---
[
https://issues.apache.org/jira/browse/FLINK-9524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520404#comment-16520404
]
ASF GitHub Bot commented on FLINK-9524:
---
Github user fhueske commented on a diff in
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6186#discussion_r197459764
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/AbstractTtlDecorator.java
---
@@ -0,0 +1,99 @@
+/*
+ * Licensed to t
[
https://issues.apache.org/jira/browse/FLINK-9524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9524:
--
Labels: pull-request-available (was: )
> NPE from ProcTimeBoundedRangeOver.scala
> ---
[
https://issues.apache.org/jira/browse/FLINK-9524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520405#comment-16520405
]
ASF GitHub Bot commented on FLINK-9524:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/6180#discussion_r197453235
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeBoundedRangeOver.scala
---
@@ -132,74 +132,80 @@ class
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/6180#discussion_r197453796
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeBoundedRangeOver.scala
---
@@ -132,74 +132,80 @@ class
[
https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520401#comment-16520401
]
ASF GitHub Bot commented on FLINK-9514:
---
Github user StefanRRichter commented on a
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6186#discussion_r197458219
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/AbstractTtlDecorator.java
---
@@ -0,0 +1,99 @@
+/*
+ * Licensed to t
Till Rohrmann created FLINK-9646:
Summary:
ExecutionGraphCoLocationRestartTest.testConstraintsAfterRestart
Key: FLINK-9646
URL: https://issues.apache.org/jira/browse/FLINK-9646
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520397#comment-16520397
]
ASF GitHub Bot commented on FLINK-9514:
---
Github user StefanRRichter commented on a
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6186#discussion_r197457017
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/AbstractTtlDecorator.java
---
@@ -0,0 +1,99 @@
+/*
+ * Licensed to t
[
https://issues.apache.org/jira/browse/FLINK-9280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9280:
--
Labels: pull-request-available (was: )
> Extend JobSubmitHandler to accept jar files
> ---
1 - 100 of 231 matches
Mail list logo
