[GitHub] [flink] flinkbot edited a comment on pull request #11868: [FLINK-17258][tests] Enabling unaligned checkpoint in all tests by default

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #11868: URL: https://github.com/apache/flink/pull/11868#issuecomment-617994961 ## CI report: * c9a8597b0f40ac2600440a65c2c2488dd385ff4e UNKNOWN * 1ed80167a0655c9fb579e93cd94a49517eaa9b42 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #12575: [FLINK-18094][checkpointing] Unifies the creation of BarrierHandlers and CheckpointedInputGate.

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12575: URL: https://github.com/apache/flink/pull/12575#issuecomment-641844980 ## CI report: * cf35ad99fab120c4ea7795406e65dcb1073ab0ed Azure:

[GitHub] [flink] flinkbot commented on pull request #12675: [FLINK-18319][notice] Lack LICENSE.protobuf in flink-sql-orc

2020-06-16 Thread GitBox
flinkbot commented on pull request #12675: URL: https://github.com/apache/flink/pull/12675#issuecomment-644619394 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] [Reopened] (FLINK-18082) UnsignedTypeConversionITCase stalls in ch.vorburger.mariadb4j.DB.stop

2020-06-16 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reopened FLINK-18082:

[GitHub] [flink] aljoscha commented on pull request #12674: [FLINK-18311] Fix StreamingKafkaITCase on Kafka 2.4.1

2020-06-16 Thread GitBox
aljoscha commented on pull request #12674: URL: https://github.com/apache/flink/pull/12674#issuecomment-644619330 @zentol The versions should already be updated on `master` and `release-1.11`. This is an automated message

[GitHub] [flink] carp84 closed pull request #12514: [FLINK-17800][roksdb] Ensure total order seek to avoid user misuse

2020-06-16 Thread GitBox
carp84 closed pull request #12514: URL: https://github.com/apache/flink/pull/12514 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] [Commented] (FLINK-18317) Verify dependencies licencses in Flink 1.11

2020-06-16 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136438#comment-17136438 ] Robert Metzger commented on FLINK-18317: Anybody has a better git diff? {{git diff

[jira] [Updated] (FLINK-18322) Fix unstable ExecutorNotifierTest#testExceptionInHandler.

2020-06-16 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-18322: - Fix Version/s: 1.11.0 > Fix unstable ExecutorNotifierTest#testExceptionInHandler. >

[jira] [Commented] (FLINK-17824) "Resuming Savepoint" e2e stalls indefinitely

2020-06-16 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136450#comment-17136450 ] Roman Khachatryan commented on FLINK-17824: --- I've published a PR to fix the test: 

[GitHub] [flink] pnowojski commented on a change in pull request #12575: [FLINK-18094][checkpointing] Unifies the creation of BarrierHandlers and CheckpointedInputGate.

2020-06-16 Thread GitBox
pnowojski commented on a change in pull request #12575: URL: https://github.com/apache/flink/pull/12575#discussion_r440595683 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/UnionInputGate.java ## @@ -105,11 +105,11 @@ public

[jira] [Comment Edited] (FLINK-16795) End to end tests timeout on Azure

2020-06-16 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136337#comment-17136337 ] Robert Metzger edited comment on FLINK-16795 at 6/16/20, 6:02 AM: --

[jira] [Commented] (FLINK-18311) StreamingKafkaITCase stalls indefinitely

2020-06-16 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136360#comment-17136360 ] Robert Metzger commented on FLINK-18311: All the builds are failing with this. Upgrading to

[jira] [Comment Edited] (FLINK-18288) WEB UI failure in Flink1.12

2020-06-16 Thread appleyuchi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136356#comment-17136356 ] appleyuchi edited comment on FLINK-18288 at 6/16/20, 6:43 AM: -- Thanks for

[GitHub] [flink] dawidwys commented on pull request #12649: [FLINK-18286] Implement type inference for GET/FLATTEN

2020-06-16 Thread GitBox
dawidwys commented on pull request #12649: URL: https://github.com/apache/flink/pull/12649#issuecomment-644565539 Let me explain what the changes are about. They are not trying to fix the nullability of the record type in all operators, but in my opinion it actually improves the behaviour

[jira] [Comment Edited] (FLINK-18288) WEB UI failure in Flink1.12

2020-06-16 Thread appleyuchi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136356#comment-17136356 ] appleyuchi edited comment on FLINK-18288 at 6/16/20, 6:54 AM: -- Thanks for

