[
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
[
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
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
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
[
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 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-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 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-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
[
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:
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=15941637#comment-15941637
]
Haohui Mai commented on FLINK-5829:
---
I just pushed a PR. The migration process is relati
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-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
[
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-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
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-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
> -
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:comment-tabpanel&focusedCommentId=15941679#comment-15941679
]
ASF GitHub Bot commented on FLINK-6189:
---
GitHub user WangTaoTheTonic opened a pull r
[
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-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-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:comment-tabpanel&focusedCommentId=15941687#comment-15941687
]
Robert Metzger commented on FLINK-6187:
---
Did you configure HA?
Are you sure the {{i
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-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
[
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
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
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()
[
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
[
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
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";>
+
+
+
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.
[
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
[
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
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-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
[
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-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-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-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-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: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: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-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
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
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
[
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
[
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-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-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=15941797#comment-15941797
]
Luke Hutchison commented on FLINK-6185:
---
Here's my simple gzip OutputFormat though,
[
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 edited comment on FLINK-6185 at 3/25/17 8:22 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:23 PM:
[
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-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
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
61 matches
Mail list logo
