[GitHub] [flink] wenlong88 commented on a change in pull request #14398: [FLINK-20516][table-planner-blink] Separate the implementation of BatchExecTableSourceScan and StreamExecTableSourceScan

2020-12-19 Thread GitBox
wenlong88 commented on a change in pull request #14398: URL: https://github.com/apache/flink/pull/14398#discussion_r546330391 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecTableSourceScan.java

[jira] [Commented] (FLINK-10868) Flink's JobCluster ResourceManager doesn't use maximum-failed-containers as limit of resource acquirement

2020-12-19 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252334#comment-17252334 ] Zhenqiu Huang commented on FLINK-10868: --- [~xintongsong] "record the failure for all containers

[jira] [Updated] (FLINK-20681) Support specifying the hdfs path when ship archives or files

2020-12-19 Thread Ruguo Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruguo Yu updated FLINK-20681: - Description: Currently, our team try to submit flink job that depends extra resource with

[jira] [Commented] (FLINK-20654) Unaligned checkpoint recovery may lead to corrupted data stream

2020-12-19 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252311#comment-17252311 ] Huang Xingbo commented on FLINK-20654: --

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

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

[jira] [Created] (FLINK-20683) TaskSlotTableImplTest.testTryMarkSlotActiveDeactivatesSlotTimeout test failed with "The slot timeout should have been deactivated."

2020-12-19 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-20683: Summary: TaskSlotTableImplTest.testTryMarkSlotActiveDeactivatesSlotTimeout test failed with "The slot timeout should have been deactivated." Key: FLINK-20683 URL:

[jira] [Commented] (FLINK-20476) New File Sink end-to-end test Failed

2020-12-19 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252307#comment-17252307 ] Huang Xingbo commented on FLINK-20476: -- [~gaoyunhaii]The first time the new report error appeared

[jira] [Commented] (FLINK-20654) Unaligned checkpoint recovery may lead to corrupted data stream

2020-12-19 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252305#comment-17252305 ] Huang Xingbo commented on FLINK-20654: -- another instance

[GitHub] [flink] xiaoHoly commented on pull request #14377: [FLINK-19905][Connector][jdbc] The Jdbc-connector's 'lookup.max-retries' option initial value is 1 in JdbcLookupFunction

2020-12-19 Thread GitBox
xiaoHoly commented on pull request #14377: URL: https://github.com/apache/flink/pull/14377#issuecomment-748555269 @wuchong @wangxlong ,Thank you for your help! This is an automated message from the Apache Git Service. To

[GitHub] [flink-web] qinjunjerry opened a new pull request #402: Add the rocksdb blog

2020-12-19 Thread GitBox
qinjunjerry opened a new pull request #402: URL: https://github.com/apache/flink-web/pull/402 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] kl0u commented on a change in pull request #14312: [FLINK-20491] Support Broadcast State in BATCH execution mode

2020-12-19 Thread GitBox
kl0u commented on a change in pull request #14312: URL: https://github.com/apache/flink/pull/14312#discussion_r546289324 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamMultipleInputProcessorFactory.java ## @@ -143,7 +150,20 @@

[GitHub] [flink] flinkbot edited a comment on pull request #8418: [FLINK-12491][docs][configuration] Fix incorrect javadoc for path sep…

2020-12-19 Thread GitBox
flinkbot edited a comment on pull request #8418: URL: https://github.com/apache/flink/pull/8418#issuecomment-748479166 ## CI report: * fe55decbf541f9e58d36e15574770d267aba92f2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14361: [FLINK-19435][connectors/jdbc] Fix deadlock when loading different driver classes concurrently using Class.forName

2020-12-19 Thread GitBox
flinkbot edited a comment on pull request #14361: URL: https://github.com/apache/flink/pull/14361#issuecomment-742899629 ## CI report: * 00c2bb5f9c7e648aebf70fdc556f5d7322b8cf3f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14404: [FLINK-20624][table-planner]Refactor StreamExecJoinRule, StreamExecIntervalJoinRule and StreamExecTemporalJoinRule

