[jira] [Updated] (FLINK-18602) Support specific offset for topic list for kafka connector in table api

2020-07-14 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-18602: -- Description: During FLINK-18449, we decide to support topic discovery for kafka connector in

[GitHub] [flink] xiaolong-sn commented on a change in pull request #12881: [FLINK-18512][kinesis] Introducing RecordPublisher. Refactor ShardConsumer to use PollingRecordPublisher

2020-07-14 Thread GitBox
xiaolong-sn commented on a change in pull request #12881: URL: https://github.com/apache/flink/pull/12881#discussion_r454251135 ## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxyMarker.java ##

[jira] [Closed] (FLINK-18603) SQL fails with java.lang.IllegalStateException: No operators defined in streaming topology

2020-07-14 Thread Alexander Filipchik (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Filipchik closed FLINK-18603. --- Resolution: Not A Problem Issues was in custom format. > SQL fails with

[jira] [Commented] (FLINK-18582) Add title anchor link for file event_driven.zh.md

2020-07-14 Thread Congxian Qiu(klion26) (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17157881#comment-17157881 ] Congxian Qiu(klion26) commented on FLINK-18582: --- [~temper] thanks for creating this

[GitHub] [flink] flinkbot edited a comment on pull request #12903: [FLINK-18492][python] Extract the implementation logic of Beam in Operations

2020-07-14 Thread GitBox
flinkbot edited a comment on pull request #12903: URL: https://github.com/apache/flink/pull/12903#issuecomment-658519879 ## CI report: * aa4bb627890b6e46ef36f44528a24aa304bb7064 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12899: [FLINK-16699][k8s] Support accessing secured services via K8s secrets

2020-07-14 Thread GitBox
flinkbot edited a comment on pull request #12899: URL: https://github.com/apache/flink/pull/12899#issuecomment-658162074 ## CI report: * 77f95464c6036283d77d6e81e2bd21ab27f29d54 Azure:

[jira] [Created] (FLINK-18603) SQL fails with java.lang.IllegalStateException: No operators defined in streaming topology

2020-07-14 Thread Alexander Filipchik (Jira)
Alexander Filipchik created FLINK-18603: --- Summary: SQL fails with java.lang.IllegalStateException: No operators defined in streaming topology Key: FLINK-18603 URL:

[jira] [Closed] (FLINK-18594) The link is broken in kafka doc

2020-07-14 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-18594. Resolution: Fixed master: bfdb3c8339347ad59ef5debb71fb171ffa87d4c8 > The link is broken in kafka

[GitHub] [flink] JingsongLi merged pull request #12897: [FLINK-18594][doc] The link is broken in kafka doc

2020-07-14 Thread GitBox
JingsongLi merged pull request #12897: URL: https://github.com/apache/flink/pull/12897 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

[jira] [Updated] (FLINK-18539) StreamExecutionEnvironment#addSource(SourceFunction, TypeInformation) doesn't use the user defined type information

2020-07-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18539: Issue Type: Bug (was: Task) > StreamExecutionEnvironment#addSource(SourceFunction, TypeInformation)

[jira] [Updated] (FLINK-18593) Hive bundle jar URLs are broken

2020-07-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18593: Issue Type: Improvement (was: New Feature) > Hive bundle jar URLs are broken >

[jira] [Created] (FLINK-18602) Support specific offset for topic list for kafka connector in table api

2020-07-14 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-18602: - Summary: Support specific offset for topic list for kafka connector in table api Key: FLINK-18602 URL: https://issues.apache.org/jira/browse/FLINK-18602 Project:

[GitHub] [flink] flinkbot edited a comment on pull request #12902: [FLINK-18415][python] Support TableResult#collect in the Python Table…

2020-07-14 Thread GitBox
flinkbot edited a comment on pull request #12902: URL: https://github.com/apache/flink/pull/12902#issuecomment-658509076 ## CI report: * 802dfd4a0a2fb3e1b6e9a31fbc850c18f00c5c2b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12899: [FLINK-16699][k8s] Support accessing secured services via K8s secrets

2020-07-14 Thread GitBox
flinkbot edited a comment on pull request #12899: URL: https://github.com/apache/flink/pull/12899#issuecomment-658162074 ## CI report: * 77f95464c6036283d77d6e81e2bd21ab27f29d54 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12866: [FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource.

2020-07-14 Thread GitBox
flinkbot edited a comment on pull request #12866: URL: https://github.com/apache/flink/pull/12866#issuecomment-656576219 ## CI report: * 5eb302884e390b6099859abcd7955e7f1c4e034e Azure:

[jira] [Updated] (FLINK-17726) Scheduler should take care of tasks directly canceled by TaskManager

2020-07-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17726: Fix Version/s: (was: 1.11.1) 1.11.2 > Scheduler should take care of tasks directly

[jira] [Updated] (FLINK-17075) Add task status reconciliation between TM and JM

2020-07-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17075: Fix Version/s: (was: 1.11.1) 1.11.2 > Add task status reconciliation between TM

[jira] [Updated] (FLINK-18479) can not commit partition when set partition time

2020-07-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18479: Fix Version/s: (was: 1.11.1) 1.11.2 > can not commit partition when set partition

[jira] [Updated] (FLINK-18549) flink 1.11 can not commit partition automatically

2020-07-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18549: Fix Version/s: (was: 1.11.1) 1.11.2 > flink 1.11 can not commit partition

[jira] [Updated] (FLINK-18376) java.lang.ArrayIndexOutOfBoundsException in RetractableTopNFunction

2020-07-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18376: Fix Version/s: (was: 1.11.1) 1.11.2 > java.lang.ArrayIndexOutOfBoundsException in

[jira] [Updated] (FLINK-18206) The timestamp is displayed incorrectly

2020-07-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18206: Fix Version/s: (was: 1.11.1) 1.11.2 > The timestamp is displayed incorrectly >

[jira] [Updated] (FLINK-18365) The same sql in a batch env and a streaming env has different value.

2020-07-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18365: Fix Version/s: (was: 1.11.1) 1.11.2 > The same sql in a batch env and a streaming

[jira] [Updated] (FLINK-16622) Type ARRAY of table field 'id' does not match with the physical type LEGACY('ARRAY', 'ANY<[Ljava.lang.String;, rO0ABXNyAD......>') of the 'id' field of the Table

2020-07-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16622: Fix Version/s: (was: 1.11.1) 1.11.2 > Type ARRAY of table field 'id' does not

[jira] [Updated] (FLINK-17964) Hivemodule does not support map type

2020-07-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17964: Fix Version/s: (was: 1.11.1) 1.11.2 > Hivemodule does not support map type >

[jira] [Updated] (FLINK-18581) Cannot find GC cleaner with java version previous 8u202

2020-07-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18581: Fix Version/s: (was: 1.11.1) 1.11.2 > Cannot find GC cleaner with java version

[jira] [Commented] (FLINK-18597) elasticsearch sql insert function cannot set documentid

2020-07-14 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17157849#comment-17157849 ] Jark Wu commented on FLINK-18597: - If you want to specify document-id, please refer to the docs:

[jira] [Commented] (FLINK-18449) Make topic discovery and partition discovery configurable for FlinkKafkaConsumer in Table API

2020-07-14 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17157848#comment-17157848 ] Shengkai Fang commented on FLINK-18449: --- Hi, all. I find that FlinkKafkaProducer doesn't support

[GitHub] [flink] flinkbot edited a comment on pull request #12903: [FLINK-18492][python] Extract the implementation logic of Beam in Operations

2020-07-14 Thread GitBox
flinkbot edited a comment on pull request #12903: URL: https://github.com/apache/flink/pull/12903#issuecomment-658519879 ## CI report: * aa4bb627890b6e46ef36f44528a24aa304bb7064 Azure:

[jira] [Updated] (FLINK-18597) elasticsearch sql insert function cannot set documentid

2020-07-14 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18597: Priority: Minor (was: Critical) > elasticsearch sql insert function cannot set documentid >

[GitHub] [flink] godfreyhe commented on a change in pull request #12866: [FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource.

2020-07-14 Thread GitBox
godfreyhe commented on a change in pull request #12866: URL: https://github.com/apache/flink/pull/12866#discussion_r454768224 ## File path: flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/factories/TestValuesTableFactory.java ## @@ -540,40

[jira] [Updated] (FLINK-18601) TaskManager shut down often in standalone cluster

2020-07-14 Thread Echo Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Echo Lee updated FLINK-18601: - Summary: TaskManager shut down often in standalone cluster (was: Taskmanager shut down often in

[jira] [Created] (FLINK-18601) Taskmanager shut down often in standalone cluster

2020-07-14 Thread Echo Lee (Jira)
Echo Lee created FLINK-18601: Summary: Taskmanager shut down often in standalone cluster Key: FLINK-18601 URL: https://issues.apache.org/jira/browse/FLINK-18601 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-18600) Kerberized YARN per-job on Docker test failed to download JDK 8u251

2020-07-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17157844#comment-17157844 ] Dian Fu commented on FLINK-18600: - Not sure the reason why we choose oracle JDK and if we could switch

[jira] [Updated] (FLINK-18600) Kerberized YARN per-job on Docker test failed to download JDK 8u251

2020-07-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18600: Priority: Blocker (was: Critical) > Kerberized YARN per-job on Docker test failed to download JDK 8u251

[jira] [Commented] (FLINK-18600) Kerberized YARN per-job on Docker test failed to download JDK 8u251

2020-07-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17157843#comment-17157843 ] Dian Fu commented on FLINK-18600: - I have checked that I can download the version *8u251* through the

[jira] [Commented] (FLINK-18540) Unnecessary retract messages when setIdleStateRetentionTime before converting dynamic table to retract stream

2020-07-14 Thread WeiqiangSun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17157838#comment-17157838 ] WeiqiangSun commented on FLINK-18540: - [~libenchao] Mini batch may not work well with retract

[GitHub] [flink] flinkbot commented on pull request #12903: [FLINK-18492][python] Extract the implementation logic of Beam in Operations

2020-07-14 Thread GitBox
flinkbot commented on pull request #12903: URL: https://github.com/apache/flink/pull/12903#issuecomment-658519879 ## CI report: * aa4bb627890b6e46ef36f44528a24aa304bb7064 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-18600) Kerberized YARN per-job on Docker test failed to download JDK 8u251

2020-07-14 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17157832#comment-17157832 ] Jark Wu commented on FLINK-18600: - Looks like we started to use this JDK link since FLINK-18485. Maybe

[GitHub] [flink] flinkbot edited a comment on pull request #12902: [FLINK-18415][python] Support TableResult#collect in the Python Table…

2020-07-14 Thread GitBox
flinkbot edited a comment on pull request #12902: URL: https://github.com/apache/flink/pull/12902#issuecomment-658509076 ## CI report: * 802dfd4a0a2fb3e1b6e9a31fbc850c18f00c5c2b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12866: [FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource.

2020-07-14 Thread GitBox
flinkbot edited a comment on pull request #12866: URL: https://github.com/apache/flink/pull/12866#issuecomment-656576219 ## CI report: * 02c81cff07ef76dc20a7c618112cc7a172856720 Azure:

[GitHub] [flink] lirui-apache commented on pull request #12888: [FLINK-18588] hive ddl create table support 'if not exists'

2020-07-14 Thread GitBox
lirui-apache commented on pull request #12888: URL: https://github.com/apache/flink/pull/12888#issuecomment-658513513 Thanks @wtog for the contribution. Could we also have some test for this in `HiveDialectITCase`? This is

[GitHub] [flink] flinkbot commented on pull request #12903: [FLINK-18492][python] Extract the implementation logic of Beam in Operations

2020-07-14 Thread GitBox
flinkbot commented on pull request #12903: URL: https://github.com/apache/flink/pull/12903#issuecomment-658512879 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] HuangXingBo opened a new pull request #12903: [FLINK-18492][python] Extract the implementation logic of Beam in Operations

2020-07-14 Thread GitBox
HuangXingBo opened a new pull request #12903: URL: https://github.com/apache/flink/pull/12903 ## What is the purpose of the change *This pull request extract the implementation logic of Beam in Operations* ## Brief change log - *Extract the beam related logic of

[jira] [Updated] (FLINK-18492) Extract the implementation logic of Beam in Operations

2020-07-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18492: --- Labels: pull-request-available (was: ) > Extract the implementation logic of Beam in

[jira] [Updated] (FLINK-17636) SingleInputGateTest.testConcurrentReadStateAndProcessAndClose: Trying to read from released RecoveredInputChannel

2020-07-14 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-17636: - Affects Version/s: 1.11.0 > SingleInputGateTest.testConcurrentReadStateAndProcessAndClose: Trying to

[jira] [Updated] (FLINK-17636) SingleInputGateTest.testConcurrentReadStateAndProcessAndClose: Trying to read from released RecoveredInputChannel

2020-07-14 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-17636: - Fix Version/s: 1.11.0 > SingleInputGateTest.testConcurrentReadStateAndProcessAndClose: Trying to read

[jira] [Closed] (FLINK-17636) SingleInputGateTest.testConcurrentReadStateAndProcessAndClose: Trying to read from released RecoveredInputChannel

2020-07-14 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-17636. Resolution: Fixed Merged in release-1.11: 57e57624deded5594749cbccf17a5878c6dc81b8 Merged in master:

[GitHub] [flink] zhijiangW merged pull request #12879: [FLINK-17636][tests] Fix unstable test SingleInputGateTest#testConcur…

2020-07-14 Thread GitBox
zhijiangW merged pull request #12879: URL: https://github.com/apache/flink/pull/12879 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

[GitHub] [flink] zhijiangW merged pull request #12898: [FLINK-17636][tests] Fix unstable test SingleInputGateTest#testConcurrentReadStateAndProcessAndClose

2020-07-14 Thread GitBox
zhijiangW merged pull request #12898: URL: https://github.com/apache/flink/pull/12898 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

[jira] [Updated] (FLINK-18599) Compile error when use windowAll and TumblingProcessingTimeWindows

2020-07-14 Thread henvealf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] henvealf updated FLINK-18599: - Description: Code: {code:java} import org.apache.commons.lang3.StringUtils import

[jira] [Updated] (FLINK-18600) Kerberized YARN per-job on Docker test failed to download JDK 8u251

2020-07-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18600: Description:

[jira] [Created] (FLINK-18600) Kerberized YARN per-job on Docker test failed to download JDK 8u251

2020-07-14 Thread Dian Fu (Jira)
Dian Fu created FLINK-18600: --- Summary: Kerberized YARN per-job on Docker test failed to download JDK 8u251 Key: FLINK-18600 URL: https://issues.apache.org/jira/browse/FLINK-18600 Project: Flink

[GitHub] [flink] flinkbot commented on pull request #12902: [FLINK-18415][python] Support TableResult#collect in the Python Table…

2020-07-14 Thread GitBox
flinkbot commented on pull request #12902: URL: https://github.com/apache/flink/pull/12902#issuecomment-658509076 ## CI report: * 802dfd4a0a2fb3e1b6e9a31fbc850c18f00c5c2b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #12866: [FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource.

2020-07-14 Thread GitBox
flinkbot edited a comment on pull request #12866: URL: https://github.com/apache/flink/pull/12866#issuecomment-656576219 ## CI report: * 02c81cff07ef76dc20a7c618112cc7a172856720 Azure:

[jira] [Created] (FLINK-18599) Compile error when use windowAll and TumblingProcessingTimeWindows

2020-07-14 Thread henvealf (Jira)
henvealf created FLINK-18599: Summary: Compile error when use windowAll and TumblingProcessingTimeWindows Key: FLINK-18599 URL: https://issues.apache.org/jira/browse/FLINK-18599 Project: Flink

[GitHub] [flink] liuyongvs commented on pull request #12866: [FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource.

2020-07-14 Thread GitBox
liuyongvs commented on pull request #12866: URL: https://github.com/apache/flink/pull/12866#issuecomment-658506250 Hi @godfreyhe . Yes, i find some type is not Comparable, such as Period int getValueAs(Class clazz). Thanks for you review in great details. And I learned a lot

[jira] [Created] (FLINK-18598) Add instructions for asynchronous execute in PyFlink doc

2020-07-14 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-18598: Summary: Add instructions for asynchronous execute in PyFlink doc Key: FLINK-18598 URL: https://issues.apache.org/jira/browse/FLINK-18598 Project: Flink

[jira] [Commented] (FLINK-18597) elasticsearch sql insert function cannot set documentid

2020-07-14 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17157811#comment-17157811 ] Yangze Guo commented on FLINK-18597: I think it is fixed by FLINK-18583. Could you take a look? If

[jira] [Created] (FLINK-18597) elasticsearch sql insert function cannot set documentid

2020-07-14 Thread xy (Jira)
xy created FLINK-18597: -- Summary: elasticsearch sql insert function cannot set documentid Key: FLINK-18597 URL: https://issues.apache.org/jira/browse/FLINK-18597 Project: Flink Issue Type: Test

[GitHub] [flink] flinkbot commented on pull request #12902: [FLINK-18415][python] Support TableResult#collect in the Python Table…

2020-07-14 Thread GitBox
flinkbot commented on pull request #12902: URL: https://github.com/apache/flink/pull/12902#issuecomment-658497220 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-18415) Support TableResult#collect in the Python Table API to align with the Java Table API

2020-07-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18415: --- Labels: pull-request-available (was: ) > Support TableResult#collect in the Python Table

[GitHub] [flink] shuiqiangchen opened a new pull request #12902: [FLINK-18415][python] Support TableResult#collect in the Python Table…

2020-07-14 Thread GitBox
shuiqiangchen opened a new pull request #12902: URL: https://github.com/apache/flink/pull/12902 ## What is the purpose of the change *Support TableResult#collect in the Python Table API to align with the Java Table API* ## Brief change log - * Add

[GitHub] [flink] flinkbot edited a comment on pull request #12901: [FLINK-17285] [API / Python, chinese-translation] Translate "Python Table API" page into Chinese (part 1)

2020-07-14 Thread GitBox
flinkbot edited a comment on pull request #12901: URL: https://github.com/apache/flink/pull/12901#issuecomment-658445990 ## CI report: * 221cb71c264d05e43eb77b5e11d9fb4c8834e7da Azure:

[GitHub] [flink] flinkbot commented on pull request #12901: [FLINK-17285] [API / Python, chinese-translation] Translate "Python Table API" page into Chinese (part 1)

2020-07-14 Thread GitBox
flinkbot commented on pull request #12901: URL: https://github.com/apache/flink/pull/12901#issuecomment-658445990 ## CI report: * 221cb71c264d05e43eb77b5e11d9fb4c8834e7da UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #12901: [FLINK-17285] [API / Python, chinese-translation] Translate "Python Table API" page into Chinese (part 1)

2020-07-14 Thread GitBox
flinkbot commented on pull request #12901: URL: https://github.com/apache/flink/pull/12901#issuecomment-658438478 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-17285) Translate "Python Table API" page into Chinese

2020-07-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17285: --- Labels: pull-request-available (was: ) > Translate "Python Table API" page into Chinese >

[GitHub] [flink] billyrrr opened a new pull request #12901: [FLINK-17285] [API / Python, chinese-translation] Translate "Python Table API" page into Chinese (part 1)

2020-07-14 Thread GitBox
billyrrr opened a new pull request #12901: URL: https://github.com/apache/flink/pull/12901 ## What is the purpose of the change This change is part of many that will translate `*.zh.md` docs for Python Table API to Chinese Simplified. Untranslated paragraphs currently in

[GitHub] [flink] flinkbot edited a comment on pull request #12900: [FLINK-18537][table] Remove RowDataTypeInfo

2020-07-14 Thread GitBox
flinkbot edited a comment on pull request #12900: URL: https://github.com/apache/flink/pull/12900#issuecomment-658213136 ## CI report: * ceb895be265bd445b9d36bfc52cf8018a508c333 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12846: [FLINK-18448][pubsub] Update Google Cloud PubSub dependencies

2020-07-14 Thread GitBox
flinkbot edited a comment on pull request #12846: URL: https://github.com/apache/flink/pull/12846#issuecomment-654978676 ## CI report: * 8c8f594927a2b72c23f8619c1932219585755054 Azure:

[jira] [Updated] (FLINK-18573) InfluxDB reporter cannot be loaded as plugin

2020-07-14 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-18573: - Description: The service entry is in the wrong directory (service vs service*s* ) It

[jira] [Updated] (FLINK-18573) InfluxDB reporter cannot be loaded as plugin

2020-07-14 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-18573: - Description: The service entry is in the wrong directory (service vs service*s*) It

[jira] [Updated] (FLINK-18573) InfluxDB reporter cannot be loaded as plugin

2020-07-14 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-18573: - Description: The service entry is in the wrong directory (service vs services) It

[jira] [Updated] (FLINK-18573) InfluxDB reporter cannot be loaded as plugin

2020-07-14 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-18573: - Summary: InfluxDB reporter cannot be loaded as plugin (was:

[jira] [Closed] (FLINK-18573) plugins/metrics-influx/flink-metrics-influxdb-1.11.0.jar META-INF has no dir named "services" , but "service"

2020-07-14 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-18573. Resolution: Fixed master: 49d3cabb8ae53900138fc1a2f5178dbec46ce378

[GitHub] [flink] zentol merged pull request #12883: [FLINK-18573][metrics] Ensure metric reporters could be loaded via SPI

2020-07-14 Thread GitBox
zentol merged pull request #12883: URL: https://github.com/apache/flink/pull/12883 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-18573) plugins/metrics-influx/flink-metrics-influxdb-1.11.0.jar META-INF has no dir named "services" , but "service"

2020-07-14 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-18573: - Fix Version/s: 1.12.0 > plugins/metrics-influx/flink-metrics-influxdb-1.11.0.jar

[jira] [Comment Edited] (FLINK-11143) AskTimeoutException is thrown during job submission and completion

2020-07-14 Thread Steven Zhen Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17156363#comment-17156363 ] Steven Zhen Wu edited comment on FLINK-11143 at 7/14/20, 5:38 PM: --

[jira] [Comment Edited] (FLINK-11143) AskTimeoutException is thrown during job submission and completion

2020-07-14 Thread Steven Zhen Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17156363#comment-17156363 ] Steven Zhen Wu edited comment on FLINK-11143 at 7/14/20, 5:38 PM: --

[jira] [Comment Edited] (FLINK-11143) AskTimeoutException is thrown during job submission and completion

2020-07-14 Thread Steven Zhen Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17156363#comment-17156363 ] Steven Zhen Wu edited comment on FLINK-11143 at 7/14/20, 5:37 PM: --

[GitHub] [flink] flinkbot edited a comment on pull request #12883: [FLINK-18573][metrics] Ensure metric reporters could be loaded via SPI

2020-07-14 Thread GitBox
flinkbot edited a comment on pull request #12883: URL: https://github.com/apache/flink/pull/12883#issuecomment-657495689 ## CI report: * 25d465768bdf87bd31e0ca9b5749344c35c919d5 Azure:

[GitHub] [flink] twalthr commented on a change in pull request #12900: [FLINK-18537][table] Remove RowDataTypeInfo

2020-07-14 Thread GitBox
twalthr commented on a change in pull request #12900: URL: https://github.com/apache/flink/pull/12900#discussion_r454506847 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/DataTypeQueryable.java ## @@ -0,0 +1,30 @@ +/* + * Licensed to

[GitHub] [flink] flinkbot edited a comment on pull request #12898: [FLINK-17636][tests] Fix unstable test SingleInputGateTest#testConcurrentReadStateAndProcessAndClose

2020-07-14 Thread GitBox
flinkbot edited a comment on pull request #12898: URL: https://github.com/apache/flink/pull/12898#issuecomment-658161964 ## CI report: * da4c38d2f9cff86990bef5bf357595971ef1cef9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12846: [FLINK-18448][pubsub] Update Google Cloud PubSub dependencies

2020-07-14 Thread GitBox
flinkbot edited a comment on pull request #12846: URL: https://github.com/apache/flink/pull/12846#issuecomment-654978676 ## CI report: * fbd3e1559f4a80424cbade77ed3034977943bf0b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12846: [FLINK-18448][pubsub] Update Google Cloud PubSub dependencies

2020-07-14 Thread GitBox
flinkbot edited a comment on pull request #12846: URL: https://github.com/apache/flink/pull/12846#issuecomment-654978676 ## CI report: * fbd3e1559f4a80424cbade77ed3034977943bf0b Azure:

[GitHub] [flink] nielsbasjes edited a comment on pull request #12846: [FLINK-18448][pubsub] Update Google Cloud PubSub dependencies

2020-07-14 Thread GitBox
nielsbasjes edited a comment on pull request #12846: URL: https://github.com/apache/flink/pull/12846#issuecomment-658267581 Notes about the current set of changes: - Updated the Google dependencies. All Google dependencies no longer specify any versions. So in all cases the inclusion of

[GitHub] [flink] nielsbasjes commented on pull request #12846: [FLINK-18448][pubsub] Update Google Cloud PubSub dependencies

2020-07-14 Thread GitBox
nielsbasjes commented on pull request #12846: URL: https://github.com/apache/flink/pull/12846#issuecomment-658270987 @Xeli @becketqin @rmetzger Since you were involved in reviewing this component when originally created I'm tagging you to kindly review these changes.

[GitHub] [flink] nielsbasjes commented on pull request #12846: [FLINK-18448][pubsub] Update Google Cloud PubSub dependencies

2020-07-14 Thread GitBox
nielsbasjes commented on pull request #12846: URL: https://github.com/apache/flink/pull/12846#issuecomment-658267581 Notes about the current set of changes: - Updated the Google dependencies. All Google dependencies no longer specify any versions. So in all cases the inclusion of the

[GitHub] [flink] flinkbot edited a comment on pull request #12883: [FLINK-18573][metrics] Ensure metric reporters could be loaded via SPI

2020-07-14 Thread GitBox
flinkbot edited a comment on pull request #12883: URL: https://github.com/apache/flink/pull/12883#issuecomment-657495689 ## CI report: * 93616ee036d921efea80c8003e408d35339cc4ec Azure:

[GitHub] [flink] dawidwys commented on a change in pull request #12900: [FLINK-18537][table] Remove RowDataTypeInfo

2020-07-14 Thread GitBox
dawidwys commented on a change in pull request #12900: URL: https://github.com/apache/flink/pull/12900#discussion_r454415036 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/DataTypeQueryable.java ## @@ -0,0 +1,30 @@ +/* + * Licensed to

[GitHub] [flink] flinkbot edited a comment on pull request #12900: [FLINK-18537][table] Remove RowDataTypeInfo

2020-07-14 Thread GitBox
flinkbot edited a comment on pull request #12900: URL: https://github.com/apache/flink/pull/12900#issuecomment-658213136 ## CI report: * ceb895be265bd445b9d36bfc52cf8018a508c333 Azure:

[jira] [Commented] (FLINK-18588) hive ddl create table should support 'if not exists'

2020-07-14 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17157430#comment-17157430 ] Jark Wu commented on FLINK-18588: - [~wtog] I CC'ed someone familiar with this part to review in the PR.

[GitHub] [flink] wuchong commented on pull request #12888: [FLINK-18588] hive ddl create table support 'if not exists'

2020-07-14 Thread GitBox
wuchong commented on pull request #12888: URL: https://github.com/apache/flink/pull/12888#issuecomment-658219194 cc @lirui-apache @JingsongLi This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot commented on pull request #12900: [FLINK-18537][table] Remove RowDataTypeInfo

2020-07-14 Thread GitBox
flinkbot commented on pull request #12900: URL: https://github.com/apache/flink/pull/12900#issuecomment-658213136 ## CI report: * ceb895be265bd445b9d36bfc52cf8018a508c333 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #12899: [FLINK-16699][k8s] Support accessing secured services via K8s secrets

2020-07-14 Thread GitBox
flinkbot edited a comment on pull request #12899: URL: https://github.com/apache/flink/pull/12899#issuecomment-658162074 ## CI report: * 77f95464c6036283d77d6e81e2bd21ab27f29d54 Azure:

[GitHub] [flink] flinkbot commented on pull request #12900: [FLINK-18537][table] Remove RowDataTypeInfo

2020-07-14 Thread GitBox
flinkbot commented on pull request #12900: URL: https://github.com/apache/flink/pull/12900#issuecomment-658202311 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] twalthr commented on pull request #12900: [FLINK-18537][table] Remove RowDataTypeInfo

2020-07-14 Thread GitBox
twalthr commented on pull request #12900: URL: https://github.com/apache/flink/pull/12900#issuecomment-658201596 CC @wuchong @dawidwys Btw after all this refactoring I was thinking about renaming `WrapperTypeInfo` to `InternalTypeInfo`. This would better match to its purpose. What do

[GitHub] [flink] twalthr opened a new pull request #12900: [FLINK-18537][table] Remove RowDataTypeInfo

2020-07-14 Thread GitBox
twalthr opened a new pull request #12900: URL: https://github.com/apache/flink/pull/12900 ## What is the purpose of the change `TypeInformation` is a legacy class for the sole purpose of creating a `TypeSerializer`. Instances of `TypeInformation` are not required in the table

[jira] [Updated] (FLINK-18537) Remove RowDataTypeInfo

2020-07-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18537: --- Labels: pull-request-available (was: ) > Remove RowDataTypeInfo > -- >

[jira] [Commented] (FLINK-18588) hive ddl create table should support 'if not exists'

2020-07-14 Thread wangtong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17157401#comment-17157401 ] wangtong commented on FLINK-18588: -- [~jark] please help to review this pr > hive ddl create table

[GitHub] [flink] flinkbot edited a comment on pull request #12866: [FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource.

2020-07-14 Thread GitBox
flinkbot edited a comment on pull request #12866: URL: https://github.com/apache/flink/pull/12866#issuecomment-656576219 ## CI report: * 02c81cff07ef76dc20a7c618112cc7a172856720 Azure:

  1   2   3   >