[jira] [Created] (FLINK-5440) Misleading error message when migrating and scaling down from savepoint

Ufuk Celebi created FLINK-5440: -- Summary: Misleading error message when migrating and scaling down from savepoint Key: FLINK-5440 URL: https://issues.apache.org/jira/browse/FLINK-5440 Project: Flink

[jira] [Created] (FLINK-5441) Directly allow SQL queries on a Table

Timo Walther created FLINK-5441: --- Summary: Directly allow SQL queries on a Table Key: FLINK-5441 URL: https://issues.apache.org/jira/browse/FLINK-5441 Project: Flink Issue Type: New Feature

[GitHub] flink issue #3040: [FLINK-3850] Add forward field annotations to DataSet

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/3040 I will also take a look at it soon. Unfortunetly, the build failed. Could you have a look at it? I also recommend to change the `TableProgramsTestBase` from `TestExecutionMode.COLLECTION` to

[jira] [Commented] (FLINK-3850) Add forward field annotations to DataSet operators generated by the Table API

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

[GitHub] flink pull request #3062: [FLINK-5144] Fix error while applying rule Aggrega...

Github user KurtYoung commented on a diff in the pull request: https://github.com/apache/flink/pull/3062#discussion_r95373645 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/batch/sql/CorrelateITCase.scala --- @@ -0,0 +1,68 @@ +/* + *

[jira] [Commented] (FLINK-5144) Error while applying rule AggregateJoinTransposeRule

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

[jira] [Commented] (FLINK-5144) Error while applying rule AggregateJoinTransposeRule

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