[jira] [Commented] (FLINK-17977) Check log sanity

2020-06-16 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136369#comment-17136369 ] Till Rohrmann commented on FLINK-17977: --- Let's create a follow up ticket for the table module and

[jira] [Comment Edited] (FLINK-18288) WEB UI failure in Flink1.12

2020-06-16 Thread appleyuchi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136356#comment-17136356 ] appleyuchi edited comment on FLINK-18288 at 6/16/20, 6:53 AM: -- Thanks for

[jira] [Commented] (FLINK-16795) End to end tests timeout on Azure

2020-06-16 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136367#comment-17136367 ] Robert Metzger commented on FLINK-16795: [~becket_qin] thanks a lot for posting the updated link

[jira] [Updated] (FLINK-18316) Add a dynamic state registration primitive for Stateful Functions

2020-06-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18316: --- Labels: pull-request-available (was: ) > Add a dynamic state registration primitive for

[GitHub] [flink-statefun] tzulitai opened a new pull request #125: [FLINK-18316] Add support for dynamic (lazy) state registration

2020-06-16 Thread GitBox
tzulitai opened a new pull request #125: URL: https://github.com/apache/flink-statefun/pull/125 ## User usage This PR introduces a new state primitive in Stateful Functions, called `PersistedStateRegistry`. Users can use a state registry to dynamically register state like so:

[GitHub] [flink] aljoscha opened a new pull request #12667: [FLINK-18209] Replace slave with worker in docker cluster test scripts

2020-06-16 Thread GitBox
aljoscha opened a new pull request #12667: URL: https://github.com/apache/flink/pull/12667 ## Brief change log We just replace `slave` by `worker` in the test script/docker-compose file. This does not affect users since it's only in tests ## Verifying this change

[jira] [Updated] (FLINK-18209) Replace "charged" words in the Flink codebase.

2020-06-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18209: --- Labels: pull-request-available (was: ) > Replace "charged" words in the Flink codebase. >

[GitHub] [flink] flinkbot edited a comment on pull request #12666: [FLINK-18313][doc] Hive dialect doc should mention that views created…

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12666: URL: https://github.com/apache/flink/pull/12666#issuecomment-644563760 ## CI report: * 30d17d142c22ddd8e0e52951969486ee4132d40b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12661: [FLINK-18299][Formats(Json)]Add option in json format to parse timestamp in different standard

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12661: URL: https://github.com/apache/flink/pull/12661#issuecomment-644211738 ## CI report: * c1314ccf8e399484f78f3cea57d0229cb6a5d79b Azure:

[GitHub] [flink] flinkbot commented on pull request #12668: [FLINK-18291][e2e] Introduce timeout into Streaming File Sink s3 test

2020-06-16 Thread GitBox
flinkbot commented on pull request #12668: URL: https://github.com/apache/flink/pull/12668#issuecomment-644575510 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] libenchao closed pull request #12642: [FLINK-18282][docs-zh] retranslate the documentation home page

2020-06-16 Thread GitBox
libenchao closed pull request #12642: URL: https://github.com/apache/flink/pull/12642 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] [Commented] (FLINK-18282) retranslate the documentation home page

2020-06-16 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136375#comment-17136375 ] Benchao Li commented on FLINK-18282: master: f4aaf8c8ee6562ad37bf4d7f2ba2778899c0 > retranslate

[jira] [Assigned] (FLINK-18311) StreamingKafkaITCase stalls indefinitely

2020-06-16 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-18311: Assignee: Aljoscha Krettek > StreamingKafkaITCase stalls indefinitely >

[GitHub] [flink] rkhachatryan opened a new pull request #12671: [FLINK-17824][tests] Fix resume_savepoint e2e test by slowing down th…

2020-06-16 Thread GitBox
rkhachatryan opened a new pull request #12671: URL: https://github.com/apache/flink/pull/12671 ## What is the purpose of the change Fix `test_resume_savepoint.sh` e2e test by slowing down the Source. This prevents it from generating too much data to consume by the downstream

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

2020-06-16 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benchao Li reassigned FLINK-18119: -- Assignee: Hyeonseop Lee > Fix unlimitedly growing state for time range bounded over

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

2020-06-16 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136386#comment-17136386 ] Benchao Li commented on FLINK-18119: [~hyeonseop] I got your point, nice catch, IMO this is a bug.

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

