[GitHub] [flink] flinkbot edited a comment on issue #11291: [FLINK-16392] [API / DataStream] oneside sorted cache in intervaljoin

2020-03-05 Thread GitBox
flinkbot edited a comment on issue #11291: [FLINK-16392] [API / DataStream] oneside sorted cache in intervaljoin URL: https://github.com/apache/flink/pull/11291#issuecomment-593677297 ## CI report: * d6b2919dd28c55230e530ccc45ca7d93d90a60df UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11174: [FLINK-16199][sql] Support IS JSON predicate for blink planner

2020-03-05 Thread GitBox
flinkbot edited a comment on issue #11174: [FLINK-16199][sql] Support IS JSON predicate for blink planner URL: https://github.com/apache/flink/pull/11174#issuecomment-589653271 ## CI report: * 1f9edd40377c412486126a329eb8ea2c5885326f Travis:

[GitHub] [flink] flinkbot edited a comment on issue #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-03-05 Thread GitBox
flinkbot edited a comment on issue #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#issuecomment-567435407 ## CI report: * 4d17b4de75015fade25228f8fa6668f0cf0d9dca UNKNOWN *

[GitHub] [flink] wuchong commented on a change in pull request #11119: [FLINK-15396][json] Support to ignore parse errors for JSON format

2020-03-05 Thread GitBox
wuchong commented on a change in pull request #9: [FLINK-15396][json] Support to ignore parse errors for JSON format URL: https://github.com/apache/flink/pull/9#discussion_r388754235 ## File path:

[GitHub] [flink] zoudan commented on a change in pull request #11119: [FLINK-15396][json] Support to ignore parse errors for JSON format

2020-03-05 Thread GitBox
zoudan commented on a change in pull request #9: [FLINK-15396][json] Support to ignore parse errors for JSON format URL: https://github.com/apache/flink/pull/9#discussion_r388753743 ## File path:

[GitHub] [flink] TisonKun commented on a change in pull request #11174: [FLINK-16199][sql] Support IS JSON predicate for blink planner

2020-03-05 Thread GitBox
TisonKun commented on a change in pull request #11174: [FLINK-16199][sql] Support IS JSON predicate for blink planner URL: https://github.com/apache/flink/pull/11174#discussion_r388752841 ## File path:

[GitHub] [flink] JingsongLi commented on issue #11296: [FLINK-16363] [table] Correct the execution behavior of TableEnvironment and StreamTableEnvironment

2020-03-05 Thread GitBox
JingsongLi commented on issue #11296: [FLINK-16363] [table] Correct the execution behavior of TableEnvironment and StreamTableEnvironment URL: https://github.com/apache/flink/pull/11296#issuecomment-595641229 Quite confused, It seems that `StreamWindowSQLExample` is wrong too?

[GitHub] [flink] TisonKun commented on a change in pull request #11174: [FLINK-16199][sql] Support IS JSON predicate for blink planner

2020-03-05 Thread GitBox
TisonKun commented on a change in pull request #11174: [FLINK-16199][sql] Support IS JSON predicate for blink planner URL: https://github.com/apache/flink/pull/11174#discussion_r388750794 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11307: [FLINK-16371] [BulkWriter] Fix Hadoop Compression BulkWriter

2020-03-05 Thread GitBox
flinkbot edited a comment on issue #11307: [FLINK-16371] [BulkWriter] Fix Hadoop Compression BulkWriter URL: https://github.com/apache/flink/pull/11307#issuecomment-594492515 ## CI report: * fd9573132fb80316ff33223e646cb27467247678 Travis:

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

2020-03-05 Thread GitBox
gaoyunhaii 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_r388749965 ## File path:

[jira] [Closed] (FLINK-16337) Add RelNodes and Rules for vectorized Python UDF execution

2020-03-05 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16337. --- Resolution: Resolved > Add RelNodes and Rules for vectorized Python UDF execution >

[jira] [Commented] (FLINK-16337) Add RelNodes and Rules for vectorized Python UDF execution

2020-03-05 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053097#comment-17053097 ] Hequn Cheng commented on FLINK-16337: - Resolved in 1.11.0 via

[GitHub] [flink] hequn8128 closed pull request #11252: [FLINK-16337][python][table-planner][table-planner-blink] Add support of vectorized Python UDF in blink planner and old planner

