Github user fpompermaier commented on a diff in the pull request:
https://github.com/apache/flink/pull/1989#discussion_r67295348
--- Diff:
flink-libraries/flink-table/src/test/java/org/apache/flink/api/java/io/RowCsvInputFormatTest.java
---
@@ -0,0 +1,1075 @@
+/*
+ * Licen
[
https://issues.apache.org/jira/browse/FLINK-3901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333241#comment-15333241
]
ASF GitHub Bot commented on FLINK-3901:
---
Github user fpompermaier commented on a dif
Github user fpompermaier commented on a diff in the pull request:
https://github.com/apache/flink/pull/1989#discussion_r67295515
--- Diff:
flink-libraries/flink-table/src/main/java/org/apache/flink/api/java/io/RowCsvInputFormat.java
---
@@ -0,0 +1,152 @@
+/*
+ * Licensed t
Github user fpompermaier commented on a diff in the pull request:
https://github.com/apache/flink/pull/1989#discussion_r67295498
--- Diff:
flink-libraries/flink-table/src/main/java/org/apache/flink/api/java/io/RowCsvInputFormat.java
---
@@ -0,0 +1,152 @@
+/*
+ * Licensed t
[
https://issues.apache.org/jira/browse/FLINK-3901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333244#comment-15333244
]
ASF GitHub Bot commented on FLINK-3901:
---
Github user fpompermaier commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-3901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333246#comment-15333246
]
ASF GitHub Bot commented on FLINK-3901:
---
Github user fpompermaier commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-4027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantin Knauf updated FLINK-4027:
Priority: Major (was: Critical)
> FlinkKafkaProducer09 sink can lose messages
> ---
[
https://issues.apache.org/jira/browse/FLINK-4027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantin Knauf updated FLINK-4027:
Priority: Critical (was: Major)
> FlinkKafkaProducer09 sink can lose messages
> ---
Github user fpompermaier commented on a diff in the pull request:
https://github.com/apache/flink/pull/1989#discussion_r67295853
--- Diff:
flink-libraries/flink-table/src/main/java/org/apache/flink/api/java/io/RowCsvInputFormat.java
---
@@ -0,0 +1,152 @@
+/*
+ * Licensed t
[
https://issues.apache.org/jira/browse/FLINK-3901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333253#comment-15333253
]
ASF GitHub Bot commented on FLINK-3901:
---
Github user fpompermaier commented on a dif
Github user fpompermaier commented on a diff in the pull request:
https://github.com/apache/flink/pull/1989#discussion_r67296019
--- Diff:
flink-libraries/flink-table/src/main/java/org/apache/flink/api/java/io/RowCsvInputFormat.java
---
@@ -0,0 +1,152 @@
+/*
+ * Licensed t
[
https://issues.apache.org/jira/browse/FLINK-3901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333255#comment-15333255
]
ASF GitHub Bot commented on FLINK-3901:
---
Github user fpompermaier commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-4027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333260#comment-15333260
]
ASF GitHub Bot commented on FLINK-4027:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2108#discussion_r67296678
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerBase.java
---
@@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1856#discussion_r67297138
--- Diff:
flink-scala/src/test/scala/org/apache/flink/api/operator/MaxByOperatorTest.scala
---
@@ -0,0 +1,176 @@
+/*
+ * Licensed to the Apache Softw
[
https://issues.apache.org/jira/browse/FLINK-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333266#comment-15333266
]
ASF GitHub Bot commented on FLINK-3650:
---
Github user fhueske commented on a diff in
Github user ramkrish86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/1856#discussion_r67297990
--- Diff:
flink-scala/src/test/scala/org/apache/flink/api/operator/MaxByOperatorTest.scala
---
@@ -0,0 +1,176 @@
+/*
+ * Licensed to the Apache So
[
https://issues.apache.org/jira/browse/FLINK-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333278#comment-15333278
]
ASF GitHub Bot commented on FLINK-3650:
---
Github user ramkrish86 commented on a diff
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1989#discussion_r67298280
--- Diff:
flink-libraries/flink-table/src/main/java/org/apache/flink/api/java/io/RowCsvInputFormat.java
---
@@ -0,0 +1,152 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-3901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333284#comment-15333284
]
ASF GitHub Bot commented on FLINK-3901:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333290#comment-15333290
]
ASF GitHub Bot commented on FLINK-3901:
---
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/1989#discussion_r67299243
--- Diff:
flink-libraries/flink-table/src/test/java/org/apache/flink/api/java/io/RowCsvInputFormatTest.java
---
@@ -0,0 +1,1075 @@
+/*
+ * Licensed t
Github user fpompermaier commented on a diff in the pull request:
https://github.com/apache/flink/pull/1989#discussion_r67299396
--- Diff:
flink-libraries/flink-table/src/test/java/org/apache/flink/api/java/io/RowCsvInputFormatTest.java
---
@@ -0,0 +1,1075 @@
+/*
+ * Licen
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1989#discussion_r67299477
--- Diff:
flink-libraries/flink-table/src/main/java/org/apache/flink/api/java/io/RowCsvInputFormat.java
---
@@ -0,0 +1,152 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-3901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333292#comment-15333292
]
ASF GitHub Bot commented on FLINK-3901:
---
Github user fpompermaier commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-3901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333293#comment-15333293
]
ASF GitHub Bot commented on FLINK-3901:
---
Github user fhueske commented on a diff in
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2100
---
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 feature
enabled and wishes so, or if the feature is enab
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2007
---
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 feature
enabled and wishes so, or if the feature is enab
[
https://issues.apache.org/jira/browse/FLINK-4024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333298#comment-15333298
]
ASF GitHub Bot commented on FLINK-4024:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-3908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333299#comment-15333299
]
ASF GitHub Bot commented on FLINK-3908:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske resolved FLINK-4024.
--
Resolution: Fixed
Fixed with fe0eb602d2e908d116d71018bb141e5c748c780b
> FileSourceFunction not
[
https://issues.apache.org/jira/browse/FLINK-3908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-3908.
Resolution: Fixed
Fix Version/s: 1.1.0
Fixed with d8747978386c0aacce1dc2631e1c5602ec9b2a00
>
GitHub user mushketyk opened a pull request:
https://github.com/apache/flink/pull/2109
[FLINK-3677] FileInputFormat: Allow to specify include/exclude file name
patterns
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list
[
https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1507#comment-1507
]
ASF GitHub Bot commented on FLINK-3677:
---
GitHub user mushketyk opened a pull request
[
https://issues.apache.org/jira/browse/FLINK-4053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1523#comment-1523
]
Ivan Mushketyk commented on FLINK-4053:
---
I'll fix this.
> Return value from Connect
[
https://issues.apache.org/jira/browse/FLINK-4053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ivan Mushketyk reassigned FLINK-4053:
-
Assignee: Ivan Mushketyk
> Return value from Connection should be checked against null
>
[
https://issues.apache.org/jira/browse/FLINK-3943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1526#comment-1526
]
Ivan Mushketyk commented on FLINK-3943:
---
I'll work on this.
> Add support for EXCEP
[
https://issues.apache.org/jira/browse/FLINK-3943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ivan Mushketyk reassigned FLINK-3943:
-
Assignee: Ivan Mushketyk
> Add support for EXCEPT (set minus)
> -
[
https://issues.apache.org/jira/browse/FLINK-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1586#comment-1586
]
ASF GitHub Bot commented on FLINK-3650:
---
Github user ramkrish86 commented on the iss
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/1856
Force pushed as per your advice @fhueske. Ran mvn clean verify and there
are no warnings generated.
---
If your project is set up for it, you can reply to this email and have your
reply appear on
[
https://issues.apache.org/jira/browse/FLINK-3344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333416#comment-15333416
]
Till Rohrmann commented on FLINK-3344:
--
Another instance, but this time the error was
[
https://issues.apache.org/jira/browse/FLINK-3974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333422#comment-15333422
]
ASF GitHub Bot commented on FLINK-3974:
---
GitHub user aljoscha opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333420#comment-15333420
]
Till Rohrmann commented on FLINK-4075:
--
Another instance:
https://s3.amazonaws.com/a
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/2110
[FLINK-3974] Fix object reuse with multi-chaining
Before, a job would fail if object reuse was enabled and multiple
operators were chained to one upstream operator. Now, we always create a
s
[
https://issues.apache.org/jira/browse/FLINK-3813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333424#comment-15333424
]
Till Rohrmann commented on FLINK-3813:
--
Another instance:
https://s3.amazonaws.com/a
[
https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333425#comment-15333425
]
Till Rohrmann commented on FLINK-2392:
--
More instances of failing yarn tests:
https:
GitHub user f7753 opened a pull request:
https://github.com/apache/flink/pull/2111
[FLINK-4076] BoltWrapper#dispose() should call
AbstractStreamOperator#dispose()
Add missing method `super.close()` that should be called in sub class
`org.apache.flink.storm.wrappers.BoltWrapper` 's
[
https://issues.apache.org/jira/browse/FLINK-4076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333432#comment-15333432
]
ASF GitHub Bot commented on FLINK-4076:
---
GitHub user f7753 opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333437#comment-15333437
]
Maximilian Michels commented on FLINK-2392:
---
The logs fail because the following
[
https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333437#comment-15333437
]
Maximilian Michels edited comment on FLINK-2392 at 6/16/16 9:26 AM:
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2093#discussion_r67313976
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java
---
@@ -132,9 +132,9 @@
[
https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333442#comment-15333442
]
Maximilian Michels commented on FLINK-2392:
---
Should be fixed the resolution of F
[
https://issues.apache.org/jira/browse/FLINK-3962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333440#comment-15333440
]
Maximilian Michels commented on FLINK-3962:
---
Another exception from the Yarn log
[
https://issues.apache.org/jira/browse/FLINK-3714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333441#comment-15333441
]
ASF GitHub Bot commented on FLINK-3714:
---
Github user aljoscha commented on a diff in
Github user fpompermaier commented on a diff in the pull request:
https://github.com/apache/flink/pull/1989#discussion_r67314234
--- Diff:
flink-libraries/flink-table/src/test/java/org/apache/flink/api/java/io/RowCsvInputFormatTest.java
---
@@ -0,0 +1,1075 @@
+/*
+ * Licen
Flavio Pompermaier created FLINK-4081:
-
Summary: FieldParsers should support empty strings
Key: FLINK-4081
URL: https://issues.apache.org/jira/browse/FLINK-4081
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-3901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333444#comment-15333444
]
ASF GitHub Bot commented on FLINK-3901:
---
Github user fpompermaier commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-3962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333458#comment-15333458
]
Chesnay Schepler commented on FLINK-3962:
-
that new exception makes no sense at al
[
https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333456#comment-15333456
]
Chesnay Schepler commented on FLINK-2392:
-
except it is entirely unrelated to metr
[
https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333461#comment-15333461
]
Maximilian Michels commented on FLINK-2392:
---
What do you mean? The issue is unre
[
https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333477#comment-15333477
]
Chesnay Schepler commented on FLINK-2392:
-
the exception is unrelated, that's why
[
https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333483#comment-15333483
]
Chesnay Schepler commented on FLINK-2392:
-
are these jobs from different profiles?
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2111
This looks good, let's see what Travis says.
---
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 feature
[
https://issues.apache.org/jira/browse/FLINK-4076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333487#comment-15333487
]
ASF GitHub Bot commented on FLINK-4076:
---
Github user zentol commented on the issue:
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2108
Thank you for the review @eliaslevy!
---
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 feature
enable
[
https://issues.apache.org/jira/browse/FLINK-4027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333492#comment-15333492
]
ASF GitHub Bot commented on FLINK-4027:
---
Github user rmetzger commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-4027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333498#comment-15333498
]
ASF GitHub Bot commented on FLINK-4027:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-4027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333497#comment-15333497
]
ASF GitHub Bot commented on FLINK-4027:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2108#discussion_r67318603
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer08.java
---
@@ -125
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2108#discussion_r67318672
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer09.java
---
@@ -127
[
https://issues.apache.org/jira/browse/FLINK-4027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333502#comment-15333502
]
ASF GitHub Bot commented on FLINK-4027:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2108#discussion_r67318807
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerBase.java
---
@@ -
[
https://issues.apache.org/jira/browse/FLINK-4027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333501#comment-15333501
]
ASF GitHub Bot commented on FLINK-4027:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-4027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333500#comment-15333500
]
ASF GitHub Bot commented on FLINK-4027:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2108#discussion_r67318738
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerBase.java
---
@@ -
[
https://issues.apache.org/jira/browse/FLINK-4037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-4037:
--
Assignee: (was: Stefan Richter)
> Introduce ArchivedExecutionGraph without any user classes
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2108#discussion_r67318778
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerBase.java
---
@@ -
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2108#discussion_r67318851
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerBase.java
---
@@ -
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2108#discussion_r67318905
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/AtLeastOnceProducerTest.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-4027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333503#comment-15333503
]
ASF GitHub Bot commented on FLINK-4027:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-4027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333505#comment-15333505
]
ASF GitHub Bot commented on FLINK-4027:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333509#comment-15333509
]
ASF GitHub Bot commented on FLINK-3677:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2109#discussion_r67319317
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java ---
@@ -70,7 +70,17 @@
* The fraction that the last split may b
[
https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333508#comment-15333508
]
ASF GitHub Bot commented on FLINK-3677:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2109#discussion_r67319428
--- Diff:
flink-core/src/test/java/org/apache/flink/api/common/io/FilesFilterTest.java ---
@@ -0,0 +1,33 @@
+package org.apache.flink.api.common.io;
--
[
https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333510#comment-15333510
]
ASF GitHub Bot commented on FLINK-3677:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2109#discussion_r67319452
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/io/FilesFilter.java ---
@@ -0,0 +1,79 @@
+package org.apache.flink.api.common.io;
--- En
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2109
You marked this PR as containing documentation for new functionality, but i
can't find any changes to the docs regarding the newly added configuration
keys. Did you forget to include them in this PR?
[
https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333514#comment-15333514
]
ASF GitHub Bot commented on FLINK-3677:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-3951:
Assignee: Till Rohrmann
> Add Histogram Metric Type
> -
>
>
Github user aljoscha closed the pull request at:
https://github.com/apache/flink/pull/2106
---
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 feature
enabled and wishes so, or if the feature is en
[
https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333516#comment-15333516
]
Maximilian Michels commented on FLINK-2392:
---
It doesn't matter if it is a naming
[
https://issues.apache.org/jira/browse/FLINK-4063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333517#comment-15333517
]
ASF GitHub Bot commented on FLINK-4063:
---
Github user aljoscha closed the pull reques
[
https://issues.apache.org/jira/browse/FLINK-4063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved FLINK-4063.
-
Resolution: Fixed
Fix Version/s: 1.1.0
Implemented here:
https://github.com/apache
[
https://issues.apache.org/jira/browse/FLINK-3949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-3949:
---
Assignee: Chesnay Schepler
> Collect Metrics in Runtime Operators
> -
[
https://issues.apache.org/jira/browse/FLINK-3951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333533#comment-15333533
]
ASF GitHub Bot commented on FLINK-3951:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2112
[FLINK-3951] Add histogram metric type
This PR introduces an interface for Flink's histogram metric type
`Histogram` and the corresponding statistics `HistogramStatistics`. The
`Histogram` int
[
https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333536#comment-15333536
]
Chesnay Schepler commented on FLINK-2392:
-
Yes it is indeed related to registering
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2090
---
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 feature
enabled and wishes so, or if the feature is enab
[
https://issues.apache.org/jira/browse/FLINK-3949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-3949.
---
Resolution: Fixed
implemented in c78b3c49e0e82874cbfa71e88bf28b99ed395610.
If additional metr
1 - 100 of 223 matches
Mail list logo
