[GitHub] [flink] zhuzhurk commented on a change in pull request #12256: [FLINK-17018][runtime] Allocates slots in bulks for pipelined region scheduling

2020-05-27 Thread GitBox
zhuzhurk commented on a change in pull request #12256: URL: https://github.com/apache/flink/pull/12256#discussion_r431025011 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/OneSlotPerExecutionSlotAllocator.java ## @@ -0,0 +1,260 @@ +/* + *

[GitHub] [flink-statefun] igalshilman commented on pull request #117: [FLINK-17690] Python function wrapper omits docstr

2020-05-27 Thread GitBox
igalshilman commented on pull request #117: URL: https://github.com/apache/flink-statefun/pull/117#issuecomment-634579978 I don’t understand this change, can you please revisit the problem description specified in the JIRA issue?

[GitHub] [flink] jiasheng55 opened a new pull request #12359: [FLINK-15448][yarn] Add host and port info to yarn ResourceID

2020-05-27 Thread GitBox
jiasheng55 opened a new pull request #12359: URL: https://github.com/apache/flink/pull/12359 ## What is the purpose of the change According to [FLIP-118](https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=148643521=contextnavpagetreemode), add host and port info to

[jira] [Commented] (FLINK-17600) Blink Planner fails to generate RowtimeAttribute based on TableSource's DefinedRowtimeAttributes implementation

2020-05-27 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117717#comment-17117717 ] Kurt Young commented on FLINK-17600: [~jark] could you check whether this issue still exist? If not,

[jira] [Commented] (FLINK-17617) Flink SQL CLI Autocomplete does not return correct hints

2020-05-27 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117716#comment-17117716 ] Kurt Young commented on FLINK-17617: I noticed the PR has been merged, should we also close this

[GitHub] [flink] lgo commented on pull request #12345: [FLINK-17288] [Runtime/StateBackends] Add RocksDB SST ingestion for batch writes

2020-05-27 Thread GitBox
lgo commented on pull request #12345: URL: https://github.com/apache/flink/pull/12345#issuecomment-634628869 @Myasuka actually this is doing exactly what the bulk loading ticket is describing. The `RocksDBSSTIngestWriter` is a drop-in repacement for `RocksDBWriteBatchWrapper` where only

[GitHub] [flink] yangyichao-mango commented on a change in pull request #12313: [FLINK-17005][docs] Translate the CREATE TABLE ... LIKE syntax documentation to Chinese

2020-05-27 Thread GitBox
yangyichao-mango commented on a change in pull request #12313: URL: https://github.com/apache/flink/pull/12313#discussion_r431081332 ## File path: docs/dev/table/sql/create.zh.md ## @@ -208,14 +215,14 @@ CREATE TABLE Orders ( **注意:** 使用 `CREATE TABLE` 语句注册的表均可用作 table

[GitHub] [flink] yangyichao-mango commented on a change in pull request #12313: [FLINK-17005][docs] Translate the CREATE TABLE ... LIKE syntax documentation to Chinese

2020-05-27 Thread GitBox
yangyichao-mango commented on a change in pull request #12313: URL: https://github.com/apache/flink/pull/12313#discussion_r431091182 ## File path: docs/dev/table/sql/create.zh.md ## @@ -208,14 +215,14 @@ CREATE TABLE Orders ( **注意:** 使用 `CREATE TABLE` 语句注册的表均可用作 table

[GitHub] [flink] tillrohrmann commented on a change in pull request #12264: [FLINK-17558][netty] Release partitions asynchronously

2020-05-27 Thread GitBox
tillrohrmann commented on a change in pull request #12264: URL: https://github.com/apache/flink/pull/12264#discussion_r431091900 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java ## @@ -366,11 +367,15 @@ public static

[GitHub] [flink] tillrohrmann commented on a change in pull request #12264: [FLINK-17558][netty] Release partitions asynchronously

2020-05-27 Thread GitBox
tillrohrmann commented on a change in pull request #12264: URL: https://github.com/apache/flink/pull/12264#discussion_r431090914 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java ## @@ -366,11 +367,15 @@ public static

