[GitHub] [flink] flinkbot edited a comment on issue #11388: [FLINK-16441][SQL] SQL Environment Configuration section will also be set in flink conf

2020-03-11 Thread GitBox
flinkbot edited a comment on issue #11388: [FLINK-16441][SQL] SQL Environment Configuration section will also be set in flink conf URL: https://github.com/apache/flink/pull/11388#issuecomment-598031774 ## CI report: * 0b39287557615cc135e3d57384c6f40c3069d428 Travis: [PENDING](ht

[GitHub] [flink] flinkbot edited a comment on issue #11344: [FLINK-16250][python][ml] Add interfaces for PipelineStage and Pipeline

2020-03-11 Thread GitBox
flinkbot edited a comment on issue #11344: [FLINK-16250][python][ml] Add interfaces for PipelineStage and Pipeline URL: https://github.com/apache/flink/pull/11344#issuecomment-596094520 ## CI report: * 95473512ec290d571496fae32da8d33013c8f56e Travis: [SUCCESS](https://travis-ci.

[GitHub] [flink] flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero

2020-03-11 Thread GitBox
flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero URL: https://github.com/apache/flink/pull/11351#issuecomment-596351676 ## CI report: * 715889a35cfcc3aaf1b17f39dadaa86f755cc75d UNKNOWN

[GitHub] [flink] zhengcanbin commented on issue #11346: [FLINK-16493][k8s] Use enum type instead of string type for KubernetesConfigOptions.REST_SERVICE_EXPOSED_TYPE

2020-03-11 Thread GitBox
zhengcanbin commented on issue #11346: [FLINK-16493][k8s] Use enum type instead of string type for KubernetesConfigOptions.REST_SERVICE_EXPOSED_TYPE URL: https://github.com/apache/flink/pull/11346#issuecomment-598033698 Hi, @knaufk. Could you help take a look? Kindly expect to see your repl

[jira] [Created] (FLINK-16562) Handle JobManager termination future in place

2020-03-11 Thread Zili Chen (Jira)
Zili Chen created FLINK-16562: - Summary: Handle JobManager termination future in place Key: FLINK-16562 URL: https://issues.apache.org/jira/browse/FLINK-16562 Project: Flink Issue Type: Improveme

[GitHub] [flink] flinkbot commented on issue #11388: [FLINK-16441][SQL] SQL Environment Configuration section will also be set in flink conf

2020-03-11 Thread GitBox
flinkbot commented on issue #11388: [FLINK-16441][SQL] SQL Environment Configuration section will also be set in flink conf URL: https://github.com/apache/flink/pull/11388#issuecomment-598031774 ## CI report: * 0b39287557615cc135e3d57384c6f40c3069d428 UNKNOWN Bot comma

[GitHub] [flink] flinkbot edited a comment on issue #11387: [FLINK-16343][table-planner-blink] Improve exception message when reading an unbounded source in batch mode

2020-03-11 Thread GitBox
flinkbot edited a comment on issue #11387: [FLINK-16343][table-planner-blink] Improve exception message when reading an unbounded source in batch mode URL: https://github.com/apache/flink/pull/11387#issuecomment-597995106 ## CI report: * 4101781e56c504d53168042efa996215b7d9d7bb T

[jira] [Updated] (FLINK-16526) Fix exception when computed column expression references a keyword column name

