Github user tzulitai commented on the pull request:
https://github.com/apache/flink/commit/eece0dd05bc38b88fcb6cbcef15add7f98eab456#commitcomment-19297476
Thanks for the fix, seems like I wasn't quite concentrated on the review :/
---
If your project is set up for it, you can reply
[
https://issues.apache.org/jira/browse/FLINK-4723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15547536#comment-15547536
]
ASF GitHub Bot commented on FLINK-4723:
---
Github user tzulitai commented on the issue
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2580
Thanks for the review @StephanEwen.
Concerning changing the contract for `commitSpecificOffsetsToKafka`:
Makes sense, I don't really like excessive copying too. With proper tests
on bot
[
https://issues.apache.org/jira/browse/FLINK-4514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-4514:
---
Fix Version/s: (was: 1.1.2)
1.1.3
> ExpiredIteratorException in
[
https://issues.apache.org/jira/browse/FLINK-4742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matt Zimmer updated FLINK-4742:
---
Description:
We have a test that otherwise passed on our CI server, but failed with an NPE
on the lin
Matt Zimmer created FLINK-4742:
--
Summary: NPE in WindowOperator.trigger() on shutdown
Key: FLINK-4742
URL: https://issues.apache.org/jira/browse/FLINK-4742
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-4260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15547157#comment-15547157
]
Neelesh Srinivas Salian commented on FLINK-4260:
Hey [~miaoever], do you h
[
https://issues.apache.org/jira/browse/FLINK-4741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joseph Sims updated FLINK-4741:
---
Component/s: (was: Core)
> WebRuntimeMonitor does not shut down all of it's threads (EventLoopGrou
[
https://issues.apache.org/jira/browse/FLINK-4741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joseph Sims updated FLINK-4741:
---
Priority: Minor (was: Major)
> WebRuntimeMonitor does not shut down all of it's threads (EventLoopGro
[
https://issues.apache.org/jira/browse/FLINK-4741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joseph Sims updated FLINK-4741:
---
Component/s: Webfrontend
> WebRuntimeMonitor does not shut down all of it's threads (EventLoopGroups)
Joseph Sims created FLINK-4741:
--
Summary: WebRuntimeMonitor does not shut down all of it's threads
(EventLoopGroups) on exit.
Key: FLINK-4741
URL: https://issues.apache.org/jira/browse/FLINK-4741
Project
[
https://issues.apache.org/jira/browse/FLINK-4729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15546531#comment-15546531
]
ASF GitHub Bot commented on FLINK-4729:
---
Github user vasia commented on the issue:
Github user vasia commented on the issue:
https://github.com/apache/flink/pull/2587
Great cleanup! Thanks @greghogan. +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
Greg Hogan created FLINK-4740:
-
Summary: Upgrade testing libraries
Key: FLINK-4740
URL: https://issues.apache.org/jira/browse/FLINK-4740
Project: Flink
Issue Type: Improvement
Component
[
https://issues.apache.org/jira/browse/FLINK-4734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15546360#comment-15546360
]
ASF GitHub Bot commented on FLINK-4734:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2590
I think that makes a lot of sense!
---
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
enabl
[
https://issues.apache.org/jira/browse/FLINK-4735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15546359#comment-15546359
]
Greg Hogan commented on FLINK-4735:
---
Apologies for sending the PR for FLINK-4734 to this
[
https://issues.apache.org/jira/browse/FLINK-4739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15546354#comment-15546354
]
ASF GitHub Bot commented on FLINK-4739:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2591
This is very helpful, thanks!
Merging 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 hav
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2578
I think this is good. Merging 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 feature
en
[
https://issues.apache.org/jira/browse/FLINK-4730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15546343#comment-15546343
]
ASF GitHub Bot commented on FLINK-4730:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-4730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15546342#comment-15546342
]
ASF GitHub Bot commented on FLINK-4730:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2583#discussion_r81829124
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java
---
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2583#discussion_r81829995
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointMetaData.java
---
@@ -0,0 +1,140 @@
+/*
+ * Licensed to the A
[
https://issues.apache.org/jira/browse/FLINK-4739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15546239#comment-15546239
]
ASF GitHub Bot commented on FLINK-4739:
---
GitHub user sthm opened a pull request:
GitHub user sthm opened a pull request:
https://github.com/apache/flink/pull/2591
[FLINK-4739] Adding packaging details for the Elasticsearch connector
When an uber-jar containing an Elasticsearch sink is executed, an
IllegalArgumentException may occur, which is caused by conflic
Steffen Hausmann created FLINK-4739:
---
Summary: Adding packaging details for the Elasticsearch connector
Key: FLINK-4739
URL: https://issues.apache.org/jira/browse/FLINK-4739
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15546180#comment-15546180
]
ASF GitHub Bot commented on FLINK-4735:
---
GitHub user greghogan opened a pull request
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/2590
[FLINK-4735] [gelly] Remove use of Tuple setField for fixed position
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/greghogan/flink
4734_rem
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15546155#comment-15546155
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user greghogan commented on a diff i
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81816707
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java
---
@@ -0,0 +1,272 @@
+/*
+ * Licensed to the Apache
Till Rohrmann created FLINK-4738:
Summary: Port TaskManager logic to TaskExecutor
Key: FLINK-4738
URL: https://issues.apache.org/jira/browse/FLINK-4738
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-4723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545989#comment-15545989
]
ASF GitHub Bot commented on FLINK-4723:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2580
Looks quite good. I would suggest one change, though:
Can we avoid copying the offsets in the checkpoint into a new map (with
increment by one) and passing that to the ZooKeeper Offset Co
GitHub user vijikarthi opened a pull request:
https://github.com/apache/flink/pull/2589
FLINK-3932 State Backend Security
This PR addresses ZK authorization (ACLs) requirement of FLINK-3932 and its
dependency FLINK-4667 (Yarn session CLI not using correct ZK namespace in
secure env
[
https://issues.apache.org/jira/browse/FLINK-3932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545908#comment-15545908
]
ASF GitHub Bot commented on FLINK-3932:
---
GitHub user vijikarthi opened a pull reques
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545884#comment-15545884
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user mushketyk commented on a diff i
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81797332
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java
---
@@ -0,0 +1,272 @@
+/*
+ * Licensed to the Apache
Stephan Ewen created FLINK-4737:
---
Summary: Add more compression algorithms to FileInputFormat
Key: FLINK-4737
URL: https://issues.apache.org/jira/browse/FLINK-4737
Project: Flink
Issue Type: Im
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2002
Sorry for the delay. This looks good to me, let's merge it and add further
changes separately.
Will merge this...
---
If your project is set up for it, you can reply to this email and h
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545784#comment-15545784
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user mushketyk commented on a diff i
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81787532
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteEdge.java
---
@@ -0,0 +1,69 @@
+/*
+ * Licensed to the Apache S
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545783#comment-15545783
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user mushketyk commented on a diff i
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81787458
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java
---
@@ -0,0 +1,272 @@
+/*
+ * Licensed to the Apache
Greg Hogan created FLINK-4736:
-
Summary: Don't duplicate fields in Ordering
Key: FLINK-4736
URL: https://issues.apache.org/jira/browse/FLINK-4736
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-4735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545661#comment-15545661
]
ASF GitHub Bot commented on FLINK-4735:
---
GitHub user KurtYoung opened a pull request
GitHub user KurtYoung opened a pull request:
https://github.com/apache/flink/pull/2588
[FLINK-4735] [cluster management] Migrate some job execution related akka
messages to rpc calls
This includes the following operations about job execution:
1. checkpointing
2. kvstate
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545633#comment-15545633
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user greghogan commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545634#comment-15545634
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user greghogan commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545637#comment-15545637
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user greghogan commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545635#comment-15545635
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user greghogan commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545632#comment-15545632
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user greghogan commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545636#comment-15545636
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user greghogan commented on a diff i
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81779541
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java
---
@@ -0,0 +1,272 @@
+/*
+ * Licensed to the Apache
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81781081
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java
---
@@ -0,0 +1,272 @@
+/*
+ * Licensed to the Apache
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81780392
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/Projection.java
---
@@ -0,0 +1,55 @@
+/*
+ * Licensed to the Apache Soft
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81781488
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java
---
@@ -0,0 +1,272 @@
+/*
+ * Licensed to the Apache
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81776392
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java
---
@@ -0,0 +1,272 @@
+/*
+ * Licensed to the Apache
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81777101
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteEdge.java
---
@@ -0,0 +1,69 @@
+/*
+ * Licensed to the Apache S
[
https://issues.apache.org/jira/browse/FLINK-4510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545579#comment-15545579
]
ASF GitHub Bot commented on FLINK-4510:
---
Github user StefanRRichter commented on the
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/2453
Thanks for the nice contribution.
I see one minor detail that could cause problems. Even if we do not
register the `CheckpointCoordinator` as `JobStatusListener`, it might still be
po
Kurt Young created FLINK-4735:
-
Summary: Migrate some job execution related akka messages to rpc
calls
Key: FLINK-4735
URL: https://issues.apache.org/jira/browse/FLINK-4735
Project: Flink
Issue
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2564
Hi @greghogan. Thank you for clarification. I'll update code accordingly.
Do you have any other comments regarding the PR?
---
If your project is set up for it, you can reply to this email and hav
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545557#comment-15545557
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user mushketyk commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545483#comment-15545483
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2564
The advantage to joining on vertex values before the grouped cross is that
the number of projected vertices is quadratic in the vertex degree. The
projected graphs will usually be much larger than
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81764640
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java
---
@@ -0,0 +1,272 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545473#comment-15545473
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user greghogan commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-2157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545423#comment-15545423
]
ASF GitHub Bot commented on FLINK-2157:
---
Github user thvasilo commented on the issue
Github user thvasilo commented on the issue:
https://github.com/apache/flink/pull/1849
@gaborhermann In terms of missing features, documentation is definitely
missing, as @rawkintrevo mentioned.
For the issues mentioned in the JIRA issue you linked I've replied on the
dev lis
[
https://issues.apache.org/jira/browse/FLINK-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-4311:
-
Fix Version/s: 1.1.3
> TableInputFormat fails when reused on next split
>
[
https://issues.apache.org/jira/browse/FLINK-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545404#comment-15545404
]
Fabian Hueske commented on FLINK-4311:
--
Merged for Flink 1.1 as 98b399d4b4ddc9ab5d01e
[
https://issues.apache.org/jira/browse/FLINK-4732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545403#comment-15545403
]
ASF GitHub Bot commented on FLINK-4732:
---
Github user mxm commented on the issue:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2586
Merged to `master` and `release-1.1`.
@uce I also like the symbolic link. I contacted the maintainer of the
plugin because it wouldn't be hard to fix this nowadays with Java 7+ which
supports th
Greg Hogan created FLINK-4734:
-
Summary: Remove use of Tuple setField for fixed position
Key: FLINK-4734
URL: https://issues.apache.org/jira/browse/FLINK-4734
Project: Flink
Issue Type: Improveme
[
https://issues.apache.org/jira/browse/FLINK-4732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-4732.
-
Resolution: Fixed
master: 5a573c6bc29c313d34981336d5bfc05185d323d2
release-1.1: a31a22ec7f
[
https://issues.apache.org/jira/browse/FLINK-4732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545390#comment-15545390
]
ASF GitHub Bot commented on FLINK-4732:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2586
---
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-4732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545385#comment-15545385
]
ASF GitHub Bot commented on FLINK-4732:
---
Github user mxm commented on the issue:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2586
Merging to both branches.
---
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,
[
https://issues.apache.org/jira/browse/FLINK-4729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545351#comment-15545351
]
ASF GitHub Bot commented on FLINK-4729:
---
GitHub user greghogan opened a pull request
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/2587
[FLINK-4729] [gelly] Use optional VertexCentric CombineFunction
Passes through the CombineFunction to VertexCentricIteration, and other
code cleanup discovered via IntelliJ's code analyzer.
You
[
https://issues.apache.org/jira/browse/FLINK-4546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-4546.
-
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed in 72e6b760fd951764c3ecc6fc191dc99a42d55e0b.
[
https://issues.apache.org/jira/browse/FLINK-4546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545344#comment-15545344
]
ASF GitHub Bot commented on FLINK-4546:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2454
---
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-4546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545286#comment-15545286
]
ASF GitHub Bot commented on FLINK-4546:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/2454
Thanks @wuchong. Will 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 feature
enabled an
[
https://issues.apache.org/jira/browse/FLINK-4068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-4068.
-
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed in a71133945e66ec471b4cb07da0693d545c40923c an
[
https://issues.apache.org/jira/browse/FLINK-4068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545247#comment-15545247
]
ASF GitHub Bot commented on FLINK-4068:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2560
---
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-4709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545101#comment-15545101
]
ASF GitHub Bot commented on FLINK-4709:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2581
Good fix, thanks a lot!
Merging 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
[
https://issues.apache.org/jira/browse/FLINK-4728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545093#comment-15545093
]
ASF GitHub Bot commented on FLINK-4728:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2582
Thanks, this is a great set of cleanups and fixes. Merging 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 do
[
https://issues.apache.org/jira/browse/FLINK-2157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545063#comment-15545063
]
ASF GitHub Bot commented on FLINK-2157:
---
Github user gaborhermann commented on the i
Github user gaborhermann commented on the issue:
https://github.com/apache/flink/pull/1849
Hi all,
What is the status of this PR?
It would be relevant for us, because we might like to use the evaluation
framework proposed here. See
[FLINK-4713](https://issues.apache.org/j
[
https://issues.apache.org/jira/browse/FLINK-4068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15544993#comment-15544993
]
ASF GitHub Bot commented on FLINK-4068:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/2560
@wuchong I heavily tested this PR again as it could introduce difficult
bugs. And I also found one issue that needs to be discussed. If you have an
expression like `CAST(TRUE AS VARCHAR) || 'Test'` t
[
https://issues.apache.org/jira/browse/FLINK-4731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-4731:
--
Summary: HeapKeyedStateBackend restoring broken for scale-in (was:
HeapKeyedStateBackend restor
[
https://issues.apache.org/jira/browse/FLINK-4730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter reassigned FLINK-4730:
-
Assignee: Stefan Richter
> Introduce CheckpointMetaData
>
>
1 - 100 of 129 matches
Mail list logo