[jira] [Assigned] (FLINK-14590) Unify the working directory of Java process and Python process when submitting python jobs via "flink run -py"

2019-11-24 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14590: --- Assignee: Hequn Cheng > Unify the working directory of Java process and Python process

[jira] [Assigned] (FLINK-14590) Unify the working directory of Java process and Python process when submitting python jobs via "flink run -py"

2019-11-24 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14590: --- Assignee: Wei Zhong (was: Hequn Cheng) > Unify the working directory of Java process and

[GitHub] [flink] flinkbot edited a comment on issue #10306: [FLINK-13943][table-api] Provide utility method to convert Flink table to Java List

2019-11-24 Thread GitBox
flinkbot edited a comment on issue #10306: [FLINK-13943][table-api] Provide utility method to convert Flink table to Java List URL: https://github.com/apache/flink/pull/10306#issuecomment-558027199 ## CI report: * 0b265d192e2a6024e5817317be0317136208ccaf : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #10305: [FLINK-14892][docs] Add documentation for checkpoint directory layout

2019-11-24 Thread GitBox
flinkbot edited a comment on issue #10305: [FLINK-14892][docs] Add documentation for checkpoint directory layout URL: https://github.com/apache/flink/pull/10305#issuecomment-558011526 ## CI report: * 160416cea63f157c0264c24812e2b2eef90e8c1d : SUCCESS

[jira] [Commented] (FLINK-13590) flink-on-yarn sometimes could create many little files that are xxx-taskmanager-conf.yaml

2019-11-24 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16981350#comment-16981350 ] Yang Wang commented on FLINK-13590: --- This Jira has been fixed via 

[GitHub] [flink] hequn8128 commented on a change in pull request #10103: [FLINK-14506][python][build] Improve the release script for Python API release package

2019-11-24 Thread GitBox
hequn8128 commented on a change in pull request #10103: [FLINK-14506][python][build] Improve the release script for Python API release package URL: https://github.com/apache/flink/pull/10103#discussion_r350021027 ## File path: flink-python/dev/lint-python.sh ## @@ -626,6

[GitHub] [flink] hequn8128 commented on a change in pull request #10103: [FLINK-14506][python][build] Improve the release script for Python API release package

2019-11-24 Thread GitBox
hequn8128 commented on a change in pull request #10103: [FLINK-14506][python][build] Improve the release script for Python API release package URL: https://github.com/apache/flink/pull/10103#discussion_r350021854 ## File path: flink-python/dev/lint-python.sh ## @@ -303,7

[GitHub] [flink] hequn8128 commented on a change in pull request #10103: [FLINK-14506][python][build] Improve the release script for Python API release package

2019-11-24 Thread GitBox
hequn8128 commented on a change in pull request #10103: [FLINK-14506][python][build] Improve the release script for Python API release package URL: https://github.com/apache/flink/pull/10103#discussion_r350022355 ## File path: flink-python/dev/lint-python.sh ## @@

[GitHub] [flink] hequn8128 commented on a change in pull request #10103: [FLINK-14506][python][build] Improve the release script for Python API release package

2019-11-24 Thread GitBox
hequn8128 commented on a change in pull request #10103: [FLINK-14506][python][build] Improve the release script for Python API release package URL: https://github.com/apache/flink/pull/10103#discussion_r350024300 ## File path: flink-python/dev/lint-python.sh ## @@ -105,6

[jira] [Commented] (FLINK-13758) failed to submit JobGraph when registered hdfs file in DistributedCache

2019-11-24 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16981342#comment-16981342 ] Arvid Heise commented on FLINK-13758: - If FLINK-14908 is indeed a duplicate, then this is also

[GitHub] [flink] flinkbot edited a comment on issue #10126: [FLINK-14590][python] Unify the working directory of Java process and Python process when submitting python jobs via "flink run -py"

2019-11-24 Thread GitBox
flinkbot edited a comment on issue #10126: [FLINK-14590][python] Unify the working directory of Java process and Python process when submitting python jobs via "flink run -py" URL: https://github.com/apache/flink/pull/10126#issuecomment-551413525 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #10304: [FLINK-14838] Cleanup the description about container number config option in Scala and python shell doc

