GitHub user shuai-xu opened a pull request:
https://github.com/apache/flink/pull/2674
Jira
This pr add a DFSInputChannel and DFSSubpartition, which enable user ouput
the results of an operator to DFS and then downstream operators can read data
from DFS.
This is mainly
[
https://issues.apache.org/jira/browse/FLINK-4419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15594339#comment-15594339
]
ASF GitHub Bot commented on FLINK-4419:
---
GitHub user shuai-xu opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15594368#comment-15594368
]
Anton Solovev commented on FLINK-4743:
--
Hello [~twalthr]
I solved the issue through c
[
https://issues.apache.org/jira/browse/FLINK-4874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-4874:
-
Flags: (was: Important)
> Enabling Flink web interface in local execution
>
[
https://issues.apache.org/jira/browse/FLINK-4874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15594393#comment-15594393
]
Fabian Hueske commented on FLINK-4874:
--
That's a good suggestion. The [Local
Executi
[
https://issues.apache.org/jira/browse/FLINK-4874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-4874:
-
Component/s: (was: Webfrontend)
Documentation
> Enabling Flink web interface
[
https://issues.apache.org/jira/browse/FLINK-4874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-4874:
-
Summary: Document how to enable Flink web interface in local execution
(was: Enabling Flink web i
[
https://issues.apache.org/jira/browse/FLINK-4874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-4874:
-
Affects Version/s: 1.2.0
> Enabling Flink web interface in local execution
> -
GitHub user shuai-xu opened a pull request:
https://github.com/apache/flink/pull/2675
[FLINK-4504][dataset api]Support user to decide whether the result of an
operator is presistent
This pr is based on #2674 , it add an setOptions() interface to the class
Operator, so user can
cal
[
https://issues.apache.org/jira/browse/FLINK-4504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15594436#comment-15594436
]
ASF GitHub Bot commented on FLINK-4504:
---
GitHub user shuai-xu opened a pull request:
Chesnay Schepler created FLINK-4875:
---
Summary: operator name not correctly inferred
Key: FLINK-4875
URL: https://issues.apache.org/jira/browse/FLINK-4875
Project: Flink
Issue Type: Bug
Bram Vogelaar created FLINK-4876:
Summary: Allow web interface to be bound to a specific
ip/interface/inetHost
Key: FLINK-4876
URL: https://issues.apache.org/jira/browse/FLINK-4876
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15594480#comment-15594480
]
ASF GitHub Bot commented on FLINK-4875:
---
GitHub user zentol opened a pull request:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/2676
[FLINK-4875] [metrics] Use correct operator name
This PR causes the operator name to be stored in the respective
StreamConfig. With this the MetricSystem no longer has to extract the name from
the T
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/2677
[FLINK-4780] Make GraphiteReporter protocol configurable
This PR allows the GraphiteReporter to use UDP for the data transmission.
This is configured by setting metrics.reporter..protocol to either T
[
https://issues.apache.org/jira/browse/FLINK-4780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15594486#comment-15594486
]
ASF GitHub Bot commented on FLINK-4780:
---
GitHub user zentol opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-4802.
---
Resolution: Not A Problem
This turned out to not be a problem. The distinct function does not
[
https://issues.apache.org/jira/browse/FLINK-4805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-4805.
---
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed in 2ece925c49a62987d547c3441150d9e13bec4d1
[
https://issues.apache.org/jira/browse/FLINK-4795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-4795.
---
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed in af96c0776ea1a48838f1d452efb42c03caa6425
[
https://issues.apache.org/jira/browse/FLINK-4794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-4794.
---
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed in 41d51670019349a7e2dfdc4f4ea55efdc488dcd
[
https://issues.apache.org/jira/browse/FLINK-4804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-4804:
Affects Version/s: 1.1.2
> Grouping.first() function usage fails
> -
[
https://issues.apache.org/jira/browse/FLINK-4804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-4804:
Component/s: Python API
> Grouping.first() function usage fails
> --
[
https://issues.apache.org/jira/browse/FLINK-4804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-4804.
---
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed in 5c83e787c7a4edafa3db34e5a58548728cc27b6
[
https://issues.apache.org/jira/browse/FLINK-4804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-4804.
---
Resolution: Fixed
> Grouping.first() function usage fails
> --
[
https://issues.apache.org/jira/browse/FLINK-4804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reopened FLINK-4804:
-
> Grouping.first() function usage fails
> -
>
>
Aljoscha Krettek created FLINK-4877:
---
Summary: Refactorings around FLINK-3674 (User Function Timers)
Key: FLINK-4877
URL: https://issues.apache.org/jira/browse/FLINK-4877
Project: Flink
Iss
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2636
Thank you
The change is good to merge!
---
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-4862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-4862:
--
Affects Version/s: 1.1.3
1.2.0
> NPE on EventTimeSessionWindows w
[
https://issues.apache.org/jira/browse/FLINK-4784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15594572#comment-15594572
]
ASF GitHub Bot commented on FLINK-4784:
---
Github user rmetzger commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-4862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-4862:
--
Fix Version/s: 1.2.0
1.14
> NPE on EventTimeSessionWindows with Conti
[
https://issues.apache.org/jira/browse/FLINK-4862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-4862:
--
Fix Version/s: (was: 1.14)
1.1.4
> NPE on EventTimeSessionWindows
[
https://issues.apache.org/jira/browse/FLINK-4727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-4727:
--
Fix Version/s: (was: 1.1.3)
1.1.4
> Kafka 0.9 Consumer should als
[
https://issues.apache.org/jira/browse/FLINK-4396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-4396:
--
Fix Version/s: (was: 1.1.3)
1.1.4
> GraphiteReporter class not fo
[
https://issues.apache.org/jira/browse/FLINK-4544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-4544:
--
Fix Version/s: (was: 1.1.3)
1.1.4
> TaskManager metrics are vulne
[
https://issues.apache.org/jira/browse/FLINK-4862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-4862:
--
Assignee: Manu Zhang
> NPE on EventTimeSessionWindows with ContinuousEventTimeTrigger
>
[
https://issues.apache.org/jira/browse/FLINK-4636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-4636:
--
Fix Version/s: (was: 1.1.3)
1.1.4
> AbstractCEPPatternOperator fa
[
https://issues.apache.org/jira/browse/FLINK-4619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-4619:
--
Fix Version/s: (was: 1.1.3)
1.1.4
> JobManager does not answer to
[
https://issues.apache.org/jira/browse/FLINK-4616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-4616:
--
Fix Version/s: (was: 1.1.3)
1.1.4
> Kafka consumer doesn't store
[
https://issues.apache.org/jira/browse/FLINK-4574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-4574:
--
Fix Version/s: (was: 1.1.3)
1.1.4
> Strengthen fetch interval imp
[
https://issues.apache.org/jira/browse/FLINK-4651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-4651:
--
Fix Version/s: (was: 1.1.3)
1.1.4
> Re-register processing time t
[
https://issues.apache.org/jira/browse/FLINK-4540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-4540:
--
Fix Version/s: (was: 1.1.3)
1.1.4
> Detached job execution may pr
[
https://issues.apache.org/jira/browse/FLINK-4862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15594587#comment-15594587
]
Maximilian Michels commented on FLINK-4862:
---
Thanks for reporting [~mauzhang]. I
Robert Metzger created FLINK-4878:
-
Summary:
ReduceTaskExternalITCase.testMultiLevelMergeCombiningReduceTask test instable
Key: FLINK-4878
URL: https://issues.apache.org/jira/browse/FLINK-4878
Project
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2662#discussion_r84448442
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/program/ProgramParametrizationException.java
---
@@ -0,0 +1,46 @@
+/*
+ * Licensed to the A
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2662#discussion_r84448541
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java ---
@@ -975,6 +981,32 @@ private int handleArgException(Exception e) {
}
[
https://issues.apache.org/jira/browse/FLINK-4824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15594650#comment-15594650
]
ASF GitHub Bot commented on FLINK-4824:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-4824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15594649#comment-15594649
]
ASF GitHub Bot commented on FLINK-4824:
---
Github user mxm commented on a diff in the
yuemeng created FLINK-4879:
--
Summary: class KafkaTableSource should be public just like
KafkaTableSink
Key: FLINK-4879
URL: https://issues.apache.org/jira/browse/FLINK-4879
Project: Flink
Issue Typ
[
https://issues.apache.org/jira/browse/FLINK-4879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng updated FLINK-4879:
---
Description:
class KafkaTableSource should be public just like KafkaTableSink,by
default,it's modifier is def
[
https://issues.apache.org/jira/browse/FLINK-4879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng updated FLINK-4879:
---
Description:
class KafkaTableSource should be public just like KafkaTableSink,by
default,it's modifier is def
[
https://issues.apache.org/jira/browse/FLINK-4879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng updated FLINK-4879:
---
Description:
*** class KafkaTableSource should be public just like KafkaTableSink,by
default,it's modifier is
[
https://issues.apache.org/jira/browse/FLINK-4879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng updated FLINK-4879:
---
Description:
class KafkaTableSource should be public just like KafkaTableSink,by
default,it's modifier is def
[
https://issues.apache.org/jira/browse/FLINK-4879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng updated FLINK-4879:
---
Attachment: 0001-class-KafkaTableSource-should-be-public.patch
> class KafkaTableSource should be public just
[
https://issues.apache.org/jira/browse/FLINK-4879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng updated FLINK-4879:
---
Description:
*class KafkaTableSource should be public just like KafkaTableSink,by
default,it's modifier is de
GitHub user hzyuemeng1 opened a pull request:
https://github.com/apache/flink/pull/2678
[FLINK-4879] [Kafka-Connector] class KafkaTableSource should be public just
like KafkaTableSink
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the follow
[
https://issues.apache.org/jira/browse/FLINK-4879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15594687#comment-15594687
]
ASF GitHub Bot commented on FLINK-4879:
---
GitHub user hzyuemeng1 opened a pull reques
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2636
---
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-4784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15594695#comment-15594695
]
ASF GitHub Bot commented on FLINK-4784:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-4784.
---
Resolution: Fixed
Fixed in 3ab97ae3d57c6b3c70c2c1103565621ccefe17f0
> MetricQueryService acto
[
https://issues.apache.org/jira/browse/FLINK-4833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15594717#comment-15594717
]
ASF GitHub Bot commented on FLINK-4833:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15594715#comment-15594715
]
ASF GitHub Bot commented on FLINK-4659:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2665
The stream would still be unclosed in case of an exception, we should use a
try-with-resource statement isntead.
---
If your project is set up for it, you can reply to this email and have your
reply
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2660
+1 to merge.
---
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 vasia commented on the issue:
https://github.com/apache/flink/pull/2663
Thanks, will merge.
---
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
[
https://issues.apache.org/jira/browse/FLINK-4129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15594719#comment-15594719
]
ASF GitHub Bot commented on FLINK-4129:
---
Github user vasia commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2650
oh, I'm afraid i misunderstood the code you posted in the JIRA; i assumed
it was to showcase the behavior from the perspective of a single reporter.
Instead of storing a single scopeString we should s
[
https://issues.apache.org/jira/browse/FLINK-4563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15594730#comment-15594730
]
ASF GitHub Bot commented on FLINK-4563:
---
Github user zentol commented on the issue:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2606
---
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/2663
---
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-4129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15594747#comment-15594747
]
ASF GitHub Bot commented on FLINK-4129:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-3888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15594748#comment-15594748
]
ASF GitHub Bot commented on FLINK-3888:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri resolved FLINK-4129.
--
Resolution: Fixed
> Remove the example HITSAlgorithm
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-4129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri updated FLINK-4129:
-
Summary: Remove the example HITSAlgorithm (was: HITSAlgorithm should test
for element-wise conver
[
https://issues.apache.org/jira/browse/FLINK-4129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri updated FLINK-4129:
-
Issue Type: Improvement (was: Bug)
> Remove the example HITSAlgorithm
> -
[
https://issues.apache.org/jira/browse/FLINK-3888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri updated FLINK-3888:
-
Fix Version/s: 1.2.0
> Custom Aggregator with Convergence can't be registered directly with
> Del
[
https://issues.apache.org/jira/browse/FLINK-3888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri resolved FLINK-3888.
--
Resolution: Fixed
> Custom Aggregator with Convergence can't be registered directly with
> Delt
[
https://issues.apache.org/jira/browse/FLINK-4563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15594760#comment-15594760
]
ASF GitHub Bot commented on FLINK-4563:
---
Github user ex00 commented on the issue:
Github user ex00 commented on the issue:
https://github.com/apache/flink/pull/2650
Thanks for you review, zentol!
>oh, I'm afraid i misunderstood the code you posted in the JIRA; i assumed
it was to showcase the behavior from the perspective of a single reporter.
Instead of storin
[
https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-3950:
--
Component/s: Metrics
> Add Meter Metric Type
> -
>
> Key: FL
[
https://issues.apache.org/jira/browse/FLINK-4831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15594771#comment-15594771
]
Robert Metzger commented on FLINK-4831:
---
So the Log4j metric reporter would periodic
[
https://issues.apache.org/jira/browse/FLINK-4830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-4830:
--
Component/s: Webfrontend
> Show latency statistics in web interface
> --
[
https://issues.apache.org/jira/browse/FLINK-4782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-4782:
--
Component/s: Build System
> log4j & slf4j-log4j are present in jar-with-dependencies artifacts
>
[
https://issues.apache.org/jira/browse/FLINK-4782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15594777#comment-15594777
]
Robert Metzger commented on FLINK-4782:
---
Thank you for reporting this issue. In whic
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2677
+1 change is good to merge.
The user who reported the issue tested the fix.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If you
[
https://issues.apache.org/jira/browse/FLINK-4780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15594780#comment-15594780
]
ASF GitHub Bot commented on FLINK-4780:
---
Github user rmetzger commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-4879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-4879:
--
Component/s: Table API & SQL
> class KafkaTableSource should be public just like KafkaTableSink
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2678
Thank you for opening a pull request.
@fhueske @twalthr @uce I think its okay to make the class public, in case
users want to use a custom Kafka consumer, right?
---
If your project is set
[
https://issues.apache.org/jira/browse/FLINK-4879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15594785#comment-15594785
]
ASF GitHub Bot commented on FLINK-4879:
---
Github user rmetzger commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-4831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15594787#comment-15594787
]
Chesnay Schepler commented on FLINK-4831:
-
correct.
> Implement a log4j metric re
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2448#discussion_r84459904
--- Diff:
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/JsonGenerators.java
---
@@ -0,0 +1,86 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-3030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15594795#comment-15594795
]
ASF GitHub Bot commented on FLINK-3030:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15594797#comment-15594797
]
Robert Metzger commented on FLINK-4775:
---
There is a PR for this JIRA now: https://gi
[
https://issues.apache.org/jira/browse/FLINK-4780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-4780.
---
Resolution: Fixed
Fix Version/s: 1.2.0
Implemented in 3137bf7746f7eb43956f0de1f1b789c8e
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2615
Storing numbers as strings is not terribly efficient, but since this only
affects the web frontend, its okay.
+1 to merge.
---
If your project is set up for it, you can reply to this email
[
https://issues.apache.org/jira/browse/FLINK-4772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15594854#comment-15594854
]
ASF GitHub Bot commented on FLINK-4772:
---
Github user rmetzger commented on the issue
Thomas FOURNIER created FLINK-4880:
--
Summary: FlinkML - Implement Feature hashing (Data pre-processing)
Key: FLINK-4880
URL: https://issues.apache.org/jira/browse/FLINK-4880
Project: Flink
I
[
https://issues.apache.org/jira/browse/FLINK-4772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-4772.
---
Resolution: Fixed
Implemented in e30e7a6192d921d7a3c94beb178eb2c7b9ba74c0
> Store metrics in
[
https://issues.apache.org/jira/browse/FLINK-4775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-4775.
---
Resolution: Fixed
Implemented in 0d290354179a5ea3a11040a2ed7e218263bc474b
> Simplify access t
[
https://issues.apache.org/jira/browse/FLINK-4880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas FOURNIER updated FLINK-4880:
---
Description:
I'm going to work on feature hashing, as it is a point mentioned on the FlinkML
[
https://issues.apache.org/jira/browse/FLINK-4623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Solovev reassigned FLINK-4623:
Assignee: Anton Solovev
> Create Physical Execution Plan of a DataStream
>
1 - 100 of 204 matches
Mail list logo