2020-06-16 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benchao Li updated FLINK-18119: --- Issue Type: Bug (was: Improvement) > Fix unlimitedly growing state for time range bounded over

[jira] [Created] (FLINK-18317) Verify dependencies licencses in Flink 1.11

2020-06-16 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-18317: -- Summary: Verify dependencies licencses in Flink 1.11 Key: FLINK-18317 URL: https://issues.apache.org/jira/browse/FLINK-18317 Project: Flink Issue Type:

[GitHub] [flink] AHeise commented on a change in pull request #12575: [FLINK-18094][checkpointing] Unifies the creation of BarrierHandlers and CheckpointedInputGate.

2020-06-16 Thread GitBox
AHeise commented on a change in pull request #12575: URL: https://github.com/apache/flink/pull/12575#discussion_r440659829 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointBarrierAligner.java ## @@ -46,14 +49,8 @@

[GitHub] [flink] flinkbot edited a comment on pull request #12575: [FLINK-18094][checkpointing] Unifies the creation of BarrierHandlers and CheckpointedInputGate.

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12575: URL: https://github.com/apache/flink/pull/12575#issuecomment-641844980 ## CI report: * cf35ad99fab120c4ea7795406e65dcb1073ab0ed Azure:

[GitHub] [flink] StephanEwen commented on pull request #12662: [FLINK-18307][scripts] Rename 'slaves' file to 'workers'

2020-06-16 Thread GitBox
StephanEwen commented on pull request #12662: URL: https://github.com/apache/flink/pull/12662#issuecomment-644603072 Merged in c47fb4704ccd123cb71ee9f3379a166f91f1c217 This is an automated message from the Apache Git

[GitHub] [flink] StephanEwen closed pull request #12662: [FLINK-18307][scripts] Rename 'slaves' file to 'workers'

2020-06-16 Thread GitBox
StephanEwen closed pull request #12662: URL: https://github.com/apache/flink/pull/12662 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to

[GitHub] [flink] wuchong commented on a change in pull request #12369: [FLINK-17678][Connectors/HBase]Support fink-sql-connector-hbase

2020-06-16 Thread GitBox
wuchong commented on a change in pull request #12369: URL: https://github.com/apache/flink/pull/12369#discussion_r440666999 ## File path: flink-connectors/flink-sql-connector-hbase/src/main/resources/META-INF/NOTICE ## @@ -0,0 +1,13 @@ +flink-sql-connector-hbase +Copyright

[jira] [Commented] (FLINK-16908) FlinkKafkaProducerITCase testScaleUpAfterScalingDown Timeout expired while initializing transactional state in 60000ms.

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

[GitHub] [flink] tillrohrmann commented on a change in pull request #11322: [FLINK-16376][yarn] Use consistent method to get Yarn application dir…

2020-06-16 Thread GitBox
tillrohrmann commented on a change in pull request #11322: URL: https://github.com/apache/flink/pull/11322#discussion_r440679410 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java ## @@ -99,6 +99,18 @@ public static void setupYarnClassPath(Configuration

[GitHub] [flink] flinkbot edited a comment on pull request #12643: [FLINK-18161][sql-client] Fix configurations from flink-conf.yaml overwrite sql-client's properties

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12643: URL: https://github.com/apache/flink/pull/12643#issuecomment-643713303 ## CI report: * c742e48f939cbfb76f6b0bcd2b380060c973ae90 Azure:

[GitHub] [flink] flinkbot commented on pull request #12675: [FLINK-18319][notice] Lack LICENSE.protobuf in flink-sql-orc

2020-06-16 Thread GitBox
flinkbot commented on pull request #12675: URL: https://github.com/apache/flink/pull/12675#issuecomment-644626744 ## CI report: * d1135557a3a80231df0aeb25951c1a7c6a3ba843 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #12664: [FLINK-18238][checkpoint] Emit CancelCheckpointMarker downstream on checkpointState in sync phase of checkpoint on task side

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12664: URL: https://github.com/apache/flink/pull/12664#issuecomment-644339378 ## CI report: * 3513fe0a856a0c678c9eea0cca246118b1ddc7bc Azure:

[GitHub] [flink] StephanEwen commented on pull request #12676: [FLINK-18322][connector/common][tests] Fix unstable ExecutorNotifierTest#testExceptionInHandler

