Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/3883
Will address and 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 and wi
[
https://issues.apache.org/jira/browse/FLINK-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009174#comment-16009174
]
ASF GitHub Bot commented on FLINK-6566:
---
Github user tzulitai commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-6565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009170#comment-16009170
]
ASF GitHub Bot commented on FLINK-6565:
---
Github user tzulitai commented on the issue
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/3882
Thanks for the review! Merging to 1.3 / master ..
---
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 f
[
https://issues.apache.org/jira/browse/FLINK-2591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009133#comment-16009133
]
ASF GitHub Bot commented on FLINK-2591:
---
Github user willmiao closed the pull reques
Github user willmiao closed the pull request at:
https://github.com/apache/flink/pull/1121
---
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-6397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009102#comment-16009102
]
ASF GitHub Bot commented on FLINK-6397:
---
Github user ifndef-SleePy commented on the
Github user ifndef-SleePy commented on the issue:
https://github.com/apache/flink/pull/3810
Nice work!
I have rebased master.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
[
https://issues.apache.org/jira/browse/FLINK-6529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008891#comment-16008891
]
Haohui Mai commented on FLINK-6529:
---
Will do. Thanks!
> Rework the shading model in Fli
[
https://issues.apache.org/jira/browse/FLINK-6569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008889#comment-16008889
]
ASF GitHub Bot commented on FLINK-6569:
---
GitHub user haohui opened a pull request:
GitHub user haohui opened a pull request:
https://github.com/apache/flink/pull/3890
[FLINK-6569] flink-table KafkaJsonTableSource example doesn't work.
This PR makes the proposed changes on the document and changes the Java
unit tests to reflect the suggested usages of the API.
You
[
https://issues.apache.org/jira/browse/FLINK-6573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008853#comment-16008853
]
Greg Hogan commented on FLINK-6573:
---
[~naagachowdary] glad to hear of your success and t
Haohui Mai created FLINK-6574:
-
Summary: External catalog should support a single level catalog
Key: FLINK-6574
URL: https://issues.apache.org/jira/browse/FLINK-6574
Project: Flink
Issue Type: Bu
[
https://issues.apache.org/jira/browse/FLINK-6568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008821#comment-16008821
]
Haohui Mai commented on FLINK-6568:
---
Hit the same issue multiple times when testing out
[
https://issues.apache.org/jira/browse/FLINK-6569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai reassigned FLINK-6569:
-
Assignee: Haohui Mai
> flink-table KafkaJsonTableSource example doesn't work
> --
[
https://issues.apache.org/jira/browse/FLINK-6568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai reassigned FLINK-6568:
-
Assignee: Haohui Mai
> flink-table doesn't work without flink-streaming-scala dependency
> --
[
https://issues.apache.org/jira/browse/FLINK-6397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008758#comment-16008758
]
ASF GitHub Bot commented on FLINK-6397:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008760#comment-16008760
]
ASF GitHub Bot commented on FLINK-6548:
---
Github user zentol closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-6561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008761#comment-16008761
]
ASF GitHub Bot commented on FLINK-6561:
---
Github user zentol closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-6558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008762#comment-16008762
]
ASF GitHub Bot commented on FLINK-6558:
---
Github user zentol closed the pull request
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3810
I've fixed the cassandra tests, would be great if you could rebase this PR.
You should be able to discard all changes to the cassandra tests in this PR.
---
If your project is set up for it, you can
Github user zentol closed the pull request at:
https://github.com/apache/flink/pull/3878
---
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 zentol closed the pull request at:
https://github.com/apache/flink/pull/3874
---
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 zentol closed the pull request at:
https://github.com/apache/flink/pull/3871
---
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-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008756#comment-16008756
]
Chesnay Schepler commented on FLINK-4500:
-
The second part of this issue (tracking
[
https://issues.apache.org/jira/browse/FLINK-5101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-5101.
---
Resolution: Fixed
Fix Version/s: 1.4.0
1.3.0
1.3: a85b1881d184c02075
[
https://issues.apache.org/jira/browse/FLINK-6548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-6548.
---
Resolution: Fixed
1.3: c743f14ecb08f39a3f7278340a89d1a035749aa7
1.4: 2ebebdfc7561a36d76d9c3f6c
[
https://issues.apache.org/jira/browse/FLINK-6558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-6558.
---
Resolution: Fixed
1.3: f0ff5046901c507d34675375c85a1f17e6d4ecdb
1.4: 2201fab1c740b8c3aa6d14ecf
[
https://issues.apache.org/jira/browse/FLINK-6558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reopened FLINK-6558:
-
> Yarn tests fail on Windows
> --
>
> Key: FLINK-6558
[
https://issues.apache.org/jira/browse/FLINK-6558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-6558.
---
Resolution: Fixed
Fix Version/s: 1.4.0
1.3.0
> Yarn tests fail on Wi
[
https://issues.apache.org/jira/browse/FLINK-5101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008741#comment-16008741
]
ASF GitHub Bot commented on FLINK-5101:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-6561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-6561.
---
Resolution: Fixed
Fix Version/s: 1.4.0
1.3.0
1.3: f3ce0885fc09b3b685
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2866
---
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-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-6013.
---
Resolution: Fixed
Fix Version/s: 1.4.0
1.3: 625da00a5797c29969b947f69ccda91ef87eb5c4
>
Nagamallikarjuna created FLINK-6573:
---
Summary: Flink MongoDB Connector
Key: FLINK-6573
URL: https://issues.apache.org/jira/browse/FLINK-6573
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008545#comment-16008545
]
ASF GitHub Bot commented on FLINK-6075:
---
Github user rtudoran commented on the issue
Github user rtudoran commented on the issue:
https://github.com/apache/flink/pull/3714
@fhueske
Please refer to #3889 which contains the same code updated to the new
interfaces
---
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-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008546#comment-16008546
]
ASF GitHub Bot commented on FLINK-6075:
---
Github user rtudoran commented on the issue
Github user rtudoran commented on the issue:
https://github.com/apache/flink/pull/3889
@fhueske I updated the code to work with 1.3 (CRow, FlinkLogicalSort)
and all the implied changes.
We can close #3714 after we merge this i guess
..that one is the same logical code only
[
https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008544#comment-16008544
]
ASF GitHub Bot commented on FLINK-6075:
---
GitHub user rtudoran opened a pull request:
GitHub user rtudoran opened a pull request:
https://github.com/apache/flink/pull/3889
[FLINK-6075] - Support Limit/Top(Sort) for Stream SQL
Order by time and optionally other fields is supported
Thanks for contributing to Apache Flink. Before you open your pull request,
ple
[
https://issues.apache.org/jira/browse/FLINK-6116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008536#comment-16008536
]
Robert Metzger commented on FLINK-6116:
---
I'm fine with leaving this open for the 1.3
[
https://issues.apache.org/jira/browse/FLINK-5095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008517#comment-16008517
]
Chesnay Schepler commented on FLINK-5095:
-
The following is what is sketched out a
[
https://issues.apache.org/jira/browse/FLINK-5095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008430#comment-16008430
]
Bowen Li commented on FLINK-5095:
-
[~Zentol] Can you list your proposed interfaces here? W
[
https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-5256.
Implemented for 1.3 with 01171e821699a4c1e5f7a73f878d696552354ab4
Implemented for 1.4 with ef751b2a1636d
[
https://issues.apache.org/jira/browse/FLINK-6562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-6562.
Resolution: Fixed
Fix Version/s: 1.4.0
1.3.0
Fixed for 1.3 with f49edf58ed
[
https://issues.apache.org/jira/browse/FLINK-6020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008382#comment-16008382
]
ASF GitHub Bot commented on FLINK-6020:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/3888
[FLINK-6020] Introduce BlobServer#readWriteLock to synchronize file
creation and deletion
This PR is based on #3873 and #3864.
This commit introduces a BlobServer#readWriteLock in orde
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3673
---
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-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008371#comment-16008371
]
ASF GitHub Bot commented on FLINK-5256:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3879
---
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-6562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008370#comment-16008370
]
ASF GitHub Bot commented on FLINK-6562:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008353#comment-16008353
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008356#comment-16008356
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008361#comment-16008361
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008358#comment-16008358
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008357#comment-16008357
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008352#comment-16008352
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008354#comment-16008354
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008355#comment-16008355
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008359#comment-16008359
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008360#comment-16008360
]
ASF GitHub Bot commented on FLINK-6232:
---
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/3715#discussion_r116272631
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeInnerJoin.scala
---
@@ -0,0 +1,323 @@
+/*
+ * Licen
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r116269111
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamJoin.scala
---
@@ -159,9 +172,9 @@ class DataStr
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r116268688
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamJoin.scala
---
@@ -0,0 +1,180 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r116272041
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeInnerJoin.scala
---
@@ -44,12 +48,18 @@ import org.apache.f
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r116270545
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/JoinUtil.scala
---
@@ -199,31 +157,38 @@ object JoinUtil {
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r116273281
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeInnerJoin.scala
---
@@ -298,16 +289,17 @@ class ProcTimeInn
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r116261121
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamJoin.scala
---
@@ -37,14 +39,18 @@ import org.ap
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r116261221
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamJoin.scala
---
@@ -37,14 +39,18 @@ import org.ap
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r116260594
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -698,14 +698,7 @@ class CodeGenerator(
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r116269180
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamJoin.scala
---
@@ -159,9 +172,9 @@ class DataStr
[
https://issues.apache.org/jira/browse/FLINK-6462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008350#comment-16008350
]
ASF GitHub Bot commented on FLINK-6462:
---
Github user sunjincheng121 commented on the
Github user sunjincheng121 commented on the issue:
https://github.com/apache/flink/pull/3851
Hi @fhueske, Thanks for the reviewing.
I forgot to run the `mvn verify` at the first time. Sorry for that.:(
I had update the PR. according your comments. Except one,i.e.:
Move `sca
GitHub user patricklucas opened a pull request:
https://github.com/apache/flink/pull/3887
[hotfix] [docs] Fix link to docker-compose.yml
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/patricklucas/flink
hotfix_update_docker_com
[
https://issues.apache.org/jira/browse/FLINK-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008336#comment-16008336
]
ASF GitHub Bot commented on FLINK-6013:
---
Github user bowenli86 commented on the issu
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/3736
Cool! 1.3 here we go!
---
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 s
[
https://issues.apache.org/jira/browse/FLINK-6572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joshua Griffith updated FLINK-6572:
---
Summary: Make configuration properties available as env vars in Docker
image (was: Make Flink
Joshua Griffith created FLINK-6572:
--
Summary: Make Flink configuration properties available as env vars
in Docker image
Key: FLINK-6572
URL: https://issues.apache.org/jira/browse/FLINK-6572
Project:
Github user DmytroShkvyra commented on a diff in the pull request:
https://github.com/apache/flink/pull/3673#discussion_r116255981
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/logical/FlinkLogicalJoin.scala
---
@@ -77,7 +77,9 @@ private cl
[
https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008271#comment-16008271
]
ASF GitHub Bot commented on FLINK-5256:
---
Github user DmytroShkvyra commented on a di
[
https://issues.apache.org/jira/browse/FLINK-5363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008264#comment-16008264
]
ASF GitHub Bot commented on FLINK-5363:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/3034
@aljoscha can the new behavior be demonstrated by a test?
---
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 ha
[
https://issues.apache.org/jira/browse/FLINK-6043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008257#comment-16008257
]
ASF GitHub Bot commented on FLINK-6043:
---
Github user greghogan commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-6043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008258#comment-16008258
]
ASF GitHub Bot commented on FLINK-6043:
---
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/3583#discussion_r116251216
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java
---
@@ -955,14 +950,33 @@ public void stop() throws Stop
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/3583#discussion_r116250328
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ErrorInfo.java
---
@@ -0,0 +1,84 @@
+/*
+ * Licensed to the Apache S
Chesnay Schepler created FLINK-6571:
---
Summary: InfiniteSource in SourceStreamOperatorTest should deal
with InterruptedExceptions
Key: FLINK-6571
URL: https://issues.apache.org/jira/browse/FLINK-6571
[
https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008255#comment-16008255
]
ASF GitHub Bot commented on FLINK-5256:
---
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/3673#discussion_r116250994
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/logical/FlinkLogicalJoin.scala
---
@@ -77,7 +77,9 @@ private class Fl
[
https://issues.apache.org/jira/browse/FLINK-6565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008254#comment-16008254
]
ASF GitHub Bot commented on FLINK-6565:
---
Github user StefanRRichter commented on the
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/3882
LGTM +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 not have this feature
enabled and wishes so, or if
Github user zentol commented on the pull request:
https://github.com/apache/flink/commit/423f4d65e3dd35482fdbc2fb7e34ec8f11243609#commitcomment-22120213
In
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/AbstractStreamOperatorTest.java:
In
flink-stream
[
https://issues.apache.org/jira/browse/FLINK-6554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008245#comment-16008245
]
ASF GitHub Bot commented on FLINK-6554:
---
Github user StefanRRichter commented on the
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/3886
LGTM +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 not have this feature
enabled and wishes so, or if
[
https://issues.apache.org/jira/browse/FLINK-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008241#comment-16008241
]
ASF GitHub Bot commented on FLINK-6566:
---
Github user StefanRRichter commented on a d
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/3883#discussion_r116249086
--- Diff:
flink-core/src/main/java/org/apache/flink/core/io/VersionedIOReadableWritable.java
---
@@ -18,55 +18,66 @@
package org.apache.fl
[
https://issues.apache.org/jira/browse/FLINK-6116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008234#comment-16008234
]
Aljoscha Krettek commented on FLINK-6116:
-
Unfortunately, I don't see an easy solu
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/3870
Updated and enhanced.
---
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 wis
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3736
Merging to 1.3 now.
---
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
1 - 100 of 252 matches
Mail list logo
