[jira] [Updated] (FLINK-16300) Rework SchedulerTestUtils with testing classes to replace mockito usages

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

[GitHub] [flink] dianfu commented on a change in pull request #11220: [FLINK-16249][python][ml] Add interfaces for Params, ParamInfo and WithParams

dianfu commented on a change in pull request #11220: [FLINK-16249][python][ml] Add interfaces for Params, ParamInfo and WithParams URL: https://github.com/apache/flink/pull/11220#discussion_r384958403 ## File path: flink-python/setup.py ## @@ -224,7 +224,7 @@ def

[GitHub] [flink] zhuzhurk opened a new pull request #11230: [FLINK-16300] Rework SchedulerTestUtils with testing classes to replace mockito usages

zhuzhurk opened a new pull request #11230: [FLINK-16300] Rework SchedulerTestUtils with testing classes to replace mockito usages URL: https://github.com/apache/flink/pull/11230 ## What is the purpose of the change Mockito is used in SchedulerTestUtils to mock ExecutionVertex and

[GitHub] [flink] dianfu commented on a change in pull request #11220: [FLINK-16249][python][ml] Add interfaces for Params, ParamInfo and WithParams

dianfu commented on a change in pull request #11220: [FLINK-16249][python][ml] Add interfaces for Params, ParamInfo and WithParams URL: https://github.com/apache/flink/pull/11220#discussion_r384961528 ## File path: flink-python/setup.py ## @@ -224,7 +224,7 @@ def

[jira] [Updated] (FLINK-16300) Rework SchedulerTestUtils with testing classes to replace mockito usages