[jira] [Updated] (FLINK-16384) Support SHOW CREATE TABLE command in SQL Client

2020-05-27 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-16384: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Support SHOW CREATE TABLE command in

[jira] [Updated] (FLINK-16528) Support Limit push down for streaming sources

2020-05-27 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-16528: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Support Limit push down for streaming

[GitHub] [flink] yangyichao-mango commented on a change in pull request #12313: [FLINK-17005][docs] Translate the CREATE TABLE ... LIKE syntax documentation to Chinese

2020-05-27 Thread GitBox
yangyichao-mango commented on a change in pull request #12313: URL: https://github.com/apache/flink/pull/12313#discussion_r431096627 ## File path: docs/dev/table/sql/create.zh.md ## @@ -249,59 +257,60 @@ CREATE TABLE Orders_with_watermark ( ); {% endhighlight %} -The

[GitHub] [flink] yangyichao-mango commented on a change in pull request #12313: [FLINK-17005][docs] Translate the CREATE TABLE ... LIKE syntax documentation to Chinese

2020-05-27 Thread GitBox
yangyichao-mango commented on a change in pull request #12313: URL: https://github.com/apache/flink/pull/12313#discussion_r431088645 ## File path: docs/dev/table/sql/create.zh.md ## @@ -208,14 +215,14 @@ CREATE TABLE Orders ( **注意:** 使用 `CREATE TABLE` 语句注册的表均可用作 table

[jira] [Created] (FLINK-17973) Test memory configuration of Flink cluster

2020-05-27 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-17973: - Summary: Test memory configuration of Flink cluster Key: FLINK-17973 URL: https://issues.apache.org/jira/browse/FLINK-17973 Project: Flink Issue Type:

[jira] [Comment Edited] (FLINK-16614) FLIP-116 Unified Memory Configuration for Job Manager

2020-05-27 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117630#comment-17117630 ] Andrey Zagrebin edited comment on FLINK-16614 at 5/27/20, 1:27 PM: ---

[jira] [Updated] (FLINK-17327) Kafka unavailability could cause Flink TM shutdown

2020-05-27 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17327: --- Fix Version/s: (was: 1.10.2) (was: 1.11.0)

[jira] [Comment Edited] (FLINK-16614) FLIP-116 Unified Memory Configuration for Job Manager

2020-05-27 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117630#comment-17117630 ] Andrey Zagrebin edited comment on FLINK-16614 at 5/27/20, 1:27 PM: ---

[GitHub] [flink] rmetzger closed pull request #11728: [hotfix][typo] Fix a comment error in StreamExecLocalGroupAggregate

2020-05-27 Thread GitBox
rmetzger closed pull request #11728: URL: https://github.com/apache/flink/pull/11728 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[jira] [Updated] (FLINK-10954) Hardlink from files of previous local stored state might cross devices

2020-05-27 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-10954: - Fix Version/s: (was: 1.7.3) 1.11.0 > Hardlink from files of previous local

[GitHub] [flink] zentol commented on a change in pull request #12344: [FLINK-16694][ci] Limit number of dumped log lines

2020-05-27 Thread GitBox
zentol commented on a change in pull request #12344: URL: https://github.com/apache/flink/pull/12344#discussion_r431146976 ## File path: flink-end-to-end-tests/test-scripts/common.sh ## @@ -366,7 +366,7 @@ function check_logs_for_errors { | grep -ic "error" || true)

[jira] [Commented] (FLINK-17857) All Kubernetes e2e tests could not run on Mac after migration

2020-05-27 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117805#comment-17117805 ] Chesnay Schepler commented on FLINK-17857: -- > So i suggest to support local Flink dist when

[jira] [Updated] (FLINK-17813) Manually test unaligned checkpoints on a cluster

2020-05-27 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17813: --- Priority: Blocker (was: Critical) > Manually test unaligned checkpoints on a cluster >

[jira] [Updated] (FLINK-17972) Consider restructuring channel state

2020-05-27 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17972: --- Description: (depends on rescaling for unaligned checkpoints)   Current structure is the

[GitHub] [flink] flinkbot commented on pull request #12361: [FLINK-13632] Port serializer upgrade tests to TypeSerializerUpgradeTestBase

