[
https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15774190#comment-15774190
]
ASF GitHub Bot commented on FLINK-5280:
---
Github user mushketyk commented on the issu
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/3039
Hi @wuchong
I've updated the PR according to your comments. Could you please review it
again?
---
If your project is set up for it, you can reply to this email and have your
reply appear
Ted Yu created FLINK-5391:
-
Summary: Unprotected access to shutdown in
AbstractNonHaServices#checkNotShutdown()
Key: FLINK-5391
URL: https://issues.apache.org/jira/browse/FLINK-5391
Project: Flink
I
Ted Yu created FLINK-5390:
-
Summary: input should be closed in finally block in
YarnFlinkApplicationMasterRunner#loadJobGraph()
Key: FLINK-5390
URL: https://issues.apache.org/jira/browse/FLINK-5390
Project: F
[
https://issues.apache.org/jira/browse/FLINK-5379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eron Wright reassigned FLINK-5379:
---
Assignee: Eron Wright
> Flink CliFrontend does not return when not logged in with kerberos
>
[
https://issues.apache.org/jira/browse/FLINK-4088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-4088:
-
Assignee: Minudika Malshan
> Add interface to save and load TableSources
> ---
[
https://issues.apache.org/jira/browse/FLINK-4088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15773864#comment-15773864
]
Fabian Hueske commented on FLINK-4088:
--
Sure, I assigned the issue to you and gave yo
[
https://issues.apache.org/jira/browse/FLINK-3850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15773852#comment-15773852
]
ASF GitHub Bot commented on FLINK-3850:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3040
Thanks for the PR @NickolayVasilishin!
I briefly skimmed over the changes and the approach looks OK.
It would be good to have a unit test for `FieldForwardingUtils`.
I'm currently on
[
https://issues.apache.org/jira/browse/FLINK-5389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Solovev updated FLINK-5389:
-
Description: {{testAnswerFailureWhenSavepointReadFails}} fails in
{{JobSubmitTest}} when {{timeou
[
https://issues.apache.org/jira/browse/FLINK-5389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Solovev updated FLINK-5389:
-
Environment: macOS sierra
Labels: test (was: )
> Fails #testAnswerFailureWhenSavepointRe
Anton Solovev created FLINK-5389:
Summary: Fails #testAnswerFailureWhenSavepointReadFails
Key: FLINK-5389
URL: https://issues.apache.org/jira/browse/FLINK-5389
Project: Flink
Issue Type: Bug
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3027
Thanks @tonycox. The changes look good. I'd would add one more test case to
cover the case of `Row` objects with `null` fields.
---
If your project is set up for it, you can reply to this email and
[
https://issues.apache.org/jira/browse/FLINK-5358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15773802#comment-15773802
]
ASF GitHub Bot commented on FLINK-5358:
---
Github user fhueske commented on the issue:
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3027#discussion_r93805887
--- Diff:
flink-core/src/test/java/org/apache/flink/api/java/typeutils/TypeExtractorTest.java
---
@@ -345,8 +346,25 @@ public CustomType cross(CustomType fir
[
https://issues.apache.org/jira/browse/FLINK-5358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15773800#comment-15773800
]
ASF GitHub Bot commented on FLINK-5358:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15773795#comment-15773795
]
Fabian Hueske commented on FLINK-3849:
--
Yes, this would be the way to go, IMO. The tr
[
https://issues.apache.org/jira/browse/FLINK-4088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15773702#comment-15773702
]
Minudika Malshan commented on FLINK-4088:
-
Hi,
I would like to work on this. Could
[
https://issues.apache.org/jira/browse/FLINK-3257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15773700#comment-15773700
]
ASF GitHub Bot commented on FLINK-3257:
---
Github user senorcarbone commented on the i
Github user senorcarbone commented on the issue:
https://github.com/apache/flink/pull/1668
@StephanEwen could you check my question above?
---
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 thi
[
https://issues.apache.org/jira/browse/FLINK-4410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15773677#comment-15773677
]
ASF GitHub Bot commented on FLINK-4410:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3042
I think what would put a cherry on top is if we can break the "End To End
Duration" down into
- Delay till triggering (how long until all barriers were there)
- Synchronous checkpoint
[
https://issues.apache.org/jira/browse/FLINK-4410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15773681#comment-15773681
]
ASF GitHub Bot commented on FLINK-4410:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3042
Wow, this looks awesome, great work.
Small note: In screenshot 2, it says "End to Duration", which should
probably be "End to End Duration".
Is there also a column that shows the
[
https://issues.apache.org/jira/browse/FLINK-5388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Solovev reassigned FLINK-5388:
Assignee: Anton Solovev
> Remove private access of edges and vertices of Gelly Graph class
[
https://issues.apache.org/jira/browse/FLINK-4410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15773649#comment-15773649
]
ASF GitHub Bot commented on FLINK-4410:
---
GitHub user uce opened a pull request:
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/3042
[FLINK-4410] Expose more fine grained checkpoint statistics
This PR exposes more fine grained checkpoint statistics. The previous
version of the tracking code had a couple of short comings:
- Only c
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/3039#discussion_r93797831
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -340,25 +331,8 @@ abstract class TableEnviron
[
https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15773574#comment-15773574
]
ASF GitHub Bot commented on FLINK-5280:
---
Github user mushketyk commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-4131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-4131.
--
Resolution: Duplicate
> Confusing error for out dated RequestPartitionState
> --
[
https://issues.apache.org/jira/browse/FLINK-5180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-5180.
--
Resolution: Invalid
> Include blocked on bounded queue length in back pressure stats
> -
Github user mtunique closed the pull request at:
https://github.com/apache/flink/pull/3041
---
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
GitHub user mtunique opened a pull request:
https://github.com/apache/flink/pull/3041
Flink 5084 tmp
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your changes take all of the items into ac
[
https://issues.apache.org/jira/browse/FLINK-5388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15773242#comment-15773242
]
wouter ligtenberg commented on FLINK-5388:
--
For my purpose, yes i think it is
>
[
https://issues.apache.org/jira/browse/FLINK-5388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15773226#comment-15773226
]
Greg Hogan commented on FLINK-5388:
---
Is it sufficient to change {{Graph.()}} to {{protec
[
https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15773176#comment-15773176
]
ASF GitHub Bot commented on FLINK-5280:
---
Github user wuchong commented on a diff in
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3039#discussion_r93780163
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSource.java
---
@@ -111,24 +112,17
[
https://issues.apache.org/jira/browse/FLINK-5388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15773154#comment-15773154
]
wouter ligtenberg commented on FLINK-5388:
--
I have created a Temporal graph tool
[
https://issues.apache.org/jira/browse/FLINK-5388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15773126#comment-15773126
]
Anton Solovev commented on FLINK-5388:
--
[~otherwise777] could you provide an example
[
https://issues.apache.org/jira/browse/FLINK-4313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Solovev closed FLINK-4313.
Resolution: Won't Fix
outdated
> Inconsistent code for Key/Value in the CheckpointCoordinator
> ---
[
https://issues.apache.org/jira/browse/FLINK-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Solovev reassigned FLINK-4228:
Assignee: Anton Solovev
> RocksDB semi-async snapshot to S3AFileSystem fails
>
[
https://issues.apache.org/jira/browse/FLINK-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Solovev updated FLINK-4228:
-
Assignee: (was: Anton Solovev)
> RocksDB semi-async snapshot to S3AFileSystem fails
>
[
https://issues.apache.org/jira/browse/FLINK-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15773084#comment-15773084
]
Cliff Resnick commented on FLINK-4228:
--
My last pull request is good to go so I guess
[
https://issues.apache.org/jira/browse/FLINK-4651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-4651:
---
Fix Version/s: (was: 1.1.4)
1.1.5
> Re-register processing time timers at the W
[
https://issues.apache.org/jira/browse/FLINK-5322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-5322:
---
Fix Version/s: (was: 1.1.4)
1.1.5
> Clean up yarn configuration documentation
>
[
https://issues.apache.org/jira/browse/FLINK-5210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-5210:
---
Fix Version/s: (was: 1.1.4)
1.1.5
> Failing performCheckpoint method causes tas
[
https://issues.apache.org/jira/browse/FLINK-5227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-5227:
---
Fix Version/s: (was: 1.1.4)
1.1.5
> Add warning to include flink-table in job f
[
https://issues.apache.org/jira/browse/FLINK-5302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-5302:
---
Fix Version/s: (was: 1.1.4)
(was: 1.2.0)
> Log failure cause at Execution
[
https://issues.apache.org/jira/browse/FLINK-5233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-5233:
---
Fix Version/s: (was: 1.1.4)
> Upgrade Jackson version because of class loader leak
> -
[
https://issues.apache.org/jira/browse/FLINK-5375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-5375:
---
Fix Version/s: (was: 1.1.4)
1.1.5
> Fix watermark documentation
> -
[
https://issues.apache.org/jira/browse/FLINK-5382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sachin Goel reassigned FLINK-5382:
--
Assignee: Sachin Goel
> Taskmanager log download button causes 404
> --
[
https://issues.apache.org/jira/browse/FLINK-5380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sachin Goel reassigned FLINK-5380:
--
Assignee: Sachin Goel
> Number of outgoing records not reported in web interface
>
[
https://issues.apache.org/jira/browse/FLINK-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15773024#comment-15773024
]
Anton Solovev commented on FLINK-4228:
--
so do you want to continue on this?
> RocksD
[
https://issues.apache.org/jira/browse/FLINK-3850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15772984#comment-15772984
]
ASF GitHub Bot commented on FLINK-3850:
---
GitHub user NickolayVasilishin opened a pul
GitHub user NickolayVasilishin opened a pull request:
https://github.com/apache/flink/pull/3040
[FLINK-3850] Add forward field annotations to DataSet
Add forward field annotations to DataSet operators generated by the Table
API
- Added field forwarding at most of `DataSe
[
https://issues.apache.org/jira/browse/FLINK-5282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Solovev reassigned FLINK-5282:
Assignee: Anton Solovev
> CheckpointStateOutputStream should be closed in finally block in
[
https://issues.apache.org/jira/browse/FLINK-5282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Solovev closed FLINK-5282.
> CheckpointStateOutputStream should be closed in finally block in
> SavepointV0Serializer#convertKeyed
[
https://issues.apache.org/jira/browse/FLINK-5282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Solovev updated FLINK-5282:
-
Assignee: Stefan Richter (was: Anton Solovev)
> CheckpointStateOutputStream should be closed in f
[
https://issues.apache.org/jira/browse/FLINK-5384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Solovev updated FLINK-5384:
-
Description:
must be closed:
FLINK-37 -> from stratosphere;
FLINK-87 -> from stratosphere;
FLINK-4
[
https://issues.apache.org/jira/browse/FLINK-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15772906#comment-15772906
]
Cliff Resnick commented on FLINK-4228:
--
The issue now is exclusive to running on YARN
[
https://issues.apache.org/jira/browse/FLINK-5282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15772899#comment-15772899
]
Ted Yu commented on FLINK-5282:
---
commit 8cda6a2260bbbd8e84349f0204d2980cfdd5a48a
Author: Ste
[
https://issues.apache.org/jira/browse/FLINK-5282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu resolved FLINK-5282.
---
Resolution: Fixed
> CheckpointStateOutputStream should be closed in finally block in
> SavepointV0Serializer#
wouter ligtenberg created FLINK-5388:
Summary: Remove private access of edges and vertices of Gelly
Graph class
Key: FLINK-5388
URL: https://issues.apache.org/jira/browse/FLINK-5388
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15772879#comment-15772879
]
ASF GitHub Bot commented on FLINK-5280:
---
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/3039#discussion_r93764349
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSource.java
---
@@ -111,24 +112,1
[
https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15772868#comment-15772868
]
ASF GitHub Bot commented on FLINK-5280:
---
Github user wuchong commented on a diff in
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3039#discussion_r93763884
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSource.java
---
@@ -111,24 +112,17
[
https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15772859#comment-15772859
]
ASF GitHub Bot commented on FLINK-5280:
---
Github user wuchong commented on a diff in
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3039#discussion_r93763491
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/TableSource.scala
---
@@ -19,21 +19,32 @@
package org.apache.flink.t
[
https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15772837#comment-15772837
]
ASF GitHub Bot commented on FLINK-5280:
---
Github user mushketyk commented on the issu
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/3039
Hi @wuchong
Thank you for review. I'll try to update the PR today.
---
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
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/3039#discussion_r93762225
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/TableSourceTable.scala
---
@@ -25,6 +25,6 @@ import org.apache.flin
[
https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15772834#comment-15772834
]
ASF GitHub Bot commented on FLINK-5280:
---
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/3039#discussion_r93762178
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/FlinkTable.scala
---
@@ -44,14 +44,14 @@ abstract class FlinkTable[
[
https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15772836#comment-15772836
]
ASF GitHub Bot commented on FLINK-5280:
---
Github user mushketyk commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15772832#comment-15772832
]
ASF GitHub Bot commented on FLINK-5280:
---
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/3039#discussion_r93762127
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/BatchTableSourceScan.scala
---
@@ -38,7 +38,9 @@ class Batch
[
https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15772830#comment-15772830
]
ASF GitHub Bot commented on FLINK-5280:
---
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/3039#discussion_r93762016
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/TableSourceTable.scala
---
@@ -25,6 +25,6 @@ import org.apache.flin
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/3039#discussion_r93761979
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSource.java
---
@@ -111,24 +112,1
[
https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15772829#comment-15772829
]
ASF GitHub Bot commented on FLINK-5280:
---
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/3039#discussion_r93761987
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSource.java
---
@@ -111,24 +112,1
[
https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15772828#comment-15772828
]
ASF GitHub Bot commented on FLINK-5280:
---
Github user mushketyk commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15772825#comment-15772825
]
ASF GitHub Bot commented on FLINK-5280:
---
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/3039#discussion_r93761841
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/TableSource.scala
---
@@ -19,21 +19,32 @@
package org.apache.flink
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/3039#discussion_r93761823
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/TableSource.scala
---
@@ -19,21 +19,32 @@
package org.apache.flink
[
https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15772822#comment-15772822
]
ASF GitHub Bot commented on FLINK-5280:
---
Github user mushketyk commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15772824#comment-15772824
]
ASF GitHub Bot commented on FLINK-5280:
---
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/3039#discussion_r93761791
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/TableSource.scala
---
@@ -19,21 +19,32 @@
package org.apache.flink
[
https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15772819#comment-15772819
]
ASF GitHub Bot commented on FLINK-5280:
---
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/3039#discussion_r93761574
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -535,4 +509,74 @@ object TableEnvironment {
[
https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15772816#comment-15772816
]
ASF GitHub Bot commented on FLINK-5280:
---
Github user mushketyk commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15772813#comment-15772813
]
ASF GitHub Bot commented on FLINK-5280:
---
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/3039#discussion_r93761556
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -535,4 +509,74 @@ object TableEnvironment {
[
https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15772815#comment-15772815
]
ASF GitHub Bot commented on FLINK-5280:
---
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/3039#discussion_r93761548
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -535,4 +509,74 @@ object TableEnvironment {
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/3039#discussion_r93761442
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -535,4 +509,74 @@ object TableEnvironment {
[
https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15772811#comment-15772811
]
ASF GitHub Bot commented on FLINK-5280:
---
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/3039#discussion_r93761407
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -535,4 +509,74 @@ object TableEnvironment {
[
https://issues.apache.org/jira/browse/FLINK-5384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Solovev updated FLINK-5384:
-
Description:
must be closed:
FLINK-37 -> from stratosphere;
FLINK-87 -> from stratosphere;
FLINK-4
1 - 100 of 155 matches
Mail list logo