2019-11-24 Thread GitBox
flinkbot edited a comment on issue #10304: [FLINK-14838] Cleanup the description about container number config option in Scala and python shell doc URL: https://github.com/apache/flink/pull/10304#issuecomment-558004149 ## CI report: * afdf3960fae62476f377aff7c27fac4f4779283a :

[GitHub] [flink] flinkbot commented on issue #10306: [FLINK-13943][table-api] Provide utility method to convert Flink table to Java List

2019-11-24 Thread GitBox
flinkbot commented on issue #10306: [FLINK-13943][table-api] Provide utility method to convert Flink table to Java List URL: https://github.com/apache/flink/pull/10306#issuecomment-558027199 ## CI report: * 0b265d192e2a6024e5817317be0317136208ccaf : UNKNOWN Bot

[GitHub] [flink] flinkbot edited a comment on issue #10268: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

2019-11-24 Thread GitBox
flinkbot edited a comment on issue #10268: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10268#issuecomment-555964030 ## CI report: * 72414aad5f654b834205103f23fbbfc3d5466748 : FAILURE

[jira] [Updated] (FLINK-14936) Introduce MemoryManager#computeMemorySize to calculate managed memory of an operator from a fraction

2019-11-24 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14936: Description: A MemoryManager#computeMemorySize(double fraction) is needed to calculate managed memory

[jira] [Updated] (FLINK-14936) Introduce MemoryManager#computeMemorySize to calculate managed memory of an operator from a fraction

2019-11-24 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14936: Description: A MemoryManager#computeMemorySize(double fraction) is needed to calculate managed memory

[GitHub] [flink] zjffdu commented on a change in pull request #10306: [FLINK-13943][table-api] Provide utility method to convert Flink table to Java List

2019-11-24 Thread GitBox
zjffdu commented on a change in pull request #10306: [FLINK-13943][table-api] Provide utility method to convert Flink table to Java List URL: https://github.com/apache/flink/pull/10306#discussion_r350016903 ## File path:

[GitHub] [flink] flinkbot commented on issue #10306: [FLINK-13943][table-api] Provide utility method to convert Flink table to Java List

2019-11-24 Thread GitBox
flinkbot commented on issue #10306: [FLINK-13943][table-api] Provide utility method to convert Flink table to Java List URL: https://github.com/apache/flink/pull/10306#issuecomment-558020653 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[jira] [Updated] (FLINK-13943) Provide api to convert flink table to java List (e.g. Table#collect)

2019-11-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13943: --- Labels: pull-request-available (was: ) > Provide api to convert flink table to java List

[GitHub] [flink] TsReaper opened a new pull request #10306: [FLINK-13943][table-api] Provide utility method to convert Flink table to Java List

2019-11-24 Thread GitBox
TsReaper opened a new pull request #10306: [FLINK-13943][table-api] Provide utility method to convert Flink table to Java List URL: https://github.com/apache/flink/pull/10306 ## What is the purpose of the change Some users would like to convert Flink table to Java List for demo or

[GitHub] [flink] flinkbot edited a comment on issue #10126: [FLINK-14590][python] Unify the working directory of Java process and Python process when submitting python jobs via "flink run -py"

2019-11-24 Thread GitBox
flinkbot edited a comment on issue #10126: [FLINK-14590][python] Unify the working directory of Java process and Python process when submitting python jobs via "flink run -py" URL: https://github.com/apache/flink/pull/10126#issuecomment-551413525 ## CI report: *

[jira] [Created] (FLINK-14936) Introduce MemoryManager#computeMemorySize to calculate managed memory of an operator from a fraction

2019-11-24 Thread Zhu Zhu (Jira)
Zhu Zhu created FLINK-14936: --- Summary: Introduce MemoryManager#computeMemorySize to calculate managed memory of an operator from a fraction Key: FLINK-14936 URL: https://issues.apache.org/jira/browse/FLINK-14936

[GitHub] [flink] flinkbot edited a comment on issue #10305: [FLINK-14892][docs] Add documentation for checkpoint directory layout