2020-05-27 Thread GitBox
flinkbot commented on pull request #12361: URL: https://github.com/apache/flink/pull/12361#issuecomment-634708030 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot edited a comment on pull request #12356: [FLINK-17916][API] Provide API to separate KafkaShuffle's Producer and Consumer to different environments

2020-05-27 Thread GitBox
flinkbot edited a comment on pull request #12356: URL: https://github.com/apache/flink/pull/12356#issuecomment-634557592 ## CI report: * 25e0f64e1351eaf4df49f4b8e7b218a160784952 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12358: [FLINK-17942][table-planner-blink] Fix WindowOperator not call StateM…

2020-05-27 Thread GitBox
flinkbot edited a comment on pull request #12358: URL: https://github.com/apache/flink/pull/12358#issuecomment-634585770 ## CI report: * 180d394ec20680583be5f735d383fe66c99d6009 Azure:

[jira] [Updated] (FLINK-16101) Translate "Hive Functions" page of "Hive Integration" into Chinese

2020-05-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16101: --- Labels: pull-request-available (was: ) > Translate "Hive Functions" page of "Hive

[GitHub] [flink] klion26 commented on a change in pull request #11664: [FLINK-16101][docs-zh] Translate "Hive Functions" page of "Hive Integration" into Chinese

2020-05-27 Thread GitBox
klion26 commented on a change in pull request #11664: URL: https://github.com/apache/flink/pull/11664#discussion_r431198978 ## File path: docs/dev/stream/state/state.zh.md ## @@ -91,7 +91,7 @@ managed keyed state 接口提供不同类型状态的访问接口,这些状态 所有类型的状态还有一个`clear()` 方法,清除当前 key

[jira] [Created] (FLINK-17963) Revert execution environment patching in StatefulFunctionsJob (FLINK-16926)

2020-05-27 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-17963: --- Summary: Revert execution environment patching in StatefulFunctionsJob (FLINK-16926) Key: FLINK-17963 URL: https://issues.apache.org/jira/browse/FLINK-17963

[GitHub] [flink] flinkbot commented on pull request #12359: [FLINK-15448][yarn] Add host and port info to yarn ResourceID

2020-05-27 Thread GitBox
flinkbot commented on pull request #12359: URL: https://github.com/apache/flink/pull/12359#issuecomment-634585827 ## CI report: * cc0b7f0225973837b4d851fd80ac87a17606f2bc UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #12358: [FLINK-17942][table-planner-blink] Fix WindowOperator not call StateM…

2020-05-27 Thread GitBox
flinkbot commented on pull request #12358: URL: https://github.com/apache/flink/pull/12358#issuecomment-634585770 ## CI report: * 180d394ec20680583be5f735d383fe66c99d6009 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #12357: [FLINK-17958][core] Fix MathUtils#divideRoundUp bug for handling zero or negative values.

2020-05-27 Thread GitBox
flinkbot edited a comment on pull request #12357: URL: https://github.com/apache/flink/pull/12357#issuecomment-634577690 ## CI report: * 89fc7314d7bf14ac3bc667422be3d2d6b6a7b8fe Azure:

[jira] [Commented] (FLINK-17825) HA end-to-end gets killed due to timeout

2020-05-27 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117665#comment-17117665 ] Robert Metzger commented on FLINK-17825: The timeout increase is part of this PR:

[GitHub] [flink] JingsongLi merged pull request #12323: [FLINK-17925][fs-connector] Fix Filesystem options to default values and types

2020-05-27 Thread GitBox
JingsongLi merged pull request #12323: URL: https://github.com/apache/flink/pull/12323 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[GitHub] [flink] flinkbot edited a comment on pull request #11752: [FLINK-14713][rest]Show All Attempts For Vertex SubTask In Rest Api

2020-05-27 Thread GitBox
flinkbot edited a comment on pull request #11752: URL: https://github.com/apache/flink/pull/11752#issuecomment-613965719 ## CI report: * ed1e68d9afea99af66fe8d3b9ad4aa181cab4907 UNKNOWN * b38b0a4ebb41da904231c886d6c52e79cec36b0e UNKNOWN *

