[
https://issues.apache.org/jira/browse/FLINK-4840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15591000#comment-15591000
]
Chesnay Schepler commented on FLINK-4840:
-
There are some things that are concerni
[
https://issues.apache.org/jira/browse/FLINK-4856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiaogang Shi reassigned FLINK-4856:
---
Assignee: Xiaogang Shi
> Add MapState for keyed streams
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-4862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15590782#comment-15590782
]
Manu Zhang commented on FLINK-4862:
---
A simple fix is to check for null return when looki
Manu Zhang created FLINK-4862:
-
Summary: NPE on EventTimeSessionWindows with
ContinuousEventTimeTrigger
Key: FLINK-4862
URL: https://issues.apache.org/jira/browse/FLINK-4862
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-4840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15590636#comment-15590636
]
zhuhaifeng commented on FLINK-4840:
---
It measure the time cost of record processing from
[
https://issues.apache.org/jira/browse/FLINK-4840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhuhaifeng updated FLINK-4840:
--
Description:
We should expose the following Metrics on the OperatorIOMetricGroup:
1. latency(ms): recor
[
https://issues.apache.org/jira/browse/FLINK-4840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhuhaifeng updated FLINK-4840:
--
Summary: Measure latency/delay of record processing and expose it as a
metric (was: Introduce an Operat
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2606
+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 t
Github user vijikarthi commented on the issue:
https://github.com/apache/flink/pull/2425
Thanks @mxm for the review. I will incorporate your feedback and attach the
patch.
>
When security is enabled, encryption should also be turned on by default.
Otherwise we will transm
GitHub user nssalian opened a pull request:
https://github.com/apache/flink/pull/2665
[FLINK-4659]: Potential resource leak due to unclosed InputStream in
SecurityContext#populateSystemSecurityProperties()
Thanks for contributing to Apache Flink. Before you open your pull request,
[
https://issues.apache.org/jira/browse/FLINK-3930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15590228#comment-15590228
]
ASF GitHub Bot commented on FLINK-3930:
---
Github user vijikarthi commented on the iss
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/2664
[FLINK-4861] [build] Package optional project artifacts
Package the Flink connectors, metrics, and libraries into subdirectories of
a new opt directory in the release/snapshot tarballs.
T
[
https://issues.apache.org/jira/browse/FLINK-4659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15590091#comment-15590091
]
ASF GitHub Bot commented on FLINK-4659:
---
GitHub user nssalian opened a pull request:
Github user vijikarthi commented on a diff in the pull request:
https://github.com/apache/flink/pull/2425#discussion_r84169656
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java
---
@@ -57,24 +61,37 @@
// constructor in order
Github user vijikarthi commented on a diff in the pull request:
https://github.com/apache/flink/pull/2425#discussion_r84175964
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java ---
@@ -442,8 +453,10 @@ public static void runInteractiveCli(YarnClu
[
https://issues.apache.org/jira/browse/FLINK-3930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15589986#comment-15589986
]
ASF GitHub Bot commented on FLINK-3930:
---
Github user vijikarthi commented on a diff
Github user vijikarthi commented on a diff in the pull request:
https://github.com/apache/flink/pull/2425#discussion_r84174244
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java ---
@@ -108,6 +111,11 @@
private final Options ALL_OPTI
Github user vijikarthi commented on a diff in the pull request:
https://github.com/apache/flink/pull/2425#discussion_r84170399
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java
---
@@ -112,9 +129,9 @@ public void write(ChannelHandler
[
https://issues.apache.org/jira/browse/FLINK-3930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15589968#comment-15589968
]
ASF GitHub Bot commented on FLINK-3930:
---
Github user vijikarthi commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-3930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15589905#comment-15589905
]
ASF GitHub Bot commented on FLINK-3930:
---
Github user vijikarthi commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-3930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15589888#comment-15589888
]
ASF GitHub Bot commented on FLINK-3930:
---
Github user vijikarthi commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-3888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15589838#comment-15589838
]
ASF GitHub Bot commented on FLINK-3888:
---
Github user greghogan commented on the issu
Github user greghogan closed the pull request at:
https://github.com/apache/flink/pull/1698
---
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 e
[
https://issues.apache.org/jira/browse/FLINK-3454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15589795#comment-15589795
]
ASF GitHub Bot commented on FLINK-3454:
---
Github user greghogan closed the pull reque
[
https://issues.apache.org/jira/browse/FLINK-3454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan resolved FLINK-3454.
---
Resolution: Won't Fix
> Add test dependencies on packaged jars
> -
[
https://issues.apache.org/jira/browse/FLINK-4861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15589790#comment-15589790
]
ASF GitHub Bot commented on FLINK-4861:
---
GitHub user greghogan opened a pull request
Greg Hogan created FLINK-4861:
-
Summary: Package optional project artifacts
Key: FLINK-4861
URL: https://issues.apache.org/jira/browse/FLINK-4861
Project: Flink
Issue Type: New Feature
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/2662
[FLINK-4824] [client] CliFrontend shows misleading error message
When a Flink program throws `ProgramParametrizationException` the optional
message is printed to stderr and the stacktrace is ignor
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/2663
[FLINK-4129] [gelly] HITSAlgorithm should test for element-wise convergence
Removes the example HITSAlgorithm. The Gelly library includes the more
performant HITS algorithm.
You can merge this pu
[
https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15589153#comment-15589153
]
Maximilian Michels edited comment on FLINK-2821 at 10/19/16 6:06 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-4129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15589419#comment-15589419
]
ASF GitHub Bot commented on FLINK-4129:
---
GitHub user greghogan opened a pull request
[
https://issues.apache.org/jira/browse/FLINK-4855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15589378#comment-15589378
]
Greg Hogan commented on FLINK-4855:
---
Hi and thanks for submitting a ticket for this idea
[
https://issues.apache.org/jira/browse/FLINK-4824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15589415#comment-15589415
]
ASF GitHub Bot commented on FLINK-4824:
---
GitHub user greghogan opened a pull request
[
https://issues.apache.org/jira/browse/FLINK-4820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15589385#comment-15589385
]
Greg Hogan commented on FLINK-4820:
---
Upgrade to what version? What are the implications
[
https://issues.apache.org/jira/browse/FLINK-4129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-4129:
--
Fix Version/s: 1.2.0
> HITSAlgorithm should test for element-wise convergence
>
[
https://issues.apache.org/jira/browse/FLINK-4129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan reassigned FLINK-4129:
-
Assignee: Greg Hogan
> HITSAlgorithm should test for element-wise convergence
> -
[
https://issues.apache.org/jira/browse/FLINK-4129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15589345#comment-15589345
]
Greg Hogan commented on FLINK-4129:
---
For the 1.2 release we'll differentiate between "dr
[
https://issues.apache.org/jira/browse/FLINK-4784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15589224#comment-15589224
]
ASF GitHub Bot commented on FLINK-4784:
---
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/2636#discussion_r84115204
--- Diff:
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/metrics/MetricFetcher.java
---
@@ -148,7 +148,7 @@ public void onSuccess(Objec
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2659
+1 LGTM
---
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
[
https://issues.apache.org/jira/browse/FLINK-4857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15589164#comment-15589164
]
ASF GitHub Bot commented on FLINK-4857:
---
Github user mxm commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15589153#comment-15589153
]
Maximilian Michels edited comment on FLINK-2821 at 10/19/16 4:21 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15589153#comment-15589153
]
Maximilian Michels commented on FLINK-2821:
---
Thanks a lot for fast testing! You'
[
https://issues.apache.org/jira/browse/FLINK-4705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-4705:
--
Issue Type: Sub-task (was: Improvement)
Parent: FLINK-4860
> Instrument FixedLengthRecordSorter
[
https://issues.apache.org/jira/browse/FLINK-3722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-3722:
--
Issue Type: Sub-task (was: Improvement)
Parent: FLINK-4860
> The divisions in the InMemorySorte
[
https://issues.apache.org/jira/browse/FLINK-4808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15589126#comment-15589126
]
Aljoscha Krettek commented on FLINK-4808:
-
I think it might be good to allow a cer
[
https://issues.apache.org/jira/browse/FLINK-1778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-1778:
--
Issue Type: Sub-task (was: Improvement)
Parent: FLINK-4860
> Improve normalized keys in composi
Greg Hogan created FLINK-4860:
-
Summary: Sort performance
Key: FLINK-4860
URL: https://issues.apache.org/jira/browse/FLINK-4860
Project: Flink
Issue Type: Improvement
Reporter: Greg H
[
https://issues.apache.org/jira/browse/FLINK-4586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-4586.
-
Resolution: Fixed
Fixed in
1.2.0: 428419d599d138f1647f84807d6d0224652f3d1b
1.1.4: 9c87f92cbb9989281024
[
https://issues.apache.org/jira/browse/FLINK-4283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15588998#comment-15588998
]
ASF GitHub Bot commented on FLINK-4283:
---
GitHub user AlexanderShoshin opened a pull
GitHub user AlexanderShoshin opened a pull request:
https://github.com/apache/flink/pull/2661
[FLINK-4283] ExecutionGraphRestartTest fails
Tests were falling by timeout on less than 3 core CPU machines. There were
several graph *RestartStrategies* that blocked threads from the
*Exe
Github user nssalian commented on the issue:
https://github.com/apache/flink/pull/2642
Thanks @uce, agreed, it would be a community effort indeed. I will try to
help as much as possible.
@ggevay, it's alright. I'll close the PR.
---
If your project is set up for it, you can rep
[
https://issues.apache.org/jira/browse/FLINK-3999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15588991#comment-15588991
]
ASF GitHub Bot commented on FLINK-3999:
---
Github user nssalian commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-3999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15588992#comment-15588992
]
ASF GitHub Bot commented on FLINK-3999:
---
Github user nssalian closed the pull reques
Github user nssalian closed the pull request at:
https://github.com/apache/flink/pull/2642
---
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-4652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-4652.
-
Resolution: Implemented
Implemented in cb78d70b270bfb6962a9731d49d0d19c6e5bc88a
> Don't pass credentials
[
https://issues.apache.org/jira/browse/FLINK-4792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-4792.
-
Resolution: Fixed
Fixed in 27c25d01b1c4eb25ef914907560c10eaa53973f8
> Update documentation - FlinkML/Quic
[
https://issues.apache.org/jira/browse/FLINK-4792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-4792:
--
Fix Version/s: 1.2.0
> Update documentation - FlinkML/QuickStart Guide
> ---
[
https://issues.apache.org/jira/browse/FLINK-4792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-4792:
--
Assignee: Neelesh Srinivas Salian
> Update documentation - FlinkML/QuickStart Guide
> --
[
https://issues.apache.org/jira/browse/FLINK-4792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-4792:
--
Component/s: Documentation
> Update documentation - FlinkML/QuickStart Guide
> -
[
https://issues.apache.org/jira/browse/FLINK-4652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15588929#comment-15588929
]
ASF GitHub Bot commented on FLINK-4652:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan reopened FLINK-4792:
---
> Update documentation - FlinkML/QuickStart Guide
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-4792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15588928#comment-15588928
]
ASF GitHub Bot commented on FLINK-4792:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15588930#comment-15588930
]
ASF GitHub Bot commented on FLINK-4586:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2635
---
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/2639
---
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/2641
---
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-4823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-4823:
--
Priority: Major (was: Blocker)
> org.apache.flink.types.NullFieldException: Field 0 is null, but expect
[
https://issues.apache.org/jira/browse/FLINK-4808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15588908#comment-15588908
]
Ufuk Celebi commented on FLINK-4808:
Should we restrict the allowed failed checkpoints
Aljoscha Krettek created FLINK-4859:
---
Summary: Clearly Separate Responsibilities of StreamOperator and
StreamTask
Key: FLINK-4859
URL: https://issues.apache.org/jira/browse/FLINK-4859
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-4858:
--
Description:
This issue tracks the removal of the deprecated/legacy interfaces that are
still i
[
https://issues.apache.org/jira/browse/FLINK-4808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi reassigned FLINK-4808:
--
Assignee: Ufuk Celebi
> Allow skipping failed checkpoints
> -
>
Aljoscha Krettek created FLINK-4858:
---
Summary: Remove Legacy Checkpointing Interfaces
Key: FLINK-4858
URL: https://issues.apache.org/jira/browse/FLINK-4858
Project: Flink
Issue Type: Improv
[
https://issues.apache.org/jira/browse/FLINK-4858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-4858:
Assignee: (was: Aljoscha Krettek)
> Remove Legacy Checkpointing Interfaces
> ---
[
https://issues.apache.org/jira/browse/FLINK-4858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-4858:
---
Assignee: Aljoscha Krettek
> Remove Legacy Checkpointing Interfaces
> ---
[
https://issues.apache.org/jira/browse/FLINK-4854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15588850#comment-15588850
]
Greg Hogan commented on FLINK-4854:
---
Hi and thanks for submitting a ticket for this idea
[
https://issues.apache.org/jira/browse/FLINK-3719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15588826#comment-15588826
]
ASF GitHub Bot commented on FLINK-3719:
---
Github user mushketyk commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-4833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15588827#comment-15588827
]
ASF GitHub Bot commented on FLINK-4833:
---
GitHub user mxm opened a pull request:
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/2660
[FLINK-4833] properly log exceptions in CountMinHeavyHitter
This logs the underlying exception properly which could help us to find the
exact cause of the reported problems.
You can merge this pull req
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2467
Hi @iampeter,
Sorry for the delay in response. I'll take a look at this on Sunday.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
[
https://issues.apache.org/jira/browse/FLINK-3030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15588822#comment-15588822
]
ASF GitHub Bot commented on FLINK-3030:
---
Github user mushketyk commented on the issu
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2448
Is there anything else that should be updated in this PR? It has been in
review for more than a month.
---
If your project is set up for it, you can reply to this email and have your
reply appear
[
https://issues.apache.org/jira/browse/FLINK-4792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15588784#comment-15588784
]
ASF GitHub Bot commented on FLINK-4792:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2641
@nssalian thanks for the contribution!
This is the only case in the documentation without the wildcard scala
import. Merging ...
---
If your project is set up for it, you can reply to thi
[
https://issues.apache.org/jira/browse/FLINK-2125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15588701#comment-15588701
]
ASF GitHub Bot commented on FLINK-2125:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/1491
This PR should be closed as FLINK-2125 was fixed with #2233.
---
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
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2655#discussion_r84063789
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
---
@@ -408,106 +528,98 @@ public void run() {
[
https://issues.apache.org/jira/browse/FLINK-4851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15588696#comment-15588696
]
ASF GitHub Bot commented on FLINK-4851:
---
Github user tillrohrmann commented on a dif
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2618
Could you please elaborate on the changes you made to the
`ContinuousFileReaderOperator`?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well.
[
https://issues.apache.org/jira/browse/FLINK-2752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan resolved FLINK-2752.
---
Resolution: Resolved
> Documentation is not easily differentiable from the Flink homepage
> --
[
https://issues.apache.org/jira/browse/FLINK-4857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15588620#comment-15588620
]
ASF GitHub Bot commented on FLINK-4857:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2659
[FLINK-4857] Remove throws clause from ZooKeeperUtils functions
Remove the unnecessary throws clauses from all ZooKeeperUtils' functions
which don't
throw an actual exception.
Remo
Till Rohrmann created FLINK-4857:
Summary: ZooKeeperUtils have a throws exception clause without
throwing exceptions
Key: FLINK-4857
URL: https://issues.apache.org/jira/browse/FLINK-4857
Project: Flin
[
https://issues.apache.org/jira/browse/FLINK-4850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15588603#comment-15588603
]
ASF GitHub Bot commented on FLINK-4850:
---
GitHub user thvasilo opened a pull request:
GitHub user thvasilo opened a pull request:
https://github.com/apache/flink/pull/2658
[FLINK-4850] [ml] FlinkML - SVM predict Operation for Vector and not
LaveledVector
The current version of the quickstart guide includes erroneous code, this
changes the function calls to have cor
[
https://issues.apache.org/jira/browse/FLINK-4850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Theodore Vasiloudis reassigned FLINK-4850:
--
Assignee: Theodore Vasiloudis
> FlinkML - SVM predict Operation for Vector and
[
https://issues.apache.org/jira/browse/FLINK-4586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15588571#comment-15588571
]
ASF GitHub Bot commented on FLINK-4586:
---
Github user greghogan commented on a diff i
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2639#discussion_r84054277
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/accumulators/AverageAccumulator.java
---
@@ -28,51 +28,52 @@
public class AverageAccumu
[
https://issues.apache.org/jira/browse/FLINK-2428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15588567#comment-15588567
]
ASF GitHub Bot commented on FLINK-2428:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/1554
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 and wishes so, or if the
1 - 100 of 259 matches
Mail list logo
