[GitHub] [flink] flinkbot edited a comment on pull request #12283: [FLINK-16975][documentation] Add docs for FileSystem connector

2020-06-04 Thread GitBox
flinkbot edited a comment on pull request #12283: URL: https://github.com/apache/flink/pull/12283#issuecomment-632089857 ## CI report: * b3fd51b309c78d9dd5056eed35dc2fe388665899 UNKNOWN * c29ec64e9bc260015c4b57395ace4a578926fa16 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #11397: [FLINK-16217] [sql-client] catch SqlExecutionException for all callXX methods

2020-06-04 Thread GitBox
flinkbot edited a comment on pull request #11397: URL: https://github.com/apache/flink/pull/11397#issuecomment-598575354 ## CI report: * 5a57da9ab11d0109d384490321cb470e96737ae2 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-18117) "Kerberized YARN per-job on Docker test" fails with "Could not start hadoop cluster."

2020-06-04 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17125607#comment-17125607 ] Robert Metzger commented on FLINK-18117: No, and the NameNode is running in a Do

[GitHub] [flink] flinkbot edited a comment on pull request #12453: [FLINK-18061] [table] TableResult#collect method should return a closeable iterator to avoid resource leak

2020-06-04 Thread GitBox
flinkbot edited a comment on pull request #12453: URL: https://github.com/apache/flink/pull/12453#issuecomment-637941328 ## CI report: * 0576ab0732c449f88663447101828e4ce69d1474 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12444: [FLINK-18067]Change default value of yarnMinAllocationMB from zero to DEFAULT_RM_S…

2020-06-04 Thread GitBox
flinkbot edited a comment on pull request #12444: URL: https://github.com/apache/flink/pull/12444#issuecomment-637596755 ## CI report: * 16ec8b694dc07564b09b60040d20b0da9c0e80c4 UNKNOWN * c23450c9e7735ca7bad0ff97c37480de6c420d0e Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #12473: [FLINK-18061] [table] TableResult#collect method should return a closeable iterator to avoid resource leak

2020-06-04 Thread GitBox
flinkbot edited a comment on pull request #12473: URL: https://github.com/apache/flink/pull/12473#issuecomment-638574481 ## CI report: * b481eaeaf53495c94556190ef2d0dce5aedc7884 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] dawidwys closed pull request #12455: [FLINK-17935] Move setting yarn.log-config-file to YarnClusterClientFactory

2020-06-04 Thread GitBox
dawidwys closed pull request #12455: URL: https://github.com/apache/flink/pull/12455 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] zentol commented on a change in pull request #12447: [FLINK-18069][CI] Test if Java/Scaladocs builds are passing in the compile stage

2020-06-04 Thread GitBox
zentol commented on a change in pull request #12447: URL: https://github.com/apache/flink/pull/12447#discussion_r435040079 ## File path: tools/ci/compile.sh ## @@ -54,10 +54,22 @@ if [ $EXIT_CODE != 0 ]; then exit $EXIT_CODE fi -echo " Checking Scaladocs ===

[jira] [Closed] (FLINK-18006) It will throw Invalid lambda deserialization Exception when writing to elastic search with new format

2020-06-04 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-18006. Resolution: Fixed Fixed in: master: 640a56fee9d777ff2acb69ab6d77275e7373415d 1.11: 10f1d37

[GitHub] [flink] rmetzger commented on a change in pull request #12447: [FLINK-18069][CI] Test if Java/Scaladocs builds are passing in the compile stage

2020-06-04 Thread GitBox
rmetzger commented on a change in pull request #12447: URL: https://github.com/apache/flink/pull/12447#discussion_r435041905 ## File path: tools/ci/compile.sh ## @@ -54,10 +54,22 @@ if [ $EXIT_CODE != 0 ]; then exit $EXIT_CODE fi -echo " Checking Scaladocs =

[GitHub] [flink-web] rmetzger commented on pull request #342: [FLINK-17926] Fix the build problem of docker image

2020-06-04 Thread GitBox
rmetzger commented on pull request #342: URL: https://github.com/apache/flink-web/pull/342#issuecomment-638655356 Thanks a lot, merging This is an automated message from the Apache Git Service. To respond to the message, plea