[jira] [Commented] (FLINK-17736) Add flink CEP examples

2020-05-27 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117693#comment-17117693 ] Robert Metzger commented on FLINK-17736: Thanks a lot for opening this ticket. I'm not sure if

[GitHub] [flink] StephanEwen commented on a change in pull request #12306: [FLINK-17899][runtime] Integrate FLIP-126 Watermarks with FLIP-27 Sources

2020-05-27 Thread GitBox
StephanEwen commented on a change in pull request #12306: URL: https://github.com/apache/flink/pull/12306#discussion_r431057279 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/source/EventTimeConfig.java ## @@ -0,0 +1,77 @@ +/* + *

[GitHub] [flink] rmetzger commented on pull request #12174: [FLINK-17736] Add flink cep example

2020-05-27 Thread GitBox
rmetzger commented on pull request #12174: URL: https://github.com/apache/flink/pull/12174#issuecomment-634608207 I agree with @klion26! I commented in the JIRA ticket. This is an automated message from the Apache Git

[GitHub] [flink] pnowojski commented on a change in pull request #12292: [FLINK-17861][task][checkpointing] Split channel state handles sent to JM

2020-05-27 Thread GitBox
pnowojski commented on a change in pull request #12292: URL: https://github.com/apache/flink/pull/12292#discussion_r431057780 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateCheckpointWriter.java ## @@ -180,17 +177,33 @@

[jira] [Commented] (FLINK-17967) Could not find document *** in docs

2020-05-27 Thread Aven Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117707#comment-17117707 ] Aven Wu commented on FLINK-17967: - Rename {color:#FF}concepts/stateful-stream-processing.md

[GitHub] [flink] flinkbot commented on pull request #12360: [FLINK-17970] Increase default value of cluster.io-pool.size from #cores to 4 * #cores

2020-05-27 Thread GitBox
flinkbot commented on pull request #12360: URL: https://github.com/apache/flink/pull/12360#issuecomment-634640865 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Updated] (FLINK-16889) Support converting BIGINT to TIMESTAMP for TO_TIMESTAMP function

2020-05-27 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-16889: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Support converting BIGINT to TIMESTAMP

[jira] [Closed] (FLINK-17617) Flink SQL CLI Autocomplete does not return correct hints

2020-05-27 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-17617. -- Resolution: Fixed Merged: a17da14fc00a1b13e6e8106863a3e049fbc217f5 > Flink SQL CLI Autocomplete does

[jira] [Updated] (FLINK-13015) Create validators, strategies and transformations required for porting logical expressions

2020-05-27 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-13015: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Create validators, strategies and

[jira] [Updated] (FLINK-17972) Consider restructuring channel state

2020-05-27 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-17972: -- Description: (depends on rescaling for unaligned checkpoints)   Current structure

[GitHub] [flink] rkhachatryan commented on a change in pull request #12292: [FLINK-17861][task][checkpointing] Split channel state handles sent to JM

2020-05-27 Thread GitBox
rkhachatryan commented on a change in pull request #12292: URL: https://github.com/apache/flink/pull/12292#discussion_r431115232 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateCheckpointWriter.java ## @@ -180,17 +177,33 @@

[GitHub] [flink] rmetzger commented on pull request #11896: [FLINK-14356] [single-value] Introduce "single-value" format to (de)serialize message to a single field

2020-05-27 Thread GitBox
rmetzger commented on pull request #11896: URL: https://github.com/apache/flink/pull/11896#issuecomment-634650222 Thanks a lot for your contribution to Apache Flink! I pinged the maintainers of the associated JIRA ticket to check out this change!

[jira] [Created] (FLINK-17976) Test native K8s integration

2020-05-27 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-17976: - Summary: Test native K8s integration Key: FLINK-17976 URL: https://issues.apache.org/jira/browse/FLINK-17976 Project: Flink Issue Type: Task

[jira] [Commented] (FLINK-17260) StreamingKafkaITCase failure on Azure

2020-05-27 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117774#comment-17117774 ] Robert Metzger commented on FLINK-17260:

[GitHub] [flink] rmetzger commented on pull request #11041: [hotfix] Fix broken link and wrong node version command in runtime-we…

2020-05-27 Thread GitBox
rmetzger commented on pull request #11041: URL: https://github.com/apache/flink/pull/11041#issuecomment-634696927 @zentol the issues we've discussed seem orthogonal to this change. Are you ok merging this change to fix the broken URL and command in the readme?

[jira] [Updated] (FLINK-17160) FLIP-111: Docker image unification

2020-05-27 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-17160: Release Note: Flink community encourages users to use or extend the official Docker Hub

[jira] [Updated] (FLINK-17160) FLIP-111: Docker image unification

2020-05-27 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-17160: Release Note: Flink community encourages users to use or extend the official Docker Hub

[jira] [Created] (FLINK-17979) Support rescaling for Unaligned Checkpoints

2020-05-27 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-17979: - Summary: Support rescaling for Unaligned Checkpoints Key: FLINK-17979 URL: https://issues.apache.org/jira/browse/FLINK-17979 Project: Flink Issue

[jira] [Comment Edited] (FLINK-16614) FLIP-116 Unified Memory Configuration for Job Manager

2020-05-27 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117630#comment-17117630 ] Andrey Zagrebin edited comment on FLINK-16614 at 5/27/20, 10:39 AM:

[jira] [Commented] (FLINK-16614) FLIP-116 Unified Memory Configuration for Job Manager

2020-05-27 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117630#comment-17117630 ] Andrey Zagrebin commented on FLINK-16614: - h1. New Flink Master Memory Model h2. Overview With

[jira] [Comment Edited] (FLINK-16614) FLIP-116 Unified Memory Configuration for Job Manager

2020-05-27 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117630#comment-17117630 ] Andrey Zagrebin edited comment on FLINK-16614 at 5/27/20, 10:39 AM:

[GitHub] [flink] flinkbot edited a comment on pull request #12251: [FLINK-17812][dist] Bundle reporters in plugins/ directory

2020-05-27 Thread GitBox
flinkbot edited a comment on pull request #12251: URL: https://github.com/apache/flink/pull/12251#issuecomment-630873924 ## CI report: * bacba6355dcb9a32e999acd296ae8f4e0dab Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12356: [FLINK-17916][API] Provide API to separate KafkaShuffle's Producer and Consumer to different environments

2020-05-27 Thread GitBox
flinkbot edited a comment on pull request #12356: URL: https://github.com/apache/flink/pull/12356#issuecomment-634557592 ## CI report: * 64323e147ad8012ef98cf72d971948dcfe5efce4 Azure:

[GitHub] [flink] flinkbot commented on pull request #12357: [FLINK-17958][core] Fix MathUtils#divideRoundUp bug for handling zero or negative values.

2020-05-27 Thread GitBox
flinkbot commented on pull request #12357: URL: https://github.com/apache/flink/pull/12357#issuecomment-634577690 ## CI report: * 89fc7314d7bf14ac3bc667422be3d2d6b6a7b8fe UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] twalthr commented on pull request #12320: [FLINK-17887][table][connector] Improve interface of ScanFormatFactory and SinkFormatFactory

2020-05-27 Thread GitBox
twalthr commented on pull request #12320: URL: https://github.com/apache/flink/pull/12320#issuecomment-634585462 +1 for `Encoding` / `DecodingFormat` This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] EchoLee5 commented on a change in pull request #12339: [FLINK-17744] StreamContextEnvironment#execute cannot be call JobListener#onJobExecuted

2020-05-27 Thread GitBox
EchoLee5 commented on a change in pull request #12339: URL: https://github.com/apache/flink/pull/12339#discussion_r431036315 ## File path: flink-clients/src/main/java/org/apache/flink/client/program/StreamContextEnvironment.java ## @@ -71,31 +74,44 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #12264: [FLINK-17558][netty] Release partitions asynchronously

2020-05-27 Thread GitBox
flinkbot edited a comment on pull request #12264: URL: https://github.com/apache/flink/pull/12264#issuecomment-631349883 ## CI report: * 19c5f57b94cc56b70002031618c32d9e6f68effb UNKNOWN * bb313e40f5a72dbf20cd0a8b48267063fd4f00af UNKNOWN *