[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15815229#comment-15815229 ] Timo Walther commented on FLINK-4604: - Any news on this [~anmu]? You could solve this issue

[GitHub] flink pull request #3086: Improve docker setup

Github user kaelumania commented on a diff in the pull request: https://github.com/apache/flink/pull/3086#discussion_r95384257 --- Diff: flink-contrib/docker-flink/Dockerfile --- @@ -22,9 +22,9 @@ FROM java:8-jre-alpine RUN apk add --no-cache bash snappy # Configure

[GitHub] flink pull request #3000: [FLINK-4861] [build] Package optional project arti...

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

[GitHub] flink issue #3086: Improve docker setup

Github user kaelumania commented on the issue: https://github.com/apache/flink/pull/3086 I am not sure, why the build fails as I am not deeply familiar with the Java/Scala world. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

[jira] [Created] (FLINK-5436) UDF state without CheckpointedRestoring can result in restarting loop

Ufuk Celebi created FLINK-5436: -- Summary: UDF state without CheckpointedRestoring can result in restarting loop Key: FLINK-5436 URL: https://issues.apache.org/jira/browse/FLINK-5436 Project: Flink

[jira] [Commented] (FLINK-5407) Savepoint for iterative Task fails.

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

[jira] [Commented] (FLINK-5407) Savepoint for iterative Task fails.

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

[jira] [Commented] (FLINK-4917) Deprecate "CheckpointedAsynchronously" interface

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

[GitHub] flink issue #3086: Improve docker setup

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3086 For creating tickets, it's actually a requirement from Apache Legal as PR comments are then automatically added to the associated Jira which documents the contribution of the code to the project.

[GitHub] flink pull request #3086: Improve docker setup

Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/3086#discussion_r95401803 --- Diff: flink-contrib/docker-flink/Dockerfile --- @@ -22,9 +22,9 @@ FROM java:8-jre-alpine RUN apk add --no-cache bash snappy # Configure

[jira] [Resolved] (FLINK-4673) TypeInfoFactory for Either type

[ https://issues.apache.org/jira/browse/FLINK-4673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-4673. - Resolution: Fixed Fix Version/s: 1.3.0 Fixed in 1.3.0:

[jira] [Commented] (FLINK-4673) TypeInfoFactory for Either type

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

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

Kurt Young created FLINK-5435: - Summary: Cleanup the rules introduced by FLINK-5144 when calcite releases 1.12 Key: FLINK-5435 URL: https://issues.apache.org/jira/browse/FLINK-5435 Project: Flink

[jira] [Commented] (FLINK-5394) the estimateRowCount method of DataSetCalc didn't work

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

[GitHub] flink pull request #3058: [FLINK-5394] [Table API & SQL]the estimateRowCount...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3058#discussion_r95372931 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetSort.scala --- @@ -71,6 +72,21 @@ class DataSetSort(

[jira] [Commented] (FLINK-5358) Support RowTypeInfo extraction in TypeExtractor by Row instance

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

[GitHub] flink issue #3027: [FLINK-5358] add RowTypeInfo exctraction in TypeExtractor

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/3027 +1 to merge --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if

[jira] [Commented] (FLINK-5358) Support RowTypeInfo extraction in TypeExtractor by Row instance

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

[GitHub] flink pull request #3086: Improve docker setup

Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/3086#discussion_r95381935 --- Diff: flink-contrib/docker-flink/Dockerfile --- @@ -22,9 +22,9 @@ FROM java:8-jre-alpine RUN apk add --no-cache bash snappy # Configure

[GitHub] flink pull request #3086: Improve docker setup

Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/3086#discussion_r95382374 --- Diff: flink-contrib/docker-flink/docker-entrypoint.sh --- @@ -36,9 +39,9 @@ elif [ "$1" == "taskmanager" ]; then echo "Starting Task Manager"

[jira] [Created] (FLINK-5438) Typo in JobGraph generator Exception

Ufuk Celebi created FLINK-5438: -- Summary: Typo in JobGraph generator Exception Key: FLINK-5438 URL: https://issues.apache.org/jira/browse/FLINK-5438 Project: Flink Issue Type: Improvement

[GitHub] flink pull request #3086: Improve docker setup

Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/3086#discussion_r95410892 --- Diff: flink-contrib/docker-flink/Dockerfile --- @@ -22,9 +22,9 @@ FROM java:8-jre-alpine RUN apk add --no-cache bash snappy # Configure Flink

[GitHub] flink pull request #3086: Improve docker setup

Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/3086#discussion_r95411497 --- Diff: flink-contrib/docker-flink/docker-entrypoint.sh --- @@ -36,9 +39,9 @@ elif [ "$1" == "taskmanager" ]; then echo "Starting Task Manager"

[GitHub] flink pull request #3086: Improve docker setup

Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/3086#discussion_r95411011 --- Diff: flink-contrib/docker-flink/docker-entrypoint.sh --- @@ -28,6 +28,9 @@ if [ "$1" == "jobmanager" ]; then echo "config file: " && grep

[GitHub] flink pull request #3075: [FLINK-5296] Expose the old AlignedWindowOperators...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/3075#discussion_r95411773 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/SlidingAlignedProcessingTimeWindows.java --- @@ -0,0 +1,61

[GitHub] flink pull request #3075: [FLINK-5296] Expose the old AlignedWindowOperators...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/3075#discussion_r95411689 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java --- @@ -977,6 +1012,79 @@ private

[jira] [Commented] (FLINK-5296) Expose the old AlignedWindowOperators to the user through explicit commands.

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

[jira] [Commented] (FLINK-5296) Expose the old AlignedWindowOperators to the user through explicit commands.

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

[jira] [Commented] (FLINK-5296) Expose the old AlignedWindowOperators to the user through explicit commands.

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

[GitHub] flink pull request #3075: [FLINK-5296] Expose the old AlignedWindowOperators...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/3075#discussion_r95412067 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/TumblingAlignedProcessingTimeWindows.java --- @@ -0,0 +1,53

[GitHub] flink pull request #3075: [FLINK-5296] Expose the old AlignedWindowOperators...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/3075#discussion_r95411761 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/SlidingAlignedProcessingTimeWindows.java --- @@ -0,0 +1,61

[GitHub] flink pull request #3075: [FLINK-5296] Expose the old AlignedWindowOperators...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/3075#discussion_r95411735 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/BaseAlignedWindowAssigner.java --- @@ -0,0 +1,71 @@ +/*

[jira] [Commented] (FLINK-5296) Expose the old AlignedWindowOperators to the user through explicit commands.

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

[GitHub] flink pull request #3075: [FLINK-5296] Expose the old AlignedWindowOperators...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/3075#discussion_r95412039 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/SlidingAlignedProcessingTimeWindows.java --- @@ -0,0 +1,61

[GitHub] flink issue #3075: [FLINK-5296] Expose the old AlignedWindowOperators throug...

Github user kl0u commented on the issue: https://github.com/apache/flink/pull/3075 @aljoscha Thanks for the review! I will integrate the comments and ping 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

[jira] [Commented] (FLINK-5296) Expose the old AlignedWindowOperators to the user through explicit commands.

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

[jira] [Commented] (FLINK-1737) Add statistical whitening transformation to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15816172#comment-15816172 ] Pattarawat Chormai commented on FLINK-1737: --- [~till.rohrmann] should we close this issue? > Add

[GitHub] flink issue #3030: Updated version of #3014

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3030 Has been merged, closing the pull request... --- 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

[jira] [Updated] (FLINK-5280) Refactor TableSource

[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5280: - Summary: Refactor TableSource (was: Extend TableSource to support nested data) > Refactor

[jira] [Closed] (FLINK-5358) Support RowTypeInfo extraction in TypeExtractor by Row instance

[ https://issues.apache.org/jira/browse/FLINK-5358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-5358. Resolution: Fixed Fix Version/s: 1.3.0 Implemented for 1.3 with

[jira] [Commented] (FLINK-4499) Introduce findbugs maven plugin

[ https://issues.apache.org/jira/browse/FLINK-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15816125#comment-15816125 ] Ted Yu commented on FLINK-4499: --- This should be assigned to [~smarthi], right ? > Introduce findbugs maven

[jira] [Commented] (FLINK-3903) Homebrew Installation

[ https://issues.apache.org/jira/browse/FLINK-3903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15816161#comment-15816161 ] Pattarawat Chormai commented on FLINK-3903: --- [~uce] are you still working on the issue? >

[jira] [Commented] (FLINK-5358) Support RowTypeInfo extraction in TypeExtractor by Row instance

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

[jira] [Commented] (FLINK-5280) Extend TableSource to support nested data

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

[GitHub] flink pull request #3030: Updated version of #3014

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

[jira] [Closed] (FLINK-5280) Refactor TableSource

[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-5280. Resolution: Fixed Fix Version/s: 1.3.0 1.2.0 Fixed for 1.2 with

[GitHub] flink pull request #3027: [FLINK-5358] add RowTypeInfo exctraction in TypeEx...

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

[GitHub] flink pull request #3039: [FLINK-5280] Update TableSource to support nested ...

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

[GitHub] flink issue #2075: [FLINK-3867] Provide Vagrant/Ansible based VMs to easily ...

Github user kempa-liehr commented on the issue: https://github.com/apache/flink/pull/2075 I just separated the Flink-VM into a separate repository [https://github.com/kempa-liehr/DSVMs], such t you can close this pull request. However, could you arrange to link

[jira] [Commented] (FLINK-3867) Provide virtualized Flink architecture for testing purposes

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

[GitHub] flink pull request #3090: [FLINK-5432] fix nested files enumeration in Conti...

GitHub user ymarzougui opened a pull request: https://github.com/apache/flink/pull/3090 [FLINK-5432] fix nested files enumeration in ContinuousFileMonitoringFunction This PR fixes reading nested files when the InputFormat has NestedFileEnumeration set to true. Nested files were

[jira] [Commented] (FLINK-5432) ContinuousFileMonitoringFunction is not monitoring nested files

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

[jira] [Commented] (FLINK-4988) Elasticsearch 5.x support

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

[GitHub] flink pull request #2767: [FLINK-4988] Elasticsearch 5.x support

Github user mikedias commented on a diff in the pull request: https://github.com/apache/flink/pull/2767#discussion_r95480042 --- Diff: flink-connectors/flink-connector-elasticsearch5/src/main/java/org/apache/flink/streaming/connectors/elasticsearch5/ElasticsearchSink.java --- @@

[jira] [Closed] (FLINK-3867) Provide virtualized Flink architecture for testing purposes

[ https://issues.apache.org/jira/browse/FLINK-3867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andreas Kempa-Liehr closed FLINK-3867. -- Resolution: Fixed Flink VM has been separated into a new repository

[jira] [Updated] (FLINK-5320) Fix result TypeInformation in WindowedStream.fold(ACC, FoldFunction, WindowFunction)

[ https://issues.apache.org/jira/browse/FLINK-5320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yassine Marzougui updated FLINK-5320: - Fix Version/s: 1.2.0 > Fix result TypeInformation in WindowedStream.fold(ACC,

[jira] [Updated] (FLINK-5432) ContinuousFileMonitoringFunction is not monitoring nested files

[ https://issues.apache.org/jira/browse/FLINK-5432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yassine Marzougui updated FLINK-5432: - Fix Version/s: 1.3.0 1.2.0 > ContinuousFileMonitoringFunction is not

[jira] [Commented] (FLINK-4917) Deprecate "CheckpointedAsynchronously" interface

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

[GitHub] flink issue #3087: [FLINK-4917] Deprecate "CheckpointedAsynchronously" inter...

Github user mtunique commented on the issue: https://github.com/apache/flink/pull/3087 I am sorry about it. --- 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

[jira] [Commented] (FLINK-4692) Add tumbling group-windows for batch tables

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

[GitHub] flink issue #2938: [FLINK-4692] [tableApi] Add tumbling group-windows for ba...

Github user wuchong commented on the issue: https://github.com/apache/flink/pull/2938 Thanks @twalthr for your hint. It is a bug in my `DataSetTumbleTimeWindowAggReduceCombineFunction#combine(...)` method, that the rowtime attribute is dropped when combining. The collection

[jira] [Commented] (FLINK-5431) time format for akka status

[ https://issues.apache.org/jira/browse/FLINK-5431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15817437#comment-15817437 ] Alexey Diomin commented on FLINK-5431: -- comment Till Rohrmann --- I agree with your proposal to use

[jira] [Commented] (FLINK-5386) Refactoring Window Clause

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

[GitHub] flink pull request #3046: [FLINK-5386][Table API & SQL] refactoring Window C...

Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/3046#discussion_r95315326 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/windows.scala --- @@ -150,7 +147,7 @@ class TumblingWindow(size:

[jira] [Commented] (FLINK-4396) GraphiteReporter class not found at startup of jobmanager

[ https://issues.apache.org/jira/browse/FLINK-4396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15816509#comment-15816509 ] Steven Ruppert commented on FLINK-4396: --- I just ran into this today. Reading:

[GitHub] flink issue #3086: Improve docker setup

Github user kaelumania commented on the issue: https://github.com/apache/flink/pull/3086 @mxn One drawback using `ENV` might be with docker-compose, see https://docs.docker.com/compose/compose-file/#/args which states > You can omit the value when specifying a build argument,

[GitHub] flink issue #3089: remove duplicated tests

Github user xhumanoid commented on the issue: https://github.com/apache/flink/pull/3089 @aljoscha @rmetzger --- 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

[jira] [Commented] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

[ https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15817549#comment-15817549 ] Anton Mushin commented on FLINK-5256: - Thanks for your comment! I update my [test

[GitHub] flink pull request #2545: [FLINK-4673] [core] TypeInfoFactory for Either typ...

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

[GitHub] flink issue #3062: [FLINK-5144] Fix error while applying rule AggregateJoinT...

Github user KurtYoung commented on the issue: https://github.com/apache/flink/pull/3062 Thanks @twalthr for the reviewing. I have opened https://issues.apache.org/jira/browse/FLINK-5435 to track the cleanup work. --- If your project is set up for it, you can reply to this email and

[GitHub] flink pull request #3086: Improve docker setup

Github user kaelumania commented on a diff in the pull request: https://github.com/apache/flink/pull/3086#discussion_r95383742 --- Diff: flink-contrib/docker-flink/docker-entrypoint.sh --- @@ -36,9 +39,9 @@ elif [ "$1" == "taskmanager" ]; then echo "Starting Task Manager"

[jira] [Commented] (FLINK-4861) Package optional project artifacts

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

[jira] [Commented] (FLINK-5144) Error while applying rule AggregateJoinTransposeRule

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

[GitHub] flink pull request #3080: [FLINK-4920] Add a Scala Function Gauge

Github user KurtYoung commented on a diff in the pull request: https://github.com/apache/flink/pull/3080#discussion_r95375413 --- Diff: flink-scala/src/main/scala/org/apache/flink/api/scala/metrics/ScalaGauge.scala --- @@ -0,0 +1,27 @@ +/* + * Licensed to the Apache

[GitHub] flink issue #2938: [FLINK-4692] [tableApi] Add tumbling group-windows for ba...

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/2938 @fhueske and I looked into this again. I seems that result depends on the batch ExecutionEnvironment. I used a regular environment while the test base uses a CollectionExecutionEnvironment. We don't

[jira] [Commented] (FLINK-4692) Add tumbling group-windows for batch tables

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

[GitHub] flink pull request #3062: [FLINK-5144] Fix error while applying rule Aggrega...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/3062#discussion_r95381307 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/batch/sql/CorrelateITCase.scala --- @@ -0,0 +1,68 @@ +/* + *

[GitHub] flink pull request #3062: [FLINK-5144] Fix error while applying rule Aggrega...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/3062#discussion_r95381802 --- Diff: tools/maven/suppressions.xml --- @@ -23,6 +23,8 @@ under the License. "http://www.puppycrawl.com/dtds/suppressions_1_1.dtd;>

[jira] [Commented] (FLINK-5144) Error while applying rule AggregateJoinTransposeRule

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

[GitHub] flink issue #3086: Improve docker setup

Github user kaelumania commented on the issue: https://github.com/apache/flink/pull/3086 @greghogan No, I didn't create a Ticket (sorry, I was not sure if this change justifies a Ticket). But I would love to see a Ticket about an automated build at DockerHub for Flink. --- If your

[GitHub] flink pull request #3087: [FLINK-4917] Deprecate "CheckpointedAsynchronously...

GitHub user mtunique opened a pull request: https://github.com/apache/flink/pull/3087 [FLINK-4917] Deprecate "CheckpointedAsynchronously" interface - [x] General - The pull request references the related JIRA issue ([FLINK-4917] Deprecate "CheckpointedAsynchronously"

[GitHub] flink pull request #2545: [FLINK-4673] [core] TypeInfoFactory for Either typ...

Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2545#discussion_r95386388 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java --- @@ -675,38 +673,6 @@ else if (isClassType(t) &&

[GitHub] flink issue #3087: [FLINK-4917] Deprecate "CheckpointedAsynchronously" inter...

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3087 Per Fabian's comment from the Jira, we should also document the deprecation in the javadoc with the recommended replacement functionality. --- If your project is set up for it, you can reply to

[jira] [Assigned] (FLINK-5432) ContinuousFileMonitoringFunction is not monitoring nested files

[ https://issues.apache.org/jira/browse/FLINK-5432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yassine Marzougui reassigned FLINK-5432: Assignee: Yassine Marzougui > ContinuousFileMonitoringFunction is not monitoring

[GitHub] flink pull request #3062: [FLINK-5144] Fix error while applying rule Aggrega...

Github user KurtYoung commented on a diff in the pull request: https://github.com/apache/flink/pull/3062#discussion_r95374019 --- Diff: tools/maven/suppressions.xml --- @@ -23,6 +23,8 @@ under the License. "http://www.puppycrawl.com/dtds/suppressions_1_1.dtd;>

[jira] [Commented] (FLINK-4920) Add a Scala Function Gauge

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

[GitHub] flink issue #3039: [FLINK-5280] Update TableSource to support nested data

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3039 Merging --- 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

[GitHub] flink issue #3027: [FLINK-5358] add RowTypeInfo exctraction in TypeExtractor

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3027 merging --- 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

[jira] [Commented] (FLINK-5280) Extend TableSource to support nested data

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

[jira] [Commented] (FLINK-5144) Error while applying rule AggregateJoinTransposeRule

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

[GitHub] flink issue #3030: Updated version of #3014

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3030 This feature has been merged? --- 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

[GitHub] flink pull request #3086: Improve docker setup

Github user kaelumania commented on a diff in the pull request: https://github.com/apache/flink/pull/3086#discussion_r95384182 --- Diff: flink-contrib/docker-flink/Dockerfile --- @@ -22,9 +22,9 @@ FROM java:8-jre-alpine RUN apk add --no-cache bash snappy # Configure

[jira] [Commented] (FLINK-4917) Deprecate "CheckpointedAsynchronously" interface

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

  1   2   >