GitHub user RalphSu opened a pull request:
https://github.com/apache/flink/pull/3615
support flink-storm metrics
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your changes take all of the i
[
https://issues.apache.org/jira/browse/FLINK-6188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-6188:
Description:
Recent changes done for FLINK-5808 move default parallelism manifestation from
[
https://issues.apache.org/jira/browse/FLINK-6188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941990#comment-15941990
]
Aljoscha Krettek commented on FLINK-6188:
-
This is the thrown exception:
{code}
Ca
[
https://issues.apache.org/jira/browse/FLINK-6185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941797#comment-15941797
]
Luke Hutchison edited comment on FLINK-6185 at 3/25/17 8:23 PM:
[
https://issues.apache.org/jira/browse/FLINK-6185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941797#comment-15941797
]
Luke Hutchison edited comment on FLINK-6185 at 3/25/17 8:22 PM:
[
https://issues.apache.org/jira/browse/FLINK-6115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941882#comment-15941882
]
Luke Hutchison commented on FLINK-6115:
---
[~greghogan] versioning of durable binary f
[
https://issues.apache.org/jira/browse/FLINK-6185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941797#comment-15941797
]
Luke Hutchison commented on FLINK-6185:
---
Here's my simple gzip OutputFormat though,
[
https://issues.apache.org/jira/browse/FLINK-6185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Hutchison updated FLINK-6185:
--
Summary: Output writers and OutputFormats need to support compression
(was: Output writers and
[
https://issues.apache.org/jira/browse/FLINK-6185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Hutchison updated FLINK-6185:
--
Summary: Output writers and OutputFormats need to support gzip (was: Input
readers and output w
[
https://issues.apache.org/jira/browse/FLINK-6185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941795#comment-15941795
]
Luke Hutchison commented on FLINK-6185:
---
Ah, sorry that I missed that. I may contrib
[
https://issues.apache.org/jira/browse/FLINK-5929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941791#comment-15941791
]
ASF GitHub Bot commented on FLINK-5929:
---
Github user sjwiesman commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-5929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941792#comment-15941792
]
ASF GitHub Bot commented on FLINK-5929:
---
Github user sjwiesman closed the pull reque
Github user sjwiesman commented on the issue:
https://github.com/apache/flink/pull/3479
Done! Thank you for for helping me get this feature merged in. This has to
be one of the most painless commits I've ever made to an open source project of
this size.
---
If your project is set u
Github user sjwiesman closed the pull request at:
https://github.com/apache/flink/pull/3479
---
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-5498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941789#comment-15941789
]
Fabian Hueske commented on FLINK-5498:
--
Thanks [~lincoln.86xy],
we might be able to
[
https://issues.apache.org/jira/browse/FLINK-5929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941773#comment-15941773
]
Aljoscha Krettek commented on FLINK-5929:
-
[~sjwiesman] I created FLINK-6163 and F
[
https://issues.apache.org/jira/browse/FLINK-5929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-5929.
---
Resolution: Fixed
Fix Version/s: 1.3.0
Implemented on master in
fad201bfb0b1f2757f68f7b
[
https://issues.apache.org/jira/browse/FLINK-5929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-5929:
---
Assignee: Seth Wiesman
> Allow Access to Per-Window State in ProcessWindowFunction
>
[
https://issues.apache.org/jira/browse/FLINK-5929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941771#comment-15941771
]
ASF GitHub Bot commented on FLINK-5929:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3479
Thanks for implementing this! ð
I just merged, could you please close this PR?
---
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-5498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941761#comment-15941761
]
lincoln.lee commented on FLINK-5498:
@Fabian, agree with you, add another groupBy and
[
https://issues.apache.org/jira/browse/FLINK-5754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941752#comment-15941752
]
Greg Hogan edited comment on FLINK-5754 at 3/25/17 3:03 PM:
[~
[
https://issues.apache.org/jira/browse/FLINK-5754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941752#comment-15941752
]
Greg Hogan commented on FLINK-5754:
---
[~shijinkui], from a nice [StackOverflow
anser|htt
[
https://issues.apache.org/jira/browse/FLINK-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941745#comment-15941745
]
ASF GitHub Bot commented on FLINK-5998:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/3604
@rmetzger thanks for the clarification. Sounds good!
---
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 th
[
https://issues.apache.org/jira/browse/FLINK-6185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941736#comment-15941736
]
Greg Hogan commented on FLINK-6185:
---
There is some [support for this
already|https://ci
[
https://issues.apache.org/jira/browse/FLINK-6107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941731#comment-15941731
]
ASF GitHub Bot commented on FLINK-6107:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/3567
@aljoscha, I likewise have no great preference for import order. I do think
it is important for the checkstyle to match IntelliJ's code style, either the
default or a provided Flink style.
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/3567#discussion_r108035621
--- Diff: tools/maven/strict-checkstyle.xml ---
@@ -0,0 +1,550 @@
+
+
+http://www.puppycrawl.com/dtds/configuration_1_3.dtd";>
+
+
+
[
https://issues.apache.org/jira/browse/FLINK-6107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941718#comment-15941718
]
ASF GitHub Bot commented on FLINK-6107:
---
Github user greghogan commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-3257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941700#comment-15941700
]
ASF GitHub Bot commented on FLINK-3257:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1668#discussion_r108034229
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamIterationTail.java
---
@@ -64,6 +70,22 @@ public void init()
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/3604
Yes, the idea is that users in some environments can even delete
`flink-dist-hadoop.jar` entirely, and just configure the classpath correctly to
point to the Hadoop lib folder of their hadoop distri
[
https://issues.apache.org/jira/browse/FLINK-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941690#comment-15941690
]
ASF GitHub Bot commented on FLINK-5998:
---
Github user rmetzger commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-6186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941689#comment-15941689
]
ASF GitHub Bot commented on FLINK-6186:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/3612
+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 th
[
https://issues.apache.org/jira/browse/FLINK-6187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941687#comment-15941687
]
Robert Metzger commented on FLINK-6187:
---
Did you configure HA?
Are you sure the {{i
[
https://issues.apache.org/jira/browse/FLINK-6186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-6186:
--
Component/s: Streaming
Scala API
> Remove unused import
>
[
https://issues.apache.org/jira/browse/FLINK-6186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-6186:
--
Component/s: DataStream API
> Remove unused import
>
>
> Ke
[
https://issues.apache.org/jira/browse/FLINK-6187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-6187:
--
Component/s: Client
> Cancel job failed with option -m on yarn session
> ---
[
https://issues.apache.org/jira/browse/FLINK-6187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-6187:
--
Component/s: YARN
> Cancel job failed with option -m on yarn session
> -
[
https://issues.apache.org/jira/browse/FLINK-6189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941679#comment-15941679
]
ASF GitHub Bot commented on FLINK-6189:
---
GitHub user WangTaoTheTonic opened a pull r
GitHub user WangTaoTheTonic opened a pull request:
https://github.com/apache/flink/pull/3614
[FLINK-6189][YARN]Do not use yarn client config to do sanity check
Now in client, if #slots is greater than then number of
"yarn.nodemanager.resource.cpu-vcores" in yarn client config, the s
[
https://issues.apache.org/jira/browse/FLINK-6189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tao Wang reassigned FLINK-6189:
---
Assignee: Tao Wang
> Do not use yarn client config to do sanity check
> -
Tao Wang created FLINK-6189:
---
Summary: Do not use yarn client config to do sanity check
Key: FLINK-6189
URL: https://issues.apache.org/jira/browse/FLINK-6189
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-6148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangrucong1982 closed FLINK-6148.
--
Resolution: Done
this issue is the same with the issue 6117. And the issue 6117 is resolved by
[
https://issues.apache.org/jira/browse/FLINK-6148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941659#comment-15941659
]
zhangrucong1982 commented on FLINK-6148:
ok，I will close the issue。
> The Zookeep
[
https://issues.apache.org/jira/browse/FLINK-6188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-6188:
Priority: Blocker (was: Major)
> Some setParallelism() method can't cope with default paral
Aljoscha Krettek created FLINK-6188:
---
Summary: Some setParallelism() method can't cope with default
parallelism
Key: FLINK-6188
URL: https://issues.apache.org/jira/browse/FLINK-6188
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941637#comment-15941637
]
Haohui Mai commented on FLINK-5829:
---
I just pushed a PR. The migration process is relati
GitHub user haohui opened a pull request:
https://github.com/apache/flink/pull/3613
[FLINK-5829] Bump Calcite version to 1.12 once available.
This PR bumps the Calcite version from 1.11 to 1.12.
The main issue is that it conflicts with FLINK-4288, as the `tableMap`
field be
[
https://issues.apache.org/jira/browse/FLINK-5829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941636#comment-15941636
]
ASF GitHub Bot commented on FLINK-5829:
---
GitHub user haohui opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-6159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941633#comment-15941633
]
CanBin Zheng commented on FLINK-6159:
-
[~StephanEwen]
I'd like to have a try, it dese
GitHub user zhengcanbin opened a pull request:
https://github.com/apache/flink/pull/3612
[FLINK-6186][cleanup]Remove unused import.
Remove unused import in
org.apache.flink.streaming.api.scala.StreamExecutionEnvironment.scala
You can merge this pull request into a Git repository by
[
https://issues.apache.org/jira/browse/FLINK-6186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941627#comment-15941627
]
ASF GitHub Bot commented on FLINK-6186:
---
GitHub user zhengcanbin opened a pull reque
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3386#discussion_r108030107
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -112,7 +113,12 @@ cla
[
https://issues.apache.org/jira/browse/FLINK-4562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941619#comment-15941619
]
ASF GitHub Bot commented on FLINK-4562:
---
Github user shijinkui commented on the issu
Github user shijinkui commented on the issue:
https://github.com/apache/flink/pull/2460
> I agree with @wuchong , that we should follow the example of Gelly and
add the flink-table-examples JAR file to the opt folder.
@fhueske Thanks for your review.
IMO, directory st
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3269
---
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-5698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-5698.
Resolution: Implemented
Fix Version/s: 1.3.0
Implemented with 5c37e55c83f854c1a9eb7bd7438b378
[
https://issues.apache.org/jira/browse/FLINK-5698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941615#comment-15941615
]
ASF GitHub Bot commented on FLINK-5698:
---
Github user asfgit closed the pull request
61 matches
Mail list logo
