Github user twalthr commented on the pull request:
https://github.com/apache/flink/pull/1679#issuecomment-188655499
If there are no objections, I would like to merge this later.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as w
[
https://issues.apache.org/jira/browse/FLINK-3226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15166872#comment-15166872
]
ASF GitHub Bot commented on FLINK-3226:
---
Github user twalthr commented on the pull r
Github user twalthr commented on the pull request:
https://github.com/apache/flink/pull/1696#issuecomment-188654410
Forwarding the expected type is not an option, because you don't know what
the previous operator produces. If the previous operator produces `Tuple5` and
you force it to
[
https://issues.apache.org/jira/browse/FLINK-3463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15166868#comment-15166868
]
ASF GitHub Bot commented on FLINK-3463:
---
Github user twalthr commented on the pull r
Chengxiang Li created FLINK-3507:
Summary: PruneEmptyRules does not prune empty node as expected.
Key: FLINK-3507
URL: https://issues.apache.org/jira/browse/FLINK-3507
Project: Flink
Issue T
Chengxiang Li created FLINK-3506:
Summary: ReduceExpressionsRule does not remove duplicate
expression in Filter
Key: FLINK-3506
URL: https://issues.apache.org/jira/browse/FLINK-3506
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-3486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chengxiang Li updated FLINK-3486:
-
Summary: Use Project to rename all record fields would fail following
Project. (was: [SQL] Use Pr
[
https://issues.apache.org/jira/browse/FLINK-3502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chengxiang Li updated FLINK-3502:
-
Summary: AggregateProjectPullUpConstantsRule fails on certain group keys
order. (was: [SQL] Aggre
[
https://issues.apache.org/jira/browse/FLINK-3486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chengxiang Li updated FLINK-3486:
-
Component/s: Table API
> [SQL] Use Project to rename all record fields would fail following Projec
[
https://issues.apache.org/jira/browse/FLINK-3487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chengxiang Li updated FLINK-3487:
-
Component/s: Table API
> [SQL] FilterAggregateTransposeRule does not transform logical plan as des
[
https://issues.apache.org/jira/browse/FLINK-3503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chengxiang Li updated FLINK-3503:
-
Summary: ProjectJoinTransposeRule fails to push down project. (was: [SQL]
ProjectJoinTransposeRul
[
https://issues.apache.org/jira/browse/FLINK-3487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chengxiang Li updated FLINK-3487:
-
Summary: FilterAggregateTransposeRule does not transform logical plan as
desired. (was: [SQL] Fil
Chengxiang Li created FLINK-3505:
Summary: JoinUnionTransposeRule fails to push Join past Union.
Key: FLINK-3505
URL: https://issues.apache.org/jira/browse/FLINK-3505
Project: Flink
Issue Typ
[
https://issues.apache.org/jira/browse/FLINK-3503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chengxiang Li updated FLINK-3503:
-
Component/s: Table API
> [SQL] ProjectJoinTransposeRule fails to push down project.
>
[
https://issues.apache.org/jira/browse/FLINK-3504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chengxiang Li updated FLINK-3504:
-
Summary: Join fails while have expression inside join condition. (was:
[SQL] Join fails while hav
Chengxiang Li created FLINK-3504:
Summary: [SQL] Join fails while have expression inside join
condition.
Key: FLINK-3504
URL: https://issues.apache.org/jira/browse/FLINK-3504
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-3487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chengxiang Li updated FLINK-3487:
-
Issue Type: Improvement (was: Bug)
> [SQL] FilterAggregateTransposeRule does not transform logica
Chengxiang Li created FLINK-3503:
Summary: [SQL] ProjectJoinTransposeRule fails to push down project.
Key: FLINK-3503
URL: https://issues.apache.org/jira/browse/FLINK-3503
Project: Flink
Issu
Chengxiang Li created FLINK-3502:
Summary: [SQL] AggregateProjectPullUpConstantsRule fails on
certain group keys order.
Key: FLINK-3502
URL: https://issues.apache.org/jira/browse/FLINK-3502
Project: F
Paul Harris created FLINK-3501:
--
Summary: flink-runtime-0.10.2-hadoop-1 jar problem
Key: FLINK-3501
URL: https://issues.apache.org/jira/browse/FLINK-3501
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-3485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15166425#comment-15166425
]
sahitya pavurala commented on FLINK-3485:
-
I attached the screenshot. For primitiv
[
https://issues.apache.org/jira/browse/FLINK-3500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-3500.
--
Resolution: Fixed
Fixed in e811e6e.
> ExecutionGraphRestartTest testFailingExecutionAfterRestart fails
[
https://issues.apache.org/jira/browse/FLINK-3500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15165698#comment-15165698
]
ASF GitHub Bot commented on FLINK-3500:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1708
---
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/1708#issuecomment-188502605
Build passes and changes are local to a test. I'm going forward and merging
this.
---
If your project is set up for it, you can reply to this email and have your
reply appe
[
https://issues.apache.org/jira/browse/FLINK-3500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15165695#comment-15165695
]
ASF GitHub Bot commented on FLINK-3500:
---
Github user uce commented on the pull reque
[
https://issues.apache.org/jira/browse/FLINK-3435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15163794#comment-15163794
]
ASF GitHub Bot commented on FLINK-3435:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-3435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-3435.
---
Resolution: Fixed
Fixed in http://git-wip-us.apache.org/repos/asf/flink/commit/ceb64248
> Cha
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1706
---
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/1699
---
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 rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1706#issuecomment-188451606
Merging & including this one into the RC1 as well.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If yo
[
https://issues.apache.org/jira/browse/FLINK-3435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15163789#comment-15163789
]
ASF GitHub Bot commented on FLINK-3435:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1699#issuecomment-188451115
I'll merge this one as it is the last blocker of the 1.0.0 RC1.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub a
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1706#issuecomment-188450931
Okay, makes sense.
+1 from my side
---
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
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1706#issuecomment-188448934
I want to add this because it enables triggers that can essentially discard
late elements. It does not change any previous behavior but just enables some
nifty custom t
[
https://issues.apache.org/jira/browse/FLINK-3179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15163719#comment-15163719
]
ASF GitHub Bot commented on FLINK-3179:
---
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/1553#discussion_r53998405
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/GroupReduceITCase.java
---
@@ -434,6 +431,95 @@ public void
testCorrectnessOfGrou
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1705
---
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-3435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15163705#comment-15163705
]
ASF GitHub Bot commented on FLINK-3435:
---
Github user aljoscha commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1699#issuecomment-188431435
There's also some commented out code but I guess we'll leave that in until
we fix the timestamp handling?
---
If your project is set up for it, you can reply to this e
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1705#issuecomment-188430962
Thanks for having a look. I'm going to merge this then.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If yo
[
https://issues.apache.org/jira/browse/FLINK-3499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15163702#comment-15163702
]
ASF GitHub Bot commented on FLINK-3499:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-3499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-3499.
--
Resolution: Fixed
Fix Version/s: 1.0.0
Fixed in af2091c.
> Possible ghost references in ZooKeepe
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1707
---
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 fhueske commented on the pull request:
https://github.com/apache/flink/pull/1705#issuecomment-188430308
The changes look good to me and make a lot of sense. +1 to merge.
In the long run, we should make the discussion of time independent of
windows, but this can be
[
https://issues.apache.org/jira/browse/FLINK-3499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15163590#comment-15163590
]
ASF GitHub Bot commented on FLINK-3499:
---
Github user uce commented on the pull reque
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1699#issuecomment-188424651
That's fine with me. As I said, that's just personal preferences.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
[
https://issues.apache.org/jira/browse/FLINK-3435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15163588#comment-15163588
]
ASF GitHub Bot commented on FLINK-3435:
---
Github user aljoscha commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-3500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15163586#comment-15163586
]
ASF GitHub Bot commented on FLINK-3500:
---
GitHub user uce opened a pull request:
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1707#issuecomment-188424801
Failed test is unrelated and I think fixed by #1708. I'm merging this for
the release.
---
If your project is set up for it, you can reply to this email and have your
reply
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/1708
[FLINK-3500] [test] Fix possible instability in ExecutionGraphRestartTest
After restart of the execution graph, the test driver waits for the graph
to assign the new executions in a loop. If `switchToRu
[
https://issues.apache.org/jira/browse/FLINK-3435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15163583#comment-15163583
]
ASF GitHub Bot commented on FLINK-3435:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1699#issuecomment-188424117
Thanks for the review.
I would like to keep the name `setAbsoluteTimestamp()` on the
`TimestampedCollector`.
For the `IngestionTimeExtractor`, what
[
https://issues.apache.org/jira/browse/FLINK-3435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15163579#comment-15163579
]
ASF GitHub Bot commented on FLINK-3435:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1699#discussion_r53994466
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimestampedCollector.java
---
@@ -51,17 +48,19 @@ public Timestampe
[
https://issues.apache.org/jira/browse/FLINK-3491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15163577#comment-15163577
]
ASF GitHub Bot commented on FLINK-3491:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1703#discussion_r53994155
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/util/HDFSCopyUtilitiesTest.java
---
@@ -35,6 +37,11 @@
@Rule
publ
[
https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15163540#comment-15163540
]
ASF GitHub Bot commented on FLINK-1159:
---
Github user stefanobaghino commented on the
Github user stefanobaghino commented on the pull request:
https://github.com/apache/flink/pull/1704#issuecomment-188409068
This should cover the missing implementations. I also included the tests I
used to test the functionality, let me know if you prefer a wider coverage.
I'll provid
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1699#issuecomment-188406380
+1 changes look good, I had some minor comments but that's just naming
preferences.
Btw, this PR also removes the distinction between `EventTimeSourceFunction`
[
https://issues.apache.org/jira/browse/FLINK-3435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15163529#comment-15163529
]
ASF GitHub Bot commented on FLINK-3435:
---
Github user aljoscha commented on the pull
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/1699#discussion_r53986228
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimestampedCollector.java
---
@@ -51,17 +48,19 @@ public TimestampedCo
[
https://issues.apache.org/jira/browse/FLINK-3435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15163505#comment-15163505
]
ASF GitHub Bot commented on FLINK-3435:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15163494#comment-15163494
]
ASF GitHub Bot commented on FLINK-3435:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1699#discussion_r53985747
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/IngestionTimeExtractor.java
---
@@ -0,0 +1,40 @@
+/*
+ * Li
[
https://issues.apache.org/jira/browse/FLINK-3435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15163491#comment-15163491
]
ASF GitHub Bot commented on FLINK-3435:
---
Github user aljoscha commented on a diff in
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1699#discussion_r53985590
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java
---
@@ -572,7 +577,7 @@ public JobGraph getJobGraph()
[
https://issues.apache.org/jira/browse/FLINK-3435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15163492#comment-15163492
]
ASF GitHub Bot commented on FLINK-3435:
---
Github user StephanEwen commented on a diff
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/1699#discussion_r53985538
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java
---
@@ -572,7 +577,7 @@ public JobGraph getJobGraph() {
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/1699#discussion_r53985422
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java
---
@@ -572,7 +577,7 @@ public JobGraph getJobGraph() {
[
https://issues.apache.org/jira/browse/FLINK-3435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15163490#comment-15163490
]
ASF GitHub Bot commented on FLINK-3435:
---
Github user aljoscha commented on a diff in
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/1699#discussion_r53984915
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/IngestionTimeExtractor.java
---
@@ -0,0 +1,40 @@
+/*
+ * Licen
[
https://issues.apache.org/jira/browse/FLINK-3435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15163483#comment-15163483
]
ASF GitHub Bot commented on FLINK-3435:
---
Github user aljoscha commented on a diff in
Github user ramkrish86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/1553#discussion_r53978205
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/GroupReduceITCase.java
---
@@ -434,6 +431,95 @@ public void
testCorrectnessOfG
[
https://issues.apache.org/jira/browse/FLINK-3179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15163421#comment-15163421
]
ASF GitHub Bot commented on FLINK-3179:
---
Github user ramkrish86 commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-3500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15163388#comment-15163388
]
Ufuk Celebi commented on FLINK-3500:
>From FLINK-3490:
See https://s3.amazonaws.com/a
Ufuk Celebi created FLINK-3500:
--
Summary: ExecutionGraphRestartTest
testFailingExecutionAfterRestart fails
Key: FLINK-3500
URL: https://issues.apache.org/jira/browse/FLINK-3500
Project: Flink
I
[
https://issues.apache.org/jira/browse/FLINK-3470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3470.
-
Resolution: Won't Fix
After further discussion, we will go for a different approach.
See descripti
[
https://issues.apache.org/jira/browse/FLINK-3468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3468.
-
Resolution: Invalid
> Change Timestamp Extractors to not support negative timestamps
> ---
[
https://issues.apache.org/jira/browse/FLINK-3499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15163328#comment-15163328
]
ASF GitHub Bot commented on FLINK-3499:
---
GitHub user uce opened a pull request:
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/1707
[FLINK-3499] [runtime] Clear ZooKeeper references on recovery
Adds a missing clear call to the ZooKeeperCompletedCheckpointStore. Before,
it could have happened that on multiple calls to recovery after
[
https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15163318#comment-15163318
]
ASF GitHub Bot commented on FLINK-1159:
---
Github user stefanobaghino commented on the
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1705#issuecomment-188352526
I like this a lot!
+1
---
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 stefanobaghino commented on the pull request:
https://github.com/apache/flink/pull/1704#issuecomment-188352497
@tillrohrmann I got mixed up reading your proposal and just got what you
meant with the `extensions.acceptPartialFunctions` implicit conversion, thanks
for the ti
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1706#issuecomment-188352346
What is the implication of this change?
---
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 proje
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/1706
[hotfix] Expose current watermark to Triggers
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aljoscha/flink window-watermark-in-trigger
Alter
[
https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15163298#comment-15163298
]
ASF GitHub Bot commented on FLINK-1159:
---
Github user stefanobaghino commented on the
Github user stefanobaghino commented on the pull request:
https://github.com/apache/flink/pull/1704#issuecomment-188343795
:+1: @StephanEwen I started working on the extension before the removal,
will fix this as well, thanks for the feedback.
---
If your project is set up for it, yo
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1704#issuecomment-188335368
Looks very nice in my opinion.
Could you remove the `ClassTag` context bounds? We recently removed them
from `DataStream`, because they are not needed.
---
[
https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15163278#comment-15163278
]
ASF GitHub Bot commented on FLINK-1159:
---
Github user StephanEwen commented on the pu
Ufuk Celebi created FLINK-3499:
--
Summary: Possible ghost references in ZooKeeper completed
checkpoint store
Key: FLINK-3499
URL: https://issues.apache.org/jira/browse/FLINK-3499
Project: Flink
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1704#issuecomment-188329671
Of course, you're right. Also in the batch guide :-)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well.
[
https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15163269#comment-15163269
]
ASF GitHub Bot commented on FLINK-1159:
---
Github user tillrohrmann commented on the p
[
https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15163252#comment-15163252
]
ASF GitHub Bot commented on FLINK-1159:
---
Github user stefanobaghino commented on the
Github user stefanobaghino commented on the pull request:
https://github.com/apache/flink/pull/1704#issuecomment-188325067
Just the streaming guide? Not on both the streaming and batch?
---
If your project is set up for it, you can reply to this email and have your
reply appear on Git
[
https://issues.apache.org/jira/browse/FLINK-3435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15163249#comment-15163249
]
ASF GitHub Bot commented on FLINK-3435:
---
Github user aljoscha commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-3435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15163248#comment-15163248
]
ASF GitHub Bot commented on FLINK-3435:
---
Github user aljoscha commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1699#issuecomment-188322569
About not allowing negative timestamps/watermarks and so on.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as w
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1699#issuecomment-188322336
The comment above is not valid anymore, right?
---
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
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1704#issuecomment-188320230
How do you want to do the implicit conversion if you return a `DataSet[T]`.
If it makes the code more readable, then I think it's a good idea :-)
We should
1 - 100 of 246 matches
Mail list logo
