[
https://issues.apache.org/jira/browse/FLINK-7822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241854#comment-16241854
]
ASF GitHub Bot commented on FLINK-7822:
---
Github user aljoscha commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241856#comment-16241856
]
ASF GitHub Bot commented on FLINK-7822:
---
Github user aljoscha commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241852#comment-16241852
]
ASF GitHub Bot commented on FLINK-7822:
---
Github user aljoscha commented on a diff in the pull
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/4966#discussion_r149337397
--- Diff: docs/dev/stream/state/queryable_state.md ---
@@ -32,38 +32,67 @@ under the License.
likely that there will be breaking API changes on the
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/4966#discussion_r149337715
--- Diff: docs/dev/stream/state/queryable_state.md ---
@@ -32,38 +32,67 @@ under the License.
likely that there will be breaking API changes on the
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/4966#discussion_r149337260
--- Diff: docs/dev/stream/state/queryable_state.md ---
@@ -32,38 +32,67 @@ under the License.
likely that there will be breaking API changes on the
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/4966#discussion_r149337820
--- Diff: docs/dev/stream/state/queryable_state.md ---
@@ -32,38 +32,67 @@ under the License.
likely that there will be breaking API changes on the
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/4966#discussion_r149337649
--- Diff: docs/dev/stream/state/queryable_state.md ---
@@ -32,38 +32,67 @@ under the License.
likely that there will be breaking API changes on the
[
https://issues.apache.org/jira/browse/FLINK-7822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241834#comment-16241834
]
ASF GitHub Bot commented on FLINK-7822:
---
GitHub user kl0u opened a pull request:
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/4966
[FLINK-7822][FLINK-7823] Adds documentation and fixes configuration of QS.
## What is the purpose of the change
*This PR adds documentation for the new queryable state.
R @aljoscha
Alejandro created FLINK-8006:
-
Summary: flink-daemon.sh: line 103: binary operator expected
Key: FLINK-8006
URL: https://issues.apache.org/jira/browse/FLINK-8006
Project: Flink
Issue Type: Bug
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4964
---
[
https://issues.apache.org/jira/browse/FLINK-8004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241815#comment-16241815
]
ASF GitHub Bot commented on FLINK-8004:
---
GitHub user zentol opened a pull request:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/4965
[FLINK-8004][metrics][docs] Fix usage examples
## What is the purpose of the change
This PR fixes several issues in the metric usage examples in the
documentation.
## Brief change
[
https://issues.apache.org/jira/browse/FLINK-8005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-8005:
Fix Version/s: 1.4.0
> Snapshotting FlinkKafkaProducer011 fails due to ClassLoader issues
>
[
https://issues.apache.org/jira/browse/FLINK-8005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-8005:
Description:
*Problem Description*
Classes in the user code jar cannot be loaded by the snapshot thread’s
[
https://issues.apache.org/jira/browse/FLINK-7419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241812#comment-16241812
]
ASF GitHub Bot commented on FLINK-7419:
---
Github user zjureel closed the pull request at:
Github user zjureel closed the pull request at:
https://github.com/apache/flink/pull/4524
---
[
https://issues.apache.org/jira/browse/FLINK-8004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8004:
Description:
Hi, we have been stumbled about some documentation inconsistencies in how to
[
https://issues.apache.org/jira/browse/FLINK-8004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241798#comment-16241798
]
Chesnay Schepler edited comment on FLINK-8004 at 11/7/17 10:33 AM:
---
Andreas Hecke created FLINK-8004:
Summary: Sample code in Debugging & Monitoring Metrics
documentation section is not valid java
Key: FLINK-8004
URL: https://issues.apache.org/jira/browse/FLINK-8004
[
https://issues.apache.org/jira/browse/FLINK-7978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241799#comment-16241799
]
ASF GitHub Bot commented on FLINK-7978:
---
Github user aljoscha commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241798#comment-16241798
]
Chesnay Schepler commented on FLINK-8004:
-
Could you add the SO link? Both your links point to the
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/4955#discussion_r149326628
--- Diff:
flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/TransactionalIdsGenerator.java
---
Gary Yao created FLINK-8005:
---
Summary: Snapshotting FlinkKafkaProducer011 fails due to
ClassLoader issues
Key: FLINK-8005
URL: https://issues.apache.org/jira/browse/FLINK-8005
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-8004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-8004:
---
Assignee: Chesnay Schepler
> Sample code in Debugging & Monitoring Metrics
[
https://issues.apache.org/jira/browse/FLINK-7773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241788#comment-16241788
]
ASF GitHub Bot commented on FLINK-7773:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4957
+1
---
[
https://issues.apache.org/jira/browse/FLINK-8000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241794#comment-16241794
]
ASF GitHub Bot commented on FLINK-8000:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4958#discussion_r149325305
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestServerEndpoint.java
---
@@ -268,4 +287,69 @@ private static void
[
https://issues.apache.org/jira/browse/FLINK-7985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler resolved FLINK-7985.
-
Resolution: Not A Problem
Fix Version/s: (was: 1.5.0)
> Update
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4955#discussion_r149322930
--- Diff:
flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/TransactionalIdsGenerator.java
---
[
https://issues.apache.org/jira/browse/FLINK-7998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241787#comment-16241787
]
Chesnay Schepler commented on FLINK-7998:
-
Could you expand a bit more under which circumstances
Github user Aitozi commented on the issue:
https://github.com/apache/flink/pull/4960
ð
---
[
https://issues.apache.org/jira/browse/FLINK-7978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241783#comment-16241783
]
ASF GitHub Bot commented on FLINK-7978:
---
Github user pnowojski commented on a diff in the pull
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/4960
Crazy realization is that there are 91 pom.xml files in Flink.
Its a large project :-)
---
[
https://issues.apache.org/jira/browse/FLINK-7996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241767#comment-16241767
]
Fabian Hueske commented on FLINK-7996:
--
Yes, {{left.time = right.time + C}} should be supported as
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/4960
:yellow_heart:
Very nice!
---
[
https://issues.apache.org/jira/browse/FLINK-7265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-7265:
---
Fix Version/s: (was: 1.4.0)
1.5.0
> FileSystems should describe their kind and
[
https://issues.apache.org/jira/browse/FLINK-7883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241762#comment-16241762
]
Antoine Philippot commented on FLINK-7883:
--
Hi [~aljoscha], is there any news about this subject,
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/4955#discussion_r149316761
--- Diff:
flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/internal/TransactionalIdsGeneratorTest.java
---
[
https://issues.apache.org/jira/browse/FLINK-7978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241760#comment-16241760
]
ASF GitHub Bot commented on FLINK-7978:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241735#comment-16241735
]
ASF GitHub Bot commented on FLINK-7978:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/4955#discussion_r149312052
--- Diff:
flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/internal/TransactionalIdsGeneratorTest.java
[
https://issues.apache.org/jira/browse/FLINK-7878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241752#comment-16241752
]
ASF GitHub Bot commented on FLINK-7878:
---
Github user shuai-xu commented on the issue:
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/4955#discussion_r149315581
--- Diff:
flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/internal/TransactionalIdsGeneratorTest.java
[
https://issues.apache.org/jira/browse/FLINK-7978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241751#comment-16241751
]
ASF GitHub Bot commented on FLINK-7978:
---
Github user tzulitai commented on a diff in the pull
Github user shuai-xu commented on the issue:
https://github.com/apache/flink/pull/4911
@tillrohrmann, There is not a generic way for both Yarn and Mesos, as their
resource allocation interface are different. I think the YARN/MESOS resource
manager should handle it in their own way.
[
https://issues.apache.org/jira/browse/FLINK-7978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241749#comment-16241749
]
ASF GitHub Bot commented on FLINK-7978:
---
Github user pnowojski commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241748#comment-16241748
]
ASF GitHub Bot commented on FLINK-7978:
---
Github user GJL commented on a diff in the pull request:
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4955#discussion_r149315173
--- Diff:
flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/internal/TransactionalIdsGeneratorTest.java
[
https://issues.apache.org/jira/browse/FLINK-6022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241747#comment-16241747
]
Stephan Ewen commented on FLINK-6022:
-
I think this should be resolved, because Generic records and
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/4955#discussion_r149315106
--- Diff:
flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/TransactionalIdsGenerator.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-7978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241736#comment-16241736
]
ASF GitHub Bot commented on FLINK-7978:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/4955#discussion_r149310451
--- Diff:
flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/TransactionalIdsGenerator.java
---
[
https://issues.apache.org/jira/browse/FLINK-7996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241732#comment-16241732
]
Xingcan Cui commented on FLINK-7996:
Hi [~fhueske], thanks for opening this. IMO, the conditions like
[
https://issues.apache.org/jira/browse/FLINK-6022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241726#comment-16241726
]
Aljoscha Krettek commented on FLINK-6022:
-
[~StephanEwen] We should probably open a follow-up
Github user aljoscha closed the pull request at:
https://github.com/apache/flink/pull/4960
---
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4729#discussion_r149307271
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnWorkerNode.java ---
@@ -0,0 +1,47 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-7076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241718#comment-16241718
]
ASF GitHub Bot commented on FLINK-7076:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/4911
How do you pass the resource specification in a generic way to Yarn and
Mesos? Is there some kind of interface defined for that?
---
[
https://issues.apache.org/jira/browse/FLINK-7878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241715#comment-16241715
]
ASF GitHub Bot commented on FLINK-7878:
---
Github user tillrohrmann commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241710#comment-16241710
]
ASF GitHub Bot commented on FLINK-7856:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241708#comment-16241708
]
ASF GitHub Bot commented on FLINK-7856:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241707#comment-16241707
]
ASF GitHub Bot commented on FLINK-7856:
---
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/4893#discussion_r149305236
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexBackPressureInfo.java
---
@@ -0,0 +1,133 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-5633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241701#comment-16241701
]
Erik van Oosten commented on FLINK-5633:
[~StephanEwen] We need to process 130K msg/s, I guess
[
https://issues.apache.org/jira/browse/FLINK-7856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241702#comment-16241702
]
ASF GitHub Bot commented on FLINK-7856:
---
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/4893#discussion_r149305184
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexBackPressureInfo.java
---
@@ -0,0 +1,133 @@
+/*
+ *
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4893#discussion_r149305450
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobVertexBackPressureHandler.java
---
@@ -0,0 +1,134 @@
+/*
+
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4893#discussion_r149305096
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexBackPressureInfo.java
---
@@ -0,0 +1,133 @@
+/*
+ *
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4893#discussion_r149305060
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexBackPressureInfo.java
---
@@ -0,0 +1,133 @@
+/*
+ *
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4893#discussion_r149305275
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexBackPressureInfo.java
---
@@ -0,0 +1,133 @@
+/*
+ *
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4893#discussion_r149304998
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexBackPressureInfo.java
---
@@ -0,0 +1,133 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-7856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241700#comment-16241700
]
ASF GitHub Bot commented on FLINK-7856:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241705#comment-16241705
]
ASF GitHub Bot commented on FLINK-7856:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241703#comment-16241703
]
ASF GitHub Bot commented on FLINK-7856:
---
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/4893#discussion_r149304880
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexBackPressureInfo.java
---
@@ -0,0 +1,133 @@
+/*
+ *
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/4893
I think the plan sounds good @zjureel. We should however not do it in this
PR. Thus, I would suggest that we create a `JobVertexBackPressureHandler` which
directly inherits from
[
https://issues.apache.org/jira/browse/FLINK-7856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241698#comment-16241698
]
ASF GitHub Bot commented on FLINK-7856:
---
Github user tillrohrmann commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241699#comment-16241699
]
ASF GitHub Bot commented on FLINK-7856:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241696#comment-16241696
]
ASF GitHub Bot commented on FLINK-7076:
---
Github user suez1224 commented on a diff in the pull
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4729#discussion_r149304158
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnWorkerNode.java ---
@@ -0,0 +1,47 @@
+/*
+ * Licensed to the Apache Software
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/4949
Hi, @tillrohrmann Could you please have a rough look at this ? I'm not sure
this is you wanted.
---
[
https://issues.apache.org/jira/browse/FLINK-7866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241691#comment-16241691
]
ASF GitHub Bot commented on FLINK-7866:
---
Github user sihuazhou commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/4960
+1
---
Github user Aitozi commented on the issue:
https://github.com/apache/flink/pull/4935
Hi @tzulitai , could you take look at this again :-) ?
---
[
https://issues.apache.org/jira/browse/FLINK-7652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241669#comment-16241669
]
ASF GitHub Bot commented on FLINK-7652:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/4734
@tillrohrmann yes, reusing `DispatcherGateway#requestJobDetails` was an
option that did occur to me but was also not sure of the redundant cost. But
sure, we can avoid adding yet another RPC for
201 - 289 of 289 matches
Mail list logo