2020-06-16 Thread GitBox
StephanEwen commented on pull request #12676: URL: https://github.com/apache/flink/pull/12676#issuecomment-644625713 Looks good, +1 This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] flinkbot edited a comment on pull request #12570: [FLINK-17976][doc] Synchronize Chinese native Kubernetes document

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12570: URL: https://github.com/apache/flink/pull/12570#issuecomment-641787412 ## CI report: * 0d8cd82808d704c61b2472c8d98a121c6bc41307 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12313: [FLINK-17005][docs] Translate the CREATE TABLE ... LIKE syntax documentation to Chinese

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12313: URL: https://github.com/apache/flink/pull/12313#issuecomment-633389597 ## CI report: * e7dd7fa0fbbab91117bea70ac0c042e08d0637a8 Azure:

[GitHub] [flink] becketqin merged pull request #12676: [FLINK-18322][connector/common][tests] Fix unstable ExecutorNotifierTest#testExceptionInHandler

2020-06-16 Thread GitBox
becketqin merged pull request #12676: URL: https://github.com/apache/flink/pull/12676 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] tillrohrmann closed pull request #11322: [FLINK-16376][yarn] Use consistent method to get Yarn application dir…

2020-06-16 Thread GitBox
tillrohrmann closed pull request #11322: URL: https://github.com/apache/flink/pull/11322 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to

[GitHub] [flink] flinkbot edited a comment on pull request #12657: [FLINK-18086][tests][e2e][kafka] Migrate SQLClientKafkaITCase to use DDL and new options to create tables

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12657: URL: https://github.com/apache/flink/pull/12657#issuecomment-644140243 ## CI report: * 50108ca39ff114f9c85ae5f2b5cc72eb3dd4357a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12674: [FLINK-18311] Fix StreamingKafkaITCase on Kafka 2.4.1

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12674: URL: https://github.com/apache/flink/pull/12674#issuecomment-644615940 ## CI report: * 58283a6caa5cfff45735b469e3bf57b11311018a Azure:

[jira] [Updated] (FLINK-18315) Insert into partitioned table can fail with values

2020-06-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18315: --- Labels: pull-request-available (was: ) > Insert into partitioned table can fail with

[jira] [Resolved] (FLINK-18322) Fix unstable ExecutorNotifierTest#testExceptionInHandler.

2020-06-16 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved FLINK-18322. -- Resolution: Fixed Merged. master: 8e2af35314384eead43ae2582664404433ac60ab release-1.11: 

[GitHub] [flink] danny0405 opened a new pull request #12677: [FLINK-18315][table-planner-blink] Insert into partitioned table can …

2020-06-16 Thread GitBox
danny0405 opened a new pull request #12677: URL: https://github.com/apache/flink/pull/12677 …fail with values ## What is the purpose of the change Before this patch, `insert into partiton ... values` could not work correctly. ## Brief change log - Fix the

[jira] [Commented] (FLINK-18290) Tests are crashing with exit code 239

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

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

2020-06-16 Thread GitBox
senegalo commented on pull request #12056: URL: https://github.com/apache/flink/pull/12056#issuecomment-644549028 awesome .. will look into the changes and hopefully be done by them next weekend. This is an automated

[GitHub] [flink] flinkbot edited a comment on pull request #12655: [FLINK-18300][sql-client] SQL Client doesn't support ALTER VIEW

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12655: URL: https://github.com/apache/flink/pull/12655#issuecomment-644085772 ## CI report: * e9f9d2e5bd744d8443b78e9e3712bd718efa6b0d Azure:

[jira] [Commented] (FLINK-18211) Dynamic properties setting 'pipeline.jars' will be overwritten

2020-06-16 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136336#comment-17136336 ] Yang Wang commented on FLINK-18211: --- [~kkl0u] Is {{pipeline.jars}} designed to cover this use case?

[jira] [Commented] (FLINK-16795) End to end tests timeout on Azure

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

[jira] [Commented] (FLINK-18236) flink elasticsearch IT test ElasticsearchSinkTestBase.runElasticsearchSink* verify it not right

2020-06-16 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136346#comment-17136346 ] jackylau commented on FLINK-18236: -- Hi [~jark] could you please spend some of time reviewing this issue

[GitHub] [flink] becketqin closed pull request #12510: [FLINK-18039]

2020-06-16 Thread GitBox
becketqin closed pull request #12510: URL: https://github.com/apache/flink/pull/12510 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] becketqin commented on pull request #12510: [FLINK-18039]