2020-12-19 Thread GitBox
flinkbot edited a comment on pull request #14404: URL: https://github.com/apache/flink/pull/14404#issuecomment-746157858 ## CI report: * dd0716385b6e0c59ae8d9b33cd56d191bd65342a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14404: [FLINK-20624][table-planner]Refactor StreamExecJoinRule, StreamExecIntervalJoinRule and StreamExecTemporalJoinRule

2020-12-19 Thread GitBox
flinkbot edited a comment on pull request #14404: URL: https://github.com/apache/flink/pull/14404#issuecomment-746157858 ## CI report: * b8f43eb25f0360886d7cf5bf47449d7122347f79 Azure:

[jira] [Comment Edited] (FLINK-20552) JdbcDynamicTableSink doesn't sink buffered data on checkpoint

2020-12-19 Thread mei jie (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252218#comment-17252218 ] mei jie edited comment on FLINK-20552 at 12/19/20, 4:53 PM: Hi, [~jark] It

[GitHub] [flink] flinkbot edited a comment on pull request #14404: [FLINK-20624][table-planner]Refactor StreamExecJoinRule, StreamExecIntervalJoinRule and StreamExecTemporalJoinRule

2020-12-19 Thread GitBox
flinkbot edited a comment on pull request #14404: URL: https://github.com/apache/flink/pull/14404#issuecomment-746157858 ## CI report: * b8f43eb25f0360886d7cf5bf47449d7122347f79 Azure:

[jira] [Commented] (FLINK-20552) JdbcDynamicTableSink doesn't sink buffered data on checkpoint

2020-12-19 Thread mei jie (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252218#comment-17252218 ] mei jie commented on FLINK-20552: - Hi, [~jark] It seems unable to create SinkOperator by using insert

[jira] [Updated] (FLINK-20682) Add configuration options related to hadoop

2020-12-19 Thread Ruguo Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruguo Yu updated FLINK-20682: - Description: {{Current, we submit flink job to yarn with run-application target and need to specify

[jira] [Created] (FLINK-20682) Add configuration options related to hadoop

2020-12-19 Thread Ruguo Yu (Jira)
Ruguo Yu created FLINK-20682: Summary: Add configuration options related to hadoop Key: FLINK-20682 URL: https://issues.apache.org/jira/browse/FLINK-20682 Project: Flink Issue Type: Improvement

[GitHub] [flink] jrthe42 commented on a change in pull request #14404: [FLINK-20624][table-planner]Refactor StreamExecJoinRule, StreamExecIntervalJoinRule and StreamExecTemporalJoinRule

2020-12-19 Thread GitBox
jrthe42 commented on a change in pull request #14404: URL: https://github.com/apache/flink/pull/14404#discussion_r546256782 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/stream/StreamExecJoinRuleBase.scala

[jira] [Closed] (FLINK-20662) UnalignedCheckpointITCase.execute failed with IndexOutOfBoundsException

2020-12-19 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-20662. - Resolution: Duplicate Thanks for the reports. Exceptions are the same as in

[jira] [Created] (FLINK-20681) Support specifying the hdfs path when ship archives or files

2020-12-19 Thread Ruguo Yu (Jira)
Ruguo Yu created FLINK-20681: Summary: Support specifying the hdfs path when ship archives or files Key: FLINK-20681 URL: https://issues.apache.org/jira/browse/FLINK-20681 Project: Flink Issue

[jira] [Closed] (FLINK-19905) The Jdbc-connector's 'lookup.max-retries' option initial value is 1 in JdbcLookupFunction

2020-12-19 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-19905. --- Resolution: Fixed Fixed in master: cc9ccc42e8c8f7221c6d35f4c011d573577d0505 > The Jdbc-connector's

[GitHub] [flink] wuchong merged pull request #14377: [FLINK-19905][Connector][jdbc] The Jdbc-connector's 'lookup.max-retries' option initial value is 1 in JdbcLookupFunction

2020-12-19 Thread GitBox
wuchong merged pull request #14377: URL: https://github.com/apache/flink/pull/14377 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] wuchong commented on pull request #14377: [FLINK-19905][Connector][jdbc] The Jdbc-connector's 'lookup.max-retries' option initial value is 1 in JdbcLookupFunction

2020-12-19 Thread GitBox
wuchong commented on pull request #14377: URL: https://github.com/apache/flink/pull/14377#issuecomment-748483872 The failed test is reported in FLINK-20662 and not related to this PR. Will merge this then. This is

[jira] [Commented] (FLINK-20662) UnalignedCheckpointITCase.execute failed with IndexOutOfBoundsException

2020-12-19 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252190#comment-17252190 ] Jark Wu commented on FLINK-20662: -

[jira] [Updated] (FLINK-20680) Fails to call var-arg function with no parameters

2020-12-19 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20680: Fix Version/s: 1.13.0 > Fails to call var-arg function with no parameters >

[GitHub] [flink] flinkbot edited a comment on pull request #14435: [FLINK-20680][table-common] Fails to call var-arg function with no parameters

2020-12-19 Thread GitBox
flinkbot edited a comment on pull request #14435: URL: https://github.com/apache/flink/pull/14435#issuecomment-748452768 ## CI report: * c774942f45c68fcf0b960890254790fc10357fa6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #8418: [FLINK-12491][docs][configuration] Fix incorrect javadoc for path sep…

2020-12-19 Thread GitBox
flinkbot edited a comment on pull request #8418: URL: https://github.com/apache/flink/pull/8418#issuecomment-748479166 ## CI report: * fe55decbf541f9e58d36e15574770d267aba92f2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14361: [FLINK-19435][connectors/jdbc] Fix deadlock when loading different driver classes concurrently using Class.forName

2020-12-19 Thread GitBox
flinkbot edited a comment on pull request #14361: URL: https://github.com/apache/flink/pull/14361#issuecomment-742899629 ## CI report: * 0aa90c60d5e038daeb11b9ed90ef1226a4410613 Azure:

[GitHub] [flink] flinkbot commented on pull request #8418: [FLINK-12491][docs][configuration] Fix incorrect javadoc for path sep…

2020-12-19 Thread GitBox
flinkbot commented on pull request #8418: URL: https://github.com/apache/flink/pull/8418#issuecomment-748479166 ## CI report: * fe55decbf541f9e58d36e15574770d267aba92f2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] kezhuw commented on pull request #8418: [FLINK-12491][docs][configuration] Fix incorrect javadoc for path sep…

2020-12-19 Thread GitBox
kezhuw commented on pull request #8418: URL: https://github.com/apache/flink/pull/8418#issuecomment-748478640 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] flinkbot edited a comment on pull request #14361: [FLINK-19435][connectors/jdbc] Fix deadlock when loading different driver classes concurrently using Class.forName

2020-12-19 Thread GitBox
flinkbot edited a comment on pull request #14361: URL: https://github.com/apache/flink/pull/14361#issuecomment-742899629 ## CI report: * 0aa90c60d5e038daeb11b9ed90ef1226a4410613 Azure:

[GitHub] [flink-docker] wangyang0918 commented on pull request #49: [FLINK-20650] Rename "native-k8s" command to a more general name in docker-entrypoint.sh

2020-12-19 Thread GitBox
wangyang0918 commented on pull request #49: URL: https://github.com/apache/flink-docker/pull/49#issuecomment-748475375 @tianon Thanks for your comments. We not only set the environments in `run` command, but also could support "disable jemalloc", "copy plugins" and other preparatory works

[GitHub] [flink] kezhuw commented on pull request #14361: [FLINK-19435][connectors/jdbc] Fix deadlock when loading different driver classes concurrently using Class.forName

2020-12-19 Thread GitBox
kezhuw commented on pull request #14361: URL: https://github.com/apache/flink/pull/14361#issuecomment-748474820 I have reported two failed test cases in building https://github.com/apache/flink/pull/14361/commits/0aa90c60d5e038daeb11b9ed90ef1226a4410613: *

[jira] [Comment Edited] (FLINK-20389) UnalignedCheckpointITCase failure caused by NullPointerException

2020-12-19 Thread Kezhu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252182#comment-17252182 ] Kezhu Wang edited comment on FLINK-20389 at 12/19/20, 1:23 PM: --- Another

[jira] [Commented] (FLINK-20389) UnalignedCheckpointITCase failure caused by NullPointerException

2020-12-19 Thread Kezhu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252182#comment-17252182 ] Kezhu Wang commented on FLINK-20389: Another case about {{NullPointerException}} from

[jira] [Commented] (FLINK-20432) SQLClientSchemaRegistryITCase hangs

2020-12-19 Thread Kezhu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252169#comment-17252169 ] Kezhu Wang commented on FLINK-20432: Two more cases after timeout changed ? * FLINK-20498

[GitHub] [flink] flinkbot edited a comment on pull request #14435: [FLINK-20680][table-common] Fails to call var-arg function with no parameters

2020-12-19 Thread GitBox
flinkbot edited a comment on pull request #14435: URL: https://github.com/apache/flink/pull/14435#issuecomment-748452768 ## CI report: * c774942f45c68fcf0b960890254790fc10357fa6 Azure:

[GitHub] [flink] flinkbot commented on pull request #14435: [FLINK-20680][table-common] Fails to call var-arg function with no parameters

2020-12-19 Thread GitBox
flinkbot commented on pull request #14435: URL: https://github.com/apache/flink/pull/14435#issuecomment-748452768 ## CI report: * c774942f45c68fcf0b960890254790fc10357fa6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-20680) Fails to call var-arg function with no parameters

2020-12-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20680: --- Labels: pull-request-available (was: ) > Fails to call var-arg function with no parameters

[GitHub] [flink] flinkbot commented on pull request #14435: [FLINK-20680][table-common] Fails to call var-arg function with no parameters

2020-12-19 Thread GitBox
flinkbot commented on pull request #14435: URL: https://github.com/apache/flink/pull/14435#issuecomment-748451293 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] lirui-apache opened a new pull request #14435: Flink 20680

2020-12-19 Thread GitBox
lirui-apache opened a new pull request #14435: URL: https://github.com/apache/flink/pull/14435 ## What is the purpose of the change Fix the issue to call a var-arg function with no parameters. ## Brief change log - Fix the validation logic in

[jira] [Created] (FLINK-20680) Fails to call var-arg function with no parameters

2020-12-19 Thread Rui Li (Jira)
Rui Li created FLINK-20680: -- Summary: Fails to call var-arg function with no parameters Key: FLINK-20680 URL: https://issues.apache.org/jira/browse/FLINK-20680 Project: Flink Issue Type: Bug

[jira] [Comment Edited] (FLINK-20562) Support ExplainDetails for EXPLAIN sytnax

2020-12-19 Thread Xiao Cai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252147#comment-17252147 ] Xiao Cai edited comment on FLINK-20562 at 12/19/20, 9:15 AM: - I think

[jira] [Comment Edited] (FLINK-20562) Support ExplainDetails for EXPLAIN sytnax

2020-12-19 Thread Xiao Cai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252147#comment-17252147 ] Xiao Cai edited comment on FLINK-20562 at 12/19/20, 9:15 AM: - I think

[jira] [Commented] (FLINK-20562) Support ExplainDetails for EXPLAIN sytnax

2020-12-19 Thread Xiao Cai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252147#comment-17252147 ] Xiao Cai commented on FLINK-20562: -- I think explain can work with select/delete/insert and update

[GitHub] [flink-statefun] Windber opened a new pull request #188: [hotfix] fix typos in StatefulFunctionModule.java.

2020-12-19 Thread GitBox
Windber opened a new pull request #188: URL: https://github.com/apache/flink-statefun/pull/188 hi, I fixed a tiny typo. This is an automated message from the Apache Git Service. To respond to the message, please log on to