[GitHub] [flink] flinkbot commented on pull request #14692: [FLINK-20944][k8s] Do not resolve the rest endpoint address when the service exposed type is ClusterIP

2021-01-18 Thread GitBox
flinkbot commented on pull request #14692: URL: https://github.com/apache/flink/pull/14692#issuecomment-762669595 ## CI report: * 48ef644b381d5f9f0dd030857fcaab5e80ab4a97 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] rkhachatryan commented on pull request #10847: [FLINK-15578][connectors/jdbc] implement exactly once JDBC sink

2021-01-18 Thread GitBox
rkhachatryan commented on pull request #10847: URL: https://github.com/apache/flink/pull/10847#issuecomment-762667088 Sure! Rebased and squashed. This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] LadyForest commented on pull request #14687: [FLINK-17868][table-planner-blink] Fix proctime in DDL can not work in batch mode

2021-01-18 Thread GitBox
LadyForest commented on pull request #14687: URL: https://github.com/apache/flink/pull/14687#issuecomment-762664434 Hi @wuchong, would you mind helping to review this PR when you're free? This is an automated message from

[GitHub] [flink] pnowojski edited a comment on pull request #10847: [FLINK-15578][connectors/jdbc] implement exactly once JDBC sink

2021-01-18 Thread GitBox
pnowojski edited a comment on pull request #10847: URL: https://github.com/apache/flink/pull/10847#issuecomment-762660463 Azure failure is unrelated and long time ago fixed issue. Thanks for the useful contribution and the reviewing effort! I will merge it soon, but can you @rkhachatryan

[GitHub] [flink] flinkbot edited a comment on pull request #14690: [FLINK-20924][python][table-planner-blink] Port StreamExecPythonOverAggregate and BatchExecPythonOverAggregate to Java

2021-01-18 Thread GitBox
flinkbot edited a comment on pull request #14690: URL: https://github.com/apache/flink/pull/14690#issuecomment-762651189 ## CI report: * 3d769c75ac612ec289fb45cc0370585dc82aef60 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14691: [FLINK-21018] Update checkpoint related documentation for UI

2021-01-18 Thread GitBox
flinkbot edited a comment on pull request #14691: URL: https://github.com/apache/flink/pull/14691#issuecomment-762651310 ## CI report: * c02e54d3e599a05ebb96cbb66aaade1e058da0fe Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14687: [FLINK-17868][table-planner-blink] Fix proctime in DDL can not work in batch mode

2021-01-18 Thread GitBox
flinkbot edited a comment on pull request #14687: URL: https://github.com/apache/flink/pull/14687#issuecomment-762573853 ## CI report: * cd776fae11a260742de0ebdfb7e3931d46d14bb1 Azure:

[GitHub] [flink] flinkbot commented on pull request #14693: [FLINK-19446][canal][json] canal-json has a situation that -U and +U are equal, when updating the null field to be non-null

2021-01-18 Thread GitBox
flinkbot commented on pull request #14693: URL: https://github.com/apache/flink/pull/14693#issuecomment-762660520 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] pnowojski commented on pull request #10847: [FLINK-15578][connectors/jdbc] implement exactly once JDBC sink

2021-01-18 Thread GitBox
pnowojski commented on pull request #10847: URL: https://github.com/apache/flink/pull/10847#issuecomment-762660463 Azure failure is unrelated and long time ago fixed issue. Thanks for the useful contribution and the reviewing effort! Merging

[jira] [Updated] (FLINK-19446) canal-json has a situation that -U and +U are equal, when updating the null field to be non-null

2021-01-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19446: --- Labels: pull-request-available (was: ) > canal-json has a situation that -U and +U are

[GitHub] [flink] SteNicholas opened a new pull request #14693: [FLINK-19446][canal][json] canal-json has a situation that -U and +U are equal, when updating the null field to be non-null

2021-01-18 Thread GitBox
SteNicholas opened a new pull request #14693: URL: https://github.com/apache/flink/pull/14693 ## What is the purpose of the change *When `CanalJsonDeserializationSchema` deserializes the null field to be non-null, canal-json has a situation that -U and +U are equal. Because