2020-03-05 Thread GitBox
hequn8128 closed pull request #11252: [FLINK-16337][python][table-planner][table-planner-blink] Add support of vectorized Python UDF in blink planner and old planner URL: https://github.com/apache/flink/pull/11252 This is

[GitHub] [flink] JingsongLi commented on issue #11296: [FLINK-16363] [table] Correct the execution behavior of TableEnvironment and StreamTableEnvironment

2020-03-05 Thread GitBox
JingsongLi commented on issue #11296: [FLINK-16363] [table] Correct the execution behavior of TableEnvironment and StreamTableEnvironment URL: https://github.com/apache/flink/pull/11296#issuecomment-595637295 Thanks for @godfreyhe for contribution. Consider 1000+ codes and 42 files, can

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

2020-03-05 Thread GitBox
gaoyunhaii 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_r388745136 ## File path:

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

2020-03-05 Thread GitBox
gaoyunhaii 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_r388742828 ## File path:

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

2020-03-05 Thread GitBox
gaoyunhaii 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_r388742647 ## File path:

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

2020-03-05 Thread GitBox
gaoyunhaii 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_r388742111 ## File path:

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

2020-03-05 Thread GitBox
gaoyunhaii 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_r388741843 ## File path:

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

2020-03-05 Thread GitBox
gaoyunhaii 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_r388741911 ## File path:

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

2020-03-05 Thread GitBox
gaoyunhaii 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_r388741953 ## File path:

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

2020-03-05 Thread GitBox
gaoyunhaii 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_r388741397 ## File path:

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

2020-03-05 Thread GitBox
gaoyunhaii 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_r388741599 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11296: [FLINK-16363] [table] Correct the execution behavior of TableEnvironment and StreamTableEnvironment

2020-03-05 Thread GitBox
flinkbot edited a comment on issue #11296: [FLINK-16363] [table] Correct the execution behavior of TableEnvironment and StreamTableEnvironment URL: https://github.com/apache/flink/pull/11296#issuecomment-59383 ## CI report: * 1cc5377ea984d66c1e4bcd62451d60359abdfb72 Travis:

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

2020-03-05 Thread GitBox
gaoyunhaii 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_r388741397 ## File path:

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

2020-03-05 Thread GitBox
gaoyunhaii 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_r388741245 ## File path:

[jira] [Commented] (FLINK-16419) Avoid to recommit transactions which are known committed successfully to Kafka upon recovery

2020-03-05 Thread Jun Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053086#comment-17053086 ] Jun Qin commented on FLINK-16419: - That should be sufficient. > Avoid to recommit transactions which

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

2020-03-05 Thread GitBox
gaoyunhaii 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_r388740363 ## File path:

[jira] [Commented] (FLINK-16313) flink-state-processor-api: surefire execution unstable on Azure

2020-03-05 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053085#comment-17053085 ] Robert Metzger commented on FLINK-16313: [~sjwiesman] Thanks for looking into it. I am also not

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

2020-03-05 Thread GitBox
gaoyunhaii 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_r388740363 ## File path:

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

2020-03-05 Thread GitBox
gaoyunhaii 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_r388740026 ## File path:

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

2020-03-05 Thread GitBox
gaoyunhaii 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_r388739692 ## File path:

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

2020-03-05 Thread GitBox
gaoyunhaii 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_r388739325 ## File path:

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

2020-03-05 Thread GitBox
gaoyunhaii 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_r388739505 ## File path:

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

2020-03-05 Thread GitBox
gaoyunhaii 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_r388738882 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11296: [FLINK-16363] [table] Correct the execution behavior of TableEnvironment and StreamTableEnvironment

2020-03-05 Thread GitBox
flinkbot edited a comment on issue #11296: [FLINK-16363] [table] Correct the execution behavior of TableEnvironment and StreamTableEnvironment URL: https://github.com/apache/flink/pull/11296#issuecomment-59383 ## CI report: * 42befb8bcb61fcb1d8c2551affe9da273f978295 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11328: [FLINK-16455][hive] Introduce flink-sql-connector-hive modules to provide hive uber jars

2020-03-05 Thread GitBox
flinkbot edited a comment on issue #11328: [FLINK-16455][hive] Introduce flink-sql-connector-hive modules to provide hive uber jars URL: https://github.com/apache/flink/pull/11328#issuecomment-595621789 ## CI report: * d42e0ab290c177605a78eb5ceb9eacbc72e54a15 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11327: [FLINK-16450][hive] Integrate parquet columnar row reader to hive

