Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1734#issuecomment-190601248
Thanks!
---
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
[
https://issues.apache.org/jira/browse/FLINK-3504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15173403#comment-15173403
]
ASF GitHub Bot commented on FLINK-3504:
---
Github user fhueske commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15173400#comment-15173400
]
ASF GitHub Bot commented on FLINK-3537:
---
Github user fhueske commented on the pull request:
Github user fhueske closed the pull request at:
https://github.com/apache/flink/pull/1734
---
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-3504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15173404#comment-15173404
]
ASF GitHub Bot commented on FLINK-3504:
---
Github user fhueske closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-3537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15173401#comment-15173401
]
ASF GitHub Bot commented on FLINK-3537:
---
Github user fhueske closed the pull request at:
Github user fhueske closed the pull request at:
https://github.com/apache/flink/pull/1733
---
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-3178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15173369#comment-15173369
]
ASF GitHub Bot commented on FLINK-3178:
---
Github user wenlonglwl commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15173359#comment-15173359
]
ASF GitHub Bot commented on FLINK-3504:
---
Github user vasia commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15173357#comment-15173357
]
ASF GitHub Bot commented on FLINK-3537:
---
Github user vasia commented on the pull request:
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1734#issuecomment-190585140
You can close this one too @fhueske.
---
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
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1733#issuecomment-190585080
You can close this @fhueske.
---
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-3422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15173356#comment-15173356
]
ASF GitHub Bot commented on FLINK-3422:
---
Github user mbalassi commented on the pull request:
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/1685#issuecomment-190584934
If no objections will merge this tomorrow morning.
---
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-3474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15173242#comment-15173242
]
ASF GitHub Bot commented on FLINK-3474:
---
GitHub user ChengXiangLi opened a pull request:
GitHub user ChengXiangLi opened a pull request:
https://github.com/apache/flink/pull/1746
[FLINK-3474] support partial aggregate
This PR includes:
* New aggregate interface which support partial aggregate.
* Simple aggregate function implementation, such as
Github user wenlonglwl commented on the pull request:
https://github.com/apache/flink/pull/1562#issuecomment-190511772
Hi, @aljoscha , I am confused about the change you make in this issue,
that makes RichFunction not supported in the aggregation function of the
windowed stream,
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/1745
[FLINK-3550] [FLINK-3552] Rework WindowJoin and SocketWindowWordCount
example
__Note: This is based on #1744__
This pull request give some of the example a more proper streaming
[
https://issues.apache.org/jira/browse/FLINK-3550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172725#comment-15172725
]
ASF GitHub Bot commented on FLINK-3550:
---
GitHub user StephanEwen opened a pull request:
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/1744
[FLINK-2788] [apis] Add TypeHint class to allow type-safe generic type
parsing
This adds the `TypeHint` as a type-safe way to create `TypeInformation` for
generic types. I think it should
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1743#issuecomment-190418707
Looks good (even though I personally prefer to not use the underscores in
inline functions).
+1
---
If your project is set up for it, you can reply to
[
https://issues.apache.org/jira/browse/FLINK-3504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172700#comment-15172700
]
ASF GitHub Bot commented on FLINK-3504:
---
Github user vasia commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172697#comment-15172697
]
ASF GitHub Bot commented on FLINK-3537:
---
Github user vasia commented on the pull request:
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1734#issuecomment-190417170
Merging this one too!
---
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
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1733#issuecomment-190417099
I'm merging this.
---
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
GitHub user vasia opened a pull request:
https://github.com/apache/flink/pull/1743
[docs] fix readme typos; use the same scala style in the examples
Fixes issues with #1736 I didn't have to report ;)
You can merge this pull request into a Git repository by running:
$ git pull
Stephan Ewen created FLINK-3552:
---
Summary: Change socket WordCount to be properly windowed
Key: FLINK-3552
URL: https://issues.apache.org/jira/browse/FLINK-3552
Project: Flink
Issue Type:
Stephan Ewen created FLINK-3551:
---
Summary: Sync Scala and Java Streaming Examples
Key: FLINK-3551
URL: https://issues.apache.org/jira/browse/FLINK-3551
Project: Flink
Issue Type: Sub-task
Stephan Ewen created FLINK-3550:
---
Summary: Rework stream join example
Key: FLINK-3550
URL: https://issues.apache.org/jira/browse/FLINK-3550
Project: Flink
Issue Type: Sub-task
Stephan Ewen created FLINK-3549:
---
Summary: Make streaming examples more streaming
Key: FLINK-3549
URL: https://issues.apache.org/jira/browse/FLINK-3549
Project: Flink
Issue Type: Improvement
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1742#issuecomment-190372453
+1
I think this is a very good cleanup fix, and it only breaks binary
compatibility, not source compatibility...
---
If your project is set up for it, you
[
https://issues.apache.org/jira/browse/FLINK-3540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-3540.
---
Resolution: Fixed
Fix Version/s: 1.1.0
1.0.0
Resolved in master for
[
https://issues.apache.org/jira/browse/FLINK-3540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172511#comment-15172511
]
ASF GitHub Bot commented on FLINK-3540:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1737
---
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-3540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172496#comment-15172496
]
ASF GitHub Bot commented on FLINK-3540:
---
Github user rmetzger commented on the pull request:
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1737#issuecomment-190356055
Merging ...
---
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
[
https://issues.apache.org/jira/browse/FLINK-3536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved FLINK-3536.
-
Resolution: Fixed
Fix Version/s: 1.0.0
Fixed in
[
https://issues.apache.org/jira/browse/FLINK-3536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172487#comment-15172487
]
ASF GitHub Bot commented on FLINK-3536:
---
Github user aljoscha closed the pull request at:
Github user aljoscha closed the pull request at:
https://github.com/apache/flink/pull/1739
---
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-3538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved FLINK-3538.
-
Resolution: Fixed
Fix Version/s: 1.0.0
Fixed in
Github user aljoscha closed the pull request at:
https://github.com/apache/flink/pull/1740
---
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-3538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172441#comment-15172441
]
ASF GitHub Bot commented on FLINK-3538:
---
Github user aljoscha closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-3548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172435#comment-15172435
]
ASF GitHub Bot commented on FLINK-3548:
---
GitHub user aljoscha opened a pull request:
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/1742
[FLINK-3548] [api-breaking] Remove unnecessary generic parameter fromâ¦
⦠SingleOutputStreamOperator
You can merge this pull request into a Git repository by running:
$ git pull
[
https://issues.apache.org/jira/browse/FLINK-3535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-3535.
--
Resolution: Fixed
Fix Version/s: 1.1.0
1.0.0
Fixed in 9580b8f (master).
Fixed
[
https://issues.apache.org/jira/browse/FLINK-3535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172424#comment-15172424
]
ASF GitHub Bot commented on FLINK-3535:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1732
---
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-3535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172421#comment-15172421
]
ASF GitHub Bot commented on FLINK-3535:
---
Github user uce commented on the pull request:
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1732#issuecomment-190338229
Build failures are unrelated and my local Travis build was successful.
Merging to master and release-1.0.
---
If your project is set up for it, you can reply to this email
[
https://issues.apache.org/jira/browse/FLINK-3534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-3534.
--
Resolution: Fixed
Fix Version/s: 1.1.0
1.0.0
Fixed in 734ba01 (master).
Fixed
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1735
---
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-3534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172418#comment-15172418
]
ASF GitHub Bot commented on FLINK-3534:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-3534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172350#comment-15172350
]
ASF GitHub Bot commented on FLINK-3534:
---
Github user uce commented on the pull request:
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1735#issuecomment-190327892
My local [Travis build has
passed](https://travis-ci.org/uce/flink/builds/112634854). I will merge this to
`master` and `release-1.0`.
---
If your project is set up for
[
https://issues.apache.org/jira/browse/FLINK-2788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen reassigned FLINK-2788:
---
Assignee: Stephan Ewen
> Add type hint with TypeExtactor call on Hint Type
>
[
https://issues.apache.org/jira/browse/FLINK-3536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172298#comment-15172298
]
ASF GitHub Bot commented on FLINK-3536:
---
Github user aljoscha commented on the pull request:
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1739#issuecomment-190319471
I think it would be good to have it in, yes.
---
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
Aljoscha Krettek created FLINK-3548:
---
Summary: Remove unnecessary generic parameter from
SingleOutputStreamOperator
Key: FLINK-3548
URL: https://issues.apache.org/jira/browse/FLINK-3548
Project:
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1739#issuecomment-190318168
Would you like to make this part of the 1.0.0 RC3?
---
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-3536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172290#comment-15172290
]
ASF GitHub Bot commented on FLINK-3536:
---
Github user rmetzger commented on the pull request:
Vasia Kalavri created FLINK-3547:
Summary: Add support for streaming projection, selection, and union
Key: FLINK-3547
URL: https://issues.apache.org/jira/browse/FLINK-3547
Project: Flink
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1740#issuecomment-190315085
I think it's simply "api breaking". Will add the tag and merge. ok? Will
then also put it on the release-1.0 branch.
---
If your project is set up for it, you can
Vasia Kalavri created FLINK-3546:
Summary: Streaming Table API
Key: FLINK-3546
URL: https://issues.apache.org/jira/browse/FLINK-3546
Project: Flink
Issue Type: New Feature
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/1741
[FLINK-3544] Introduce ResourceManager component
So far the JobManager has been the central instance which is responsible
for resource management and allocation.
While thinking about how to
[
https://issues.apache.org/jira/browse/FLINK-3544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172214#comment-15172214
]
ASF GitHub Bot commented on FLINK-3544:
---
GitHub user mxm opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172208#comment-15172208
]
ASF GitHub Bot commented on FLINK-3538:
---
Github user tillrohrmann commented on the pull request:
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1740#issuecomment-190305207
Changes look good to me. Good work @aljoscha :-)
---
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-3538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172200#comment-15172200
]
ASF GitHub Bot commented on FLINK-3538:
---
Github user tillrohrmann commented on the pull request:
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1740#issuecomment-190303294
I think the changes are source API breaking since the return type of
`where`, `equalTo` and `join` changed.
---
If your project is set up for it, you can reply
[
https://issues.apache.org/jira/browse/FLINK-3538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172185#comment-15172185
]
ASF GitHub Bot commented on FLINK-3538:
---
Github user StephanEwen commented on the pull request:
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1740#issuecomment-190299923
Code looks good. Let's see if Travis agrees.
This code is *Binary-API-Breaking, but not *Source-API-Breaking*, correct?
Can you tag the commit?
---
If your
[
https://issues.apache.org/jira/browse/FLINK-3222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3222:
--
Description:
Here is related code:
{code}
result = 31 * result + (int) (subTaskStats.length ^
[
https://issues.apache.org/jira/browse/FLINK-3534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172157#comment-15172157
]
ASF GitHub Bot commented on FLINK-3534:
---
Github user StephanEwen commented on the pull request:
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1735#issuecomment-190293717
True, that is rather ugly behavior. I guess the important thing is that at
least one of the Executions results in state `failed`.
---
If your project is set up for
Maximilian Michels created FLINK-3545:
-
Summary: ResourceManager: YARN integration
Key: FLINK-3545
URL: https://issues.apache.org/jira/browse/FLINK-3545
Project: Flink
Issue Type:
Maximilian Michels created FLINK-3544:
-
Summary: ResourceManager runtime components
Key: FLINK-3544
URL: https://issues.apache.org/jira/browse/FLINK-3544
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-3534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172150#comment-15172150
]
ASF GitHub Bot commented on FLINK-3534:
---
Github user uce commented on the pull request:
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1735#issuecomment-190291277
I've fixed the test failures.
@StephanEwen, the changes can result in the following behaviour: if a slot
is released, some of its executions can end up in cancelled
[
https://issues.apache.org/jira/browse/FLINK-3543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-3543:
--
Attachment: ResourceManagerSketch.pdf
An overview of the message flow.
> Introduce
Maximilian Michels created FLINK-3543:
-
Summary: Introduce ResourceManager component
Key: FLINK-3543
URL: https://issues.apache.org/jira/browse/FLINK-3543
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-3538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172118#comment-15172118
]
ASF GitHub Bot commented on FLINK-3538:
---
GitHub user aljoscha opened a pull request:
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/1740
[FLINK-3538] Streamline Scala DataStream.join/coGroup
This enforces that the user always has to specify keys for both inputs
before .window() can be called.
You can merge this pull request
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/1739
[FLINK-3536] Make clearer distinction between event time and processiâ¦
â¦ng time
This brings it more in line with *ProcessingTimeWindows and makes it
clear what type of window
[
https://issues.apache.org/jira/browse/FLINK-3538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-3538:
---
Assignee: Aljoscha Krettek
> DataStream join API does not enforce consistent usage
>
[
https://issues.apache.org/jira/browse/FLINK-3536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-3536:
---
Assignee: Aljoscha Krettek
> Make clearer distinction between event time and
Github user senorcarbone commented on the pull request:
https://github.com/apache/flink/pull/1668#issuecomment-190279441
You can find an alternative version using `ListState` in the following
branch:
https://github.com/senorcarbone/flink/commits/ftloopsalt
So I noticed that
[
https://issues.apache.org/jira/browse/FLINK-3257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172094#comment-15172094
]
ASF GitHub Bot commented on FLINK-3257:
---
Github user senorcarbone commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172085#comment-15172085
]
ASF GitHub Bot commented on FLINK-3486:
---
Github user fhueske commented on the pull request:
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1738#issuecomment-190276423
I fixed the failing tests.
---
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
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1738#discussion_r54430812
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/table.scala
---
@@ -98,7 +100,19 @@ class Table(
[
https://issues.apache.org/jira/browse/FLINK-3504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172069#comment-15172069
]
ASF GitHub Bot commented on FLINK-3504:
---
Github user vasia commented on the pull request:
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1734#issuecomment-190272164
looks good, thanks!
---
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
[
https://issues.apache.org/jira/browse/FLINK-3486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172056#comment-15172056
]
ASF GitHub Bot commented on FLINK-3486:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172050#comment-15172050
]
ASF GitHub Bot commented on FLINK-3486:
---
Github user vasia commented on a diff in the pull request:
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1736#discussion_r54428884
--- Diff: README.md ---
@@ -34,21 +69,23 @@ Prerequisites for building Flink:
* Unix-like environment (We use Linux, Mac OS X, Cygwin)
*
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1738#discussion_r54430318
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/table.scala
---
@@ -98,7 +100,19 @@ class Table(
.map(toRexNode(_,
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1734#issuecomment-190267290
I added a commit to catch Calcite's planner exception and extend the error
message.
---
If your project is set up for it, you can reply to this email and have your
[
https://issues.apache.org/jira/browse/FLINK-3504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172044#comment-15172044
]
ASF GitHub Bot commented on FLINK-3504:
---
Github user fhueske commented on the pull request:
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1736#discussion_r54428143
--- Diff: README.md ---
@@ -1,10 +1,55 @@
# Apache Flink
-Apache Flink is an open source platform for scalable batch and stream data
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1736#discussion_r54428408
--- Diff: README.md ---
@@ -1,10 +1,55 @@
# Apache Flink
-Apache Flink is an open source platform for scalable batch and stream data
1 - 100 of 177 matches
Mail list logo
