[jira] [Commented] (FLINK-6259) Fix a small spelling error

[ https://issues.apache.org/jira/browse/FLINK-6259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15954425#comment-15954425 ] ASF GitHub Bot commented on FLINK-6259: --- GitHub user sunjincheng121 opened a pull request:

[GitHub] flink pull request #3667: Fix a small spelling error har-with-dependencies -...

GitHub user sunjincheng121 opened a pull request: https://github.com/apache/flink/pull/3667 Fix a small spelling error har-with-dependencies -> jar-with-dependen… …cies Thanks for contributing to Apache Flink. Before you open your pull request, please take the

[jira] [Updated] (FLINK-6259) Fix a small spelling error

[ https://issues.apache.org/jira/browse/FLINK-6259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6259: --- Description: flink-gelly-scala/pom.xml {{har-with-dependencies}} -> {{jar-with-dependencies}} (was:

[jira] [Created] (FLINK-6259) Fix a small spelling error

sunjincheng created FLINK-6259: -- Summary: Fix a small spelling error Key: FLINK-6259 URL: https://issues.apache.org/jira/browse/FLINK-6259 Project: Flink Issue Type: Bug Components:

[jira] [Commented] (FLINK-6247) Build a jar-with-dependencies for flink-table and put it into ./opt

[ https://issues.apache.org/jira/browse/FLINK-6247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15954418#comment-15954418 ] ASF GitHub Bot commented on FLINK-6247: --- GitHub user sunjincheng121 opened a pull request:

[GitHub] flink pull request #3666: [FLINK-6247][table] Build a jar-with-dependencies ...

GitHub user sunjincheng121 opened a pull request: https://github.com/apache/flink/pull/3666 [FLINK-6247][table] Build a jar-with-dependencies for flink-table and… … put it into ./opt Thanks for contributing to Apache Flink. Before you open your pull request, please

[GitHub] flink issue #3661: [FLINK-4953] Allow access to "time" in ProcessWindowFunct...

Github user manuzhang commented on the issue: https://github.com/apache/flink/pull/3661 Okay. Shall we open a JIRA to deprecate `WindowOperatorTest` ? I found a minor bug in `WindowOperatorTest#Tuple3ResultSortComparator` (same as `WindowOperatorMigrationTest`), do we want to fix it

[jira] [Commented] (FLINK-4953) Allow access to "time" in ProcessWindowFunction.Context

[ https://issues.apache.org/jira/browse/FLINK-4953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15954344#comment-15954344 ] ASF GitHub Bot commented on FLINK-4953: --- Github user manuzhang commented on the issue:

[jira] [Commented] (FLINK-5991) Expose Broadcast Operator State through public APIs

[ https://issues.apache.org/jira/browse/FLINK-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15954326#comment-15954326 ] ASF GitHub Bot commented on FLINK-5991: --- Github user tzulitai commented on a diff in the pull

[GitHub] flink pull request #3508: [FLINK-5991] [state-backend, streaming] Expose Bro...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3508#discussion_r109547924 --- Diff: docs/dev/stream/state.md --- @@ -233,45 +229,44 @@ val counts: DataStream[(String, Int)] = stream ## Using Managed Operator State

[GitHub] flink issue #3508: [FLINK-5991] [state-backend, streaming] Expose Broadcast ...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3508 Updated managed operator state docs. @aljoscha @StefanRRichter could you have a final look at it? If there's no other problems I'll proceed to merge this. Thanks :) --- If your project is set

[jira] [Commented] (FLINK-5991) Expose Broadcast Operator State through public APIs

[ https://issues.apache.org/jira/browse/FLINK-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15954323#comment-15954323 ] ASF GitHub Bot commented on FLINK-5991: --- Github user tzulitai commented on the issue:

[jira] [Commented] (FLINK-6249) Distinct Aggregates for OVER window

[ https://issues.apache.org/jira/browse/FLINK-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15954190#comment-15954190 ] Fabian Hueske commented on FLINK-6249: -- Hi [~rtudoran], thanks for creating the JIRA. I think the

[jira] [Commented] (FLINK-6011) Support TUMBLE, HOP, SESSION window in streaming SQL

[ https://issues.apache.org/jira/browse/FLINK-6011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15954189#comment-15954189 ] ASF GitHub Bot commented on FLINK-6011: --- GitHub user haohui opened a pull request:

[GitHub] flink pull request #3665: [FLINK-6011] Support TUMBLE, HOP, SESSION window i...

GitHub user haohui opened a pull request: https://github.com/apache/flink/pull/3665 [FLINK-6011] Support TUMBLE, HOP, SESSION window in streaming SQL. This PR adds supports for the `TUMBLE`, `HOP`, and `SESSION` windows in Flink. The work of supporting WindowStart and

[GitHub] flink issue #3508: [FLINK-5991] [state-backend, streaming] Expose Broadcast ...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3508 I've opened a separate JIRA to deprecate `ListCheckpointed`. Lets keep this PR self-contained in just refining the `OperatorStateStore` interface. I think this PR is still lacking an update

[jira] [Commented] (FLINK-5991) Expose Broadcast Operator State through public APIs

[ https://issues.apache.org/jira/browse/FLINK-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15954123#comment-15954123 ] ASF GitHub Bot commented on FLINK-5991: --- Github user tzulitai commented on the issue:

[jira] [Created] (FLINK-6258) Deprecate ListCheckpointed interface for managed operator state

Tzu-Li (Gordon) Tai created FLINK-6258: -- Summary: Deprecate ListCheckpointed interface for managed operator state Key: FLINK-6258 URL: https://issues.apache.org/jira/browse/FLINK-6258 Project:

[jira] [Commented] (FLINK-6209) StreamPlanEnvironment always has a parallelism of 1

[ https://issues.apache.org/jira/browse/FLINK-6209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953916#comment-15953916 ] Aljoscha Krettek commented on FLINK-6209: - [~wheat9] The snipped was removed because it wasn't

[jira] [Commented] (FLINK-6217) ContaineredTaskManagerParameters sets off heap memory size incorrectly

[ https://issues.apache.org/jira/browse/FLINK-6217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953865#comment-15953865 ] ASF GitHub Bot commented on FLINK-6217: --- Github user haohui commented on the issue:

[GitHub] flink issue #3648: [FLINK-6217] ContaineredTaskManagerParameters sets off-he...

Github user haohui commented on the issue: https://github.com/apache/flink/pull/3648 The test failure seems unrelated. Cannot reproduce locally. --- 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

[jira] [Commented] (FLINK-2814) DeltaIteration: DualInputPlanNode cannot be cast to SingleInputPlanNode

[ https://issues.apache.org/jira/browse/FLINK-2814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953831#comment-15953831 ] ASF GitHub Bot commented on FLINK-2814: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #3563: [FLINK-2814] [optimizer] DualInputPlanNode cannot be cast...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3563 I think cherry-picking this into the `release-1.2` branch would be nice --- 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

[jira] [Commented] (FLINK-6243) Continuous Joins: True Sliding Window Joins

[ https://issues.apache.org/jira/browse/FLINK-6243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953798#comment-15953798 ] Elias Levy commented on FLINK-6243: --- Thanks for pointing out FLINK-5725. I did review the documentation

[GitHub] flink pull request #3664: [FLINK-5808] Revert changes

GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/3664 [FLINK-5808] Revert changes You can merge this pull request into a Git repository by running: $ git pull https://github.com/aljoscha/flink revert-5808-release12 Alternatively you can review

[jira] [Commented] (FLINK-5808) Missing verification for setParallelism and setMaxParallelism

[ https://issues.apache.org/jira/browse/FLINK-5808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953775#comment-15953775 ] ASF GitHub Bot commented on FLINK-5808: --- GitHub user aljoscha opened a pull request:

[jira] [Reopened] (FLINK-5808) Missing verification for setParallelism and setMaxParallelism

[ https://issues.apache.org/jira/browse/FLINK-5808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-5808: - Assignee: Aljoscha Krettek Reopening because this is not properly fixed and we

[jira] [Commented] (FLINK-3089) State API Should Support Data Expiration

[ https://issues.apache.org/jira/browse/FLINK-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953761#comment-15953761 ] Elias Levy commented on FLINK-3089: --- Thanks for the clarification. It is curious that the

[jira] [Commented] (FLINK-6124) support max/min aggregations for string type

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

[GitHub] flink pull request #3593: [FLINK-6124] [table] Add min/max string aggregatio...

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

[jira] [Commented] (FLINK-6124) support max/min aggregations for string type

[ https://issues.apache.org/jira/browse/FLINK-6124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953738#comment-15953738 ] Timo Walther commented on FLINK-6124: - Added retraction support in:

[GitHub] flink issue #3593: [FLINK-6124] [table] Add min/max string aggregation with ...

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/3593 Thanks for the hint @shaoxuan-wang. I added the tests and 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

[jira] [Commented] (FLINK-6124) support max/min aggregations for string type

[ https://issues.apache.org/jira/browse/FLINK-6124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953729#comment-15953729 ] ASF GitHub Bot commented on FLINK-6124: --- Github user twalthr commented on the issue:

[jira] [Updated] (FLINK-6257) Post-pass OVER windows

[ https://issues.apache.org/jira/browse/FLINK-6257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-6257: - Issue Type: Sub-task (was: Improvement) Parent: FLINK-4557 > Post-pass OVER windows >

[jira] [Created] (FLINK-6257) Post-pass OVER windows

Fabian Hueske created FLINK-6257: Summary: Post-pass OVER windows Key: FLINK-6257 URL: https://issues.apache.org/jira/browse/FLINK-6257 Project: Flink Issue Type: Improvement

[GitHub] flink pull request #3660: [FLINK-6237] [table] support RAND and RAND_INTEGER...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/3660#discussion_r109453119 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala --- @@ -1106,6 +1106,31 @@ class CodeGenerator(

[jira] [Commented] (FLINK-6237) support RAND and RAND_INTEGER on SQL

[ https://issues.apache.org/jira/browse/FLINK-6237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953697#comment-15953697 ] ASF GitHub Bot commented on FLINK-6237: --- Github user twalthr commented on a diff in the pull

[GitHub] flink pull request #3660: [FLINK-6237] [table] support RAND and RAND_INTEGER...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/3660#discussion_r109453682 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/calls/ScalarOperators.scala --- @@ -911,6 +911,64 @@ object

[jira] [Commented] (FLINK-6237) support RAND and RAND_INTEGER on SQL

[ https://issues.apache.org/jira/browse/FLINK-6237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953695#comment-15953695 ] ASF GitHub Bot commented on FLINK-6237: --- Github user twalthr commented on a diff in the pull

[jira] [Commented] (FLINK-6237) support RAND and RAND_INTEGER on SQL

[ https://issues.apache.org/jira/browse/FLINK-6237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953696#comment-15953696 ] ASF GitHub Bot commented on FLINK-6237: --- Github user twalthr commented on a diff in the pull

[GitHub] flink pull request #3660: [FLINK-6237] [table] support RAND and RAND_INTEGER...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/3660#discussion_r109451391 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/calls/ScalarOperators.scala --- @@ -911,6 +911,64 @@ object

[jira] [Commented] (FLINK-6219) Add a state backend which supports sorting

[ https://issues.apache.org/jira/browse/FLINK-6219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953687#comment-15953687 ] Fabian Hueske commented on FLINK-6219: -- If we add such a {{TimeSortedQueue}}, the user code could

[jira] [Commented] (FLINK-5994) Add Janino to flink-table JAR file

[ https://issues.apache.org/jira/browse/FLINK-5994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953682#comment-15953682 ] Fabian Hueske commented on FLINK-5994: -- I don't think we need to include Janino into the default

[jira] [Commented] (FLINK-6112) Support new numerical functions when calcite release 1.12

[ https://issues.apache.org/jira/browse/FLINK-6112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953678#comment-15953678 ] Timo Walther commented on FLINK-6112: - [~mtunqiue] We bumped up the Calcite version. We can now

[jira] [Commented] (FLINK-5435) Cleanup the rules introduced by FLINK-5144 when calcite releases 1.12

[ https://issues.apache.org/jira/browse/FLINK-5435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953675#comment-15953675 ] Timo Walther commented on FLINK-5435: - [~ykt836] We updated the Calcite version. Would be great if you

[jira] [Commented] (FLINK-5545) Remove FlinkAggregateExpandDistinctAggregatesRule when upgrading to Calcite 1.12

[ https://issues.apache.org/jira/browse/FLINK-5545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953674#comment-15953674 ] Timo Walther commented on FLINK-5545: - [~docete] We updated the Calcite version. Would be great if you

[jira] [Created] (FLINK-6256) Fix documentation of ProcessFunction.

Kostas Kloudas created FLINK-6256: - Summary: Fix documentation of ProcessFunction. Key: FLINK-6256 URL: https://issues.apache.org/jira/browse/FLINK-6256 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-5829) Bump Calcite version to 1.12 once available

[ https://issues.apache.org/jira/browse/FLINK-5829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953667#comment-15953667 ] Timo Walther commented on FLINK-5829: - Fixed in 1.3.0: 05ceec0ace45135bc1cc17934a0b8721f4f85a03 >

[jira] [Assigned] (FLINK-6254) Consolidate late data methods on PatternStream and WindowedStream

[ https://issues.apache.org/jira/browse/FLINK-6254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-6254: - Assignee: Kostas Kloudas > Consolidate late data methods on PatternStream and

[GitHub] flink pull request #3613: [FLINK-5829] Bump Calcite version to 1.12 once ava...

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

[jira] [Commented] (FLINK-5829) Bump Calcite version to 1.12 once available

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

[jira] [Created] (FLINK-6255) Remove PatternStream.getSideOutput()

Aljoscha Krettek created FLINK-6255: --- Summary: Remove PatternStream.getSideOutput() Key: FLINK-6255 URL: https://issues.apache.org/jira/browse/FLINK-6255 Project: Flink Issue Type:

[jira] [Created] (FLINK-6254) Consolidate late data methods on PatternStream and WindowedStream

Aljoscha Krettek created FLINK-6254: --- Summary: Consolidate late data methods on PatternStream and WindowedStream Key: FLINK-6254 URL: https://issues.apache.org/jira/browse/FLINK-6254 Project: Flink

[jira] [Assigned] (FLINK-6215) Make the StatefulSequenceSource scalable.

[ https://issues.apache.org/jira/browse/FLINK-6215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-6215: - Assignee: Kostas Kloudas > Make the StatefulSequenceSource scalable. >

[jira] [Commented] (FLINK-6249) Distinct Aggregates for OVER window

[ https://issues.apache.org/jira/browse/FLINK-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953646#comment-15953646 ] radu commented on FLINK-6249: - [~fhueske] [~shijinkui] [~Yuhong_kyo] [~sunjincheng121] [~twalthr]

[jira] [Created] (FLINK-6253) Distinct rowTime with time range boundaries

radu created FLINK-6253: --- Summary: Distinct rowTime with time range boundaries Key: FLINK-6253 URL: https://issues.apache.org/jira/browse/FLINK-6253 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-6252) Distinct rowTime with Rows boundaries

radu created FLINK-6252: --- Summary: Distinct rowTime with Rows boundaries Key: FLINK-6252 URL: https://issues.apache.org/jira/browse/FLINK-6252 Project: Flink Issue Type: Sub-task Reporter:

[jira] [Commented] (FLINK-3427) Add watermark monitoring to JobManager web frontend

[ https://issues.apache.org/jira/browse/FLINK-3427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953644#comment-15953644 ] Chesnay Schepler commented on FLINK-3427: - [~vpernin] The backpressure monitoring should still be

[jira] [Assigned] (FLINK-6251) Distinct procTime with time range boundaries

[ https://issues.apache.org/jira/browse/FLINK-6251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu reassigned FLINK-6251: --- Assignee: radu > Distinct procTime with time range boundaries >

[jira] [Created] (FLINK-6251) Distinct procTime with time range boundaries

radu created FLINK-6251: --- Summary: Distinct procTime with time range boundaries Key: FLINK-6251 URL: https://issues.apache.org/jira/browse/FLINK-6251 Project: Flink Issue Type: Sub-task

[jira] [Assigned] (FLINK-6250) Distinct procTime with Rows boundaries

[ https://issues.apache.org/jira/browse/FLINK-6250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu reassigned FLINK-6250: --- Assignee: Stefano Bortoli Description: Support proctime with rows boundaries Q1.1. `SELECT SUM(

[jira] [Closed] (FLINK-3031) Consistent Shutdown of Streaming Jobs

[ https://issues.apache.org/jira/browse/FLINK-3031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-3031. -- Resolution: Invalid Yes > Consistent Shutdown of Streaming Jobs >

[jira] [Created] (FLINK-6250) Distinct procTime with Rows boundaries

radu created FLINK-6250: --- Summary: Distinct procTime with Rows boundaries Key: FLINK-6250 URL: https://issues.apache.org/jira/browse/FLINK-6250 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-6249) Distinct Aggregates for OVER window

[ https://issues.apache.org/jira/browse/FLINK-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6249: Description: Time target: ProcTime/EventTime SQL targeted query examples: Q1.

[jira] [Commented] (FLINK-5829) Bump Calcite version to 1.12 once available

[ https://issues.apache.org/jira/browse/FLINK-5829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953634#comment-15953634 ] ASF GitHub Bot commented on FLINK-5829: --- Github user twalthr commented on the issue:

[GitHub] flink issue #3613: [FLINK-5829] Bump Calcite version to 1.12 once available.

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/3613 Thanks @haohui. I 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

[jira] [Commented] (FLINK-6244) Emit timeouted Patterns as Side Output

[ https://issues.apache.org/jira/browse/FLINK-6244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953621#comment-15953621 ] Dawid Wysakowicz commented on FLINK-6244: - I think it is a good way to proceed. Another way I was

[jira] [Commented] (FLINK-3427) Add watermark monitoring to JobManager web frontend

[ https://issues.apache.org/jira/browse/FLINK-3427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953612#comment-15953612 ] Vladislav Pernin commented on FLINK-3427: - What is the official way of monitoring backpressure ?

[jira] [Created] (FLINK-6249) Distinct Aggregates for OVER window

radu created FLINK-6249: --- Summary: Distinct Aggregates for OVER window Key: FLINK-6249 URL: https://issues.apache.org/jira/browse/FLINK-6249 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-6248) Make the optional() available to all offered patterns.

Kostas Kloudas created FLINK-6248: - Summary: Make the optional() available to all offered patterns. Key: FLINK-6248 URL: https://issues.apache.org/jira/browse/FLINK-6248 Project: Flink Issue

[jira] [Commented] (FLINK-5994) Add Janino to flink-table JAR file

[ https://issues.apache.org/jira/browse/FLINK-5994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953588#comment-15953588 ] ASF GitHub Bot commented on FLINK-5994: --- Github user fhueske commented on the issue:

[jira] [Commented] (FLINK-6244) Emit timeouted Patterns as Side Output

[ https://issues.apache.org/jira/browse/FLINK-6244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953590#comment-15953590 ] Kostas Kloudas commented on FLINK-6244: --- The only problem I can find, and we have to think of how to

[GitHub] flink issue #3656: [FLINK-5994][table] Add Janino to flink-dist JAR file

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3656 Here's the JIRA for this PR: https://issues.apache.org/jira/browse/FLINK-6247 --- 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

[jira] [Created] (FLINK-6247) Build a jar-with-dependencies for flink-table and put it into ./opt

Fabian Hueske created FLINK-6247: Summary: Build a jar-with-dependencies for flink-table and put it into ./opt Key: FLINK-6247 URL: https://issues.apache.org/jira/browse/FLINK-6247 Project: Flink

[jira] [Updated] (FLINK-6209) StreamPlanEnvironment always has a parallelism of 1

[ https://issues.apache.org/jira/browse/FLINK-6209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6209: Affects Version/s: 1.2.1 > StreamPlanEnvironment always has a parallelism of 1 >

[jira] [Updated] (FLINK-6244) Emit timeouted Patterns as Side Output

[ https://issues.apache.org/jira/browse/FLINK-6244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-6244: -- Fix Version/s: 1.3.0 > Emit timeouted Patterns as Side Output >

[jira] [Updated] (FLINK-6244) Emit timeouted Patterns as Side Output

[ https://issues.apache.org/jira/browse/FLINK-6244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-6244: -- Affects Version/s: 1.3.0 > Emit timeouted Patterns as Side Output >

[jira] [Commented] (FLINK-5994) Add Janino to flink-table JAR file

[ https://issues.apache.org/jira/browse/FLINK-5994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953578#comment-15953578 ] ASF GitHub Bot commented on FLINK-5994: --- Github user fhueske commented on the issue:

[GitHub] flink issue #3656: [FLINK-5994][table] Add Janino to flink-dist JAR file

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3656 I will create another JIRA for this issue and assign it to you. --- 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

[jira] [Commented] (FLINK-5994) Add Janino to flink-table JAR file

[ https://issues.apache.org/jira/browse/FLINK-5994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953574#comment-15953574 ] ASF GitHub Bot commented on FLINK-5994: --- Github user fhueske commented on the issue:

[GitHub] flink issue #3656: [FLINK-5994][table] Add Janino to flink-dist JAR file

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3656 The jar-with-dependencies should include Janino. This jar needs to include everything that is required to run flink-table, but nothing that is already included in flink-dist.jar. If I

[jira] [Commented] (FLINK-3871) Add Kafka TableSource with Avro serialization

[ https://issues.apache.org/jira/browse/FLINK-3871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953573#comment-15953573 ] ASF GitHub Bot commented on FLINK-3871: --- GitHub user twalthr opened a pull request:

[GitHub] flink pull request #3663: [FLINK-3871] [table] Add Kafka TableSource with Av...

GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/3663 [FLINK-3871] [table] Add Kafka TableSource with Avro serialization This PR adds KafkaAvroTableSource. It serializes/deserializes (nested) Avro records to (nested) Flink rows. Avro Utf8 strings are

[jira] [Commented] (FLINK-6246) Fix generic type of OutputTag in operator Output

[ https://issues.apache.org/jira/browse/FLINK-6246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953559#comment-15953559 ] ASF GitHub Bot commented on FLINK-6246: --- Github user dawidwys commented on a diff in the pull

[jira] [Commented] (FLINK-6246) Fix generic type of OutputTag in operator Output

[ https://issues.apache.org/jira/browse/FLINK-6246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953560#comment-15953560 ] ASF GitHub Bot commented on FLINK-6246: --- Github user dawidwys commented on a diff in the pull

[jira] [Commented] (FLINK-6246) Fix generic type of OutputTag in operator Output

[ https://issues.apache.org/jira/browse/FLINK-6246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953558#comment-15953558 ] ASF GitHub Bot commented on FLINK-6246: --- Github user dawidwys commented on a diff in the pull

[GitHub] flink pull request #3662: [FLINK-6246] Fix generic type of OutputTag in oper...

Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/3662#discussion_r109428703 --- Diff: flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/iteration/IterateExample.java --- @@ -107,7 +107,8 @@

[GitHub] flink pull request #3662: [FLINK-6246] Fix generic type of OutputTag in oper...

Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/3662#discussion_r109428555 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java --- @@ -619,20 +619,20 @@ public void

[GitHub] flink pull request #3662: [FLINK-6246] Fix generic type of OutputTag in oper...

Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/3662#discussion_r109428611 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java --- @@ -619,20 +619,20 @@ public void

[jira] [Commented] (FLINK-6246) Fix generic type of OutputTag in operator Output

[ https://issues.apache.org/jira/browse/FLINK-6246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953547#comment-15953547 ] ASF GitHub Bot commented on FLINK-6246: --- GitHub user aljoscha opened a pull request:

[GitHub] flink pull request #3662: [FLINK-6246] Fix generic type of OutputTag in oper...

GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/3662 [FLINK-6246] Fix generic type of OutputTag in operator Output R: @dawidwys You can merge this pull request into a Git repository by running: $ git pull https://github.com/aljoscha/flink

[jira] [Commented] (FLINK-5994) Add Janino to flink-table JAR file

[ https://issues.apache.org/jira/browse/FLINK-5994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953543#comment-15953543 ] ASF GitHub Bot commented on FLINK-5994: --- Github user sunjincheng121 commented on the issue:

[GitHub] flink issue #3656: [FLINK-5994][table] Add Janino to flink-dist JAR file

Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/3656 Hi @fhueske In the ML: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-1-2-Proper-Packaging-of-flink-table-with-SBT-td12096.html user want

[jira] [Created] (FLINK-6246) Fix generic type of OutputTag in operator Output

Aljoscha Krettek created FLINK-6246: --- Summary: Fix generic type of OutputTag in operator Output Key: FLINK-6246 URL: https://issues.apache.org/jira/browse/FLINK-6246 Project: Flink Issue

[jira] [Commented] (FLINK-6237) support RAND and RAND_INTEGER on SQL

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

[jira] [Commented] (FLINK-6237) support RAND and RAND_INTEGER on SQL

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

[jira] [Commented] (FLINK-6237) support RAND and RAND_INTEGER on SQL

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

[jira] [Commented] (FLINK-6237) support RAND and RAND_INTEGER on SQL

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

[jira] [Commented] (FLINK-6237) support RAND and RAND_INTEGER on SQL

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

[GitHub] flink pull request #3660: [FLINK-6237] [table] support RAND and RAND_INTEGER...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3660#discussion_r109424063 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/calls/ScalarOperators.scala --- @@ -911,6 +911,64 @@ object

  1   2   3   >