[GitHub] [flink] yangyichao-mango commented on pull request #12311: [FLINK-17269][docs] Translate new Training Overview to Chinese

2020-06-11 Thread GitBox
yangyichao-mango commented on pull request #12311: URL: https://github.com/apache/flink/pull/12311#issuecomment-642623819 @klion26 Thx for your review. I've rebased my branch. This is an automated message from the Apache

[jira] [Comment Edited] (FLINK-18241) Custom OptionsFactory in user code not working when configured via flink-conf.yaml

2020-06-11 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133229#comment-17133229 ] Dawid Wysakowicz edited comment on FLINK-18241 at 6/11/20, 12:44 PM: -

[jira] [Commented] (FLINK-18241) Custom OptionsFactory in user code not working when configured via flink-conf.yaml

2020-06-11 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133229#comment-17133229 ] Dawid Wysakowicz commented on FLINK-18241: -- The problem is that the

[GitHub] [flink] godfreyhe commented on a change in pull request #12577: [FLINK-17599][docs] Update documents due to FLIP-84

2020-06-11 Thread GitBox
godfreyhe commented on a change in pull request #12577: URL: https://github.com/apache/flink/pull/12577#discussion_r438752625 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/batch/table/TableSinkITCase.scala ## @@

[GitHub] [flink] godfreyhe commented on a change in pull request #12577: [FLINK-17599][docs] Update documents due to FLIP-84

2020-06-11 Thread GitBox
godfreyhe commented on a change in pull request #12577: URL: https://github.com/apache/flink/pull/12577#discussion_r438752625 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/batch/table/TableSinkITCase.scala ## @@

[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-642616312 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-17895) Default value of rows-per-second in datagen can be limited

2020-06-11 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-17895: - Fix Version/s: (was: 1.12.0) 1.11.0 > Default value of rows-per-second

[GitHub] [flink] godfreyhe opened a new pull request #12608: [FLINK-18247][table-planner-blink] Fix unstable test: TableITCase.testCollectWithClose

2020-06-11 Thread GitBox
godfreyhe opened a new pull request #12608: URL: https://github.com/apache/flink/pull/12608 ## What is the purpose of the change *The reason is after calling CloseableIterator#close to cancel job in TableITCase.testCollectWithClose method, the job status may be CANCELED, CANCELING

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

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

[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-642613687 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] godfreyhe commented on a change in pull request #12577: [FLINK-17599][docs] Update documents due to FLIP-84

2020-06-11 Thread GitBox
godfreyhe commented on a change in pull request #12577: URL: https://github.com/apache/flink/pull/12577#discussion_r438747612 ## File path: flink-end-to-end-tests/flink-batch-sql-test/src/main/java/org/apache/flink/sql/tests/BatchSQLTestProgram.java ## @@ -48,7 +48,7 @@ *

[GitHub] [flink] dawidwys opened a new pull request #12607: [FLINK-18241] Use correct user class loader in OptimizerPlaneEnvironment & StreamPlanEnvironment

2020-06-11 Thread GitBox
dawidwys opened a new pull request #12607: URL: https://github.com/apache/flink/pull/12607 ## What is the purpose of the change Use the user classloader when creating `StreamPlanEnvironment` and `OptimizerPlanEnvironment` ## Verifying this change Added test in

[jira] [Commented] (FLINK-18247) Unstable test: TableITCase.testCollectWithClose:122 expected: but was:

2020-06-11 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133223#comment-17133223 ] Jingsong Lee commented on FLINK-18247: -- master: 0b0a6bc60b04e9b838db0e63ae17d0d4885888ae

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

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

[GitHub] [flink] flinkbot 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
flinkbot commented on pull request #12604: URL: https://github.com/apache/flink/pull/12604#issuecomment-642611183 ## CI report: * 962a120dbdef84aad1f0db143e88bf1c0ba09b2a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[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] [Commented] (FLINK-18137) JobMasterTriggerSavepointITCase.testStopJobAfterSavepoint fails with AskTimeoutException

2020-06-11 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133222#comment-17133222 ] Till Rohrmann commented on FLINK-18137: --- The problem seems to be that we call {{onTriggerFailure}}

[GitHub] [flink] JingsongLi merged pull request #12595: [FLINK-18247][table-planner-blink] Fix unstable test: TableITCase.testCollectWithClose

2020-06-11 Thread GitBox
JingsongLi merged pull request #12595: URL: https://github.com/apache/flink/pull/12595 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 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-642609435 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] twalthr opened a new pull request #12606: [FLINK-18248][docs] Update data type documentation for 1.11

2020-06-11 Thread GitBox
twalthr opened a new pull request #12606: URL: https://github.com/apache/flink/pull/12606 ## What is the purpose of the change Updates the data types documentation according to current master. ## Brief change log See commit messages. ## Verifying this change

[jira] [Updated] (FLINK-18248) Update data type documentation for 1.11

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

[jira] [Commented] (FLINK-18251) Cannot create index by time field?

2020-06-11 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133218#comment-17133218 ] Leonard Xu commented on FLINK-18251: Please see  FLINK-18249  for more detail, and this feature is

[jira] [Commented] (FLINK-18226) ResourceManager requests unnecessary new workers if previous workers are allocated but not registered.

2020-06-11 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133219#comment-17133219 ] Till Rohrmann commented on FLINK-18226: --- Yes this sounds like a good plan [~xintongsong]. Maybe

[GitHub] [flink] StephanEwen commented on a change in pull request #12507: [FLINK-18162][connector/common] Serialize the splits in the AddSplitsEvent

2020-06-11 Thread GitBox
StephanEwen commented on a change in pull request #12507: URL: https://github.com/apache/flink/pull/12507#discussion_r438741095 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/source/event/AddSplitEvent.java ## @@ -30,15 +33,23 @@ Licensed to the Apache

[jira] [Commented] (FLINK-18249) Cannot create index by time field?

2020-06-11 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133217#comment-17133217 ] Leonard Xu commented on FLINK-18249: Hi, [~moon_...@foxmail.com]  This feature is works for

[jira] [Commented] (FLINK-15687) Potential test instabilities due to concurrent access to TaskSlotTable.

2020-06-11 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133216#comment-17133216 ] Till Rohrmann commented on FLINK-15687: --- Thanks for fixing this problem [~xintongsong]. Let me

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

2020-06-11 Thread GitBox
zhuzhurk commented on pull request #12278: URL: https://github.com/apache/flink/pull/12278#issuecomment-642606221 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] zhuzhurk removed a comment on pull request #12278: [FLINK-17019][runtime] Fulfill slot requests in request order

2020-06-11 Thread GitBox
zhuzhurk removed a comment on pull request #12278: URL: https://github.com/apache/flink/pull/12278#issuecomment-642479713 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the

[jira] [Created] (FLINK-18258) Implement SHOW PARTITIONS for Hive dialect

2020-06-11 Thread Rui Li (Jira)
Rui Li created FLINK-18258: -- Summary: Implement SHOW PARTITIONS for Hive dialect Key: FLINK-18258 URL: https://issues.apache.org/jira/browse/FLINK-18258 Project: Flink Issue Type: Task

[jira] [Comment Edited] (FLINK-17824) "Resuming Savepoint" e2e stalls indefinitely

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

[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=17133213#comment-17133213 ] Till Rohrmann commented on FLINK-18257: --- I think 1. should not be a problem because we have a

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

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

[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: * d94219e43b9ec7087a1d87aae6cbef395fa9862c 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: * 306dc21418f239ff2e109e025c9e11db1a41bd6d Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/170840652) *

[GitHub] [flink] flinkbot edited a comment on pull request #12510: [FLINK-18039]

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

[GitHub] [flink] flinkbot edited a comment on pull request #12442: [FLINK-12428][docs-zh] Translate the "Event Time" page into Chinese

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

[jira] [Closed] (FLINK-15849) Update SQL-CLIENT document from type to data-type

2020-06-11 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-15849. Resolution: Fixed master: 0028e2e8631d953887f5feef4bfd455b634e0f97 release-1.11: 

[jira] [Commented] (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 commented on FLINK-18209: -- Let's do it. The most visible part is probably the "slave"

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

2020-06-11 Thread GitBox
flinkbot commented on pull request #12605: URL: https://github.com/apache/flink/pull/12605#issuecomment-642599894 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 merged pull request #12567: [FLINK-15849][doc] Update SQL-CLIENT document from type to data-type

2020-06-11 Thread GitBox
JingsongLi merged pull request #12567: URL: https://github.com/apache/flink/pull/12567 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-18241) Custom OptionsFactory in user code not working when configured via flink-conf.yaml

2020-06-11 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-18241: - Component/s: Runtime / Configuration > Custom OptionsFactory in user code not working

[jira] [Updated] (FLINK-18241) Custom OptionsFactory in user code not working when configured via flink-conf.yaml

2020-06-11 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-18241: - Fix Version/s: 1.10.2 1.11.0 > Custom OptionsFactory in user code

[jira] [Assigned] (FLINK-18241) Custom OptionsFactory in user code not working when configured via flink-conf.yaml

2020-06-11 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-18241: -- Assignee: Dawid Wysakowicz > Custom OptionsFactory in user code not working when

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

2020-06-11 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-16448. Resolution: Fixed master: 582d9e43f9e892d194c07bb31458df07fa31c13f release-1.11: 

[jira] [Closed] (FLINK-17733) Add documentation for real-time hive

2020-06-11 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-17733. Resolution: Fixed master: 582d9e43f9e892d194c07bb31458df07fa31c13f release-1.11: 

[jira] [Closed] (FLINK-18237) IllegalArgumentException when reading filesystem partitioned table with stream mode

2020-06-11 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-18237. Resolution: Fixed master: 35e2fca5c9b59a87a6f1a17628daf75d3de575b0 release-1.11: 

[jira] [Commented] (FLINK-18166) JAVA_HOME is not read from .bashrc when start flink

2020-06-11 Thread appleyuchi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133189#comment-17133189 ] appleyuchi commented on FLINK-18166: Thanks for your replies. I'm sure it's ok in ubuntu19.10

[GitHub] [flink] JingsongLi merged pull request #12537: [FLINK-17733][FLINK-16448][hive][doc] Adjust Hive doc & Add documentation for real-time hive

2020-06-11 Thread GitBox
JingsongLi merged pull request #12537: URL: https://github.com/apache/flink/pull/12537 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] [Closed] (FLINK-18227) official example stuck in flink shell(local mode)

2020-06-11 Thread appleyuchi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] appleyuchi closed FLINK-18227. -- Resolution: Fixed > official example stuck in flink shell(local mode) >

[jira] [Updated] (FLINK-18242) Custom OptionsFactory settings seem to have no effect on RocksDB

2020-06-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18242: --- Labels: pull-request-available (was: ) > Custom OptionsFactory settings seem to have no

[GitHub] [flink] carp84 opened a new pull request #12605: [FLINK-18242][state-backend-rocksdb] Separate RocksDBOptionsFactory from OptionsFactory

2020-06-11 Thread GitBox
carp84 opened a new pull request #12605: URL: https://github.com/apache/flink/pull/12605 ## What is the purpose of the change Completely separate `RocksDBOptionsFactory` from `OptionsFactory` to prevent silent failure of setting RocksDB options by extending

[GitHub] [flink] flinkbot 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
flinkbot commented on pull request #12604: URL: https://github.com/apache/flink/pull/12604#issuecomment-642590657 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 opened a new 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 opened a new pull request #12604: URL: https://github.com/apache/flink/pull/12604 ## What is the purpose of the change The hadoop-common and hadoop-hdfs have been bundled into the flink-orc_2.11-1.11-SNAPSHOT-jar-with-dependencies.jar. Since we suggest our

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

2020-06-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18256: --- Labels: pull-request-available (was: ) > Hadoop is bundled in flink-orc exceptionally >

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

2020-06-11 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-18257: --- Priority: Blocker (was: Major) > MasterStateSnapshot future may not be completed >

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

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

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

2020-06-11 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-18257: --- Fix Version/s: (was: 1.12.0) 1.11.0 > MasterStateSnapshot future may

[GitHub] [flink] JingsongLi merged pull request #12576: [FLINK-18237][fs-connector] Exception when reading filesystem partitioned table with stream mode

2020-06-11 Thread GitBox
JingsongLi merged pull request #12576: URL: https://github.com/apache/flink/pull/12576 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] wuchong commented on a change in pull request #12599: [FLINK-18253][doc][avro] Add filesystem option documentation for Avro

2020-06-11 Thread GitBox
wuchong commented on a change in pull request #12599: URL: https://github.com/apache/flink/pull/12599#discussion_r438721524 ## File path: docs/dev/table/connectors/formats/avro.md ## @@ -97,6 +97,13 @@ Format Options String Specify what format to use, here should

[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: * a1304a3c20a9ba848ddc3308d6da9ecab8a85a5b Azure:

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

2020-06-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-18257: --- Component/s: Runtime / Checkpointing > MasterStateSnapshot future may not be completed >

[jira] [Comment Edited] (FLINK-18137) JobMasterTriggerSavepointITCase.testStopJobAfterSavepoint fails with AskTimeoutException

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

[jira] [Updated] (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 updated FLINK-18257: -- Description: From 

[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_r438713863 ## 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] [Commented] (FLINK-18242) Custom OptionsFactory settings seem to have no effect on RocksDB

2020-06-11 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133170#comment-17133170 ] Yu Li commented on FLINK-18242: --- I agree that making `DefaultConfigurableOptionsFactory` final is not a

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

2020-06-11 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-18257: - Summary: MasterStateSnapshot future may not be completed Key: FLINK-18257 URL: https://issues.apache.org/jira/browse/FLINK-18257 Project: Flink

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

2020-06-11 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133168#comment-17133168 ] Yang Wang commented on FLINK-18256: --- [~lzljs3620320] Could you assign this ticket to me? I will attach

[jira] [Commented] (FLINK-17978) Test Hadoop dependency change

2020-06-11 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133167#comment-17133167 ] Yang Wang commented on FLINK-17978: --- I have used the following command to scan all the jars and find

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

2020-06-11 Thread Yang Wang (Jira)
Yang Wang created FLINK-18256: - Summary: Hadoop is bundled in flink-orc exceptionally Key: FLINK-18256 URL: https://issues.apache.org/jira/browse/FLINK-18256 Project: Flink Issue Type: Bug

[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 #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: * a1304a3c20a9ba848ddc3308d6da9ecab8a85a5b 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 #12603: [1.11][FLINK-16375][table] Reintroduce registerTable[Source/Sink] methods for table env

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12603: URL: https://github.com/apache/flink/pull/12603#issuecomment-642565785 ## CI report: * c72ad51588a4ac9f2f86dea570c5154988cfff68 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: * 306dc21418f239ff2e109e025c9e11db1a41bd6d Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/170840652) *

[GitHub] [flink] flinkbot edited a comment on pull request #12600: [FLINK-16375][table] Reintroduce registerTable[Source/Sink] methods for table env

2020-06-11 Thread GitBox
flinkbot edited a comment on pull request #12600: URL: https://github.com/apache/flink/pull/12600#issuecomment-642557137 ## CI report: * b30ed347f6232e005ed27a039cd18408dad8a5a4 UNKNOWN * 160d7fc0995727aa03ac83231424513020b4dcf6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12602: [FLINK-18140][doc][orc] Add documentation for ORC format

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

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

2020-06-11 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133157#comment-17133157 ] Aljoscha Krettek commented on FLINK-18209: -- I don't think we should rush changing "master".

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

2020-06-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-18217: --- Component/s: Deployment / Scripts > config.sh#extractExecutionResults does not fail on

[jira] [Updated] (FLINK-18049) The Flink kafka consumer job will be interrupted if the upstream kafka producer change the AVRO schema

2020-06-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-18049: --- Component/s: Connectors / Kafka > The Flink kafka consumer job will be interrupted if the

[jira] [Comment Edited] (FLINK-18137) JobMasterTriggerSavepointITCase.testStopJobAfterSavepoint fails with AskTimeoutException

2020-06-11 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133144#comment-17133144 ] Roman Khachatryan edited comment on FLINK-18137 at 6/11/20, 10:58 AM:

[jira] [Commented] (FLINK-18255) Add API annotations to RocksDB user-facing classes

2020-06-11 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133152#comment-17133152 ] Yu Li commented on FLINK-18255: --- +1, I think this is a long existing issue that should be addressed. >

[jira] [Updated] (FLINK-18039) Change SourceCoordinator to handle resetToCheckpoint() call after started.

2020-06-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-18039: --- Component/s: API / DataStream > Change SourceCoordinator to handle resetToCheckpoint() call

[jira] [Commented] (FLINK-18166) JAVA_HOME is not read from .bashrc when start flink

2020-06-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133153#comment-17133153 ] Robert Metzger commented on FLINK-18166: Please validate that JAVA_HOME is set in your shell by

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

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

[jira] [Created] (FLINK-18255) Add API annotations to RocksDB user-facing classes

2020-06-11 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-18255: --- Summary: Add API annotations to RocksDB user-facing classes Key: FLINK-18255 URL: https://issues.apache.org/jira/browse/FLINK-18255 Project: Flink Issue Type:

[jira] [Updated] (FLINK-18166) JAVA_HOME is not read from .bashrc when start flink

2020-06-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-18166: --- Component/s: Deployment / Scripts > JAVA_HOME is not read from .bashrc when start flink >

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

2020-06-11 Thread GitBox
aljoscha commented on a change in pull request #12297: URL: https://github.com/apache/flink/pull/12297#discussion_r438698136 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/TumblingProcessingTimeWindows.java ## @@ -107,7

[jira] [Updated] (FLINK-18080) Translate the "Kerberos Authentication Setup and Configuration" page into Chinese

2020-06-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-18080: --- Component/s: Documentation chinese-translation > Translate the "Kerberos

[jira] [Updated] (FLINK-18081) Fix broken links in "Kerberos Authentication Setup and Configuration" doc

2020-06-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-18081: --- Component/s: Runtime / Configuration Documentation > Fix broken links in

[jira] [Updated] (FLINK-18227) official example stuck in flink shell(local mode)

2020-06-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-18227: --- Component/s: Scala Shell > official example stuck in flink shell(local mode) >

[jira] [Updated] (FLINK-18089) Add the network zero-copy test into the azure E2E pipeline

2020-06-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-18089: --- Component/s: Runtime / Network Build System / Azure Pipelines > Add the

[jira] [Commented] (FLINK-18137) JobMasterTriggerSavepointITCase.testStopJobAfterSavepoint fails with AskTimeoutException

2020-06-11 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133144#comment-17133144 ] Roman Khachatryan commented on FLINK-18137: --- I think there are several issues that can this

[jira] [Updated] (FLINK-17788) scala shell in yarn mode is broken

2020-06-11 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17788: --- Fix Version/s: 1.12.0 1.10.2 1.11.0 > scala shell in

[jira] [Assigned] (FLINK-17788) scala shell in yarn mode is broken

2020-06-11 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-17788: -- Assignee: Kostas Kloudas > scala shell in yarn mode is broken >

[GitHub] [flink] flinkbot commented on pull request #12603: [1.11][FLINK-16375][table] Reintroduce registerTable[Source/Sink] methods for table env

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

[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: * d94219e43b9ec7087a1d87aae6cbef395fa9862c 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: * 306dc21418f239ff2e109e025c9e11db1a41bd6d Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/170840652) *

[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 commented on pull request #12602: [FLINK-18140][doc][orc] Add documentation for ORC format

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

<    1   2   3   4   5   6   7   8   >