[GitHub] [flink] wangyang0918 commented on a change in pull request #10602: [FLINK-10938] Add e2e test for natively running flink session cluster on kubernetes

wangyang0918 commented on a change in pull request #10602: [FLINK-10938] Add e2e test for natively running flink session cluster on kubernetes URL: https://github.com/apache/flink/pull/10602#discussion_r360448617 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #10602: [FLINK-10938] Add e2e test for natively running flink session cluster on kubernetes

wangyang0918 commented on a change in pull request #10602: [FLINK-10938] Add e2e test for natively running flink session cluster on kubernetes URL: https://github.com/apache/flink/pull/10602#discussion_r360447908 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #10602: [FLINK-10938] Add e2e test for natively running flink session cluster on kubernetes

wangyang0918 commented on a change in pull request #10602: [FLINK-10938] Add e2e test for natively running flink session cluster on kubernetes URL: https://github.com/apache/flink/pull/10602#discussion_r360447289 ## File path:

[jira] [Resolved] (FLINK-15301) Flink Kinesis AsyncRecordEmitter needs to handle unchecked exception gracefully

[ https://issues.apache.org/jira/browse/FLINK-15301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved FLINK-15301. -- Fix Version/s: 1.11.0 Resolution: Fixed > Flink Kinesis AsyncRecordEmitter needs to

[GitHub] [flink] tweise merged pull request #10611: [FLINK-15301] [kinesis] Exception propagation from record emitter to source thread

tweise merged pull request #10611: [FLINK-15301] [kinesis] Exception propagation from record emitter to source thread URL: https://github.com/apache/flink/pull/10611 This is an automated message from the Apache Git Service.

[GitHub] [flink] flinkbot edited a comment on issue #10645: [FLINK-10938] trigger e2e test for 10644

flinkbot edited a comment on issue #10645: [FLINK-10938] trigger e2e test for 10644 URL: https://github.com/apache/flink/pull/10645#issuecomment-567843108 ## CI report: * 461f3a92f7ec15c82e2878a631d5673cc467e53b Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10642: [FLINK-10938] enable e2e test on travis

flinkbot edited a comment on issue #10642: [FLINK-10938] enable e2e test on travis URL: https://github.com/apache/flink/pull/10642#issuecomment-567843009 ## CI report: * c41710f70754f7955ddc0ff93653f43f9c18640f Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10591: [FLINK-15272][table-planner-blink] Better error message when insert partition with values

flinkbot edited a comment on issue #10591: [FLINK-15272][table-planner-blink] Better error message when insert partition with values URL: https://github.com/apache/flink/pull/10591#issuecomment-565986156 ## CI report: * efafb1293280291624d5a1122f1af1513cce3456 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10570: [FLINK-15248][FileSystems] Fix the bug in FileUtils#compressDirectory when processing relative directory path.

flinkbot edited a comment on issue #10570: [FLINK-15248][FileSystems] Fix the bug in FileUtils#compressDirectory when processing relative directory path. URL: https://github.com/apache/flink/pull/10570#issuecomment-565434555 ## CI report: *

[jira] [Closed] (FLINK-15308) Job failed when enable pipelined-shuffle.compression and numberOfTaskSlots > 1

[ https://issues.apache.org/jira/browse/FLINK-15308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao closed FLINK-15308. --- > Job failed when enable pipelined-shuffle.compression and numberOfTaskSlots > 1 >

[jira] [Resolved] (FLINK-15308) Job failed when enable pipelined-shuffle.compression and numberOfTaskSlots > 1

[ https://issues.apache.org/jira/browse/FLINK-15308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao resolved FLINK-15308. - Release Note: taskmanager.network.pipelined-shuffle.compression.enabled was removed. Data

[jira] [Commented] (FLINK-15308) Job failed when enable pipelined-shuffle.compression and numberOfTaskSlots > 1

[ https://issues.apache.org/jira/browse/FLINK-15308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000982#comment-17000982 ] Yingjie Cao commented on FLINK-15308: - Fix via 8525c378b91c16245d2e0456d423ed39f5c9b330 on master.

[jira] [Created] (FLINK-15347) ZooKeeperDefaultDispatcherRunnerTest.testResourceCleanupUnderLeadershipChange failed on Travis

Till Rohrmann created FLINK-15347: - Summary: ZooKeeperDefaultDispatcherRunnerTest.testResourceCleanupUnderLeadershipChange failed on Travis Key: FLINK-15347 URL: https://issues.apache.org/jira/browse/FLINK-15347

[GitHub] [flink] zhijiangW merged pull request #10627: [FLINK-15308][runtime] Remove data compression for pipelined shuffle.

zhijiangW merged pull request #10627: [FLINK-15308][runtime] Remove data compression for pipelined shuffle. URL: https://github.com/apache/flink/pull/10627 This is an automated message from the Apache Git Service. To

[GitHub] [flink] zhuzhurk commented on issue #10551: [FLINK-13662][kinesis] Relax timing requirements

zhuzhurk commented on issue #10551: [FLINK-13662][kinesis] Relax timing requirements URL: https://github.com/apache/flink/pull/10551#issuecomment-567969587 Thanks @zentol for replying to the comments. My questions are answered and the change looks good to me. I can help to rebase and

[GitHub] [flink] flinkbot edited a comment on issue #10652: [FLINK-15337][docs] Add vendor table to documentation

flinkbot edited a comment on issue #10652: [FLINK-15337][docs] Add vendor table to documentation URL: https://github.com/apache/flink/pull/10652#issuecomment-567958386 ## CI report: * 1fb38853b09b94803f33ab9098e75b4fa6b65a60 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10645: [FLINK-10938] trigger e2e test for 10644

flinkbot edited a comment on issue #10645: [FLINK-10938] trigger e2e test for 10644 URL: https://github.com/apache/flink/pull/10645#issuecomment-567843108 ## CI report: * 461f3a92f7ec15c82e2878a631d5673cc467e53b Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10619: [FLINK-15175]Fix CTES not supported in SQL CLI

flinkbot edited a comment on issue #10619: [FLINK-15175]Fix CTES not supported in SQL CLI URL: https://github.com/apache/flink/pull/10619#issuecomment-566919711 ## CI report: * 6a8566b5b33bb07c0277da8842b511f6b4722f10 Travis:

[GitHub] [flink] zhijiangW merged pull request #10638: [FLINK-15308][runtime] Remove data compression for pipelined shuffle.

zhijiangW merged pull request #10638: [FLINK-15308][runtime] Remove data compression for pipelined shuffle. URL: https://github.com/apache/flink/pull/10638 This is an automated message from the Apache Git Service. To

[GitHub] [flink] zhuzhurk commented on a change in pull request #10551: [FLINK-13662][kinesis] Relax timing requirements

zhuzhurk commented on a change in pull request #10551: [FLINK-13662][kinesis] Relax timing requirements URL: https://github.com/apache/flink/pull/10551#discussion_r360421356 ## File path:

[jira] [Closed] (FLINK-15311) Lz4BlockCompressionFactory should use native compressor instead of java unsafe

[ https://issues.apache.org/jira/browse/FLINK-15311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao closed FLINK-15311. --- > Lz4BlockCompressionFactory should use native compressor instead of java unsafe >

[jira] [Commented] (FLINK-15311) Lz4BlockCompressionFactory should use native compressor instead of java unsafe

[ https://issues.apache.org/jira/browse/FLINK-15311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000971#comment-17000971 ] Yingjie Cao commented on FLINK-15311: - Fix via 5a30c79b0db7c99784fbb40346b7682d0ac64740 on

[jira] [Resolved] (FLINK-15311) Lz4BlockCompressionFactory should use native compressor instead of java unsafe

[ https://issues.apache.org/jira/browse/FLINK-15311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao resolved FLINK-15311. - Resolution: Fixed > Lz4BlockCompressionFactory should use native compressor instead of java

[GitHub] [flink] zhuzhurk commented on a change in pull request #10551: [FLINK-13662][kinesis] Relax timing requirements

zhuzhurk commented on a change in pull request #10551: [FLINK-13662][kinesis] Relax timing requirements URL: https://github.com/apache/flink/pull/10551#discussion_r360421356 ## File path:

[GitHub] [flink] zhijiangW merged pull request #10639: [FLINK-15311][runtime] Remove shade of org.lz4:lz4-java to make lz4 block compression use native implementation by default.

zhijiangW merged pull request #10639: [FLINK-15311][runtime] Remove shade of org.lz4:lz4-java to make lz4 block compression use native implementation by default. URL: https://github.com/apache/flink/pull/10639 This is an

[GitHub] [flink] zhijiangW removed a comment on issue #10639: [FLINK-15311][runtime] Remove shade of org.lz4:lz4-java to make lz4 block compression use native implementation by default.

zhijiangW removed a comment on issue #10639: [FLINK-15311][runtime] Remove shade of org.lz4:lz4-java to make lz4 block compression use native implementation by default. URL: https://github.com/apache/flink/pull/10639#issuecomment-567960585 backport from #10636

[GitHub] [flink] zhijiangW edited a comment on issue #10639: [FLINK-15311][runtime] Remove shade of org.lz4:lz4-java to make lz4 block compression use native implementation by default.

zhijiangW edited a comment on issue #10639: [FLINK-15311][runtime] Remove shade of org.lz4:lz4-java to make lz4 block compression use native implementation by default. URL: https://github.com/apache/flink/pull/10639#issuecomment-567960585 backport from #10636

[GitHub] [flink] zhijiangW commented on issue #10639: [FLINK-15311][runtime] Remove shade of org.lz4:lz4-java to make lz4 block compression use native implementation by default.

zhijiangW commented on issue #10639: [FLINK-15311][runtime] Remove shade of org.lz4:lz4-java to make lz4 block compression use native implementation by default. URL: https://github.com/apache/flink/pull/10639#issuecomment-567960585 back port from #10636

[GitHub] [flink] zhijiangW merged pull request #10636: [FLINK-15311][runtime] Remove shade of org.lz4:lz4-java to make lz4 block compression use native implementation by default.

zhijiangW merged pull request #10636: [FLINK-15311][runtime] Remove shade of org.lz4:lz4-java to make lz4 block compression use native implementation by default. URL: https://github.com/apache/flink/pull/10636 This is an

[GitHub] [flink] flinkbot commented on issue #10652: [FLINK-15337][docs] Add vendor table to documentation

flinkbot commented on issue #10652: [FLINK-15337][docs] Add vendor table to documentation URL: https://github.com/apache/flink/pull/10652#issuecomment-567958386 ## CI report: * 1fb38853b09b94803f33ab9098e75b4fa6b65a60 UNKNOWN Bot commands The @flinkbot bot

[GitHub] [flink] flinkbot edited a comment on issue #10651: [FLINK-15343][streaming] Add Watermarks options for TwoInputStreamOpe…

flinkbot edited a comment on issue #10651: [FLINK-15343][streaming] Add Watermarks options for TwoInputStreamOpe… URL: https://github.com/apache/flink/pull/10651#issuecomment-567927075 ## CI report: * 5945e5e8f373215b0dfe051c7f91f7b91e6b0928 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10591: [FLINK-15272][table-planner-blink] Better error message when insert partition with values

flinkbot edited a comment on issue #10591: [FLINK-15272][table-planner-blink] Better error message when insert partition with values URL: https://github.com/apache/flink/pull/10591#issuecomment-565986156 ## CI report: * efafb1293280291624d5a1122f1af1513cce3456 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10553: [FLINK-11524][tests] Throw descriptive error if job terminates prematurely

flinkbot edited a comment on issue #10553: [FLINK-11524][tests] Throw descriptive error if job terminates prematurely URL: https://github.com/apache/flink/pull/10553#issuecomment-565027016 ## CI report: * 2d5103c61fb54ea4bc8fe0ee85f949dc7d458aab Travis:

[jira] [Commented] (FLINK-15325) Input location preference which affects task distribution may make certain job performance worse

[ https://issues.apache.org/jira/browse/FLINK-15325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000940#comment-17000940 ] Zhu Zhu commented on FLINK-15325: - Yes, if the config is enabled,

[GitHub] [flink] zentol commented on a change in pull request #10551: [FLINK-13662][kinesis] Relax timing requirements

zentol commented on a change in pull request #10551: [FLINK-13662][kinesis] Relax timing requirements URL: https://github.com/apache/flink/pull/10551#discussion_r360404427 ## File path:

[jira] [Commented] (FLINK-15262) kafka connector doesn't read from beginning immediately when 'connector.startup-mode' = 'earliest-offset'

[ https://issues.apache.org/jira/browse/FLINK-15262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000925#comment-17000925 ] Jiangjie Qin commented on FLINK-15262: -- [~phoenixjiangnan] Hmm, that was the same steps I tried.

[GitHub] [flink] flinkbot edited a comment on issue #10591: [FLINK-15272][table-planner-blink] Better error message when insert partition with values

flinkbot edited a comment on issue #10591: [FLINK-15272][table-planner-blink] Better error message when insert partition with values URL: https://github.com/apache/flink/pull/10591#issuecomment-565986156 ## CI report: * efafb1293280291624d5a1122f1af1513cce3456 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10553: [FLINK-11524][tests] Throw descriptive error if job terminates prematurely

flinkbot edited a comment on issue #10553: [FLINK-11524][tests] Throw descriptive error if job terminates prematurely URL: https://github.com/apache/flink/pull/10553#issuecomment-565027016 ## CI report: * 2d5103c61fb54ea4bc8fe0ee85f949dc7d458aab Travis:

[GitHub] [flink] flinkbot commented on issue #10652: [FLINK-15337][docs] Add vendor table to documentation

flinkbot commented on issue #10652: [FLINK-15337][docs] Add vendor table to documentation URL: https://github.com/apache/flink/pull/10652#issuecomment-567945031 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[jira] [Updated] (FLINK-15337) Add vendor table to documentation

[ https://issues.apache.org/jira/browse/FLINK-15337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15337: --- Labels: pull-request-available (was: ) > Add vendor table to documentation >

[GitHub] [flink] sjwiesman opened a new pull request #10652: [FLINK-15337][docs] Add vendor table to documentation

sjwiesman opened a new pull request #10652: [FLINK-15337][docs] Add vendor table to documentation URL: https://github.com/apache/flink/pull/10652 ## What is the purpose of the change Add an overview of vendor offerings to help improve Flink adoption in the enterprise. ##

[GitHub] [flink] sjwiesman commented on issue #10652: [FLINK-15337][docs] Add vendor table to documentation

sjwiesman commented on issue #10652: [FLINK-15337][docs] Add vendor table to documentation URL: https://github.com/apache/flink/pull/10652#issuecomment-567944004 cc @rmetzger This is an automated message from the Apache Git

[jira] [Updated] (FLINK-15287) Vectorized orc reader fails with Hive 2.0.1

[ https://issues.apache.org/jira/browse/FLINK-15287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15287: - Priority: Major (was: Blocker) > Vectorized orc reader fails with Hive 2.0.1 >

[GitHub] [flink] zhuzhurk commented on a change in pull request #10551: [FLINK-13662][kinesis] Relax timing requirements

zhuzhurk commented on a change in pull request #10551: [FLINK-13662][kinesis] Relax timing requirements URL: https://github.com/apache/flink/pull/10551#discussion_r360394234 ## File path: flink-core/src/main/java/org/apache/flink/api/common/time/Deadline.java ## @@ -47,6

[GitHub] [flink] zentol commented on a change in pull request #10551: [FLINK-13662][kinesis] Relax timing requirements

zentol commented on a change in pull request #10551: [FLINK-13662][kinesis] Relax timing requirements URL: https://github.com/apache/flink/pull/10551#discussion_r360393301 ## File path: flink-core/src/main/java/org/apache/flink/api/common/time/Deadline.java ## @@ -47,6

[GitHub] [flink] zentol commented on a change in pull request #10551: [FLINK-13662][kinesis] Relax timing requirements

zentol commented on a change in pull request #10551: [FLINK-13662][kinesis] Relax timing requirements URL: https://github.com/apache/flink/pull/10551#discussion_r360390236 ## File path: flink-core/src/main/java/org/apache/flink/api/common/time/Deadline.java ## @@ -47,6

[GitHub] [flink] zentol commented on a change in pull request #10553: [FLINK-11524][tests] Throw descriptive error if job terminates prematurely

zentol commented on a change in pull request #10553: [FLINK-11524][tests] Throw descriptive error if job terminates prematurely URL: https://github.com/apache/flink/pull/10553#discussion_r360388962 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #10553: [FLINK-11524][tests] Throw descriptive error if job terminates prematurely

zentol commented on a change in pull request #10553: [FLINK-11524][tests] Throw descriptive error if job terminates prematurely URL: https://github.com/apache/flink/pull/10553#discussion_r360389018 ## File path:

[jira] [Updated] (FLINK-15287) Vectorized orc reader fails with Hive 2.0.1

[ https://issues.apache.org/jira/browse/FLINK-15287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15287: - Priority: Blocker (was: Major) > Vectorized orc reader fails with Hive 2.0.1 >

[jira] [Commented] (FLINK-15327) 'Walkthrough DataStream Scala nightly' sometimes fails with InterruptedException

[ https://issues.apache.org/jira/browse/FLINK-15327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000903#comment-17000903 ] Robert Metzger commented on FLINK-15327: [~pnowojski]: I had an offline chat with [~sewen] about

[GitHub] [flink] flinkbot edited a comment on issue #10651: [FLINK-15343][streaming] Add Watermarks options for TwoInputStreamOpe…

flinkbot edited a comment on issue #10651: [FLINK-15343][streaming] Add Watermarks options for TwoInputStreamOpe… URL: https://github.com/apache/flink/pull/10651#issuecomment-567927075 ## CI report: * 5945e5e8f373215b0dfe051c7f91f7b91e6b0928 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10642: [FLINK-10938] enable e2e test on travis

flinkbot edited a comment on issue #10642: [FLINK-10938] enable e2e test on travis URL: https://github.com/apache/flink/pull/10642#issuecomment-567843009 ## CI report: * c41710f70754f7955ddc0ff93653f43f9c18640f Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10607: [FLINK-15298][docs] Fix dependences in the DataStream API Tutorial doc

flinkbot edited a comment on issue #10607: [FLINK-15298][docs] Fix dependences in the DataStream API Tutorial doc URL: https://github.com/apache/flink/pull/10607#issuecomment-566603542 ## CI report: * c4189f26145c1ef60b0d9485a52f09b47ea14f4e Travis:

[GitHub] [flink] flinkbot commented on issue #10651: [FLINK-15343][streaming] Add Watermarks options for TwoInputStreamOpe…

flinkbot commented on issue #10651: [FLINK-15343][streaming] Add Watermarks options for TwoInputStreamOpe… URL: https://github.com/apache/flink/pull/10651#issuecomment-567927075 ## CI report: * 5945e5e8f373215b0dfe051c7f91f7b91e6b0928 UNKNOWN Bot commands The

[jira] [Updated] (FLINK-15327) 'Walkthrough DataStream Scala nightly' sometimes fails with InterruptedException

[ https://issues.apache.org/jira/browse/FLINK-15327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-15327: --- Description: The "Walkthrough DataStream Scala nightly end-to-end test"

[GitHub] [flink] CrazyTomatoOo commented on issue #10631: [FLINK-15081]Translation work has been finished. Please check it out. This page is about Table API This is my first contribution. Please

CrazyTomatoOo commented on issue #10631: [FLINK-15081]Translation work has been finished. Please check it out. This page is about Table API This is my first contribution. Please advise. Thanks！ URL: https://github.com/apache/flink/pull/10631#issuecomment-567926768 > (For example: This

[GitHub] [flink] CrazyTomatoOo removed a comment on issue #10631: [FLINK-15081]Translation work has been finished. Please check it out. This page is about Table API This is my first contribution.

CrazyTomatoOo removed a comment on issue #10631: [FLINK-15081]Translation work has been finished. Please check it out. This page is about Table API This is my first contribution. Please advise. Thanks！ URL: https://github.com/apache/flink/pull/10631#issuecomment-567926768 > (For example:

[GitHub] [flink] CrazyTomatoOo closed pull request #10631: [FLINK-15081]Translation work has been finished. Please check it out. This page is about Table API This is my first contribution. Please

CrazyTomatoOo closed pull request #10631: [FLINK-15081]Translation work has been finished. Please check it out. This page is about Table API This is my first contribution. Please advise. Thanks！ URL: https://github.com/apache/flink/pull/10631

[GitHub] [flink] CrazyTomatoOo opened a new pull request #10631: [FLINK-15081]Translation work has been finished. Please check it out. This page is about Table API This is my first contribution.

CrazyTomatoOo opened a new pull request #10631: [FLINK-15081]Translation work has been finished. Please check it out. This page is about Table API This is my first contribution. Please advise. Thanks！ URL: https://github.com/apache/flink/pull/10631 ## What is the purpose of the

[GitHub] [flink] flinkbot edited a comment on issue #10627: [FLINK-15308][runtime] Remove data compression for pipelined shuffle.

flinkbot edited a comment on issue #10627: [FLINK-15308][runtime] Remove data compression for pipelined shuffle. URL: https://github.com/apache/flink/pull/10627#issuecomment-567438838 ## CI report: * c09e6a14c7c5c22969e54d6fa8a35842b4b18baf UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #10607: [FLINK-15298][docs] Fix dependences in the DataStream API Tutorial doc

flinkbot edited a comment on issue #10607: [FLINK-15298][docs] Fix dependences in the DataStream API Tutorial doc URL: https://github.com/apache/flink/pull/10607#issuecomment-566603542 ## CI report: * c4189f26145c1ef60b0d9485a52f09b47ea14f4e Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10570: [FLINK-15248][FileSystems] Fix the bug in FileUtils#compressDirectory when processing relative directory path.

flinkbot edited a comment on issue #10570: [FLINK-15248][FileSystems] Fix the bug in FileUtils#compressDirectory when processing relative directory path. URL: https://github.com/apache/flink/pull/10570#issuecomment-565434555 ## CI report: *

[jira] [Closed] (FLINK-15065) RocksDB configurable options doc description error

[ https://issues.apache.org/jira/browse/FLINK-15065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-15065. --- Fix Version/s: 1.11.0 1.9.2 1.8.4 Resolution:

[jira] [Assigned] (FLINK-14177) Bump Curator From 2.12.0 to 4.2.0

[ https://issues.apache.org/jira/browse/FLINK-14177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-14177: - Assignee: (was: lamber-ken) > Bump Curator From 2.12.0 to 4.2.0 >

[jira] [Commented] (FLINK-15325) Input location preference which affects task distribution may make certain job performance worse

[ https://issues.apache.org/jira/browse/FLINK-15325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000886#comment-17000886 ] Till Rohrmann commented on FLINK-15325: --- If there is a good need for this feature, then one could

[GitHub] [flink] tillrohrmann commented on a change in pull request #10602: [FLINK-10938] Add e2e test for natively running flink session cluster on kubernetes

tillrohrmann commented on a change in pull request #10602: [FLINK-10938] Add e2e test for natively running flink session cluster on kubernetes URL: https://github.com/apache/flink/pull/10602#discussion_r360366871 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #10602: [FLINK-10938] Add e2e test for natively running flink session cluster on kubernetes

tillrohrmann commented on a change in pull request #10602: [FLINK-10938] Add e2e test for natively running flink session cluster on kubernetes URL: https://github.com/apache/flink/pull/10602#discussion_r360367004 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #10602: [FLINK-10938] Add e2e test for natively running flink session cluster on kubernetes

tillrohrmann commented on a change in pull request #10602: [FLINK-10938] Add e2e test for natively running flink session cluster on kubernetes URL: https://github.com/apache/flink/pull/10602#discussion_r360366671 ## File path:

[jira] [Updated] (FLINK-14846) Correct the default writerbuffer size documentation of RocksDB

[ https://issues.apache.org/jira/browse/FLINK-14846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-14846: Fix Version/s: 1.9.2 1.8.4 > Correct the default writerbuffer size

[jira] [Commented] (FLINK-14846) Correct the default writerbuffer size documentation of RocksDB

[ https://issues.apache.org/jira/browse/FLINK-14846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000883#comment-17000883 ] Andrey Zagrebin commented on FLINK-14846: - merged into master by 

[GitHub] [flink] azagrebin merged pull request #10569: [FLINK-15065][docs] Correct default value of RocksDB options in documentation

azagrebin merged pull request #10569: [FLINK-15065][docs] Correct default value of RocksDB options in documentation URL: https://github.com/apache/flink/pull/10569 This is an automated message from the Apache Git Service.

[jira] [Closed] (FLINK-15268) Shaded Hadoop S3A end-to-end test fails on travis

[ https://issues.apache.org/jira/browse/FLINK-15268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-15268. -- Resolution: Fixed Merged to master as 96f4c79 Merged to release-1.10 as 

[GitHub] [flink] flinkbot edited a comment on issue #10650: [FLINK-14796][hive][doc] Add document about limitations of different …

flinkbot edited a comment on issue #10650: [FLINK-14796][hive][doc] Add document about limitations of different … URL: https://github.com/apache/flink/pull/10650#issuecomment-567863360 ## CI report: * 9bd4cf6d411f94df0759850f82d07fd657173577 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10649: [FLINK-15268][build] Correctly set Multi-Release in manifest.

flinkbot edited a comment on issue #10649: [FLINK-15268][build] Correctly set Multi-Release in manifest. URL: https://github.com/apache/flink/pull/10649#issuecomment-567863312 ## CI report: * d0a1fa151d9906b64e947276a0ed5e68c94229cd Travis:

[GitHub] [flink] pnowojski merged pull request #10649: [FLINK-15268][build] Correctly set Multi-Release in manifest.

pnowojski merged pull request #10649: [FLINK-15268][build] Correctly set Multi-Release in manifest. URL: https://github.com/apache/flink/pull/10649 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot edited a comment on issue #10642: [FLINK-10938] enable e2e test on travis

flinkbot edited a comment on issue #10642: [FLINK-10938] enable e2e test on travis URL: https://github.com/apache/flink/pull/10642#issuecomment-567843009 ## CI report: * c41710f70754f7955ddc0ff93653f43f9c18640f Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10619: [FLINK-15175]Fix CTES not supported in SQL CLI

flinkbot edited a comment on issue #10619: [FLINK-15175]Fix CTES not supported in SQL CLI URL: https://github.com/apache/flink/pull/10619#issuecomment-566919711 ## CI report: * 6a8566b5b33bb07c0277da8842b511f6b4722f10 Travis:

[GitHub] [flink] flinkbot commented on issue #10651: [FLINK-15343][streaming] Add Watermarks options for TwoInputStreamOpe…

flinkbot commented on issue #10651: [FLINK-15343][streaming] Add Watermarks options for TwoInputStreamOpe… URL: https://github.com/apache/flink/pull/10651#issuecomment-567917119 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Updated] (FLINK-15343) Add Watermarks options for TwoInputStreamOperator

[ https://issues.apache.org/jira/browse/FLINK-15343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15343: --- Labels: pull-request-available (was: ) > Add Watermarks options for TwoInputStreamOperator

[GitHub] [flink] shidayang opened a new pull request #10651: [FLINK-15343][streaming] Add Watermarks options for TwoInputStreamOpe…

shidayang opened a new pull request #10651: [FLINK-15343][streaming] Add Watermarks options for TwoInputStreamOpe… URL: https://github.com/apache/flink/pull/10651 …rator ## What is the purpose of the change Add Watermarks options for TwoInputStreamOperator, user can

[GitHub] [flink] AHeise commented on issue #10649: [FLINK-15268][build] Correctly set Multi-Release in manifest.

AHeise commented on issue #10649: [FLINK-15268][build] Correctly set Multi-Release in manifest. URL: https://github.com/apache/flink/pull/10649#issuecomment-567915842 > +1 > > No idea why I didn't run into issues when I tested the packaging... It occurred only after I changed

[GitHub] [flink] tillrohrmann commented on a change in pull request #10538: [FLINK-15135][e2e][Mesos] Adding e2e tests for Flink's Mesos integration

tillrohrmann commented on a change in pull request #10538: [FLINK-15135][e2e][Mesos] Adding e2e tests for Flink's Mesos integration URL: https://github.com/apache/flink/pull/10538#discussion_r360354770 ## File path: flink-end-to-end-tests/test-scripts/common_mesos_docker.sh

[GitHub] [flink] tillrohrmann commented on a change in pull request #10538: [FLINK-15135][e2e][Mesos] Adding e2e tests for Flink's Mesos integration

tillrohrmann commented on a change in pull request #10538: [FLINK-15135][e2e][Mesos] Adding e2e tests for Flink's Mesos integration URL: https://github.com/apache/flink/pull/10538#discussion_r360354998 ## File path: flink-end-to-end-tests/test-scripts/common_mesos_docker.sh

[GitHub] [flink] tillrohrmann commented on a change in pull request #10538: [FLINK-15135][e2e][Mesos] Adding e2e tests for Flink's Mesos integration

tillrohrmann commented on a change in pull request #10538: [FLINK-15135][e2e][Mesos] Adding e2e tests for Flink's Mesos integration URL: https://github.com/apache/flink/pull/10538#discussion_r360356662 ## File path: tools/travis/splits/split_container_hadoopfree.sh ## @@

[GitHub] [flink] qinjunjerry commented on a change in pull request #10607: [FLINK-15298][docs] Fix dependences in the DataStream API Tutorial doc

qinjunjerry commented on a change in pull request #10607: [FLINK-15298][docs] Fix dependences in the DataStream API Tutorial doc URL: https://github.com/apache/flink/pull/10607#discussion_r360360529 ## File path: docs/getting-started/tutorials/datastream_api.md ## @@

[jira] [Commented] (FLINK-15065) RocksDB configurable options doc description error

[ https://issues.apache.org/jira/browse/FLINK-15065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000869#comment-17000869 ] Andrey Zagrebin commented on FLINK-15065: - [~yunta] do you want to cherry pick your rocksdb 

[jira] [Updated] (FLINK-15343) Add Watermarks options for TwoInputStreamOperator

[ https://issues.apache.org/jira/browse/FLINK-15343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jocean.shi updated FLINK-15343: --- Issue Type: Improvement (was: New Feature) > Add Watermarks options for TwoInputStreamOperator >

[GitHub] [flink] flinkbot edited a comment on issue #10649: [FLINK-15268][build] Correctly set Multi-Release in manifest.

flinkbot edited a comment on issue #10649: [FLINK-15268][build] Correctly set Multi-Release in manifest. URL: https://github.com/apache/flink/pull/10649#issuecomment-567863312 ## CI report: * d0a1fa151d9906b64e947276a0ed5e68c94229cd Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10645: [FLINK-10938] trigger e2e test for 10644

flinkbot edited a comment on issue #10645: [FLINK-10938] trigger e2e test for 10644 URL: https://github.com/apache/flink/pull/10645#issuecomment-567843108 ## CI report: * 461f3a92f7ec15c82e2878a631d5673cc467e53b Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10647: [FLINK-15344][documentation] Update limitations in hive udf document

flinkbot edited a comment on issue #10647: [FLINK-15344][documentation] Update limitations in hive udf document URL: https://github.com/apache/flink/pull/10647#issuecomment-567852868 ## CI report: * a74a90370f241bb7745baee6b3a0b21ada2067fb Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10627: [FLINK-15308][runtime] Remove data compression for pipelined shuffle.

flinkbot edited a comment on issue #10627: [FLINK-15308][runtime] Remove data compression for pipelined shuffle. URL: https://github.com/apache/flink/pull/10627#issuecomment-567438838 ## CI report: * c09e6a14c7c5c22969e54d6fa8a35842b4b18baf UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #10570: [FLINK-15248][FileSystems] Fix the bug in FileUtils#compressDirectory when processing relative directory path.

flinkbot edited a comment on issue #10570: [FLINK-15248][FileSystems] Fix the bug in FileUtils#compressDirectory when processing relative directory path. URL: https://github.com/apache/flink/pull/10570#issuecomment-565434555 ## CI report: *

[GitHub] [flink] wuchong commented on issue #10591: [FLINK-15272][table-planner-blink] Better error message when insert partition with values

wuchong commented on issue #10591: [FLINK-15272][table-planner-blink] Better error message when insert partition with values URL: https://github.com/apache/flink/pull/10591#issuecomment-567908148 @JingsongLi the travis is failed. Please have a look.

[jira] [Assigned] (FLINK-15344) Update limitations in hive udf document

[ https://issues.apache.org/jira/browse/FLINK-15344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-15344: --- Assignee: Jingsong Lee > Update limitations in hive udf document >

[GitHub] [flink] tillrohrmann commented on a change in pull request #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager

tillrohrmann commented on a change in pull request #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager URL: https://github.com/apache/flink/pull/10532#discussion_r360336903 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager

tillrohrmann commented on a change in pull request #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager URL: https://github.com/apache/flink/pull/10532#discussion_r360342044 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager

tillrohrmann commented on a change in pull request #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager URL: https://github.com/apache/flink/pull/10532#discussion_r360335622 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager

tillrohrmann commented on a change in pull request #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager URL: https://github.com/apache/flink/pull/10532#discussion_r360336410 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager

tillrohrmann commented on a change in pull request #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager URL: https://github.com/apache/flink/pull/10532#discussion_r360343306 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager

tillrohrmann commented on a change in pull request #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager URL: https://github.com/apache/flink/pull/10532#discussion_r360342653 ## File path:

<    1   2   3   4   >