2019-11-24 Thread GitBox
flinkbot edited a comment on issue #10305: [FLINK-14892][docs] Add documentation for checkpoint directory layout URL: https://github.com/apache/flink/pull/10305#issuecomment-558011526 ## CI report: * 160416cea63f157c0264c24812e2b2eef90e8c1d : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #10296: [FLINK-14691][table]Add use/create/drop/alter database operation and support it in flink/blink planner

2019-11-24 Thread GitBox
flinkbot edited a comment on issue #10296: [FLINK-14691][table]Add use/create/drop/alter database operation and support it in flink/blink planner URL: https://github.com/apache/flink/pull/10296#issuecomment-557762350 ## CI report: * 7c5e46d1f794cb01be5088f5f5d29aec5850bf7f :

[GitHub] [flink] flinkbot edited a comment on issue #10268: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

2019-11-24 Thread GitBox
flinkbot edited a comment on issue #10268: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10268#issuecomment-555964030 ## CI report: * 72414aad5f654b834205103f23fbbfc3d5466748 : FAILURE

[GitHub] [flink] wangyang0918 commented on issue #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission

2019-11-24 Thread GitBox
wangyang0918 commented on issue #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission URL: https://github.com/apache/flink/pull/10193#issuecomment-558013369 @walterddr Your assumption 1 is right. For assumption 2, the pre-uploaded flink binary is located

[jira] [Commented] (FLINK-14930) OSS Filesystem Uses Wrong Shading Prefix

2019-11-24 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16981322#comment-16981322 ] Konstantin Knauf commented on FLINK-14930: -- [~chesnay] Could you assign me to this? > OSS

[jira] [Assigned] (FLINK-14552) Enable partition statistics in blink planner

2019-11-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-14552: --- Assignee: Jingsong Lee > Enable partition statistics in blink planner >

[jira] [Assigned] (FLINK-14543) Support partition for temporary table

2019-11-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-14543: --- Assignee: Jingsong Lee > Support partition for temporary table >

[GitHub] [flink] flinkbot commented on issue #10305: [FLINK-14892][docs] Add documentation for checkpoint directory layout

2019-11-24 Thread GitBox
flinkbot commented on issue #10305: [FLINK-14892][docs] Add documentation for checkpoint directory layout URL: https://github.com/apache/flink/pull/10305#issuecomment-558011526 ## CI report: * 160416cea63f157c0264c24812e2b2eef90e8c1d : UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on issue #10304: [FLINK-14838] Cleanup the description about container number config option in Scala and python shell doc

2019-11-24 Thread GitBox
flinkbot edited a comment on issue #10304: [FLINK-14838] Cleanup the description about container number config option in Scala and python shell doc URL: https://github.com/apache/flink/pull/10304#issuecomment-558004149 ## CI report: * afdf3960fae62476f377aff7c27fac4f4779283a :

[GitHub] [flink] wuchong commented on issue #10268: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

2019-11-24 Thread GitBox
wuchong commented on issue #10268: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10268#issuecomment-558010632 I agree with @JingsongLi . We can add some tests for high precision timestamp as group key, as

[GitHub] [flink] JingsongLi commented on issue #10268: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

2019-11-24 Thread GitBox
JingsongLi commented on issue #10268: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10268#issuecomment-558009679 Can you add more tests for timestamp type with precision that bigger than 3? Like in batch

[GitHub] [flink] JingsongLi commented on a change in pull request #10268: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

2019-11-24 Thread GitBox
JingsongLi commented on a change in pull request #10268: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10268#discussion_r350004855 ## File path:

[GitHub] [flink] docete commented on issue #10268: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

2019-11-24 Thread GitBox
docete commented on issue #10268: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10268#issuecomment-558008007 > Looks like your base is broken, rebase to master to let the tests pass? OK. Would rebase

[GitHub] [flink] KurtYoung commented on issue #10268: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

2019-11-24 Thread GitBox
KurtYoung commented on issue #10268: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10268#issuecomment-558006414 Looks like your base is broken, rebase to master to let the tests pass?

[GitHub] [flink] klion26 commented on a change in pull request #10305: [FLINK-14892][docs] Add documentation for checkpoint directory layout