2020-03-05 Thread GitBox
flinkbot edited a comment on issue #11327: [FLINK-16450][hive] Integrate parquet columnar row reader to hive URL: https://github.com/apache/flink/pull/11327#issuecomment-595580274 ## CI report: * c3b16385089b077cc856f24d9b0f33903a17a91c Travis:

[GitHub] [flink] wuchong commented on a change in pull request #11174: [FLINK-16199][sql] Support IS JSON predicate for blink planner

2020-03-05 Thread GitBox
wuchong commented on a change in pull request #11174: [FLINK-16199][sql] Support IS JSON predicate for blink planner URL: https://github.com/apache/flink/pull/11174#discussion_r388736245 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #11119: [FLINK-15396][json] Support to ignore parse errors for JSON format

2020-03-05 Thread GitBox
wuchong commented on a change in pull request #9: [FLINK-15396][json] Support to ignore parse errors for JSON format URL: https://github.com/apache/flink/pull/9#discussion_r388735355 ## File path:

[GitHub] [flink] zenfenan commented on a change in pull request #11307: [FLINK-16371] [BulkWriter] Fix Hadoop Compression BulkWriter

2020-03-05 Thread GitBox
zenfenan commented on a change in pull request #11307: [FLINK-16371] [BulkWriter] Fix Hadoop Compression BulkWriter URL: https://github.com/apache/flink/pull/11307#discussion_r388733214 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11327: [FLINK-16450][hive] Integrate parquet columnar row reader to hive

2020-03-05 Thread GitBox
flinkbot edited a comment on issue #11327: [FLINK-16450][hive] Integrate parquet columnar row reader to hive URL: https://github.com/apache/flink/pull/11327#issuecomment-595580274 ## CI report: * c3b16385089b077cc856f24d9b0f33903a17a91c Travis:

[GitHub] [flink] flinkbot commented on issue #11328: [FLINK-16455][hive] Introduce flink-sql-connector-hive modules to provide hive uber jars

2020-03-05 Thread GitBox
flinkbot commented on issue #11328: [FLINK-16455][hive] Introduce flink-sql-connector-hive modules to provide hive uber jars URL: https://github.com/apache/flink/pull/11328#issuecomment-595621789 ## CI report: * d42e0ab290c177605a78eb5ceb9eacbc72e54a15 UNKNOWN Bot

[GitHub] [flink] flinkbot edited a comment on issue #11307: [FLINK-16371] [BulkWriter] Fix Hadoop Compression BulkWriter

2020-03-05 Thread GitBox
flinkbot edited a comment on issue #11307: [FLINK-16371] [BulkWriter] Fix Hadoop Compression BulkWriter URL: https://github.com/apache/flink/pull/11307#issuecomment-594492515 ## CI report: * 5d238893d1906a27fee0d8d9f8b5289b4e16595c Travis:

[GitHub] [flink] flinkbot commented on issue #11328: [FLINK-16455][hive] Introduce flink-sql-connector-hive modules to provide hive uber jars

2020-03-05 Thread GitBox
flinkbot commented on issue #11328: [FLINK-16455][hive] Introduce flink-sql-connector-hive modules to provide hive uber jars URL: https://github.com/apache/flink/pull/11328#issuecomment-595619627 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] zenfenan commented on a change in pull request #11307: [FLINK-16371] [BulkWriter] Fix Hadoop Compression BulkWriter

2020-03-05 Thread GitBox
zenfenan commented on a change in pull request #11307: [FLINK-16371] [BulkWriter] Fix Hadoop Compression BulkWriter URL: https://github.com/apache/flink/pull/11307#discussion_r388730578 ## File path:

[jira] [Commented] (FLINK-16447) Non serializable field on CompressWriterFactory

2020-03-05 Thread Sivaprasanna Sethuraman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053067#comment-17053067 ] Sivaprasanna Sethuraman commented on FLINK-16447: - Hi [~eskabetxe] I don't think it is

[GitHub] [flink] flinkbot edited a comment on issue #11307: [FLINK-16371] [BulkWriter] Fix Hadoop Compression BulkWriter

2020-03-05 Thread GitBox
flinkbot edited a comment on issue #11307: [FLINK-16371] [BulkWriter] Fix Hadoop Compression BulkWriter URL: https://github.com/apache/flink/pull/11307#issuecomment-594492515 ## CI report: * 5d238893d1906a27fee0d8d9f8b5289b4e16595c Travis:

[jira] [Updated] (FLINK-16455) Introduce flink-sql-connector-hive modules to provide hive uber jars

2020-03-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16455: --- Labels: pull-request-available (was: ) > Introduce flink-sql-connector-hive modules to

[GitHub] [flink] JingsongLi opened a new pull request #11328: [FLINK-16455][hive] Introduce flink-sql-connector-hive modules to provide hive uber jars

2020-03-05 Thread GitBox
JingsongLi opened a new pull request #11328: [FLINK-16455][hive] Introduce flink-sql-connector-hive modules to provide hive uber jars URL: https://github.com/apache/flink/pull/11328 ## What is the purpose of the change Provide uber jars to improve hive dependencies out-of-box

[GitHub] [flink] zenfenan commented on a change in pull request #11307: [FLINK-16371] [BulkWriter] Fix Hadoop Compression BulkWriter

2020-03-05 Thread GitBox
zenfenan commented on a change in pull request #11307: [FLINK-16371] [BulkWriter] Fix Hadoop Compression BulkWriter URL: https://github.com/apache/flink/pull/11307#discussion_r388727756 ## File path:

[jira] [Created] (FLINK-16455) Introduce flink-sql-connector-hive modules to provide hive uber jars

2020-03-05 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-16455: Summary: Introduce flink-sql-connector-hive modules to provide hive uber jars Key: FLINK-16455 URL: https://issues.apache.org/jira/browse/FLINK-16455 Project: Flink

[jira] [Comment Edited] (FLINK-16422) Cannot use [catalog].[db].table with Hive catalog

2020-03-05 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053058#comment-17053058 ] Danny Chen edited comment on FLINK-16422 at 3/6/20, 6:08 AM: - Thanks

[jira] [Commented] (FLINK-16422) Cannot use [catalog].[db].table with Hive catalog

2020-03-05 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053058#comment-17053058 ] Danny Chen commented on FLINK-16422: Thanks [~gyfora] for reporting this issue ~ If a use writes a

[jira] [Resolved] (FLINK-16130) Translate "Common Configurations" page of "File Systems" into Chinese

2020-03-05 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-16130. - Fix Version/s: 1.11.0 Resolution: Fixed Fixed in master (1.11.0):

[GitHub] [flink] wuchong closed pull request #11182: [FLINK-16130] [docs] Translate /ops/filesystems/common.zh.md into Chinese

2020-03-05 Thread GitBox
wuchong closed pull request #11182: [FLINK-16130] [docs] Translate /ops/filesystems/common.zh.md into Chinese URL: https://github.com/apache/flink/pull/11182 This is an automated message from the Apache Git Service. To

[jira] [Resolved] (FLINK-16129) Translate "Overview" page of "File Systems" into Chinese

2020-03-05 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-16129. - Fix Version/s: 1.11.0 Resolution: Fixed Fixed in master(1.11.0):

[GitHub] [flink] xintongsong commented on issue #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

2020-03-05 Thread GitBox
xintongsong commented on issue #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#issuecomment-595612104 Thanks for the review, @KarmaGYZ. Please see my explanations in the

[GitHub] [flink] wuchong merged pull request #11167: [FLINK-16129] [docs] Translate /ops/filesystems/index.zh.md

2020-03-05 Thread GitBox
wuchong merged pull request #11167: [FLINK-16129] [docs] Translate /ops/filesystems/index.zh.md URL: https://github.com/apache/flink/pull/11167 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] xintongsong commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

2020-03-05 Thread GitBox
xintongsong commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#discussion_r388723786 ## File path:

[GitHub] [flink] xintongsong commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

2020-03-05 Thread GitBox
xintongsong commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#discussion_r388723699 ## File path:

[GitHub] [flink] xintongsong commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

2020-03-05 Thread GitBox
xintongsong commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#discussion_r388723609 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager

2020-03-05 Thread GitBox
flinkbot edited a comment on issue #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager URL: https://github.com/apache/flink/pull/11323#issuecomment-595267888 ## CI report: *

[GitHub] [flink] xintongsong commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

2020-03-05 Thread GitBox
xintongsong commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#discussion_r388721739 ## File path:

[GitHub] [flink] xintongsong commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

2020-03-05 Thread GitBox
xintongsong commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#discussion_r388721585 ## File path:

[GitHub] [flink] xintongsong commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

2020-03-05 Thread GitBox
xintongsong commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#discussion_r388721558 ## File path:

[jira] [Updated] (FLINK-16454) Update the copyright year in NOTICE files

2020-03-05 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-16454: - Fix Version/s: 1.11.0 > Update the copyright year in NOTICE files >

[jira] [Created] (FLINK-16454) Update the copyright year in NOTICE files

2020-03-05 Thread Zhijiang (Jira)
Zhijiang created FLINK-16454: Summary: Update the copyright year in NOTICE files Key: FLINK-16454 URL: https://issues.apache.org/jira/browse/FLINK-16454 Project: Flink Issue Type: Task

[GitHub] [flink] flinkbot edited a comment on issue #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager

2020-03-05 Thread GitBox
flinkbot edited a comment on issue #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager URL: https://github.com/apache/flink/pull/11323#issuecomment-595267888 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager

2020-03-05 Thread GitBox
flinkbot edited a comment on issue #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager URL: https://github.com/apache/flink/pull/11323#issuecomment-595267888 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager

2020-03-05 Thread GitBox
flinkbot edited a comment on issue #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager URL: https://github.com/apache/flink/pull/11323#issuecomment-595267888 ## CI report: *

[GitHub] [flink] xintongsong commented on issue #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager

2020-03-05 Thread GitBox
xintongsong commented on issue #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager URL: https://github.com/apache/flink/pull/11323#issuecomment-595599221 Updated PR extracting common logics into

[jira] [Created] (FLINK-16453) A test failure in KafkaTest

2020-03-05 Thread cpugputpu (Jira)
cpugputpu created FLINK-16453: - Summary: A test failure in KafkaTest Key: FLINK-16453 URL: https://issues.apache.org/jira/browse/FLINK-16453 Project: Flink Issue Type: Bug Components:

[GitHub] [flink] flinkbot edited a comment on issue #11327: [FLINK-16450][hive] Integrate parquet columnar row reader to hive

2020-03-05 Thread GitBox
flinkbot edited a comment on issue #11327: [FLINK-16450][hive] Integrate parquet columnar row reader to hive URL: https://github.com/apache/flink/pull/11327#issuecomment-595580274 ## CI report: * c3b16385089b077cc856f24d9b0f33903a17a91c Travis:

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

2020-03-05 Thread GitBox
KarmaGYZ commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#discussion_r388696487 ## File path:

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

2020-03-05 Thread GitBox
KarmaGYZ commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#discussion_r388697084 ## File path:

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

2020-03-05 Thread GitBox
KarmaGYZ commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#discussion_r388690566 ## File path:

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

2020-03-05 Thread GitBox
KarmaGYZ commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#discussion_r388693078 ## File path:

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

2020-03-05 Thread GitBox
KarmaGYZ commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#discussion_r388691635 ## File path:

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

2020-03-05 Thread GitBox
KarmaGYZ commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#discussion_r388697567 ## File path:

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

2020-03-05 Thread GitBox
KarmaGYZ commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#discussion_r388691152 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11327: [FLINK-16450][hive] Integrate parquet columnar row reader to hive

2020-03-05 Thread GitBox
flinkbot edited a comment on issue #11327: [FLINK-16450][hive] Integrate parquet columnar row reader to hive URL: https://github.com/apache/flink/pull/11327#issuecomment-595580274 ## CI report: * c3b16385089b077cc856f24d9b0f33903a17a91c Travis:

[jira] [Closed] (FLINK-10908) Add yarn.application.priority in YarnConfigOptions

2020-03-05 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-10908. - Resolution: Duplicate > Add yarn.application.priority in YarnConfigOptions >

[jira] [Commented] (FLINK-16452) Insert into static partition doesn't support order by or limit

2020-03-05 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17052723#comment-17052723 ] Jingsong Lee commented on FLINK-16452: -- Thanks for reporting. Also not support values They are

[jira] [Commented] (FLINK-16005) Propagate yarn.application.classpath from client to TaskManager Classpath

2020-03-05 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17052722#comment-17052722 ] Yang Wang commented on FLINK-16005: --- It seems that this ticket will cover the situation in 

[GitHub] [flink] flinkbot commented on issue #11327: [FLINK-16450][hive] Integrate parquet columnar row reader to hive

2020-03-05 Thread GitBox
flinkbot commented on issue #11327: [FLINK-16450][hive] Integrate parquet columnar row reader to hive URL: https://github.com/apache/flink/pull/11327#issuecomment-595580274 ## CI report: * c3b16385089b077cc856f24d9b0f33903a17a91c UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on issue #11250: [FLINK-16302][rest]add log list and read log by name for taskmanager

