[
https://issues.apache.org/jira/browse/FLINK-3596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15190601#comment-15190601
]
ASF GitHub Bot commented on FLINK-3596:
---
Github user vasia closed the pull request a
[
https://issues.apache.org/jira/browse/FLINK-3596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15190600#comment-15190600
]
ASF GitHub Bot commented on FLINK-3596:
---
Github user vasia commented on the pull req
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1777#issuecomment-195241544
Thanks for finalizing and 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 n
Github user vasia closed the pull request at:
https://github.com/apache/flink/pull/1777
---
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 enabl
[
https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15190553#comment-15190553
]
ramkrishna.s.vasudevan commented on FLINK-3579:
---
Went thro the code. Seems t
[
https://issues.apache.org/jira/browse/FLINK-2997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15190534#comment-15190534
]
ASF GitHub Bot commented on FLINK-2997:
---
Github user gallenvara commented on a diff
Github user gallenvara commented on a diff in the pull request:
https://github.com/apache/flink/pull/1776#discussion_r55794734
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/CustomDistributionITCase.java
---
@@ -0,0 +1,142 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-3605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew Palumbo updated FLINK-3605:
--
Labels: mahout (was: )
> DataSet.output(HadoopOutput) always expects a LongWritable as a key an
[
https://issues.apache.org/jira/browse/FLINK-3605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew Palumbo updated FLINK-3605:
--
Description:
When trying to output a {{DataSet}} as a Sequence file, using the Scala API, an
Ex
Andrew Palumbo created FLINK-3605:
-
Summary: DataSet.output(HadoopOutput) always expects a
LongWritable as a key and throws an exception when supplied with other Writable
Key Types
Key: FLINK-3605
URL: https://is
[
https://issues.apache.org/jira/browse/FLINK-1932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15190382#comment-15190382
]
Soila Kavulya commented on FLINK-1932:
--
I would like to work on this. I can use the S
Fabian Hueske created FLINK-3604:
Summary: Enable ignored Table API tests
Key: FLINK-3604
URL: https://issues.apache.org/jira/browse/FLINK-3604
Project: Flink
Issue Type: Improvement
Fabian Hueske created FLINK-3603:
Summary: Re-enable Table API explain
Key: FLINK-3603
URL: https://issues.apache.org/jira/browse/FLINK-3603
Project: Flink
Issue Type: Improvement
C
[
https://issues.apache.org/jira/browse/FLINK-3596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15190159#comment-15190159
]
ASF GitHub Bot commented on FLINK-3596:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1777#issuecomment-195093887
Thanks for the update @vasia.
Merged to `tableOnCalcite`. PR can be closed.
---
If your project is set up for it, you can reply to this email and have your
reply app
[
https://issues.apache.org/jira/browse/FLINK-3594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189912#comment-15189912
]
Stephan Ewen commented on FLINK-3594:
-
I have a fix for that coming up...
> StreamTas
[
https://issues.apache.org/jira/browse/FLINK-3594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen reassigned FLINK-3594:
---
Assignee: Stephan Ewen
> StreamTask may fail when checkpoint is concurrent to regular termina
[
https://issues.apache.org/jira/browse/FLINK-3594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189899#comment-15189899
]
Stephan Ewen commented on FLINK-3594:
-
Chesnay almost pinned it down precisely.
The a
[
https://issues.apache.org/jira/browse/FLINK-3594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-3594:
Priority: Critical (was: Major)
> StreamTask may fail when checkpoint is concurrent to regular term
[
https://issues.apache.org/jira/browse/FLINK-3594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-3594:
Summary: StreamTask may fail when checkpoint is concurrent to regular
termination (was: Unstable Ka
[
https://issues.apache.org/jira/browse/FLINK-3327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189893#comment-15189893
]
ASF GitHub Bot commented on FLINK-3327:
---
Github user zentol commented on the pull re
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/1583#issuecomment-195034317
are there any objections to merging this? let's get this one in.
---
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-3577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3577.
---
> Display anchor links when hovering over headers.
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-3577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3577.
-
Resolution: Fixed
Fix Version/s: 1.1.0
Fixed via 5fbedff0148b8793885ce99204cbc86bd7aef400
[
https://issues.apache.org/jira/browse/FLINK-3577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189806#comment-15189806
]
ASF GitHub Bot commented on FLINK-3577:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1762
---
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 uce commented on the pull request:
https://github.com/apache/flink/pull/1781#issuecomment-195009701
Looks good, the man page actually says:
```
-p source_port
Specifies the source port nc should use, subject to privilege
restrictions and availability.
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1767#issuecomment-195003857
This has been merged into master (1.1.x) and release-1.0 (1.0.x).
@mxm Can you close this? (was not autoclosed)
---
If your project is set up for it, you ca
[
https://issues.apache.org/jira/browse/FLINK-3569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189758#comment-15189758
]
ASF GitHub Bot commented on FLINK-3569:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1762#issuecomment-195003453
Merging this into the master (1.1.x) branch
---
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 p
[
https://issues.apache.org/jira/browse/FLINK-3577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189753#comment-15189753
]
ASF GitHub Bot commented on FLINK-3577:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1753#issuecomment-195003250
+1, looks good to me
A minor "wish" from my side: I like it to not have generated files in the
project directories, so I'd suggest to change the output file
[
https://issues.apache.org/jira/browse/FLINK-3454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189745#comment-15189745
]
ASF GitHub Bot commented on FLINK-3454:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1745#issuecomment-195002277
Manually merged
---
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
[
https://issues.apache.org/jira/browse/FLINK-3550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189746#comment-15189746
]
ASF GitHub Bot commented on FLINK-3550:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-3550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189747#comment-15189747
]
ASF GitHub Bot commented on FLINK-3550:
---
Github user StephanEwen closed the pull req
Github user StephanEwen closed the pull request at:
https://github.com/apache/flink/pull/1745
---
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 StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1698#issuecomment-195002236
@tillrohrmann That true, in cases the tests are run individually.
---
If your project is set up for it, you can reply to this email and have your
reply appear on Git
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1694#issuecomment-195000972
@fs111 Any updates here?
---
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
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1781#issuecomment-194996626
I use actully `nc -l ` on Linux as well, so can we list that for both
OS?
---
If your project is set up for it, you can reply to this email and have your
reply appe
GitHub user zitterbewegung opened a pull request:
https://github.com/apache/flink/pull/1781
Netcat arguments for Mac OS X
The default netcat implementation for mac OS X uses nc -l 9000 to listen on
port 9000.
You can merge this pull request into a Git repository by running:
$
[
https://issues.apache.org/jira/browse/FLINK-3207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189652#comment-15189652
]
ASF GitHub Bot commented on FLINK-3207:
---
Github user vasia commented on the pull req
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1575#issuecomment-194981424
Hey @s1ck,
thanks a lot for the valuable feedback. I've addressed your comments and
rebased on the current master. Regarding the method renamings, I suggest we
handle
Stephan Ewen created FLINK-3602:
---
Summary: Recursive Types are not supported / crash TypeExtractor
Key: FLINK-3602
URL: https://issues.apache.org/jira/browse/FLINK-3602
Project: Flink
Issue Typ
[
https://issues.apache.org/jira/browse/FLINK-3544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189522#comment-15189522
]
ASF GitHub Bot commented on FLINK-3544:
---
Github user mxm commented on the pull reque
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1741#issuecomment-194945986
Our testing infrastructure is currently very unstable. Here is at least a
build where everything passes: https://travis-ci.org/mxm/flink/builds/115046589
If nobody o
Maximilian Michels created FLINK-3601:
-
Summary: JobManagerTest times out on StopSignal test
Key: FLINK-3601
URL: https://issues.apache.org/jira/browse/FLINK-3601
Project: Flink
Issue Typ
Ufuk Celebi created FLINK-3600:
--
Summary: Provide clear description network ports usage
Key: FLINK-3600
URL: https://issues.apache.org/jira/browse/FLINK-3600
Project: Flink
Issue Type: Improvem
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/1729#discussion_r55687974
--- Diff: CONTRIBUTING.md ---
@@ -8,4 +8,4 @@ To make the process smooth for the project *committers*
(those who review and ac
Please check out the [Ho
[
https://issues.apache.org/jira/browse/FLINK-3529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189377#comment-15189377
]
ASF GitHub Bot commented on FLINK-3529:
---
Github user mxm commented on the pull reque
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1729#issuecomment-194879749
Yes, the test failures are unrelated. Looks good. Could you incorporate the
last comments?
---
If your project is set up for it, you can reply to this email and have your
[
https://issues.apache.org/jira/browse/FLINK-3529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189374#comment-15189374
]
ASF GitHub Bot commented on FLINK-3529:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/1729#discussion_r55688207
--- Diff: PULL_REQUEST_TEMPLATE.md ---
@@ -0,0 +1,18 @@
+Thanks for contributing to Apache Flink. Before you open your pull
request, please take the following
[
https://issues.apache.org/jira/browse/FLINK-3529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189373#comment-15189373
]
ASF GitHub Bot commented on FLINK-3529:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-3529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189366#comment-15189366
]
ASF GitHub Bot commented on FLINK-3529:
---
Github user mliesenberg commented on the pu
Github user mliesenberg commented on the pull request:
https://github.com/apache/flink/pull/1729#issuecomment-194873275
build failed because all jobs failed the
`ClassLoaderITCase.testJobsWithCustomClassLoader` test.
I guess this is unrelated.
---
If your project is set up for it
[
https://issues.apache.org/jira/browse/FLINK-2445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189355#comment-15189355
]
ASF GitHub Bot commented on FLINK-2445:
---
Github user mliesenberg commented on the pu
Github user mliesenberg commented on the pull request:
https://github.com/apache/flink/pull/1625#issuecomment-194871909
build failure because of
- [FLINK-1445](https://issues.apache.org/jira/browse/FLINK-1455) in [build
job](https://travis-ci.org/apache/flink/jobs/114046004)
-
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/1780
[FLINK-3595] [runtime] Eagerly destroy buffer pools on cancelling
When canceling a job, the Kafka 0.9 Consumer Thread may be stuck in a
blocking method (output emitting) and never wakes up.
The
[
https://issues.apache.org/jira/browse/FLINK-3595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189312#comment-15189312
]
ASF GitHub Bot commented on FLINK-3595:
---
GitHub user uce opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-3561.
-
Resolution: Fixed
f6e6924 [FLINK-3561] remove unused timestampsEnabled flag
> ExecutionCo
[
https://issues.apache.org/jira/browse/FLINK-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189279#comment-15189279
]
Stephan Ewen commented on FLINK-2671:
-
Also looking into it right now. Curious what ch
[
https://issues.apache.org/jira/browse/FLINK-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels reopened FLINK-2671:
---
This test is still unstable and fails the master in almost every build. For
example: http
[
https://issues.apache.org/jira/browse/FLINK-3596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189256#comment-15189256
]
ASF GitHub Bot commented on FLINK-3596:
---
Github user vasia commented on the pull req
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1777#issuecomment-194833766
Thanks for the review @fhueske. I've addressed your comments.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as wel
[
https://issues.apache.org/jira/browse/FLINK-2997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189072#comment-15189072
]
ASF GitHub Bot commented on FLINK-2997:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1776#issuecomment-194786495
Thanks @gallenvara for opening the PR. Looks mostly good but the tests need
to be improved, IMO.
It would also be good to extend the `DataDistribution` interface
[
https://issues.apache.org/jira/browse/FLINK-2997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189067#comment-15189067
]
ASF GitHub Bot commented on FLINK-2997:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-2997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189065#comment-15189065
]
ASF GitHub Bot commented on FLINK-2997:
---
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/1776#discussion_r55661252
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/CustomDistributionITCase.java
---
@@ -0,0 +1,142 @@
+/*
+ * Licensed to th
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1776#discussion_r55661214
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/CustomDistributionITCase.java
---
@@ -0,0 +1,142 @@
+/*
+ * Licensed to th
[
https://issues.apache.org/jira/browse/FLINK-2997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189062#comment-15189062
]
ASF GitHub Bot commented on FLINK-2997:
---
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/1776#discussion_r55661084
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/CustomDistributionITCase.java
---
@@ -0,0 +1,142 @@
+/*
+ * Licensed to th
[
https://issues.apache.org/jira/browse/FLINK-2997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189061#comment-15189061
]
ASF GitHub Bot commented on FLINK-2997:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rik Schreurs closed FLINK-3598.
---
Resolution: Not A Problem
Was using two different versions together.
> java.lang.NoSuchMethodError:
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1776#discussion_r55660961
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/CustomDistributionITCase.java
---
@@ -0,0 +1,142 @@
+/*
+ * Licensed to th
[
https://issues.apache.org/jira/browse/FLINK-3598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189056#comment-15189056
]
Rik Schreurs commented on FLINK-3598:
-
Thanks, that was indeed the problem. We were us
[
https://issues.apache.org/jira/browse/FLINK-2997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189053#comment-15189053
]
ASF GitHub Bot commented on FLINK-2997:
---
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/1776#discussion_r55660703
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/CustomDistributionITCase.java
---
@@ -0,0 +1,142 @@
+/*
+ * Licensed to th
[
https://issues.apache.org/jira/browse/FLINK-2997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189050#comment-15189050
]
ASF GitHub Bot commented on FLINK-2997:
---
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/1776#discussion_r55660531
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/CustomDistributionITCase.java
---
@@ -0,0 +1,142 @@
+/*
+ * Licensed to th
[
https://issues.apache.org/jira/browse/FLINK-2997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189044#comment-15189044
]
ASF GitHub Bot commented on FLINK-2997:
---
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/1776#discussion_r55660409
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/distribution/CustomDistribution.java
---
@@ -0,0 +1,164 @@
+/*
+ * Licensed to the Apache S
[
https://issues.apache.org/jira/browse/FLINK-2997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189037#comment-15189037
]
ASF GitHub Bot commented on FLINK-2997:
---
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/1776#discussion_r55660236
--- Diff:
flink-optimizer/src/main/java/org/apache/flink/optimizer/traversals/RangePartitionRewriter.java
---
@@ -113,10 +113,12 @@ public void postVisit(Pla
[
https://issues.apache.org/jira/browse/FLINK-2997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189036#comment-15189036
]
ASF GitHub Bot commented on FLINK-2997:
---
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/1776#discussion_r55660109
--- Diff:
flink-optimizer/src/main/java/org/apache/flink/optimizer/dataproperties/GlobalProperties.java
---
@@ -92,6 +95,10 @@ public void setRangePartitione
[
https://issues.apache.org/jira/browse/FLINK-2997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189035#comment-15189035
]
ASF GitHub Bot commented on FLINK-2997:
---
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/1776#discussion_r55660005
--- Diff:
flink-optimizer/src/main/java/org/apache/flink/optimizer/dataproperties/GlobalProperties.java
---
@@ -167,6 +174,8 @@ public PartitioningProperty g
Márton Balassi created FLINK-3599:
-
Summary: GSoC: Code Generation in Serializers
Key: FLINK-3599
URL: https://issues.apache.org/jira/browse/FLINK-3599
Project: Flink
Issue Type: Improvement
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1776#discussion_r55659105
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/operators/PartitionOperator.java
---
@@ -82,6 +88,7 @@ public PartitionOperator(DataSet input, K
[
https://issues.apache.org/jira/browse/FLINK-2997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189021#comment-15189021
]
ASF GitHub Bot commented on FLINK-2997:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189001#comment-15189001
]
Stephan Ewen commented on FLINK-3598:
-
A {{java.lang.NoSuchMethodError}} is virtually
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1779#issuecomment-194760972
Sorry, just removed right before you.
---
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 aljoscha closed the pull request at:
https://github.com/apache/flink/pull/1779
---
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-3589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15188968#comment-15188968
]
ASF GitHub Bot commented on FLINK-3589:
---
Github user zentol commented on the pull re
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/1778#issuecomment-194756703
passing the default to Operator.setParallelism() will result in an
exception, intended?
---
If your project is set up for it, you can reply to this email and have your
r
[
https://issues.apache.org/jira/browse/FLINK-3589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15188965#comment-15188965
]
ASF GitHub Bot commented on FLINK-3589:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/1778#discussion_r55653990
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java ---
@@ -64,10 +64,15 @@
/**
* The constant to use fo
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/1779
[hotfix] Remove obsolete "Working with Time" Section from Doc
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aljoscha/flink doc-remove-time
A
1 - 100 of 103 matches
Mail list logo