2019-11-24 Thread GitBox
klion26 commented on a change in pull request #10305: [FLINK-14892][docs] Add documentation for checkpoint directory layout URL: https://github.com/apache/flink/pull/10305#discussion_r350003208 ## File path: docs/ops/state/checkpoints.md ## @@ -63,6 +63,24 @@ files. The

[GitHub] [flink] flinkbot commented on issue #10305: [FLINK-14892][docs] Add documentation for checkpoint directory layout

2019-11-24 Thread GitBox
flinkbot commented on issue #10305: [FLINK-14892][docs] Add documentation for checkpoint directory layout URL: https://github.com/apache/flink/pull/10305#issuecomment-558005628 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] KurtYoung commented on a change in pull request #10239: [FLINK-11491][end2end] Support all TPC-DS queries

2019-11-24 Thread GitBox
KurtYoung commented on a change in pull request #10239: [FLINK-11491][end2end] Support all TPC-DS queries URL: https://github.com/apache/flink/pull/10239#discussion_r349973287 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #10239: [FLINK-11491][end2end] Support all TPC-DS queries

2019-11-24 Thread GitBox
KurtYoung commented on a change in pull request #10239: [FLINK-11491][end2end] Support all TPC-DS queries URL: https://github.com/apache/flink/pull/10239#discussion_r349973626 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #10239: [FLINK-11491][end2end] Support all TPC-DS queries

2019-11-24 Thread GitBox
KurtYoung commented on a change in pull request #10239: [FLINK-11491][end2end] Support all TPC-DS queries URL: https://github.com/apache/flink/pull/10239#discussion_r34496 ## File path:

[GitHub] [flink] klion26 commented on issue #10305: [FLINK-14892][docs] Add documentation for checkpoint directory layout

2019-11-24 Thread GitBox
klion26 commented on issue #10305: [FLINK-14892][docs] Add documentation for checkpoint directory layout URL: https://github.com/apache/flink/pull/10305#issuecomment-558005061 cc @pnowojski cc @wuchong for the translated Chinese version

[GitHub] [flink] flinkbot edited a comment on issue #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch

2019-11-24 Thread GitBox
flinkbot edited a comment on issue #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch URL: https://github.com/apache/flink/pull/9864#issuecomment-539910284 ## CI report: * e66114b1aa73a82b4c6bcf5c3a16baedb598f8c3 : FAILURE

[jira] [Updated] (FLINK-14892) Add documentation for checkpoint directory layout

2019-11-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14892: --- Labels: pull-request-available (was: ) > Add documentation for checkpoint directory layout

[GitHub] [flink] wangyang0918 commented on a change in pull request #9957: [FLINK-10932] Initialize flink-kubernetes module

2019-11-24 Thread GitBox
wangyang0918 commented on a change in pull request #9957: [FLINK-10932] Initialize flink-kubernetes module URL: https://github.com/apache/flink/pull/9957#discussion_r350002500 ## File path: flink-kubernetes/pom.xml ## @@ -0,0 +1,208 @@ + + +

[GitHub] [flink] klion26 opened a new pull request #10305: [FLINK-14892][docs] Add documentation for checkpoint directory layout

2019-11-24 Thread GitBox
klion26 opened a new pull request #10305: [FLINK-14892][docs] Add documentation for checkpoint directory layout URL: https://github.com/apache/flink/pull/10305 ## What is the purpose of the change In FLINK-8531, we change the checkpoint directory layout to ```

[GitHub] [flink] flinkbot commented on issue #10304: [FLINK-14838] Cleanup the description about container number config option in Scala and python shell doc

2019-11-24 Thread GitBox
flinkbot commented on issue #10304: [FLINK-14838] Cleanup the description about container number config option in Scala and python shell doc URL: https://github.com/apache/flink/pull/10304#issuecomment-558004149 ## CI report: * afdf3960fae62476f377aff7c27fac4f4779283a : UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #10296: [FLINK-14691][table]Add use/create/drop/alter database operation and support it in flink/blink planner

2019-11-24 Thread GitBox
flinkbot edited a comment on issue #10296: [FLINK-14691][table]Add use/create/drop/alter database operation and support it in flink/blink planner URL: https://github.com/apache/flink/pull/10296#issuecomment-557762350 ## CI report: * 7c5e46d1f794cb01be5088f5f5d29aec5850bf7f :

