[
https://issues.apache.org/jira/browse/FLINK-9640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16527141#comment-16527141
]
Hai Zhou commented on FLINK-9640:
-
CC [~StephanEwen], what do you think about this ticket?
>
[
https://issues.apache.org/jira/browse/FLINK-9091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-9091:
--
Comment: was deleted
(was: What should be the next step ?
Thanks)
> Failure while enforcing releasability in
[
https://issues.apache.org/jira/browse/FLINK-9236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-9236:
--
Description:
Flink is still using Apache Parent POM 18. Apache Parent POM 19 is out.
This will also fix
[
https://issues.apache.org/jira/browse/FLINK-9393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu resolved FLINK-9393.
---
Resolution: Later
> LocatableInputSplit#hashCode should take hostnames into account
>
[
https://issues.apache.org/jira/browse/FLINK-9363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-9363:
--
Labels: security (was: )
> Bump up the Jackson version
> ---
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-7588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16258309#comment-16258309
]
Ted Yu edited comment on FLINK-7588 at 6/29/18 2:56 AM:
bq. Be careful about
Github user xueyumusic commented on a diff in the pull request:
https://github.com/apache/flink/pull/6188#discussion_r199040249
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/scala/expressionDsl.scala
---
@@ -1029,6 +1029,29 @@ object
[
https://issues.apache.org/jira/browse/FLINK-6846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16527093#comment-16527093
]
ASF GitHub Bot commented on FLINK-6846:
---
Github user xueyumusic commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16527083#comment-16527083
]
ASF GitHub Bot commented on FLINK-9666:
---
Github user lamber-ken commented on the issue:
Github user lamber-ken commented on the issue:
https://github.com/apache/flink/pull/6212
hi, @tillrohrmann , what does this mean?
I don't understand, need I delete the branch?
[
https://issues.apache.org/jira/browse/FLINK-9567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16527046#comment-16527046
]
ASF GitHub Bot commented on FLINK-9567:
---
Github user Clark commented on a diff in the pull
Github user Clark commented on a diff in the pull request:
https://github.com/apache/flink/pull/6192#discussion_r199036840
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java ---
@@ -334,8 +335,11 @@ public void onContainersCompleted(final
List
[
https://issues.apache.org/jira/browse/FLINK-9567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16527034#comment-16527034
]
ASF GitHub Bot commented on FLINK-9567:
---
Github user Clark commented on a diff in the pull
Github user Clark commented on a diff in the pull request:
https://github.com/apache/flink/pull/6192#discussion_r199035271
--- Diff:
flink-yarn/src/test/java/org/apache/flink/yarn/YarnResourceManagerTest.java ---
@@ -421,4 +425,139 @@ public void testDeleteApplicationFiles()
[
https://issues.apache.org/jira/browse/FLINK-9567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16527033#comment-16527033
]
ASF GitHub Bot commented on FLINK-9567:
---
Github user Clark commented on a diff in the pull
Github user Clark commented on a diff in the pull request:
https://github.com/apache/flink/pull/6192#discussion_r199035236
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
---
@@ -1120,5 +1120,28 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-9456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16527026#comment-16527026
]
ASF GitHub Bot commented on FLINK-9456:
---
Github user sihuazhou commented on the issue:
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/6132
@tillrohrmann Thanks for your review and good suggestions, changing the
code according to it.
---
[
https://issues.apache.org/jira/browse/FLINK-9687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526910#comment-16526910
]
ASF GitHub Bot commented on FLINK-9687:
---
Github user Aitozi commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9687:
--
Labels: pull-request-available (was: )
> Delay the state fetch only when the triggerResult is
Github user Aitozi commented on the issue:
https://github.com/apache/flink/pull/6224
The failed info in travis error shows the test with `checkClusterEmpty` is
wrong, Is this happened due to the reuse of yarn cluster? It seems unrelated
with this pull request.
---
Lakshmi Rao created FLINK-9691:
--
Summary: Modify run loop in Kinesis ShardConsumer to not sleep for
a fixed fetchIntervalMillis
Key: FLINK-9691
URL: https://issues.apache.org/jira/browse/FLINK-9691
[
https://issues.apache.org/jira/browse/FLINK-9690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526709#comment-16526709
]
Piotr Nowojski commented on FLINK-9690:
---
Yep, it looks so. Once I was trying to upgrade our
[
https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526671#comment-16526671
]
ASF GitHub Bot commented on FLINK-9514:
---
Github user azagrebin commented on a diff in the pull
Github user azagrebin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6186#discussion_r198947650
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlFoldFunction.java
---
@@ -0,0 +1,43 @@
+/*
+ * Licensed to the Apache
Ufuk Celebi created FLINK-9690:
--
Summary: Restoring state with FlinkKafkaProducer and Kafka 1.1.0
client fails
Key: FLINK-9690
URL: https://issues.apache.org/jira/browse/FLINK-9690
Project: Flink
Github user snuyanzin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6226#discussion_r198928207
--- Diff: docs/dev/table/sql.md ---
@@ -115,6 +115,10 @@ The following BNF-grammar describes the superset of
supported SQL features in ba
{%
[
https://issues.apache.org/jira/browse/FLINK-8650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526602#comment-16526602
]
ASF GitHub Bot commented on FLINK-8650:
---
Github user snuyanzin commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526601#comment-16526601
]
ASF GitHub Bot commented on FLINK-8650:
---
Github user snuyanzin commented on a diff in the pull
Github user snuyanzin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6226#discussion_r198928117
--- Diff: docs/dev/table/sql.md ---
@@ -139,7 +143,8 @@ select:
[ WHERE booleanExpression ]
[ GROUP BY { groupItem [, groupItem ]* } ]
[
https://issues.apache.org/jira/browse/FLINK-8650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-8650:
--
Labels: pull-request-available (was: )
> Add tests and documentation for WINDOW clause
>
[
https://issues.apache.org/jira/browse/FLINK-8650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526597#comment-16526597
]
ASF GitHub Bot commented on FLINK-8650:
---
GitHub user snuyanzin opened a pull request:
GitHub user snuyanzin opened a pull request:
https://github.com/apache/flink/pull/6226
[FLINK-8650] Tests for WINDOW clause and documentation update
*Thank you very much for contributing to Apache Flink - we are happy that
you want to help us improve Flink. To help the community
[
https://issues.apache.org/jira/browse/FLINK-9567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526563#comment-16526563
]
ASF GitHub Bot commented on FLINK-9567:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526564#comment-16526564
]
ASF GitHub Bot commented on FLINK-9567:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526565#comment-16526565
]
ASF GitHub Bot commented on FLINK-9567:
---
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/6192#discussion_r198914433
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
---
@@ -1120,5 +1120,28 @@ public void
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6192#discussion_r198915014
--- Diff:
flink-yarn/src/test/java/org/apache/flink/yarn/YarnResourceManagerTest.java ---
@@ -421,4 +425,139 @@ public void
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6192#discussion_r198917467
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java ---
@@ -334,8 +335,11 @@ public void onContainersCompleted(final
[
https://issues.apache.org/jira/browse/FLINK-9456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526534#comment-16526534
]
ASF GitHub Bot commented on FLINK-9456:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9456:
--
Labels: pull-request-available (was: )
> Let ResourceManager notify JobManager about
[
https://issues.apache.org/jira/browse/FLINK-9456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526541#comment-16526541
]
ASF GitHub Bot commented on FLINK-9456:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526537#comment-16526537
]
ASF GitHub Bot commented on FLINK-9456:
---
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/6132#discussion_r198910651
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/ResourceActions.java
---
@@ -53,4 +56,13 @@
*
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6132#discussion_r198491021
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMasterGateway.java
---
@@ -278,4 +279,13 @@ void heartbeatFromTaskManager(
[
https://issues.apache.org/jira/browse/FLINK-9456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526540#comment-16526540
]
ASF GitHub Bot commented on FLINK-9456:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9456:
--
Labels: pull-request-available (was: )
> Let ResourceManager notify JobManager about
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6132#discussion_r198490490
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -984,6 +985,15 @@ private void
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6132#discussion_r198491683
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
---
@@ -1120,5 +1131,14 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-9456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526535#comment-16526535
]
ASF GitHub Bot commented on FLINK-9456:
---
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/6132#discussion_r198493145
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManagerTest.java
---
@@ -1202,6 +1209,111 @@ public
[
https://issues.apache.org/jira/browse/FLINK-9456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526538#comment-16526538
]
ASF GitHub Bot commented on FLINK-9456:
---
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/6132#discussion_r198912464
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManager.java
---
@@ -717,6 +728,32 @@ private void
[
https://issues.apache.org/jira/browse/FLINK-9456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526536#comment-16526536
]
ASF GitHub Bot commented on FLINK-9456:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526542#comment-16526542
]
ASF GitHub Bot commented on FLINK-9456:
---
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/6132#discussion_r198491884
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/ResourceActions.java
---
@@ -53,4 +56,13 @@
*
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6132#discussion_r198490029
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/TaskManagerSlot.java
---
@@ -45,6 +46,9 @@
/**
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6132#discussion_r198489897
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManager.java
---
@@ -619,7 +619,11 @@ public void
Satheesh created FLINK-9689:
---
Summary: Flink consumer deserialization example
Key: FLINK-9689
URL: https://issues.apache.org/jira/browse/FLINK-9689
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-9456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526533#comment-16526533
]
ASF GitHub Bot commented on FLINK-9456:
---
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/6132#discussion_r198491333
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMasterGateway.java
---
@@ -278,4 +279,13 @@ void heartbeatFromTaskManager(
[
https://issues.apache.org/jira/browse/FLINK-9456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526539#comment-16526539
]
ASF GitHub Bot commented on FLINK-9456:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526528#comment-16526528
]
ASF GitHub Bot commented on FLINK-9672:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/6213#discussion_r198912529
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
---
@@ -322,9 +322,6 @@ private JobManagerRunner
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6083
---
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526502#comment-16526502
]
ASF GitHub Bot commented on FLINK-8983:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-8983.
Resolution: Fixed
Fix Version/s: 1.6.0
Added via
a36b56999240d1ead0793be7acb4ad13cd0559f2
[
https://issues.apache.org/jira/browse/FLINK-8745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8745:
Affects Version/s: (was: 1.5.0)
(was: 1.4.0)
[
https://issues.apache.org/jira/browse/FLINK-9687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526454#comment-16526454
]
Hequn Cheng commented on FLINK-9687:
Good catch. When isFire=false, there is no need to get contents
[
https://issues.apache.org/jira/browse/FLINK-9684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526449#comment-16526449
]
Ethan Li commented on FLINK-9684:
-
PR: https://github.com/apache/flink/pull/6225
>
[
https://issues.apache.org/jira/browse/FLINK-9687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526330#comment-16526330
]
aitozi commented on FLINK-9687:
---
Hi, [~kkl0u]
I have added my thought/description on this issue, can you
[
https://issues.apache.org/jira/browse/FLINK-9687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
aitozi updated FLINK-9687:
--
Description: When the window operator is fired by the event timer or
processing timer, it fetch the state
[
https://issues.apache.org/jira/browse/FLINK-9687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526286#comment-16526286
]
Kostas Kloudas commented on FLINK-9687:
---
Hi [~aitozi].
Can you provide a description here on what
[
https://issues.apache.org/jira/browse/FLINK-9662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526247#comment-16526247
]
Renjie Liu commented on FLINK-9662:
---
Would it be better if we reuse the existing job id field in
[
https://issues.apache.org/jira/browse/FLINK-9666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-9666.
--
Resolution: Fixed
Fixed via da37daa8ba387435abf6a3bc5629ce7d21a6b017
> short-circuit logic
[
https://issues.apache.org/jira/browse/FLINK-9666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-9666:
Assignee: lamber-ken
> short-circuit logic should be used in boolean contexts
>
[
https://issues.apache.org/jira/browse/FLINK-9662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526224#comment-16526224
]
Till Rohrmann commented on FLINK-9662:
--
I think you can still solve the problem of task manager
[
https://issues.apache.org/jira/browse/FLINK-9624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-9624.
---
Resolution: Fixed
master: dd4c8469b11184b633d2b9514b9910622734270f
> Move jar/artifact
[
https://issues.apache.org/jira/browse/FLINK-9688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526175#comment-16526175
]
Fabian Hueske commented on FLINK-9688:
--
We aim of course for a large set of built-in function.
So
[
https://issues.apache.org/jira/browse/FLINK-9688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526166#comment-16526166
]
Sergey Nuyanzin commented on FLINK-9688:
ok I see, thank you for clarification
> ATAN2 Sql
[
https://issues.apache.org/jira/browse/FLINK-9688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526161#comment-16526161
]
Fabian Hueske commented on FLINK-9688:
--
This is issue requests a new feature. The {{ATAN2}} is not
[
https://issues.apache.org/jira/browse/FLINK-9688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-9688:
-
Issue Type: New Feature (was: Bug)
> ATAN2 Sql Function support
> --
>
[
https://issues.apache.org/jira/browse/FLINK-9688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-9688:
---
Issue Type: Bug (was: New Feature)
> ATAN2 Sql Function support
>
[
https://issues.apache.org/jira/browse/FLINK-9688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-9688:
-
Priority: Minor (was: Major)
> ATAN2 Sql Function support
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-9688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-9688:
-
Issue Type: New Feature (was: Bug)
> ATAN2 Sql Function support
> --
>
[
https://issues.apache.org/jira/browse/FLINK-9682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-9682:
---
Assignee: vinoyang
> Add setDescription to execution environment and display it in the UI
>
[
https://issues.apache.org/jira/browse/FLINK-9688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-9688:
---
Description:
simple query fails {code}
ExecutionEnvironment env =
Sergey Nuyanzin created FLINK-9688:
--
Summary: ATAN2 Sql Function support
Key: FLINK-9688
URL: https://issues.apache.org/jira/browse/FLINK-9688
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-9580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-9580.
---
Resolution: Fixed
Fix Version/s: 1.5.1
1.6.0
master:
[
https://issues.apache.org/jira/browse/FLINK-9629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-9629.
---
Resolution: Fixed
Fix Version/s: 1.5.1
1.6.0
master:
[
https://issues.apache.org/jira/browse/FLINK-9629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-9629:
Affects Version/s: (was: 1.5.1)
> Datadog metrics reporter does not have shaded
[
https://issues.apache.org/jira/browse/FLINK-9580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-9580:
Affects Version/s: 1.6.0
1.5.0
> Potentially unclosed
[
https://issues.apache.org/jira/browse/FLINK-8785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-8785:
--
Labels: flip-6 pull-request-available (was: flip-6)
> JobSubmitHandler does not handle
[
https://issues.apache.org/jira/browse/FLINK-8785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526130#comment-16526130
]
ASF GitHub Bot commented on FLINK-8785:
---
GitHub user zentol opened a pull request:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/6222
[FLINK-8785][rest] Handle JobSubmissionExceptions
## What is the purpose of the change
This PR modifies the `JobSubmitHandler` to handle exceptions contained in
the future returned by
[
https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526115#comment-16526115
]
ASF GitHub Bot commented on FLINK-9514:
---
Github user azagrebin commented on a diff in the pull
Github user azagrebin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6186#discussion_r198757244
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlFoldFunction.java
---
@@ -0,0 +1,43 @@
+/*
+ * Licensed to the Apache
aitozi created FLINK-9687:
-
Summary: Delay the state fetch only when the triggerResult is fire
Key: FLINK-9687
URL: https://issues.apache.org/jira/browse/FLINK-9687
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526096#comment-16526096
]
ASF GitHub Bot commented on FLINK-9514:
---
Github user azagrebin commented on a diff in the pull
Github user azagrebin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6186#discussion_r198751723
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlMapState.java
---
@@ -0,0 +1,132 @@
+/*
+ * Licensed to the Apache
1 - 100 of 120 matches
Mail list logo
