[GitHub] [flink] azagrebin edited a comment on pull request #14199: [FLINK-20118][file connector] Extend FileSourceTextLinesITCase with JM/TM failover tests

2020-11-29 Thread GitBox
azagrebin edited a comment on pull request #14199: URL: https://github.com/apache/flink/pull/14199#issuecomment-735617972 Thanks for the review @StephanEwen I addressed comments, the commits can be also just merged into one before merge. I can merge the PR if you want.

[GitHub] [flink] azagrebin edited a comment on pull request #14199: [FLINK-20118][file connector] Extend FileSourceTextLinesITCase with JM/TM failover tests

2020-11-29 Thread GitBox
azagrebin edited a comment on pull request #14199: URL: https://github.com/apache/flink/pull/14199#issuecomment-735617972 Thanks for the review @StephanEwen I addressed comments, the commits can be also just merged into one before merge. I can merge the PR if you want after at least

[GitHub] [flink] azagrebin commented on pull request #14199: [FLINK-20118][file connector] Extend FileSourceTextLinesITCase with JM/TM failover tests

2020-11-29 Thread GitBox
azagrebin commented on pull request #14199: URL: https://github.com/apache/flink/pull/14199#issuecomment-735617972 Thanks for the review @StephanEwen I addressed comments, the commits can be also just merged into one before merge.

[GitHub] [flink] azagrebin commented on a change in pull request #14199: [FLINK-20118][file connector] Extend FileSourceTextLinesITCase with JM/TM failover tests

2020-11-29 Thread GitBox
azagrebin commented on a change in pull request #14199: URL: https://github.com/apache/flink/pull/14199#discussion_r532397107 ## File path: flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/src/FileSourceTextLinesITCase.java ## @@ -61,20

[GitHub] [flink] azagrebin commented on a change in pull request #14199: [FLINK-20118][file connector] Extend FileSourceTextLinesITCase with JM/TM failover tests

2020-11-29 Thread GitBox
azagrebin commented on a change in pull request #14199: URL: https://github.com/apache/flink/pull/14199#discussion_r532397548 ## File path: flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/src/FileSourceTextLinesITCase.java ## @@ -84,18

[GitHub] [flink] rmetzger commented on a change in pull request #14238: [FLINK-20347] Rework YARN documentation page

2020-11-29 Thread GitBox
rmetzger commented on a change in pull request #14238: URL: https://github.com/apache/flink/pull/14238#discussion_r532397327 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java ## @@ -1020,7 +1020,7 @@ private void

[GitHub] [flink] azagrebin commented on a change in pull request #14199: [FLINK-20118][file connector] Extend FileSourceTextLinesITCase with JM/TM failover tests

2020-11-29 Thread GitBox
azagrebin commented on a change in pull request #14199: URL: https://github.com/apache/flink/pull/14199#discussion_r532397107 ## File path: flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/src/FileSourceTextLinesITCase.java ## @@ -61,20

[jira] [Closed] (FLINK-19172) [AbstractFileStateBackend]

2020-11-29 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li closed FLINK-19172. - Resolution: Not A Problem In Flink we use the code convention that method parameters are non-null unless

[GitHub] [flink] flinkbot edited a comment on pull request #14152: [FLINK-19082][doc] Add docs for temporal table and temporal table join

2020-11-29 Thread GitBox
flinkbot edited a comment on pull request #14152: URL: https://github.com/apache/flink/pull/14152#issuecomment-731145130 ## CI report: * dfa09ece231af0ac4c36c21c9b192aa97c6b70f1 Azure:

[GitHub] [flink] rmetzger commented on a change in pull request #14238: [FLINK-20347] Rework YARN documentation page

2020-11-29 Thread GitBox
rmetzger commented on a change in pull request #14238: URL: https://github.com/apache/flink/pull/14238#discussion_r532395243 ## File path: docs/deployment/filesystems/index.zh.md ## @@ -82,7 +82,7 @@ cp ./opt/flink-s3-fs-hadoop-{{ site.version }}.jar ./plugins/s3-fs-hadoop/

