[
https://issues.apache.org/jira/browse/FLINK-2669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-2669.
--
Resolution: Won't Fix
Yeah, I agree and I didn't mean to "fix" this (that's also why I've labelled it
a
GitHub user HuangWHWHW opened a pull request:
https://github.com/apache/flink/pull/1131
[hotfix][Table API tests]add toDataSet in table API tests
See the discussion in the PR:https://github.com/apache/flink/pull/1098 for
detail.
And I'm not sure this change need a JIRA or just t
[
https://issues.apache.org/jira/browse/FLINK-2669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14744915#comment-14744915
]
Stephan Ewen commented on FLINK-2669:
-
This is by (admittedly somewhat tricky) design.
[
https://issues.apache.org/jira/browse/FLINK-2669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14744914#comment-14744914
]
Stephan Ewen commented on FLINK-2669:
-
The seializability of the execution graph is tr
[
https://issues.apache.org/jira/browse/FLINK-2525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14744911#comment-14744911
]
ASF GitHub Bot commented on FLINK-2525:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1046#issuecomment-140291773
As per discussion on the dev list, the `ExecuionConfig` has the
`GlobalJobParameters`, which are useful if one type of config is used across
all operators.
Github user mfahimazizi commented on the pull request:
https://github.com/apache/flink/pull/765#issuecomment-140280883
@andralungu and @vasia , we are outside germany :(
we need to access edges inside vertexupdate function (not inside messaging
function), as we mentioned in above c
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1106#issuecomment-140239647
The tests use the shell scripts (`.sh` or `.bat`) to start the Scala Shell
and rely on finding these scripts in the `flink-dist/target` folder. I think
this is a bit fra
[
https://issues.apache.org/jira/browse/FLINK-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14744560#comment-14744560
]
ASF GitHub Bot commented on FLINK-2613:
---
Github user fhueske commented on the pull r
[
https://issues.apache.org/jira/browse/FLINK-2525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14744411#comment-14744411
]
ASF GitHub Bot commented on FLINK-2525:
---
Github user mjsax commented on the pull req
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/1046#issuecomment-140224226
It is not clear (at least to me) how to do this. The API does not offer an
(obvious) way to set a configuration... (or I just don't get it).
`StreamExecutionEnvironment` o
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/867#issuecomment-140223417
OK, I will close this PR tomorrow, unless somebody speaks up.
@Shiti, I am sorry for the time you invested in this PR, but we cannot add
it to Flink's codebase without
[
https://issues.apache.org/jira/browse/FLINK-2230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14744406#comment-14744406
]
ASF GitHub Bot commented on FLINK-2230:
---
Github user fhueske commented on the pull r
[
https://issues.apache.org/jira/browse/FLINK-2525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14744399#comment-14744399
]
ASF GitHub Bot commented on FLINK-2525:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1046#issuecomment-140222747
Actually, I think going through the `TaskConfig` as proposed by @mjsax is
the cleaner way. Going through the system-internal `JobConfiguration` and
exposing it to user p
[
https://issues.apache.org/jira/browse/FLINK-2525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14744372#comment-14744372
]
ASF GitHub Bot commented on FLINK-2525:
---
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/1046#discussion_r39453328
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamingRuntimeContext.java
---
@@ -91,7
[
https://issues.apache.org/jira/browse/FLINK-2525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14744362#comment-14744362
]
ASF GitHub Bot commented on FLINK-2525:
---
Github user mjsax commented on a diff in th
Github user mjsax commented on a diff in the pull request:
https://github.com/apache/flink/pull/1046#discussion_r39453004
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/Configuration.java ---
@@ -418,6 +418,17 @@ public void setBytes(String key, byte[] bytes) {
Ufuk Celebi created FLINK-2669:
--
Summary: Execution contains non-serializable field
Key: FLINK-2669
URL: https://issues.apache.org/jira/browse/FLINK-2669
Project: Flink
Issue Type: Bug
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1046#discussion_r39452503
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/Configuration.java ---
@@ -418,6 +418,17 @@ public void setBytes(String key, byte[] bytes) {
[
https://issues.apache.org/jira/browse/FLINK-2525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14744355#comment-14744355
]
ASF GitHub Bot commented on FLINK-2525:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-2525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14744329#comment-14744329
]
ASF GitHub Bot commented on FLINK-2525:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-2525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14744330#comment-14744330
]
ASF GitHub Bot commented on FLINK-2525:
---
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/1046#discussion_r39450885
--- Diff: docs/apis/storm_compatibility.md ---
@@ -169,6 +169,13 @@ The input type is `Tuple1` and
`Fields("sentence")` specify that `input.
See
[
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1046#discussion_r39450937
--- Diff: docs/apis/storm_compatibility.md ---
@@ -169,6 +169,13 @@ The input type is `Tuple1` and
`Fields("sentence")` specify that `input.
See
[
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1118#issuecomment-140212980
Will merge this PR tomorrow.
---
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 hav
[
https://issues.apache.org/jira/browse/FLINK-2655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14744327#comment-14744327
]
ASF GitHub Bot commented on FLINK-2655:
---
Github user fhueske commented on the pull r
[
https://issues.apache.org/jira/browse/FLINK-2373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14744326#comment-14744326
]
ASF GitHub Bot commented on FLINK-2373:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1066#issuecomment-140212838
Thanks for the update!
Will merge this PR tomorrow.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. I
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1110#issuecomment-140212159
I will merge this PR tomorrow.
---
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 h
[
https://issues.apache.org/jira/browse/FLINK-2533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14744318#comment-14744318
]
ASF GitHub Bot commented on FLINK-2533:
---
Github user fhueske commented on the pull r
[
https://issues.apache.org/jira/browse/FLINK-2668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14744286#comment-14744286
]
Fabian Hueske commented on FLINK-2668:
--
This behavior is actually intended (not sayin
[
https://issues.apache.org/jira/browse/FLINK-2668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-2668:
--
Description:
I have come across an issue in my code where I called project(...) on a DataSet
which was
[
https://issues.apache.org/jira/browse/FLINK-2668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-2668:
--
Description:
I have come across an issue in my code where I called
{noformat}project(...){noformat} on
[
https://issues.apache.org/jira/browse/FLINK-2661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andra Lungu closed FLINK-2661.
--
Resolution: Won't Fix
> Add a Node Splitting Technique to Overcome the Limitations of Skewed Graphs
> --
Github user andralungu closed the pull request at:
https://github.com/apache/flink/pull/1124
---
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-2661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14744092#comment-14744092
]
ASF GitHub Bot commented on FLINK-2661:
---
Github user andralungu closed the pull requ
[
https://issues.apache.org/jira/browse/FLINK-2668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-2668:
--
Description:
I have come across an issue in my code where I called
{{monospaced}}project(...){{monospac
[
https://issues.apache.org/jira/browse/FLINK-2668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-2668:
--
Description:
I have come across an issue in my code where I called
{monospace}project(...){noformat} on
Greg Hogan created FLINK-2668:
-
Summary: ProjectOperator method to close projection
Key: FLINK-2668
URL: https://issues.apache.org/jira/browse/FLINK-2668
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-2665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14743875#comment-14743875
]
ASF GitHub Bot commented on FLINK-2665:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1128#issuecomment-140153585
+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 mxm commented on the pull request:
https://github.com/apache/flink/pull/1125#issuecomment-140148408
Closing this in favor of #1129. For further discussion please see
https://issues.apache.org/jira/browse/FLINK-2667.
---
If your project is set up for it, you can reply to t
[
https://issues.apache.org/jira/browse/FLINK-2667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14743859#comment-14743859
]
Robert Metzger edited comment on FLINK-2667 at 9/14/15 5:21 PM:
[
https://issues.apache.org/jira/browse/FLINK-2667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14743859#comment-14743859
]
Robert Metzger commented on FLINK-2667:
---
- For those changes where you change from {
[
https://issues.apache.org/jira/browse/FLINK-2641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14743845#comment-14743845
]
ASF GitHub Bot commented on FLINK-2641:
---
Github user mxm closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-2641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14743844#comment-14743844
]
ASF GitHub Bot commented on FLINK-2641:
---
Github user mxm commented on the pull reque
Github user mxm closed the pull request at:
https://github.com/apache/flink/pull/1125
---
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 enabled
Maximilian Michels created FLINK-2667:
-
Summary: Rework configuration parameters
Key: FLINK-2667
URL: https://issues.apache.org/jira/browse/FLINK-2667
Project: Flink
Issue Type: Improveme
[
https://issues.apache.org/jira/browse/FLINK-2661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14743836#comment-14743836
]
ASF GitHub Bot commented on FLINK-2661:
---
Github user vasia commented on the pull req
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1124#issuecomment-140146467
Sure, I'm not saying you shouldn't have opened this PR. I'm trying to save
you some time.
So, my opinion is that in order for this to be useful, we need 2 things:
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/1130
[FLINK-2659] Fix object reuse in UnionWithTempOperator
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/greghogan/flink
2659_object_reuse_in_u
[
https://issues.apache.org/jira/browse/FLINK-2659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14743815#comment-14743815
]
ASF GitHub Bot commented on FLINK-2659:
---
GitHub user greghogan opened a pull request
[
https://issues.apache.org/jira/browse/FLINK-2634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14743803#comment-14743803
]
ASF GitHub Bot commented on FLINK-2634:
---
Github user vasia commented on the pull req
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1105#issuecomment-140140403
Sounds good to me! A benchmark would be great, since I can also only guess
about the performance ;)
---
If your project is set up for it, you can reply to this email and
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1105#issuecomment-140137717
Fair enough, we can stick with your implementation. I was only guessing
about the performance implications. I did not check the code in detail though.
---
If your proj
[
https://issues.apache.org/jira/browse/FLINK-2634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14743797#comment-14743797
]
ASF GitHub Bot commented on FLINK-2634:
---
Github user fhueske commented on the pull r
[
https://issues.apache.org/jira/browse/FLINK-2641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14743795#comment-14743795
]
ASF GitHub Bot commented on FLINK-2641:
---
GitHub user mxm opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-2664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora resolved FLINK-2664.
---
Resolution: Fixed
> Remove partitioned states when set to null
> -
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/1129
[FLINK-2641] integrate off-heap memory configuration
Following the discussion in #1125, this pull request introduces a less
"invasive" change to make the off-heap memory configurable.
- add off
[
https://issues.apache.org/jira/browse/FLINK-2664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14743794#comment-14743794
]
ASF GitHub Bot commented on FLINK-2664:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1126
---
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-2283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14743787#comment-14743787
]
Stephan Ewen commented on FLINK-2283:
-
No state backend can handle infinite state, how
Github user andralungu commented on the pull request:
https://github.com/apache/flink/pull/1105#issuecomment-140133538
Hey you two :)
I suggest that we add this one.
Let the JIRA that @vasia opened handle the keys.
Then add the DataSet example (another JIRA) and a JIRA
[
https://issues.apache.org/jira/browse/FLINK-2634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14743779#comment-14743779
]
ASF GitHub Bot commented on FLINK-2634:
---
Github user andralungu commented on the pul
[
https://issues.apache.org/jira/browse/FLINK-2661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14743766#comment-14743766
]
ASF GitHub Bot commented on FLINK-2661:
---
Github user andralungu commented on the pul
Github user andralungu commented on the pull request:
https://github.com/apache/flink/pull/1124#issuecomment-140131099
Hi @vasia ,
There was no clear rejection in the discussion, so I thought I'd try my
luck :)
This technique could be enabled by using a flag only if w
[
https://issues.apache.org/jira/browse/FLINK-2658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax closed FLINK-2658.
--
Resolution: Fixed
> fieldsGrouping for multiple output streams fails
> -
[
https://issues.apache.org/jira/browse/FLINK-2658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14743723#comment-14743723
]
Matthias J. Sax commented on FLINK-2658:
Resolved via ce68cbd91621b1a58cb34b33ab27
[
https://issues.apache.org/jira/browse/FLINK-2658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14743720#comment-14743720
]
ASF GitHub Bot commented on FLINK-2658:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1122
---
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-2283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14743706#comment-14743706
]
Gyula Fora commented on FLINK-2283:
---
I understand your point but what I am trying to say
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1122#issuecomment-140120338
This does not affect any code outside the storm compatibility layer, so I
think if you judge it as solid, it is probably fine...
---
If your project is set up for i
[
https://issues.apache.org/jira/browse/FLINK-2658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14743691#comment-14743691
]
ASF GitHub Bot commented on FLINK-2658:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-2283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14743686#comment-14743686
]
Stephan Ewen commented on FLINK-2283:
-
Aggregating is a group operation, group operati
[
https://issues.apache.org/jira/browse/FLINK-2658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14743685#comment-14743685
]
ASF GitHub Bot commented on FLINK-2658:
---
Github user mjsax commented on the pull req
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/1122#issuecomment-140119712
Can I merge 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
[
https://issues.apache.org/jira/browse/FLINK-2665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14743639#comment-14743639
]
ASF GitHub Bot commented on FLINK-2665:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/1128
[FLINK-2665] [api-breaking] [runtime] Makes ExecutionConfig serializable by
forcing Kryo serializers to be Serializable
Adding an explicit type constraint for the Kryo serializers to be
`Seria
[
https://issues.apache.org/jira/browse/FLINK-2283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14743590#comment-14743590
]
Gyula Fora commented on FLINK-2283:
---
On the other hand forcing the users to use the wind
[
https://issues.apache.org/jira/browse/FLINK-2557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14743583#comment-14743583
]
ASF GitHub Bot commented on FLINK-2557:
---
Github user tillrohrmann commented on the p
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1045#issuecomment-140098455
I'm ok with this approach.
---
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
[
https://issues.apache.org/jira/browse/FLINK-2283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14743545#comment-14743545
]
Aljoscha Krettek commented on FLINK-2283:
-
I want to reiterate what I said earlier
[
https://issues.apache.org/jira/browse/FLINK-2536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14743526#comment-14743526
]
ASF GitHub Bot commented on FLINK-2536:
---
Github user HuangWHWHW commented on the pul
Github user HuangWHWHW commented on the pull request:
https://github.com/apache/flink/pull/1030#issuecomment-140079694
Sorry for misunderstading.
I have changed the `LOG.error(e)` to `LOG.error(e.getMessage())` now.
---
If your project is set up for it, you can reply to this email
[
https://issues.apache.org/jira/browse/FLINK-2167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14743517#comment-14743517
]
ASF GitHub Bot commented on FLINK-2167:
---
GitHub user twalthr opened a pull request:
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/1127
[FLINK-2167] [table] Add fromHCat() to TableEnvironment
This PR introduces input format interfaces (so-called `TableSource`s) for
the Table API. There are two types of TableSources:
- `Adap
Github user HuangWHWHW commented on a diff in the pull request:
https://github.com/apache/flink/pull/1119#discussion_r39392417
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/sink/WriteSinkFunction.java
---
@@ -56
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/1126#issuecomment-140071198
If no objections, I would like to merge this soon.
---
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-2664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14743497#comment-14743497
]
ASF GitHub Bot commented on FLINK-2664:
---
Github user gyfora commented on the pull re
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1119
---
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 mbalassi commented on a diff in the pull request:
https://github.com/apache/flink/pull/1119#discussion_r39389124
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/sink/WriteSinkFunction.java
---
@@ -56,7
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1119#discussion_r39388903
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/sink/WriteSinkFunction.java
---
@@ -5
Gyula Fora created FLINK-2666:
-
Summary: Allow custom Timestamp extractors for Flink sources
Key: FLINK-2666
URL: https://issues.apache.org/jira/browse/FLINK-2666
Project: Flink
Issue Type: Impro
[
https://issues.apache.org/jira/browse/FLINK-1934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14743459#comment-14743459
]
Till Rohrmann commented on FLINK-1934:
--
Alright [~danielblazevski]. Looking forward t
[
https://issues.apache.org/jira/browse/FLINK-2533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14743460#comment-14743460
]
ASF GitHub Bot commented on FLINK-2533:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1110#issuecomment-140058876
@gallenvara, thanks for the PR.
Looks good to me.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/1119#issuecomment-140056107
Makes sense, 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 hav
[
https://issues.apache.org/jira/browse/FLINK-2665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14743420#comment-14743420
]
Till Rohrmann commented on FLINK-2665:
--
It's actually not possible to add the bounds,
1 - 100 of 144 matches
Mail list logo
