[jira] [Updated] (FLINK-18497) Publish Dockerfiles for release 1.11.0

2020-07-14 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-18497: --- Fix Version/s: (was: 1.12.0) 1.11.0 > Publish Dockerfiles for release

[jira] [Closed] (FLINK-18497) Publish Dockerfiles for release 1.11.0

2020-07-14 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-18497. -- Resolution: Fixed > Publish Dockerfiles for release 1.11.0 > -

[jira] [Commented] (FLINK-18595) Deadlock during job shutdown

2020-07-14 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17157944#comment-17157944 ] Zhijiang commented on FLINK-18595: -- Thanks for reporting this [~dian.fu]. It is caused

[jira] [Assigned] (FLINK-18595) Deadlock during job shutdown

2020-07-14 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-18595: Assignee: Zhijiang > Deadlock during job shutdown > > >

[jira] [Comment Edited] (FLINK-18523) Advance watermark if there is no data in all of the partitions after some time

2020-07-14 Thread chen yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17157933#comment-17157933 ] chen yong edited comment on FLINK-18523 at 7/15/20, 6:43 AM: -

[jira] [Commented] (FLINK-18523) Advance watermark if there is no data in all of the partitions after some time

2020-07-14 Thread chen yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17157933#comment-17157933 ] chen yong commented on FLINK-18523: --- In DataStream API module , in version 1.11 by imp

[jira] [Commented] (FLINK-18145) Segment optimization does not work in blink ?

2020-07-14 Thread hehuiyuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17157929#comment-17157929 ] hehuiyuan commented on FLINK-18145: --- Hi  [~godfreyhe]  , thx. > Segment optimization

[GitHub] [flink] klion26 commented on a change in pull request #12237: [FLINK-17290] [chinese-translation, Documentation / Training] Transla…

2020-07-14 Thread GitBox
klion26 commented on a change in pull request #12237: URL: https://github.com/apache/flink/pull/12237#discussion_r454812043 ## File path: docs/learn-flink/streaming_analytics.zh.md ## @@ -355,18 +306,15 @@ private static class MyWindowFunction extends ProcessWindowFunction< }

[GitHub] [flink] klion26 commented on a change in pull request #12237: [FLINK-17290] [chinese-translation, Documentation / Training] Transla…

2020-07-14 Thread GitBox
klion26 commented on a change in pull request #12237: URL: https://github.com/apache/flink/pull/12237#discussion_r454812043 ## File path: docs/learn-flink/streaming_analytics.zh.md ## @@ -355,18 +306,15 @@ private static class MyWindowFunction extends ProcessWindowFunction< }

[GitHub] [flink] klion26 commented on a change in pull request #12237: [FLINK-17290] [chinese-translation, Documentation / Training] Transla…

2020-07-14 Thread GitBox
klion26 commented on a change in pull request #12237: URL: https://github.com/apache/flink/pull/12237#discussion_r454812043 ## File path: docs/learn-flink/streaming_analytics.zh.md ## @@ -355,18 +306,15 @@ private static class MyWindowFunction extends ProcessWindowFunction< }

[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 java.lang.I

[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&focusedCommentId=17157881#comment-17157881 ] Congxian Qiu(klion26) commented on FLINK-18582: --- [~temper] thanks for crea

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: https://issues.apache.org/jira/browse/FLINK

[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) doesn

[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: Fl

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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 and

[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 t

[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 automatic

[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 R

[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 e

[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 match

[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 prev

[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&focusedCommentId=17157849#comment-17157849 ] Jark Wu commented on FLINK-18597: - If you want to specify document-id, please refer to t

[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&focusedCommentId=17157848#comment-17157848 ] Shengkai Fang commented on FLINK-18449: --- Hi, all. I find that FlinkKafkaProducer d

[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: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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 +5

[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 standal

[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&focusedCommentId=17157844#comment-17157844 ] Dian Fu commented on FLINK-18600: - Not sure the reason why we choose oracle JDK and if w

[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&focusedCommentId=17157843#comment-17157843 ] Dian Fu commented on FLINK-18600: - I have checked that I can download the version *8u251

[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&focusedCommentId=17157838#comment-17157838 ] WeiqiangSun commented on FLINK-18540: - [~libenchao] Mini batch may not work well wit

[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 r

[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&focusedCommentId=17157832#comment-17157832 ] Jark Wu commented on FLINK-18600: - Looks like we started to use this JDK link since FLIN

[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: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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 a

[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 pro

[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 fa

[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 Operat

[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: a9cce

[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 rea

[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 t

[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 t

[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 org.apache.flink.stre

[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: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=4514&view=logs&j=c88ee

[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 Is

[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 r

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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 I

[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 Issu

[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&focusedCommentId=17157811#comment-17157811 ] Yangze Guo commented on FLINK-18597: I think it is fixed by FLINK-18583. Could you t

[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 Affe

[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 pro

[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 AP

[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 collect(

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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 r

[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 pro

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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 ca

[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 cau

[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 cause

[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: plugins/metrics-influx/flin

[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 c3e0d450c82ea8246a7f0ab

[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 t

[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 META-IN

[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&focusedCommentId=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&focusedCommentId=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&focusedCommentId=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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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 th

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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 `li

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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 t

[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: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

  1   2   3   >