[ https://issues.apache.org/jira/browse/FLINK-16300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-16300: Description: Mockito is used in SchedulerTestUtils to mock ExecutionVertex and Execution for testing. It

[jira] [Updated] (FLINK-16300) Rework SchedulerTestUtils with testing classes to replace mockito usages

[ https://issues.apache.org/jira/browse/FLINK-16300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-16300: Summary: Rework SchedulerTestUtils with testing classes to replace mockito usages (was: Reworks

[GitHub] [flink] flinkbot edited a comment on issue #11213: [FLINK-16276][tests] Introduce a builder and factory methods to create DefaultScheduler for testing

flinkbot edited a comment on issue #11213: [FLINK-16276][tests] Introduce a builder and factory methods to create DefaultScheduler for testing URL: https://github.com/apache/flink/pull/11213#issuecomment-590853060 ## CI report: * b31d7fab8da81827ca063075427a3737377bf0ed UNKNOWN

[GitHub] [flink] dianfu commented on a change in pull request #11220: [FLINK-16249][python][ml] Add interfaces for Params, ParamInfo and WithParams

dianfu commented on a change in pull request #11220: [FLINK-16249][python][ml] Add interfaces for Params, ParamInfo and WithParams URL: https://github.com/apache/flink/pull/11220#discussion_r384958403 ## File path: flink-python/setup.py ## @@ -224,7 +224,7 @@ def

[jira] [Commented] (FLINK-13934) HistoryServerStaticFileServerHandlerTest failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046262#comment-17046262 ] Xintong Song commented on FLINK-13934: -- Another instance: 

[jira] [Resolved] (FLINK-16234) Fix unstable cases in StreamingJobGraphGeneratorTest

[ https://issues.apache.org/jira/browse/FLINK-16234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu resolved FLINK-16234. - Resolution: Fixed Fixed via: master: 39e75eb2f1be9f6ce872e558bb8cf234897dfbfc release-1.10:

[jira] [Updated] (FLINK-16234) Fix unstable cases in StreamingJobGraphGeneratorTest

[ https://issues.apache.org/jira/browse/FLINK-16234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-16234: Affects Version/s: 1.10.0 > Fix unstable cases in StreamingJobGraphGeneratorTest >

[jira] [Updated] (FLINK-16234) Fix unstable cases in StreamingJobGraphGeneratorTest

[ https://issues.apache.org/jira/browse/FLINK-16234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-16234: Fix Version/s: 1.11.0 1.10.1 > Fix unstable cases in StreamingJobGraphGeneratorTest >

[GitHub] [flink] flinkbot edited a comment on issue #11130: [FLINK-15972][python][table-planner][table-planner-blink] Add Python building blocks to make sure the basic functionality of Python TableFun

flinkbot edited a comment on issue #11130: [FLINK-15972][python][table-planner][table-planner-blink] Add Python building blocks to make sure the basic functionality of Python TableFunction could work URL: https://github.com/apache/flink/pull/11130#issuecomment-588081932 ## CI report:

[GitHub] [flink] zhuzhurk closed pull request #11187: [FLINK-16234][tests] Fix unstable cases in StreamingJobGraphGeneratorTest

zhuzhurk closed pull request #11187: [FLINK-16234][tests] Fix unstable cases in StreamingJobGraphGeneratorTest URL: https://github.com/apache/flink/pull/11187 This is an automated message from the Apache Git Service. To

[jira] [Commented] (FLINK-16299) Release containers recovered from previous attempt in which TaskExecutor is not started.

[ https://issues.apache.org/jira/browse/FLINK-16299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046248#comment-17046248 ] Yangze Guo commented on FLINK-16299: I'd like work on it. > Release containers recovered from

[jira] [Comment Edited] (FLINK-16299) Release containers recovered from previous attempt in which TaskExecutor is not started.

[ https://issues.apache.org/jira/browse/FLINK-16299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046248#comment-17046248 ] Yangze Guo edited comment on FLINK-16299 at 2/27/20 7:17 AM: - I'd like to

[GitHub] [flink] hequn8128 commented on a change in pull request #11220: [FLINK-16249][python][ml] Add interfaces for Params, ParamInfo and WithParams

hequn8128 commented on a change in pull request #11220: [FLINK-16249][python][ml] Add interfaces for Params, ParamInfo and WithParams URL: https://github.com/apache/flink/pull/11220#discussion_r384947771 ## File path: flink-python/setup.py ## @@ -224,7 +224,7 @@ def

[GitHub] [flink] flinkbot edited a comment on issue #11130: [FLINK-15972][python][table-planner][table-planner-blink] Add Python building blocks to make sure the basic functionality of Python TableFun

flinkbot edited a comment on issue #11130: [FLINK-15972][python][table-planner][table-planner-blink] Add Python building blocks to make sure the basic functionality of Python TableFunction could work URL: https://github.com/apache/flink/pull/11130#issuecomment-588081932 ## CI report:

[GitHub] [flink] flinkbot edited a comment on issue #10858: [FLINK-15582][tests] Enable batch scheduling tests for both LegacyScheduler and DefaultScheduler

flinkbot edited a comment on issue #10858: [FLINK-15582][tests] Enable batch scheduling tests for both LegacyScheduler and DefaultScheduler URL: https://github.com/apache/flink/pull/10858#issuecomment-574561465 ## CI report: * 005f203017442c2c736b4752f3dbd4b6fb08a979 Travis:

[jira] [Closed] (FLINK-14818) StreamNetworkBenchmarkEnvironment incorrectly setups a receiving InputGate

[ https://issues.apache.org/jira/browse/FLINK-14818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao closed FLINK-14818. --- Resolution: Fixed > StreamNetworkBenchmarkEnvironment incorrectly setups a receiving InputGate >

[jira] [Created] (FLINK-16300) Reworks SchedulerTestUtils with testing classes to replace mockito usages

Zhu Zhu created FLINK-16300: --- Summary: Reworks SchedulerTestUtils with testing classes to replace mockito usages Key: FLINK-16300 URL: https://issues.apache.org/jira/browse/FLINK-16300 Project: Flink

[jira] [Commented] (FLINK-14818) StreamNetworkBenchmarkEnvironment incorrectly setups a receiving InputGate

[ https://issues.apache.org/jira/browse/FLINK-14818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046246#comment-17046246 ] Yingjie Cao commented on FLINK-14818: - Fixed on master via 92253f2e15090f5dac8cfc68c49727b62da23b8c.

[jira] [Commented] (FLINK-16299) Release containers recovered from previous attempt in which TaskExecutor is not started.

[ https://issues.apache.org/jira/browse/FLINK-16299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046244#comment-17046244 ] Xintong Song commented on FLINK-16299: -- [~trohrmann], could you help assign this ticket to

[jira] [Updated] (FLINK-14818) StreamNetworkBenchmarkEnvironment incorrectly setups a receiving InputGate

[ https://issues.apache.org/jira/browse/FLINK-14818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-14818: Fix Version/s: 1.11.0 > StreamNetworkBenchmarkEnvironment incorrectly setups a receiving

[jira] [Commented] (FLINK-16215) Start redundant TaskExecutor when JM failed

[ https://issues.apache.org/jira/browse/FLINK-16215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046241#comment-17046241 ] Xintong Song commented on FLINK-16215: -- I believe the problem of identifying recovered containers

[GitHub] [flink] zhijiangW merged pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

zhijiangW merged pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155 This is an automated message from the Apache

[GitHub] [flink] zhijiangW commented on issue #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

zhijiangW commented on issue #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#issuecomment-591816599 The failure case in travis is unrelated to this PR, merging

[jira] [Created] (FLINK-16299) Release containers recovered from previous attempt in which TaskExecutor is not started.

Xintong Song created FLINK-16299: Summary: Release containers recovered from previous attempt in which TaskExecutor is not started. Key: FLINK-16299 URL: https://issues.apache.org/jira/browse/FLINK-16299

[GitHub] [flink] flinkbot edited a comment on issue #11130: [FLINK-15972][python][table-planner][table-planner-blink] Add Python building blocks to make sure the basic functionality of Python TableFun

flinkbot edited a comment on issue #11130: [FLINK-15972][python][table-planner][table-planner-blink] Add Python building blocks to make sure the basic functionality of Python TableFunction could work URL: https://github.com/apache/flink/pull/11130#issuecomment-588081932 ## CI report:

[GitHub] [flink] flinkbot edited a comment on issue #11213: [FLINK-16276][tests] Introduce a builder and factory methods to create DefaultScheduler for testing

flinkbot edited a comment on issue #11213: [FLINK-16276][tests] Introduce a builder and factory methods to create DefaultScheduler for testing URL: https://github.com/apache/flink/pull/11213#issuecomment-590853060 ## CI report: * b31d7fab8da81827ca063075427a3737377bf0ed UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #10858: [FLINK-15582][tests] Enable batch scheduling tests for both LegacyScheduler and DefaultScheduler

flinkbot edited a comment on issue #10858: [FLINK-15582][tests] Enable batch scheduling tests for both LegacyScheduler and DefaultScheduler URL: https://github.com/apache/flink/pull/10858#issuecomment-574561465 ## CI report: * 005f203017442c2c736b4752f3dbd4b6fb08a979 Travis:

[GitHub] [flink] wsry commented on issue #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

wsry commented on issue #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#issuecomment-591814004 @flinkbot run travis This is

[GitHub] [flink] zhijiangW commented on issue #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

zhijiangW commented on issue #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#issuecomment-591812975 Thanks for the updates and patience @gaoyunhaii . The core codes are almost good now except

[GitHub] [flink] zhuzhurk commented on issue #10858: [FLINK-15582][tests] Enable batch scheduling tests for both LegacyScheduler and DefaultScheduler

zhuzhurk commented on issue #10858: [FLINK-15582][tests] Enable batch scheduling tests for both LegacyScheduler and DefaultScheduler URL: https://github.com/apache/flink/pull/10858#issuecomment-591811909 Now the `DefaultSchedulerBatchSchedulingTest` is reworked to be

[jira] [Comment Edited] (FLINK-16215) Start redundant TaskExecutor when JM failed

[ https://issues.apache.org/jira/browse/FLINK-16215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046207#comment-17046207 ] Xintong Song edited comment on FLINK-16215 at 2/27/20 6:48 AM: ---

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r384939418 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11218: [FLINK-16285][network] Refactor SingleInputGate#setInputChannel to remove IntermediateResultPartitionID argument

flinkbot edited a comment on issue #11218: [FLINK-16285][network] Refactor SingleInputGate#setInputChannel to remove IntermediateResultPartitionID argument URL: https://github.com/apache/flink/pull/11218#issuecomment-591253355 ## CI report: *

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r384938142 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11213: [FLINK-16276][tests] Introduce a builder and factory methods to create DefaultScheduler for testing

flinkbot edited a comment on issue #11213: [FLINK-16276][tests] Introduce a builder and factory methods to create DefaultScheduler for testing URL: https://github.com/apache/flink/pull/11213#issuecomment-590853060 ## CI report: * b31d7fab8da81827ca063075427a3737377bf0ed UNKNOWN

[jira] [Updated] (FLINK-16234) Fix unstable cases in StreamingJobGraphGeneratorTest

[ https://issues.apache.org/jira/browse/FLINK-16234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-16234: Summary: Fix unstable cases in StreamingJobGraphGeneratorTest (was: Use LinkedHashSet in

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r384937643 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r384937643 ## File path:

[jira] [Updated] (FLINK-16298) GroupWindowTableAggregateITCase.testEventTimeTumblingWindow fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-16298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-16298: Issue Type: Bug (was: Test) > GroupWindowTableAggregateITCase.testEventTimeTumblingWindow fails

[jira] [Created] (FLINK-16298) GroupWindowTableAggregateITCase.testEventTimeTumblingWindow fails on Travis

Yingjie Cao created FLINK-16298: --- Summary: GroupWindowTableAggregateITCase.testEventTimeTumblingWindow fails on Travis Key: FLINK-16298 URL: https://issues.apache.org/jira/browse/FLINK-16298 Project:

[GitHub] [flink] zhuzhurk commented on a change in pull request #11213: [FLINK-16276][tests] Introduce a builder and factory methods to create DefaultScheduler for testing

zhuzhurk commented on a change in pull request #11213: [FLINK-16276][tests] Introduce a builder and factory methods to create DefaultScheduler for testing URL: https://github.com/apache/flink/pull/11213#discussion_r384936512 ## File path:

[GitHub] [flink] hequn8128 commented on issue #11220: [FLINK-16249][python][ml] Add interfaces for Params, ParamInfo and WithParams

hequn8128 commented on issue #11220: [FLINK-16249][python][ml] Add interfaces for Params, ParamInfo and WithParams URL: https://github.com/apache/flink/pull/11220#issuecomment-591807495 > @hequn8128 Thanks for the PR. > > 1. I noticed that there are two modules "ml" and "mllib"

[GitHub] [flink] zhuzhurk commented on a change in pull request #11213: [FLINK-16276][tests] Introduce a builder and factory methods to create DefaultScheduler for testing

zhuzhurk commented on a change in pull request #11213: [FLINK-16276][tests] Introduce a builder and factory methods to create DefaultScheduler for testing URL: https://github.com/apache/flink/pull/11213#discussion_r384935971 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #11213: [FLINK-16276][tests] Introduce a builder and factory methods to create DefaultScheduler for testing

zhuzhurk commented on a change in pull request #11213: [FLINK-16276][tests] Introduce a builder and factory methods to create DefaultScheduler for testing URL: https://github.com/apache/flink/pull/11213#discussion_r384935575 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r384934330 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r384934049 ## File path:

[jira] [Commented] (FLINK-16215) Start redundant TaskExecutor when JM failed

[ https://issues.apache.org/jira/browse/FLINK-16215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046207#comment-17046207 ] Xintong Song commented on FLINK-16215: -- Just trying to understand, why do we need to block

[jira] [Closed] (FLINK-16252) Optimize the output emit logic to remove unnecessary overhead

[ https://issues.apache.org/jira/browse/FLINK-16252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-16252. --- Resolution: Resolved Merged to master via 2ed4cf7c1bcde30d65325b48f277fcec038a4d07. > Optimize the output

[GitHub] [flink] wsry commented on issue #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

wsry commented on issue #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#issuecomment-591803930 @flinkbot run travis re-run the last Travis build

[jira] [Updated] (FLINK-16252) Optimize the output emit logic to remove unnecessary overhead

[ https://issues.apache.org/jira/browse/FLINK-16252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16252: Summary: Optimize the output emit logic to remove unnecessary overhead (was: Optimize the output emit in

[GitHub] [flink] dianfu merged pull request #11224: [FLINK-16252][python] Optimize the progress of the process_outputs in Python UDF

dianfu merged pull request #11224: [FLINK-16252][python] Optimize the progress of the process_outputs in Python UDF URL: https://github.com/apache/flink/pull/11224 This is an automated message from the Apache Git Service.

[jira] [Updated] (FLINK-16252) Optimize the output emit in Python UDF

[ https://issues.apache.org/jira/browse/FLINK-16252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16252: Summary: Optimize the output emit in Python UDF (was: Optimize the progress of the process_outputs in

[jira] [Commented] (FLINK-16215) Start redundant TaskExecutor when JM failed

[ https://issues.apache.org/jira/browse/FLINK-16215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046198#comment-17046198 ] Yangze Guo commented on FLINK-16215: [~liuyufei] SlotManager will decide what and how many

[jira] [Commented] (FLINK-16215) Start redundant TaskExecutor when JM failed

[ https://issues.apache.org/jira/browse/FLINK-16215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046195#comment-17046195 ] YufeiLiu commented on FLINK-16215: -- [~xintongsong] This sounds good. We can do some actual recovery

[GitHub] [flink] dianfu commented on issue #11224: [FLINK-16252][python] Optimize the progress of the process_outputs in Python UDF

dianfu commented on issue #11224: [FLINK-16252][python] Optimize the progress of the process_outputs in Python UDF URL: https://github.com/apache/flink/pull/11224#issuecomment-591801113 @HuangXingBo Thanks for the PR. LGTM. The test failure is not related to this PR and has been tracked

[GitHub] [flink] ayushtkn commented on issue #10978: [FLINK-15584] Give nested data type of ROWs in ValidationException.

ayushtkn commented on issue #10978: [FLINK-15584] Give nested data type of ROWs in ValidationException. URL: https://github.com/apache/flink/pull/10978#issuecomment-591801056 Thanx @rmetzger Seems the CI result is success. can you give a check once

[jira] [Commented] (FLINK-13553) KvStateServerHandlerTest.readInboundBlocking unstable on Travis

[ https://issues.apache.org/jira/browse/FLINK-13553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046193#comment-17046193 ] Dian Fu commented on FLINK-13553: - Another instance: 

[GitHub] [flink] flinkbot edited a comment on issue #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

flinkbot edited a comment on issue #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#issuecomment-588965557 ## CI report: * 035041ed96b561f0d7bb69fa09436a24e42a5a54 Travis:

[jira] [Commented] (FLINK-16297) Remove the redundant intent and blank line in highlight code blocks

[ https://issues.apache.org/jira/browse/FLINK-16297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046192#comment-17046192 ] Yangze Guo commented on FLINK-16297: [~chesnay] I'd like to work for it. Could you assign this to

[jira] [Updated] (FLINK-16297) Remove the redundant intent and blank line in highlight code blocks

[ https://issues.apache.org/jira/browse/FLINK-16297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-16297: --- Description: Currently, there are lots of redundant intent and blank lines in highlight code

[jira] [Created] (FLINK-16297) Remove the redundant intent and blank line in highlight code blocks

Yangze Guo created FLINK-16297: -- Summary: Remove the redundant intent and blank line in highlight code blocks Key: FLINK-16297 URL: https://issues.apache.org/jira/browse/FLINK-16297 Project: Flink

[jira] [Comment Edited] (FLINK-16265) TPC-H end-to-end test (Blink Planner): Encodings that differ from the schema are not supported yet for CsvTableSources.

[ https://issues.apache.org/jira/browse/FLINK-16265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046033#comment-17046033 ] Jingsong Lee edited comment on FLINK-16265 at 2/27/20 5:56 AM: ---

[jira] [Commented] (FLINK-16265) TPC-H end-to-end test (Blink Planner): Encodings that differ from the schema are not supported yet for CsvTableSources.

[ https://issues.apache.org/jira/browse/FLINK-16265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046187#comment-17046187 ] Jingsong Lee commented on FLINK-16265: -- Fix csv sink in master: 

[GitHub] [flink] JingsongLi merged pull request #11229: [FLINK-16265][table][csv] CsvTableSinkFactoryBase should compare LogicalTypes instead of TableSchema

JingsongLi merged pull request #11229: [FLINK-16265][table][csv] CsvTableSinkFactoryBase should compare LogicalTypes instead of TableSchema URL: https://github.com/apache/flink/pull/11229 This is an automated message from

[GitHub] [flink] flinkbot edited a comment on issue #11100: [FLINK-15562][docs] Add Example settings.xml for maven archetype command wh…

flinkbot edited a comment on issue #11100: [FLINK-15562][docs] Add Example settings.xml for maven archetype command wh… URL: https://github.com/apache/flink/pull/11100#issuecomment-586663648 ## CI report: * 5a0a60e65f243141a09fd357b9142803ad517f02 Travis:

[GitHub] [flink] zhuzhurk commented on issue #10858: [FLINK-15582][tests] Enable batch scheduling tests for both LegacyScheduler and DefaultScheduler

zhuzhurk commented on issue #10858: [FLINK-15582][tests] Enable batch scheduling tests for both LegacyScheduler and DefaultScheduler URL: https://github.com/apache/flink/pull/10858#issuecomment-591788932 Yeah. This ticket was opened before 1.10 release and I thought it would help to

[GitHub] [flink] flinkbot edited a comment on issue #10995: [FLINK-15847][ml] Include flink-ml-api and flink-ml-lib in opt

flinkbot edited a comment on issue #10995: [FLINK-15847][ml] Include flink-ml-api and flink-ml-lib in opt URL: https://github.com/apache/flink/pull/10995#issuecomment-581294934 ## CI report: * 478491bde663e58f1e84753bf6fac3a7367ef195 Travis:

[GitHub] [flink] dianfu commented on a change in pull request #11220: [FLINK-16249][python][ml] Add interfaces for Params, ParamInfo and WithParams

dianfu commented on a change in pull request #11220: [FLINK-16249][python][ml] Add interfaces for Params, ParamInfo and WithParams URL: https://github.com/apache/flink/pull/11220#discussion_r384916133 ## File path: flink-python/pyflink/ml/param/base.py ## @@ -0,0 +1,356

[GitHub] [flink] dianfu commented on a change in pull request #11220: [FLINK-16249][python][ml] Add interfaces for Params, ParamInfo and WithParams

dianfu commented on a change in pull request #11220: [FLINK-16249][python][ml] Add interfaces for Params, ParamInfo and WithParams URL: https://github.com/apache/flink/pull/11220#discussion_r384915516 ## File path: flink-python/pyflink/ml/param/base.py ## @@ -0,0 +1,356

[GitHub] [flink] dianfu commented on a change in pull request #11220: [FLINK-16249][python][ml] Add interfaces for Params, ParamInfo and WithParams

dianfu commented on a change in pull request #11220: [FLINK-16249][python][ml] Add interfaces for Params, ParamInfo and WithParams URL: https://github.com/apache/flink/pull/11220#discussion_r384914716 ## File path: flink-python/pyflink/ml/tests/test_params.py ## @@ -0,0

[GitHub] [flink] dianfu commented on a change in pull request #11220: [FLINK-16249][python][ml] Add interfaces for Params, ParamInfo and WithParams

dianfu commented on a change in pull request #11220: [FLINK-16249][python][ml] Add interfaces for Params, ParamInfo and WithParams URL: https://github.com/apache/flink/pull/11220#discussion_r384915111 ## File path: flink-python/pyflink/ml/param/base.py ## @@ -0,0 +1,356

[GitHub] [flink] dianfu commented on a change in pull request #11220: [FLINK-16249][python][ml] Add interfaces for Params, ParamInfo and WithParams

dianfu commented on a change in pull request #11220: [FLINK-16249][python][ml] Add interfaces for Params, ParamInfo and WithParams URL: https://github.com/apache/flink/pull/11220#discussion_r384916133 ## File path: flink-python/pyflink/ml/param/base.py ## @@ -0,0 +1,356

[GitHub] [flink] flinkbot edited a comment on issue #10709: [FLINK-13437][test] Add Hive SQL E2E test

flinkbot edited a comment on issue #10709: [FLINK-13437][test] Add Hive SQL E2E test URL: https://github.com/apache/flink/pull/10709#issuecomment-569310266 ## CI report: * e580f035522a9ccf395fa571e668dfef834f2695 Travis:

[GitHub] [flink] hequn8128 commented on issue #10995: [FLINK-15847][ml] Include flink-ml-api and flink-ml-lib in opt

hequn8128 commented on issue #10995: [FLINK-15847][ml] Include flink-ml-api and flink-ml-lib in opt URL: https://github.com/apache/flink/pull/10995#issuecomment-591779672 @zentol Thanks for the review. The PR has been updated accordingly.

[GitHub] [flink] flinkbot edited a comment on issue #11100: [FLINK-15562][docs] Add Example settings.xml for maven archetype command wh…

flinkbot edited a comment on issue #11100: [FLINK-15562][docs] Add Example settings.xml for maven archetype command wh… URL: https://github.com/apache/flink/pull/11100#issuecomment-586663648 ## CI report: * 5a0a60e65f243141a09fd357b9142803ad517f02 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11218: [FLINK-16285][network] Refactor SingleInputGate#setInputChannel to remove IntermediateResultPartitionID argument

flinkbot edited a comment on issue #11218: [FLINK-16285][network] Refactor SingleInputGate#setInputChannel to remove IntermediateResultPartitionID argument URL: https://github.com/apache/flink/pull/11218#issuecomment-591253355 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #10709: [FLINK-13437][test] Add Hive SQL E2E test

flinkbot edited a comment on issue #10709: [FLINK-13437][test] Add Hive SQL E2E test URL: https://github.com/apache/flink/pull/10709#issuecomment-569310266 ## CI report: * e580f035522a9ccf395fa571e668dfef834f2695 Travis:

[GitHub] [flink] dianfu commented on a change in pull request #11220: [FLINK-16249][python][ml] Add interfaces for Params, ParamInfo and WithParams

dianfu commented on a change in pull request #11220: [FLINK-16249][python][ml] Add interfaces for Params, ParamInfo and WithParams URL: https://github.com/apache/flink/pull/11220#discussion_r384908071 ## File path: flink-python/setup.py ## @@ -224,7 +224,7 @@ def

[jira] [Commented] (FLINK-16296) Improve performance of BaseRowSerializer#serialize() for GenericRow

[ https://issues.apache.org/jira/browse/FLINK-16296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046143#comment-17046143 ] Jark Wu commented on FLINK-16296: - [~lzljs3620320] True. > Improve performance of

[GitHub] [flink] flinkbot edited a comment on issue #11218: [FLINK-16285][network] Refactor SingleInputGate#setInputChannel to remove IntermediateResultPartitionID argument

flinkbot edited a comment on issue #11218: [FLINK-16285][network] Refactor SingleInputGate#setInputChannel to remove IntermediateResultPartitionID argument URL: https://github.com/apache/flink/pull/11218#issuecomment-591253355 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

flinkbot edited a comment on issue #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#issuecomment-588965557 ## CI report: * fbf92243b17619df704bf2600d294cda449c7ddc Travis:

[GitHub] [flink] libenchao commented on a change in pull request #11223: [FLINK-16281][Table SQL / Ecosystem] parameter 'maxRetryTimes' can not work in JDBCUpsertTableSink.

libenchao commented on a change in pull request #11223: [FLINK-16281][Table SQL / Ecosystem] parameter 'maxRetryTimes' can not work in JDBCUpsertTableSink. URL: https://github.com/apache/flink/pull/11223#discussion_r384908566 ## File path:

[GitHub] [flink] libenchao commented on issue #11223: [FLINK-16281][Table SQL / Ecosystem] parameter 'maxRetryTimes' can not work in JDBCUpsertTableSink.

libenchao commented on issue #11223: [FLINK-16281][Table SQL / Ecosystem] parameter 'maxRetryTimes' can not work in JDBCUpsertTableSink. URL: https://github.com/apache/flink/pull/11223#issuecomment-591775312 LGTM, +1 for merging.

[GitHub] [flink] flinkbot edited a comment on issue #11229: [FLINK-16265][table][csv] CsvTableSinkFactoryBase should compare LogicalTypes instead of TableSchema

flinkbot edited a comment on issue #11229: [FLINK-16265][table][csv] CsvTableSinkFactoryBase should compare LogicalTypes instead of TableSchema URL: https://github.com/apache/flink/pull/11229#issuecomment-591745212 ## CI report: * dbb73eabacff825c8c353a3196ffab14ecae4f53 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

flinkbot edited a comment on issue #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#issuecomment-588965557 ## CI report: * fbf92243b17619df704bf2600d294cda449c7ddc Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11223: [FLINK-16281][Table SQL / Ecosystem] parameter 'maxRetryTimes' can not work in JDBCUpsertTableSink.

flinkbot edited a comment on issue #11223: [FLINK-16281][Table SQL / Ecosystem] parameter 'maxRetryTimes' can not work in JDBCUpsertTableSink. URL: https://github.com/apache/flink/pull/11223#issuecomment-591439360 ## CI report: * 2cb96534f083b219b8652650425b2a6f8fbc1baa Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11223: [FLINK-16281][Table SQL / Ecosystem] parameter 'maxRetryTimes' can not work in JDBCUpsertTableSink.

flinkbot edited a comment on issue #11223: [FLINK-16281][Table SQL / Ecosystem] parameter 'maxRetryTimes' can not work in JDBCUpsertTableSink. URL: https://github.com/apache/flink/pull/11223#issuecomment-591439360 ## CI report: * 64692a3605478258174ec0e1b88754843170a01e Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11229: [FLINK-16265][table][csv] CsvTableSinkFactoryBase should compare LogicalTypes instead of TableSchema

flinkbot edited a comment on issue #11229: [FLINK-16265][table][csv] CsvTableSinkFactoryBase should compare LogicalTypes instead of TableSchema URL: https://github.com/apache/flink/pull/11229#issuecomment-591745212 ## CI report: * dbb73eabacff825c8c353a3196ffab14ecae4f53 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10988: Add commas to large numeric accumulators

flinkbot edited a comment on issue #10988: Add commas to large numeric accumulators URL: https://github.com/apache/flink/pull/10988#issuecomment-580980044 ## CI report: * 06668089b730778948e758f114c2ed34d141135f UNKNOWN * ac364646023681c9a4b237afe86f073c3fe5d108 Travis:

[GitHub] [flink] JingsongLi commented on issue #10709: [FLINK-13437][test] Add Hive SQL E2E test

JingsongLi commented on issue #10709: [FLINK-13437][test] Add Hive SQL E2E test URL: https://github.com/apache/flink/pull/10709#issuecomment-591767034 Thanks @zjuwangg for your great work! I will continue to working on this.

[GitHub] [flink] leonardBang commented on a change in pull request #11223: [FLINK-16281][Table SQL / Ecosystem] parameter 'maxRetryTimes' can not work in JDBCUpsertTableSink.

leonardBang commented on a change in pull request #11223: [FLINK-16281][Table SQL / Ecosystem] parameter 'maxRetryTimes' can not work in JDBCUpsertTableSink. URL: https://github.com/apache/flink/pull/11223#discussion_r384900067 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11223: [FLINK-16281][Table SQL / Ecosystem] parameter 'maxRetryTimes' can not work in JDBCUpsertTableSink.

flinkbot edited a comment on issue #11223: [FLINK-16281][Table SQL / Ecosystem] parameter 'maxRetryTimes' can not work in JDBCUpsertTableSink. URL: https://github.com/apache/flink/pull/11223#issuecomment-591439360 ## CI report: * 64692a3605478258174ec0e1b88754843170a01e Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10995: [FLINK-15847][ml] Include flink-ml-api and flink-ml-lib in opt

flinkbot edited a comment on issue #10995: [FLINK-15847][ml] Include flink-ml-api and flink-ml-lib in opt URL: https://github.com/apache/flink/pull/10995#issuecomment-581294934 ## CI report: * 9c1edd078c466ee56f2aed16ce9098e35bfae69e Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11100: [FLINK-15562][docs] Add Example settings.xml for maven archetype command wh…

flinkbot edited a comment on issue #11100: [FLINK-15562][docs] Add Example settings.xml for maven archetype command wh… URL: https://github.com/apache/flink/pull/11100#issuecomment-586663648 ## CI report: * 02620095a58249cf77e0c801541060e5b86df404 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10709: [FLINK-13437][test] Add Hive SQL E2E test

flinkbot edited a comment on issue #10709: [FLINK-13437][test] Add Hive SQL E2E test URL: https://github.com/apache/flink/pull/10709#issuecomment-569310266 ## CI report: * 889c2d9112462f22e6e8f4af9ba85b07b5f3c424 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11100: [FLINK-15562][docs] Add Example settings.xml for maven archetype command wh…

flinkbot edited a comment on issue #11100: [FLINK-15562][docs] Add Example settings.xml for maven archetype command wh… URL: https://github.com/apache/flink/pull/11100#issuecomment-586663648 ## CI report: * 02620095a58249cf77e0c801541060e5b86df404 Travis:

  1   2   3   4   5   6   >