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
[
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=15941990#comment-15941990
]
Aljoscha Krettek commented on FLINK-6188:
-
This is the thrown exception:
{code}
Caused by:
[
https://issues.apache.org/jira/browse/FLINK-6185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15941797#comment-15941797
]
Luke Hutchison edited comment on FLINK-6185 at 3/25/17 8:23 PM:
Here's my
[
https://issues.apache.org/jira/browse/FLINK-6185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15941797#comment-15941797
]
Luke Hutchison edited comment on FLINK-6185 at 3/25/17 8:22 PM:
Here's my
[
https://issues.apache.org/jira/browse/FLINK-6115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15941882#comment-15941882
]
Luke Hutchison commented on FLINK-6115:
---
[~greghogan] versioning of durable binary formats is not
[
https://issues.apache.org/jira/browse/FLINK-6185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15941797#comment-15941797
]
Luke Hutchison commented on FLINK-6185:
---
Here's my simple gzip OutputFormat though, in case anyone
[
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
[
https://issues.apache.org/jira/browse/FLINK-6185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15941795#comment-15941795
]
Luke Hutchison commented on FLINK-6185:
---
Ah, sorry that I missed that. I may contribute some code to
[
https://issues.apache.org/jira/browse/FLINK-5929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15941791#comment-15941791
]
ASF GitHub Bot commented on FLINK-5929:
---
Github user sjwiesman commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15941792#comment-15941792
]
ASF GitHub Bot commented on FLINK-5929:
---
Github user sjwiesman closed the pull request at:
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
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
[
https://issues.apache.org/jira/browse/FLINK-5498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15941789#comment-15941789
]
Fabian Hueske commented on FLINK-5498:
--
Thanks [~lincoln.86xy],
we might be able to tweak the plan
[
https://issues.apache.org/jira/browse/FLINK-5929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15941773#comment-15941773
]
Aljoscha Krettek commented on FLINK-5929:
-
[~sjwiesman] I created FLINK-6163 and FLINK-6164 as
[
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
[
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=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=15941761#comment-15941761
]
lincoln.lee commented on FLINK-5498:
@Fabian, agree with you, add another groupBy and apply a
[
https://issues.apache.org/jira/browse/FLINK-5754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15941752#comment-15941752
]
Greg Hogan edited comment on FLINK-5754 at 3/25/17 3:03 PM:
[~shijinkui], from
[
https://issues.apache.org/jira/browse/FLINK-5754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15941752#comment-15941752
]
Greg Hogan commented on FLINK-5754:
---
[~shijinkui], from a nice [StackOverflow
[
https://issues.apache.org/jira/browse/FLINK-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15941745#comment-15941745
]
ASF GitHub Bot commented on FLINK-5998:
---
Github user greghogan commented on the issue:
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
[
https://issues.apache.org/jira/browse/FLINK-6185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15941736#comment-15941736
]
Greg Hogan commented on FLINK-6185:
---
There is some [support for this
[
https://issues.apache.org/jira/browse/FLINK-6107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15941731#comment-15941731
]
ASF GitHub Bot commented on FLINK-6107:
---
Github user greghogan commented on the issue:
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=15941718#comment-15941718
]
ASF GitHub Bot commented on FLINK-6107:
---
Github user greghogan commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15941700#comment-15941700
]
ASF GitHub Bot commented on FLINK-3257:
---
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/1668#discussion_r108034229
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamIterationTail.java
---
@@ -64,6 +70,22 @@ public void
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
[
https://issues.apache.org/jira/browse/FLINK-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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=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
[
https://issues.apache.org/jira/browse/FLINK-6187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15941687#comment-15941687
]
Robert Metzger commented on FLINK-6187:
---
Did you configure HA?
Are you sure the {{ip:port}} you've
[
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
>
>
>
[
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=15941679#comment-15941679
]
ASF GitHub Bot commented on FLINK-6189:
---
GitHub user WangTaoTheTonic opened a pull request:
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
[
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=15941659#comment-15941659
]
zhangrucong1982 commented on FLINK-6148:
ok，I will close the issue。
> The Zookeeper client occur
[
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
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=15941637#comment-15941637
]
Haohui Mai commented on FLINK-5829:
---
I just pushed a PR. The migration process is relatively
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
[
https://issues.apache.org/jira/browse/FLINK-5829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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=15941633#comment-15941633
]
CanBin Zheng commented on FLINK-6159:
-
[~StephanEwen]
I'd like to have a try, it deserves.
> Add
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
[
https://issues.apache.org/jira/browse/FLINK-6186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15941627#comment-15941627
]
ASF GitHub Bot commented on FLINK-6186:
---
GitHub user zhengcanbin opened a pull request:
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 @@
[
https://issues.apache.org/jira/browse/FLINK-4562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15941619#comment-15941619
]
ASF GitHub Bot commented on FLINK-4562:
---
Github user shijinkui commented on the issue:
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
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-5698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15941615#comment-15941615
]
ASF GitHub Bot commented on FLINK-5698:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15941614#comment-15941614
]
ASF GitHub Bot commented on FLINK-5658:
---
Github user fhueske commented on a diff in the pull
Yuhong Hong created FLINK-6187:
--
Summary: Cancel job failed with option -m on yarn session
Key: FLINK-6187
URL: https://issues.apache.org/jira/browse/FLINK-6187
Project: Flink
Issue Type: Bug
63 matches
Mail list logo