[GitHub] [flink] flinkbot commented on issue #10304: [FLINK-14838] Cleanup the description about container number config option in Scala and python shell doc

2019-11-24 Thread GitBox
flinkbot commented on issue #10304: [FLINK-14838] Cleanup the description about container number config option in Scala and python shell doc URL: https://github.com/apache/flink/pull/10304#issuecomment-558002278 Thanks a lot for your contribution to the Apache Flink project. I'm the

[jira] [Updated] (FLINK-14838) Cleanup the description about container number config option in Scala and python shell doc

2019-11-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14838: --- Labels: pull-request-available (was: ) > Cleanup the description about container number

[GitHub] [flink] yanghua opened a new pull request #10304: [FLINK-14838] Cleanup the description about container number config option in Scala and python shell doc

2019-11-24 Thread GitBox
yanghua opened a new pull request #10304: [FLINK-14838] Cleanup the description about container number config option in Scala and python shell doc URL: https://github.com/apache/flink/pull/10304 ## What is the purpose of the change *This pull request cleanups the description

[GitHub] [flink] flinkbot edited a comment on issue #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch

2019-11-24 Thread GitBox
flinkbot edited a comment on issue #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch URL: https://github.com/apache/flink/pull/9864#issuecomment-539910284 ## CI report: * e66114b1aa73a82b4c6bcf5c3a16baedb598f8c3 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10296: [FLINK-14691][table]Add use/create/drop/alter database operation and support it in flink/blink planner

2019-11-24 Thread GitBox
flinkbot edited a comment on issue #10296: [FLINK-14691][table]Add use/create/drop/alter database operation and support it in flink/blink planner URL: https://github.com/apache/flink/pull/10296#issuecomment-557762350 ## CI report: * 7c5e46d1f794cb01be5088f5f5d29aec5850bf7f :

[GitHub] [flink] flinkbot edited a comment on issue #10022: [FLINK-14135][hive][orc] Introduce orc ColumnarRow reader for hive connector

2019-11-24 Thread GitBox
flinkbot edited a comment on issue #10022: [FLINK-14135][hive][orc] Introduce orc ColumnarRow reader for hive connector URL: https://github.com/apache/flink/pull/10022#issuecomment-547278354 ## CI report: * 73e9fbb7c4edb8628b93e9a5b17271e57a8b8f14 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10271: [FLINK-14874] [table-planner-blink] add local aggregate to solve data skew for ROLLUP/CUBE case

2019-11-24 Thread GitBox
flinkbot edited a comment on issue #10271: [FLINK-14874] [table-planner-blink] add local aggregate to solve data skew for ROLLUP/CUBE case URL: https://github.com/apache/flink/pull/10271#issuecomment-556037401 ## CI report: * dfd530a162b1912b00f5740ca07f828b44dcd4bd : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch

2019-11-24 Thread GitBox
flinkbot edited a comment on issue #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch URL: https://github.com/apache/flink/pull/9864#issuecomment-539910284 ## CI report: * e66114b1aa73a82b4c6bcf5c3a16baedb598f8c3 : FAILURE

[GitHub] [flink] zjuwangg commented on a change in pull request #10296: [FLINK-14691][table]Add use/create/drop/alter database operation and support it in flink/blink planner

2019-11-24 Thread GitBox
zjuwangg commented on a change in pull request #10296: [FLINK-14691][table]Add use/create/drop/alter database operation and support it in flink/blink planner URL: https://github.com/apache/flink/pull/10296#discussion_r349991863 ## File path:

[GitHub] [flink] zjuwangg commented on a change in pull request #10296: [FLINK-14691][table]Add use/create/drop/alter database operation and support it in flink/blink planner

2019-11-24 Thread GitBox
zjuwangg commented on a change in pull request #10296: [FLINK-14691][table]Add use/create/drop/alter database operation and support it in flink/blink planner URL: https://github.com/apache/flink/pull/10296#discussion_r349991483 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10210: [FLINK-14800][hive] Introduce parallelism inference for HiveSource