[GitHub] [flink] flinkbot commented on pull request #14692: [FLINK-20944][k8s] Do not resolve the rest endpoint address when the service exposed type is ClusterIP

2021-01-18 Thread GitBox
flinkbot commented on pull request #14692: URL: https://github.com/apache/flink/pull/14692#issuecomment-762658235 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Commented] (FLINK-20944) Launching in application mode requesting a ClusterIP rest service type results in an Exception

2021-01-18 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17267718#comment-17267718 ] Yang Wang commented on FLINK-20944: --- [~rmetzger] I have attached a PR for this issue. Could you please

[jira] [Updated] (FLINK-20944) Launching in application mode requesting a ClusterIP rest service type results in an Exception

2021-01-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20944: --- Labels: pull-request-available (was: ) > Launching in application mode requesting a

[GitHub] [flink] wangyang0918 opened a new pull request #14692: [FLINK-20944][k8s] Do not resolve the rest endpoint address when the service exposed type is ClusterIP

2021-01-18 Thread GitBox
wangyang0918 opened a new pull request #14692: URL: https://github.com/apache/flink/pull/14692 ## What is the purpose of the change If the `kubernetes.rest-service.exposed.type` is `ClusterIP`, then we do not need to resolve the rest endpoint address(aka namespaced service

[GitHub] [flink] YuvalItzchakov commented on pull request #14633: [FLINK-20961][table-planner-blink] Fix NPE when no assigned timestamp defined

2021-01-18 Thread GitBox
YuvalItzchakov commented on pull request #14633: URL: https://github.com/apache/flink/pull/14633#issuecomment-762653431 Hi @wuchong. Yes I'm working on it ATM, struggling a bit to get Flink to compile from source but I'm confident I'll resolve it soon

[GitHub] [flink] flinkbot commented on pull request #14691: [FLINK-21018] Update checkpoint related documentation for UI

2021-01-18 Thread GitBox
flinkbot commented on pull request #14691: URL: https://github.com/apache/flink/pull/14691#issuecomment-762651310 ## CI report: * c02e54d3e599a05ebb96cbb66aaade1e058da0fe UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #14690: [FLINK-20924][python][table-planner-blink] Port StreamExecPythonOverAggregate and BatchExecPythonOverAggregate to Java

2021-01-18 Thread GitBox
flinkbot commented on pull request #14690: URL: https://github.com/apache/flink/pull/14690#issuecomment-762651189 ## CI report: * 3d769c75ac612ec289fb45cc0370585dc82aef60 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #14637: [FLINK-20949][table-planner-blink] Separate the implementation of sink nodes

2021-01-18 Thread GitBox
flinkbot edited a comment on pull request #14637: URL: https://github.com/apache/flink/pull/14637#issuecomment-759980085 ## CI report: * f2db6f3e6c725c09b24e919ea6cc45537be86d35 Azure:

[GitHub] [flink] XComp commented on a change in pull request #14686: [FLINK-6042][runtime] Adds exception history

2021-01-18 Thread GitBox
XComp commented on a change in pull request #14686: URL: https://github.com/apache/flink/pull/14686#discussion_r559953578 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java ## @@ -270,9 +270,22 @@ private void

[GitHub] [flink] dixingxing0 commented on pull request #14634: [FLINK-20913][hive]Improve HiveConf creation

2021-01-18 Thread GitBox
dixingxing0 commented on pull request #14634: URL: https://github.com/apache/flink/pull/14634#issuecomment-762646954 > @dixingxing0 , could you also create pull requests for release-1.12 and release-1.11? I would like to do that, i will submit the PR asap.

[GitHub] [flink] wuchong commented on pull request #14633: [FLINK-20961][table-planner-blink] Fix NPE when no assigned timestamp defined

2021-01-18 Thread GitBox
wuchong commented on pull request #14633: URL: https://github.com/apache/flink/pull/14633#issuecomment-762644603 Hi @YuvalItzchakov do you have to to update the pull request? This is an automated message from the Apache Git

[jira] [Commented] (FLINK-20913) Improve new HiveConf(jobConf, HiveConf.class)

2021-01-18 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17267696#comment-17267696 ] Rui Li commented on FLINK-20913: Hi [~dixingx...@yeah.net] could you please also submit PRs for 1.11 and

