[
https://issues.apache.org/jira/browse/FLINK-2522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15066909#comment-15066909
]
ASF GitHub Bot commented on FLINK-2522:
---
Github user nikste commented on the pull re
Github user nikste commented on the pull request:
https://github.com/apache/flink/pull/1412#issuecomment-166394233
Hey @mxm,
So I've tried to initialize the scala shell with one and two different
miniclusters and initialize the streaming and batch environment simultaneously.
Howev
[
https://issues.apache.org/jira/browse/FLINK-598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15066798#comment-15066798
]
Fabian Hueske commented on FLINK-598:
-
The DataSet API features an auto-sampling range
[
https://issues.apache.org/jira/browse/FLINK-146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-146.
---
Resolution: Fixed
Fix Version/s: (was: pre-apache)
1.0.0
Fully sorted out
[
https://issues.apache.org/jira/browse/FLINK-7?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15066790#comment-15066790
]
Fabian Hueske commented on FLINK-7:
---
The correct commit hash is f5957ce3b7d87d89052f0328e56
[
https://issues.apache.org/jira/browse/FLINK-8?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-8.
-
Resolution: Fixed
Assignee: Chengxiang Li
Fix Version/s: (was: pre-apache)
[
https://issues.apache.org/jira/browse/FLINK-7?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-7.
-
Resolution: Implemented
Fix Version/s: (was: pre-apache)
1.0.0
Implemented with
[
https://issues.apache.org/jira/browse/FLINK-3180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-3180.
Resolution: Fixed
Fixed with af996301756563e58df7559ca0d5e0e58a87145b
> MemoryLogger does not log d
[
https://issues.apache.org/jira/browse/FLINK-3116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske resolved FLINK-3116.
--
Resolution: Fixed
Fixed with ba2aba80f578659b8e7331855d1518744c90f860
> Remove RecordOperator
>
[
https://issues.apache.org/jira/browse/FLINK-2622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-2622.
Resolution: Fixed
Fix Version/s: 1.0.0
Fixed with c08bcf1e008397bfe22353e3ba3d9d9656e7d3c1
>
[
https://issues.apache.org/jira/browse/FLINK-2622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15066771#comment-15066771
]
ASF GitHub Bot commented on FLINK-2622:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-2622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15066770#comment-15066770
]
ASF GitHub Bot commented on FLINK-2622:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-3116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15066772#comment-15066772
]
ASF GitHub Bot commented on FLINK-3116:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1098
---
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 asfgit closed the pull request at:
https://github.com/apache/flink/pull/1459
---
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 asfgit closed the pull request at:
https://github.com/apache/flink/pull/1444
---
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 asfgit closed the pull request at:
https://github.com/apache/flink/pull/1466
---
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 asfgit closed the pull request at:
https://github.com/apache/flink/pull/1473
---
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-7?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15066774#comment-15066774
]
ASF GitHub Bot commented on FLINK-7:
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-3180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15066773#comment-15066773
]
ASF GitHub Bot commented on FLINK-3180:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1255
---
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-3014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15066754#comment-15066754
]
Ted Yu commented on FLINK-3014:
---
Thanks for the PR, Chesnay.
> Return code from InputStream
[
https://issues.apache.org/jira/browse/FLINK-3103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15066750#comment-15066750
]
ASF GitHub Bot commented on FLINK-3103:
---
GitHub user tedyu opened a pull request:
GitHub user tedyu opened a pull request:
https://github.com/apache/flink/pull/1474
FLINK-3103 Remove synchronization in
FsStateBackend#FsCheckpointStateOutputStream#close()
Stephan made the following comment:
I would actually suggest to not use a lock in the close() methods
[
https://issues.apache.org/jira/browse/FLINK-3103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu reassigned FLINK-3103:
-
Assignee: Ted Yu
> Remove synchronization in FsStateBackend#FsCheckpointStateOutputStream#close()
> -
[
https://issues.apache.org/jira/browse/FLINK-3103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3103:
--
Summary: Remove synchronization in
FsStateBackend#FsCheckpointStateOutputStream#close() (was: Accessing closed
[
https://issues.apache.org/jira/browse/FLINK-3188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15066657#comment-15066657
]
Sebastian Klemke commented on FLINK-3188:
-
Unfortunately, we also didn't have the
[
https://issues.apache.org/jira/browse/FLINK-3181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15066609#comment-15066609
]
ASF GitHub Bot commented on FLINK-3181:
---
Github user tillrohrmann commented on the p
[
https://issues.apache.org/jira/browse/FLINK-3118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15066623#comment-15066623
]
ASF GitHub Bot commented on FLINK-3118:
---
Github user s1ck commented on the pull requ
Github user s1ck commented on the pull request:
https://github.com/apache/flink/pull/1471#issuecomment-166341381
Sorry for missing javadoc, I was inspired by the other methods in
`TypeExtractor` ;) The test will be a generic version of `LabelPropagation`,
described in https://issues.a
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1459#issuecomment-166340498
I'll close this PR.
---
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 tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1467#issuecomment-166339189
Makes sense. +1 for 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
[
https://issues.apache.org/jira/browse/FLINK-3118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15066605#comment-15066605
]
ASF GitHub Bot commented on FLINK-3118:
---
Github user tillrohrmann commented on the p
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1471#issuecomment-166338426
Changes look good to me. Maybe we could add a test case which verifies the
behaviour. Apart from that, +1 for merging :-)
---
If your project is set up for it, you
[
https://issues.apache.org/jira/browse/FLINK-2622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15066602#comment-15066602
]
ASF GitHub Bot commented on FLINK-2622:
---
Github user fhueske commented on the pull r
[
https://issues.apache.org/jira/browse/FLINK-3118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15066603#comment-15066603
]
ASF GitHub Bot commented on FLINK-3118:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1471#discussion_r48158308
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java
---
@@ -340,6 +340,15 @@ protected TypeExtractor() {
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1098#issuecomment-166338012
Thanks for working on this issue!
I'll close this PR due to inactivity and PR #1473.
---
If your project is set up for it, you can reply to this email and have your
[
https://issues.apache.org/jira/browse/FLINK-3118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15066598#comment-15066598
]
ASF GitHub Bot commented on FLINK-3118:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1471#discussion_r48158234
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java
---
@@ -340,6 +340,15 @@ protected TypeExtractor() {
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1471#discussion_r48155988
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java
---
@@ -340,6 +340,15 @@ protected TypeExtractor() {
[
https://issues.apache.org/jira/browse/FLINK-3118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15066577#comment-15066577
]
ASF GitHub Bot commented on FLINK-3118:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15066574#comment-15066574
]
ASF GitHub Bot commented on FLINK-7:
Github user fhueske commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15066575#comment-15066575
]
ASF GitHub Bot commented on FLINK-3185:
---
Github user tillrohrmann commented on the p
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1472#issuecomment-166331038
Good fix @uce. +1 for 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 do
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1255#issuecomment-166330992
Thanks @ChengXiangLi.
I will increase the sample size to 1000 elements per partition and finally
merge this PR :-)
Thanks for your patience!
---
If your p
[
https://issues.apache.org/jira/browse/FLINK-3116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15066568#comment-15066568
]
ASF GitHub Bot commented on FLINK-3116:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1444#issuecomment-166330470
Will merge this PR
---
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 fea
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1466#issuecomment-166330037
LGTM, will 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 featu
[
https://issues.apache.org/jira/browse/FLINK-3188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15066567#comment-15066567
]
Robert Metzger commented on FLINK-3188:
---
Thank you for providing a patch for the iss
[
https://issues.apache.org/jira/browse/FLINK-3188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-3188:
-
Assignee: Robert Metzger
> Deletes in Kafka source should be passed on to KeyedDeserializ
[
https://issues.apache.org/jira/browse/FLINK-3180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15066566#comment-15066566
]
ASF GitHub Bot commented on FLINK-3180:
---
Github user fhueske commented on the pull r
[
https://issues.apache.org/jira/browse/FLINK-3185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15066565#comment-15066565
]
ASF GitHub Bot commented on FLINK-3185:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1472#discussion_r48155515
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -245,6 +245,8 @@ class JobManager(
// TO
[
https://issues.apache.org/jira/browse/FLINK-2622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15066562#comment-15066562
]
ASF GitHub Bot commented on FLINK-2622:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1473#issuecomment-166329040
LGTM. Will 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 featu
[
https://issues.apache.org/jira/browse/FLINK-2622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15066559#comment-15066559
]
ASF GitHub Bot commented on FLINK-2622:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1473#discussion_r48155123
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
---
@@ -937,26 +941,40 @@ public ExecutionConfig
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1473#discussion_r48154545
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
---
@@ -937,26 +941,40 @@ public ExecutionConfig getEx
[
https://issues.apache.org/jira/browse/FLINK-2622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15066546#comment-15066546
]
ASF GitHub Bot commented on FLINK-2622:
---
Github user fhueske commented on a diff in
Filip Leczycki created FLINK-3189:
-
Summary: Error while parsing job arguments passed by CLI
Key: FLINK-3189
URL: https://issues.apache.org/jira/browse/FLINK-3189
Project: Flink
Issue Type: B
[
https://issues.apache.org/jira/browse/FLINK-7?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15066420#comment-15066420
]
ASF GitHub Bot commented on FLINK-7:
Github user ChengXiangLi commented on the pull reque
Github user ChengXiangLi commented on the pull request:
https://github.com/apache/flink/pull/1255#issuecomment-166297616
Sorry, @fhueske , i misunderstood your test data, the keys should be skewed
on some value, while in my previous test, the keys are now skewed. it's
complicate to ca
[
https://issues.apache.org/jira/browse/FLINK-2622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15066332#comment-15066332
]
ASF GitHub Bot commented on FLINK-2622:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/1473
[FLINK-2622] [streaming] Align Scala streaming writeAsCsv API call with
Java API
Allows the Scala API to call `writeAsCsv` with the same parameters as the
Java API does.
This PR is a
[
https://issues.apache.org/jira/browse/FLINK-2622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-2622:
Assignee: Till Rohrmann
> Scala DataStream API does not have writeAsText method which suppo
66 matches
Mail list logo