2020-06-16 Thread GitBox
becketqin commented on pull request #12510: URL: https://github.com/apache/flink/pull/12510#issuecomment-644554936 Merged to master. 24201cc1b6c46c689abbff8635a01cec7b088983 e01cab2f713802f6fb92f7472a258c07f2c18af7 Cherry-picked to release-1.11

[GitHub] [flink] becketqin closed pull request #12507: [FLINK-18162][connector/common] Serialize the splits in the AddSplitsEvent

2020-06-16 Thread GitBox
becketqin closed pull request #12507: URL: https://github.com/apache/flink/pull/12507 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] becketqin commented on pull request #12507: [FLINK-18162][connector/common] Serialize the splits in the AddSplitsEvent

2020-06-16 Thread GitBox
becketqin commented on pull request #12507: URL: https://github.com/apache/flink/pull/12507#issuecomment-644555205 Merged to master: f883f1190132f9dd6b37f1e5c8ae0e0d25f78333 Cherry-picked to release-1.11: 6cf60fda000d25baddfd7a2c3725eeecba77f886

[GitHub] [flink] leonardBang commented on pull request #12369: [FLINK-17678][Connectors/HBase]Support fink-sql-connector-hbase

2020-06-16 Thread GitBox
leonardBang commented on pull request #12369: URL: https://github.com/apache/flink/pull/12369#issuecomment-644561250 > @wuchong Sorry, due to my personal physical reasons, I don't have enough time to finish this work recently.You can assign others to finish this. I'll be involved in

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

2020-06-16 Thread Hyeonseop Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136362#comment-17136362 ] Hyeonseop Lee edited comment on FLINK-18119 at 6/16/20, 6:48 AM: -

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

2020-06-16 Thread Hyeonseop Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136362#comment-17136362 ] Hyeonseop Lee commented on FLINK-18119: --- [~libenchao] {{RowTimeRange*Unbounded*PrecedingFunction}}

[jira] [Comment Edited] (FLINK-18288) WEB UI failure in Flink1.12

2020-06-16 Thread appleyuchi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136356#comment-17136356 ] appleyuchi edited comment on FLINK-18288 at 6/16/20, 6:49 AM: -- Thanks for

[GitHub] [flink] flinkbot edited a comment on pull request #12642: [FLINK-18282][docs-zh] retranslate the documentation home page

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12642: URL: https://github.com/apache/flink/pull/12642#issuecomment-643624564 ## CI report: * d13e1778d93d1aa4f365057bda967ed708555962 Azure:

[GitHub] [flink] flinkbot commented on pull request #12669: [FLINK-17800][roksdb] Ensure total order seek to avoid user misuse

2020-06-16 Thread GitBox
flinkbot commented on pull request #12669: URL: https://github.com/apache/flink/pull/12669#issuecomment-644576340 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] flinkbot commented on pull request #12670: [FLINK-18290][checkpointing] Fail job on checkpoint future failure instead of System.exit

2020-06-16 Thread GitBox
flinkbot commented on pull request #12670: URL: https://github.com/apache/flink/pull/12670#issuecomment-644578119 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] rkhachatryan opened a new pull request #12670: [FLINK-18290][checkpointing] Fail job on checkpoint future failure instead of System.exit

2020-06-16 Thread GitBox
rkhachatryan opened a new pull request #12670: URL: https://github.com/apache/flink/pull/12670 ## What is the purpose of the change *Replace `System.exit` with job failure `CheckpointCoordinator` and fix related issues:* - Fail job only once - Remove only succeeded

[GitHub] [flink] aljoscha opened a new pull request #12674: [FLINK-18311] Fix StreamingKafkaITCase on Kafka 2.4.1

2020-06-16 Thread GitBox
aljoscha opened a new pull request #12674: URL: https://github.com/apache/flink/pull/12674 ## What is the purpose of the change / Brief change log This was broken because the behaviour of the Kafka/ZooKeeper command line tools on Kafka 2.4.1 is slightly different:

[jira] [Updated] (FLINK-18311) StreamingKafkaITCase stalls indefinitely

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

[GitHub] [flink] rkhachatryan commented on a change in pull request #12575: [FLINK-18094][checkpointing] Unifies the creation of BarrierHandlers and CheckpointedInputGate.

2020-06-16 Thread GitBox
rkhachatryan commented on a change in pull request #12575: URL: https://github.com/apache/flink/pull/12575#discussion_r440653529 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointBarrierAligner.java ## @@ -46,14 +49,8 @@