2019-11-24 Thread GitBox
flinkbot edited a comment on issue #10210: [FLINK-14800][hive] Introduce parallelism inference for HiveSource URL: https://github.com/apache/flink/pull/10210#issuecomment-554238019 ## CI report: * 642c74d85bdc002a43307814307cc5fb4cba923c : FAILURE

[GitHub] [flink] JingsongLi commented on issue #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch

2019-11-24 Thread GitBox
JingsongLi commented on issue #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch URL: https://github.com/apache/flink/pull/9864#issuecomment-557985620 @KurtYoung @lirui-apache Hope you take a look again.

[GitHub] [flink] flinkbot edited a comment on issue #10300: [FLINK-14926] [state backends] Make sure no resource leak of RocksObject

2019-11-24 Thread GitBox
flinkbot edited a comment on issue #10300: [FLINK-14926] [state backends] Make sure no resource leak of RocksObject URL: https://github.com/apache/flink/pull/10300#issuecomment-557891612 ## CI report: * dae41b86e4710d0c83d3f764e6196513db26a2c8 : FAILURE

[GitHub] [flink] zjuwangg commented on a change in pull request #10296: [FLINK-14691][table]Add use/create/drop/alter database operation and support it in flink/blink planner

2019-11-24 Thread GitBox
zjuwangg commented on a change in pull request #10296: [FLINK-14691][table]Add use/create/drop/alter database operation and support it in flink/blink planner URL: https://github.com/apache/flink/pull/10296#discussion_r349987842 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10022: [FLINK-14135][hive][orc] Introduce orc ColumnarRow reader for hive connector

2019-11-24 Thread GitBox
flinkbot edited a comment on issue #10022: [FLINK-14135][hive][orc] Introduce orc ColumnarRow reader for hive connector URL: https://github.com/apache/flink/pull/10022#issuecomment-547278354 ## CI report: * 73e9fbb7c4edb8628b93e9a5b17271e57a8b8f14 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10271: [FLINK-14874] [table-planner-blink] add local aggregate to solve data skew for ROLLUP/CUBE case

2019-11-24 Thread GitBox
flinkbot edited a comment on issue #10271: [FLINK-14874] [table-planner-blink] add local aggregate to solve data skew for ROLLUP/CUBE case URL: https://github.com/apache/flink/pull/10271#issuecomment-556037401 ## CI report: * dfd530a162b1912b00f5740ca07f828b44dcd4bd : FAILURE

[GitHub] [flink] JingsongLi commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch

2019-11-24 Thread GitBox
JingsongLi commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch URL: https://github.com/apache/flink/pull/9864#discussion_r349986777 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch

2019-11-24 Thread GitBox
JingsongLi commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch URL: https://github.com/apache/flink/pull/9864#discussion_r349986703 ## File path:

[GitHub] [flink] godfreyhe commented on a change in pull request #10174: [FLINK-14625][table-planner-blink] Add a rule to eliminate cross join as much as possible without statistics

2019-11-24 Thread GitBox
godfreyhe commented on a change in pull request #10174: [FLINK-14625][table-planner-blink] Add a rule to eliminate cross join as much as possible without statistics URL: https://github.com/apache/flink/pull/10174#discussion_r349981321 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch

2019-11-24 Thread GitBox
JingsongLi commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch URL: https://github.com/apache/flink/pull/9864#discussion_r349985201 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch

2019-11-24 Thread GitBox
JingsongLi commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch URL: https://github.com/apache/flink/pull/9864#discussion_r349985134 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch

2019-11-24 Thread GitBox
JingsongLi commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch URL: https://github.com/apache/flink/pull/9864#discussion_r349984971 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch

2019-11-24 Thread GitBox
JingsongLi commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch URL: https://github.com/apache/flink/pull/9864#discussion_r349984854 ## File path:

[jira] [Commented] (FLINK-13995) Fix shading of the licence information of netty

2019-11-24 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16981282#comment-16981282 ] Hequn Cheng commented on FLINK-13995: - [~chesnay] Hi, as legal problems are always important, so I

[GitHub] [flink] JingsongLi commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch

2019-11-24 Thread GitBox
JingsongLi commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch URL: https://github.com/apache/flink/pull/9864#discussion_r349983145 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10271: [FLINK-14874] [table-planner-blink] add local aggregate to solve data skew for ROLLUP/CUBE case

2019-11-24 Thread GitBox
flinkbot edited a comment on issue #10271: [FLINK-14874] [table-planner-blink] add local aggregate to solve data skew for ROLLUP/CUBE case URL: https://github.com/apache/flink/pull/10271#issuecomment-556037401 ## CI report: * dfd530a162b1912b00f5740ca07f828b44dcd4bd : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10022: [FLINK-14135][hive][orc] Introduce orc ColumnarRow reader for hive connector

2019-11-24 Thread GitBox
flinkbot edited a comment on issue #10022: [FLINK-14135][hive][orc] Introduce orc ColumnarRow reader for hive connector URL: https://github.com/apache/flink/pull/10022#issuecomment-547278354 ## CI report: * 73e9fbb7c4edb8628b93e9a5b17271e57a8b8f14 : SUCCESS

[jira] [Commented] (FLINK-14933) translate "Data Streaming Fault Tolerance" page in to Chinese

2019-11-24 Thread Zhangcheng Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16981280#comment-16981280 ] Zhangcheng Hu commented on FLINK-14933: --- ok,thx > translate "Data Streaming Fault Tolerance" page

[GitHub] [flink] JingsongLi commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch

2019-11-24 Thread GitBox
JingsongLi commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch URL: https://github.com/apache/flink/pull/9864#discussion_r349983145 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch

2019-11-24 Thread GitBox
JingsongLi commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch URL: https://github.com/apache/flink/pull/9864#discussion_r349982946 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch

2019-11-24 Thread GitBox
JingsongLi commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch URL: https://github.com/apache/flink/pull/9864#discussion_r349982669 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10210: [FLINK-14800][hive] Introduce parallelism inference for HiveSource

2019-11-24 Thread GitBox
flinkbot edited a comment on issue #10210: [FLINK-14800][hive] Introduce parallelism inference for HiveSource URL: https://github.com/apache/flink/pull/10210#issuecomment-554238019 ## CI report: * 642c74d85bdc002a43307814307cc5fb4cba923c : FAILURE

[jira] [Commented] (FLINK-14933) translate "Data Streaming Fault Tolerance" page in to Chinese

2019-11-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16981278#comment-16981278 ] Jark Wu commented on FLINK-14933: - Hi [~Zhangcheng], I assigned this issue to you. Feel free to open

