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
enable
[
https://issues.apache.org/jira/browse/FLINK-3504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15173403#comment-15173403
]
ASF GitHub Bot commented on FLINK-3504:
---
Github user fhueske commented on the pull r
[
https://issues.apache.org/jira/browse/FLINK-3537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15173400#comment-15173400
]
ASF GitHub Bot commented on FLINK-3537:
---
Github user fhueske commented on the pull r
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 ena
[
https://issues.apache.org/jira/browse/FLINK-3504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15173404#comment-15173404
]
ASF GitHub Bot commented on FLINK-3504:
---
Github user fhueske closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-3537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15173401#comment-15173401
]
ASF GitHub Bot commented on FLINK-3537:
---
Github user fhueske closed the pull request
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 ena
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1733#issuecomment-190601208
Thanks, @vasia
---
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 featur
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1743
---
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 wenlonglwl commented on the pull request:
https://github.com/apache/flink/pull/1542#issuecomment-190586930
@aljoscha @StephanEwen This would not work for finite stream, data of
in-flight window would lost, when the stream finished. Can this clear window
operator changed to
[
https://issues.apache.org/jira/browse/FLINK-3178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15173369#comment-15173369
]
ASF GitHub Bot commented on FLINK-3178:
---
Github user wenlonglwl commented on the pul
[
https://issues.apache.org/jira/browse/FLINK-3504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15173359#comment-15173359
]
ASF GitHub Bot commented on FLINK-3504:
---
Github user vasia commented on the pull req
[
https://issues.apache.org/jira/browse/FLINK-3537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15173357#comment-15173357
]
ASF GitHub Bot commented on FLINK-3537:
---
Github user vasia commented on the pull req
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 n
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&focusedCommentId=15173356#comment-15173356
]
ASF GitHub Bot commented on FLINK-3422:
---
Github user mbalassi commented on the pull
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 yo
[
https://issues.apache.org/jira/browse/FLINK-3474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15173242#comment-15173242
]
ASF GitHub Bot commented on FLINK-3474:
---
GitHub user ChengXiangLi opened a pull requ
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 SUM/AVG/COUNT/MIN/
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, wha
[
https://issues.apache.org/jira/browse/FLINK-3550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15172725#comment-15172725
]
ASF GitHub Bot commented on FLINK-3550:
---
GitHub user StephanEwen opened a pull reque
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 feeling
[
https://issues.apache.org/jira/browse/FLINK-2788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15172718#comment-15172718
]
ASF GitHub Bot commented on FLINK-2788:
---
GitHub user StephanEwen opened a pull reque
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 gradu
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1743#issuecomment-190420580
I can change it back, but I chose this because this is how it's also
implemented in `SocketTextStreamWordCount.scala`.
---
If your project is set up for it, you can reply
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 this
[
https://issues.apache.org/jira/browse/FLINK-3504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15172700#comment-15172700
]
ASF GitHub Bot commented on FLINK-3504:
---
Github user vasia commented on the pull req
[
https://issues.apache.org/jira/browse/FLINK-3537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15172697#comment-15172697
]
ASF GitHub Bot commented on FLINK-3537:
---
Github user vasia commented on the pull req
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 fe
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 featur
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 h
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: Sub-t
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
Compone
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
[
https://issues.apache.org/jira/browse/FLINK-3548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved FLINK-3548.
-
Resolution: Fixed
Fix Version/s: 1.0.0
Fixed in
https://github.com/apache/flink/co
[
https://issues.apache.org/jira/browse/FLINK-3548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15172552#comment-15172552
]
ASF GitHub Bot commented on FLINK-3548:
---
Github user aljoscha closed the pull reques
Github user aljoscha closed the pull request at:
https://github.com/apache/flink/pull/1742
---
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 en
[
https://issues.apache.org/jira/browse/FLINK-3548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15172543#comment-15172543
]
ASF GitHub Bot commented on FLINK-3548:
---
Github user StephanEwen commented on the pu
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&focusedCommentId=15172511#comment-15172511
]
ASF GitHub Bot commented on FLINK-3540:
---
Github user asfgit closed the pull request
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 enab
[
https://issues.apache.org/jira/browse/FLINK-3540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15172496#comment-15172496
]
ASF GitHub Bot commented on FLINK-3540:
---
Github user rmetzger commented on the pull
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
e
[
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://github.com/apache/flink/co
[
https://issues.apache.org/jira/browse/FLINK-3536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15172487#comment-15172487
]
ASF GitHub Bot commented on FLINK-3536:
---
Github user aljoscha closed the pull reques
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 en
[
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
https://github.com/apache/flink/co
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 en
[
https://issues.apache.org/jira/browse/FLINK-3538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15172441#comment-15172441
]
ASF GitHub Bot commented on FLINK-3538:
---
Github user aljoscha closed the pull reques
[
https://issues.apache.org/jira/browse/FLINK-3548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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://git
[
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&focusedCommentId=15172424#comment-15172424
]
ASF GitHub Bot commented on FLINK-3535:
---
Github user asfgit closed the pull request
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 enab
[
https://issues.apache.org/jira/browse/FLINK-3535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15172421#comment-15172421
]
ASF GitHub Bot commented on FLINK-3535:
---
Github user uce commented on the pull reque
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 enab
[
https://issues.apache.org/jira/browse/FLINK-3534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15172418#comment-15172418
]
ASF GitHub Bot commented on FLINK-3534:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-3534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15172350#comment-15172350
]
ASF GitHub Bot commented on FLINK-3534:
---
Github user uce commented on the pull reque
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 it
[
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&focusedCommentId=15172298#comment-15172298
]
ASF GitHub Bot commented on FLINK-3536:
---
Github user aljoscha commented on the pull
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 pro
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: Fli
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 yo
[
https://issues.apache.org/jira/browse/FLINK-3536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15172290#comment-15172290
]
ASF GitHub Bot commented on FLINK-3536:
---
Github user rmetzger commented on the pull
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
Issu
[
https://issues.apache.org/jira/browse/FLINK-3538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15172270#comment-15172270
]
ASF GitHub Bot commented on FLINK-3538:
---
Github user aljoscha commented on the pull
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 repl
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
Component
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 int
[
https://issues.apache.org/jira/browse/FLINK-3544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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&focusedCommentId=15172208#comment-15172208
]
ASF GitHub Bot commented on FLINK-3538:
---
Github user tillrohrmann commented on the p
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&focusedCommentId=15172200#comment-15172200
]
ASF GitHub Bot commented on FLINK-3538:
---
Github user tillrohrmann commented on the p
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 to
[
https://issues.apache.org/jira/browse/FLINK-3538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15172185#comment-15172185
]
ASF GitHub Bot commented on FLINK-3538:
---
Github user StephanEwen commented on the pu
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 proj
[
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 ^ (subTaskStats.
[
https://issues.apache.org/jira/browse/FLINK-3534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15172157#comment-15172157
]
ASF GitHub Bot commented on FLINK-3534:
---
Github user StephanEwen commented on the pu
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: Sub-tas
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: Sub-ta
[
https://issues.apache.org/jira/browse/FLINK-3534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15172150#comment-15172150
]
ASF GitHub Bot commented on FLINK-3534:
---
Github user uce commented on the pull reque
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 Reso
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 F
[
https://issues.apache.org/jira/browse/FLINK-3538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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 into
[
https://issues.apache.org/jira/browse/FLINK-3536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15172113#comment-15172113
]
ASF GitHub Bot commented on FLINK-3536:
---
GitHub user aljoscha opened a 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 assign
[
https://issues.apache.org/jira/browse/FLINK-3505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15172111#comment-15172111
]
Fabian Hueske commented on FLINK-3505:
--
Hi [~chengxiang li], can you provide a test c
[
https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15172109#comment-15172109
]
Nick Dimiduk commented on FLINK-3368:
-
My streaming jobs are continuing to die when Ka
[
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 processi
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 thi
[
https://issues.apache.org/jira/browse/FLINK-3257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15172094#comment-15172094
]
ASF GitHub Bot commented on FLINK-3257:
---
Github user senorcarbone commented on the p
1 - 100 of 198 matches
Mail list logo
