[jira] [Comment Edited] (FLINK-15992) Incorrect classloader when finding TableFactory

2020-02-20 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17041642#comment-17041642 ] Jark Wu edited comment on FLINK-15992 at 2/21/20 7:54 AM: -- Hi [

[jira] [Commented] (FLINK-15992) Incorrect classloader when finding TableFactory

2020-02-20 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17041643#comment-17041643 ] Jark Wu commented on FLINK-15992: - Btw, I will revert this commit and re-implement based

[GitHub] [flink] flinkbot commented on issue #11167: [FLINK-16129] [docs] Translate /ops/filesystems/index.zh.md

2020-02-20 Thread GitBox
flinkbot commented on issue #11167: [FLINK-16129] [docs] Translate /ops/filesystems/index.zh.md URL: https://github.com/apache/flink/pull/11167#issuecomment-589539473 ## CI report: * e210c1aad1a84a8b2baabb019a895b677c358ebf UNKNOWN Bot commands The @flinkbot bot s

[jira] [Commented] (FLINK-15992) Incorrect classloader when finding TableFactory

2020-02-20 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17041642#comment-17041642 ] Jark Wu commented on FLINK-15992: - Hi [~victor-wong], I re-think about this issue. I thi

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

2020-02-20 Thread GitBox
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: * fee93cecf80cb73fcdf082f47fe0b9bd727a3002 Travis: [FAILUR

[GitHub] [flink] PatrickRen commented on a change in pull request #11129: [FLINK-16127][docs]Translate "Fault Tolerance Guarantees" page of connectors into Chinese

2020-02-20 Thread GitBox
PatrickRen commented on a change in pull request #11129: [FLINK-16127][docs]Translate "Fault Tolerance Guarantees" page of connectors into Chinese URL: https://github.com/apache/flink/pull/11129#discussion_r382437767 ## File path: docs/dev/connectors/guarantees.zh.md ## @

[GitHub] [flink] PatrickRen commented on a change in pull request #11129: [FLINK-16127][docs]Translate "Fault Tolerance Guarantees" page of connectors into Chinese

2020-02-20 Thread GitBox
PatrickRen commented on a change in pull request #11129: [FLINK-16127][docs]Translate "Fault Tolerance Guarantees" page of connectors into Chinese URL: https://github.com/apache/flink/pull/11129#discussion_r382437471 ## File path: docs/dev/connectors/guarantees.zh.md ## @

[jira] [Commented] (FLINK-15400) elasticsearch sink support dynamic index.

2020-02-20 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17041638#comment-17041638 ] Leonard Xu commented on FLINK-15400: [~jark] Thanks for your tips, updated : {code:j

[jira] [Closed] (FLINK-16056) NullPointerException during ContinuousFileProcessingITCase

2020-02-20 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-16056. -- > NullPointerException during ContinuousFileProcessingITCase > ---

[jira] [Commented] (FLINK-16175) Add config option to switch case sensitive for column names in SQL

2020-02-20 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17041631#comment-17041631 ] Leonard Xu commented on FLINK-16175: [~jark] Thanks for your supplement, could you

[jira] [Commented] (FLINK-15400) elasticsearch sink support dynamic index.

2020-02-20 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17041630#comment-17041630 ] Jark Wu commented on FLINK-15400: - [~Leonard Xu], thanks for the update. Two minor suges

[GitHub] [flink] PatrickRen commented on a change in pull request #11129: [FLINK-16127][docs]Translate "Fault Tolerance Guarantees" page of connectors into Chinese

2020-02-20 Thread GitBox
PatrickRen commented on a change in pull request #11129: [FLINK-16127][docs]Translate "Fault Tolerance Guarantees" page of connectors into Chinese URL: https://github.com/apache/flink/pull/11129#discussion_r382433493 ## File path: docs/dev/connectors/guarantees.zh.md ## @

[GitHub] [flink] PatrickRen commented on a change in pull request #11129: [FLINK-16127][docs]Translate "Fault Tolerance Guarantees" page of connectors into Chinese

2020-02-20 Thread GitBox
PatrickRen commented on a change in pull request #11129: [FLINK-16127][docs]Translate "Fault Tolerance Guarantees" page of connectors into Chinese URL: https://github.com/apache/flink/pull/11129#discussion_r382433210 ## File path: docs/dev/connectors/guarantees.zh.md ## @

[GitHub] [flink] Sxnan commented on a change in pull request #11167: [FLINK-16129] [docs] Translate /ops/filesystems/index.zh.md

2020-02-20 Thread GitBox
Sxnan commented on a change in pull request #11167: [FLINK-16129] [docs] Translate /ops/filesystems/index.zh.md URL: https://github.com/apache/flink/pull/11167#discussion_r382432036 ## File path: docs/ops/filesystems/index.zh.md ## @@ -24,104 +24,82 @@ specific language go

[GitHub] [flink] pnowojski closed pull request #11071: [FLINK-16019][runtime] fix ContinuousFileReaderOperator error reporting

2020-02-20 Thread GitBox
pnowojski closed pull request #11071: [FLINK-16019][runtime] fix ContinuousFileReaderOperator error reporting URL: https://github.com/apache/flink/pull/11071 This is an automated message from the Apache Git Service. To respo

[GitHub] [flink] pnowojski commented on issue #11071: [FLINK-16019][runtime] fix ContinuousFileReaderOperator error reporting

2020-02-20 Thread GitBox
pnowojski commented on issue #11071: [FLINK-16019][runtime] fix ContinuousFileReaderOperator error reporting URL: https://github.com/apache/flink/pull/11071#issuecomment-589532338 Merged to master after adding the test. This

[jira] [Commented] (FLINK-15400) elasticsearch sink support dynamic index.

2020-02-20 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17041627#comment-17041627 ] Leonard Xu commented on FLINK-15400: Hi, [~jark]  nice suggestion! {quote}(I think "

[jira] [Closed] (FLINK-16019) ContinuousFileReaderOperatorBenchmark restarts indefinetly on failure

2020-02-20 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-16019. -- Assignee: Roman Khachatryan Resolution: Fixed Merged to master as 0f71ab3edb and dddbc2b

[GitHub] [flink] PatrickRen commented on a change in pull request #11129: [FLINK-16127][docs]Translate "Fault Tolerance Guarantees" page of connectors into Chinese

2020-02-20 Thread GitBox
PatrickRen commented on a change in pull request #11129: [FLINK-16127][docs]Translate "Fault Tolerance Guarantees" page of connectors into Chinese URL: https://github.com/apache/flink/pull/11129#discussion_r382431151 ## File path: docs/dev/connectors/guarantees.zh.md ## @

[jira] [Commented] (FLINK-16175) Add config option to switch case sensitive for column names in SQL

2020-02-20 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17041623#comment-17041623 ] Jark Wu commented on FLINK-16175: - Hi [~Leonard Xu], I changed the title to be more spec

[GitHub] [flink] Sxnan commented on a change in pull request #11167: [FLINK-16129] [docs] Translate /ops/filesystems/index.zh.md

2020-02-20 Thread GitBox
Sxnan commented on a change in pull request #11167: [FLINK-16129] [docs] Translate /ops/filesystems/index.zh.md URL: https://github.com/apache/flink/pull/11167#discussion_r382429418 ## File path: docs/ops/filesystems/index.zh.md ## @@ -24,104 +24,82 @@ specific language go

[jira] [Assigned] (FLINK-16181) IfCallGen will throw NPE for primitive types in blink

2020-02-20 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-16181: --- Assignee: Benchao Li > IfCallGen will throw NPE for primitive types in blink >

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

2020-02-20 Thread GitBox
wsry commented on issue #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#issuecomment-589529462 I have updated the PR. @zhijiangW I will attach the new benchmark results soon. --

[GitHub] [flink] wangyang0918 edited a comment on issue #11070: [FLINK-16013][core] Make complex type config options could be parsed correctly

2020-02-20 Thread GitBox
wangyang0918 edited a comment on issue #11070: [FLINK-16013][core] Make complex type config options could be parsed correctly URL: https://github.com/apache/flink/pull/11070#issuecomment-586291406 @dawidwys @zentol @kl0u Thanks a lot for your review and nice suggestion. I have addressed al

[jira] [Updated] (FLINK-16175) Add config option to switch case sensitive for column names in SQL

2020-02-20 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16175: Summary: Add config option to switch case sensitive for column names in SQL (was: Add configOption to set

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

2020-02-20 Thread GitBox
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: * fee93cecf80cb73fcdf082f47fe0b9bd727a3002 Travis: [FAILUR

[jira] [Commented] (FLINK-16195) Append constant fields to unique key set when deriving unique keys in FlinkRelMdUniqueKeys on project

2020-02-20 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17041616#comment-17041616 ] Jark Wu commented on FLINK-16195: - What's the problem when we don't have the additional

[jira] [Updated] (FLINK-16175) Add configOption to set CaseSensitive for SQL

2020-02-20 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16175: Component/s: Table SQL / API > Add configOption to set CaseSensitive for SQL > ---

[jira] [Updated] (FLINK-16195) Append constant fields to unique key set when deriving unique keys in FlinkRelMdUniqueKeys on project

2020-02-20 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16195: Summary: Append constant fields to unique key set when deriving unique keys in FlinkRelMdUniqueKeys on pro

[GitHub] [flink] wsry commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

2020-02-20 Thread GitBox
wsry commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#discussion_r382426966 ## File path: flink-streaming-java/src/test/java/org/apache/flink/st

[GitHub] [flink] flinkbot commented on issue #11167: [FLINK-16129] [docs] Translate /ops/filesystems/index.zh.md

2020-02-20 Thread GitBox
flinkbot commented on issue #11167: [FLINK-16129] [docs] Translate /ops/filesystems/index.zh.md URL: https://github.com/apache/flink/pull/11167#issuecomment-589527617 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your p

[jira] [Assigned] (FLINK-16195) [FLINK-16195] [table-planner-blink] append constant fields to unique key set when deriving unique keys in FlinkRelMdUniqueKeys on project

2020-02-20 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-16195: --- Assignee: godfrey he > [FLINK-16195] [table-planner-blink] append constant fields to unique key set

[jira] [Updated] (FLINK-16129) Translate "Overview" page of "File Systems" into Chinese

2020-02-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16129: --- Labels: pull-request-available (was: ) > Translate "Overview" page of "File Systems" into C

[jira] [Commented] (FLINK-15400) elasticsearch sink support dynamic index.

2020-02-20 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17041614#comment-17041614 ] Jark Wu commented on FLINK-15400: - Thanks for sharing this great proposal [~Leonard Xu],

[GitHub] [flink] PatrickRen opened a new pull request #11167: [FLINK-16129] [docs] Translate /ops/filesystems/index.zh.md

2020-02-20 Thread GitBox
PatrickRen opened a new pull request #11167: [FLINK-16129] [docs] Translate /ops/filesystems/index.zh.md URL: https://github.com/apache/flink/pull/11167 ## What is the purpose of the change This pull request translates the overview part of the file system document into Chinese.

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

2020-02-20 Thread GitBox
flinkbot edited a comment 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-567435407 ## CI report: * 6b12b52b99894864db993a2fa8ab2bfcce0edd5c Travis: [FAILURE](https://t

[jira] [Updated] (FLINK-16195) [FLINK-16195] [table-planner-blink] append constant fields to unique key set when deriving unique keys in FlinkRelMdUniqueKeys on project

2020-02-20 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-16195: --- Summary: [FLINK-16195] [table-planner-blink] append constant fields to unique key set when deriving

[jira] [Commented] (FLINK-15400) elasticsearch sink support dynamic index.

2020-02-20 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17041612#comment-17041612 ] Leonard Xu commented on FLINK-15400: [~libenchao]  Thanks for involved. I'm worried

[jira] [Commented] (FLINK-15959) Add min/max number of slots configuration to limit total number of slots

2020-02-20 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17041609#comment-17041609 ] Yangze Guo commented on FLINK-15959: Hi, [~liuyufei]. I have basic some ideas from t

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

2020-02-20 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17041608#comment-17041608 ] Yingjie Cao commented on FLINK-14818: - I have opened a PR for this issue and Zhijian

[jira] [Commented] (FLINK-15400) elasticsearch sink support dynamic index.

2020-02-20 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17041607#comment-17041607 ] Leonard Xu commented on FLINK-15400: Hi, [~ouyangwuli] happy to hear you  have imple

[GitHub] [flink] wsry commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

2020-02-20 Thread GitBox
wsry commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#discussion_r382418406 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/i

[jira] [Commented] (FLINK-9477) FLIP-90: Support SQL 2016 JSON functions in Flink SQL

2020-02-20 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17041599#comment-17041599 ] Jark Wu commented on FLINK-9477: Yes [~tison], I target this issue to 1.11. Hi [~x1q1j1

[jira] [Commented] (FLINK-16185) FLIP-90: Support SQL 2016-2017 JSON functions in Table API & SQL

2020-02-20 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17041597#comment-17041597 ] Jark Wu commented on FLINK-16185: - Hi [~tison], the functions you mentioned is exactly w

[jira] [Updated] (FLINK-9477) FLIP-90: Support SQL 2016 JSON functions in Flink SQL

2020-02-20 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-9477: --- Fix Version/s: 1.11.0 > FLIP-90: Support SQL 2016 JSON functions in Flink SQL > -

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

2020-02-20 Thread GitBox
flinkbot edited a comment 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-567435407 ## CI report: * 6b12b52b99894864db993a2fa8ab2bfcce0edd5c Travis: [FAILURE](https://t

[GitHub] [flink] wsry commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

2020-02-20 Thread GitBox
wsry commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#discussion_r382414363 ## File path: flink-streaming-java/src/test/java/org/apache/flink/st

[GitHub] [flink] hequn8128 commented on a change in pull request #11112: [FLINK-16121][python] Introduce ArrowReader and ArrowWriter for Arrow format data read and write

2020-02-20 Thread GitBox
hequn8128 commented on a change in pull request #2: [FLINK-16121][python] Introduce ArrowReader and ArrowWriter for Arrow format data read and write URL: https://github.com/apache/flink/pull/2#discussion_r382381926 ## File path: flink-python/src/main/java/org/apache/flink/t

[GitHub] [flink] hequn8128 commented on a change in pull request #11112: [FLINK-16121][python] Introduce ArrowReader and ArrowWriter for Arrow format data read and write

2020-02-20 Thread GitBox
hequn8128 commented on a change in pull request #2: [FLINK-16121][python] Introduce ArrowReader and ArrowWriter for Arrow format data read and write URL: https://github.com/apache/flink/pull/2#discussion_r382413407 ## File path: flink-python/src/test/java/org/apache/flink/t

[GitHub] [flink] hequn8128 commented on a change in pull request #11112: [FLINK-16121][python] Introduce ArrowReader and ArrowWriter for Arrow format data read and write

2020-02-20 Thread GitBox
hequn8128 commented on a change in pull request #2: [FLINK-16121][python] Introduce ArrowReader and ArrowWriter for Arrow format data read and write URL: https://github.com/apache/flink/pull/2#discussion_r382375658 ## File path: flink-python/src/main/java/org/apache/flink/t

[GitHub] [flink] hequn8128 commented on a change in pull request #11112: [FLINK-16121][python] Introduce ArrowReader and ArrowWriter for Arrow format data read and write

2020-02-20 Thread GitBox
hequn8128 commented on a change in pull request #2: [FLINK-16121][python] Introduce ArrowReader and ArrowWriter for Arrow format data read and write URL: https://github.com/apache/flink/pull/2#discussion_r382389771 ## File path: flink-python/src/main/java/org/apache/flink/t

[GitHub] [flink] hequn8128 commented on a change in pull request #11112: [FLINK-16121][python] Introduce ArrowReader and ArrowWriter for Arrow format data read and write

2020-02-20 Thread GitBox
hequn8128 commented on a change in pull request #2: [FLINK-16121][python] Introduce ArrowReader and ArrowWriter for Arrow format data read and write URL: https://github.com/apache/flink/pull/2#discussion_r382382416 ## File path: flink-python/src/main/java/org/apache/flink/t

[GitHub] [flink] hequn8128 commented on a change in pull request #11112: [FLINK-16121][python] Introduce ArrowReader and ArrowWriter for Arrow format data read and write

2020-02-20 Thread GitBox
hequn8128 commented on a change in pull request #2: [FLINK-16121][python] Introduce ArrowReader and ArrowWriter for Arrow format data read and write URL: https://github.com/apache/flink/pull/2#discussion_r382371474 ## File path: flink-python/src/main/java/org/apache/flink/t

[GitHub] [flink] hequn8128 commented on a change in pull request #11112: [FLINK-16121][python] Introduce ArrowReader and ArrowWriter for Arrow format data read and write

2020-02-20 Thread GitBox
hequn8128 commented on a change in pull request #2: [FLINK-16121][python] Introduce ArrowReader and ArrowWriter for Arrow format data read and write URL: https://github.com/apache/flink/pull/2#discussion_r382412615 ## File path: flink-python/src/main/java/org/apache/flink/t

[GitHub] [flink] hequn8128 commented on a change in pull request #11112: [FLINK-16121][python] Introduce ArrowReader and ArrowWriter for Arrow format data read and write

2020-02-20 Thread GitBox
hequn8128 commented on a change in pull request #2: [FLINK-16121][python] Introduce ArrowReader and ArrowWriter for Arrow format data read and write URL: https://github.com/apache/flink/pull/2#discussion_r382412135 ## File path: flink-python/src/main/java/org/apache/flink/t

[GitHub] [flink] hequn8128 commented on a change in pull request #11112: [FLINK-16121][python] Introduce ArrowReader and ArrowWriter for Arrow format data read and write

2020-02-20 Thread GitBox
hequn8128 commented on a change in pull request #2: [FLINK-16121][python] Introduce ArrowReader and ArrowWriter for Arrow format data read and write URL: https://github.com/apache/flink/pull/2#discussion_r382384546 ## File path: flink-python/src/test/java/org/apache/flink/t

[GitHub] [flink] hequn8128 commented on a change in pull request #11112: [FLINK-16121][python] Introduce ArrowReader and ArrowWriter for Arrow format data read and write

2020-02-20 Thread GitBox
hequn8128 commented on a change in pull request #2: [FLINK-16121][python] Introduce ArrowReader and ArrowWriter for Arrow format data read and write URL: https://github.com/apache/flink/pull/2#discussion_r382413045 ## File path: flink-python/src/test/java/org/apache/flink/t

[GitHub] [flink] hequn8128 commented on a change in pull request #11112: [FLINK-16121][python] Introduce ArrowReader and ArrowWriter for Arrow format data read and write

2020-02-20 Thread GitBox
hequn8128 commented on a change in pull request #2: [FLINK-16121][python] Introduce ArrowReader and ArrowWriter for Arrow format data read and write URL: https://github.com/apache/flink/pull/2#discussion_r382381840 ## File path: flink-python/src/main/java/org/apache/flink/t

[GitHub] [flink] JingsongLi commented on a change in pull request #11127: [FLINK-16081][docs] Translate /dev/table/index.zh.md

2020-02-20 Thread GitBox
JingsongLi commented on a change in pull request #11127: [FLINK-16081][docs] Translate /dev/table/index.zh.md URL: https://github.com/apache/flink/pull/11127#discussion_r382408900 ## File path: docs/dev/table/index.zh.md ## @@ -25,41 +25,41 @@ specific language governing p

[GitHub] [flink] JingsongLi commented on a change in pull request #11127: [FLINK-16081][docs] Translate /dev/table/index.zh.md

2020-02-20 Thread GitBox
JingsongLi commented on a change in pull request #11127: [FLINK-16081][docs] Translate /dev/table/index.zh.md URL: https://github.com/apache/flink/pull/11127#discussion_r382411234 ## File path: docs/dev/table/index.zh.md ## @@ -109,9 +108,9 @@ Internally, parts of the tabl

[GitHub] [flink] JingsongLi commented on a change in pull request #11127: [FLINK-16081][docs] Translate /dev/table/index.zh.md

2020-02-20 Thread GitBox
JingsongLi commented on a change in pull request #11127: [FLINK-16081][docs] Translate /dev/table/index.zh.md URL: https://github.com/apache/flink/pull/11127#discussion_r382409904 ## File path: docs/dev/table/index.zh.md ## @@ -25,41 +25,41 @@ specific language governing p

[GitHub] [flink] JingsongLi commented on a change in pull request #11127: [FLINK-16081][docs] Translate /dev/table/index.zh.md

2020-02-20 Thread GitBox
JingsongLi commented on a change in pull request #11127: [FLINK-16081][docs] Translate /dev/table/index.zh.md URL: https://github.com/apache/flink/pull/11127#discussion_r382410038 ## File path: docs/dev/table/index.zh.md ## @@ -25,41 +25,41 @@ specific language governing p

[GitHub] [flink] JingsongLi commented on a change in pull request #11127: [FLINK-16081][docs] Translate /dev/table/index.zh.md

2020-02-20 Thread GitBox
JingsongLi commented on a change in pull request #11127: [FLINK-16081][docs] Translate /dev/table/index.zh.md URL: https://github.com/apache/flink/pull/11127#discussion_r382408413 ## File path: docs/dev/table/index.zh.md ## @@ -25,41 +25,41 @@ specific language governing p

[GitHub] [flink] JingsongLi commented on a change in pull request #11127: [FLINK-16081][docs] Translate /dev/table/index.zh.md

2020-02-20 Thread GitBox
JingsongLi commented on a change in pull request #11127: [FLINK-16081][docs] Translate /dev/table/index.zh.md URL: https://github.com/apache/flink/pull/11127#discussion_r382410647 ## File path: docs/dev/table/index.zh.md ## @@ -25,41 +25,41 @@ specific language governing p

[GitHub] [flink] JingsongLi commented on a change in pull request #11127: [FLINK-16081][docs] Translate /dev/table/index.zh.md

2020-02-20 Thread GitBox
JingsongLi commented on a change in pull request #11127: [FLINK-16081][docs] Translate /dev/table/index.zh.md URL: https://github.com/apache/flink/pull/11127#discussion_r382409287 ## File path: docs/dev/table/index.zh.md ## @@ -25,41 +25,41 @@ specific language governing p

[GitHub] [flink] JingsongLi commented on a change in pull request #11127: [FLINK-16081][docs] Translate /dev/table/index.zh.md

2020-02-20 Thread GitBox
JingsongLi commented on a change in pull request #11127: [FLINK-16081][docs] Translate /dev/table/index.zh.md URL: https://github.com/apache/flink/pull/11127#discussion_r382411106 ## File path: docs/dev/table/index.zh.md ## @@ -25,41 +25,41 @@ specific language governing p

[GitHub] [flink] JingsongLi commented on a change in pull request #11127: [FLINK-16081][docs] Translate /dev/table/index.zh.md

2020-02-20 Thread GitBox
JingsongLi commented on a change in pull request #11127: [FLINK-16081][docs] Translate /dev/table/index.zh.md URL: https://github.com/apache/flink/pull/11127#discussion_r38240 ## File path: docs/dev/table/index.zh.md ## @@ -25,41 +25,41 @@ specific language governing p

[jira] [Closed] (FLINK-15652) Support for imagePullSecrets k8s option

2020-02-20 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-15652. - Resolution: Fixed master via 294a219b89e42fda199e0c6de697fd7a48c97c38 7bc7930d409bebcec10d9bd5d7832d498

[jira] [Updated] (FLINK-15652) Support for imagePullSecrets k8s option

2020-02-20 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-15652: -- Description: It's likely that one would pull images from the private image registry, credentials can

[GitHub] [flink] TisonKun closed pull request #11166: [FLINK-15652][kubernetes] Support for imagePullSecrets K8s option

2020-02-20 Thread GitBox
TisonKun closed pull request #11166: [FLINK-15652][kubernetes] Support for imagePullSecrets K8s option URL: https://github.com/apache/flink/pull/11166 This is an automated message from the Apache Git Service. To respond to t

[GitHub] [flink] TisonKun closed pull request #11054: [FLINK-15652][K8s] Support for imagePullSecrets K8s option.

2020-02-20 Thread GitBox
TisonKun closed pull request #11054: [FLINK-15652][K8s] Support for imagePullSecrets K8s option. URL: https://github.com/apache/flink/pull/11054 This is an automated message from the Apache Git Service. To respond to the mes

[jira] [Commented] (FLINK-13302) DateTimeUtils.unixDateCeil returns the same value as unixDateFloor does

2020-02-20 Thread Zhenghua Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17041568#comment-17041568 ] Zhenghua Gao commented on FLINK-13302: -- [~tison] The related issue is fixed in avat

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

2020-02-20 Thread GitBox
flinkbot edited a comment 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-567435407 ## CI report: * 6b12b52b99894864db993a2fa8ab2bfcce0edd5c Travis: [FAILURE](https://t

[GitHub] [flink] wsry commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

2020-02-20 Thread GitBox
wsry commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#discussion_r382404708 ## File path: flink-streaming-java/src/test/java/org/apache/flink/st

[GitHub] [flink] wuchong commented on issue #10822: [FLINK-15081][docs-zh]Translate "Concepts & Common API" page of Table…

2020-02-20 Thread GitBox
wuchong commented on issue #10822: [FLINK-15081][docs-zh]Translate "Concepts & Common API" page of Table… URL: https://github.com/apache/flink/pull/10822#issuecomment-589505461 @CrazyTomatoOo could you resolve the conflict if you have time? -

[GitHub] [flink] wuchong commented on issue #10822: [FLINK-15081][docs-zh]Translate "Concepts & Common API" page of Table…

2020-02-20 Thread GitBox
wuchong commented on issue #10822: [FLINK-15081][docs-zh]Translate "Concepts & Common API" page of Table… URL: https://github.com/apache/flink/pull/10822#issuecomment-589505409 Hi @libenchao , could you help to review this?

[GitHub] [flink] wuchong commented on issue #11114: FLINK-16105 Translate "User-defined Sources & Sinks" page of "Table API & SQL" into Chinese

2020-02-20 Thread GitBox
wuchong commented on issue #4: FLINK-16105 Translate "User-defined Sources & Sinks" page of "Table API & SQL" into Chinese URL: https://github.com/apache/flink/pull/4#issuecomment-589505219 Hi @zgq25302111 , it seems that the content is not translated. Is this PR a mistake? --

[GitHub] [flink] wuchong commented on issue #11127: [FLINK-16081][docs] Translate /dev/table/index.zh.md

2020-02-20 Thread GitBox
wuchong commented on issue #11127: [FLINK-16081][docs] Translate /dev/table/index.zh.md URL: https://github.com/apache/flink/pull/11127#issuecomment-589505030 Hi @JingsongLi , could you help to review this? This is an automat

[GitHub] [flink] wuchong commented on a change in pull request #11128: [FLINK-16082][docs] Translate /dev/table/streaming/index.zh.md

2020-02-20 Thread GitBox
wuchong commented on a change in pull request #11128: [FLINK-16082][docs] Translate /dev/table/streaming/index.zh.md URL: https://github.com/apache/flink/pull/11128#discussion_r382403928 ## File path: docs/dev/table/streaming/index.zh.md ## @@ -25,20 +25,20 @@ specific lan

[GitHub] [flink] flinkbot edited a comment on issue #11158: [FLINK-16070] [table-planner-blink] blink stream planner supports remove constant keys from an aggregate

2020-02-20 Thread GitBox
flinkbot edited a comment on issue #11158: [FLINK-16070] [table-planner-blink] blink stream planner supports remove constant keys from an aggregate URL: https://github.com/apache/flink/pull/11158#issuecomment-589009467 ## CI report: * 8d5d2238515b1d63bf1591e1b1bbef8611af5c99 Trav

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

2020-02-20 Thread GitBox
flinkbot edited a comment 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-567435407 ## CI report: * 6b12b52b99894864db993a2fa8ab2bfcce0edd5c Travis: [FAILURE](https://t

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

2020-02-20 Thread GitBox
zhijiangW commented on issue #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#issuecomment-589501898 @pnowojski I guess you might also be interested in taking a look. :) ---

[GitHub] [flink] zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

2020-02-20 Thread GitBox
zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#discussion_r382399441 ## File path: flink-streaming-java/src/test/java/org/apache/fl

[jira] [Comment Edited] (FLINK-15400) elasticsearch sink support dynamic index.

2020-02-20 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17041552#comment-17041552 ] Benchao Li edited comment on FLINK-15400 at 2/21/20 5:00 AM: -

[GitHub] [flink] zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

2020-02-20 Thread GitBox
zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#discussion_r382398126 ## File path: flink-runtime/src/main/java/org/apache/flink/run

[GitHub] [flink] zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

2020-02-20 Thread GitBox
zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#discussion_r382397221 ## File path: flink-streaming-java/src/test/java/org/apache/fl

[jira] [Comment Edited] (FLINK-15400) elasticsearch sink support dynamic index.

2020-02-20 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17041552#comment-17041552 ] Benchao Li edited comment on FLINK-15400 at 2/21/20 4:55 AM: -

[jira] [Commented] (FLINK-15400) elasticsearch sink support dynamic index.

2020-02-20 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17041552#comment-17041552 ] Benchao Li commented on FLINK-15400: [~Leonard Xu] [~ouyangwuli]  I raise another op

[GitHub] [flink] flinkbot edited a comment on issue #11166: [FLINK-15652][kubernetes] Support for imagePullSecrets K8s option

2020-02-20 Thread GitBox
flinkbot edited a comment on issue #11166: [FLINK-15652][kubernetes] Support for imagePullSecrets K8s option URL: https://github.com/apache/flink/pull/11166#issuecomment-589483589 ## CI report: * 2ffeee94cc50f782aa6f9b937391d007e9bd6d90 Travis: [SUCCESS](https://travis-ci.com/fl

[GitHub] [flink] flinkbot edited a comment on issue #11158: [FLINK-16070] [table-planner-blink] blink stream planner supports remove constant keys from an aggregate

2020-02-20 Thread GitBox
flinkbot edited a comment on issue #11158: [FLINK-16070] [table-planner-blink] blink stream planner supports remove constant keys from an aggregate URL: https://github.com/apache/flink/pull/11158#issuecomment-589009467 ## CI report: * 8d5d2238515b1d63bf1591e1b1bbef8611af5c99 Trav

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

2020-02-20 Thread GitBox
gaoyunhaii 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_r382395900 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/netw

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

2020-02-20 Thread GitBox
gaoyunhaii 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_r382395948 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/netw

[GitHub] [flink] zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

2020-02-20 Thread GitBox
zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#discussion_r382395379 ## File path: flink-runtime/src/main/java/org/apache/flink/run

[GitHub] [flink] zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

2020-02-20 Thread GitBox
zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#discussion_r382395379 ## File path: flink-runtime/src/main/java/org/apache/flink/run

[jira] [Commented] (FLINK-15400) elasticsearch sink support dynamic index.

2020-02-20 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17041547#comment-17041547 ] ouyangwulin commented on FLINK-15400: - [~Leonard Xu] If configed 'connector.dynamicI

[jira] [Commented] (FLINK-15400) elasticsearch sink support dynamic index.

2020-02-20 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17041545#comment-17041545 ] ouyangwulin commented on FLINK-15400: - [~Leonard Xu]. Yes I have a design from blink

[GitHub] [flink] zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

2020-02-20 Thread GitBox
zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#discussion_r382394612 ## File path: flink-streaming-java/src/test/java/org/apache/fl

[GitHub] [flink] zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

2020-02-20 Thread GitBox
zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#discussion_r382394298 ## File path: flink-streaming-java/src/test/java/org/apache/fl

[GitHub] [flink] zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

2020-02-20 Thread GitBox
zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#discussion_r382390260 ## File path: flink-streaming-java/src/test/java/org/apache/fl

[GitHub] [flink] zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

2020-02-20 Thread GitBox
zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#discussion_r382390727 ## File path: flink-streaming-java/src/test/java/org/apache/fl

  1   2   3   4   5   6   >