[
https://issues.apache.org/jira/browse/FLINK-2941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15179492#comment-15179492
]
Martin Junghanns commented on FLINK-2941:
-
Hi, thank you guys for the input! Forking it into
Github user ramkrish86 commented on the pull request:
https://github.com/apache/flink/pull/1553#issuecomment-192131350
New PR submitted @fhueske . Thanks for helping me thro this code review. It
is was more of a beginner and there is a lot to learn from my side.
---
If your project
[
https://issues.apache.org/jira/browse/FLINK-3179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15179424#comment-15179424
]
ASF GitHub Bot commented on FLINK-3179:
---
Github user ramkrish86 commented on the pull request:
Ted Yu created FLINK-3576:
-
Summary: Upgrade Snappy Java to 1.1.2.1
Key: FLINK-3576
URL: https://issues.apache.org/jira/browse/FLINK-3576
Project: Flink
Issue Type: Improvement
Reporter:
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1756#issuecomment-191915950
This looks like a good fix, thanks for contributing!
+1 to merge this
---
If your project is set up for it, you can reply to this email and have your
reply
[
https://issues.apache.org/jira/browse/FLINK-3566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15178113#comment-15178113
]
ASF GitHub Bot commented on FLINK-3566:
---
Github user chobeat commented on the pull request:
Github user chobeat commented on the pull request:
https://github.com/apache/flink/pull/1759#issuecomment-191857083
I tested it too and it works perfectly both on an example case and in the
code where the problem arose.
---
If your project is set up for it, you can reply to this
[
https://issues.apache.org/jira/browse/FLINK-3569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15178079#comment-15178079
]
Maximilian Michels commented on FLINK-3569:
---
I'll open a new pull request once I have fixed the
[
https://issues.apache.org/jira/browse/FLINK-3380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-3380:
Labels: test-stability (was: )
> Unstable Test: JobSubmissionFailsITCase
>
[
https://issues.apache.org/jira/browse/FLINK-3569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15178070#comment-15178070
]
ASF GitHub Bot commented on FLINK-3569:
---
Github user mxm commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15178071#comment-15178071
]
ASF GitHub Bot commented on FLINK-3569:
---
Github user mxm closed the pull request at:
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1757#issuecomment-191842883
Setting the Surefire working directory is not possible because the Shade
plugin changes the basedir beforehand. We will have to change the test cases
for now if we don't
[
https://issues.apache.org/jira/browse/FLINK-2369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-2369.
---
Resolution: Fixed
Fix Version/s: 1.0.0
> On Windows, in testFailingSortingDataSinkTask
[
https://issues.apache.org/jira/browse/FLINK-2757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-2757.
---
Resolution: Fixed
Fixed via ff4fbf9bfb5107a6f4d0cbd040f36d583065aa4a
> DataSinkTaskTest
[
https://issues.apache.org/jira/browse/FLINK-3495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-3495:
---
Assignee: Chesnay Schepler
> RocksDB Tests can't run on Windows
>
[
https://issues.apache.org/jira/browse/FLINK-3507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-3507:
Component/s: Table API
> PruneEmptyRules does not prune empty node as expected.
>
[
https://issues.apache.org/jira/browse/FLINK-3484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved FLINK-3484.
-
Resolution: Fixed
Added here:
[
https://issues.apache.org/jira/browse/FLINK-3574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-3574:
Assignee: Dawid Wysakowicz
> Implement math functions for Table API
>
[
https://issues.apache.org/jira/browse/FLINK-3403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved FLINK-3403.
-
Resolution: Fixed
Added
> Create Section "Working with Time" in Streaming Guide
>
[
https://issues.apache.org/jira/browse/FLINK-3575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15178001#comment-15178001
]
ASF GitHub Bot commented on FLINK-3575:
---
GitHub user aljoscha opened a pull request:
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/1760
[FLINK-3575] Update Working With State Section in Doc
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aljoscha/flink doc-update-state
[
https://issues.apache.org/jira/browse/FLINK-3566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15177982#comment-15177982
]
ASF GitHub Bot commented on FLINK-3566:
---
Github user gyfora commented on the pull request:
Aljoscha Krettek created FLINK-3575:
---
Summary: Update Working With State Section in Doc
Key: FLINK-3575
URL: https://issues.apache.org/jira/browse/FLINK-3575
Project: Flink
Issue Type:
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/1759#issuecomment-191821834
I tested it in my application where I was previously having both issues.
Now it works perfectly, thanks!
+1 from me :+1:
---
If your project is set up
[
https://issues.apache.org/jira/browse/FLINK-3432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15177952#comment-15177952
]
ASF GitHub Bot commented on FLINK-3432:
---
Github user tillrohrmann commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-3432.
--
Resolution: Fixed
Fixed via a52f9d8628b03cc6c223dfda33ae93d2fe16c27c
>
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1664
---
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
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1664#issuecomment-191814477
Will merge it. Thanks for your contribution @zentol :-)
---
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-3152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15177953#comment-15177953
]
Dawid Wysakowicz commented on FLINK-3152:
-
Great, thanks a lot. I will take it.
> Support all
[
https://issues.apache.org/jira/browse/FLINK-3573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther reassigned FLINK-3573:
---
Assignee: Timo Walther
> Implement more String functions for Table API
>
[
https://issues.apache.org/jira/browse/FLINK-3152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15177949#comment-15177949
]
Timo Walther commented on FLINK-3152:
-
[~dawidwys] I just created [FLINK-3574]. It is not too
[
https://issues.apache.org/jira/browse/FLINK-2523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15177939#comment-15177939
]
ASF GitHub Bot commented on FLINK-2523:
---
Github user tillrohrmann commented on the pull request:
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1662#issuecomment-191812912
Thanks for your contribution @kl0u. Changes for the task cancellation
interval look good.
Maybe it would be good to add a test case which makes sure that
Timo Walther created FLINK-3574:
---
Summary: Implement math functions for Table API
Key: FLINK-3574
URL: https://issues.apache.org/jira/browse/FLINK-3574
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-3573:
---
Summary: Implement more String functions for Table API
Key: FLINK-3573
URL: https://issues.apache.org/jira/browse/FLINK-3573
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-3467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15177934#comment-15177934
]
ASF GitHub Bot commented on FLINK-3467:
---
Github user tillrohrmann commented on the pull request:
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1691#issuecomment-191809419
Thanks for your contribution @greghogan. Changes look good to me. +1 for
merging :-)
---
If your project is set up for it, you can reply to this email and have
[
https://issues.apache.org/jira/browse/FLINK-3571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi reassigned FLINK-3571:
--
Assignee: Ufuk Celebi
> SavepointITCase.testRestoreFailure fails on Travis
>
[
https://issues.apache.org/jira/browse/FLINK-3454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15177929#comment-15177929
]
ASF GitHub Bot commented on FLINK-3454:
---
Github user tillrohrmann commented on the pull request:
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1698#issuecomment-191806709
I think, this does not solve the problem of the test. The test case
`ScalaShellITCase.testSubmissionOfExternalLibrary` expects that `flink-ml` has
been packaged,
[
https://issues.apache.org/jira/browse/FLINK-3563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15177925#comment-15177925
]
Timo Walther commented on FLINK-3563:
-
[~chobeat] can you check if
[
https://issues.apache.org/jira/browse/FLINK-3566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15177921#comment-15177921
]
ASF GitHub Bot commented on FLINK-3566:
---
GitHub user twalthr opened a pull request:
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/1759
[FLINK-3566] [FLINK-3563] Input type validation improvements
This PR fixes issues with the input type validation.
[FLINK-3566] Custom type information have been interpreted as basic or
[
https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15177907#comment-15177907
]
ASF GitHub Bot commented on FLINK-1159:
---
Github user tillrohrmann commented on the pull request:
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1704#issuecomment-191799798
There are scalastyle violations in the code:
```
error
[
https://issues.apache.org/jira/browse/FLINK-3496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15177903#comment-15177903
]
ASF GitHub Bot commented on FLINK-3496:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1710
---
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-3496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-3496.
--
Resolution: Fixed
Fixed via b02ee764b022683ff3ca1b739bfe8d58a298f103
> Flink-ml tests fail on
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/1753#issuecomment-191797058
Thanks or catching it, pushed the fix.
---
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
Till Rohrmann created FLINK-3572:
Summary: SourceStreamTaskTest.testCheckpointing fails on Travis
Key: FLINK-3572
URL: https://issues.apache.org/jira/browse/FLINK-3572
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-3496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15177901#comment-15177901
]
ASF GitHub Bot commented on FLINK-3496:
---
Github user tillrohrmann commented on the pull request:
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1710#issuecomment-191796890
Will merge it.
---
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
Till Rohrmann created FLINK-3571:
Summary: SavepointITCase.testRestoreFailure fails on Travis
Key: FLINK-3571
URL: https://issues.apache.org/jira/browse/FLINK-3571
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-3563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15177871#comment-15177871
]
Timo Walther commented on FLINK-3563:
-
I think I have identified the problem. I will open a PR later.
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1750#issuecomment-191781217
So, the semantics are that at the end of a finite source, the "end of event
time" is reached, which would make the emission of pending event time
semantically
[
https://issues.apache.org/jira/browse/FLINK-3554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15177858#comment-15177858
]
ASF GitHub Bot commented on FLINK-3554:
---
Github user StephanEwen commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Klou reassigned FLINK-3429:
---
Assignee: Klou
> Add histogram-based timestamp/watermark extractor
>
[
https://issues.apache.org/jira/browse/FLINK-2941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15177835#comment-15177835
]
Vitor Santos Vieira commented on FLINK-2941:
I believe that this same situation will occur
[
https://issues.apache.org/jira/browse/FLINK-3563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15177831#comment-15177831
]
Simone Robutti commented on FLINK-3563:
---
Anyway I just rewrote a good part of the library I was
[
https://issues.apache.org/jira/browse/FLINK-3570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15177811#comment-15177811
]
ASF GitHub Bot commented on FLINK-3570:
---
GitHub user tillrohrmann opened a pull request:
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/1758
[FLINK-3570] [runtime] Use InetAddress.getLocalHost() as heuristic to find
local address
The ConnectionUtils.findAddressUsingStrategy method tries to find out the
local address which is
[
https://issues.apache.org/jira/browse/FLINK-3568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15177785#comment-15177785
]
Chesnay Schepler commented on FLINK-3568:
-
according to HADOOP-10614 this was already fixed.
>
[
https://issues.apache.org/jira/browse/FLINK-3569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15177782#comment-15177782
]
ASF GitHub Bot commented on FLINK-3569:
---
Github user mxm commented on the pull request:
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1757#issuecomment-191752822
Sorry, still failing (wasn't failing in my machine). I'll look into it.
---
If your project is set up for it, you can reply to this email and have your
reply appear on
Till Rohrmann created FLINK-3570:
Summary: Replace random NIC selection heuristic by
InetAddress.getLocalHost
Key: FLINK-3570
URL: https://issues.apache.org/jira/browse/FLINK-3570
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-3179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1519#comment-1519
]
ASF GitHub Bot commented on FLINK-3179:
---
Github user fhueske commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15177765#comment-15177765
]
ASF GitHub Bot commented on FLINK-3179:
---
Github user ramkrish86 commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther reassigned FLINK-3563:
---
Assignee: Timo Walther
> .returns() doesn't compile when using .map() with a custom
[
https://issues.apache.org/jira/browse/FLINK-3568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15177733#comment-15177733
]
Moritz Schubotz commented on FLINK-3568:
Thanks for your report. However, I would classify with
[
https://issues.apache.org/jira/browse/FLINK-3569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15177717#comment-15177717
]
ASF GitHub Bot commented on FLINK-3569:
---
GitHub user mxm opened a pull request:
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/1757
[FLINK-3569] set Maven Surefire working directory
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mxm/flink FLINK-3569
Alternatively you can
Maximilian Michels created FLINK-3569:
-
Summary: Test cases fail due to Maven Shade plugin
Key: FLINK-3569
URL: https://issues.apache.org/jira/browse/FLINK-3569
Project: Flink
Issue
Sebastian Neef created FLINK-3568:
-
Summary: Hadoop's Bzip decompression is not thread safe
Key: FLINK-3568
URL: https://issues.apache.org/jira/browse/FLINK-3568
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-3562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3562.
-
Resolution: Fixed
Assignee: Stephan Ewen
Fixed in
- 1.0.1 via
[
https://issues.apache.org/jira/browse/FLINK-3562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3562.
---
> Update docs in the course of EventTimeSourceFunction removal
>
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1755#issuecomment-191703337
The issue is that we use relative paths to JARs in the tests. The Shade
plugin changes the working directory. Will provide a fix.
---
If your project is set up for it, you
[
https://issues.apache.org/jira/browse/FLINK-3565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15177658#comment-15177658
]
ASF GitHub Bot commented on FLINK-3565:
---
Github user mxm commented on the pull request:
Timo Walther created FLINK-3567:
---
Summary: Rework selection when grouping in Table API
Key: FLINK-3567
URL: https://issues.apache.org/jira/browse/FLINK-3567
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-3566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15177648#comment-15177648
]
Gyula Fora commented on FLINK-3566:
---
Thanks Timo :)
> Input type validation often fails on custom
[
https://issues.apache.org/jira/browse/FLINK-3566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15177641#comment-15177641
]
Timo Walther commented on FLINK-3566:
-
Thanks for the examples. I will look into it.
> Input type
[
https://issues.apache.org/jira/browse/FLINK-3566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther reassigned FLINK-3566:
---
Assignee: Timo Walther
> Input type validation often fails on custom TypeInfo
[
https://issues.apache.org/jira/browse/FLINK-3564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15177636#comment-15177636
]
ASF GitHub Bot commented on FLINK-3564:
---
Github user twalthr commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15177635#comment-15177635
]
Stephan Ewen commented on FLINK-3562:
-
Fixed the javadocs for 1.0 and 1.1
> Update docs in the course
Github user twalthr commented on the pull request:
https://github.com/apache/flink/pull/1754#issuecomment-191699364
@fhueske I corrected the tests and rebased. I will create an issue for the
wrong aggregation usage.
---
If your project is set up for it, you can reply to this email
[
https://issues.apache.org/jira/browse/FLINK-3474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15177634#comment-15177634
]
ASF GitHub Bot commented on FLINK-3474:
---
Github user ChengXiangLi commented on the pull request:
Github user ChengXiangLi commented on the pull request:
https://github.com/apache/flink/pull/1746#issuecomment-191698778
Thanks, @fhueske , i've updated the PR.
---
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
[
https://issues.apache.org/jira/browse/FLINK-3554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15177619#comment-15177619
]
ASF GitHub Bot commented on FLINK-3554:
---
Github user aljoscha commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15177618#comment-15177618
]
ASF GitHub Bot commented on FLINK-3565:
---
Github user rmetzger commented on the pull request:
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1750#issuecomment-191695612
Yes, right now we favor correctness over completeness. For example in a
Count window, if we emitted an unfinished count window then the count of the
elements in the
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1755#issuecomment-191695544
The change breaks the tests:
https://travis-ci.org/apache/flink/builds/113179846
---
If your project is set up for it, you can reply to this email and have your
reply
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1750#issuecomment-191694897
It is a matter of how we want to define the semantics.
For windows that do not depend on event time, should incomplete windows be
emitted or not? There are
[
https://issues.apache.org/jira/browse/FLINK-3554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15177614#comment-15177614
]
ASF GitHub Bot commented on FLINK-3554:
---
Github user StephanEwen commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15177609#comment-15177609
]
ASF GitHub Bot commented on FLINK-3554:
---
Github user aljoscha commented on the pull request:
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1750#issuecomment-191693706
Yes, you are right and we are thinking about it.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
[
https://issues.apache.org/jira/browse/FLINK-3562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-3562:
--
Assignee: (was: Maximilian Michels)
> Update docs in the course of
[
https://issues.apache.org/jira/browse/FLINK-3474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15177586#comment-15177586
]
ASF GitHub Bot commented on FLINK-3474:
---
Github user fhueske commented on the pull request:
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1746#issuecomment-191689616
Hi @ChengXiangLi, you need copy this code snippet from
`DataSetGroupReduce.translateToPlan()` to `DataSetMap.translateToPlan()` to
enforce `Row` as input type:
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1562#issuecomment-191683975
Okay, that sounds like a design flaw in hiding the aggregating functions
completely from the window operator in the state. I think the operator should
be aware of
[
https://issues.apache.org/jira/browse/FLINK-3474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15177576#comment-15177576
]
ASF GitHub Bot commented on FLINK-3474:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1746#discussion_r54857042
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/Aggregate.scala
---
@@ -17,26 +17,77 @@
*/
1 - 100 of 113 matches
Mail list logo
