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

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 * 3d121cb731b45565917fa47ecf

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

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: [SUCCESS](https://travis-ci.com/flink

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

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

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

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: flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowD

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

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: flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDe

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

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: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/plan

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

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: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/plan

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

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] flinkbot edited a comment on issue #11307: [FLINK-16371] [BulkWriter] Fix Hadoop Compression BulkWriter

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: [PENDING](https://travis-ci.com/flink-c

[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

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: flink-runtime/src/test/java/org/apache/flink/runtime/io/netw

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-16337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17053097#comment-17053097 ] Hequn Cheng commented on FLINK-16337: - Resolved in 1.11.0 via 2a3daf3931acd0b6089c80

[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

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 a

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

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

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: flink-runtime/src/test/java/org/apache/flink/runtime/io/netw

[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

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: flink-runtime/src/test/java/org/apache/flink/runtime/io/netw

[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

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: flink-runtime/src/test/java/org/apache/flink/runtime/io/netw

[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

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: flink-runtime/src/test/java/org/apache/flink/runtime/io/netw

[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

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: flink-runtime/src/test/java/org/apache/flink/runtime/io/netw

[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

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: flink-runtime/src/main/java/org/apache/flink/runtime/io/netw

[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

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: flink-runtime/src/test/java/org/apache/flink/runtime/io/netw

[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

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: flink-runtime/src/test/java/org/apache/flink/runtime/io/netw

[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

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: flink-runtime/src/test/java/org/apache/flink/runtime/io/netw

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

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

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: flink-runtime/src/test/java/org/apache/flink/runtime/io/netw

[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

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: flink-runtime/src/test/java/org/apache/flink/runtime/io/netw

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

[ https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17053086#comment-17053086 ] Jun Qin commented on FLINK-16419: - That should be sufficient. > Avoid to recommit trans

[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

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: flink-runtime/src/test/java/org/apache/flink/runtime/io/netw

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

[ https://issues.apache.org/jira/browse/FLINK-16313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17053085#comment-17053085 ] Robert Metzger commented on FLINK-16313: [~sjwiesman] Thanks for looking into it

[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

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: flink-runtime/src/test/java/org/apache/flink/runtime/io/netw

[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

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: flink-runtime/src/test/java/org/apache/flink/runtime/io/netw

[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

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: flink-runtime/src/test/java/org/apache/flink/runtime/io/netw

[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

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: flink-runtime/src/test/java/org/apache/flink/runtime/io/netw

[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

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: flink-runtime/src/test/java/org/apache/flink/runtime/io/netw

[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

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: flink-runtime/src/test/java/org/apache/flink/runtime/io/netw

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

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

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: [PENDING](h

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

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: [SUCCESS](https://travis-ci.com/fl

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

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: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/plann

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

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: flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowD

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

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: flink-formats/flink-compress/src/main/java/org/apache/flink/formats/compress/Compr

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

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: [SUCCESS](https://travis-ci.com/fl

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

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 comm

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

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: [SUCCESS](https://travis-ci.com/flink-c

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

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

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: flink-formats/flink-compress/src/main/java/org/apache/flink/formats/compress/Compr

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

[ https://issues.apache.org/jira/browse/FLINK-16447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17053067#comment-17053067 ] Sivaprasanna Sethuraman commented on FLINK-16447: - Hi [~eskabetxe] I do

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

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: [SUCCESS](https://travis-ci.com/flink-c

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

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

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

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 exp

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

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: flink-formats/flink-compress/src/main/java/org/apache/flink/formats/compress/Compr

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

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

[ https://issues.apache.org/jira/browse/FLINK-16422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17053058#comment-17053058 ] Danny Chen edited comment on FLINK-16422 at 3/6/20, 6:08 AM: -

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

[ https://issues.apache.org/jira/browse/FLINK-16422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17053058#comment-17053058 ] Danny Chen commented on FLINK-16422: Thanks [~gyfora] for reporting this issue ~ If

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

[ 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): 5adbd70a30d72df1b315a36e79ccdf0

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

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 respo

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

[ 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): 1ec78b7feef1ca703ba5747a4b11e0b1

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

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 mess

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

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 repl

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

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: flink-runtime/src/main/java/org/a

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

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: flink-runtime/src/main/java/org/a

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

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: flink-runtime/src/main/java/org/a

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

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

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

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: flink-mesos/src/main/java/org/apa

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

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: flink-kubernetes/src/main/java/or

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

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: flink-yarn/src/main/java/org/apac

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

[ 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

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

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

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

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: * 2e0fb83e0784cd3b3315856e51e0fece5e

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

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: * 2e0fb83e0784cd3b3315856e51e0fece5e

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

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 `ActiveResourceManager`,

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

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

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

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: [SUCCESS](https://travis-ci.com/fl

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

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: flink-kubernetes/src/main/java/org/a

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

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: flink-runtime/src/main/java/org/apac

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

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: flink-runtime/src/main/java/org/apac

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

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: flink-yarn/src/main/java/org/apache/

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

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: flink-runtime/src/main/java/org/apac

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

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: flink-mesos/src/main/java/org/apache

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

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: flink-runtime/src/main/java/org/apac

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

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: [PENDING](https://travis-ci.com/fl

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-16452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17052723#comment-17052723 ] Jingsong Lee commented on FLINK-16452: -- Thanks for reporting. Also not support valu

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

[ https://issues.apache.org/jira/browse/FLINK-16005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17052722#comment-17052722 ] Yang Wang commented on FLINK-16005: --- It seems that this ticket will cover the situatio

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

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 @flinkbot

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

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 * 306b1e6622445245bdc59517d23

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

[ 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

[ 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

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

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 Typ

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

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

[ 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

[ 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 listagg(distinc

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

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 * 3d121cb731b45565917fa47ecf

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

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

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

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 Compon

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

[ https://issues.apache.org/jira/browse/FLINK-16376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17052688#comment-17052688 ] Victor Wong commented on FLINK-16376: - Hi, [~trohrmann], the PR is attached. > Usin

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

[ https://issues.apache.org/jira/browse/FLINK-16448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17052680#comment-17052680 ] Jingsong Lee commented on FLINK-16448: -- Source not exist too... > add documentatio

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

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 * 3d121cb731b45565917fa47ecf

  1   2   3   4   5   >