[jira] [Closed] (FLINK-17976) Test native K8s integration

2020-06-16 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-17976. -- Resolution: Fixed Docs have been updated in master:

[GitHub] [flink] flinkbot commented on pull request #12674: [FLINK-18311] Fix StreamingKafkaITCase on Kafka 2.4.1

2020-06-16 Thread GitBox
flinkbot commented on pull request #12674: URL: https://github.com/apache/flink/pull/12674#issuecomment-644598573 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] rmetzger commented on pull request #12674: [FLINK-18311] Fix StreamingKafkaITCase on Kafka 2.4.1

2020-06-16 Thread GitBox
rmetzger commented on pull request #12674: URL: https://github.com/apache/flink/pull/12674#issuecomment-644598554 Do you have a fast-path CI available for this PR? (which does not run the bash e2e before + runs on your personal CI)

[GitHub] [flink] twalthr commented on pull request #12654: [FLINK-18298][table] Rename TableResult headers of SHOW statements

2020-06-16 Thread GitBox
twalthr commented on pull request #12654: URL: https://github.com/apache/flink/pull/12654#issuecomment-644597857 Sure, will merge this in my next batch. This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] flinkbot edited a comment on pull request #12649: [FLINK-18286] Implement type inference for GET/FLATTEN

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12649: URL: https://github.com/apache/flink/pull/12649#issuecomment-643957887 ## CI report: * c38f0da0bd042779c6c9a096e305cb40e8b1e367 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12656: [FLINK-17666][table-planner-blink] Insert into partitioned table can …

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12656: URL: https://github.com/apache/flink/pull/12656#issuecomment-644099955 ## CI report: * 8cec6fea4e3f8fe1edab5aab8484b8d315feae11 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12668: [FLINK-18291][e2e] Introduce timeout into Streaming File Sink s3 test

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12668: URL: https://github.com/apache/flink/pull/12668#issuecomment-644591653 ## CI report: * 76390cf85f3af4a5e17568323cdb5104dc91f778 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12657: [FLINK-18086][tests][e2e][kafka] Migrate SQLClientKafkaITCase to use DDL and new options to create tables

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12657: URL: https://github.com/apache/flink/pull/12657#issuecomment-644140243 ## CI report: * 14cdb5d641588f9dfa7f8536fe92e3e57abd8e14 Azure:

[jira] [Created] (FLINK-18318) Flink ML

2020-06-16 Thread Dimitris Vogiatzidakis (Jira)
Dimitris Vogiatzidakis created FLINK-18318: -- Summary: Flink ML Key: FLINK-18318 URL: https://issues.apache.org/jira/browse/FLINK-18318 Project: Flink Issue Type: Task

[GitHub] [flink] openinx commented on a change in pull request #12369: [FLINK-17678][Connectors/HBase]Support fink-sql-connector-hbase

2020-06-16 Thread GitBox
openinx commented on a change in pull request #12369: URL: https://github.com/apache/flink/pull/12369#discussion_r440660808 ## File path: flink-connectors/flink-sql-connector-hbase/pom.xml ## @@ -0,0 +1,140 @@ + + +http://maven.apache.org/POM/4.0.0; +

[GitHub] [flink] flinkbot edited a comment on pull request #12670: [FLINK-18290][checkpointing] Fail job on checkpoint future failure instead of System.exit

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12670: URL: https://github.com/apache/flink/pull/12670#issuecomment-644591855 ## CI report: * 5b7a339a0755861a904a119770fc6a26edc59fd8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12669: [FLINK-17800][roksdb] Ensure total order seek to avoid user misuse

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12669: URL: https://github.com/apache/flink/pull/12669#issuecomment-644591765 ## CI report: * 675830149a56096b87e46e3b1276a6e21625274c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12667: [FLINK-18209] Replace slave with worker in docker cluster test scripts

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12667: URL: https://github.com/apache/flink/pull/12667#issuecomment-644591558 ## CI report: * ec7c66712749236ebbb65ad2c16ffd9020373818 Azure:

[GitHub] [flink] flinkbot commented on pull request #12672: [hotfix][typo] fix typos in ProcTimeRangeBoundedPrecedingFunction & ProcTimeBoundedRangeOver