[jira] [Commented] (FLINK-13943) Provide api to convert flink table to java List (e.g. Table#collect)

2019-11-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16981276#comment-16981276 ] Jark Wu commented on FLINK-13943: - Just want to confirm that we don't want to support \{{collect()}} for

[GitHub] [flink] JingsongLi commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch

2019-11-24 Thread GitBox
JingsongLi commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch URL: https://github.com/apache/flink/pull/9864#discussion_r349980532 ## File path:

[jira] [Assigned] (FLINK-14933) translate "Data Streaming Fault Tolerance" page in to Chinese

2019-11-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-14933: --- Assignee: Zhangcheng Hu > translate "Data Streaming Fault Tolerance" page in to Chinese >

[GitHub] [flink] JingsongLi commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch

2019-11-24 Thread GitBox
JingsongLi commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch URL: https://github.com/apache/flink/pull/9864#discussion_r349980532 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10300: [FLINK-14926] [state backends] Make sure no resource leak of RocksObject

2019-11-24 Thread GitBox
flinkbot edited a comment on issue #10300: [FLINK-14926] [state backends] Make sure no resource leak of RocksObject URL: https://github.com/apache/flink/pull/10300#issuecomment-557891612 ## CI report: * dae41b86e4710d0c83d3f764e6196513db26a2c8 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10291: [FLINK-14899] [table-planner-blink] Fix unexpected plan when PROCTIME() is defined in query

2019-11-24 Thread GitBox
flinkbot edited a comment on issue #10291: [FLINK-14899] [table-planner-blink] Fix unexpected plan when PROCTIME() is defined in query URL: https://github.com/apache/flink/pull/10291#issuecomment-557488395 ## CI report: * c3082d201afec00fff9e25d46059b3789c9d28d5 : CANCELED

[GitHub] [flink] godfreyhe commented on a change in pull request #10271: [FLINK-14874] [table-planner-blink] add local aggregate to solve data skew for ROLLUP/CUBE case

2019-11-24 Thread GitBox
godfreyhe commented on a change in pull request #10271: [FLINK-14874] [table-planner-blink] add local aggregate to solve data skew for ROLLUP/CUBE case URL: https://github.com/apache/flink/pull/10271#discussion_r349980293 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch

2019-11-24 Thread GitBox
JingsongLi commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch URL: https://github.com/apache/flink/pull/9864#discussion_r349979952 ## File path:

[jira] [Updated] (FLINK-14574) flink-s3-fs-hadoop doesn't work with plugins mechanism

2019-11-24 Thread clay (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] clay updated FLINK-14574: - Description: As reported by a user via [mailing

[jira] [Resolved] (FLINK-14595) Move flink-orc to flink-formats from flink-connectors

2019-11-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-14595. - Resolution: Fixed 1.10.0: 320240e2c412c15c7fa91649a0faa78018e74d86 > Move flink-orc to flink-formats

[GitHub] [flink] sunhaibotb commented on a change in pull request #10151: [FLINK-14231] Handle the processing-time timers before closing operator to properly support endInput

2019-11-24 Thread GitBox
sunhaibotb commented on a change in pull request #10151: [FLINK-14231] Handle the processing-time timers before closing operator to properly support endInput URL: https://github.com/apache/flink/pull/10151#discussion_r349979144 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch

2019-11-24 Thread GitBox
JingsongLi commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch URL: https://github.com/apache/flink/pull/9864#discussion_r349978969 ## File path:

[GitHub] [flink] openinx commented on a change in pull request #10270: [FLINK-14672][sql-client] Make Executor stateful in sql client

2019-11-24 Thread GitBox
openinx commented on a change in pull request #10270: [FLINK-14672][sql-client] Make Executor stateful in sql client URL: https://github.com/apache/flink/pull/10270#discussion_r349978430 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10210: [FLINK-14800][hive] Introduce parallelism inference for HiveSource

2019-11-24 Thread GitBox
flinkbot edited a comment on issue #10210: [FLINK-14800][hive] Introduce parallelism inference for HiveSource URL: https://github.com/apache/flink/pull/10210#issuecomment-554238019 ## CI report: * 642c74d85bdc002a43307814307cc5fb4cba923c : FAILURE

[GitHub] [flink] klion26 commented on issue #10292: [FLINK-14928][docs] Fix the broken links in documentation of page systemFunctions

2019-11-24 Thread GitBox
klion26 commented on issue #10292: [FLINK-14928][docs] Fix the broken links in documentation of page systemFunctions URL: https://github.com/apache/flink/pull/10292#issuecomment-557970148 @carp84 @wuchong thanks for the review and merging.

[GitHub] [flink] wuchong merged pull request #10277: [FLINK-14595][orc] Move flink-orc to flink-formats from flink-connectors

2019-11-24 Thread GitBox
wuchong merged pull request #10277: [FLINK-14595][orc] Move flink-orc to flink-formats from flink-connectors URL: https://github.com/apache/flink/pull/10277 This is an automated message from the Apache Git Service. To

[jira] [Updated] (FLINK-14712) Improve back-pressure reporting mechanism

2019-11-24 Thread lining (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-14712: --- Description: h4. (1) The current monitor is heavy-weight.  *   Backpressure monitoring works by repeatedly

[jira] [Commented] (FLINK-14838) Cleanup the description about container number config option in Scala and python shell doc

2019-11-24 Thread vinoyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16981268#comment-16981268 ] vinoyang commented on FLINK-14838: -- OK, will open a PR soon.  > Cleanup the description about

[jira] [Updated] (FLINK-14815) Expose network metric in IOMetricsInfo

2019-11-24 Thread lining (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-14815: --- Description: * SubTask **  pool usage: outPoolUsage, inputExclusiveBuffersUsage, 

  1   2   3   >