[jira] [Created] (FLINK-17965) Hive dialect doesn't properly handle special character escaping with SQL CLI

2020-05-27 Thread Rui Li (Jira)
Rui Li created FLINK-17965: -- Summary: Hive dialect doesn't properly handle special character escaping with SQL CLI Key: FLINK-17965 URL: https://issues.apache.org/jira/browse/FLINK-17965 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #12251: [FLINK-17812][dist] Bundle reporters in plugins/ directory

2020-05-27 Thread GitBox
flinkbot edited a comment on pull request #12251: URL: https://github.com/apache/flink/pull/12251#issuecomment-630873924 ## CI report: * bacba6355dcb9a32e999acd296ae8f4e0dab Azure:

[jira] [Created] (FLINK-17967) Could not find document *** in docs

2020-05-27 Thread Aven Wu (Jira)
Aven Wu created FLINK-17967: --- Summary: Could not find document *** in docs Key: FLINK-17967 URL: https://issues.apache.org/jira/browse/FLINK-17967 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-17966) Documentation improvement of checkpointing API

2020-05-27 Thread Vijaya Bhaskar V (Jira)
Vijaya Bhaskar V created FLINK-17966: Summary: Documentation improvement of checkpointing API Key: FLINK-17966 URL: https://issues.apache.org/jira/browse/FLINK-17966 Project: Flink Issue

[jira] [Updated] (FLINK-17973) Test memory configuration of Flink cluster

2020-05-27 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-17973: -- Labels: release-testing (was: ) > Test memory configuration of Flink cluster >

[GitHub] [flink] yangyichao-mango commented on a change in pull request #12313: [FLINK-17005][docs] Translate the CREATE TABLE ... LIKE syntax documentation to Chinese

2020-05-27 Thread GitBox
yangyichao-mango commented on a change in pull request #12313: URL: https://github.com/apache/flink/pull/12313#discussion_r431134547 ## File path: docs/dev/table/sql/create.zh.md ## @@ -249,59 +257,60 @@ CREATE TABLE Orders_with_watermark ( ); {% endhighlight %} -The

[jira] [Commented] (FLINK-17167) Extend entry point script and docs with history server mode

2020-05-27 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117785#comment-17117785 ] Andrey Zagrebin commented on FLINK-17167: - [~derjust] could you move the JIRA issue in progress?

[jira] [Updated] (FLINK-17167) Extend entry point script and docs with history server mode

2020-05-27 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-17167: Fix Version/s: (was: 1.11.0) 1.12.0 > Extend entry point script

[GitHub] [flink] rmetzger commented on pull request #10855: [FLINK-15587][container] Initial container for OpenShift.

2020-05-27 Thread GitBox
rmetzger commented on pull request #10855: URL: https://github.com/apache/flink/pull/10855#issuecomment-634698885 Thanks a lot for your contribution to the Apache Flink project! There seem to be some concerns in the JIRA ticket from this PR. I propose to close this PR until these

[GitHub] [flink] rmetzger closed pull request #10560: FLINK-15174 added certificate pinning for SSL mutual auth to further protect cluster

2020-05-27 Thread GitBox
rmetzger closed pull request #10560: URL: https://github.com/apache/flink/pull/10560 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[jira] [Updated] (FLINK-17928) Incorrect state size reported when using unaligned checkpoints

2020-05-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17928: --- Labels: pull-request-available (was: ) > Incorrect state size reported when using

[GitHub] [flink] rkhachatryan opened a new pull request #12362: [FLINK-17928][checkpointing] Fix ChannelStateHandle size

2020-05-27 Thread GitBox
rkhachatryan opened a new pull request #12362: URL: https://github.com/apache/flink/pull/12362 ## What is the purpose of the change With Unaligned Checkpoints enabled, channel state is written to the file system. If the underlying state handle is shared between multiple handles,

[jira] [Commented] (FLINK-17923) It will throw MemoryAllocationException if rocksdb statebackend and Python UDF are used in the same slot