2020-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16526: Summary: Fix exception when computed column expression references a keyword column name (was: Escape char

[jira] [Resolved] (FLINK-16526) Fix exception when computed column expression references a keyword column name

2020-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-16526. - Resolution: Fixed Fixed in - master (1.11.0) : d723d0012c6b5e41e9d56784bc424e3942747225 - 1.10.1: 884e

[GitHub] [flink] wuchong commented on issue #11380: [FLINK-16526][table-planner-blink] Fix exception when computed column expression references a keyword column name

2020-03-11 Thread GitBox
wuchong commented on issue #11380: [FLINK-16526][table-planner-blink] Fix exception when computed column expression references a keyword column name URL: https://github.com/apache/flink/pull/11380#issuecomment-598029515 Thanks @danny0405 , will merge this. -

[GitHub] [flink] wuchong merged pull request #11380: [FLINK-16526][table-planner-blink] Fix exception when computed column expression references a keyword column name

2020-03-11 Thread GitBox
wuchong merged pull request #11380: [FLINK-16526][table-planner-blink] Fix exception when computed column expression references a keyword column name URL: https://github.com/apache/flink/pull/11380 This is an automated messa

[jira] [Assigned] (FLINK-16554) Extract static classes from StreamTask

2020-03-11 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-16554: -- Assignee: Roman Khachatryan > Extract static classes from StreamTask > --

[GitHub] [flink] flinkbot edited a comment on issue #11387: [FLINK-16343][table-planner-blink] Improve exception message when reading an unbounded source in batch mode

2020-03-11 Thread GitBox
flinkbot edited a comment on issue #11387: [FLINK-16343][table-planner-blink] Improve exception message when reading an unbounded source in batch mode URL: https://github.com/apache/flink/pull/11387#issuecomment-597995106 ## CI report: * 4101781e56c504d53168042efa996215b7d9d7bb T

[GitHub] [flink] flinkbot edited a comment on issue #11334: [FLINK-16464][sql-client]result-mode tableau may shift when content contains Chinese String in SQL CLI

2020-03-11 Thread GitBox
flinkbot edited a comment on issue #11334: [FLINK-16464][sql-client]result-mode tableau may shift when content contains Chinese String in SQL CLI URL: https://github.com/apache/flink/pull/11334#issuecomment-595841256 ## CI report: * 71e99474dc27f501c2c512e80761edd2057c00d0 Travis

[GitHub] [flink] flinkbot commented on issue #11388: [FLINK-16441][SQL] SQL Environment Configuration section will also be set in flink conf

2020-03-11 Thread GitBox
flinkbot commented on issue #11388: [FLINK-16441][SQL] SQL Environment Configuration section will also be set in flink conf URL: https://github.com/apache/flink/pull/11388#issuecomment-598024633 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the c

[GitHub] [flink] gyfora commented on issue #11388: [FLINK-16441][SQL] SQL Environment Configuration section will also be set in flink conf

2020-03-11 Thread GitBox
gyfora commented on issue #11388: [FLINK-16441][SQL] SQL Environment Configuration section will also be set in flink conf URL: https://github.com/apache/flink/pull/11388#issuecomment-598024337 cc @wuchong I still need to add a test case + some docs, just opening the PR for comments

[GitHub] [flink] gyfora opened a new pull request #11388: [FLINK-16441][SQL] SQL Environment Configuration section will also be set in flink conf

2020-03-11 Thread GitBox
gyfora opened a new pull request #11388: [FLINK-16441][SQL] SQL Environment Configuration section will also be set in flink conf URL: https://github.com/apache/flink/pull/11388 ## What is the purpose of the change Allow users to override regular Flink configuration settings f

[jira] [Updated] (FLINK-16441) Allow users to override flink-conf parameters from SQL CLI environment

2020-03-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16441: --- Labels: pull-request-available (was: ) > Allow users to override flink-conf parameters from

[jira] [Updated] (FLINK-16070) Blink planner can not extract correct unique key for UpsertStreamTableSink

2020-03-11 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-16070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 吴彦祖 updated FLINK-16070: Attachment: image-2020-03-12-14-07-37-429.png > Blink planner can not extract correct unique key for UpsertStreamT

[GitHub] [flink] flinkbot edited a comment on issue #11317: [FLINK-16433][table-api] TableEnvironmentImpl doesn't clear…

2020-03-11 Thread GitBox
flinkbot edited a comment on issue #11317: [FLINK-16433][table-api] TableEnvironmentImpl doesn't clear… URL: https://github.com/apache/flink/pull/11317#issuecomment-595145709 ## CI report: * 6cb26ab23d18cd85dda0501861873fa9382332ff UNKNOWN * 3bfc593562df2a1b7026ea7474c558edd04

[GitHub] [flink] flinkbot edited a comment on issue #11344: [FLINK-16250][python][ml] Add interfaces for PipelineStage and Pipeline

2020-03-11 Thread GitBox
flinkbot edited a comment on issue #11344: [FLINK-16250][python][ml] Add interfaces for PipelineStage and Pipeline URL: https://github.com/apache/flink/pull/11344#issuecomment-596094520 ## CI report: * a976d122cca58ccf820360a2bf12a094871d0977 Travis: [SUCCESS](https://travis-ci.

[GitHub] [flink] flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero

2020-03-11 Thread GitBox
flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero URL: https://github.com/apache/flink/pull/11351#issuecomment-596351676 ## CI report: * 715889a35cfcc3aaf1b17f39dadaa86f755cc75d UNKNOWN

[jira] [Assigned] (FLINK-16441) Allow users to override flink-conf parameters from SQL CLI environment

2020-03-11 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-16441: -- Assignee: Gyula Fora > Allow users to override flink-conf parameters from SQL CLI environment

[jira] [Commented] (FLINK-16441) Allow users to override flink-conf parameters from SQL CLI environment

2020-03-11 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17057620#comment-17057620 ] Gyula Fora commented on FLINK-16441: I have a quick fix that sets the contents of th

[GitHub] [flink] flinkbot edited a comment on issue #11344: [FLINK-16250][python][ml] Add interfaces for PipelineStage and Pipeline

2020-03-11 Thread GitBox
flinkbot edited a comment on issue #11344: [FLINK-16250][python][ml] Add interfaces for PipelineStage and Pipeline URL: https://github.com/apache/flink/pull/11344#issuecomment-596094520 ## CI report: * a976d122cca58ccf820360a2bf12a094871d0977 Travis: [SUCCESS](https://travis-ci.

[GitHub] [flink] flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero

2020-03-11 Thread GitBox
flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero URL: https://github.com/apache/flink/pull/11351#issuecomment-596351676 ## CI report: * 715889a35cfcc3aaf1b17f39dadaa86f755cc75d UNKNOWN

[jira] [Updated] (FLINK-16560) StreamExecutionEnvironment configuration is empty when building program via PackagedProgramUtils#createJobGraph

2020-03-11 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-16560: -- Fix Version/s: 1.11.0 1.10.1 > StreamExecutionEnvironment configuration is empty when build

[jira] [Commented] (FLINK-15290) Need a way to turn off vectorized orc reader for SQL CLI

2020-03-11 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17057617#comment-17057617 ] Jingsong Lee commented on FLINK-15290: -- Hi [~TsReaper], it is done in FLINK-16179

[jira] [Commented] (FLINK-16227) Streaming bucketing end-to-end test / test_streaming_bucketing.sh unstable

2020-03-11 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17057614#comment-17057614 ] Zhijiang commented on FLINK-16227: -- Another broken for nightly cron :  [https://dev.azu

[jira] [Updated] (FLINK-16227) Streaming bucketing end-to-end test / test_streaming_bucketing.sh unstable

2020-03-11 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-16227: - Priority: Critical (was: Major) > Streaming bucketing end-to-end test / test_streaming_bucketing.sh uns

[GitHub] [flink] hequn8128 commented on a change in pull request #11344: [FLINK-16250][python][ml] Add interfaces for PipelineStage and Pipeline

2020-03-11 Thread GitBox
hequn8128 commented on a change in pull request #11344: [FLINK-16250][python][ml] Add interfaces for PipelineStage and Pipeline URL: https://github.com/apache/flink/pull/11344#discussion_r391376778 ## File path: flink-python/pyflink/ml/api/base.py ## @@ -0,0 +1,275 @@ +###

[GitHub] [flink] flinkbot edited a comment on issue #11361: [FLINK-15727] Let BashJavaUtils return dynamic configs and JVM parame…

2020-03-11 Thread GitBox
flinkbot edited a comment on issue #11361: [FLINK-15727] Let BashJavaUtils return dynamic configs and JVM parame… URL: https://github.com/apache/flink/pull/11361#issuecomment-596976998 ## CI report: * 1ffc375e2b14f76c86e56d6d7aa888094a45d475 Travis: [SUCCESS](https://travis-ci.c

[GitHub] [flink] flinkbot edited a comment on issue #11386: [FLINK-16541][doc] Fix document of table.exec.shuffle-mode

2020-03-11 Thread GitBox
flinkbot edited a comment on issue #11386: [FLINK-16541][doc] Fix document of table.exec.shuffle-mode URL: https://github.com/apache/flink/pull/11386#issuecomment-597972340 ## CI report: * 7b06167c46752d062c2034dbbc00ac30d78aa542 Travis: [SUCCESS](https://travis-ci.com/github/fl

[GitHub] [flink] flinkbot edited a comment on issue #11387: [FLINK-16343][table-planner-blink] Improve exception message when reading an unbounded source in batch mode

2020-03-11 Thread GitBox
flinkbot edited a comment on issue #11387: [FLINK-16343][table-planner-blink] Improve exception message when reading an unbounded source in batch mode URL: https://github.com/apache/flink/pull/11387#issuecomment-597995106 ## CI report: * 4101781e56c504d53168042efa996215b7d9d7bb T

[GitHub] [flink] flinkbot edited a comment on issue #11334: [FLINK-16464][sql-client]result-mode tableau may shift when content contains Chinese String in SQL CLI

2020-03-11 Thread GitBox
flinkbot edited a comment on issue #11334: [FLINK-16464][sql-client]result-mode tableau may shift when content contains Chinese String in SQL CLI URL: https://github.com/apache/flink/pull/11334#issuecomment-595841256 ## CI report: * 8aa3b784db3bdd4b0c5bc455c96cfa59092cbe6f Travis

[GitHub] [flink] flinkbot edited a comment on issue #11317: [FLINK-16433][table-api] TableEnvironmentImpl doesn't clear…

2020-03-11 Thread GitBox
flinkbot edited a comment on issue #11317: [FLINK-16433][table-api] TableEnvironmentImpl doesn't clear… URL: https://github.com/apache/flink/pull/11317#issuecomment-595145709 ## CI report: * 6cb26ab23d18cd85dda0501861873fa9382332ff UNKNOWN * 3bfc593562df2a1b7026ea7474c558edd04

[GitHub] [flink] flinkbot edited a comment on issue #11387: [FLINK-16343][table-planner-blink] Improve exception message when reading an unbounded source in batch mode

2020-03-11 Thread GitBox
flinkbot edited a comment on issue #11387: [FLINK-16343][table-planner-blink] Improve exception message when reading an unbounded source in batch mode URL: https://github.com/apache/flink/pull/11387#issuecomment-597995106 ## CI report: * 4101781e56c504d53168042efa996215b7d9d7bb T

[jira] [Commented] (FLINK-15290) Need a way to turn off vectorized orc reader for SQL CLI

2020-03-11 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17057605#comment-17057605 ] Caizhi Weng commented on FLINK-15290: - Hi [~lzljs3620320], I also agree that hive s

[GitHub] [flink] flinkbot edited a comment on issue #11361: [FLINK-15727] Let BashJavaUtils return dynamic configs and JVM parame…

2020-03-11 Thread GitBox
flinkbot edited a comment on issue #11361: [FLINK-15727] Let BashJavaUtils return dynamic configs and JVM parame… URL: https://github.com/apache/flink/pull/11361#issuecomment-596976998 ## CI report: * 1ffc375e2b14f76c86e56d6d7aa888094a45d475 Travis: [SUCCESS](https://travis-ci.c

[GitHub] [flink] flinkbot edited a comment on issue #11374: [FLINK-16524][python] Optimize the result of FlattenRowCoder and ArrowCoder to generator to eliminate unnecessary function calls

2020-03-11 Thread GitBox
flinkbot edited a comment on issue #11374: [FLINK-16524][python] Optimize the result of FlattenRowCoder and ArrowCoder to generator to eliminate unnecessary function calls URL: https://github.com/apache/flink/pull/11374#issuecomment-597497985 ## CI report: * ef45405e3baca296b9ac

[GitHub] [flink] flinkbot edited a comment on issue #11386: [FLINK-16541][doc] Fix document of table.exec.shuffle-mode

2020-03-11 Thread GitBox
flinkbot edited a comment on issue #11386: [FLINK-16541][doc] Fix document of table.exec.shuffle-mode URL: https://github.com/apache/flink/pull/11386#issuecomment-597972340 ## CI report: * 7b06167c46752d062c2034dbbc00ac30d78aa542 Travis: [SUCCESS](https://travis-ci.com/github/fl

[GitHub] [flink] flinkbot edited a comment on issue #11334: [FLINK-16464][sql-client]result-mode tableau may shift when content contains Chinese String in SQL CLI

2020-03-11 Thread GitBox
flinkbot edited a comment on issue #11334: [FLINK-16464][sql-client]result-mode tableau may shift when content contains Chinese String in SQL CLI URL: https://github.com/apache/flink/pull/11334#issuecomment-595841256 ## CI report: * 8aa3b784db3bdd4b0c5bc455c96cfa59092cbe6f Travis

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-03-11 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r391399168 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/netwo

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-03-11 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r391397625 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/netwo

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-03-11 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r391397736 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/netwo

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-03-11 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r391397108 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/netwo

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-03-11 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r391396891 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/netwo

[GitHub] [flink] flinkbot edited a comment on issue #11387: [FLINK-16343][table-planner-blink] Improve exception message when reading an unbounded source in batch mode

2020-03-11 Thread GitBox
flinkbot edited a comment on issue #11387: [FLINK-16343][table-planner-blink] Improve exception message when reading an unbounded source in batch mode URL: https://github.com/apache/flink/pull/11387#issuecomment-597995106 ## CI report: * 4101781e56c504d53168042efa996215b7d9d7bb T

[jira] [Updated] (FLINK-16160) Schema#proctime and Schema#rowtime don't work in TableEnvironment#connect code path

2020-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16160: Fix Version/s: (was: 1.10.1) > Schema#proctime and Schema#rowtime don't work in TableEnvironment#conne

[jira] [Created] (FLINK-16561) Resuming Externalized Checkpoint (rocks, incremental, no parallelism change) end-to-end test fails on Azure

2020-03-11 Thread Biao Liu (Jira)
Biao Liu created FLINK-16561: Summary: Resuming Externalized Checkpoint (rocks, incremental, no parallelism change) end-to-end test fails on Azure Key: FLINK-16561 URL: https://issues.apache.org/jira/browse/FLINK-1656

[jira] [Updated] (FLINK-16021) DescriptorProperties.putTableSchema does not include constraints

2020-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16021: Priority: Critical (was: Major) > DescriptorProperties.putTableSchema does not include constraints >

[jira] [Updated] (FLINK-16021) DescriptorProperties.putTableSchema does not include constraints

2020-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16021: Fix Version/s: 1.11.0 1.10.1 > DescriptorProperties.putTableSchema does not include con

[jira] [Closed] (FLINK-16110) LogicalTypeParser can't parse "TIMESTAMP(3) *ROWTIME*" and "TIMESTAMP(3) *PROCTIME*"

2020-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-16110. --- Resolution: Invalid Close this issue according to the discussion. Please reopen it if you have other though

[jira] [Updated] (FLINK-16282) Wrong exception using DESCRIBE SQL command

2020-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16282: Fix Version/s: 1.11.0 1.10.1 > Wrong exception using DESCRIBE SQL command > ---

[jira] [Updated] (FLINK-16451) listagg with distinct for over window codegen error

2020-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16451: Fix Version/s: 1.11.0 1.10.1 > listagg with distinct for over window codegen error > -

[jira] [Updated] (FLINK-15669) SQL client can't cancel flink job

2020-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-15669: Priority: Critical (was: Major) > SQL client can't cancel flink job > - >

[jira] [Updated] (FLINK-16047) Blink planner produces wrong aggregate results with state clean up

2020-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16047: Fix Version/s: 1.11.0 > Blink planner produces wrong aggregate results with state clean up > -

[GitHub] [flink] flinkbot commented on issue #11387: [FLINK-16343][table-planner-blink] Improve exception message when reading an unbounded source in batch mode

2020-03-11 Thread GitBox
flinkbot commented on issue #11387: [FLINK-16343][table-planner-blink] Improve exception message when reading an unbounded source in batch mode URL: https://github.com/apache/flink/pull/11387#issuecomment-597995106 ## CI report: * 4101781e56c504d53168042efa996215b7d9d7bb UNKNOWN

[jira] [Updated] (FLINK-16345) Computed column can not refer time attribute column

2020-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16345: Priority: Critical (was: Major) > Computed column can not refer time attribute column >

[jira] [Updated] (FLINK-16441) Allow users to override flink-conf parameters from SQL CLI environment

2020-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16441: Priority: Critical (was: Major) > Allow users to override flink-conf parameters from SQL CLI environment

[jira] [Updated] (FLINK-16560) StreamExecutionEnvironment configuration is empty when building program via PackagedProgramUtils#createJobGraph

2020-03-11 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-16560: Description: PackagedProgramUtils#createJobGraph(...) is used to generate JobGraph in k8s job mode. The p

[jira] [Commented] (FLINK-16441) Allow users to override flink-conf parameters from SQL CLI environment

2020-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17057586#comment-17057586 ] Jark Wu commented on FLINK-16441: - Hi [~gyfora], do you want to work on this? I would li

[jira] [Created] (FLINK-16560) StreamExecutionEnvironment configuration is empty when building program via PackagedProgramUtils#createJobGraph

2020-03-11 Thread Zhu Zhu (Jira)
Zhu Zhu created FLINK-16560: --- Summary: StreamExecutionEnvironment configuration is empty when building program via PackagedProgramUtils#createJobGraph Key: FLINK-16560 URL: https://issues.apache.org/jira/browse/FLINK-16

[jira] [Commented] (FLINK-16560) StreamExecutionEnvironment configuration is empty when building program via PackagedProgramUtils#createJobGraph

2020-03-11 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17057585#comment-17057585 ] Zhu Zhu commented on FLINK-16560: - cc [~aljoscha] [~klion26] > StreamExecutionEnvironme

[jira] [Comment Edited] (FLINK-16294) JDBC connector support create database table automatically

2020-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17057583#comment-17057583 ] Jark Wu edited comment on FLINK-16294 at 3/12/20, 3:53 AM: --- Wh

[jira] [Commented] (FLINK-16294) JDBC connector support create database table automatically

2020-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17057583#comment-17057583 ] Jark Wu commented on FLINK-16294: - What about to use this title "Support to create non-e

[GitHub] [flink] flinkbot commented on issue #11387: [FLINK-16343][table-planner-blink] Improve exception message when reading an unbounded source in batch mode

2020-03-11 Thread GitBox
flinkbot commented on issue #11387: [FLINK-16343][table-planner-blink] Improve exception message when reading an unbounded source in batch mode URL: https://github.com/apache/flink/pull/11387#issuecomment-597992527 Thanks a lot for your contribution to the Apache Flink project. I'm the @fl

[GitHub] [flink] wuchong opened a new pull request #11387: [FLINK-16343][table-planner-blink] Improve exception message when reading an unbounded source in batch mode

2020-03-11 Thread GitBox
wuchong opened a new pull request #11387: [FLINK-16343][table-planner-blink] Improve exception message when reading an unbounded source in batch mode URL: https://github.com/apache/flink/pull/11387 ## What is the purpose of the change This is an improvement for the except

[jira] [Updated] (FLINK-16343) Improve exception message when reading an unbounded source in batch mode

2020-03-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16343: --- Labels: pull-request-available (was: ) > Improve exception message when reading an unbounde

[GitHub] [flink] flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero

2020-03-11 Thread GitBox
flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero URL: https://github.com/apache/flink/pull/11351#issuecomment-596351676 ## CI report: * 715889a35cfcc3aaf1b17f39dadaa86f755cc75d UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #11238: [FLINK-16304][python] Remove python packages bundled in the flink-python jar.

2020-03-11 Thread GitBox
flinkbot edited a comment on issue #11238: [FLINK-16304][python] Remove python packages bundled in the flink-python jar. URL: https://github.com/apache/flink/pull/11238#issuecomment-591923781 ## CI report: * a715f80958d35e1507f075982e63e5844d94d893 UNKNOWN * 1e1f9de29552097bc7

[jira] [Commented] (FLINK-16343) Improve exception message when reading an unbounded source in batch mode

2020-03-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17057572#comment-17057572 ] Kurt Young commented on FLINK-16343: Thanks [~jark], and sorry for the false alarm.

[jira] [Updated] (FLINK-16343) Improve exception message when reading an unbounded source in batch mode

2020-03-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16343: --- Fix Version/s: (was: 1.10.1) > Improve exception message when reading an unbounded source in bat

[jira] [Updated] (FLINK-16343) Improve exception message when reading an unbounded source in batch mode

2020-03-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16343: --- Issue Type: Improvement (was: Bug) > Improve exception message when reading an unbounded source in

[jira] [Commented] (FLINK-16343) Improve exception message when reading an unbounded source in batch mode

2020-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17057571#comment-17057571 ] Jark Wu commented on FLINK-16343: - The exception is hard to understand, we should improv

[jira] [Updated] (FLINK-16343) Improve exception message when reading an unbounded source in batch mode

2020-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16343: Summary: Improve exception message when reading an unbounded source in batch mode (was: Failed to read a

[GitHub] [flink] ifndef-SleePy commented on issue #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded

2020-03-11 Thread GitBox
ifndef-SleePy commented on issue #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded URL: https://github.com/apache/flink/pull/11347#issuecomment-597988749 Hey @pnowojski , thanks for reviewing. The e2e testing case got passed this t

[jira] [Comment Edited] (FLINK-16343) Failed to read a table with watermark in batch mode

2020-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17057569#comment-17057569 ] Jark Wu edited comment on FLINK-16343 at 3/12/20, 3:29 AM: --- Af

[jira] [Commented] (FLINK-16343) Failed to read a table with watermark in batch mode

2020-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17057569#comment-17057569 ] Jark Wu commented on FLINK-16343: - After some discussion with Kurt, this happens when qu

[GitHub] [flink] ifndef-SleePy commented on a change in pull request #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded

2020-03-11 Thread GitBox
ifndef-SleePy commented on a change in pull request #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded URL: https://github.com/apache/flink/pull/11347#discussion_r391383507 ## File path: flink-runtime/src/main/java/org/apac

[jira] [Updated] (FLINK-16547) Correct the order to write temporary files in YarnClusterDescriptor#startAppMaster

2020-03-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-16547: - Summary: Correct the order to write temporary files in YarnClusterDescriptor#startAppMaster (wa

[GitHub] [flink] KarmaGYZ commented on issue #11361: [FLINK-15727] Let BashJavaUtils return dynamic configs and JVM parame…

2020-03-11 Thread GitBox
KarmaGYZ commented on issue #11361: [FLINK-15727] Let BashJavaUtils return dynamic configs and JVM parame… URL: https://github.com/apache/flink/pull/11361#issuecomment-597986864 Thanks for the review @zentol . PR updated. Thi

[GitHub] [flink] ifndef-SleePy commented on a change in pull request #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded

2020-03-11 Thread GitBox
ifndef-SleePy commented on a change in pull request #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded URL: https://github.com/apache/flink/pull/11347#discussion_r391381769 ## File path: flink-runtime/src/main/java/org/apac

[GitHub] [flink] flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero

2020-03-11 Thread GitBox
flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero URL: https://github.com/apache/flink/pull/11351#issuecomment-596351676 ## CI report: * 715889a35cfcc3aaf1b17f39dadaa86f755cc75d UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #11317: [FLINK-16433][table-api] TableEnvironmentImpl doesn't clear…

2020-03-11 Thread GitBox
flinkbot edited a comment on issue #11317: [FLINK-16433][table-api] TableEnvironmentImpl doesn't clear… URL: https://github.com/apache/flink/pull/11317#issuecomment-595145709 ## CI report: * 6cb26ab23d18cd85dda0501861873fa9382332ff UNKNOWN * 6b044fa7bc048d0f2381eb80f438bdf0db0

[GitHub] [flink] flinkbot edited a comment on issue #11326: [FLINK-11427][formats] Add protobuf parquet support for StreamingFileSink

2020-03-11 Thread GitBox
flinkbot edited a comment on issue #11326: [FLINK-11427][formats] Add protobuf parquet support for StreamingFileSink URL: https://github.com/apache/flink/pull/11326#issuecomment-595547530 ## CI report: * 6beb3402b4bd44d60b0b8c893edae0493a7b85ed Travis: [SUCCESS](https://travis-c

[GitHub] [flink] flinkbot edited a comment on issue #11238: [FLINK-16304][python] Remove python packages bundled in the flink-python jar.

2020-03-11 Thread GitBox
flinkbot edited a comment on issue #11238: [FLINK-16304][python] Remove python packages bundled in the flink-python jar. URL: https://github.com/apache/flink/pull/11238#issuecomment-591923781 ## CI report: * a715f80958d35e1507f075982e63e5844d94d893 UNKNOWN * 1e1f9de29552097bc7

[jira] [Commented] (FLINK-16446) Add rate limiting feature for FlinkKafkaConsumer

2020-03-11 Thread Zou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17057557#comment-17057557 ] Zou commented on FLINK-16446: - I have implemented this in our internal version, and I'd like

[jira] [Updated] (FLINK-16558) Reword Stateful Functions doc's tagline

2020-03-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16558: --- Labels: pull-request-available (was: ) > Reword Stateful Functions doc's tagline > ---

[GitHub] [flink-statefun] tzulitai opened a new pull request #56: [FLINK-16558] [doc] Reword project website tagline

2020-03-11 Thread GitBox
tzulitai opened a new pull request #56: [FLINK-16558] [doc] Reword project website tagline URL: https://github.com/apache/flink-statefun/pull/56 This PR changes the project tagline in the docs to: ![image](https://user-images.githubusercontent.com/5284370/76483039-ed52a880-6450-11ea

[jira] [Commented] (FLINK-16559) Cannot create Hive avro table in test

2020-03-11 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17057553#comment-17057553 ] Rui Li commented on FLINK-16559: This is due to avro conflict between hive-exec and flin

[GitHub] [flink] hequn8128 commented on a change in pull request #11344: [FLINK-16250][python][ml] Add interfaces for PipelineStage and Pipeline

2020-03-11 Thread GitBox
hequn8128 commented on a change in pull request #11344: [FLINK-16250][python][ml] Add interfaces for PipelineStage and Pipeline URL: https://github.com/apache/flink/pull/11344#discussion_r391376778 ## File path: flink-python/pyflink/ml/api/base.py ## @@ -0,0 +1,275 @@ +###

[GitHub] [flink] hequn8128 commented on a change in pull request #11344: [FLINK-16250][python][ml] Add interfaces for PipelineStage and Pipeline

2020-03-11 Thread GitBox
hequn8128 commented on a change in pull request #11344: [FLINK-16250][python][ml] Add interfaces for PipelineStage and Pipeline URL: https://github.com/apache/flink/pull/11344#discussion_r391376778 ## File path: flink-python/pyflink/ml/api/base.py ## @@ -0,0 +1,275 @@ +###

[jira] [Updated] (FLINK-16559) Cannot create Hive avro table in test

2020-03-11 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-16559: --- Description: Trying to create a Hive avro table will hit the following exception: {noformat} Caused by: java

[GitHub] [flink] flinkbot edited a comment on issue #11374: [FLINK-16524][python] Optimize the result of FlattenRowCoder and ArrowCoder to generator to eliminate unnecessary function calls

2020-03-11 Thread GitBox
flinkbot edited a comment on issue #11374: [FLINK-16524][python] Optimize the result of FlattenRowCoder and ArrowCoder to generator to eliminate unnecessary function calls URL: https://github.com/apache/flink/pull/11374#issuecomment-597497985 ## CI report: * ef45405e3baca296b9ac

[GitHub] [flink] hequn8128 commented on a change in pull request #11344: [FLINK-16250][python][ml] Add interfaces for PipelineStage and Pipeline

2020-03-11 Thread GitBox
hequn8128 commented on a change in pull request #11344: [FLINK-16250][python][ml] Add interfaces for PipelineStage and Pipeline URL: https://github.com/apache/flink/pull/11344#discussion_r391376778 ## File path: flink-python/pyflink/ml/api/base.py ## @@ -0,0 +1,275 @@ +###

[jira] [Commented] (FLINK-16294) JDBC connector support create database table automatically

2020-03-11 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17057546#comment-17057546 ] Leonard Xu commented on FLINK-16294: Hi [~sjwiesman] (1) this feature is different

[GitHub] [flink] flinkbot edited a comment on issue #11361: [FLINK-15727] Let BashJavaUtils return dynamic configs and JVM parame…

2020-03-11 Thread GitBox
flinkbot edited a comment on issue #11361: [FLINK-15727] Let BashJavaUtils return dynamic configs and JVM parame… URL: https://github.com/apache/flink/pull/11361#issuecomment-596976998 ## CI report: * cd09736f8968ac04c685e0bd502a18bd163388bf Travis: [SUCCESS](https://travis-ci.c

[jira] [Created] (FLINK-16559) Cannot create Hive avro table in test

2020-03-11 Thread Rui Li (Jira)
Rui Li created FLINK-16559: -- Summary: Cannot create Hive avro table in test Key: FLINK-16559 URL: https://issues.apache.org/jira/browse/FLINK-16559 Project: Flink Issue Type: Bug Component

[GitHub] [flink] flinkbot edited a comment on issue #11317: [FLINK-16433][table-api] TableEnvironmentImpl doesn't clear…

2020-03-11 Thread GitBox
flinkbot edited a comment on issue #11317: [FLINK-16433][table-api] TableEnvironmentImpl doesn't clear… URL: https://github.com/apache/flink/pull/11317#issuecomment-595145709 ## CI report: * 6cb26ab23d18cd85dda0501861873fa9382332ff UNKNOWN * 6b044fa7bc048d0f2381eb80f438bdf0db0

  1   2   3   4   5   6   >