[jira] [Commented] (FLINK-1284) Uniform random sampling operator over windows

[ https://issues.apache.org/jira/browse/FLINK-1284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15259486#comment-15259486 ] Austin Ouyang commented on FLINK-1284: -- Hi [~till.rohrmann], I've noticed that there

[jira] [Commented] (FLINK-2220) Join on Pojo without hashCode() silently fails

[ https://issues.apache.org/jira/browse/FLINK-2220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15259367#comment-15259367 ] GaoLun commented on FLINK-2220: --- I wrote test for generictype and the problem still arose. T

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15259202#comment-15259202 ] ASF GitHub Bot commented on FLINK-2828: --- Github user fhueske commented on the pull r

[GitHub] flink pull request: [FLINK-2828] [tableAPI] Add TableSource interf...

Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1939#issuecomment-214922363 Thanks for the review @vasia. I addressed your comments. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

[jira] [Commented] (FLINK-2946) Add orderBy() to Table API

[ https://issues.apache.org/jira/browse/FLINK-2946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15259045#comment-15259045 ] ASF GitHub Bot commented on FLINK-2946: --- Github user fhueske commented on the pull r

[jira] [Updated] (FLINK-2971) Add outer joins to the Table API

[ https://issues.apache.org/jira/browse/FLINK-2971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2971: - Assignee: Dawid Wysakowicz > Add outer joins to the Table API > >

[GitHub] flink pull request: [FLINK-2946] Add orderBy() to Table API

Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1926#issuecomment-214903475 Hi @dawidwys, thanks for the fast update. I'll have a look at the PR tomorrow. The JIRA for Table API outer joins is FLINK-2971. I'll assign it to you. Thanks! --

[jira] [Commented] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask

[ https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258912#comment-15258912 ] Konstantin Knauf commented on FLINK-3669: - [~aljoscha] Hmpf. You're right. I was a

[jira] [Commented] (FLINK-3257) Add Exactly-Once Processing Guarantees in Iterative DataStream Jobs

[ https://issues.apache.org/jira/browse/FLINK-3257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258904#comment-15258904 ] ASF GitHub Bot commented on FLINK-3257: --- Github user senorcarbone commented on the p

[GitHub] flink pull request: [FLINK-3257] Add Exactly-Once Processing Guara...

Github user senorcarbone commented on the pull request: https://github.com/apache/flink/pull/1668#issuecomment-214883298 ok good to know @uce! Let me get back to it in a couple of weeks and make it right, now it is a bit impossible to find time. --- If your project is set up for it,

[GitHub] flink pull request: [FLINK-2946] Add orderBy() to Table API

Github user dawidwys commented on the pull request: https://github.com/apache/flink/pull/1926#issuecomment-214862766 I tried to address all your comments. Unfortunately I didn't notice lines longer than 100 yesterday, sorry for that. I started working on outer joins, but unfor

[jira] [Commented] (FLINK-2946) Add orderBy() to Table API

[ https://issues.apache.org/jira/browse/FLINK-2946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258772#comment-15258772 ] ASF GitHub Bot commented on FLINK-2946: --- Github user dawidwys commented on the pull

[jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly

[ https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258680#comment-15258680 ] Saumitra Shahapure commented on FLINK-2254: --- Hi [~vkalavri], I started working o

[jira] [Updated] (FLINK-2254) Add Bipartite Graph Support for Gelly

[ https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Saumitra Shahapure updated FLINK-2254: -- Assignee: (was: Saumitra Shahapure) > Add Bipartite Graph Support for Gelly > --

[jira] [Commented] (FLINK-951) Reworking of Iteration Synchronization, Accumulators and Aggregators

[ https://issues.apache.org/jira/browse/FLINK-951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258599#comment-15258599 ] ASF GitHub Bot commented on FLINK-951: -- Github user markus-h closed the pull request a

[jira] [Commented] (FLINK-951) Reworking of Iteration Synchronization, Accumulators and Aggregators

[ https://issues.apache.org/jira/browse/FLINK-951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258598#comment-15258598 ] ASF GitHub Bot commented on FLINK-951: -- Github user markus-h commented on the pull req

[GitHub] flink pull request: [FLINK-951] Reworking of Iteration Synchroniza...

Github user markus-h commented on the pull request: https://github.com/apache/flink/pull/570#issuecomment-214833775 Sorry for not driving this further. I think this pull request is now way too outdated to have any chance of rebasing it to the current master, therefore I will close it.

[GitHub] flink pull request: [FLINK-951] Reworking of Iteration Synchroniza...

Github user markus-h closed the pull request at: https://github.com/apache/flink/pull/570 --- 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 ena

[jira] [Commented] (FLINK-2899) The groupReduceOn* methods which take types as a parameter fail with TypeErasure

[ https://issues.apache.org/jira/browse/FLINK-2899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258588#comment-15258588 ] Greg Hogan commented on FLINK-2899: --- Is this due to a limitation of {{TypeExtractor.crea

[jira] [Commented] (FLINK-3771) Methods for translating Graphs

[ https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258532#comment-15258532 ] ASF GitHub Bot commented on FLINK-3771: --- Github user greghogan commented on the pull

[GitHub] flink pull request: [FLINK-3771] [gelly] Methods for translating G...

Github user greghogan commented on the pull request: https://github.com/apache/flink/pull/1900#issuecomment-214825734 By reuse I was referring to needing `MapVertexValueLongToString` and `MapEdgeValueLongToString` since the current `Graph` methods operate at the level of `Vertex` and

[jira] [Commented] (FLINK-3771) Methods for translating Graphs

[ https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258510#comment-15258510 ] ASF GitHub Bot commented on FLINK-3771: --- Github user vasia commented on the pull req

[GitHub] flink pull request: [FLINK-3771] [gelly] Methods for translating G...

Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1900#issuecomment-214819709 Implementations of `MapFunction`s can also be reused :) What I was thinking was to provide the translator simply as map functions, e.g. like `Tuple2ToVertexMap`. We can

[jira] [Commented] (FLINK-3717) Add functionality to be a able to restore from specific point in a FileInputFormat

[ https://issues.apache.org/jira/browse/FLINK-3717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258499#comment-15258499 ] ASF GitHub Bot commented on FLINK-3717: --- Github user kl0u commented on the pull requ

[GitHub] flink pull request: FLINK-3717 - Be able to re-start reading from ...

Github user kl0u commented on the pull request: https://github.com/apache/flink/pull/1895#issuecomment-214817636 The problem with this change would be that we do not have yet a way to deserialize a record, so when we are trying to advance readRecords in the block, we have a NULL

[jira] [Updated] (FLINK-3825) Update CEP documentation to include Scala API

[ https://issues.apache.org/jira/browse/FLINK-3825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-3825: - Assignee: Stefan Richter > Update CEP documentation to include Scala API > ---

[GitHub] flink pull request: Flink 3750 fixed

GitHub user fpompermaier opened a pull request: https://github.com/apache/flink/pull/1941 Flink 3750 fixed 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 i

[jira] [Commented] (FLINK-3086) ExpressionParser does not support concatenation of suffix operations

[ https://issues.apache.org/jira/browse/FLINK-3086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258480#comment-15258480 ] ASF GitHub Bot commented on FLINK-3086: --- Github user fhueske commented on the pull r

[GitHub] flink pull request: [FLINK-3086] [table] ExpressionParser does not...

Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1912#issuecomment-214814868 Yes, same here ;-) --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this fea

[jira] [Commented] (FLINK-3750) Make JDBCInputFormat a parallel source

[ https://issues.apache.org/jira/browse/FLINK-3750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258471#comment-15258471 ] ASF GitHub Bot commented on FLINK-3750: --- Github user fpompermaier closed the pull re

[GitHub] flink pull request: Improved JDBCInputFormat (FLINK-3750) and othe...

Github user fpompermaier commented on the pull request: https://github.com/apache/flink/pull/1885#issuecomment-214813684 Sorry messed up... --- 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

[jira] [Commented] (FLINK-3750) Make JDBCInputFormat a parallel source

[ https://issues.apache.org/jira/browse/FLINK-3750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258472#comment-15258472 ] ASF GitHub Bot commented on FLINK-3750: --- Github user fpompermaier commented on the p

[GitHub] flink pull request: Improved JDBCInputFormat (FLINK-3750) and othe...

Github user fpompermaier closed the pull request at: https://github.com/apache/flink/pull/1885 --- 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 i

[jira] [Commented] (FLINK-3800) ExecutionGraphs can become orphans

[ https://issues.apache.org/jira/browse/FLINK-3800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258466#comment-15258466 ] ASF GitHub Bot commented on FLINK-3800: --- Github user asfgit closed the pull request

[jira] [Closed] (FLINK-3800) ExecutionGraphs can become orphans

[ https://issues.apache.org/jira/browse/FLINK-3800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-3800. Resolution: Fixed Fixed via 28c57c3a57cbd7a02e756ee98c0b1168cec69feb > ExecutionGraphs can become o

[GitHub] flink pull request: [FLINK-3800] [jobmanager] Terminate ExecutionG...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1923 --- 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

[jira] [Commented] (FLINK-3800) ExecutionGraphs can become orphans

[ https://issues.apache.org/jira/browse/FLINK-3800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258463#comment-15258463 ] ASF GitHub Bot commented on FLINK-3800: --- Github user tillrohrmann commented on the p

[GitHub] flink pull request: [FLINK-3800] [jobmanager] Terminate ExecutionG...

Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1923#issuecomment-214812452 Unrelated test case failures. Will be merging this PR to master and the 1.0-release branch. --- If your project is set up for it, you can reply to this email and h

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258451#comment-15258451 ] ASF GitHub Bot commented on FLINK-2828: --- Github user vasia commented on a diff in th

[GitHub] flink pull request: [FLINK-2828] [tableAPI] Add TableSource interf...

Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1939#discussion_r61123187 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/schema/TableSourceTable.scala --- @@ -0,0 +1,32 @@ +/* + * License

[jira] [Resolved] (FLINK-3708) Scala API for CEP

[ https://issues.apache.org/jira/browse/FLINK-3708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-3708. -- Resolution: Fixed Added via e29ac036a76cc78ea608ffe1f0784ec15e351c60 > Scala API for CEP >

[jira] [Created] (FLINK-3825) Update CEP documentation to include Scala API

Till Rohrmann created FLINK-3825: Summary: Update CEP documentation to include Scala API Key: FLINK-3825 URL: https://issues.apache.org/jira/browse/FLINK-3825 Project: Flink Issue Type: Impro

[jira] [Created] (FLINK-3824) ResourceManager may repeatedly connect to outdated JobManager in HA mode

Maximilian Michels created FLINK-3824: - Summary: ResourceManager may repeatedly connect to outdated JobManager in HA mode Key: FLINK-3824 URL: https://issues.apache.org/jira/browse/FLINK-3824 Proj

[jira] [Commented] (FLINK-3708) Scala API for CEP

[ https://issues.apache.org/jira/browse/FLINK-3708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258427#comment-15258427 ] ASF GitHub Bot commented on FLINK-3708: --- Github user asfgit closed the pull request

[GitHub] flink pull request: [FLINK-3708] Scala API for CEP (initial).

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1905 --- 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] flink pull request: [FLINK-2828] [tableAPI] Add TableSource interf...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1939#discussion_r61120533 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/schema/TableSourceTable.scala --- @@ -0,0 +1,32 @@ +/* + * Licen

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258417#comment-15258417 ] ASF GitHub Bot commented on FLINK-2828: --- Github user fhueske commented on a diff in

[GitHub] flink pull request: [FLINK-2828] [tableAPI] Add TableSource interf...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1939#discussion_r61121181 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/BatchTableSourceScanRule.scala --- @@ -0,0 +1,71 @@ +/

[jira] [Commented] (FLINK-3708) Scala API for CEP

[ https://issues.apache.org/jira/browse/FLINK-3708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258406#comment-15258406 ] ASF GitHub Bot commented on FLINK-3708: --- Github user tillrohrmann commented on the p

[GitHub] flink pull request: [FLINK-3708] Scala API for CEP (initial).

Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1905#issuecomment-214806804 Failing test case is unrelated. Really good work @StefanRRichter. Will merge it. As a follow up, we should update the CEP documentation to also include Sc

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258402#comment-15258402 ] ASF GitHub Bot commented on FLINK-2828: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258399#comment-15258399 ] ASF GitHub Bot commented on FLINK-2828: --- Github user fhueske commented on a diff in

[GitHub] flink pull request: [FLINK-2828] [tableAPI] Add TableSource interf...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1939#discussion_r61120275 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/datastream/StreamTableSourceScan.scala --- @@ -0,0 +1,126 @@ +

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258398#comment-15258398 ] ASF GitHub Bot commented on FLINK-2828: --- Github user fhueske commented on a diff in

[GitHub] flink pull request: [FLINK-2828] [tableAPI] Add TableSource interf...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1939#discussion_r61120172 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/BatchTableSourceScan.scala --- @@ -0,0 +1,139 @@ +/*

[jira] [Commented] (FLINK-3741) Travis Compile Error: MissingRequirementError: object scala.runtime in compiler mirror not found.

[ https://issues.apache.org/jira/browse/FLINK-3741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258361#comment-15258361 ] ASF GitHub Bot commented on FLINK-3741: --- Github user tillrohrmann commented on the p

[jira] [Commented] (FLINK-3741) Travis Compile Error: MissingRequirementError: object scala.runtime in compiler mirror not found.

[ https://issues.apache.org/jira/browse/FLINK-3741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258362#comment-15258362 ] ASF GitHub Bot commented on FLINK-3741: --- Github user tillrohrmann closed the pull re

[GitHub] flink pull request: [FLINK-3741] [build] Replace maven-scala-plugi...

Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1931#issuecomment-214799876 This PR does not solve the issue FLINK-3741. --- 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] flink pull request: [FLINK-3741] [build] Replace maven-scala-plugi...

Github user tillrohrmann closed the pull request at: https://github.com/apache/flink/pull/1931 --- 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 i

[GitHub] flink pull request: [FLINK-2220] Join on Pojo without hashCode() s...

GitHub user gallenvara opened a pull request: https://github.com/apache/flink/pull/1940 [FLINK-2220] Join on Pojo without hashCode() silently fails Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration.

[jira] [Commented] (FLINK-2220) Join on Pojo without hashCode() silently fails

[ https://issues.apache.org/jira/browse/FLINK-2220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258358#comment-15258358 ] ASF GitHub Bot commented on FLINK-2220: --- GitHub user gallenvara opened a pull reques

[jira] [Created] (FLINK-3823) Kafka08ITCase.testOffsetInZookeeper failed on Travis

Till Rohrmann created FLINK-3823: Summary: Kafka08ITCase.testOffsetInZookeeper failed on Travis Key: FLINK-3823 URL: https://issues.apache.org/jira/browse/FLINK-3823 Project: Flink Issue Type

[GitHub] flink pull request:

Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/commit/1ccc798914a2bd94157f2a86f7961bc1cc5de490#commitcomment-17257298 Yes, will add it right away. --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-3199) KafkaITCase.testOneToOneSources

[ https://issues.apache.org/jira/browse/FLINK-3199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258317#comment-15258317 ] Till Rohrmann commented on FLINK-3199: -- Found another instance: https://s3.amazonaws

[GitHub] flink pull request:

Github user uce commented on the pull request: https://github.com/apache/flink/commit/1ccc798914a2bd94157f2a86f7961bc1cc5de490#commitcomment-17256873 Can we add this to release-1.0 as well? --- If your project is set up for it, you can reply to this email and have your reply appear o

[jira] [Commented] (FLINK-3741) Travis Compile Error: MissingRequirementError: object scala.runtime in compiler mirror not found.

[ https://issues.apache.org/jira/browse/FLINK-3741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258316#comment-15258316 ] ASF GitHub Bot commented on FLINK-3741: --- Github user tillrohrmann commented on the p

[GitHub] flink pull request: [FLINK-3741] [build] Replace maven-scala-plugi...

Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1931#issuecomment-214790629 The initial problem still persists :-( Still, I would like to merge this PR to update the `scala-maven-plugin` using in Flink-ML. --- If your project is

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258282#comment-15258282 ] ASF GitHub Bot commented on FLINK-2828: --- Github user vasia commented on the pull req

[jira] [Commented] (FLINK-3771) Methods for translating Graphs

[ https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258288#comment-15258288 ] ASF GitHub Bot commented on FLINK-3771: --- Github user greghogan commented on the pull

[GitHub] flink pull request: [FLINK-3771] [gelly] Methods for translating G...

Github user greghogan commented on the pull request: https://github.com/apache/flink/pull/1900#issuecomment-214782976 Hi @vasia, Comparing the APIs, `Translate` processes at the level of label or value whereas `mapVertices/Edges` process vertices and edges. What are use cases for

[GitHub] flink pull request: [FLINK-2828] [tableAPI] Add TableSource interf...

Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1939#issuecomment-214782320 Thanks @fhueske, PR looks good :) Maybe we can refactor the source RelNode to avoid much code duplication. And do you think we need a test for `CsvTableSource`? --- I

[GitHub] flink pull request: [FLINK-2828] [tableAPI] Add TableSource interf...

Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1939#discussion_r61103432 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/datastream/StreamTableSourceScan.scala --- @@ -0,0 +1,126 @@ +/*

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258271#comment-15258271 ] ASF GitHub Bot commented on FLINK-2828: --- Github user vasia commented on a diff in th

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258270#comment-15258270 ] ASF GitHub Bot commented on FLINK-2828: --- Github user vasia commented on a diff in th

[GitHub] flink pull request: [FLINK-2828] [tableAPI] Add TableSource interf...

Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1939#discussion_r61106195 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/table/test/TableSourceITCase.scala --- @@ -0,0 +1,123 @@ +/* + * Licens

[GitHub] flink pull request: [FLINK-2828] [tableAPI] Add TableSource interf...

Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1939#discussion_r61106226 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/table/test/TableSourceITCase.scala --- @@ -0,0 +1,123 @@ +/* + * Licens

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258266#comment-15258266 ] ASF GitHub Bot commented on FLINK-2828: --- Github user vasia commented on a diff in th

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258264#comment-15258264 ] ASF GitHub Bot commented on FLINK-2828: --- Github user vasia commented on a diff in th

[GitHub] flink pull request: [FLINK-2828] [tableAPI] Add TableSource interf...

Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1939#discussion_r61105889 --- Diff: flink-libraries/flink-table/src/test/java/org/apache/flink/api/java/table/test/TableSourceITCase.java --- @@ -0,0 +1,120 @@ +/* + * Licensed

[GitHub] flink pull request: [FLINK-2828] [tableAPI] Add TableSource interf...

Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1939#discussion_r61105940 --- Diff: flink-libraries/flink-table/src/test/java/org/apache/flink/api/java/table/test/TableSourceITCase.java --- @@ -0,0 +1,120 @@ +/* + * Licensed

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258258#comment-15258258 ] ASF GitHub Bot commented on FLINK-2828: --- Github user vasia commented on a diff in th

[GitHub] flink pull request: [FLINK-2828] [tableAPI] Add TableSource interf...

Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1939#discussion_r61105638 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/schema/TableSourceTable.scala --- @@ -0,0 +1,32 @@ +/* + * License

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258231#comment-15258231 ] ASF GitHub Bot commented on FLINK-2828: --- Github user vasia commented on a diff in th

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258247#comment-15258247 ] ASF GitHub Bot commented on FLINK-2828: --- Github user vasia commented on a diff in th

[GitHub] flink pull request: [FLINK-2828] [tableAPI] Add TableSource interf...

Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1939#discussion_r61104611 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/BatchTableSourceScanRule.scala --- @@ -0,0 +1,71 @@ +/*

[jira] [Resolved] (FLINK-3804) Update YARN documentation

[ https://issues.apache.org/jira/browse/FLINK-3804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3804. --- Resolution: Fixed Assignee: Robert Metzger Fix Version/s: 1.1.0 Resolved in ht

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258219#comment-15258219 ] ASF GitHub Bot commented on FLINK-2828: --- Github user vasia commented on a diff in th

[GitHub] flink pull request: [FLINK-2828] [tableAPI] Add TableSource interf...

Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1939#discussion_r61101726 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/BatchTableSourceScan.scala --- @@ -0,0 +1,139 @@ +/*

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258199#comment-15258199 ] ASF GitHub Bot commented on FLINK-2828: --- Github user vasia commented on a diff in th

[GitHub] flink pull request: [FLINK-2828] [tableAPI] Add TableSource interf...

Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1939#discussion_r61098440 --- Diff: docs/apis/batch/libs/table.md --- @@ -67,6 +67,165 @@ The central concept of the Table API is a `Table` which represents a table with The f

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258192#comment-15258192 ] ASF GitHub Bot commented on FLINK-2828: --- Github user vasia commented on a diff in th

[GitHub] flink pull request: [FLINK-2828] [tableAPI] Add TableSource interf...

Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1939#discussion_r61098044 --- Diff: docs/apis/batch/libs/table.md --- @@ -67,6 +67,165 @@ The central concept of the Table API is a `Table` which represents a table with The f

[GitHub] flink pull request:

Github user aljoscha commented on the pull request: https://github.com/apache/flink/commit/879bb1bb029ed37e33adc7a655328940135cfcb3#commitcomment-17254978 Could do, but it does not really impact performance very much. --- If your project is set up for it, you can reply to this email

[jira] [Commented] (FLINK-3086) ExpressionParser does not support concatenation of suffix operations

[ https://issues.apache.org/jira/browse/FLINK-3086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258160#comment-15258160 ] ASF GitHub Bot commented on FLINK-3086: --- Github user vasia commented on the pull req

[GitHub] flink pull request: [FLINK-3086] [table] ExpressionParser does not...

Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1912#issuecomment-214762168 I'm not very familiar with the `ExpressionParser`, but I don't see anything suspicious :) --- If your project is set up for it, you can reply to this email and have your

[GitHub] flink pull request:

Github user uce commented on the pull request: https://github.com/apache/flink/commit/879bb1bb029ed37e33adc7a655328940135cfcb3#commitcomment-17254739 Should we add this to `release-1.0` as well? --- If your project is set up for it, you can reply to this email and have your reply app

[jira] [Commented] (FLINK-3777) Add open and close methods to manage IF lifecycle

[ https://issues.apache.org/jira/browse/FLINK-3777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258127#comment-15258127 ] ASF GitHub Bot commented on FLINK-3777: --- Github user asfgit closed the pull request

[jira] [Closed] (FLINK-3777) Add open and close methods to manage IF lifecycle

[ https://issues.apache.org/jira/browse/FLINK-3777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-3777. --- Resolution: Fixed Implemented in ac2137cfa5e63bd4f53a4b7669dc591ab210093f > Add open and clos

[GitHub] flink pull request: [FLINK-3777] Managed closeInputFormat()

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1903 --- 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

[jira] [Commented] (FLINK-3618) Rename abstract UDF classes in Scatter-Gather implementation

[ https://issues.apache.org/jira/browse/FLINK-3618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258097#comment-15258097 ] Vasia Kalavri commented on FLINK-3618: -- I agree. The sooner we make this change the b

  1   2   3   >