[GitHub] [flink] wuchong commented on pull request #14634: [FLINK-20913][hive]Improve HiveConf creation

2021-01-18 Thread GitBox
wuchong commented on pull request #14634: URL: https://github.com/apache/flink/pull/14634#issuecomment-762643936 @dixingxing0 , could you also create pull requests for release-1.12 and release-1.11? This is an automated

[GitHub] [flink] flinkbot commented on pull request #14690: [FLINK-20924][python][table-planner-blink] Port StreamExecPythonOverAggregate and BatchExecPythonOverAggregate to Java

2021-01-18 Thread GitBox
flinkbot commented on pull request #14690: URL: https://github.com/apache/flink/pull/14690#issuecomment-762643741 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Commented] (FLINK-20913) Improve new HiveConf(jobConf, HiveConf.class)

2021-01-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17267695#comment-17267695 ] Jark Wu commented on FLINK-20913: - Fixed in - master: ccc306f398f1b74681f12667de855b940dc61498 >

[GitHub] [flink] flinkbot commented on pull request #14691: [FLINK-21018] Update checkpoint related documentation for UI

2021-01-18 Thread GitBox
flinkbot commented on pull request #14691: URL: https://github.com/apache/flink/pull/14691#issuecomment-762643722 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] wuchong merged pull request #14634: [FLINK-20913][hive]Improve HiveConf creation

2021-01-18 Thread GitBox
wuchong merged pull request #14634: URL: https://github.com/apache/flink/pull/14634 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[jira] [Updated] (FLINK-21018) Follow up of FLINK-20488 to update checkpoint related documentation for UI

2021-01-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21018: --- Labels: pull-request-available (was: ) > Follow up of FLINK-20488 to update checkpoint

[GitHub] [flink] JavaPentesters commented on pull request #14535: [FLINK-20026][Connector][Jdbc] Jdbc connector support regular expression

2021-01-18 Thread GitBox
JavaPentesters commented on pull request #14535: URL: https://github.com/apache/flink/pull/14535#issuecomment-762642866 Thanks for your nice work! It's a good idea to add a unit test! Please Refer to the existing unit tests

[GitHub] [flink] curcur opened a new pull request #14691: [FLINK-21018] Update checkpoint related documentation for UI

2021-01-18 Thread GitBox
curcur opened a new pull request #14691: URL: https://github.com/apache/flink/pull/14691 ## What is the purpose of the change Follow up of FLINK-20488 to update checkpoint related documentation for UI This is

[jira] [Updated] (FLINK-20924) Port StreamExecPythonOverAggregate and BatchExecPythonOverAggregate to Java

2021-01-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20924: --- Labels: pull-request-available (was: ) > Port StreamExecPythonOverAggregate and

[GitHub] [flink] HuangXingBo opened a new pull request #14690: [FLINK-20924][python][table-planner-blink] Port StreamExecPythonOverAggregate and BatchExecPythonOverAggregate to Java

2021-01-18 Thread GitBox
HuangXingBo opened a new pull request #14690: URL: https://github.com/apache/flink/pull/14690 ## What is the purpose of the change *This pull request will Port StreamExecPythonOverAggregate and BatchExecPythonOverAggregate to Java* ## Brief change log -

[jira] [Assigned] (FLINK-20961) Flink throws NullPointerException for tables created from DataStream with no assigned timestamps and watermarks

2021-01-18 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-20961: -- Assignee: Yuval Itzchakov > Flink throws NullPointerException for tables created from

[jira] [Updated] (FLINK-20913) Improve new HiveConf(jobConf, HiveConf.class)

2021-01-18 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-20913: --- Priority: Critical (was: Major) > Improve new HiveConf(jobConf, HiveConf.class) >

[jira] [Updated] (FLINK-20913) Improve new HiveConf(jobConf, HiveConf.class)

2021-01-18 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-20913: --- Fix Version/s: 1.11.4 > Improve new HiveConf(jobConf, HiveConf.class) >

[jira] [Updated] (FLINK-20913) Improve new HiveConf(jobConf, HiveConf.class)