2020-03-05 Thread GitBox
flinkbot edited a comment on issue #11250: [FLINK-16302][rest]add log list and read log by name for taskmanager URL: https://github.com/apache/flink/pull/11250#issuecomment-592336212 ## CI report: * e474761e49927bb30bac6a297e992dc2ec98e01a UNKNOWN *

[jira] [Updated] (FLINK-16452) Insert into static partition doesn't support order by or limit

2020-03-05 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-16452: --- Affects Version/s: 1.10.0 > Insert into static partition doesn't support order by or limit >

[jira] [Updated] (FLINK-16452) Insert into static partition doesn't support order by or limit

2020-03-05 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-16452: --- Description: The following example would fail: {code} create table src (x int, y string); create table dest

[GitHub] [flink] flinkbot commented on issue #11327: [FLINK-16450][hive] Integrate parquet columnar row reader to hive

2020-03-05 Thread GitBox
flinkbot commented on issue #11327: [FLINK-16450][hive] Integrate parquet columnar row reader to hive URL: https://github.com/apache/flink/pull/11327#issuecomment-595575696 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[jira] [Created] (FLINK-16452) Insert into static partition doesn't support order by or limit

2020-03-05 Thread Rui Li (Jira)
Rui Li created FLINK-16452: -- Summary: Insert into static partition doesn't support order by or limit Key: FLINK-16452 URL: https://issues.apache.org/jira/browse/FLINK-16452 Project: Flink Issue

[GitHub] [flink] JingsongLi opened a new pull request #11327: [FLINK-16450][hive] Integrate parquet columnar row reader to hive

2020-03-05 Thread GitBox
JingsongLi opened a new pull request #11327: [FLINK-16450][hive] Integrate parquet columnar row reader to hive URL: https://github.com/apache/flink/pull/11327 ## What is the purpose of the change #10922 has introduce `ParquetColumnarRowSplitReader`, we should enable it in hive.

[jira] [Updated] (FLINK-16450) Integrate parquet columnar row reader to hive

2020-03-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16450: --- Labels: pull-request-available (was: ) > Integrate parquet columnar row reader to hive >

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

2020-03-05 Thread jinfeng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jinfeng updated FLINK-16451: Description: When I use lisgagg with distinct and over window. {code:java} //代码占位符 "select

[GitHub] [flink] flinkbot edited a comment on issue #11291: [FLINK-16392] [API / DataStream] oneside sorted cache in intervaljoin

2020-03-05 Thread GitBox
flinkbot edited a comment on issue #11291: [FLINK-16392] [API / DataStream] oneside sorted cache in intervaljoin URL: https://github.com/apache/flink/pull/11291#issuecomment-593677297 ## CI report: * d6b2919dd28c55230e530ccc45ca7d93d90a60df UNKNOWN *

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

2020-03-05 Thread jinfeng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jinfeng updated FLINK-16451: Summary: listagg with distinct for over window codegen error (was: listagg with distinct for over

[jira] [Created] (FLINK-16451) listagg with distinct for over window

2020-03-05 Thread jinfeng (Jira)
jinfeng created FLINK-16451: --- Summary: listagg with distinct for over window Key: FLINK-16451 URL: https://issues.apache.org/jira/browse/FLINK-16451 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-16376) Using consistent method to get Yarn application directory

2020-03-05 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17052688#comment-17052688 ] Victor Wong commented on FLINK-16376: - Hi, [~trohrmann], the PR is attached. > Using consistent

[jira] [Commented] (FLINK-16448) add documentation for Hive table source and sink parallelism setting strategy

2020-03-05 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17052680#comment-17052680 ] Jingsong Lee commented on FLINK-16448: -- Source not exist too... > add documentation for Hive table

[GitHub] [flink] flinkbot edited a comment on issue #11291: [FLINK-16392] [API / DataStream] oneside sorted cache in intervaljoin

2020-03-05 Thread GitBox
flinkbot edited a comment on issue #11291: [FLINK-16392] [API / DataStream] oneside sorted cache in intervaljoin URL: https://github.com/apache/flink/pull/11291#issuecomment-593677297 ## CI report: * d6b2919dd28c55230e530ccc45ca7d93d90a60df UNKNOWN *

  1   2   3   4   5   >