[jira] [Assigned] (FLINK-18205) Mitigate the use of reflection in HadoopModule

2020-06-11 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-18205: - Assignee: Yangze Guo > Mitigate the use of reflection in HadoopModule >

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

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

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

2020-06-11 Thread GitBox
zhuzhurk commented on a change in pull request #12256: URL: https://github.com/apache/flink/pull/12256#discussion_r438860474 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/AbstractExecutionSlotAllocator.java ## @@ -0,0 +1,119 @@ +/* + * Licensed

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

2020-06-11 Thread GitBox
zhuzhurk commented on a change in pull request #12256: URL: https://github.com/apache/flink/pull/12256#discussion_r438859474 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultExecutionSlotAllocator.java ## @@ -77,22 +75,20 @@ public

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

2020-06-11 Thread GitBox
zhuzhurk commented on a change in pull request #12256: URL: https://github.com/apache/flink/pull/12256#discussion_r438859134 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultExecutionSlotAllocator.java ## @@ -36,41 +35,28 @@ import

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

2020-06-11 Thread GitBox
zhuzhurk commented on a change in pull request #12256: URL: https://github.com/apache/flink/pull/12256#discussion_r438858533 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/OneSlotPerExecutionSlotAllocatorTest.java ## @@ -0,0 +1,305 @@ +/* + *

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

2020-06-11 Thread GitBox
zhuzhurk commented on a change in pull request #12256: URL: https://github.com/apache/flink/pull/12256#discussion_r438858595 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/OneSlotPerExecutionSlotAllocatorTest.java ## @@ -0,0 +1,305 @@ +/* + *

[jira] [Closed] (FLINK-17017) Implements bulk allocation for physical slots

2020-06-11 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-17017. --- Resolution: Fixed Done via 7054f97350efec83e3bf8b10b9b2c44f1a149cf1

[jira] [Commented] (FLINK-18257) MasterStateSnapshot future may not be completed

2020-06-11 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133316#comment-17133316 ] Roman Khachatryan commented on FLINK-18257: --- Yes, you are right. Closing the ticket. >

[jira] [Closed] (FLINK-18257) MasterStateSnapshot future may not be completed

2020-06-11 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-18257. - Resolution: Not A Bug > MasterStateSnapshot future may not be completed >

[GitHub] [flink] zhuzhurk merged pull request #12375: [FLINK-17017][runtime] Implements bulk allocation for physical slots

2020-06-11 Thread GitBox
zhuzhurk merged pull request #12375: URL: https://github.com/apache/flink/pull/12375 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] zhuzhurk commented on pull request #12375: [FLINK-17017][runtime] Implements bulk allocation for physical slots

2020-06-11 Thread GitBox
zhuzhurk commented on pull request #12375: URL: https://github.com/apache/flink/pull/12375#issuecomment-642719717 Merging. This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] azagrebin commented on a change in pull request #12278: [FLINK-17019][runtime] Fulfill slot requests in request order

2020-06-11 Thread GitBox
azagrebin commented on a change in pull request #12278: URL: https://github.com/apache/flink/pull/12278#discussion_r438835441 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/DualKeyLinkedMap.java ## @@ -37,20 +44,20 @@ private

[jira] [Commented] (FLINK-18257) MasterStateSnapshot future may not be completed

2020-06-11 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133312#comment-17133312 ] Till Rohrmann commented on FLINK-18257: --- Won't {{PendingCheckpoint.discarded}} only written in

[GitHub] [flink] pnowojski commented on pull request #11541: [FLINK-15416][network] add task manager netty client retry mechenism

2020-06-11 Thread GitBox
pnowojski commented on pull request #11541: URL: https://github.com/apache/flink/pull/11541#issuecomment-642709638 Thanks for the udpate @HuangZhenQiu > There is no test that is marked to ignore by this PR. Would you please double-check? The whole

[GitHub] [flink] pnowojski edited a comment on pull request #11541: [FLINK-15416][network] add task manager netty client retry mechenism

2020-06-11 Thread GitBox
pnowojski edited a comment on pull request #11541: URL: https://github.com/apache/flink/pull/11541#issuecomment-642709638 Thanks for the udpate @HuangZhenQiu > There is no test that is marked to ignore by this PR. Would you please double-check? The whole

[GitHub] [flink] tillrohrmann commented on a change in pull request #12278: [FLINK-17019][runtime] Fulfill slot requests in request order

2020-06-11 Thread GitBox
tillrohrmann commented on a change in pull request #12278: URL: https://github.com/apache/flink/pull/12278#discussion_r438843898 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolImpl.java ## @@ -648,26 +648,8 @@ boolean offerSlot(

[GitHub] [flink] rmetzger commented on pull request #12558: [FLINK-17976][docs][k8s/docker] Improvements about custom docker images

2020-06-11 Thread GitBox
rmetzger commented on pull request #12558: URL: https://github.com/apache/flink/pull/12558#issuecomment-642707724 Thank you for your review. I pushed a commit addressing your concerns! This is an automated message from the

[GitHub] [flink] flinkbot commented on pull request #12611: [FLINK-18137] Handle discarding of triggering checkpoint correctly

2020-06-11 Thread GitBox
flinkbot commented on pull request #12611: URL: https://github.com/apache/flink/pull/12611#issuecomment-642705333 ## CI report: * 806a7a29d591bd46c65ca094818990b953ff65eb UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #12527: [FLINK-18173][build] Bundle flink-csv,flink-json,flink-avro jars in lib

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12527: URL: https://github.com/apache/flink/pull/12527#issuecomment-640564258 ## CI report: * a6add24c7d5a479f5ad83bf25f3086881b69cad7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12605: [FLINK-18242][state-backend-rocksdb] Separate RocksDBOptionsFactory from OptionsFactory

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12605: URL: https://github.com/apache/flink/pull/12605#issuecomment-642611275 ## CI report: * 389cda97d6fc7b4473f9b6f32a9126ae23d59259 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12610: [FLINK-17686][doc] Add document to dataGen, print, blackhole connectors

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12610: URL: https://github.com/apache/flink/pull/12610#issuecomment-642692845 ## CI report: * cb675d757233281e6e6d71e5b95efe445eb8a7e4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12577: [FLINK-17599][docs] Update documents due to FLIP-84

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12577: URL: https://github.com/apache/flink/pull/12577#issuecomment-641885509 ## CI report: * 924761b6433d96aeffe4afb6807d8aec9b69cc45 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12375: [FLINK-17017][runtime] Implements bulk allocation for physical slots

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12375: URL: https://github.com/apache/flink/pull/12375#issuecomment-635184560 ## CI report: * cd3fc98c034fdc61235d9109c05b4f55d7423746 UNKNOWN * f9ea7bdfe11e677c214913340ef804e3e28c25aa UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #12596: [FLINK-18250] Enrich OOM error messages with more details in ClusterEntrypoint

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12596: URL: https://github.com/apache/flink/pull/12596#issuecomment-642518065 ## CI report: * 561630ec0c557fd12b4c094ce5289008e6dfdeac Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11868: [FLINK-17258][tests] Enabling unaligned checkpoint in all tests by default

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #11868: URL: https://github.com/apache/flink/pull/11868#issuecomment-617994961 ## CI report: * c9a8597b0f40ac2600440a65c2c2488dd385ff4e UNKNOWN * 1ed80167a0655c9fb579e93cd94a49517eaa9b42 UNKNOWN *

[GitHub] [flink] carp84 commented on pull request #12514: [FLINK-17800][roksdb] Ensure total order seek to avoid user misuse

2020-06-11 Thread GitBox
carp84 commented on pull request #12514: URL: https://github.com/apache/flink/pull/12514#issuecomment-642703796 PS. The latest pre-commit check failed on e2e part at `Kubernetes test` due to some connection problem, thus is irrelative to the changes here. It would be nice if we could get

[GitHub] [flink] carp84 commented on pull request #12514: [FLINK-17800][roksdb] Ensure total order seek to avoid user misuse

2020-06-11 Thread GitBox
carp84 commented on pull request #12514: URL: https://github.com/apache/flink/pull/12514#issuecomment-642701467 Thanks @Myasuka for the updates, the latest changes LGTM. I've triggered a micro-benchmark run on our Jenkins, will give my +1 if there's no performance regression.

[GitHub] [flink] wangyang0918 commented on pull request #12604: [FLINK-18256][orc] Exclude ORC's Hadoop dependency and pull in provided vanilla hadoop in flink-orc

2020-06-11 Thread GitBox
wangyang0918 commented on pull request #12604: URL: https://github.com/apache/flink/pull/12604#issuecomment-642695631 cc @JingsongLi Could you please help with review? This is an automated message from the Apache Git

[GitHub] [flink] flinkbot commented on pull request #12611: [FLINK-18137] Handle discarding of triggering checkpoint correctly

2020-06-11 Thread GitBox
flinkbot commented on pull request #12611: URL: https://github.com/apache/flink/pull/12611#issuecomment-642695349 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-18137) JobMasterTriggerSavepointITCase.testStopJobAfterSavepoint fails with AskTimeoutException

2020-06-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18137: --- Labels: pull-request-available test-stability (was: test-stability) >

[jira] [Comment Edited] (FLINK-18257) MasterStateSnapshot future may not be completed

2020-06-11 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133282#comment-17133282 ] Roman Khachatryan edited comment on FLINK-18257 at 6/11/20, 2:25 PM: -

[GitHub] [flink] tillrohrmann opened a new pull request #12611: [FLINK-18137] Handle discarding of triggering checkpoint correctly

2020-06-11 Thread GitBox
tillrohrmann opened a new pull request #12611: URL: https://github.com/apache/flink/pull/12611 ## What is the purpose of the change Before discarding a triggering checkpoint could cause a NPE which would stop the processing of subsequent checkpoint requests. This commit changes

[GitHub] [flink] rmetzger commented on a change in pull request #12558: [FLINK-17976][docs][k8s/docker] Improvements about custom docker images

2020-06-11 Thread GitBox
rmetzger commented on a change in pull request #12558: URL: https://github.com/apache/flink/pull/12558#discussion_r438826927 ## File path: docs/ops/deployment/native_kubernetes.md ## @@ -116,10 +116,12 @@ $ kubectl port-forward service/ 8081 - `NodePort`: Exposes the service

[GitHub] [flink] flinkbot edited a comment on pull request #12589: [FLINK-17327] Fix Kafka Producer Resource Leaks

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12589: URL: https://github.com/apache/flink/pull/12589#issuecomment-642078835 ## CI report: * 4dcc3252561499a444be7c76fd8ef6edb6547211 Azure:

[GitHub] [flink] flinkbot commented on pull request #12610: [FLINK-17686][doc] Add document to dataGen, print, blackhole connectors

2020-06-11 Thread GitBox
flinkbot commented on pull request #12610: URL: https://github.com/apache/flink/pull/12610#issuecomment-642692845 ## CI report: * cb675d757233281e6e6d71e5b95efe445eb8a7e4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #12598: [FLINK-18246][python][e2e] Disable PyFlink e2e tests when running on jdk11 to avoid the UnsupportedClassVersionError.

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12598: URL: https://github.com/apache/flink/pull/12598#issuecomment-642529967 ## CI report: * 3f78cec4c88d1b0e2f0bb11e003a0b2f3f48f969 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12597: [FLINK-18141][doc][parquet] Add documentation for Parquet format

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12597: URL: https://github.com/apache/flink/pull/12597#issuecomment-642529852 ## CI report: * 0310550dbaa4b060c3029e6e3f01308652d9faab Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12577: [FLINK-17599][docs] Update documents due to FLIP-84

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12577: URL: https://github.com/apache/flink/pull/12577#issuecomment-641885509 ## CI report: * 924761b6433d96aeffe4afb6807d8aec9b69cc45 Azure:

[GitHub] [flink-playgrounds] sjwiesman commented on a change in pull request #13: [FLINK-18194][walkthrough] Update Table API Walkthrough

2020-06-11 Thread GitBox
sjwiesman commented on a change in pull request #13: URL: https://github.com/apache/flink-playgrounds/pull/13#discussion_r438825548 ## File path: table-walkthrough/src/main/java/org/apache/flink/playgrounds/spendreport/SpendReport.java ## @@ -0,0 +1,67 @@ +/* + * Licensed to

[GitHub] [flink] flinkbot edited a comment on pull request #12297: [FLINK-12855] [streaming-java][window-assigners] Add functionality that staggers panes on partitions to distribute workload.

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12297: URL: https://github.com/apache/flink/pull/12297#issuecomment-632945310 ## CI report: * 0a5d093998b2dcdd13a8213fede0ee213ad8ae31 Azure:

[jira] [Updated] (FLINK-18260) Asynchronous Sinks

2020-06-11 Thread Ori Popowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ori Popowski updated FLINK-18260: - Description: Flink already supports [async

[GitHub] [flink] azagrebin commented on a change in pull request #12278: [FLINK-17019][runtime] Fulfill slot requests in request order

2020-06-11 Thread GitBox
azagrebin commented on a change in pull request #12278: URL: https://github.com/apache/flink/pull/12278#discussion_r438824119 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolImpl.java ## @@ -648,26 +648,8 @@ boolean offerSlot(

[jira] [Created] (FLINK-18260) Asynchronous Sinks

2020-06-11 Thread Ori Popowski (Jira)
Ori Popowski created FLINK-18260: Summary: Asynchronous Sinks Key: FLINK-18260 URL: https://issues.apache.org/jira/browse/FLINK-18260 Project: Flink Issue Type: Wish Components:

[jira] [Commented] (FLINK-18256) Hadoop dependencies are wrongly bundled into flink-orc

2020-06-11 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133285#comment-17133285 ] Aljoscha Krettek commented on FLINK-18256: -- We should only assign fixVersion = 1.11.0, not

[jira] [Updated] (FLINK-18256) Hadoop dependencies are wrongly bundled into flink-orc

2020-06-11 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-18256: - Summary: Hadoop dependencies are wrongly bundled into flink-orc (was: Hadoop is

[jira] [Updated] (FLINK-18256) Hadoop dependencies are wrongly bundled into flink-orc

2020-06-11 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-18256: - Fix Version/s: (was: 1.12.0) > Hadoop dependencies are wrongly bundled into

[jira] [Commented] (FLINK-18257) MasterStateSnapshot future may not be completed

2020-06-11 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133282#comment-17133282 ] Roman Khachatryan commented on FLINK-18257: --- Looks like there is also a race condition when

[GitHub] [flink] JingsongLi commented on a change in pull request #12609: [FLINK-17836][hive][doc] Add document for Hive dim join

2020-06-11 Thread GitBox
JingsongLi commented on a change in pull request #12609: URL: https://github.com/apache/flink/pull/12609#discussion_r438799868 ## File path: docs/dev/table/hive/hive_streaming.md ## @@ -163,4 +163,33 @@ SELECT * FROM hive_table /*+ OPTIONS('streaming-source.enable'='true',

[GitHub] [flink] JingsongLi commented on a change in pull request #12609: [FLINK-17836][hive][doc] Add document for Hive dim join

2020-06-11 Thread GitBox
JingsongLi commented on a change in pull request #12609: URL: https://github.com/apache/flink/pull/12609#discussion_r438798598 ## File path: docs/dev/table/hive/hive_streaming.md ## @@ -163,4 +163,33 @@ SELECT * FROM hive_table /*+ OPTIONS('streaming-source.enable'='true',

[GitHub] [flink] JingsongLi commented on a change in pull request #12609: [FLINK-17836][hive][doc] Add document for Hive dim join

2020-06-11 Thread GitBox
JingsongLi commented on a change in pull request #12609: URL: https://github.com/apache/flink/pull/12609#discussion_r438796572 ## File path: docs/dev/table/hive/hive_streaming.md ## @@ -163,4 +163,33 @@ SELECT * FROM hive_table /*+ OPTIONS('streaming-source.enable'='true',

[GitHub] [flink] flinkbot edited a comment on pull request #12609: [FLINK-17836][hive][doc] Add document for Hive dim join

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12609: URL: https://github.com/apache/flink/pull/12609#issuecomment-642647320 ## CI report: * 9c109ae1c7de41fbee20707324bae19382261f4e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12533: [FLINK-18175][conf] Log final memory configuration

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12533: URL: https://github.com/apache/flink/pull/12533#issuecomment-640762807 ## CI report: * a1b0c37233ff7200b36ec769bedb5cd745cc0fd5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12311: [FLINK-17269][docs] Translate new Training Overview to Chinese

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12311: URL: https://github.com/apache/flink/pull/12311#issuecomment-633370054 ## CI report: * 5424b3998edf8611a5168238998b77d1030284d0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12594: [FLINK-18072][hbase] HBaseLookupFunction can not work with new internal data structure RowData

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12594: URL: https://github.com/apache/flink/pull/12594#issuecomment-642474618 ## CI report: * 5be824fed4684ac3078b929bb7e5eecb7c976ce6 Azure:

[GitHub] [flink] flinkbot commented on pull request #12610: [FLINK-17686][doc] Add document to dataGen, print, blackhole connectors

2020-06-11 Thread GitBox
flinkbot commented on pull request #12610: URL: https://github.com/apache/flink/pull/12610#issuecomment-642658801 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] JingsongLi commented on a change in pull request #12609: [FLINK-17836][hive][doc] Add document for Hive dim join

2020-06-11 Thread GitBox
JingsongLi commented on a change in pull request #12609: URL: https://github.com/apache/flink/pull/12609#discussion_r438794639 ## File path: docs/dev/table/hive/hive_streaming.md ## @@ -163,4 +163,33 @@ SELECT * FROM hive_table /*+ OPTIONS('streaming-source.enable'='true',

[GitHub] [flink] JingsongLi opened a new pull request #12610: [FLINK-17686][doc] Add document to dataGen, print, blackhole connectors

2020-06-11 Thread GitBox
JingsongLi opened a new pull request #12610: URL: https://github.com/apache/flink/pull/12610 ## What is the purpose of the change Add document to dataGen, print, blackhole connectors ## Verifying this change

[jira] [Updated] (FLINK-17686) Add document to dataGen, print, blackhole connectors

2020-06-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17686: --- Labels: pull-request-available (was: ) > Add document to dataGen, print, blackhole

[jira] [Commented] (FLINK-18209) Replace "charged" words in the Flink codebase.

2020-06-11 Thread Fabian Hueske (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133274#comment-17133274 ] Fabian Hueske commented on FLINK-18209: --- +1 > Replace "charged" words in the Flink codebase. >

[jira] [Commented] (FLINK-18257) MasterStateSnapshot future may not be completed

2020-06-11 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133270#comment-17133270 ] Till Rohrmann commented on FLINK-18257: --- I think 2. is also not a problem because we execute the

[GitHub] [flink] azagrebin commented on a change in pull request #11245: [FLINK-15794][Kubernetes] Generate the Kubernetes default image version

2020-06-11 Thread GitBox
azagrebin commented on a change in pull request #11245: URL: https://github.com/apache/flink/pull/11245#discussion_r438777643 ## File path: docs/ops/deployment/kubernetes.md ## @@ -262,7 +262,7 @@ spec: spec: containers: - name: jobmanager -image:

[GitHub] [flink] flinkbot edited a comment on pull request #12608: [FLINK-18247][table-planner-blink] Fix unstable test: TableITCase.testCollectWithClose

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12608: URL: https://github.com/apache/flink/pull/12608#issuecomment-642635512 ## CI report: * 362543e4cad857f4fb61a2c5010f0e6a58cc2b8d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12601: [FLINK-18241] Use correct user class loader in OptimizerPlaneEnvironment & StreamPlanEnvironment

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12601: URL: https://github.com/apache/flink/pull/12601#issuecomment-642557238 ## CI report: * 37f1a8fc159bd90b516b5a038fbd490f8e2e807c UNKNOWN * 750a305836e4cf516fd6c1d8d9023b824af1598f Travis:

[GitHub] [flink] flinkbot edited a comment on pull request #12606: [FLINK-18248][docs] Update data type documentation for 1.11

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12606: URL: https://github.com/apache/flink/pull/12606#issuecomment-642635270 ## CI report: * 9616bba566dd903d52490e9ed1b1c4ef2ab3ae0b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12594: [FLINK-18072][hbase] HBaseLookupFunction can not work with new internal data structure RowData

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12594: URL: https://github.com/apache/flink/pull/12594#issuecomment-642474618 ## CI report: * 5be824fed4684ac3078b929bb7e5eecb7c976ce6 Azure:

[GitHub] [flink] flinkbot commented on pull request #12609: [FLINK-17836][hive][doc] Add document for Hive dim join

2020-06-11 Thread GitBox
flinkbot commented on pull request #12609: URL: https://github.com/apache/flink/pull/12609#issuecomment-642647320 ## CI report: * 9c109ae1c7de41fbee20707324bae19382261f4e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #12533: [FLINK-18175][conf] Log final memory configuration

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12533: URL: https://github.com/apache/flink/pull/12533#issuecomment-640762807 ## CI report: * a1b0c37233ff7200b36ec769bedb5cd745cc0fd5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12589: [FLINK-17327] Fix Kafka Producer Resource Leaks

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12589: URL: https://github.com/apache/flink/pull/12589#issuecomment-642078835 ## CI report: * 7b046578a4dcdf41f971409b4e3d5c409ad27316 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12607: [FLINK-18241] Use correct user class loader in OptimizerPlaneEnvironment & StreamPlanEnvironment

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12607: URL: https://github.com/apache/flink/pull/12607#issuecomment-642635387 ## CI report: * 3235ac3644d373acad07fd4ab4eca32590daf9a4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12311: [FLINK-17269][docs] Translate new Training Overview to Chinese

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12311: URL: https://github.com/apache/flink/pull/12311#issuecomment-633370054 ## CI report: * 5424b3998edf8611a5168238998b77d1030284d0 Azure:

[GitHub] [flink-playgrounds] sjwiesman edited a comment on pull request #13: [FLINK-18194][walkthrough] Update Table API Walkthrough

2020-06-11 Thread GitBox
sjwiesman edited a comment on pull request #13: URL: https://github.com/apache/flink-playgrounds/pull/13#issuecomment-642642789 @twalthr @dawidwys could either of you help review a4152a5 . This is going to be the new introduction to the table api and I want to make sure I'm showing of the

[GitHub] [flink] KurtYoung closed pull request #12600: [FLINK-16375][table] Reintroduce registerTable[Source/Sink] methods for table env

2020-06-11 Thread GitBox
KurtYoung closed pull request #12600: URL: https://github.com/apache/flink/pull/12600 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-playgrounds] sjwiesman commented on pull request #13: [FLINK-18194][walkthrough] Update Table API Walkthrough

2020-06-11 Thread GitBox
sjwiesman commented on pull request #13: URL: https://github.com/apache/flink-playgrounds/pull/13#issuecomment-642642789 @twalthr @dawidwys could either of you help review bc804b9. This is going to be the new introduction to the table api and I want to make sure I'm showing of the right

[jira] [Commented] (FLINK-16375) Reintroduce registerTableSource/Sink methods for table env

2020-06-11 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133258#comment-17133258 ] Dawid Wysakowicz commented on FLINK-16375: -- I'd be fine with reverting it only for 1.11. >

[jira] [Commented] (FLINK-16375) Reintroduce registerTableSource/Sink methods for table env

2020-06-11 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133256#comment-17133256 ] Timo Walther commented on FLINK-16375: -- Yes, we can just merge it to 1.11. > Reintroduce

[jira] [Closed] (FLINK-17829) Add documentation for the new JDBC connector

2020-06-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-17829. --- Resolution: Fixed - master (1.12.0): 8cb6ef66c1d40ba09f3838c75d7ce7347e504f61 - 1.11.0:

[jira] [Commented] (FLINK-12030) KafkaITCase.testMultipleSourcesOnePartition is unstable: This server does not host this topic-partition

2020-06-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133253#comment-17133253 ] Robert Metzger commented on FLINK-12030: Another case (just adding it to measure frequency)

[GitHub] [flink] wuchong closed pull request #12487: [FLINK-17829][docs][jdbc] Add documentation for the new JDBC connector.

2020-06-11 Thread GitBox
wuchong closed pull request #12487: URL: https://github.com/apache/flink/pull/12487 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

[jira] [Created] (FLINK-18259) HeartbeatManagerTest.testHeartbeatCluster unstable

2020-06-11 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-18259: -- Summary: HeartbeatManagerTest.testHeartbeatCluster unstable Key: FLINK-18259 URL: https://issues.apache.org/jira/browse/FLINK-18259 Project: Flink Issue

[GitHub] [flink] zentol commented on a change in pull request #12558: [FLINK-17976][docs][k8s/docker] Improvements about custom docker images

2020-06-11 Thread GitBox
zentol commented on a change in pull request #12558: URL: https://github.com/apache/flink/pull/12558#discussion_r438767198 ## File path: docs/ops/deployment/docker.md ## @@ -319,13 +329,57 @@ as described in [how to run the Flink image](#how-to-run-flink-image). ENV

[jira] [Updated] (FLINK-18058) MesosResourceManagerTest.testWorkerStarted:656 » NullPointer

2020-06-11 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-18058: - Affects Version/s: (was: 1.12.0) 1.11.0 >

[GitHub] [flink] flinkbot commented on pull request #12608: [FLINK-18247][table-planner-blink] Fix unstable test: TableITCase.testCollectWithClose

2020-06-11 Thread GitBox
flinkbot commented on pull request #12608: URL: https://github.com/apache/flink/pull/12608#issuecomment-642635512 ## CI report: * 362543e4cad857f4fb61a2c5010f0e6a58cc2b8d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Closed] (FLINK-18058) MesosResourceManagerTest.testWorkerStarted:656 » NullPointer

2020-06-11 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-18058. Fix Version/s: 1.11.0 Resolution: Fixed master:

[GitHub] [flink] flinkbot commented on pull request #12607: [FLINK-18241] Use correct user class loader in OptimizerPlaneEnvironment & StreamPlanEnvironment

2020-06-11 Thread GitBox
flinkbot commented on pull request #12607: URL: https://github.com/apache/flink/pull/12607#issuecomment-642635387 ## CI report: * 3235ac3644d373acad07fd4ab4eca32590daf9a4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #12606: [FLINK-18248][docs] Update data type documentation for 1.11

2020-06-11 Thread GitBox
flinkbot commented on pull request #12606: URL: https://github.com/apache/flink/pull/12606#issuecomment-642635270 ## CI report: * 9616bba566dd903d52490e9ed1b1c4ef2ab3ae0b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #12605: [FLINK-18242][state-backend-rocksdb] Separate RocksDBOptionsFactory from OptionsFactory

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12605: URL: https://github.com/apache/flink/pull/12605#issuecomment-642611275 ## CI report: * 389cda97d6fc7b4473f9b6f32a9126ae23d59259 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12604: [FLINK-18256][orc] Exclude ORC's Hadoop dependency and pull in provided vanilla hadoop in flink-orc

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12604: URL: https://github.com/apache/flink/pull/12604#issuecomment-642611183 ## CI report: * 962a120dbdef84aad1f0db143e88bf1c0ba09b2a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12599: [FLINK-18253][doc][avro] Add filesystem option documentation for Avro

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12599: URL: https://github.com/apache/flink/pull/12599#issuecomment-642546114 ## CI report: * 8b70cb96566c8e71418a49462ecda2a17b092fd2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12527: [FLINK-18173][build] Bundle flink-csv,flink-json,flink-avro jars in lib

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12527: URL: https://github.com/apache/flink/pull/12527#issuecomment-640564258 ## CI report: * a257e64aef0a534241a2ed8e78b733a4df26c354 Azure:

[jira] [Closed] (FLINK-18217) config.sh#extractExecutionResults does not fail on wrong input

2020-06-11 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-18217. Fix Version/s: 1.11.0 Resolution: Fixed master:

[GitHub] [flink] flinkbot commented on pull request #12609: [FLINK-17836][hive][doc] Add document for Hive dim join

2020-06-11 Thread GitBox
flinkbot commented on pull request #12609: URL: https://github.com/apache/flink/pull/12609#issuecomment-642634134 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] zentol merged pull request #12588: [FLINK-18058][mesos][tests] Increase heartbeat interval/timeout

2020-06-11 Thread GitBox
zentol merged pull request #12588: URL: https://github.com/apache/flink/pull/12588 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] zentol merged pull request #12582: [hotfix] Use hyphen instead of underscore when naming plugin's directory

2020-06-11 Thread GitBox
zentol merged pull request #12582: URL: https://github.com/apache/flink/pull/12582 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

[jira] [Assigned] (FLINK-18256) Hadoop is bundled in flink-orc exceptionally

2020-06-11 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-18256: -- Assignee: Yang Wang > Hadoop is bundled in flink-orc exceptionally >

[GitHub] [flink] zentol merged pull request #12553: [FLINK-18217][conf] Explicitly check for empty string

2020-06-11 Thread GitBox
zentol merged pull request #12553: URL: https://github.com/apache/flink/pull/12553 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] lirui-apache commented on pull request #12609: [FLINK-17836][hive][doc] Add document for Hive dim join

2020-06-11 Thread GitBox
lirui-apache commented on pull request #12609: URL: https://github.com/apache/flink/pull/12609#issuecomment-642626212 ![Screen Shot 2020-06-11 at 8 51 25 PM](https://user-images.githubusercontent.com/5210788/84387324-6a92e280-ac25-11ea-83db-971e3c66088c.png)

[jira] [Updated] (FLINK-17836) Add document for Hive dim join

2020-06-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17836: --- Labels: pull-request-available (was: ) > Add document for Hive dim join >

[GitHub] [flink] lirui-apache opened a new pull request #12609: [FLINK-17836][hive][doc] Add document for Hive dim join

2020-06-11 Thread GitBox
lirui-apache opened a new pull request #12609: URL: https://github.com/apache/flink/pull/12609 ## What is the purpose of the change Add doc for Hive table lookup join. ## Brief change log Add doc ## Verifying this change NA ## Does

[jira] [Comment Edited] (FLINK-18209) Replace "charged" words in the Flink codebase.

2020-06-11 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133202#comment-17133202 ] Stephan Ewen edited comment on FLINK-18209 at 6/11/20, 12:47 PM: - +1

<    1   2   3   4   5   6   7   8   >