[
https://issues.apache.org/jira/browse/FLINK-2665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14743341#comment-14743341
]
Stephan Ewen commented on FLINK-2665:
-
Yes, please add those bounds!
> ExecutionConfig is not
Github user mbalassi commented on a diff in the pull request:
https://github.com/apache/flink/pull/1126#discussion_r39383837
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/state/EagerStateStore.java
---
@@ -43,7 +44,7 @@
Github user gyfora commented on a diff in the pull request:
https://github.com/apache/flink/pull/1126#discussion_r39383921
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/state/EagerStateStore.java
---
@@ -43,7 +44,7 @@
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/1120#issuecomment-140046200
Hey @lofifnc,
Thanks for your interest in Flink. Could you explain why do you need access
to the wrapped Java `StreamExecutionEnvironment`? I think all the
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
[
https://issues.apache.org/jira/browse/FLINK-2657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14743363#comment-14743363
]
Maximilian Michels commented on FLINK-2657:
---
I think these are related issues but can be dealt
[
https://issues.apache.org/jira/browse/FLINK-2665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14743420#comment-14743420
]
Till Rohrmann commented on FLINK-2665:
--
It's actually not possible to add the bounds, because
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
[
https://issues.apache.org/jira/browse/FLINK-2664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14743385#comment-14743385
]
ASF GitHub Bot commented on FLINK-2664:
---
GitHub user gyfora opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-2664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14743397#comment-14743397
]
ASF GitHub Bot commented on FLINK-2664:
---
Github user mbalassi commented on the pull request:
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/1126#issuecomment-140045524
Apart from that one comment looks good to me, handy feature.
---
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-2664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14743396#comment-14743396
]
ASF GitHub Bot commented on FLINK-2664:
---
Github user gyfora commented on a diff in the pull request:
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
[
https://issues.apache.org/jira/browse/FLINK-1934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14743459#comment-14743459
]
Till Rohrmann commented on FLINK-1934:
--
Alright [~danielblazevski]. Looking forward to your R-tree
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
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:
GitHub user gyfora opened a pull request:
https://github.com/apache/flink/pull/1126
[FLINK-2664] [streaming] Allow partitioned state removal
This PR changes the way Partitioned states handle null values.
Before this PR the user was not allowed to put null values in a
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1084#issuecomment-140048228
Yes, let's merge it before extending it.
@aminouvic If you want, can you create a JIRA with a description of that
behavior, as a followup task?
As
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
---
@@
[
https://issues.apache.org/jira/browse/FLINK-2664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14743497#comment-14743497
]
ASF GitHub Bot commented on FLINK-2664:
---
Github user gyfora commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14743353#comment-14743353
]
Maximilian Michels commented on FLINK-2665:
---
+1
> ExecutionConfig is not serializable
>
[
https://issues.apache.org/jira/browse/FLINK-2641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14743351#comment-14743351
]
ASF GitHub Bot commented on FLINK-2641:
---
Github user mxm commented on the pull request:
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1125#issuecomment-140035559
How about we rename `taskmanager.memory.size` to `taskmanager.memory`? Then
there wouldn't be any possible clash. I could also live with
`taskmanager.jvm.memory.size`.
[
https://issues.apache.org/jira/browse/FLINK-2583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14743411#comment-14743411
]
ASF GitHub Bot commented on FLINK-2583:
---
Github user StephanEwen commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14743460#comment-14743460
]
ASF GitHub Bot commented on FLINK-2533:
---
Github user fhueske commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14743517#comment-14743517
]
ASF GitHub Bot commented on FLINK-2167:
---
GitHub user twalthr opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-2283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14743545#comment-14743545
]
Aljoscha Krettek commented on FLINK-2283:
-
I want to reiterate what I said earlier: I don't think
[
https://issues.apache.org/jira/browse/FLINK-2283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14743590#comment-14743590
]
Gyula Fora commented on FLINK-2283:
---
On the other hand forcing the users to use the windowing
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:
-
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
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
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
---
@@
[
https://issues.apache.org/jira/browse/FLINK-2557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14743583#comment-14743583
]
ASF GitHub Bot commented on FLINK-2557:
---
Github user tillrohrmann commented on the pull request:
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
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
[
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
>
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
[
https://issues.apache.org/jira/browse/FLINK-2658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14743720#comment-14743720
]
ASF GitHub Bot commented on FLINK-2658:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-2283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14743686#comment-14743686
]
Stephan Ewen commented on FLINK-2283:
-
Aggregating is a group operation, group operations need
[
https://issues.apache.org/jira/browse/FLINK-2665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14743639#comment-14743639
]
ASF GitHub Bot commented on FLINK-2665:
---
GitHub user tillrohrmann opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-2658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14743685#comment-14743685
]
ASF GitHub Bot commented on FLINK-2658:
---
Github user mjsax commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14743723#comment-14743723
]
Matthias J. Sax commented on FLINK-2658:
Resolved via ce68cbd91621b1a58cb34b33ab27762c6525cfa0
>
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
[
https://issues.apache.org/jira/browse/FLINK-2658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14743691#comment-14743691
]
ASF GitHub Bot commented on FLINK-2658:
---
Github user StephanEwen commented on the pull request:
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
[
https://issues.apache.org/jira/browse/FLINK-2283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14743706#comment-14743706
]
Gyula Fora commented on FLINK-2283:
---
I understand your point but what I am trying to say that this
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
[
https://issues.apache.org/jira/browse/FLINK-2664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14743794#comment-14743794
]
ASF GitHub Bot commented on FLINK-2664:
---
Github user asfgit closed the pull request at:
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
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:
[
https://issues.apache.org/jira/browse/FLINK-2641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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-2667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14743859#comment-14743859
]
Robert Metzger edited comment on FLINK-2667 at 9/14/15 5:21 PM:
- For
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
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
[
https://issues.apache.org/jira/browse/FLINK-2665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14743875#comment-14743875
]
ASF GitHub Bot commented on FLINK-2665:
---
Github user rmetzger commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14743803#comment-14743803
]
ASF GitHub Bot commented on FLINK-2634:
---
Github user vasia commented on the pull request:
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
[
https://issues.apache.org/jira/browse/FLINK-2641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14743844#comment-14743844
]
ASF GitHub Bot commented on FLINK-2641:
---
Github user mxm commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14743787#comment-14743787
]
Stephan Ewen commented on FLINK-2283:
-
No state backend can handle infinite state, how should it do
[
https://issues.apache.org/jira/browse/FLINK-2634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14743797#comment-14743797
]
ASF GitHub Bot commented on FLINK-2634:
---
Github user fhueske commented on the pull request:
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
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
[
https://issues.apache.org/jira/browse/FLINK-2659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14743815#comment-14743815
]
ASF GitHub Bot commented on FLINK-2659:
---
GitHub user greghogan opened a pull request:
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:
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
[
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 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
[
https://issues.apache.org/jira/browse/FLINK-2661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14743836#comment-14743836
]
ASF GitHub Bot commented on FLINK-2661:
---
Github user vasia commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14743859#comment-14743859
]
Robert Metzger commented on FLINK-2667:
---
- For those changes where you change from {{*.mb} to
[
https://issues.apache.org/jira/browse/FLINK-2525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14744355#comment-14744355
]
ASF GitHub Bot commented on FLINK-2525:
---
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/1046#discussion_r39453328
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamingRuntimeContext.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-2525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14744372#comment-14744372
]
ASF GitHub Bot commented on FLINK-2525:
---
Github user fhueske commented on a diff in the pull
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
[
https://issues.apache.org/jira/browse/FLINK-2230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14744406#comment-14744406
]
ASF GitHub Bot commented on FLINK-2230:
---
Github user fhueske commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14744318#comment-14744318
]
ASF GitHub Bot commented on FLINK-2533:
---
Github user fhueske commented on the pull request:
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
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.
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-2668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14744286#comment-14744286
]
Fabian Hueske commented on FLINK-2668:
--
This behavior is actually intended (not saying that this
[
https://issues.apache.org/jira/browse/FLINK-2525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14744362#comment-14744362
]
ASF GitHub Bot commented on FLINK-2525:
---
Github user mjsax commented on a diff in the pull request:
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) {
[
https://issues.apache.org/jira/browse/FLINK-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14744560#comment-14744560
]
ASF GitHub Bot commented on FLINK-2613:
---
Github user fhueske commented on the pull request:
[
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-2525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14744330#comment-14744330
]
ASF GitHub Bot commented on FLINK-2525:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14744329#comment-14744329
]
ASF GitHub Bot commented on FLINK-2525:
---
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/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/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
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
[
https://issues.apache.org/jira/browse/FLINK-2525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14744399#comment-14744399
]
ASF GitHub Bot commented on FLINK-2525:
---
Github user fhueske commented on the pull request:
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
[
https://issues.apache.org/jira/browse/FLINK-2373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14744326#comment-14744326
]
ASF GitHub Bot commented on FLINK-2373:
---
Github user fhueske commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14744327#comment-14744327
]
ASF GitHub Bot commented on FLINK-2655:
---
Github user fhueske commented on the pull request:
[
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
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
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
[
https://issues.apache.org/jira/browse/FLINK-2525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14744411#comment-14744411
]
ASF GitHub Bot commented on FLINK-2525:
---
Github user mjsax commented on the pull request:
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`
[
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}
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
1 - 100 of 130 matches
Mail list logo