[GitHub] [flink-web] asfgit closed pull request #342: [FLINK-17926] Fix the build problem of docker image

2020-06-04 Thread GitBox
asfgit closed pull request #342: URL: https://github.com/apache/flink-web/pull/342 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] [Closed] (FLINK-17926) Can't build flink-web docker image because of EOL of Ubuntu:18.10

2020-06-04 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-17926. -- Resolution: Fixed Resolved in https://github.com/apache/flink-web/commit/815eaadaafcc8747678f

[GitHub] [flink] zjffdu commented on a change in pull request #12346: [FLINK-17944][sql-client] Wrong output in sql client's table mode

2020-06-04 Thread GitBox
zjffdu commented on a change in pull request #12346: URL: https://github.com/apache/flink/pull/12346#discussion_r435045007 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/result/MaterializedCollectStreamResult.java ## @@ -22

[GitHub] [flink] flinkbot edited a comment on pull request #11541: [FLINK-15416][network] add task manager netty client retry mechenism

2020-06-04 Thread GitBox
flinkbot edited a comment on pull request #11541: URL: https://github.com/apache/flink/pull/11541#issuecomment-604812212 ## CI report: * b5ef19285000d692d6b1b8b0aa7a37ce35c216f5 UNKNOWN * baf2c55f7bb0b9df7bdef94083c947693b75eae2 UNKNOWN * e5419f41a18eaae05814837d679f58480a2c

[GitHub] [flink] flinkbot edited a comment on pull request #12474: [javadocs] Fix typo in TwoPhaseCommitSinkFunction.java

2020-06-04 Thread GitBox
flinkbot edited a comment on pull request #12474: URL: https://github.com/apache/flink/pull/12474#issuecomment-638579512 ## CI report: * 7c4289c4f4b7752e5693f631c4e84c1ebc0d8beb Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12410: [FLINK-13782][table-api] Implement type strategies for IF ELSE expression

2020-06-04 Thread GitBox
flinkbot edited a comment on pull request #12410: URL: https://github.com/apache/flink/pull/12410#issuecomment-635946149 ## CI report: * ce34ce1e7b16cf8c6bf359ffadbf5d3e96613947 UNKNOWN * 9e2c9729f2c4fb3af0e339c9f7046bf1cef2fb60 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] carp84 commented on a change in pull request #12144: [FLINK-17384][flink-dist] support read hbase conf dir from flink.conf and change HBaseConfiguration construction.

2020-06-04 Thread GitBox
carp84 commented on a change in pull request #12144: URL: https://github.com/apache/flink/pull/12144#discussion_r435046468 ## File path: flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/util/HBaseConfigurationUtil.java ## @@ -22,20 +22,85 @

[GitHub] [flink] wuchong commented on a change in pull request #12436: [FLINK-17847][table sql / planner] ArrayIndexOutOfBoundsException happens in StreamExecCalc operator

2020-06-04 Thread GitBox
wuchong commented on a change in pull request #12436: URL: https://github.com/apache/flink/pull/12436#discussion_r435038062 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/calls/ScalarOperatorGens.scala ## @@ -1643,19 +

[jira] [Comment Edited] (FLINK-17466) toRetractStream doesn't work correctly with Pojo conversion class

2020-06-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17125527#comment-17125527 ] Jark Wu edited comment on FLINK-17466 at 6/4/20, 7:30 AM: -- - ma

[jira] [Assigned] (FLINK-18091) Test Relocatable Savepoints

2020-06-04 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li reassigned FLINK-18091: - Assignee: Congxian Qiu(klion26) Thanks [~klion26], just assigned to you. > Test Relocatable Savepoints

[jira] [Updated] (FLINK-16451) Fix IndexOutOfBoundsException for DISTINCT AGG with constants