2020-06-16 Thread GitBox
flinkbot commented on pull request #12672: URL: https://github.com/apache/flink/pull/12672#issuecomment-644603982 ## CI report: * 15bd67ad2a3dd57cb96ed947f48901c905c5c2c5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] JingsongLi commented on a change in pull request #12369: [FLINK-17678][Connectors/HBase]Support fink-sql-connector-hbase

2020-06-16 Thread GitBox
JingsongLi commented on a change in pull request #12369: URL: https://github.com/apache/flink/pull/12369#discussion_r440667980 ## File path: flink-connectors/flink-sql-connector-hbase/src/main/resources/META-INF/NOTICE ## @@ -0,0 +1,23 @@ +flink-sql-connector-hbase +Copyright

[GitHub] [flink] tillrohrmann commented on a change in pull request #12636: [FLINK-17998][hs] Support Flink history server archive size limitation

2020-06-16 Thread GitBox
tillrohrmann commented on a change in pull request #12636: URL: https://github.com/apache/flink/pull/12636#discussion_r440667418 ## File path: flink-core/src/main/java/org/apache/flink/configuration/HistoryServerOptions.java ## @@ -99,6 +99,11 @@

[GitHub] [flink] flinkbot edited a comment on pull request #12664: [FLINK-18238][checkpoint] Emit CancelCheckpointMarker downstream on checkpointState in sync phase of checkpoint on task side

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12664: URL: https://github.com/apache/flink/pull/12664#issuecomment-644339378 ## CI report: * 3513fe0a856a0c678c9eea0cca246118b1ddc7bc Azure:

[GitHub] [flink] flinkbot commented on pull request #12674: [FLINK-18311] Fix StreamingKafkaITCase on Kafka 2.4.1

2020-06-16 Thread GitBox
flinkbot commented on pull request #12674: URL: https://github.com/apache/flink/pull/12674#issuecomment-644615940 ## CI report: * 58283a6caa5cfff45735b469e3bf57b11311018a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #12672: [hotfix][typo] fix typos in ProcTimeRangeBoundedPrecedingFunction & ProcTimeBoundedRangeOver

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12672: URL: https://github.com/apache/flink/pull/12672#issuecomment-644603982 ## CI report: * 15bd67ad2a3dd57cb96ed947f48901c905c5c2c5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12649: [FLINK-18286] Implement type inference for GET/FLATTEN

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12649: URL: https://github.com/apache/flink/pull/12649#issuecomment-643957887 ## CI report: * c38f0da0bd042779c6c9a096e305cb40e8b1e367 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12673: [FLINK-18242][state-backend-rocksdb] Separate RocksDBOptionsFactory from OptionsFactory

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12673: URL: https://github.com/apache/flink/pull/12673#issuecomment-644604112 ## CI report: * 5b41145108afc366b94e820320cbbf19be9031e8 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/171540258) Bot

[GitHub] [flink] flinkbot edited a comment on pull request #12643: [FLINK-18161][sql-client] Fix configurations from flink-conf.yaml overwrite sql-client's properties

2020-06-16 Thread GitBox
flinkbot edited a comment on pull request #12643: URL: https://github.com/apache/flink/pull/12643#issuecomment-643713303 ## CI report: * c742e48f939cbfb76f6b0bcd2b380060c973ae90 Azure:

[GitHub] [flink] wangyang0918 commented on pull request #12570: [FLINK-17976][doc] Synchronize Chinese native Kubernetes document

2020-06-16 Thread GitBox
wangyang0918 commented on pull request #12570: URL: https://github.com/apache/flink/pull/12570#issuecomment-644620703 cc @klion26 Could you please have a look this change? This is an automated message from the Apache Git

[jira] [Created] (FLINK-18322) Fix unstable ExecutorNotifierTest#testExceptionInHandler.

2020-06-16 Thread Jiangjie Qin (Jira)
Jiangjie Qin created FLINK-18322: Summary: Fix unstable ExecutorNotifierTest#testExceptionInHandler. Key: FLINK-18322 URL: https://issues.apache.org/jira/browse/FLINK-18322 Project: Flink

[jira] [Updated] (FLINK-18322) Fix unstable ExecutorNotifierTest#testExceptionInHandler.

2020-06-16 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-18322: - Priority: Blocker (was: Major) > Fix unstable ExecutorNotifierTest#testExceptionInHandler. >

[jira] [Closed] (FLINK-16376) Using consistent method to get Yarn application directory

2020-06-16 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-16376. - Resolution: Duplicate > Using consistent method to get Yarn application directory >

<    1   2   3   4   5   6   7   8   >