2021-01-18 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-20913: --- Fix Version/s: 1.12.2 1.13.0 > Improve new HiveConf(jobConf, HiveConf.class) >

[GitHub] [flink] zhuzhurk commented on a change in pull request #14659: [FLINK-20931][coordination] Remove globalModVersion from ExecutionGraph

2021-01-18 Thread GitBox
zhuzhurk commented on a change in pull request #14659: URL: https://github.com/apache/flink/pull/14659#discussion_r559941714 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java ## @@ -938,7 +929,7 @@ public void

[jira] [Updated] (FLINK-21022) flink-connector-es add onSuccess handler after bulk process for sync success data to other third party system for data consistency checking

2021-01-18 Thread Zheng WEI (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zheng WEI updated FLINK-21022: -- Affects Version/s: 1.12.0 > flink-connector-es add onSuccess handler after bulk process for sync

[jira] [Updated] (FLINK-21022) flink-connector-es add onSuccess handler after bulk process for sync success data to other third party system for data consistency checking

2021-01-18 Thread Zheng WEI (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zheng WEI updated FLINK-21022: -- Description: flink-connector-es add onSuccess handler after successful bulk process, in order to sync

[GitHub] [flink] flinkbot edited a comment on pull request #14675: [FLINK-18383][docs]translate "JDBC SQL Connector" documentation into …

2021-01-18 Thread GitBox
flinkbot edited a comment on pull request #14675: URL: https://github.com/apache/flink/pull/14675#issuecomment-761769906 ## CI report: * b57985e871e0b703fcaaeb85a597a8ab1584c10b Azure:

[jira] [Updated] (FLINK-21022) flink-connector-es add onSuccess handler after bulk process for sync success data to other third party system for data consistency checking

2021-01-18 Thread Zheng WEI (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zheng WEI updated FLINK-21022: -- Fix Version/s: 1.12.3 1.13.0 > flink-connector-es add onSuccess handler after bulk

[jira] [Updated] (FLINK-21022) flink-connector-es add onSuccess handler after bulk process for sync success data to other third party system for data consistency checking

2021-01-18 Thread Zheng WEI (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zheng WEI updated FLINK-21022: -- Affects Version/s: (was: 1.10.2) > flink-connector-es add onSuccess handler after bulk process

[jira] [Updated] (FLINK-21022) flink-connector-es add onSuccess handler after bulk process for sync success data to other third party system for data consistency checking

2021-01-18 Thread Zheng WEI (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zheng WEI updated FLINK-21022: -- Affects Version/s: 1.10.2 > flink-connector-es add onSuccess handler after bulk process for sync

[jira] [Commented] (FLINK-8093) flink job fail because of kafka producer create fail of "javax.management.InstanceAlreadyExistsException"

2021-01-18 Thread Alexey Trenikhin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17267686#comment-17267686 ] Alexey Trenikhin commented on FLINK-8093: - Same issue with Flink 1.12 > flink job fail because

[jira] [Created] (FLINK-21022) flink-connector-es add onSuccess handler after bulk process for sync success data to other third party system for data consistency checking

2021-01-18 Thread Zheng WEI (Jira)
Zheng WEI created FLINK-21022: - Summary: flink-connector-es add onSuccess handler after bulk process for sync success data to other third party system for data consistency checking Key: FLINK-21022 URL:

[jira] [Closed] (FLINK-21006) HBaseTablePlanTest tests failed in haoop 3.1.3 with "java.lang.NoSuchMethodError: com.google.common.base.Preconditions.checkArgument(ZLjava/lang/String;Ljava/lang/Object;

2021-01-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-21006. --- Resolution: Fixed Fixed in master: c1b700ba0ba3e2361b82434441946eb26d25afea > HBaseTablePlanTest tests

[GitHub] [flink] wuchong merged pull request #14680: [FLINK-21006][HBase] fix HBaseTablePlanTest tests failed in haoop 3.1.3 with "ja…

2021-01-18 Thread GitBox
wuchong merged pull request #14680: URL: https://github.com/apache/flink/pull/14680 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[jira] [Assigned] (FLINK-21002) Support exactly once sink for JDBC in Table SQL API

2021-01-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-21002: --- Assignee: Zhi Qi > Support exactly once sink for JDBC in Table SQL API >

[GitHub] [flink] flinkbot edited a comment on pull request #14675: [FLINK-18383][docs]translate "JDBC SQL Connector" documentation into …

2021-01-18 Thread GitBox
flinkbot edited a comment on pull request #14675: URL: https://github.com/apache/flink/pull/14675#issuecomment-761769906 ## CI report: * 519566b1079bfca772b00c6c905cbb177594b346 Azure:

[GitHub] [flink] JavaPentesters commented on pull request #14675: [FLINK-18383][docs]translate "JDBC SQL Connector" documentation into …

2021-01-18 Thread GitBox
JavaPentesters commented on pull request #14675: URL: https://github.com/apache/flink/pull/14675#issuecomment-762620839 > > @leonardBang Thanks for all your great suggestion! It's my first time to receive PR review.So, what should I do next? How to append commit? > > You can append

[jira] [Commented] (FLINK-20811) Support HTTP paths for yarn ship files/archives

2021-01-18 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17267672#comment-17267672 ] Nicholas Jiang commented on FLINK-20811: [~xintongsong], [~ZhenqiuHuang], thanks for the summary

[jira] [Commented] (FLINK-10360) support timeout in savepoint REST api

2021-01-18 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17267664#comment-17267664 ] Roman Khachatryan commented on FLINK-10360: --- [~stevenz3wu], is it the same issue as

[jira] [Commented] (FLINK-20811) Support HTTP paths for yarn ship files/archives

2021-01-18 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17267662#comment-17267662 ] Zhenqiu Huang commented on FLINK-20811: --- [~xintongsong] I think we are on the same page. If

[jira] [Updated] (FLINK-10360) support timeout in savepoint REST api

2021-01-18 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-10360: -- Component/s: Runtime / Checkpointing > support timeout in savepoint REST api >

[jira] [Commented] (FLINK-20811) Support HTTP paths for yarn ship files/archives

2021-01-18 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17267661#comment-17267661 ] Xintong Song commented on FLINK-20811: -- [~ZhenqiuHuang] [~nicholasjiang] [~trohrmann]

[jira] [Created] (FLINK-21021) Bump Beam to 2.27.0

2021-01-18 Thread Dian Fu (Jira)
Dian Fu created FLINK-21021: --- Summary: Bump Beam to 2.27.0 Key: FLINK-21021 URL: https://issues.apache.org/jira/browse/FLINK-21021 Project: Flink Issue Type: Improvement Components: API

[GitHub] [flink] JavaPentesters commented on a change in pull request #14675: [FLINK-18383][docs]translate "JDBC SQL Connector" documentation into …

2021-01-18 Thread GitBox
JavaPentesters commented on a change in pull request #14675: URL: https://github.com/apache/flink/pull/14675#discussion_r559918021 ## File path: docs/dev/table/connectors/jdbc.zh.md ## @@ -92,210 +93,207 @@ ON myTopic.key = MyUserTable.id; -Connector Options +连接器参数选项

[jira] [Created] (FLINK-21020) Bump Jackson to 2.12.1

2021-01-18 Thread Dian Fu (Jira)
Dian Fu created FLINK-21020: --- Summary: Bump Jackson to 2.12.1 Key: FLINK-21020 URL: https://issues.apache.org/jira/browse/FLINK-21020 Project: Flink Issue Type: Improvement Components:

[jira] [Created] (FLINK-21019) Bump Netty 4 to 4.1.58

2021-01-18 Thread Dian Fu (Jira)
Dian Fu created FLINK-21019: --- Summary: Bump Netty 4 to 4.1.58 Key: FLINK-21019 URL: https://issues.apache.org/jira/browse/FLINK-21019 Project: Flink Issue Type: Improvement Components:

[GitHub] [flink] flinkbot edited a comment on pull request #14689: [FLINK-20500][upsert-kafka] Fix temporal join test

2021-01-18 Thread GitBox
flinkbot edited a comment on pull request #14689: URL: https://github.com/apache/flink/pull/14689#issuecomment-762595621 ## CI report: * 7421043232e94c67d4e44020b8a5a319a3e95a09 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14637: [FLINK-20949][table-planner-blink] Separate the implementation of sink nodes

2021-01-18 Thread GitBox
flinkbot edited a comment on pull request #14637: URL: https://github.com/apache/flink/pull/14637#issuecomment-759980085 ## CI report: * 5e0f4982e094db9168e2f32e604776a7a40e0849 Azure:

[GitHub] [flink] leonardBang commented on pull request #14675: [FLINK-18383][docs]translate "JDBC SQL Connector" documentation into …

2021-01-18 Thread GitBox
leonardBang commented on pull request #14675: URL: https://github.com/apache/flink/pull/14675#issuecomment-762599669 > @leonardBang Thanks for all your great suggestion! It's my first time to receive PR review.So, what should I do next? How to append commit? You can append a commit

[GitHub] [flink] rkhachatryan commented on pull request #10847: [FLINK-15578][connectors/jdbc] implement exactly once JDBC sink

2021-01-18 Thread GitBox
rkhachatryan commented on pull request #10847: URL: https://github.com/apache/flink/pull/10847#issuecomment-762598597 Thanks a lot for reviewing and opening FLINK-21002 @wuchong ! This is an automated message from the Apache

[GitHub] [flink] flinkbot commented on pull request #14689: [FLINK-20500][upsert-kafka] Fix temporal join test

2021-01-18 Thread GitBox
flinkbot commented on pull request #14689: URL: https://github.com/apache/flink/pull/14689#issuecomment-762595621 ## CI report: * 7421043232e94c67d4e44020b8a5a319a3e95a09 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

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

2021-01-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17267640#comment-17267640 ] Jark Wu commented on FLINK-9477: Postgres supports the SQL standard JSON PATH, and support lex and strict

[jira] [Issue Comment Deleted] (FLINK-6949) Add ability to ship custom resource files to YARN cluster

2021-01-18 Thread Tang Yan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tang Yan updated FLINK-6949: Comment: was deleted (was: hi [~m.pryahin] Is the option -yt  can ship the folders to TaskManager's

[GitHub] [flink] flinkbot commented on pull request #14689: [FLINK-20500][upsert-kafka] Fix temporal join test

2021-01-18 Thread GitBox
flinkbot commented on pull request #14689: URL: https://github.com/apache/flink/pull/14689#issuecomment-762590774 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] fsk119 opened a new pull request #14689: [FLINK-20500][upsert-kafka] Fix temporal join test

2021-01-18 Thread GitBox
fsk119 opened a new pull request #14689: URL: https://github.com/apache/flink/pull/14689 ## What is the purpose of the change *The reason why the test fails is the records in the same partition are out-of-order. I print the partition-id and offset in the partition.*

[GitHub] [flink] flinkbot edited a comment on pull request #14688: [FLINK-21017][docs] Fix missing backquote in table connectors docs

2021-01-18 Thread GitBox
flinkbot edited a comment on pull request #14688: URL: https://github.com/apache/flink/pull/14688#issuecomment-762585652 ## CI report: * 900efdc160d8cc3f9b06a2558773cf692b4bcffa Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14637: [FLINK-20949][table-planner-blink] Separate the implementation of sink nodes

2021-01-18 Thread GitBox
flinkbot edited a comment on pull request #14637: URL: https://github.com/apache/flink/pull/14637#issuecomment-759980085 ## CI report: * 2e6f8afb27e427f04a3336e643476f57c482cc6e Azure:

[jira] [Commented] (FLINK-6949) Add ability to ship custom resource files to YARN cluster

2021-01-18 Thread Tang Yan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17267632#comment-17267632 ] Tang Yan commented on FLINK-6949: - hi [~m.pryahin] Is the option -yt  can ship the folders to

[GitHub] [flink] flinkbot commented on pull request #14688: [FLINK-21017][docs] Fix missing backquote in table connectors docs

2021-01-18 Thread GitBox
flinkbot commented on pull request #14688: URL: https://github.com/apache/flink/pull/14688#issuecomment-762585652 ## CI report: * 900efdc160d8cc3f9b06a2558773cf692b4bcffa UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #14685: [FLINK-21010] Separate the implementation of StreamExecJoin

2021-01-18 Thread GitBox
flinkbot edited a comment on pull request #14685: URL: https://github.com/apache/flink/pull/14685#issuecomment-762256472 ## CI report: * 0a5fff76d69da75391ceb25e470173bae504e1c9 Azure:

[jira] [Updated] (FLINK-21018) Follow up of FLINK-20488 to update checkpoint related documentation for UI

2021-01-18 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-21018: - Summary: Follow up of FLINK-20488 to update checkpoint related documentation for UI (was: Follow up of

[jira] [Commented] (FLINK-21002) Support exactly once sink for JDBC in Table SQL API

2021-01-18 Thread Zhi Qi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17267625#comment-17267625 ] Zhi Qi commented on FLINK-21002: [~jark] I want to do this, could you assign it to me? > Support

[jira] [Closed] (FLINK-20963) Rewrite the example under 'flink-python/pyflink/table/examples'

2021-01-18 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-20963. --- Resolution: Fixed Merged to master via 41a8a2ebcc9f9f5e062736d8f56331881f7244ce > Rewrite the example

[jira] [Created] (FLINK-21018) Follow up of FLINK-20488 to update checkpoint related documentation

2021-01-18 Thread Yuan Mei (Jira)
Yuan Mei created FLINK-21018: Summary: Follow up of FLINK-20488 to update checkpoint related documentation Key: FLINK-21018 URL: https://issues.apache.org/jira/browse/FLINK-21018 Project: Flink

[GitHub] [flink] dianfu merged pull request #14673: [FLINK-20963][python] Update example with the latest recommended API

2021-01-18 Thread GitBox
dianfu merged pull request #14673: URL: https://github.com/apache/flink/pull/14673 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] RocMarshal commented on pull request #14671: [hotfix][docs] Fix typo in 'docs/dev/table/functions/udfs.md & udfs.zh.md'.

2021-01-18 Thread GitBox
RocMarshal commented on pull request #14671: URL: https://github.com/apache/flink/pull/14671#issuecomment-762580819 @klion26 This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] flinkbot edited a comment on pull request #14687: [FLINK-17868][table-planner-blink] Fix proctime in DDL can not work in batch mode

2021-01-18 Thread GitBox
flinkbot edited a comment on pull request #14687: URL: https://github.com/apache/flink/pull/14687#issuecomment-762573853 ## CI report: * cd776fae11a260742de0ebdfb7e3931d46d14bb1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14637: [FLINK-20949][table-planner-blink] Separate the implementation of sink nodes

2021-01-18 Thread GitBox
flinkbot edited a comment on pull request #14637: URL: https://github.com/apache/flink/pull/14637#issuecomment-759980085 ## CI report: * 2e6f8afb27e427f04a3336e643476f57c482cc6e Azure:

[GitHub] [flink] flinkbot commented on pull request #14688: [FLINK-21017][docs] Fix missing backquote in table connectors docs

2021-01-18 Thread GitBox
flinkbot commented on pull request #14688: URL: https://github.com/apache/flink/pull/14688#issuecomment-762579727 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink-web] xintongsong closed pull request #405: Add Apache Flink release 1.12.1

2021-01-18 Thread GitBox
xintongsong closed pull request #405: URL: https://github.com/apache/flink-web/pull/405 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to

[GitHub] [flink-web] xintongsong commented on pull request #405: Add Apache Flink release 1.12.1

2021-01-18 Thread GitBox
xintongsong commented on pull request #405: URL: https://github.com/apache/flink-web/pull/405#issuecomment-762578540 Thanks all for the review. Comments addressed. Merging this. This is an automated message from the Apache

[GitHub] [flink] wenlong88 commented on a change in pull request #14637: [FLINK-20949][table-planner-blink] Separate the implementation of sink nodes

2021-01-18 Thread GitBox
wenlong88 commented on a change in pull request #14637: URL: https://github.com/apache/flink/pull/14637#discussion_r559890485 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecLegacySink.java ##

[jira] [Commented] (FLINK-21013) Blink planner does not ingest timestamp into StreamRecord

2021-01-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17267617#comment-17267617 ] Jark Wu commented on FLINK-21013: - I think this is an missing feature since Blink merge. See the

[jira] [Updated] (FLINK-21017) Fix missing backquote in table connectors docs

2021-01-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21017: --- Labels: pull-request-available (was: ) > Fix missing backquote in table connectors docs >

[jira] [Comment Edited] (FLINK-21013) Blink planner does not ingest timestamp into StreamRecord

2021-01-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17267617#comment-17267617 ] Jark Wu edited comment on FLINK-21013 at 1/19/21, 3:26 AM: --- I think this is a

[GitHub] [flink] fornaix opened a new pull request #14688: [FLINK-21017][docs] Fix missing backquote in table connectors docs

2021-01-18 Thread GitBox
fornaix opened a new pull request #14688: URL: https://github.com/apache/flink/pull/14688 ## What is the purpose of the change Fix missing backquote in table connectors docs. ## Brief change log * Fix missing backquote in `dev/table/connectors/index.md` * Fix

[jira] [Commented] (FLINK-20495) Elasticsearch6DynamicSinkITCase Hang

2021-01-18 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17267614#comment-17267614 ] Huang Xingbo commented on FLINK-20495: --

[GitHub] [flink-web] wangyang0918 commented on a change in pull request #405: Add Apache Flink release 1.12.1

2021-01-18 Thread GitBox
wangyang0918 commented on a change in pull request #405: URL: https://github.com/apache/flink-web/pull/405#discussion_r559889375 ## File path: _posts/2021-01-19-release-1.12.1.md ## @@ -0,0 +1,231 @@ +--- +layout: post +title: "Apache Flink 1.12.1 Released" +date:

[GitHub] [flink-web] dianfu commented on a change in pull request #405: Add Apache Flink release 1.12.1

2021-01-18 Thread GitBox
dianfu commented on a change in pull request #405: URL: https://github.com/apache/flink-web/pull/405#discussion_r559888663 ## File path: _posts/2021-01-19-release-1.12.1.md ## @@ -0,0 +1,231 @@ +--- +layout: post +title: "Apache Flink 1.12.1 Released" +date: 2021-01-19

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

2021-01-18 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17267612#comment-17267612 ] Jingsong Lee commented on FLINK-9477: - +1 for removing "lax " prefix. > FLIP-90: Support SQL 2016

[GitHub] [flink] JavaPentesters commented on pull request #14675: [FLINK-18383][docs]translate "JDBC SQL Connector" documentation into …

2021-01-18 Thread GitBox
JavaPentesters commented on pull request #14675: URL: https://github.com/apache/flink/pull/14675#issuecomment-762574753 @leonardBang Thanks for all your great suggestion! It's my first time to receive PR review.So, what should I do next? How to append commit?

[jira] [Created] (FLINK-21017) Fix missing backquote in table connectors docs

2021-01-18 Thread Han (Jira)
Han created FLINK-21017: --- Summary: Fix missing backquote in table connectors docs Key: FLINK-21017 URL: https://issues.apache.org/jira/browse/FLINK-21017 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-21016) Upload missing packages to PyPI for release 1.12.1

2021-01-18 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21016: - Description: Due to the PyPI project space limit, the following 1.12.1 packages are missing on

[GitHub] [flink] flinkbot commented on pull request #14687: [FLINK-17868][table-planner-blink] Fix proctime in DDL can not work in batch mode

2021-01-18 Thread GitBox
flinkbot commented on pull request #14687: URL: https://github.com/apache/flink/pull/14687#issuecomment-762573853 ## CI report: * cd776fae11a260742de0ebdfb7e3931d46d14bb1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #14685: [FLINK-21010] Separate the implementation of StreamExecJoin

2021-01-18 Thread GitBox
flinkbot edited a comment on pull request #14685: URL: https://github.com/apache/flink/pull/14685#issuecomment-762256472 ## CI report: * 6b3df98514e16f9956bffa301a96bd2530fcb4a5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14637: [FLINK-20949][table-planner-blink] Separate the implementation of sink nodes

2021-01-18 Thread GitBox
flinkbot edited a comment on pull request #14637: URL: https://github.com/apache/flink/pull/14637#issuecomment-759980085 ## CI report: * 2e6f8afb27e427f04a3336e643476f57c482cc6e Azure:

  1   2   3   4   >