[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

[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=17057620#comment-17057620 ] Gyula Fora commented on FLINK-16441: I have a quick fix that sets the contents of the configuration

[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:

[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

[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=17057617#comment-17057617 ] Jingsong Lee commented on FLINK-15290: -- Hi [~TsReaper], it is done in FLINK-16179 > Need a way to

[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=17057614#comment-17057614 ] Zhijiang commented on FLINK-16227: -- Another broken for nightly cron : 

[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

[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:

[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:

[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

[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

[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 *

[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

[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=17057605#comment-17057605 ] Caizhi Weng commented on FLINK-15290: - Hi [~lzljs3620320], I also agree that hive source configs

[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:

[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: *

[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:

[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

[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:

[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:

[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:

[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:

[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:

[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

[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

[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:

[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

[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] [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

[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

[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=17057586#comment-17057586 ] Jark Wu commented on FLINK-16441: - Hi [~gyfora], do you want to work on this? I would like to have this

[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:

[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=17057585#comment-17057585 ] Zhu Zhu commented on FLINK-16560: - cc [~aljoscha] [~klion26] > StreamExecutionEnvironment configuration

[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=17057583#comment-17057583 ] Jark Wu edited comment on FLINK-16294 at 3/12/20, 3:53 AM: --- What about to use

[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=17057583#comment-17057583 ] Jark Wu commented on FLINK-16294: - What about to use this title "Support to create non-exist table in

[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

[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

[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

[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 *

[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=17057572#comment-17057572 ] Kurt Young commented on FLINK-16343: Thanks [~jark], and sorry for the false alarm. I will change

[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

[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=17057571#comment-17057571 ] Jark Wu commented on FLINK-16343: - The exception is hard to understand, we should improve the exception

[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

[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

[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=17057569#comment-17057569 ] Jark Wu edited comment on FLINK-16343 at 3/12/20, 3:29 AM: --- After some

[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=17057569#comment-17057569 ] Jark Wu commented on FLINK-16343: - After some discussion with Kurt, this happens when querying on an

[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:

[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

[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.

[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:

[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 *

[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:

[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 *

[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=17057557#comment-17057557 ] Zou commented on FLINK-16446: - I have implemented this in our internal version, and I'd like to contribute

[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:

[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=17057553#comment-17057553 ] Rui Li commented on FLINK-16559: This is due to avro conflict between hive-exec and

[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:

[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: *

[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=17057546#comment-17057546 ] Leonard Xu commented on FLINK-16294: Hi [~sjwiesman] (1) this feature is different with JDBC

[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:

[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

[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 *

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

2020-03-11 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-16558: --- Summary: Reword Stateful Functions doc's tagline Key: FLINK-16558 URL: https://issues.apache.org/jira/browse/FLINK-16558 Project: Flink Issue

[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_r391375251 ## File path:

[jira] [Created] (FLINK-16557) Document YAML-ized Kafka egresses / ingresses in Stateful Functions documentation

2020-03-11 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-16557: --- Summary: Document YAML-ized Kafka egresses / ingresses in Stateful Functions documentation Key: FLINK-16557 URL: https://issues.apache.org/jira/browse/FLINK-16557

[jira] [Closed] (FLINK-16515) Refactor statefun documentation for multi-language SDKs

2020-03-11 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-16515. --- Resolution: Fixed Thanks [~sjwiesman]! Merged to master via

[jira] [Assigned] (FLINK-16515) Refactor statefun documentation for multi-language SDKs

2020-03-11 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-16515: --- Assignee: Seth Wiesman > Refactor statefun documentation for

[GitHub] [flink-statefun] tzulitai closed pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs

2020-03-11 Thread GitBox
tzulitai closed pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs URL: https://github.com/apache/flink-statefun/pull/54 This is an automated message from the Apache Git Service.

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

2020-03-11 Thread Tarush Grover (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057542#comment-17057542 ] Tarush Grover commented on FLINK-16446: --- [~FrankZou] Can I take this issue? > Add rate limiting

[GitHub] [flink-statefun] sjwiesman commented on issue #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs

2020-03-11 Thread GitBox
sjwiesman commented on issue #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs URL: https://github.com/apache/flink-statefun/pull/54#issuecomment-597978052 @tzulitai I have squashed the fixup commits

[GitHub] [flink-statefun] tzulitai commented on issue #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs

2020-03-11 Thread GitBox
tzulitai commented on issue #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs URL: https://github.com/apache/flink-statefun/pull/54#issuecomment-597978011 Thanks for the awesome work and reviews @sjwiesman @igalshilman! +1 to merge this.

[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:

[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:

[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_r391372489 ## File path:

[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:

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs

2020-03-11 Thread GitBox
tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs URL: https://github.com/apache/flink-statefun/pull/54#discussion_r391371162 ## File path: statefun-docs/docs/sdk/modules.rst ## @@ -0,0 +1,96 @@

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs

2020-03-11 Thread GitBox
tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs URL: https://github.com/apache/flink-statefun/pull/54#discussion_r391370729 ## File path: statefun-docs/docs/concepts/index.rst ## @@ -0,0 +1,97

[GitHub] [flink] lirui-apache commented on issue #11317: [FLINK-16433][table-api] TableEnvironmentImpl doesn't clear…

2020-03-11 Thread GitBox
lirui-apache commented on issue #11317: [FLINK-16433][table-api] TableEnvironmentImpl doesn't clear… URL: https://github.com/apache/flink/pull/11317#issuecomment-597975309 @godfreyhe I updated the java doc of `TableEnvironment#execute`. Please let me know if change makes sense to you.

[jira] [Commented] (FLINK-16379) Introduce fromValues in TableEnvironment

2020-03-11 Thread Zhenghua Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057536#comment-17057536 ] Zhenghua Gao commented on FLINK-16379: -- That's right that we can improve `fromValues(Object ...)`.

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

2020-03-11 Thread GitBox
flinkbot commented 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 UNKNOWN Bot commands The @flinkbot bot

[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-16541) Document of table.exec.shuffle-mode is incorrect

2020-03-11 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-16541: Assignee: Caizhi Weng > Document of table.exec.shuffle-mode is incorrect >

[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 *

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

2020-03-11 Thread GitBox
flinkbot commented on issue #11386: [FLINK-16541][doc] Fix document of table.exec.shuffle-mode URL: https://github.com/apache/flink/pull/11386#issuecomment-597970264 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

  1   2   3   4   5   6   >