2020-05-27 Thread sunjincheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117629#comment-17117629 ] sunjincheng commented on FLINK-17923: - Our consensus is that The final solution is both Python and

[GitHub] [flink] flinkbot commented on pull request #12358: [FLINK-17942][table-planner-blink] Fix WindowOperator not call StateM…

2020-05-27 Thread GitBox
flinkbot commented on pull request #12358: URL: https://github.com/apache/flink/pull/12358#issuecomment-634576414 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] wangyang0918 commented on a change in pull request #12357: [FLINK-17958][core] Fix MathUtils#divideRoundUp bug for handling zero or negative values.

2020-05-27 Thread GitBox
wangyang0918 commented on a change in pull request #12357: URL: https://github.com/apache/flink/pull/12357#discussion_r431025047 ## File path: flink-core/src/main/java/org/apache/flink/util/MathUtils.java ## @@ -209,12 +209,18 @@ public static long flipSignBit(long in) {

[GitHub] [flink] rmetzger commented on a change in pull request #12340: [FLINK-17844][build] Enforce @PublicEvolving compatibility for minor versions

2020-05-27 Thread GitBox
rmetzger commented on a change in pull request #12340: URL: https://github.com/apache/flink/pull/12340#discussion_r431045521 ## File path: tools/releasing/create_release_branch.sh ## @@ -59,6 +59,22 @@ git checkout -b $target_branch #change version in all pom files find .

[jira] [Updated] (FLINK-17965) Hive dialect doesn't properly handle special character escaping with SQL CLI

2020-05-27 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-17965: --- Description: The following DDL runs fine with table api but doesn't work with sql-client: {code:java}

[GitHub] [flink] dianfu merged pull request #12349: [FLINK-17722][python][build system] (followups) Keeps all jars of lib directory in CachedFiles

2020-05-27 Thread GitBox
dianfu merged pull request #12349: URL: https://github.com/apache/flink/pull/12349 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] tillrohrmann commented on a change in pull request #12344: [FLINK-16694][ci] Limit number of dumped log lines

2020-05-27 Thread GitBox
tillrohrmann commented on a change in pull request #12344: URL: https://github.com/apache/flink/pull/12344#discussion_r431071033 ## File path: flink-end-to-end-tests/test-scripts/common.sh ## @@ -366,7 +366,7 @@ function check_logs_for_errors { | grep -ic "error" ||

[GitHub] [flink] zentol commented on a change in pull request #12264: [FLINK-17558][netty] Release partitions asynchronously

2020-05-27 Thread GitBox
zentol commented on a change in pull request #12264: URL: https://github.com/apache/flink/pull/12264#discussion_r431071230 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java ## @@ -366,11 +367,15 @@ public static

[jira] [Created] (FLINK-17969) Enhance Flink (Task) logging to include job name as context diagnostic information

2020-05-27 Thread Bhagavan (Jira)
Bhagavan created FLINK-17969: Summary: Enhance Flink (Task) logging to include job name as context diagnostic information Key: FLINK-17969 URL: https://issues.apache.org/jira/browse/FLINK-17969 Project:

[jira] [Updated] (FLINK-16824) Creating Temporal Table Function via DDL

2020-05-27 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16824: --- Fix Version/s: (was: 1.11.0) > Creating Temporal Table Function via DDL >

[GitHub] [flink] flinkbot edited a comment on pull request #12264: [FLINK-17558][netty] Release partitions asynchronously

2020-05-27 Thread GitBox
flinkbot edited a comment on pull request #12264: URL: https://github.com/apache/flink/pull/12264#issuecomment-631349883 ## CI report: * 19c5f57b94cc56b70002031618c32d9e6f68effb UNKNOWN * bb313e40f5a72dbf20cd0a8b48267063fd4f00af UNKNOWN *

[jira] [Created] (FLINK-17970) Increase default value of IO pool executor to 4 * #cores

2020-05-27 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-17970: - Summary: Increase default value of IO pool executor to 4 * #cores Key: FLINK-17970 URL: https://issues.apache.org/jira/browse/FLINK-17970 Project: Flink

[GitHub] [flink] zentol commented on a change in pull request #12360: [FLINK-17970] Increase default value of cluster.io-pool.size from #cores to 4 * #cores

