[
https://issues.apache.org/jira/browse/FLINK-4108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15576308#comment-15576308
]
ASF GitHub Bot commented on FLINK-4108:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan reassigned FLINK-4586:
-
Assignee: Greg Hogan
> NumberSequenceIterator and Accumulator threading issue
>
[
https://issues.apache.org/jira/browse/FLINK-4586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-4586:
--
Fix Version/s: 1.1.4
1.2.0
> NumberSequenceIterator and Accumulator threading issue
[
https://issues.apache.org/jira/browse/FLINK-4771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15576421#comment-15576421
]
ASF GitHub Bot commented on FLINK-4771:
---
Github user qingdao81 commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2631
Merging
---
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
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2477
Thanks for the update @kirill-morozov-epam!
Merging
---
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
[
https://issues.apache.org/jira/browse/FLINK-4771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15576438#comment-15576438
]
ASF GitHub Bot commented on FLINK-4771:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15576435#comment-15576435
]
ASF GitHub Bot commented on FLINK-4506:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15576439#comment-15576439
]
ASF GitHub Bot commented on FLINK-4108:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15576491#comment-15576491
]
ASF GitHub Bot commented on FLINK-4108:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15576429#comment-15576429
]
ASF GitHub Bot commented on FLINK-4294:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15576430#comment-15576430
]
ASF GitHub Bot commented on FLINK-4294:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2619#discussion_r83502181
--- Diff:
flink-scala/src/main/scala/org/apache/flink/api/scala/ExecutionEnvironment.scala
---
@@ -110,7 +110,7 @@ class ExecutionEnvironment(javaEnv:
[
https://issues.apache.org/jira/browse/FLINK-4586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15576379#comment-15576379
]
ASF GitHub Bot commented on FLINK-4586:
---
GitHub user greghogan opened a pull request:
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/2639
[FLINK-4586] [core] Broken AverageAccumulator
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/greghogan/flink 4586_broken_averageaccumulator
Github user qingdao81 commented on the issue:
https://github.com/apache/flink/pull/2612
Thats good news :-) Thank you!
---
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
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2319#discussion_r83492573
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/FlinkTypeFactory.scala
---
@@ -79,14 +83,27 @@ class
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2319#discussion_r83492774
--- Diff: docs/dev/table_api.md ---
@@ -1656,6 +1656,29 @@ temporalOverlaps(TIMEPOINT, TEMPORAL, TIMEPOINT,
TEMPORAL)
+
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2631
Seems like this is the same change as #2632 but on a different version of
the master.
Closing this PR since #2632 was already merged.
---
If your project is set up for it, you can reply to
[
https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels reassigned FLINK-2821:
-
Assignee: Maximilian Michels
> Change Akka configuration to allow accessing
[
https://issues.apache.org/jira/browse/FLINK-4370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15574880#comment-15574880
]
Greg Hogan commented on FLINK-4370:
---
I thought you had already force-added the file to git, but there is
[
https://issues.apache.org/jira/browse/FLINK-4828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15574839#comment-15574839
]
Stephan Ewen commented on FLINK-4828:
-
I think this is a special case of that issue:
Till Rohrmann created FLINK-4829:
Summary: Accumulators are not thread safe
Key: FLINK-4829
URL: https://issues.apache.org/jira/browse/FLINK-4829
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-4829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15574886#comment-15574886
]
Maximilian Michels commented on FLINK-4829:
---
Actually, they used to be a synchronized map when I
[
https://issues.apache.org/jira/browse/FLINK-4829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels reassigned FLINK-4829:
-
Assignee: Maximilian Michels
> Accumulators are not thread safe
>
[
https://issues.apache.org/jira/browse/FLINK-3722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15574672#comment-15574672
]
ASF GitHub Bot commented on FLINK-3722:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15574583#comment-15574583
]
ASF GitHub Bot commented on FLINK-4771:
---
Github user qingdao81 commented on a diff in the pull
Github user qingdao81 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2612#discussion_r83372815
--- Diff:
flink-batch-connectors/flink-avro/src/test/java/org/apache/flink/api/java/io/AvroOutputFormatTest.java
---
@@ -0,0 +1,126 @@
+package
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15574717#comment-15574717
]
ASF GitHub Bot commented on FLINK-4391:
---
Github user StephanEwen commented on a diff in the pull
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2629#discussion_r83382895
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncCollectorBuffer.java
---
@@ -0,0 +1,469 @@
+/*
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2629#discussion_r83382559
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncCollector.java
---
@@ -0,0 +1,85 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15574718#comment-15574718
]
ASF GitHub Bot commented on FLINK-4391:
---
Github user StephanEwen commented on a diff in the pull
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2629#discussion_r83380500
--- Diff:
flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/async/AsyncIOExample.java
---
@@ -0,0 +1,186 @@
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15574719#comment-15574719
]
ASF GitHub Bot commented on FLINK-4391:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15574716#comment-15574716
]
ASF GitHub Bot commented on FLINK-4391:
---
Github user StephanEwen commented on a diff in the pull
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2629#discussion_r83380141
--- Diff:
flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/async/AsyncIOExample.java
---
@@ -0,0 +1,186 @@
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15574720#comment-15574720
]
ASF GitHub Bot commented on FLINK-4391:
---
Github user StephanEwen commented on a diff in the pull
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2629#discussion_r83380179
--- Diff:
flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/async/AsyncIOExample.java
---
@@ -0,0 +1,186 @@
[
https://issues.apache.org/jira/browse/FLINK-4373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15574844#comment-15574844
]
ASF GitHub Bot commented on FLINK-4373:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2630
---
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
[
https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15574755#comment-15574755
]
Maximilian Michels commented on FLINK-2821:
---
Here you can find the custom release-2.3 branch of
[
https://issues.apache.org/jira/browse/FLINK-4415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-4415:
Description:
Currently, when a {{Trigger}} returns {{PURGE}} (or {{FIRE_AND_PURGE}}) the
[
https://issues.apache.org/jira/browse/FLINK-4828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Anderson closed FLINK-4828.
-
Resolution: Duplicate
> execute stream job asynchronously
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-4717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15574612#comment-15574612
]
ASF GitHub Bot commented on FLINK-4717:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2609
---
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
David Anderson created FLINK-4828:
-
Summary: execute stream job asynchronously
Key: FLINK-4828
URL: https://issues.apache.org/jira/browse/FLINK-4828
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-2313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15574877#comment-15574877
]
David Anderson commented on FLINK-2313:
---
+1
This would be super helpful when working with streams
[
https://issues.apache.org/jira/browse/FLINK-4512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15574609#comment-15574609
]
ASF GitHub Bot commented on FLINK-4512:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2608
---
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
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2628
Thanks for these cool experiments. Looks like a nice improvement.
I'll try to dig into your code in the next days...
---
If your project is set up for it, you can reply to this email and
[
https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15574814#comment-15574814
]
ASF GitHub Bot commented on FLINK-2608:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2623
Okay, in detail it seems that compatibility is not maintained for "Unsafe
based I/O", but maintained for standard I/O.
---
If your project is set up for it, you can reply to this email and have
[
https://issues.apache.org/jira/browse/FLINK-4828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15574815#comment-15574815
]
David Anderson commented on FLINK-4828:
---
It's not clear to me what this would do to the output from
[
https://issues.apache.org/jira/browse/FLINK-2265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2265.
---
> Tachyon Tests sometimes fail with pre-mature process exists
>
[
https://issues.apache.org/jira/browse/FLINK-2265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2265.
-
Resolution: Invalid
These tests are no longer part of the Flink codebase
> Tachyon Tests
[
https://issues.apache.org/jira/browse/FLINK-4370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15574851#comment-15574851
]
Stephan Ewen commented on FLINK-4370:
-
I would like to go with putting the file into {{.idea}}, but
Github user fhueske commented on the pull request:
https://github.com/apache/flink/commit/6d4dd75859aa5e78a20dc3a9492391f1c7f7ca7a#commitcomment-19438191
In
flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java:
In
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2577
---
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
[
https://issues.apache.org/jira/browse/FLINK-4492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15575225#comment-15575225
]
Stefan Richter commented on FLINK-4492:
---
I did not add any cleanup on cancel in the changes I did,
[
https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15575226#comment-15575226
]
Maximilian Michels commented on FLINK-2821:
---
[~philipp.bussche] Which version of Flink do you
[
https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15575320#comment-15575320
]
Timo Walther commented on FLINK-4604:
-
The problem is that the rule translates not only into {{SUM}}
[
https://issues.apache.org/jira/browse/FLINK-4829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15575329#comment-15575329
]
ASF GitHub Bot commented on FLINK-4829:
---
GitHub user mxm opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-4831:
Summary: Implement a log4j metric reporter (was: IMplement a log4j metric
reporter)
>
Chesnay Schepler created FLINK-4831:
---
Summary: IMplement a log4j metric reporter
Key: FLINK-4831
URL: https://issues.apache.org/jira/browse/FLINK-4831
Project: Flink
Issue Type:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2633
The important class is `CassandraScalaProductSink` which extracts the
fields from the scala classes. Apart from that it behaves exactly like the
`CassandraTupleSink`. As a result of that this common
[
https://issues.apache.org/jira/browse/FLINK-4497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15575145#comment-15575145
]
ASF GitHub Bot commented on FLINK-4497:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15575161#comment-15575161
]
ASF GitHub Bot commented on FLINK-4827:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-4315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15575192#comment-15575192
]
Fabian Hueske commented on FLINK-4315:
--
Hi [~kenmy],
while discussing to drop Hadoop1 support, the
[
https://issues.apache.org/jira/browse/FLINK-2907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan resolved FLINK-2907.
---
Resolution: Later
Closing this issue with current thoughts:
- this would only be applicable for batch
[
https://issues.apache.org/jira/browse/FLINK-4315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-4315:
-
Summary: Deprecate Hadoop dependent methods in flink-java (was: Remove
Hadoop Dependency from
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2634
I don't think fixes the reported issue. The supplied stacktrace shows that
the exception is thrown in a TreeMap, in the AccRegistry we however only deal
with HashMaps. The histograms internally have
[
https://issues.apache.org/jira/browse/FLINK-4829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15575382#comment-15575382
]
ASF GitHub Bot commented on FLINK-4829:
---
Github user zentol commented on the issue:
Timo Walther created FLINK-4832:
---
Summary: Count/Sum 0 elements
Key: FLINK-4832
URL: https://issues.apache.org/jira/browse/FLINK-4832
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-4294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15575154#comment-15575154
]
ASF GitHub Bot commented on FLINK-4294:
---
Github user twalthr commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15575175#comment-15575175
]
ASF GitHub Bot commented on FLINK-3660:
---
Github user aljoscha commented on the issue:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2386
This looks good to merge 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 feature
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2386
---
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
[
https://issues.apache.org/jira/browse/FLINK-3660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15575209#comment-15575209
]
ASF GitHub Bot commented on FLINK-3660:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-3660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-3660.
---
Resolution: Fixed
Fix Version/s: 1.2.0
Resolved in
[
https://issues.apache.org/jira/browse/FLINK-3660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-3660:
--
Component/s: Metrics
> Measure latency of elements and expose it as a metric
>
[
https://issues.apache.org/jira/browse/FLINK-3660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-3660:
--
Summary: Measure latency of elements and expose it as a metric (was:
Measure latency of
[
https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15575240#comment-15575240
]
Maximilian Michels commented on FLINK-2821:
---
Forgot to mention, the build is based on the Hadoop
[
https://issues.apache.org/jira/browse/FLINK-4315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15575288#comment-15575288
]
Fabian Hueske commented on FLINK-4315:
--
Thanks, [~kenmy]!
I move this method from the FLINK-3975
[
https://issues.apache.org/jira/browse/FLINK-4652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15575336#comment-15575336
]
ASF GitHub Bot commented on FLINK-4652:
---
GitHub user greghogan opened a pull request:
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/2635
[FLINK-4652] [streaming connectors] Automatically refresh AWS credentials
By using the credentials explicitly we are responsible for checking and
refreshing credentials before they expire. If no
[
https://issues.apache.org/jira/browse/FLINK-4706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan resolved FLINK-4706.
---
Resolution: Not A Problem
> Is there a way to load user classes first?
>
[
https://issues.apache.org/jira/browse/FLINK-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15575390#comment-15575390
]
ASF GitHub Bot commented on FLINK-4564:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-4564.
---
Resolution: Fixed
Fix Version/s: 1.2.0
Implemented in
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/2633
[FLINK-4497] CassadraSink support for scala tuples/case classes
This PR adds support for scala tuples/case classes to the streaming
at-least-once-sink. If this pattern works we can extend it to
[
https://issues.apache.org/jira/browse/FLINK-4497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15575138#comment-15575138
]
ASF GitHub Bot commented on FLINK-4497:
---
GitHub user zentol opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15575212#comment-15575212
]
Robert Metzger commented on FLINK-4221:
---
I assigned the issue to myself, however, [~Zentol] and
[
https://issues.apache.org/jira/browse/FLINK-4221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-4221:
-
Assignee: Robert Metzger
> Show metrics in WebFrontend
> ---
>
>
Github user zentol commented on the pull request:
https://github.com/apache/flink/commit/a612b9966f3ee020a5721ac2f039a3633c40146c#commitcomment-19427630
In
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java:
In
[
https://issues.apache.org/jira/browse/FLINK-4315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-4315:
-
Issue Type: Task (was: Sub-task)
Parent: (was: FLINK-3957)
> Remove Hadoop
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2517
---
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
Github user zentol closed the pull request at:
https://github.com/apache/flink/pull/2613
---
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
[
https://issues.apache.org/jira/browse/FLINK-4774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15575132#comment-15575132
]
ASF GitHub Bot commented on FLINK-4774:
---
Github user zentol closed the pull request at:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/2319
@fhueske I updated the PR. It is now in a mergable state. I had to disable
automatic flattening as it flattens types but does no unflattening. So if a
composite type enters the Table API it can
[
https://issues.apache.org/jira/browse/FLINK-4315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15575273#comment-15575273
]
Evgeny Kincharov commented on FLINK-4315:
-
Sure, I am doing it now. May be a separate issue for
Robert Metzger created FLINK-4830:
-
Summary: Show latency statistics in web interface
Key: FLINK-4830
URL: https://issues.apache.org/jira/browse/FLINK-4830
Project: Flink
Issue Type:
1 - 100 of 167 matches
Mail list logo