[jira] [Updated] (FLINK-20415) Parsed QueryOperation does not contain watermark in schema

2020-11-29 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-20415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ingo Bürk updated FLINK-20415: -- Description: A parsed QueryOperation (e.g. from Parser#parse) does not contain the watermark

[jira] [Updated] (FLINK-20415) Parsed QueryOperation does not contain watermark in schema

2020-11-29 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-20415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ingo Bürk updated FLINK-20415: -- Description: A parsed QueryOperation (e.g. from Parser#parse) does not contain the watermark

[jira] [Commented] (FLINK-19863) SQLClientHBaseITCase.testHBase failed with "java.io.IOException: Process failed due to timeout"

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

[jira] [Created] (FLINK-20415) Parsed QueryOperation does not contain watermark in schema

2020-11-29 Thread Jira
Ingo Bürk created FLINK-20415: - Summary: Parsed QueryOperation does not contain watermark in schema Key: FLINK-20415 URL: https://issues.apache.org/jira/browse/FLINK-20415 Project: Flink Issue

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

2020-11-29 Thread GitBox
flinkbot edited a comment on pull request #10847: URL: https://github.com/apache/flink/pull/10847#issuecomment-573933799 ## CI report: * 693e48ac1e9cd413f54e7cbc4c46b9ae190ce848 Azure:

[GitHub] [flink] rmetzger commented on a change in pull request #14254: [FLINK-20357][docs] Split HA documentation up into a general overview and the specific implementations

2020-11-29 Thread GitBox
rmetzger commented on a change in pull request #14254: URL: https://github.com/apache/flink/pull/14254#discussion_r532384255 ## File path: docs/deployment/ha/zookeeper_ha.md ## @@ -23,113 +23,104 @@ specific language governing permissions and limitations under the License.

[jira] [Commented] (FLINK-20195) Jobs endpoint returns duplicated jobs

2020-11-29 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-20195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17240522#comment-17240522 ] Ingo Bürk commented on FLINK-20195: --- [~chesnay] Yes, we only observed this during a transition to

[GitHub] [flink] wangyang0918 commented on a change in pull request #14254: [FLINK-20357][docs] Split HA documentation up into a general overview and the specific implementations

2020-11-29 Thread GitBox
wangyang0918 commented on a change in pull request #14254: URL: https://github.com/apache/flink/pull/14254#discussion_r532384451 ## File path: docs/deployment/ha/kubernetes_ha.md ## @@ -2,7 +2,7 @@ title: "Kubernetes HA Services" nav-title: Kubernetes HA Services

[GitHub] [flink] flinkbot edited a comment on pull request #13983: [FLINK-19989][python] Add collect operation in Python DataStream API

2020-11-29 Thread GitBox
flinkbot edited a comment on pull request #13983: URL: https://github.com/apache/flink/pull/13983#issuecomment-723574143 ## CI report: * 89743b74e9f51dcb0b202a6ea54e2bd94947170e Azure:

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

2020-11-29 Thread GitBox
flinkbot edited a comment on pull request #10847: URL: https://github.com/apache/flink/pull/10847#issuecomment-573933799 ## CI report: * 693e48ac1e9cd413f54e7cbc4c46b9ae190ce848 Azure:

[GitHub] [flink] wangyang0918 commented on a change in pull request #14238: [FLINK-20347] Rework YARN documentation page

2020-11-29 Thread GitBox
wangyang0918 commented on a change in pull request #14238: URL: https://github.com/apache/flink/pull/14238#discussion_r532339513 ## File path: docs/deployment/resource-providers/yarn.md ## @@ -0,0 +1,238 @@ +--- +title: "Apache Hadoop YARN" +nav-title: YARN +nav-parent_id:

[GitHub] [flink] flinkbot edited a comment on pull request #13983: [FLINK-19989][python] Add collect operation in Python DataStream API

2020-11-29 Thread GitBox
flinkbot edited a comment on pull request #13983: URL: https://github.com/apache/flink/pull/13983#issuecomment-723574143 ## CI report: * 89743b74e9f51dcb0b202a6ea54e2bd94947170e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13488: [FLINK-19381][docs] Fix docs for savepoint relocation

2020-11-29 Thread GitBox
flinkbot edited a comment on pull request #13488: URL: https://github.com/apache/flink/pull/13488#issuecomment-699590439 ## CI report: * c8ba0ba6a2af6587da888a0365176c9e33759bad Azure:

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

2020-11-29 Thread GitBox
flinkbot edited a comment on pull request #10847: URL: https://github.com/apache/flink/pull/10847#issuecomment-573933799 ## CI report: * 693e48ac1e9cd413f54e7cbc4c46b9ae190ce848 Azure:

[GitHub] [flink] SteNicholas removed a comment on pull request #13983: [FLINK-19989][python] Add collect operation in Python DataStream API

2020-11-29 Thread GitBox
SteNicholas removed a comment on pull request #13983: URL: https://github.com/apache/flink/pull/13983#issuecomment-735070443 @dianfu , I have followed your comments above mentioned. Please help to review again. This is an

[GitHub] [flink] flinkbot edited a comment on pull request #14165: [FLINK-19687][table] Support to get execution plan from StatementSet

2020-11-29 Thread GitBox
flinkbot edited a comment on pull request #14165: URL: https://github.com/apache/flink/pull/14165#issuecomment-732020040 ## CI report: * c5728be97ab3b29a7dc4834b9fb2bbf63a0143dd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14152: [FLINK-19082][doc] Add docs for temporal table and temporal table join

2020-11-29 Thread GitBox
flinkbot edited a comment on pull request #14152: URL: https://github.com/apache/flink/pull/14152#issuecomment-731145130 ## CI report: * 25f4b1496af119c99555cfaf302a8eca568b1b8f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13488: [FLINK-19381][docs] Fix docs for savepoint relocation

2020-11-29 Thread GitBox
flinkbot edited a comment on pull request #13488: URL: https://github.com/apache/flink/pull/13488#issuecomment-699590439 ## CI report: * c8ba0ba6a2af6587da888a0365176c9e33759bad Azure:

[GitHub] [flink] rmetzger commented on pull request #14256: [FLINK-20396][checkpointing] Add a 'subtaskReset()' method to the OperatorCoordinator.

2020-11-29 Thread GitBox
rmetzger commented on pull request #14256: URL: https://github.com/apache/flink/pull/14256#issuecomment-735580490 I reported the e2e failure in https://issues.apache.org/jira/browse/FLINK-20410. This is an automated message

[jira] [Commented] (FLINK-20410) SQLClientSchemaRegistryITCase.testWriting failed with "Subject 'user_behavior' not found.; error code: 40401"

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

[GitHub] [flink] flinkbot edited a comment on pull request #14152: [FLINK-19082][doc] Add docs for temporal table and temporal table join

2020-11-29 Thread GitBox
flinkbot edited a comment on pull request #14152: URL: https://github.com/apache/flink/pull/14152#issuecomment-731145130 ## CI report: * 25f4b1496af119c99555cfaf302a8eca568b1b8f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13800: [FLINK-19650][connectors jdbc]Support the limit push down for the Jdb…

2020-11-29 Thread GitBox
flinkbot edited a comment on pull request #13800: URL: https://github.com/apache/flink/pull/13800#issuecomment-717132623 ## CI report: * d03e417c4b828ffb3e3b8061d0a9b5dd9a38b018 Azure:

[GitHub] [flink] leonardBang commented on pull request #14152: [FLINK-19082][doc] Add docs for temporal table and temporal table join

2020-11-29 Thread GitBox
leonardBang commented on pull request #14152: URL: https://github.com/apache/flink/pull/14152#issuecomment-735560931 @sjwiesman I've rebased again, do you have time to have a look? thanks. This is an automated message from

[GitHub] [flink] carp84 commented on pull request #13488: [FLINK-19381][docs] Fix docs for savepoint relocation

2020-11-29 Thread GitBox
carp84 commented on pull request #13488: URL: https://github.com/apache/flink/pull/13488#issuecomment-735552504 @klion26 Please also check @StephanEwen's comments [here](https://github.com/apache/flink/pull/14175#pullrequestreview-540475738).

[GitHub] [flink] flinkbot edited a comment on pull request #13800: [FLINK-19650][connectors jdbc]Support the limit push down for the Jdb…

2020-11-29 Thread GitBox
flinkbot edited a comment on pull request #13800: URL: https://github.com/apache/flink/pull/13800#issuecomment-717132623 ## CI report: * d03e417c4b828ffb3e3b8061d0a9b5dd9a38b018 Azure:

[GitHub] [flink] wangyang0918 commented on a change in pull request #14238: [FLINK-20347] Rework YARN documentation page

2020-11-29 Thread GitBox
wangyang0918 commented on a change in pull request #14238: URL: https://github.com/apache/flink/pull/14238#discussion_r532329248 ## File path: docs/deployment/index.zh.md ## @@ -25,47 +25,158 @@ specific language governing permissions and limitations under the License. -->

[GitHub] [flink] flinkbot edited a comment on pull request #13800: [FLINK-19650][connectors jdbc]Support the limit push down for the Jdb…

2020-11-29 Thread GitBox
flinkbot edited a comment on pull request #13800: URL: https://github.com/apache/flink/pull/13800#issuecomment-717132623 ## CI report: * d03e417c4b828ffb3e3b8061d0a9b5dd9a38b018 Azure:

[jira] [Resolved] (FLINK-20288) Correct documentation about savepoint self-contained

2020-11-29 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li resolved FLINK-20288. --- Resolution: Duplicate [~klion26] thanks for the reminder, closing this one as duplication of FLINK-19381

[GitHub] [flink] carp84 closed pull request #14175: [FLINK-20288][docs] Correct documentation about savepoint self-contained

2020-11-29 Thread GitBox
carp84 closed pull request #14175: URL: https://github.com/apache/flink/pull/14175 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] carp84 commented on pull request #14175: [FLINK-20288][docs] Correct documentation about savepoint self-contained

2020-11-29 Thread GitBox
carp84 commented on pull request #14175: URL: https://github.com/apache/flink/pull/14175#issuecomment-735533931 @klion26 I think you're right, this PR duplicates #13488 . Please check out Stephan's comments and address them in #13488 as well, thanks. @Myasuka @StephanEwen I'm

[GitHub] [flink-statefun] carp84 commented on pull request #131: [FLINK-18968] Translate README.md to Chinese

2020-11-29 Thread GitBox
carp84 commented on pull request #131: URL: https://github.com/apache/flink-statefun/pull/131#issuecomment-735532283 Closing this PR since it's already superseded by #176 This is an automated message from the Apache Git

[GitHub] [flink-statefun] carp84 closed pull request #131: [FLINK-18968] Translate README.md to Chinese

2020-11-29 Thread GitBox
carp84 closed pull request #131: URL: https://github.com/apache/flink-statefun/pull/131 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

[jira] [Closed] (FLINK-20405) The LAG function in over window is not implemented correctly

2020-11-29 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-20405. -- Resolution: Duplicate > The LAG function in over window is not implemented correctly >

[jira] [Commented] (FLINK-20405) The LAG function in over window is not implemented correctly

2020-11-29 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17240468#comment-17240468 ] Leonard Xu commented on FLINK-20405: [~libenchao] You're wright,  I will close and link to the

[GitHub] [flink] carp84 commented on a change in pull request #14248: [FLINK-20287][docs] Add documentation of how to switch memory allocator in Flink docker image

2020-11-29 Thread GitBox
carp84 commented on a change in pull request #14248: URL: https://github.com/apache/flink/pull/14248#discussion_r532335274 ## File path: docs/deployment/resource-providers/standalone/docker.zh.md ## @@ -268,6 +268,18 @@ The `ENABLE_BUILT_IN_PLUGINS` should contain a list of

[jira] [Commented] (FLINK-20414) 【HBase】FileNotFoundException: File /tmp/hbase-deploy/hbase/lib does not exist

2020-11-29 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17240466#comment-17240466 ] Jark Wu commented on FLINK-20414: - Did you find the reason? [~zhisheng] > 【HBase】FileNotFoundException:

[jira] [Assigned] (FLINK-20315) Optimize the compaction section for the document of table filesystem sink.

2020-11-29 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-20315: Assignee: Jingsong Lee > Optimize the compaction section for the document of table

[jira] [Assigned] (FLINK-20334) Introduce function endpoint path templating in module YAML specifications

2020-11-29 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-20334: --- Assignee: Tzu-Li (Gordon) Tai > Introduce function endpoint path

[GitHub] [flink-statefun] tzulitai commented on pull request #181: [FLINK-18810][sdk] Golang remote functions SDK

2020-11-29 Thread GitBox
tzulitai commented on pull request #181: URL: https://github.com/apache/flink-statefun/pull/181#issuecomment-735523466 Concerning the licensing: Since we won't be releasing artifacts for the Go SDK, I think ensuring compatibility for ASF 2.0 breaks down to: - Are there any copied

[jira] [Closed] (FLINK-20414) 【HBase】FileNotFoundException: File /tmp/hbase-deploy/hbase/lib does not exist

2020-11-29 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhisheng closed FLINK-20414. Resolution: Fixed > 【HBase】FileNotFoundException: File /tmp/hbase-deploy/hbase/lib does not exist >

[jira] [Updated] (FLINK-20414) 【HBase】FileNotFoundException: File /tmp/hbase-deploy/hbase/lib does not exist

2020-11-29 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20414: Component/s: Table SQL / Ecosystem > 【HBase】FileNotFoundException: File /tmp/hbase-deploy/hbase/lib does

[jira] [Commented] (FLINK-20405) The LAG function in over window is not implemented correctly

2020-11-29 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17240461#comment-17240461 ] Benchao Li commented on FLINK-20405: This is duplicated with  FLINK-19449 ? > The LAG function in

[GitHub] [flink] flinkbot edited a comment on pull request #14259: [FLINK-20290][runtime] Fix split duplication issues in Sources

2020-11-29 Thread GitBox
flinkbot edited a comment on pull request #14259: URL: https://github.com/apache/flink/pull/14259#issuecomment-735471312 ## CI report: * eb435ff41287c9bc7d77e0ed5a711e10f8b53385 Azure:

[jira] [Commented] (FLINK-20378) Watermark generation check TIMESTAMP_WITHOUT_TIME_ZONE

2020-11-29 Thread wxmimperio (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17240457#comment-17240457 ] wxmimperio commented on FLINK-20378: [~jark] Thanks,I will continue to follow this issue. >

[GitHub] [flink] caozhen1937 commented on pull request #14088: [FLINK-20168][docs-zh] Translate page 'Flink Architecture' into Chinese.

2020-11-29 Thread GitBox
caozhen1937 commented on pull request #14088: URL: https://github.com/apache/flink/pull/14088#issuecomment-735519308 hi @wuchong ,please help to review if you have time. This is an automated message from the Apache Git

[GitHub] [flink] fsk119 commented on a change in pull request #14224: [FLINK-20274][docs-zh] Translate page 'testing' into Chinese

2020-11-29 Thread GitBox
fsk119 commented on a change in pull request #14224: URL: https://github.com/apache/flink/pull/14224#discussion_r532314361 ## File path: docs/dev/stream/testing.zh.md ## @@ -62,7 +62,7 @@ class IncrementMapFunction extends MapFunction[Long, Long] { -It is very easy to

[jira] [Updated] (FLINK-20414) 【HBase】FileNotFoundException: File /tmp/hbase-deploy/hbase/lib does not exist

2020-11-29 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhisheng updated FLINK-20414: - Summary: 【HBase】FileNotFoundException: File /tmp/hbase-deploy/hbase/lib does not exist (was: 【HBase】)

[jira] [Created] (FLINK-20414) 【HBase】

2020-11-29 Thread zhisheng (Jira)
zhisheng created FLINK-20414: Summary: 【HBase】 Key: FLINK-20414 URL: https://issues.apache.org/jira/browse/FLINK-20414 Project: Flink Issue Type: Bug Components: Connectors / HBase

[GitHub] [flink] flinkbot edited a comment on pull request #14165: [FLINK-19687][table] Support to get execution plan from StatementSet

2020-11-29 Thread GitBox
flinkbot edited a comment on pull request #14165: URL: https://github.com/apache/flink/pull/14165#issuecomment-732020040 ## CI report: * 560977065e15581698d2eec2307cd19a319ee918 Azure:

[jira] [Commented] (FLINK-16258) Update test utilities to FLIP-65

2020-11-29 Thread CaoZhen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17240446#comment-17240446 ] CaoZhen commented on FLINK-16258: - Hi [~twalthr], I'm so sorry to stay for this task for so long. This

[jira] [Commented] (FLINK-20411) The annotation config do not support complex structure

2020-11-29 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17240443#comment-17240443 ] Yang Wang commented on FLINK-20411: --- I think the ConfigOption in Map type could support complex

[GitHub] [flink] flinkbot edited a comment on pull request #14165: [FLINK-19687][table] Support to get execution plan from StatementSet

2020-11-29 Thread GitBox
flinkbot edited a comment on pull request #14165: URL: https://github.com/apache/flink/pull/14165#issuecomment-732020040 ## CI report: * 560977065e15581698d2eec2307cd19a319ee918 Azure:

[GitHub] [flink] V1ncentzzZ edited a comment on pull request #14165: [FLINK-19687][table] Support to get execution plan from StatementSet

2020-11-29 Thread GitBox
V1ncentzzZ edited a comment on pull request #14165: URL: https://github.com/apache/flink/pull/14165#issuecomment-735046296 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] V1ncentzzZ edited a comment on pull request #14165: [FLINK-19687][table] Support to get execution plan from StatementSet

2020-11-29 Thread GitBox
V1ncentzzZ edited a comment on pull request #14165: URL: https://github.com/apache/flink/pull/14165#issuecomment-735046296 @flinkbot run azure. This is an automated message from the Apache Git Service. To respond to the

[jira] [Commented] (FLINK-20388) Supports users setting operators' metrics name

2020-11-29 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17240425#comment-17240425 ] Jark Wu commented on FLINK-20388: - [~chesnay], yes, this is original from SQL, because the generated

[jira] [Commented] (FLINK-18634) FlinkKafkaProducerITCase.testRecoverCommittedTransaction failed with "Timeout expired after 60000milliseconds while awaiting InitProducerId"

2020-11-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17240421#comment-17240421 ] Dian Fu commented on FLINK-18634: -

[jira] [Commented] (FLINK-20014) Resolve CVE-2020-11022 and CVE-2020-11023 in scala-compiler

2020-11-29 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17240411#comment-17240411 ] Chesnay Schepler commented on FLINK-20014: -- Does this affect users running Flink, or only

[jira] [Commented] (FLINK-20195) Jobs endpoint returns duplicated jobs

2020-11-29 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17240410#comment-17240410 ] Chesnay Schepler commented on FLINK-20195: -- Am I understanding you correctly that this happens

[jira] [Commented] (FLINK-20092) [Java 11] Multi-thread Flink compilation not working

2020-11-29 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17240407#comment-17240407 ] Chesnay Schepler commented on FLINK-20092: -- We cannot do that in general, because otherwise

[jira] [Commented] (FLINK-20388) Supports users setting operators' metrics name

2020-11-29 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17240404#comment-17240404 ] Chesnay Schepler commented on FLINK-20388: -- Is this purely about SQL? The operator name used

[jira] [Commented] (FLINK-20404) ZooKeeper quorum fails to start due to missing log4j library

2020-11-29 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17240403#comment-17240403 ] Chesnay Schepler commented on FLINK-20404: -- This is due to ZK 3.4 having a hard dependency on

[jira] [Closed] (FLINK-20404) ZooKeeper quorum fails to start due to missing log4j library

2020-11-29 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-20404. Fix Version/s: (was: 1.11.3) (was: 1.12.0) Resolution:

[GitHub] [flink] flinkbot edited a comment on pull request #14258: [FLINK-20356][docs] Updated Mesos documentation.

2020-11-29 Thread GitBox
flinkbot edited a comment on pull request #14258: URL: https://github.com/apache/flink/pull/14258#issuecomment-735471233 ## CI report: * 299cc3011151c3efb544fc5c9891c9418e9019ac Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14249: [FLINK-20391] Set FORWARD_EDGES_PIPELINED for BATCH ExecutionMode

2020-11-29 Thread GitBox
flinkbot edited a comment on pull request #14249: URL: https://github.com/apache/flink/pull/14249#issuecomment-734789081 ## CI report: * 2ce421de97821f5fa47a965362d3c08c4971fa92 Azure:

[jira] [Updated] (FLINK-20404) ZooKeeper quorum fails to start due to missing log4j library

2020-11-29 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-20404: - Component/s: Build System > ZooKeeper quorum fails to start due to missing log4j

[GitHub] [flink] flinkbot edited a comment on pull request #14258: [FLINK-20356][docs] Updated Mesos documentation.

2020-11-29 Thread GitBox
flinkbot edited a comment on pull request #14258: URL: https://github.com/apache/flink/pull/14258#issuecomment-735471233 ## CI report: * 299cc3011151c3efb544fc5c9891c9418e9019ac Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14259: [FLINK-20290][runtime] Fix split duplication issues in Sources

2020-11-29 Thread GitBox
flinkbot edited a comment on pull request #14259: URL: https://github.com/apache/flink/pull/14259#issuecomment-735471312 ## CI report: * eb435ff41287c9bc7d77e0ed5a711e10f8b53385 Azure:

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

2020-11-29 Thread GitBox
flinkbot edited a comment on pull request #10847: URL: https://github.com/apache/flink/pull/10847#issuecomment-573933799 ## CI report: * 693e48ac1e9cd413f54e7cbc4c46b9ae190ce848 Azure:

[GitHub] [flink] flinkbot commented on pull request #14259: [FLINK-20290][runtime] Fix split duplication issues in Sources

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

[GitHub] [flink] flinkbot commented on pull request #14258: [FLINK-20356][docs] Updated Mesos documentation.

2020-11-29 Thread GitBox
flinkbot commented on pull request #14258: URL: https://github.com/apache/flink/pull/14258#issuecomment-735471233 ## CI report: * 299cc3011151c3efb544fc5c9891c9418e9019ac UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

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

2020-11-29 Thread GitBox
flinkbot edited a comment on pull request #10847: URL: https://github.com/apache/flink/pull/10847#issuecomment-573933799 ## CI report: * b55a17559f8bbd427788152fdc5a2e79e273ad7a Azure:

[GitHub] [flink] flinkbot commented on pull request #14259: [FLINK-20290][runtime] Fix split duplication issues in Sources

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

[jira] [Updated] (FLINK-20290) Duplicated output in FileSource continuous ITCase with TM failover

2020-11-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20290: --- Labels: pull-request-available (was: ) > Duplicated output in FileSource continuous ITCase

[GitHub] [flink] StephanEwen opened a new pull request #14259: [FLINK-20290][runtime] Fix split duplication issues in Sources

2020-11-29 Thread GitBox
StephanEwen opened a new pull request #14259: URL: https://github.com/apache/flink/pull/14259 ## What is the purpose of the change This changes the split duplication problem in the new source framework, as initially observed on the File Source. The issues are independent of the

[GitHub] [flink] flinkbot commented on pull request #14258: [FLINK-20356][docs] Updated Mesos documentation.

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

[jira] [Updated] (FLINK-20356) Rework Mesos deployment documentation page

2020-11-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20356: --- Labels: pull-request-available (was: ) > Rework Mesos deployment documentation page >

[GitHub] [flink] XComp opened a new pull request #14258: [FLINK-20356][docs] Updated Mesos documentation.

2020-11-29 Thread GitBox
XComp opened a new pull request #14258: URL: https://github.com/apache/flink/pull/14258 First version of the Mesos page. See a screenshot of the page below... ![mesos](https://user-images.githubusercontent.com/1101012/100555395-7a69b600-329b-11eb-9130-6affe06b7581.png)

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

2020-11-29 Thread GitBox
flinkbot edited a comment on pull request #10847: URL: https://github.com/apache/flink/pull/10847#issuecomment-573933799 ## CI report: * b55a17559f8bbd427788152fdc5a2e79e273ad7a Azure:

[jira] [Updated] (FLINK-20396) Add "OperatorCoordinator.resetSubtask()" to fix order problems of "subtaskFailed()"

2020-11-29 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-20396: - Summary: Add "OperatorCoordinator.resetSubtask()" to fix order problems of "subtaskFailed()"

[jira] [Created] (FLINK-20413) Sources should add splits back in "resetSubtask()", rather than in "subtaskFailed()".

2020-11-29 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-20413: Summary: Sources should add splits back in "resetSubtask()", rather than in "subtaskFailed()". Key: FLINK-20413 URL: https://issues.apache.org/jira/browse/FLINK-20413

[jira] [Commented] (FLINK-20290) Duplicated output in FileSource continuous ITCase with TM failover

2020-11-29 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17240375#comment-17240375 ] Stephan Ewen commented on FLINK-20290: -- Update: A sequence similar to the one described by

[GitHub] [flink] StephanEwen commented on pull request #14143: [FLINK-20223] The RecreateOnResetOperatorCoordinator and SourceCoordi…

2020-11-29 Thread GitBox
StephanEwen commented on pull request #14143: URL: https://github.com/apache/flink/pull/14143#issuecomment-735463122 Merged as part of this change 40bbc174411b1502842ed3cdb9c421d51aa5fc0d This is an automated message from

[GitHub] [flink] StephanEwen closed pull request #14143: [FLINK-20223] The RecreateOnResetOperatorCoordinator and SourceCoordi…

2020-11-29 Thread GitBox
StephanEwen closed pull request #14143: URL: https://github.com/apache/flink/pull/14143 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] flinkbot edited a comment on pull request #10847: [FLINK-15578][connectors/jdbc] implement exactly once JDBC sink

2020-11-29 Thread GitBox
flinkbot edited a comment on pull request #10847: URL: https://github.com/apache/flink/pull/10847#issuecomment-573933799 ## CI report: * Unknown: [CANCELED](TBD) * b55a17559f8bbd427788152fdc5a2e79e273ad7a Azure:

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

2020-11-29 Thread GitBox
flinkbot edited a comment on pull request #10847: URL: https://github.com/apache/flink/pull/10847#issuecomment-573933799 ## CI report: * Unknown: [CANCELED](TBD) * b55a17559f8bbd427788152fdc5a2e79e273ad7a UNKNOWN Bot commands The @flinkbot bot supports the

[jira] [Commented] (FLINK-20412) Collect Result Fetching occasionally fails after a JobManager Failover

2020-11-29 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17240369#comment-17240369 ] Stephan Ewen commented on FLINK-20412: -- [~TsReaper] for your attention. > Collect Result Fetching

[jira] [Created] (FLINK-20412) Collect Result Fetching occasionally fails after a JobManager Failover

2020-11-29 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-20412: Summary: Collect Result Fetching occasionally fails after a JobManager Failover Key: FLINK-20412 URL: https://issues.apache.org/jira/browse/FLINK-20412 Project:

[jira] [Closed] (FLINK-20406) Return the Checkpoint ID of the restored Checkpoint in CheckpointCoordinator.restoreLatestCheckpointedStateToSubtasks()

2020-11-29 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-20406. > Return the Checkpoint ID of the restored Checkpoint in >

[jira] [Resolved] (FLINK-20406) Return the Checkpoint ID of the restored Checkpoint in CheckpointCoordinator.restoreLatestCheckpointedStateToSubtasks()

2020-11-29 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-20406. -- Resolution: Fixed Fixed in - 1.13.0 (master) via 856d4ea3cabce335f25ed163df8ae8eba9680890

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

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

  1   2   >