2020-05-27 Thread GitBox
zentol commented on a change in pull request #12360: URL: https://github.com/apache/flink/pull/12360#discussion_r431096427 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/util/ClusterEntrypointUtils.java ## @@ -70,7 +70,7 @@ private static File

[jira] [Updated] (FLINK-16332) Support un-ordered mode for async lookup join

2020-05-27 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-16332: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Support un-ordered mode for async

[GitHub] [flink] rmetzger merged pull request #12080: [hotfix][runtime][javadoc] Fix typo

2020-05-27 Thread GitBox
rmetzger merged pull request #12080: URL: https://github.com/apache/flink/pull/12080 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[jira] [Updated] (FLINK-17133) Support CsvParser Features for CSV format via SQL DDL

2020-05-27 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-17133: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Support CsvParser Features for CSV

[jira] [Created] (FLINK-17975) Test ZooKeeper 3.5 support

2020-05-27 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-17975: - Summary: Test ZooKeeper 3.5 support Key: FLINK-17975 URL: https://issues.apache.org/jira/browse/FLINK-17975 Project: Flink Issue Type: Task

[GitHub] [flink] zentol merged pull request #12251: [FLINK-17812][dist] Bundle reporters in plugins/ directory

2020-05-27 Thread GitBox
zentol merged pull request #12251: URL: https://github.com/apache/flink/pull/12251 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] rmetzger closed pull request #10929: Fixed Vertex Degree algorithm implementation

2020-05-27 Thread GitBox
rmetzger closed pull request #10929: URL: https://github.com/apache/flink/pull/10929 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[GitHub] [flink] rmetzger commented on pull request #10929: Fixed Vertex Degree algorithm implementation

2020-05-27 Thread GitBox
rmetzger commented on pull request #10929: URL: https://github.com/apache/flink/pull/10929#issuecomment-634697582 I'm closing this PR as it seems to be stale. Please re-open if you want to continue working on it. This is an

[GitHub] [flink] rmetzger commented on pull request #10510: [FLINK-15176][container] Add '--job-classname' to flink-container 'jo…

2020-05-27 Thread GitBox
rmetzger commented on pull request #10510: URL: https://github.com/apache/flink/pull/10510#issuecomment-634710310 Thank you for this PR! I propose to close this PR as it is outdated (flink-container/kubernetes does not exist anymore). Please re-open it if you disagree.

[GitHub] [flink] aljoscha opened a new pull request #12363: [FLINK-13632] Port serializer upgrade tests to TypeSerializerUpgradeTestBase

2020-05-27 Thread GitBox
aljoscha opened a new pull request #12363: URL: https://github.com/apache/flink/pull/12363 ## What is the purpose of the change We migrate all serializer upgrade tests from `TypeSerializerSnapshotMigrationTestBase` to `TypeSerializerUpgradeTestBase`. Additionally, we add snapshots

[jira] [Commented] (FLINK-17923) It will throw MemoryAllocationException if rocksdb statebackend and Python UDF are used in the same slot

2020-05-27 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117620#comment-17117620 ] Dian Fu commented on FLINK-17923: - Based on option #4, we can also have option #5 to add a switch to

[GitHub] [flink] zentol commented on a change in pull request #12340: [FLINK-17844][build] Enforce @PublicEvolving compatibility for minor versions

2020-05-27 Thread GitBox
zentol commented on a change in pull request #12340: URL: https://github.com/apache/flink/pull/12340#discussion_r431015632 ## File path: tools/releasing/create_release_branch.sh ## @@ -59,6 +59,22 @@ git checkout -b $target_branch #change version in all pom files find .

[GitHub] [flink] flinkbot edited a comment on pull request #12355: [FLINK-17893] [sql-client] SQL CLI should print the root cause if the statement is invalid

2020-05-27 Thread GitBox
flinkbot edited a comment on pull request #12355: URL: https://github.com/apache/flink/pull/12355#issuecomment-634548726 ## CI report: * 578b299f37b20eab2cd6ce64160cbbfc3ba10479 Azure:

  1   2   3   4   5   6   7   >