Maximilian Michels created FLINK-3561:
-
Summary: ExecutionConfig's timestampsEnabled is unused
Key: FLINK-3561
URL: https://issues.apache.org/jira/browse/FLINK-3561
Project: Flink
Issue T
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1752#issuecomment-191159732
That is a good point @vasia. Will add the missing `ProgramDescriptions`.
---
If your project is set up for it, you can reply to this email and have your
reply appea
[
https://issues.apache.org/jira/browse/FLINK-3560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15175353#comment-15175353
]
ASF GitHub Bot commented on FLINK-3560:
---
Github user tillrohrmann commented on the p
[
https://issues.apache.org/jira/browse/FLINK-3560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15175389#comment-15175389
]
ASF GitHub Bot commented on FLINK-3560:
---
Github user tillrohrmann commented on the p
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1752#issuecomment-191171356
Added the missing `ProgramDescriptions`.
---
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 pro
Maximilian Michels created FLINK-3562:
-
Summary: Update docs in the course of EventTimeSourceFunction
removal
Key: FLINK-3562
URL: https://issues.apache.org/jira/browse/FLINK-3562
Project: Flink
GitHub user mbalassi opened a pull request:
https://github.com/apache/flink/pull/1753
[build] Consolidate scala checkstyle usage and update version to 0.8.0
Consolidation is done via plugin management, so that configuration is done
in one central location.
Version update is
Github user ChengXiangLi commented on a diff in the pull request:
https://github.com/apache/flink/pull/1746#discussion_r54706319
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/Aggregate.scala
---
@@ -17,26 +17,77 @@
*/
[
https://issues.apache.org/jira/browse/FLINK-3474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15175412#comment-15175412
]
ASF GitHub Bot commented on FLINK-3474:
---
Github user ChengXiangLi commented on a dif
Github user ChengXiangLi commented on the pull request:
https://github.com/apache/flink/pull/1746#issuecomment-191186632
Hi, @fhueske , i've update the PR based on your comments, except object
reusing in `AggregateGroupCombineFunction`. I found `GroupReduceOperator`
would transform i
[
https://issues.apache.org/jira/browse/FLINK-3474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15175430#comment-15175430
]
ASF GitHub Bot commented on FLINK-3474:
---
Github user ChengXiangLi commented on the p
[
https://issues.apache.org/jira/browse/FLINK-2941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15175434#comment-15175434
]
Vasia Kalavri commented on FLINK-2941:
--
Hey [~mju],
thanks for working on this! I'm v
Simone Robutti created FLINK-3563:
-
Summary: .returns() doesn't compile when using .map() with a
custom MapFunction
Key: FLINK-3563
URL: https://issues.apache.org/jira/browse/FLINK-3563
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-2941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15175453#comment-15175453
]
Chesnay Schepler commented on FLINK-2941:
-
does neo4j have something akin to our f
Timo Walther created FLINK-3564:
---
Summary: Implement distinct() for Table API
Key: FLINK-3564
URL: https://issues.apache.org/jira/browse/FLINK-3564
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-3564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15175522#comment-15175522
]
ASF GitHub Bot commented on FLINK-3564:
---
GitHub user twalthr opened a pull request:
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/1754
[FLINK-3564] [table] Implement distinct() for Table API
Implements some syntactic sugar. Another step towards a SQL-like API.
You can merge this pull request into a Git repository by running:
$
[
https://issues.apache.org/jira/browse/FLINK-3152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15175564#comment-15175564
]
Dawid Wysakowicz commented on FLINK-3152:
-
Hi,
I would happily try to work on this
[
https://issues.apache.org/jira/browse/FLINK-3152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15175570#comment-15175570
]
Timo Walther commented on FLINK-3152:
-
Hi Dawid,
thanks for your interest. We are curr
[
https://issues.apache.org/jira/browse/FLINK-3152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15175570#comment-15175570
]
Timo Walther edited comment on FLINK-3152 at 3/2/16 1:21 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-3152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15175590#comment-15175590
]
Dawid Wysakowicz commented on FLINK-3152:
-
Thanks Timo,
Sure, I will happily work
Aljoscha Krettek created FLINK-3565:
---
Summary: FlinkKafkaConsumer does not work with Scala 2.11
Key: FLINK-3565
URL: https://issues.apache.org/jira/browse/FLINK-3565
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-3565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels reassigned FLINK-3565:
-
Assignee: Maximilian Michels
> FlinkKafkaConsumer does not work with Scala 2.11
[
https://issues.apache.org/jira/browse/FLINK-2941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15175600#comment-15175600
]
Robert Metzger commented on FLINK-2941:
---
Have a look at this discussion at the gene.
[
https://issues.apache.org/jira/browse/FLINK-3152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15175603#comment-15175603
]
Timo Walther commented on FLINK-3152:
-
I think a subtask of [FLINK-3497] would be a go
[
https://issues.apache.org/jira/browse/FLINK-3565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15175609#comment-15175609
]
Maximilian Michels commented on FLINK-3565:
---
Problem: flink-parent contains the
[
https://issues.apache.org/jira/browse/FLINK-3561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15175613#comment-15175613
]
Aljoscha Krettek commented on FLINK-3561:
-
I think so, yes. [~StephanEwen] must ha
[
https://issues.apache.org/jira/browse/FLINK-3565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15175616#comment-15175616
]
Aljoscha Krettek commented on FLINK-3565:
-
I think 2) is the way to go, yes.
> Fl
[
https://issues.apache.org/jira/browse/FLINK-3563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15175641#comment-15175641
]
Timo Walther commented on FLINK-3563:
-
As far as I know, mixing of Scala and Java API
[
https://issues.apache.org/jira/browse/FLINK-3563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15175641#comment-15175641
]
Timo Walther edited comment on FLINK-3563 at 3/2/16 2:11 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-3152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15175657#comment-15175657
]
Fabian Hueske commented on FLINK-3152:
--
Yes, a subtask of FLINK-3497 sounds good. I w
[
https://issues.apache.org/jira/browse/FLINK-3554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15175663#comment-15175663
]
ASF GitHub Bot commented on FLINK-3554:
---
Github user aljoscha commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1750#issuecomment-191260012
Hi,
what are you referring to? The watermark does not interact with count
windows.
---
If your project is set up for it, you can reply to this email and have your
Gyula Fora created FLINK-3566:
-
Summary: Input type validation often fails on custom TypeInfo
implementations
Key: FLINK-3566
URL: https://issues.apache.org/jira/browse/FLINK-3566
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-3566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15175770#comment-15175770
]
Gyula Fora commented on FLINK-3566:
---
Another example with KeySelectors and interfaces:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1685
---
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-3422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15175883#comment-15175883
]
ASF GitHub Bot commented on FLINK-3422:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-3422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi resolved FLINK-3422.
---
Resolution: Fixed
Fixed via 0ff286d and f0f93c2.
> Scramble HashPartitioner hashes
>
[
https://issues.apache.org/jira/browse/FLINK-3565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15176007#comment-15176007
]
Maximilian Michels commented on FLINK-3565:
---
Thanks to [~till.rohrmann], I've co
[
https://issues.apache.org/jira/browse/FLINK-3565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15176012#comment-15176012
]
ASF GitHub Bot commented on FLINK-3565:
---
GitHub user mxm opened a pull request:
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/1755
[FLINK-3565] add module to force execution of Shade plugin
This ensures that all properties of the root pom are properly
resolved by running the Shade plugin. Thus, our root pom does not have
to
[
https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Horvath reassigned FLINK-3322:
Assignee: Gabor Horvath
> MemoryManager creates too much GC pressure with iterative jobs
>
[
https://issues.apache.org/jira/browse/FLINK-3498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15176050#comment-15176050
]
ASF GitHub Bot commented on FLINK-3498:
---
Github user fhueske commented on the pull r
[
https://issues.apache.org/jira/browse/FLINK-3474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15176059#comment-15176059
]
ASF GitHub Bot commented on FLINK-3474:
---
Github user fhueske commented on the pull r
[
https://issues.apache.org/jira/browse/FLINK-3565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15176060#comment-15176060
]
ASF GitHub Bot commented on FLINK-3565:
---
Github user rmetzger commented on the pull
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1746#issuecomment-191343405
Yes, you are right.
We need a `RichCombineToGroupCombineWrapper` and inject it as a temporary
fix until we have dedicated drivers for `CombineFunction`.
---
If yo
[
https://issues.apache.org/jira/browse/FLINK-3474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15176085#comment-15176085
]
ASF GitHub Bot commented on FLINK-3474:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1746#discussion_r54761986
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/Aggregate.scala
---
@@ -17,26 +17,77 @@
*/
packa
[
https://issues.apache.org/jira/browse/FLINK-3474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15176104#comment-15176104
]
ASF GitHub Bot commented on FLINK-3474:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1746#discussion_r54763270
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateReduceGroupFunction.scala
---
@@ -0,0 +1,198 @@
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1755#issuecomment-191343477
+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
e
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1755
---
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-3565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15176241#comment-15176241
]
ASF GitHub Bot commented on FLINK-3565:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-3565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-3565.
---
Resolution: Fixed
Fix Version/s: 1.1.0
1.0.0
Resolved for 1.0 in htt
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1747#issuecomment-191341765
OK, I see. Sounds good to me.
+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 p
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1754#discussion_r54808671
--- Diff:
flink-libraries/flink-table/src/test/java/org/apache/flink/api/java/table/test/DistinctITCase.java
---
@@ -0,0 +1,92 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-3564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15176672#comment-15176672
]
ASF GitHub Bot commented on FLINK-3564:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1754#discussion_r54808793
--- Diff:
flink-libraries/flink-table/src/test/java/org/apache/flink/api/java/table/test/DistinctITCase.java
---
@@ -0,0 +1,92 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-3564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15176674#comment-15176674
]
ASF GitHub Bot commented on FLINK-3564:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1754#discussion_r54814006
--- Diff:
flink-libraries/flink-table/src/test/java/org/apache/flink/api/java/table/test/DistinctITCase.java
---
@@ -0,0 +1,92 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-3564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15176735#comment-15176735
]
ASF GitHub Bot commented on FLINK-3564:
---
Github user fhueske commented on a diff in
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1738#issuecomment-191502994
Will merge this to `tableOnCalcite` branch.
---
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 proje
[
https://issues.apache.org/jira/browse/FLINK-3486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15176766#comment-15176766
]
ASF GitHub Bot commented on FLINK-3486:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1747#issuecomment-191503064
Will merge this to `tableOnCalcite` branch.
---
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 proje
[
https://issues.apache.org/jira/browse/FLINK-3498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15176768#comment-15176768
]
ASF GitHub Bot commented on FLINK-3498:
---
Github user fhueske commented on the pull r
Github user wenlonglwl commented on the pull request:
https://github.com/apache/flink/pull/1750#issuecomment-191534452
just want to remind, this dose not completely solve the problem of loss of
pending windows over finite sources~ looking forward to the solutions~
---
If your project
[
https://issues.apache.org/jira/browse/FLINK-3554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15176939#comment-15176939
]
ASF GitHub Bot commented on FLINK-3554:
---
Github user wenlonglwl commented on the pul
GitHub user wuchong opened a pull request:
https://github.com/apache/flink/pull/1756
[docs] fix javascript exception caused by disqus
As we comment `` but not the disqus
javascript. It will cause a exception like this:
