[jira] [Closed] (FLINK-14298) Change LeaderContender#getAddress into LeaderContender#getDescription

[ https://issues.apache.org/jira/browse/FLINK-14298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-14298. - Resolution: Done Done via 4813a2396cc7a1a054b2c46c673ea96ced982523 > Change

[jira] [Closed] (FLINK-14307) Extract JobGraphWriter from JobGraphStore

[ https://issues.apache.org/jira/browse/FLINK-14307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-14307. - Resolution: Done Done via cda6dc0c44239aa7a36105988328de5744aea125 > Extract JobGraphWriter

[GitHub] [flink] tillrohrmann closed pull request #9830: [FLINK-14307] Extract JobGraphWriter from JobGraphStore

tillrohrmann closed pull request #9830: [FLINK-14307] Extract JobGraphWriter from JobGraphStore URL: https://github.com/apache/flink/pull/9830 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] tillrohrmann closed pull request #9821: [FLINK-14298] Replace LeaderContender#getAddress with #getDescription

tillrohrmann closed pull request #9821: [FLINK-14298] Replace LeaderContender#getAddress with #getDescription URL: https://github.com/apache/flink/pull/9821 This is an automated message from the Apache Git Service. To

[GitHub] [flink] zentol commented on a change in pull request #9867: [FLINK-7958][metrics] Reporters provide default delimiter

zentol commented on a change in pull request #9867: [FLINK-7958][metrics] Reporters provide default delimiter URL: https://github.com/apache/flink/pull/9867#discussion_r333832960 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricRegistryImpl.java

[GitHub] [flink] flinkbot edited a comment on issue #9852: [FLINK-14343][coordination] Remove uncompleted YARNHighAvailabilityService

flinkbot edited a comment on issue #9852: [FLINK-14343][coordination] Remove uncompleted YARNHighAvailabilityService URL: https://github.com/apache/flink/pull/9852#issuecomment-539417112 ## CI report: * 451eb3a627d34d1b3592a5d149e53e2810591465 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9852: [FLINK-14343][coordination] Remove uncompleted YARNHighAvailabilityService

flinkbot edited a comment on issue #9852: [FLINK-14343][coordination] Remove uncompleted YARNHighAvailabilityService URL: https://github.com/apache/flink/pull/9852#issuecomment-539417112 ## CI report: * 451eb3a627d34d1b3592a5d149e53e2810591465 : FAILURE

[GitHub] [flink] xintongsong commented on issue #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese

xintongsong commented on issue #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese URL: https://github.com/apache/flink/pull/9805#issuecomment-540896884 Thanks @wuchong, I do have other concerns. I've left several comments, regarding translations that

[GitHub] [flink] zhuzhurk commented on a change in pull request #9860: [FLINK-14331][runtime] Reset vertices right after they transition to terminated states

zhuzhurk commented on a change in pull request #9860: [FLINK-14331][runtime] Reset vertices right after they transition to terminated states URL: https://github.com/apache/flink/pull/9860#discussion_r333820137 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #9860: [FLINK-14331][runtime] Reset vertices right after they transition to terminated states

zhuzhurk commented on a change in pull request #9860: [FLINK-14331][runtime] Reset vertices right after they transition to terminated states URL: https://github.com/apache/flink/pull/9860#discussion_r333820162 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #9860: [FLINK-14331][runtime] Reset vertices right after they transition to terminated states

zhuzhurk commented on a change in pull request #9860: [FLINK-14331][runtime] Reset vertices right after they transition to terminated states URL: https://github.com/apache/flink/pull/9860#discussion_r333560883 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #9860: [FLINK-14331][runtime] Reset vertices right after they transition to terminated states

zhuzhurk commented on a change in pull request #9860: [FLINK-14331][runtime] Reset vertices right after they transition to terminated states URL: https://github.com/apache/flink/pull/9860#discussion_r333554475 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #9860: [FLINK-14331][runtime] Reset vertices right after they transition to terminated states

zhuzhurk commented on a change in pull request #9860: [FLINK-14331][runtime] Reset vertices right after they transition to terminated states URL: https://github.com/apache/flink/pull/9860#discussion_r333558658 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9880: [FLINK-14347][test] Filter out expected exception string in YARN tests

flinkbot edited a comment on issue #9880: [FLINK-14347][test] Filter out expected exception string in YARN tests URL: https://github.com/apache/flink/pull/9880#issuecomment-540877244 ## CI report: * efc1356715ea531b4b3e636fe2551a12b3472032 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9852: [FLINK-14343][coordination] Remove uncompleted YARNHighAvailabilityService

flinkbot edited a comment on issue #9852: [FLINK-14343][coordination] Remove uncompleted YARNHighAvailabilityService URL: https://github.com/apache/flink/pull/9852#issuecomment-539417112 ## CI report: * 451eb3a627d34d1b3592a5d149e53e2810591465 : FAILURE

[GitHub] [flink] wuchong commented on issue #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese

wuchong commented on issue #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese URL: https://github.com/apache/flink/pull/9805#issuecomment-540891917 I think it should be FLINK-11635. I updated the title. Hi @xintongsong , do you have other concerns on

[GitHub] [flink] wuchong commented on a change in pull request #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect

wuchong commented on a change in pull request #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect URL: https://github.com/apache/flink/pull/9866#discussion_r333816871 ## File path: docs/dev/table/connect.md

[GitHub] [flink] wuchong commented on a change in pull request #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect

wuchong commented on a change in pull request #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect URL: https://github.com/apache/flink/pull/9866#discussion_r333816597 ## File path: docs/dev/table/connect.md

[GitHub] [flink] wuchong commented on a change in pull request #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect

wuchong commented on a change in pull request #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect URL: https://github.com/apache/flink/pull/9866#discussion_r333817211 ## File path:

[jira] [Commented] (FLINK-14359) Create a module called flink-sql-connector-hbase to shade HBase

[ https://issues.apache.org/jira/browse/FLINK-14359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16949112#comment-16949112 ] Zheng Hu commented on FLINK-14359: -- [~jark], Thanks for your information, let me have a try.. >

[jira] [Created] (FLINK-14364) Allow comments fail when not ignore parse errors in CsvRowDeserializationSchema

Jingsong Lee created FLINK-14364: Summary: Allow comments fail when not ignore parse errors in CsvRowDeserializationSchema Key: FLINK-14364 URL: https://issues.apache.org/jira/browse/FLINK-14364

[jira] [Commented] (FLINK-14364) Allow comments fail when not ignore parse errors in CsvRowDeserializationSchema

[ https://issues.apache.org/jira/browse/FLINK-14364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16949111#comment-16949111 ] Jingsong Lee commented on FLINK-14364: -- CC: [~twalthr] > Allow comments fail when not ignore parse

[jira] [Comment Edited] (FLINK-14359) Create a module called flink-sql-connector-hbase to shade HBase

[ https://issues.apache.org/jira/browse/FLINK-14359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16949108#comment-16949108 ] Jark Wu edited comment on FLINK-14359 at 10/11/19 3:38 AM: --- A big +1 to adding

[jira] [Commented] (FLINK-14359) Create a module called flink-sql-connector-hbase to shade HBase

[ https://issues.apache.org/jira/browse/FLINK-14359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16949108#comment-16949108 ] Jark Wu commented on FLINK-14359: - A big +1 to adding e2e tests for HBase. I don't have much experience

[GitHub] [flink] TisonKun commented on issue #9852: [FLINK-14343][coordination] Remove uncompleted YARNHighAvailabilityService

TisonKun commented on issue #9852: [FLINK-14343][coordination] Remove uncompleted YARNHighAvailabilityService URL: https://github.com/apache/flink/pull/9852#issuecomment-540886234 Hi @tillrohrmann , as reached consensus on mailing list, please take a look at this patch. I feel the

[GitHub] [flink] flinkbot edited a comment on issue #9782: [FLINK-14241][test] Add ARM installation steps for flink e2e container tests

flinkbot edited a comment on issue #9782: [FLINK-14241][test] Add ARM installation steps for flink e2e container tests URL: https://github.com/apache/flink/pull/9782#issuecomment-535826739 ## CI report: * d48b95539070679639d5e8c4e640b9a710d7 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9768: [FLINK-14086][test][core] Add OperatingArchitecture Enum

flinkbot edited a comment on issue #9768: [FLINK-14086][test][core] Add OperatingArchitecture Enum URL: https://github.com/apache/flink/pull/9768#issuecomment-534899022 ## CI report: * 51ae12da735fd7fd1bdadd282839c9bfe7b80146 : SUCCESS

[GitHub] [flink] xintongsong commented on a change in pull request #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools

xintongsong commented on a change in pull request #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools URL: https://github.com/apache/flink/pull/9693#discussion_r333814167 ## File path:

[jira] [Assigned] (FLINK-14356) Introduce "single-field" format to (de)serialize message to a single field

[ https://issues.apache.org/jira/browse/FLINK-14356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-14356: --- Assignee: jinfeng > Introduce "single-field" format to (de)serialize message to a single field >

[jira] [Commented] (FLINK-14356) Introduce "single-field" format to (de)serialize message to a single field

[ https://issues.apache.org/jira/browse/FLINK-14356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16949097#comment-16949097 ] Jark Wu commented on FLINK-14356: - Hi [~twalthr], I think STRING is also a commonly used case if the

[GitHub] [flink] zhuzhurk commented on issue #9872: [FLINK-14291][runtime, tests] Add test coverage to DefaultScheduler

zhuzhurk commented on issue #9872: [FLINK-14291][runtime,tests] Add test coverage to DefaultScheduler URL: https://github.com/apache/flink/pull/9872#issuecomment-540883672 Thanks for addressing the comment @GJL. The change looks good to me. +1 to merge it.

[GitHub] [flink] flinkbot edited a comment on issue #9880: [FLINK-14347][test] Filter out expected exception string in YARN tests

flinkbot edited a comment on issue #9880: [FLINK-14347][test] Filter out expected exception string in YARN tests URL: https://github.com/apache/flink/pull/9880#issuecomment-540877244 ## CI report: * efc1356715ea531b4b3e636fe2551a12b3472032 : PENDING

[GitHub] [flink] xintongsong commented on a change in pull request #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools

xintongsong commented on a change in pull request #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools URL: https://github.com/apache/flink/pull/9693#discussion_r333812031 ## File path:

[jira] [Commented] (FLINK-7151) Add a basic function SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16949093#comment-16949093 ] Jark Wu commented on FLINK-7151: I think it's great to take Python into account in the first stage! I

[GitHub] [flink] zhuzhurk commented on a change in pull request #9872: [FLINK-14291][runtime, tests] Add test coverage to DefaultScheduler

zhuzhurk commented on a change in pull request #9872: [FLINK-14291][runtime,tests] Add test coverage to DefaultScheduler URL: https://github.com/apache/flink/pull/9872#discussion_r333811817 ## File path:

[jira] [Commented] (FLINK-14359) Create a module called flink-sql-connector-hbase to shade HBase

[ https://issues.apache.org/jira/browse/FLINK-14359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16949091#comment-16949091 ] Zheng Hu commented on FLINK-14359: -- One question: should we shaded the hadoop dependencies into

[GitHub] [flink] xintongsong commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics

xintongsong commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#discussion_r333809794 ## File path:

[jira] [Commented] (FLINK-13417) Bump Zookeeper to 3.5.5

[ https://issues.apache.org/jira/browse/FLINK-13417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16949076#comment-16949076 ] Zili Chen commented on FLINK-13417: --- Hi [~sewen], [here|https://github.com/apache/flink/pull/9840] is

[GitHub] [flink] flinkbot commented on issue #9880: [FLINK-14347][test] Filter out expected exception string in YARN tests

flinkbot commented on issue #9880: [FLINK-14347][test] Filter out expected exception string in YARN tests URL: https://github.com/apache/flink/pull/9880#issuecomment-540877244 ## CI report: * efc1356715ea531b4b3e636fe2551a12b3472032 : UNKNOWN Bot commands The

[GitHub] [flink] klion26 commented on a change in pull request #9873: [FLINK-14336][DataStream] Log Exception for failed checkpoint on TaskExecutor side

klion26 commented on a change in pull request #9873: [FLINK-14336][DataStream] Log Exception for failed checkpoint on TaskExecutor side URL: https://github.com/apache/flink/pull/9873#discussion_r333807609 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9782: [FLINK-14241][test] Add ARM installation steps for flink e2e container tests

flinkbot edited a comment on issue #9782: [FLINK-14241][test] Add ARM installation steps for flink e2e container tests URL: https://github.com/apache/flink/pull/9782#issuecomment-535826739 ## CI report: * d48b95539070679639d5e8c4e640b9a710d7 : FAILURE

[jira] [Commented] (FLINK-14347) YARNSessionFIFOITCase.checkForProhibitedLogContents found a log with prohibited string

[ https://issues.apache.org/jira/browse/FLINK-14347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16949065#comment-16949065 ] Zili Chen commented on FLINK-14347: --- [~trohrmann] PR submitted. >

[jira] [Commented] (FLINK-14347) YARNSessionFIFOITCase.checkForProhibitedLogContents found a log with prohibited string

[ https://issues.apache.org/jira/browse/FLINK-14347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16949064#comment-16949064 ] Zili Chen commented on FLINK-14347: --- Thanks for your information [~fly_in_gis]! >

[jira] [Updated] (FLINK-14289) Remove Optional fields from RecordWriter relevant classes

[ https://issues.apache.org/jira/browse/FLINK-14289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-14289: - Affects Version/s: 1.8.0 1.9.0 > Remove Optional fields from RecordWriter

[jira] [Updated] (FLINK-14289) Remove Optional fields from RecordWriter relevant classes

[ https://issues.apache.org/jira/browse/FLINK-14289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-14289: - Fix Version/s: 1.10.0 > Remove Optional fields from RecordWriter relevant classes >

[jira] [Commented] (FLINK-14347) YARNSessionFIFOITCase.checkForProhibitedLogContents found a log with prohibited string

[ https://issues.apache.org/jira/browse/FLINK-14347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16949063#comment-16949063 ] Yang Wang commented on FLINK-14347: --- When there is `ApplicationAttemptNotFoundException` in

[jira] [Resolved] (FLINK-14289) Remove Optional fields from RecordWriter relevant classes

[ https://issues.apache.org/jira/browse/FLINK-14289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang resolved FLINK-14289. -- Resolution: Fixed Fixed in master : 71e440d5f62fbd43df18f999b7818de48a279eb0 > Remove Optional

[GitHub] [flink] KarmaGYZ commented on a change in pull request #9873: [FLINK-14336][DataStream] Log Exception for failed checkpoint on TaskExecutor side

KarmaGYZ commented on a change in pull request #9873: [FLINK-14336][DataStream] Log Exception for failed checkpoint on TaskExecutor side URL: https://github.com/apache/flink/pull/9873#discussion_r333804415 ## File path:

[GitHub] [flink] zhijiangW merged pull request #9818: [FLINK-14289][runtime] Remove Optional fields from RecordWriter relevant classes

zhijiangW merged pull request #9818: [FLINK-14289][runtime] Remove Optional fields from RecordWriter relevant classes URL: https://github.com/apache/flink/pull/9818 This is an automated message from the Apache Git Service.

[GitHub] [flink] xintongsong commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics

xintongsong commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#discussion_r333803624 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9782: [FLINK-14241][test] Add ARM installation steps for flink e2e container tests

flinkbot edited a comment on issue #9782: [FLINK-14241][test] Add ARM installation steps for flink e2e container tests URL: https://github.com/apache/flink/pull/9782#issuecomment-535826739 ## CI report: * d48b95539070679639d5e8c4e640b9a710d7 : FAILURE

[GitHub] [flink] flinkbot commented on issue #9880: [FLINK-14347][test] Filter out expected exception string in YARN tests

flinkbot commented on issue #9880: [FLINK-14347][test] Filter out expected exception string in YARN tests URL: https://github.com/apache/flink/pull/9880#issuecomment-540870200 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] flinkbot edited a comment on issue #9768: [FLINK-14086][test][core] Add OperatingArchitecture Enum

flinkbot edited a comment on issue #9768: [FLINK-14086][test][core] Add OperatingArchitecture Enum URL: https://github.com/apache/flink/pull/9768#issuecomment-534899022 ## CI report: * 51ae12da735fd7fd1bdadd282839c9bfe7b80146 : PENDING

[GitHub] [flink] xintongsong commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics

xintongsong commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#discussion_r333803202 ## File path:

[GitHub] [flink] TisonKun opened a new pull request #9880: [FLINK-14347][test] Filter out expected exception string in YARN tests

TisonKun opened a new pull request #9880: [FLINK-14347][test] Filter out expected exception string in YARN tests URL: https://github.com/apache/flink/pull/9880 ## What is the purpose of the change Filter out expected exception string in YARN tests, especially

[jira] [Updated] (FLINK-14347) YARNSessionFIFOITCase.checkForProhibitedLogContents found a log with prohibited string

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

[GitHub] [flink] xintongsong commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics

xintongsong commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#discussion_r333802226 ## File path: flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java

[GitHub] [flink] xintongsong commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics

xintongsong commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#discussion_r333802199 ## File path: flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java

[jira] [Commented] (FLINK-14359) Create a module called flink-sql-connector-hbase to shade HBase

[ https://issues.apache.org/jira/browse/FLINK-14359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16949056#comment-16949056 ] Zheng Hu commented on FLINK-14359: -- Creating the flink-sql-connector-hbase module is easy, the problem

[GitHub] [flink] wangxiyuan commented on issue #9768: [FLINK-14086][test][core] Add OperatingArchitecture Enum

wangxiyuan commented on issue #9768: [FLINK-14086][test][core] Add OperatingArchitecture Enum URL: https://github.com/apache/flink/pull/9768#issuecomment-540868466 @flinkbot run travis This is an automated message from the

[jira] [Assigned] (FLINK-14347) YARNSessionFIFOITCase.checkForProhibitedLogContents found a log with prohibited string

[ https://issues.apache.org/jira/browse/FLINK-14347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-14347: - Assignee: Zili Chen > YARNSessionFIFOITCase.checkForProhibitedLogContents found a log with >

[GitHub] [flink] openinx commented on issue #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect

openinx commented on issue #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect URL: https://github.com/apache/flink/pull/9866#issuecomment-540867483 Ping @wuchong @JingsongLi , Any other concerns ? Thanks.

[GitHub] [flink] openinx commented on issue #9875: [hotfix][docs] Fix the incorrect scala checkstyle configure file path

openinx commented on issue #9875: [hotfix][docs] Fix the incorrect scala checkstyle configure file path URL: https://github.com/apache/flink/pull/9875#issuecomment-540867230 The document change should not affect the CI test. Any other concerns ? @rmetzger

[GitHub] [flink] Henvealf commented on issue #9805: [FLINK-14227] translate dev/stream/state/checkpointing into Chinese

Henvealf commented on issue #9805: [FLINK-14227] translate dev/stream/state/checkpointing into Chinese URL: https://github.com/apache/flink/pull/9805#issuecomment-540865855 > Hi @Henvealf , this is not a pull request for FLINK-14227. Please correct it in the title. Thanks. Which

[jira] [Updated] (FLINK-14341) Flink-python builds with failure: no such option: --prefix

[ https://issues.apache.org/jira/browse/FLINK-14341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14341: Affects Version/s: (was: 1.9.0) > Flink-python builds with failure: no such option: --prefix

[jira] [Closed] (FLINK-14341) Flink-python builds with failure: no such option: --prefix

[ https://issues.apache.org/jira/browse/FLINK-14341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14341. --- Resolution: Fixed > Flink-python builds with failure: no such option: --prefix >

[jira] [Commented] (FLINK-14341) Flink-python builds with failure: no such option: --prefix

[ https://issues.apache.org/jira/browse/FLINK-14341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16949046#comment-16949046 ] Hequn Cheng commented on FLINK-14341: - Fixed in 1.10.0 via: 2750b2ea29c440c6e699f756e5cd3431653fc49f

[jira] [Commented] (FLINK-14341) Flink-python builds with failure: no such option: --prefix

[ https://issues.apache.org/jira/browse/FLINK-14341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16949044#comment-16949044 ] Hequn Cheng commented on FLINK-14341: - Change jira type to "improvement" as previously, only pip

[jira] [Updated] (FLINK-14341) Flink-python builds with failure: no such option: --prefix

[ https://issues.apache.org/jira/browse/FLINK-14341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14341: Issue Type: Improvement (was: Bug) > Flink-python builds with failure: no such option: --prefix

[jira] [Updated] (FLINK-14341) Flink-python builds with failure: no such option: --prefix

[ https://issues.apache.org/jira/browse/FLINK-14341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14341: Fix Version/s: 1.10.0 > Flink-python builds with failure: no such option: --prefix >

[jira] [Assigned] (FLINK-14341) Flink-python builds with failure: no such option: --prefix

[ https://issues.apache.org/jira/browse/FLINK-14341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14341: --- Assignee: liupengcheng > Flink-python builds with failure: no such option: --prefix >

[GitHub] [flink] hequn8128 closed pull request #9851: [FLINK-14341][python] Support pip version of 7.1.x for gen_protos.py

hequn8128 closed pull request #9851: [FLINK-14341][python] Support pip version of 7.1.x for gen_protos.py URL: https://github.com/apache/flink/pull/9851 This is an automated message from the Apache Git Service. To respond

[jira] [Commented] (FLINK-14309) Kafka09ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-14309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16948921#comment-16948921 ] Jiangjie Qin commented on FLINK-14309: -- Patch merged to master. githash:

[jira] [Resolved] (FLINK-14309) Kafka09ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-14309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved FLINK-14309. -- Resolution: Fixed >

[GitHub] [flink] becketqin commented on issue #9824: [FLINK-14302] FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` request if `newPartitionsInTransaction` is empty when enable EoS

becketqin commented on issue #9824: [FLINK-14302] FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` request if `newPartitionsInTransaction` is empty when enable EoS URL: https://github.com/apache/flink/pull/9824#issuecomment-540767473 @tony810430 Have you tried to

[GitHub] [flink] becketqin merged pull request #9835: [FLINK-14309] [test-stability] Add retries and acks config in producer test

becketqin merged pull request #9835: [FLINK-14309] [test-stability] Add retries and acks config in producer test URL: https://github.com/apache/flink/pull/9835 This is an automated message from the Apache Git Service. To

[GitHub] [flink] becketqin commented on issue #9835: [FLINK-14309] [test-stability] Add retries and acks config in producer test

becketqin commented on issue #9835: [FLINK-14309] [test-stability] Add retries and acks config in producer test URL: https://github.com/apache/flink/pull/9835#issuecomment-540763771 @flinkbot approve all This is an automated

[GitHub] [flink] flinkbot edited a comment on issue #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools

flinkbot edited a comment on issue #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools URL: https://github.com/apache/flink/pull/9693#issuecomment-531808855 ## CI report: * 62ad65e31df8f36747991513ab89504126758af6 : CANCELED

[jira] [Assigned] (FLINK-14309) Kafka09ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-14309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-14309: Assignee: Jiayi Liao >

[jira] [Commented] (FLINK-14309) Kafka09ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-14309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16948912#comment-16948912 ] Jiangjie Qin commented on FLINK-14309: -- [~wind_ljy] Sorry for the late reply. I agree. In any case,

[GitHub] [flink] flinkbot edited a comment on issue #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools

flinkbot edited a comment on issue #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools URL: https://github.com/apache/flink/pull/9693#issuecomment-531808855 ## CI report: * 62ad65e31df8f36747991513ab89504126758af6 : CANCELED

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r333559910 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r333551907 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r333690736 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r333556130 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r333564050 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r333690977 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r333550391 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r333571342 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r333692391 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r333571648 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r333574964 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools

flinkbot edited a comment on issue #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools URL: https://github.com/apache/flink/pull/9693#issuecomment-531808855 ## CI report: * 62ad65e31df8f36747991513ab89504126758af6 : CANCELED

[GitHub] [flink] flinkbot edited a comment on issue #9830: [FLINK-14307] Extract JobGraphWriter from JobGraphStore

flinkbot edited a comment on issue #9830: [FLINK-14307] Extract JobGraphWriter from JobGraphStore URL: https://github.com/apache/flink/pull/9830#issuecomment-537017897 ## CI report: * ed86e6d768a1353423d969e6c9dcf5fd967c4f19 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9821: [FLINK-14298] Replace LeaderContender#getAddress with #getDescription

flinkbot edited a comment on issue #9821: [FLINK-14298] Replace LeaderContender#getAddress with #getDescription URL: https://github.com/apache/flink/pull/9821#issuecomment-536618253 ## CI report: * 9ca9df3eaa22965444373a3b6142798ca5559f50 : FAILURE

[GitHub] [flink] tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics

tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#discussion_r333652584 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics

tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#discussion_r333660886 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics

tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#discussion_r333658742 ## File path: flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java

[GitHub] [flink] tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics

tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#discussion_r333659120 ## File path: flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java

[GitHub] [flink] tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics

tillrohrmann commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#discussion_r333664352 ## File path:

  1   2   3   4   >