2020-06-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16451: Summary: Fix IndexOutOfBoundsException for DISTINCT AGG with constants (was: listagg with distinct for ov

[jira] [Comment Edited] (FLINK-16451) Fix IndexOutOfBoundsException for DISTINCT AGG with constants

2020-06-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17125525#comment-17125525 ] Jark Wu edited comment on FLINK-16451 at 6/4/20, 7:30 AM: -- - ma

[jira] [Closed] (FLINK-17466) toRetractStream doesn't work correctly with Pojo conversion class

2020-06-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-17466. --- Resolution: Fixed > toRetractStream doesn't work correctly with Pojo conversion class >

[jira] [Closed] (FLINK-16451) Fix IndexOutOfBoundsException for DISTINCT AGG with constants

2020-06-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-16451. --- Resolution: Fixed > Fix IndexOutOfBoundsException for DISTINCT AGG with constants >

[jira] [Commented] (FLINK-18055) Catalog does not exist in SQL Client

2020-06-04 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17125626#comment-17125626 ] Dawid Wysakowicz commented on FLINK-18055: -- Isn't it a duplicate of FLINK-17941

[jira] [Commented] (FLINK-17260) StreamingKafkaITCase failure on Azure

2020-06-04 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17125629#comment-17125629 ] Aljoscha Krettek commented on FLINK-17260: -- I think this is two separate issues

[jira] [Created] (FLINK-18118) Some SQL Jobs with two input operators are loosing data with unaligned checkpoints

2020-06-04 Thread Jark Wu (Jira)
Jark Wu created FLINK-18118: --- Summary: Some SQL Jobs with two input operators are loosing data with unaligned checkpoints Key: FLINK-18118 URL: https://issues.apache.org/jira/browse/FLINK-18118 Project: Fli

[jira] [Updated] (FLINK-15066) Cannot run multiple `insert into csvTable values ()`

2020-06-04 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-15066: --- Affects Version/s: 1.10.1 > Cannot run multiple `insert into csvTable values ()` > -

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

2020-06-04 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17125632#comment-17125632 ] Nicholas Jiang commented on FLINK-17726: I have already discuss with [~trohrmann

[jira] [Updated] (FLINK-17918) LIMIT queries are failed when adding sleeping time of async checkpoint

2020-06-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-17918: Description: {{org.apache.flink.table.planner.runtime.stream.sql.AggregateITCase#testDifferentTypesSumWith

[jira] [Updated] (FLINK-17918) LIMIT queries are failed when adding sleeping time of async checkpoint

2020-06-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-17918: Summary: LIMIT queries are failed when adding sleeping time of async checkpoint (was: Blink Jobs are loos

[jira] [Updated] (FLINK-17918) LIMIT queries are failed when adding sleeping time of async checkpoint

2020-06-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-17918: Description: {{org.apache.flink.table.planner.runtime.stream.sql.AggregateITCase#testDifferentTypesSumWith

[jira] [Assigned] (FLINK-17260) StreamingKafkaITCase failure on Azure

2020-06-04 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-17260: -- Assignee: Aljoscha Krettek > StreamingKafkaITCase failure on Azure >

[GitHub] [flink] rmetzger commented on a change in pull request #12447: [FLINK-18069][CI] Test if Java/Scaladocs builds are passing in the compile stage

2020-06-04 Thread GitBox
rmetzger commented on a change in pull request #12447: URL: https://github.com/apache/flink/pull/12447#discussion_r435054927 ## File path: tools/ci/compile.sh ## @@ -54,10 +54,22 @@ if [ $EXIT_CODE != 0 ]; then exit $EXIT_CODE fi -echo " Checking Scaladocs =

[jira] [Updated] (FLINK-17918) LIMIT queries are failed when adding sleeping time of async checkpoint

2020-06-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-17918: Description: When we change the timing of operations (sleep after emit first record and sleep for async op

[jira] [Assigned] (FLINK-17965) Hive dialect doesn't properly handle special character escaping with SQL CLI

2020-06-04 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-17965: -- Assignee: Rui Li > Hive dialect doesn't properly handle special character escaping wi

[jira] [Commented] (FLINK-17918) LIMIT queries are failed when adding sleeping time of async checkpoint

2020-06-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17125637#comment-17125637 ] Jark Wu commented on FLINK-17918: - FYI, I have updated the title and description of this

[GitHub] [flink] rkhachatryan opened a new pull request #12478: [FLINK-17869][task][checkpointing] Fix race condition when caling ChannelStateWriter.abort

2020-06-04 Thread GitBox
rkhachatryan opened a new pull request #12478: URL: https://github.com/apache/flink/pull/12478 __This is a draft PR. It depends on #12457 and should not be merged before__ ## What is the purpose of the change Before FLINK-17218 there were two problems: 1. Exceeding `ChannelS

[jira] [Updated] (FLINK-17869) Fix the race condition of aborting unaligned checkpoint

2020-06-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17869: --- Labels: pull-request-available (was: ) > Fix the race condition of aborting unaligned check

[jira] [Commented] (FLINK-18018) Bundle GPU plugin in "plugins/" directory

2020-06-04 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17125639#comment-17125639 ] Chesnay Schepler commented on FLINK-18018: -- I see no reference in the thread in

[GitHub] [flink-web] klion26 commented on pull request #342: [FLINK-17926] Fix the build problem of docker image

2020-06-04 Thread GitBox
klion26 commented on pull request #342: URL: https://github.com/apache/flink-web/pull/342#issuecomment-638670980 @rmetzger @sjwiesman thanks for the review and merging. This is an automated message from the Apache Git Servic

[GitHub] [flink] flinkbot commented on pull request #12478: [FLINK-17869][task][checkpointing] Fix race condition when caling ChannelStateWriter.abort

2020-06-04 Thread GitBox
flinkbot commented on pull request #12478: URL: https://github.com/apache/flink/pull/12478#issuecomment-638671681 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] rkhachatryan commented on a change in pull request #12457: [FLINK-18050][task][checkpointing] Fix double buffer recycling

2020-06-04 Thread GitBox
rkhachatryan commented on a change in pull request #12457: URL: https://github.com/apache/flink/pull/12457#discussion_r435058156 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateCheckpointWriter.java ## @@ -108,32 +108,30 @@

[GitHub] [flink] flinkbot edited a comment on pull request #12283: [FLINK-16975][documentation] Add docs for FileSystem connector

2020-06-04 Thread GitBox
flinkbot edited a comment on pull request #12283: URL: https://github.com/apache/flink/pull/12283#issuecomment-632089857 ## CI report: * b3fd51b309c78d9dd5056eed35dc2fe388665899 UNKNOWN * 8569d299f41b57033debc94d33ab11af91452140 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Commented] (FLINK-18076) Sql client uses wrong class loader when parsing queries

2020-06-04 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17125650#comment-17125650 ] Dawid Wysakowicz commented on FLINK-18076: -- I will review the issue. [~Leonard

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

2020-06-04 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17125653#comment-17125653 ] Zhu Zhu commented on FLINK-17726: - Thanks for the updates. [~nicholasjiang] Looking for

[GitHub] [flink] azagrebin commented on a change in pull request #12256: [FLINK-17018][runtime] Allocates slots in bulks for pipelined region scheduling

2020-06-04 Thread GitBox
azagrebin commented on a change in pull request #12256: URL: https://github.com/apache/flink/pull/12256#discussion_r435061970 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/OneSlotPerExecutionSlotAllocator.java ## @@ -0,0 +1,277 @@ +/* + * License

[jira] [Commented] (FLINK-18018) Bundle GPU plugin in "plugins/" directory

2020-06-04 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17125656#comment-17125656 ] Yangze Guo commented on FLINK-18018: I see Stephan's comment: {quote}(1) Now that we

[GitHub] [flink] wangyang0918 commented on pull request #12455: [FLINK-17935] Move setting yarn.log-config-file to YarnClusterClientFactory

2020-06-04 Thread GitBox
wangyang0918 commented on pull request #12455: URL: https://github.com/apache/flink/pull/12455#issuecomment-638678244 cc @dawidwys This PR is closed exceptionally by this commit 640a56fee9d777ff2acb69ab6d77275e7373415d. Could you please have a look? A wrong PR id is used in the commit mess

[jira] [Updated] (FLINK-18109) Manually test external resource framework with GPUDriver

2020-06-04 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-18109: --- Priority: Blocker (was: Major) > Manually test external resource framework with GPUDriver > ---

[jira] [Commented] (FLINK-18115) StabilityTest

2020-06-04 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17125662#comment-17125662 ] Aljoscha Krettek commented on FLINK-18115: -- Please use a meaningful Issue title

[GitHub] [flink] wangyang0918 commented on pull request #12444: [FLINK-18067]Change default value of yarnMinAllocationMB from zero to DEFAULT_RM_S…

2020-06-04 Thread GitBox
wangyang0918 commented on pull request #12444: URL: https://github.com/apache/flink/pull/12444#issuecomment-638679742 The changes look good to me. cc @TisonKun @tillrohrmann could you please have a final check and help with merging?

[jira] [Commented] (FLINK-18116) E2E performance test

2020-06-04 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17125663#comment-17125663 ] Aljoscha Krettek commented on FLINK-18116: -- Please use a meaningful Issue title

[jira] [Updated] (FLINK-18116) Manually test E2E performance on Flink 1.11

2020-06-04 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-18116: --- Summary: Manually test E2E performance on Flink 1.11 (was: E2E performance test) > Manuall

[GitHub] [flink] jinglining commented on pull request #11752: [FLINK-14713][rest]Show All Attempts For Vertex SubTask In Rest Api

2020-06-04 Thread GitBox
jinglining commented on pull request #11752: URL: https://github.com/apache/flink/pull/11752#issuecomment-638682502 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, plea

[GitHub] [flink] wangyang0918 edited a comment on pull request #12455: [FLINK-17935] Move setting yarn.log-config-file to YarnClusterClientFactory

2020-06-04 Thread GitBox
wangyang0918 edited a comment on pull request #12455: URL: https://github.com/apache/flink/pull/12455#issuecomment-638678244 cc @dawidwys This PR is closed accidentally by this commit 640a56fee9d777ff2acb69ab6d77275e7373415d. Could you please have a look? A wrong PR id is used in the commi

[jira] [Updated] (FLINK-18115) Manually test fault-tolerance stability on Flink 1.11

2020-06-04 Thread Aihua Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aihua Li updated FLINK-18115: - Summary: Manually test fault-tolerance stability on Flink 1.11 (was: StabilityTest) > Manually test fa

[jira] [Commented] (FLINK-18076) Sql client uses wrong class loader when parsing queries

2020-06-04 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17125668#comment-17125668 ] Leonard Xu commented on FLINK-18076: [~dwysakowicz] sure, thanks. > Sql client uses

[jira] [Assigned] (FLINK-18118) Some SQL Jobs with two input operators are loosing data with unaligned checkpoints

2020-06-04 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-18118: -- Assignee: Arvid Heise > Some SQL Jobs with two input operators are loosing data with

[jira] [Updated] (FLINK-17422) Create user document for the external resource framework and the GPU plugin..

2020-06-04 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-17422: --- Priority: Critical (was: Major) > Create user document for the external resource framework and the

[GitHub] [flink] flinkbot edited a comment on pull request #12471: [FLINK-18073][FLINK-18029][avro] Fix AvroRowDataSerializationSchema is not serializable and add IT cases

2020-06-04 Thread GitBox
flinkbot edited a comment on pull request #12471: URL: https://github.com/apache/flink/pull/12471#issuecomment-638362836 ## CI report: * cd6af0ccaeda47e15c31f20df9743ab038b4bfa9 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Comment Edited] (FLINK-18018) Bundle GPU plugin in "plugins/" directory

2020-06-04 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17125656#comment-17125656 ] Yangze Guo edited comment on FLINK-18018 at 6/4/20, 8:11 AM: -

[GitHub] [flink] flinkbot edited a comment on pull request #12410: [FLINK-13782][table-api] Implement type strategies for IF ELSE expression

2020-06-04 Thread GitBox
flinkbot edited a comment on pull request #12410: URL: https://github.com/apache/flink/pull/12410#issuecomment-635946149 ## CI report: * ce34ce1e7b16cf8c6bf359ffadbf5d3e96613947 UNKNOWN * 9e2c9729f2c4fb3af0e339c9f7046bf1cef2fb60 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #12457: [FLINK-18050][task][checkpointing] Fix double buffer recycling

2020-06-04 Thread GitBox
flinkbot edited a comment on pull request #12457: URL: https://github.com/apache/flink/pull/12457#issuecomment-638033007 ## CI report: * 7e7fa184fdc100b55d436011081b645dc4ef069c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #12478: [FLINK-17869][task][checkpointing] Fix race condition when caling ChannelStateWriter.abort

2020-06-04 Thread GitBox
flinkbot commented on pull request #12478: URL: https://github.com/apache/flink/pull/12478#issuecomment-638685986 ## CI report: * bb036ae536e7705d8dfd8b8a5654198bbf4fa5c2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Commented] (FLINK-17769) Wrong order of log events on a task failure

2020-06-04 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17125674#comment-17125674 ] Yuan Mei commented on FLINK-17769: -- *This is what I think is happening:* The error msg

[GitHub] [flink] kl0u commented on pull request #12455: [FLINK-17935] Move setting yarn.log-config-file to YarnClusterClientFactory

2020-06-04 Thread GitBox
kl0u commented on pull request #12455: URL: https://github.com/apache/flink/pull/12455#issuecomment-638692082 Yep, this seems to be a mistake. This is an automated message from the Apache Git Service. To respond to the messag

[GitHub] [flink] dawidwys commented on pull request #12475: [FLINK-18076][table sql / client] Sql client uses wrong class loader when parsing queries

2020-06-04 Thread GitBox
dawidwys commented on pull request #12475: URL: https://github.com/apache/flink/pull/12475#issuecomment-638692230 @leonardBang Have you verified the fix? Unfortunately it does not work. @godfreyhe I am not exactly what is your suggested solution, so sorry if I am wrong here. However,

[GitHub] [flink] dawidwys commented on pull request #12455: [FLINK-17935] Move setting yarn.log-config-file to YarnClusterClientFactory

2020-06-04 Thread GitBox
dawidwys commented on pull request #12455: URL: https://github.com/apache/flink/pull/12455#issuecomment-638693240 Oh snap, really sorry about that :( This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] dawidwys edited a comment on pull request #12455: [FLINK-17935] Move setting yarn.log-config-file to YarnClusterClientFactory

2020-06-04 Thread GitBox
dawidwys edited a comment on pull request #12455: URL: https://github.com/apache/flink/pull/12455#issuecomment-638693240 Oh snap, really sorry about that :( I made a typo with #12445 This is an automated message from

[GitHub] [flink] JingsongLi commented on pull request #12283: [FLINK-16975][documentation] Add docs for FileSystem connector

2020-06-04 Thread GitBox
JingsongLi commented on pull request #12283: URL: https://github.com/apache/flink/pull/12283#issuecomment-638696047 Thanks everyone for review, merging... This is an automated message from the Apache Git Service. To respond t

[GitHub] [flink] dawidwys edited a comment on pull request #12475: [FLINK-18076][table sql / client] Sql client uses wrong class loader when parsing queries

2020-06-04 Thread GitBox
dawidwys edited a comment on pull request #12475: URL: https://github.com/apache/flink/pull/12475#issuecomment-638692230 @leonardBang Have you verified the fix? Unfortunately it does not work. @godfreyhe I am not exactly sure what is your suggested solution, so sorry if I am wrong he

[GitHub] [flink] JingsongLi merged pull request #12283: [FLINK-16975][documentation] Add docs for FileSystem connector

2020-06-04 Thread GitBox
JingsongLi merged pull request #12283: URL: https://github.com/apache/flink/pull/12283 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] [Closed] (FLINK-16975) Add docs for FileSystem connector

2020-06-04 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-16975. Resolution: Fixed master: f92e70ee4da72ee0585cd17ef1febf1c4dea4f67 release-1.11: 749620d007e93a6f

[jira] [Closed] (FLINK-14256) [Umbrella] Introduce FileSystemTableFactory with partitioned support

2020-06-04 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-14256. Resolution: Implemented > [Umbrella] Introduce FileSystemTableFactory with partitioned support > -

[jira] [Created] (FLINK-18119) Fix unlimitedly growing state for time range bounded over aggregate

2020-06-04 Thread Hyeonseop Lee (Jira)
Hyeonseop Lee created FLINK-18119: - Summary: Fix unlimitedly growing state for time range bounded over aggregate Key: FLINK-18119 URL: https://issues.apache.org/jira/browse/FLINK-18119 Project: Flink

[jira] [Updated] (FLINK-18119) Fix unlimitedly growing state for time range bounded over aggregate

2020-06-04 Thread Hyeonseop Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hyeonseop Lee updated FLINK-18119: -- Description: For time range bounded over aggregation in streaming query, like below, {code:jav

[jira] [Updated] (FLINK-18119) Fix unlimitedly growing state for time range bounded over aggregate

2020-06-04 Thread Hyeonseop Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hyeonseop Lee updated FLINK-18119: -- Affects Version/s: 1.10.1 > Fix unlimitedly growing state for time range bounded over aggregat

[GitHub] [flink] kl0u closed pull request #12455: [FLINK-17935] Move setting yarn.log-config-file to YarnClusterClientFactory

2020-06-04 Thread GitBox
kl0u closed pull request #12455: URL: https://github.com/apache/flink/pull/12455 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 the

[GitHub] [flink] danny0405 commented on a change in pull request #12355: [FLINK-17893] [sql-client] SQL CLI should print the root cause if the statement is invalid

2020-06-04 Thread GitBox
danny0405 commented on a change in pull request #12355: URL: https://github.com/apache/flink/pull/12355#discussion_r435085251 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliClient.java ## @@ -253,7 +253,13 @@ public boolean submit

[GitHub] [flink-docker] rmetzger opened a new pull request #24: [hotfix] Add readme with simple instructions

2020-06-04 Thread GitBox
rmetzger opened a new pull request #24: URL: https://github.com/apache/flink-docker/pull/24 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 t

[jira] [Closed] (FLINK-17935) Logs could not show up when deploying Flink on Yarn via "--executor"

2020-06-04 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-17935. -- Resolution: Fixed Fixed on master with 2eb7377163490878f12e4687db5fb4db0e6f47c2 and on release

[jira] [Closed] (FLINK-18102) Test Pandas UDF support

2020-06-04 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-18102. --- Resolution: Done Verified that * Single Pandas UDF works as expected * Multiple Chaining Pandas UDF works

[GitHub] [flink] aljoscha opened a new pull request #12479: [FLINK-17260] Fix StreamingKafkaITCase instabilities

2020-06-04 Thread GitBox
aljoscha opened a new pull request #12479: URL: https://github.com/apache/flink/pull/12479 This fixes two possible sources of instability: - not reading all the messages because of timeout - clashes in topic names, which lead to double counting -

[jira] [Updated] (FLINK-17260) StreamingKafkaITCase failure on Azure

2020-06-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17260: --- Labels: pull-request-available test-stability (was: test-stability) > StreamingKafkaITCase

[GitHub] [flink] dawidwys edited a comment on pull request #12445: [FLINK-18006] Always overwrite RestClientFactory in ElasticsearchXDynamicSink

2020-06-04 Thread GitBox
dawidwys edited a comment on pull request #12445: URL: https://github.com/apache/flink/pull/12445#issuecomment-638706110 Closed in 640a56fee9d777ff2acb69ab6d77275e7373415d This is an automated message from the Apache Git Serv

[GitHub] [flink] dawidwys closed pull request #12445: [FLINK-18006] Always overwrite RestClientFactory in ElasticsearchXDynamicSink

2020-06-04 Thread GitBox
dawidwys closed pull request #12445: URL: https://github.com/apache/flink/pull/12445 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] dawidwys commented on pull request #12445: [FLINK-18006] Always overwrite RestClientFactory in ElasticsearchXDynamicSink

2020-06-04 Thread GitBox
dawidwys commented on pull request #12445: URL: https://github.com/apache/flink/pull/12445#issuecomment-638706110 Close in 640a56fee9d777ff2acb69ab6d77275e7373415d This is an automated message from the Apache Git Service. To

[GitHub] [flink] flinkbot edited a comment on pull request #12311: [FLINK-17269][docs] Translate new Training Overview to Chinese

2020-06-04 Thread GitBox
flinkbot edited a comment on pull request #12311: URL: https://github.com/apache/flink/pull/12311#issuecomment-633370054 ## CI report: * 75e9cf373a523c6a30319c0f98c4cb51107839fc Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12457: [FLINK-18050][task][checkpointing] Fix double buffer recycling

2020-06-04 Thread GitBox
flinkbot edited a comment on pull request #12457: URL: https://github.com/apache/flink/pull/12457#issuecomment-638033007 ## CI report: * 7e7fa184fdc100b55d436011081b645dc4ef069c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #12479: [FLINK-17260] Fix StreamingKafkaITCase instabilities

2020-06-04 Thread GitBox
flinkbot commented on pull request #12479: URL: https://github.com/apache/flink/pull/12479#issuecomment-638708092 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] flinkbot edited a comment on pull request #12475: [FLINK-18076][table sql / client] Sql client uses wrong class loader when parsing queries

2020-06-04 Thread GitBox
flinkbot edited a comment on pull request #12475: URL: https://github.com/apache/flink/pull/12475#issuecomment-638593958 ## CI report: * 41240cd524255ffc7cf63d2bc2ee9ff38f3abcbd UNKNOWN * fda75fa6db31dc6cc66f5b4fa7f86db3d4e26356 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #12478: [FLINK-17869][task][checkpointing] Fix race condition when caling ChannelStateWriter.abort

2020-06-04 Thread GitBox
flinkbot edited a comment on pull request #12478: URL: https://github.com/apache/flink/pull/12478#issuecomment-638685986 ## CI report: * bb036ae536e7705d8dfd8b8a5654198bbf4fa5c2 UNKNOWN * 420b7b3f645625b0b43f056440509cdd53bbd4ef UNKNOWN Bot commands The @flinkbo

[GitHub] [flink] dawidwys commented on pull request #12056: [FLINK-17502] [flink-connector-rabbitmq] RMQSource refactor

2020-06-04 Thread GitBox
dawidwys commented on pull request #12056: URL: https://github.com/apache/flink/pull/12056#issuecomment-638709334 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] danny0405 commented on a change in pull request #12381: [FLINK-17941][sql-client] Switching catalog or database doesn't work …

2020-06-04 Thread GitBox
danny0405 commented on a change in pull request #12381: URL: https://github.com/apache/flink/pull/12381#discussion_r435094113 ## File path: flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/cli/SqlCommandParserTest.java ## @@ -134,8 +134,8 @@ public void

[GitHub] [flink] godfreyhe commented on pull request #12475: [FLINK-18076][table sql / client] Sql client uses wrong class loader when parsing queries

2020-06-04 Thread GitBox
godfreyhe commented on pull request #12475: URL: https://github.com/apache/flink/pull/12475#issuecomment-638710775 @dawidwys For a long term, I think sql client should has an extended sql parser which can parse not not standard sql statement but also some special commands (e.g. `SOURCE`, `

[GitHub] [flink] wuchong commented on pull request #12326: [FLINK-16577] [table-planner-blink] Fix numeric type mismatch error in  column interval relmetadata

2020-06-04 Thread GitBox
wuchong commented on pull request #12326: URL: https://github.com/apache/flink/pull/12326#issuecomment-638713329 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] liuyongvs commented on a change in pull request #12144: [FLINK-17384][flink-dist] support read hbase conf dir from flink.conf and change HBaseConfiguration construction.

2020-06-04 Thread GitBox
liuyongvs commented on a change in pull request #12144: URL: https://github.com/apache/flink/pull/12144#discussion_r435096361 ## File path: flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/util/HBaseConfigurationUtil.java ## @@ -22,20 +22,8

[jira] [Updated] (FLINK-15796) Extend Kubernetes documentation on how to use a custom image

2020-06-04 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-15796: -- Fix Version/s: (was: 1.10.2) Removing 1.10.2 from the fix version since the changes for FLINK-17161 is not

  1   2   3   4   5   6   7   >