zhangjing created FLINK-4449:
Summary: Heartbeat Manager between ResourceManager and TaskExecutor
Key: FLINK-4449
URL: https://issues.apache.org/jira/browse/FLINK-4449
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432328#comment-15432328
]
ASF GitHub Bot commented on FLINK-2055:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2332
Cool. Let me know if you have any questions or if you need any help.
I'll keep an eye on this PR and the Bahir-flink repository.
---
If your project is set up for it, you can reply to this email
[
https://issues.apache.org/jira/browse/FLINK-3710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432349#comment-15432349
]
Maximilian Michels commented on FLINK-3710:
---
The JavaDoc linked on the homepage
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2342
Builds are passing here: https://travis-ci.org/uce/flink/builds/154236174
I'm going to merge this later today. Thanks for starting this renaming.
---
If your project is set up for it, you can r
[
https://issues.apache.org/jira/browse/FLINK-4253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432416#comment-15432416
]
ASF GitHub Bot commented on FLINK-4253:
---
Github user uce commented on the issue:
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2094#discussion_r75826683
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeinfo/BasicArrayTypeInfo.java
---
@@ -121,6 +122,18 @@ public boolean isKeyType() {
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432430#comment-15432430
]
ASF GitHub Bot commented on FLINK-3702:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432436#comment-15432436
]
ASF GitHub Bot commented on FLINK-3702:
---
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/2094#discussion_r75826929
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeinfo/BasicTypeInfo.java
---
@@ -171,6 +172,23 @@ public boolean isKeyType() {
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2094#discussion_r75827289
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeinfo/TypeInformation.java
---
@@ -160,6 +161,53 @@ public boolean isSortKeyType() {
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432442#comment-15432442
]
ASF GitHub Bot commented on FLINK-3702:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432439#comment-15432439
]
ASF GitHub Bot commented on FLINK-3702:
---
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/2094#discussion_r75827397
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeinfo/TypeInformation.java
---
@@ -160,6 +161,53 @@ public boolean isSortKeyType() {
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2094#discussion_r75827568
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeinfo/TypeInformation.java
---
@@ -160,6 +161,53 @@ public boolean isSortKeyType() {
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432447#comment-15432447
]
ASF GitHub Bot commented on FLINK-3702:
---
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/2094#discussion_r75828177
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/FieldAccessor.java
---
@@ -0,0 +1,295 @@
+/*
+ * Licensed to the Apache Softwa
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432455#comment-15432455
]
ASF GitHub Bot commented on FLINK-3702:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432461#comment-15432461
]
ASF GitHub Bot commented on FLINK-3702:
---
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/2094#discussion_r75828736
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/FieldAccessor.java
---
@@ -0,0 +1,295 @@
+/*
+ * Licensed to the Apache Softwa
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2094#discussion_r75828673
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/FieldAccessor.java
---
@@ -0,0 +1,295 @@
+/*
+ * Licensed to the Apache Softwa
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432464#comment-15432464
]
ASF GitHub Bot commented on FLINK-3702:
---
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/2094#discussion_r75829026
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/FieldAccessor.java
---
@@ -0,0 +1,295 @@
+/*
+ * Licensed to the Apache Softwa
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432467#comment-15432467
]
ASF GitHub Bot commented on FLINK-3702:
---
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/2094#discussion_r75830865
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/PojoTypeInfo.java
---
@@ -317,7 +308,39 @@ public int getFieldIndex(String fieldName)
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2288
Hey Cliff! I looked over this again and I think we have to address some
things:
- The problem you mentioned on the mailing list with respect to to
flattening is actually something we should not ignor
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432487#comment-15432487
]
ASF GitHub Bot commented on FLINK-3702:
---
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/2094#discussion_r75831968
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/PojoTypeInfo.java
---
@@ -317,7 +308,39 @@ public int getFieldIndex(String fieldName)
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432497#comment-15432497
]
ASF GitHub Bot commented on FLINK-3702:
---
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/2094#discussion_r75832360
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/TupleTypeInfoBase.java
---
@@ -203,7 +205,26 @@ public void getFlatFields(String field
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432502#comment-15432502
]
ASF GitHub Bot commented on FLINK-3702:
---
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/2094#discussion_r75833200
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/TupleTypeInfoBase.java
---
@@ -203,7 +205,26 @@ public void getFlatFields(String field
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432513#comment-15432513
]
ASF GitHub Bot commented on FLINK-3702:
---
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/2094#discussion_r75833983
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/TupleTypeInfoBase.java
---
@@ -203,7 +205,26 @@ public void getFlatFields(String field
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432519#comment-15432519
]
ASF GitHub Bot commented on FLINK-3702:
---
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/2094#discussion_r75834786
--- Diff:
flink-core/src/test/java/org/apache/flink/api/java/typeutils/FieldAccessorTest.java
---
@@ -0,0 +1,280 @@
+/*
+ * Licensed to the Apache So
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2094#discussion_r75834833
--- Diff:
flink-core/src/test/java/org/apache/flink/api/java/typeutils/FieldAccessorTest.java
---
@@ -0,0 +1,280 @@
+/*
+ * Licensed to the Apache So
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432535#comment-15432535
]
ASF GitHub Bot commented on FLINK-3702:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432533#comment-15432533
]
ASF GitHub Bot commented on FLINK-3702:
---
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/2094#discussion_r75835061
--- Diff:
flink-core/src/test/java/org/apache/flink/api/java/typeutils/FieldAccessorTest.java
---
@@ -0,0 +1,280 @@
+/*
+ * Licensed to the Apache So
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432539#comment-15432539
]
ASF GitHub Bot commented on FLINK-3702:
---
Github user twalthr commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2244#discussion_r75835251
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/sinks/TableSink.scala
---
@@ -41,46 +38,13 @@ trait TableSink[T] {
*
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432544#comment-15432544
]
ASF GitHub Bot commented on FLINK-3874:
---
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/2244#discussion_r75835356
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/table.scala
---
@@ -26,6 +26,8 @@ import org.apache.flink.api.table.plan.logi
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2244#discussion_r75835433
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/Kafka08JsonTableSink.java
---
@@ -0,
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432547#comment-15432547
]
ASF GitHub Bot commented on FLINK-3874:
---
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/2244#discussion_r75835537
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/Kafka08JsonTableSink.java
---
@@ -0,
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432546#comment-15432546
]
ASF GitHub Bot commented on FLINK-3874:
---
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/2244#discussion_r75835608
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/Kafka09JsonTableSink.java
---
@@ -0,
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2244#discussion_r75835662
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/Kafka09JsonTableSink.java
---
@@ -0,
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432549#comment-15432549
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432548#comment-15432548
]
ASF GitHub Bot commented on FLINK-3874:
---
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/2244#discussion_r75835821
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.8/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka08JsonTableSinkTest.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432550#comment-15432550
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user fhueske commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2094#discussion_r75835835
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/FieldAccessor.java
---
@@ -0,0 +1,295 @@
+/*
+ * Licensed to the Apache Softwa
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2244#discussion_r75835841
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka09JsonTableSinkTest.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432553#comment-15432553
]
ASF GitHub Bot commented on FLINK-3702:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432551#comment-15432551
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432552#comment-15432552
]
ASF GitHub Bot commented on FLINK-3874:
---
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/2244#discussion_r75836176
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSink.java
---
@@ -0,0 +1,
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2244#discussion_r75836302
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/JsonRowSerializationSchema.java
---
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432555#comment-15432555
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user fhueske commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2094#discussion_r75836333
--- Diff:
flink-scala/src/main/java/org/apache/flink/api/scala/typeutils/ProductFieldAccessor.java
---
@@ -0,0 +1,63 @@
+/*
+ * Licensed to the Apach
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432556#comment-15432556
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432557#comment-15432557
]
ASF GitHub Bot commented on FLINK-3702:
---
Github user twalthr commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2244#discussion_r75836644
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/JsonRowSerializationSchema.java
---
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2244#discussion_r75836733
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/JsonRowSerializationSchemaTest.java
---
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432561#comment-15432561
]
ASF GitHub Bot commented on FLINK-3874:
---
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/2244#discussion_r75836831
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSinkTestBase.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432558#comment-15432558
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432563#comment-15432563
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2244
Hi @mushketyk, thanks for the PR. Looks quite good. I added a few comments.
Cheers, Fabian
---
If your project is set up for it, you can reply to this email and have your
reply appear on G
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2094#discussion_r75837546
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/FieldAccessor.java
---
@@ -0,0 +1,295 @@
+/*
+ * Licensed to the Apache Softwa
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432566#comment-15432566
]
ASF GitHub Bot commented on FLINK-3702:
---
Github user twalthr commented on a diff in
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2244
Hi @fhueske. Thank you for your code review. I'll update the PR today.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your projec
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432569#comment-15432569
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user mushketyk commented on the issu
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2094#discussion_r75839040
--- Diff:
flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/CaseClassTypeInfo.scala
---
@@ -236,6 +237,31 @@ abstract class CaseClassTypeInfo[T
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432577#comment-15432577
]
ASF GitHub Bot commented on FLINK-3702:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432579#comment-15432579
]
Sergii Koshel commented on FLINK-4425:
--
It works with `release-1.1` branch.
> "Out O
[
https://issues.apache.org/jira/browse/FLINK-4425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432626#comment-15432626
]
Ufuk Celebi commented on FLINK-4425:
OK thanks! Will be fixed in {{1.1.2}}. Sorry abou
[
https://issues.apache.org/jira/browse/FLINK-4425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-4425.
--
Resolution: Fixed
Fix Version/s: 1.1.2
1.2.0
Fixed in 3f3bab10b9ca68eb31a7ef5a
[
https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-4329:
---
Fix Version/s: (was: 1.1.1)
> Fix Streaming File Source Timestamps/Watermarks Handling
> -
yuzhongliu created FLINK-4450:
-
Summary: update storm version to 1.0.0
Key: FLINK-4450
URL: https://issues.apache.org/jira/browse/FLINK-4450
Project: Flink
Issue Type: Improvement
Compo
[
https://issues.apache.org/jira/browse/FLINK-4439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432664#comment-15432664
]
ASF GitHub Bot commented on FLINK-4439:
---
Github user gheo21 commented on the issue:
Github user gheo21 commented on the issue:
https://github.com/apache/flink/pull/2397
@StephanEwen can you please take a look if it makes sense? there is also a
small discussion in the Jira issue about it. Thanks!
---
If your project is set up for it, you can reply to this email and h
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2389#discussion_r75851298
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/resourcemanager/ResourceManager.java
---
@@ -52,18 +61,45 @@
public class Resour
[
https://issues.apache.org/jira/browse/FLINK-4348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432684#comment-15432684
]
ASF GitHub Bot commented on FLINK-4348:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-4348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432682#comment-15432682
]
ASF GitHub Bot commented on FLINK-4348:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2389#discussion_r75851341
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/resourcemanager/ResourceManager.java
---
@@ -52,18 +61,45 @@
public class Resour
[
https://issues.apache.org/jira/browse/FLINK-4440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432718#comment-15432718
]
Greg Hogan commented on FLINK-4440:
---
Yes, I stand corrected.
When would these new metho
[
https://issues.apache.org/jira/browse/FLINK-4396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-4396:
--
Issue Type: Improvement (was: Wish)
> GraphiteReporter class not found at startup of jobmanager
> -
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2400#discussion_r75860606
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/taskexecutor/TaskExecutor.java
---
@@ -35,27 +79,634 @@
*/
public class TaskExecuto
[
https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432743#comment-15432743
]
ASF GitHub Bot commented on FLINK-4363:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-4426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-4426.
-
Resolution: Resolved
Glad you were able to solve the problem. Thank you for letting us kno
[
https://issues.apache.org/jira/browse/FLINK-4396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432746#comment-15432746
]
Greg Hogan commented on FLINK-4396:
---
I've relabeled this as an Improvement because we sh
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2275
>The RollingFileSink error might be due to
https://issues.apache.org/jira/browse/HDFS-9213. The secure MiniDFS cluster
requires privileged ports to be used and we need to enable the java process to
gran
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432757#comment-15432757
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user mxm commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432788#comment-15432788
]
Chesnay Schepler commented on FLINK-4396:
-
We don't require users to track down an
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2314
Great, I'll take your changes to open a PR now.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this fea
[
https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432792#comment-15432792
]
ASF GitHub Bot commented on FLINK-3298:
---
Github user rmetzger commented on the issue
1 - 100 of 338 matches
Mail list logo
