[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] tillrohrmann commented on pull request #11322: [FLINK-16376][yarn] Use consistent method to get Yarn application dir…

2020-06-16 Thread GitBox
tillrohrmann commented on pull request #11322: URL: https://github.com/apache/flink/pull/11322#issuecomment-644626939 Has been subsumed by #11991. This is an automated message from the Apache Git Service. To respond to the

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

[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 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 #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] 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

[jira] [Commented] (FLINK-18320) flink-sql-connector-hive modules should merge hive-exec dependencies

2020-06-16 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136444#comment-17136444 ] Robert Metzger commented on FLINK-18320: The maven shade plugin lists the following included

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

2020-06-16 Thread GitBox
flinkbot commented on pull request #12676: URL: https://github.com/apache/flink/pull/12676#issuecomment-644624967 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

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

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

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

2020-06-16 Thread GitBox
becketqin opened a new pull request #12676: URL: https://github.com/apache/flink/pull/12676 ## What is the purpose of the change The ExecutorNotifierTest#testExceptionInHandler() fails intermittently because the UncaughtExceptionHandler may fire after the ExecutorService has shutdown.

[jira] [Commented] (FLINK-17800) RocksDB optimizeForPointLookup results in missing time windows

2020-06-16 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136440#comment-17136440 ] Yu Li commented on FLINK-17800: --- Merged into master via 8ca388ca0225ff22f532c8a65f97d8cfea027c22

[jira] [Assigned] (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 reassigned FLINK-18322: Assignee: Jiangjie Qin > Fix unstable ExecutorNotifierTest#testExceptionInHandler. >

[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] [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. >

[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

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

2020-06-16 Thread GitBox
carp84 commented on pull request #12669: URL: https://github.com/apache/flink/pull/12669#issuecomment-644619177 Thanks for the review @StephanEwen. Changes merged via 8ca388ca and f1250625 This is an automated message

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

2020-06-16 Thread GitBox
dawidwys edited a comment on pull request #12649: URL: https://github.com/apache/flink/pull/12649#issuecomment-644618279 Yes, but does it always. We want that behaviour only when accessing the field. Imagine a user function that accepts `ADDRESS(id INT NOT NULL, city STRING)`.

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

2020-06-16 Thread GitBox
dawidwys edited a comment on pull request #12649: URL: https://github.com/apache/flink/pull/12649#issuecomment-644618279 Yes, but does it always. We want that behaviour only when accessing the field. Imagine a user function that accepts `ADDRESS(id INT NOT NULL, city STRING)`.

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

2020-06-16 Thread GitBox
carp84 closed pull request #12669: URL: https://github.com/apache/flink/pull/12669 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 #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-644618279 Yes, but does it always. We want that behaviour only when accessing the field. Imagine a user function that accepts `ADDRESS(id INT NOT NULL, city STRING)`. ```

[jira] [Created] (FLINK-18321) AbstractCloseableRegistryTest.testClose unstable

2020-06-16 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-18321: -- Summary: AbstractCloseableRegistryTest.testClose unstable Key: FLINK-18321 URL: https://issues.apache.org/jira/browse/FLINK-18321 Project: Flink Issue

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

2020-06-16 Thread Kevin Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136434#comment-17136434 ] Kevin Zhang commented on FLINK-18211: - hi [~kkl0u] IIRC, there is no other good way to ship jars, so

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

2020-06-16 Thread GitBox
zentol commented on pull request #12674: URL: https://github.com/apache/flink/pull/12674#issuecomment-644617809 You also need to update the version in the StreamingKafkaITCase/SQLClientKafkaITCase parameters; those are used for downloading the kafka distribution. (They aren't just for

[jira] [Updated] (FLINK-18319) Lack LICENSE.protobuf in flink-sql-orc

2020-06-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18319: --- Labels: pull-request-available (was: ) > Lack LICENSE.protobuf in flink-sql-orc >

[GitHub] [flink] JingsongLi opened a new pull request #12675: [FLINK-18319][notice] Lack LICENSE.protobuf in flink-sql-orc

2020-06-16 Thread GitBox
JingsongLi opened a new pull request #12675: URL: https://github.com/apache/flink/pull/12675 ## What is the purpose of the change flink-sql-orc bundle protobuf but not include LICENSE.protobuf. This is an

[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] 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 #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 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 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 #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] danny0405 commented on pull request #12649: [FLINK-18286] Implement type inference for GET/FLATTEN

2020-06-16 Thread GitBox
danny0405 commented on pull request #12649: URL: https://github.com/apache/flink/pull/12649#issuecomment-644612644 > This is not possible in Calcite by default. Thats why we have the changes in `org.apache.calcite.rel.type.RelDataTypeFactoryImpl#createTypeWithNullability:326-338`.

[GitHub] [flink] JingsongLi merged pull request #12656: [FLINK-17666][table-planner-blink] Insert into partitioned table can …

2020-06-16 Thread GitBox
JingsongLi merged pull request #12656: URL: https://github.com/apache/flink/pull/12656 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 commented on pull request #11707: [FLINK-15648][k8s] Introduce CPU limit support for JM/TM Container

2020-06-16 Thread GitBox
tillrohrmann commented on pull request #11707: URL: https://github.com/apache/flink/pull/11707#issuecomment-644611861 Shall we close this PR until we have reached agreement on the JIRA ticket @zhengcanbin? This is an

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

2020-06-16 Thread GitBox
aljoscha commented on a change in pull request #12674: URL: https://github.com/apache/flink/pull/12674#discussion_r440669394 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/main/java/org/apache/flink/tests/util/kafka/LocalStandaloneKafkaResource.java

[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_r440668940 ## File path: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServerArchiveFetcher.java ## @@ -295,6 +315,19 @@

[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_r440668761 ## 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] leonardBang commented on a change in pull request #12369: [FLINK-17678][Connectors/HBase]Support fink-sql-connector-hbase

2020-06-16 Thread GitBox
leonardBang commented on a change in pull request #12369: URL: https://github.com/apache/flink/pull/12369#discussion_r440668815 ## File path: flink-connectors/flink-sql-connector-hbase/src/main/resources/hbase-default.xml ## @@ -0,0 +1,1558 @@ + + + + + + + Review comment:

[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] 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] [Created] (FLINK-18320) flink-sql-connector-hive modules should merge hive-exec dependencies

2020-06-16 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-18320: Summary: flink-sql-connector-hive modules should merge hive-exec dependencies Key: FLINK-18320 URL: https://issues.apache.org/jira/browse/FLINK-18320 Project: Flink

[jira] [Resolved] (FLINK-18307) Replace "slave" file name with "workers"

2020-06-16 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-18307. -- Release Note: For Standalone Setups, the file with the worker nodes is no longer called

[jira] [Closed] (FLINK-18307) Replace "slave" file name with "workers"

2020-06-16 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-18307. > Replace "slave" file name with "workers" > > >

[jira] [Created] (FLINK-18319) Lack LICENSE.protobuf in flink-sql-orc

2020-06-16 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-18319: Summary: Lack LICENSE.protobuf in flink-sql-orc Key: FLINK-18319 URL: https://issues.apache.org/jira/browse/FLINK-18319 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #12671: [FLINK-17824][tests] Fix resume_savepoint e2e test by slowing down th…

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

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

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

[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] 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] 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 #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 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 #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] 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 #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] 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] pnowojski edited a comment on pull request #11541: [FLINK-15416][network] add task manager netty client retry mechenism

2020-06-16 Thread GitBox
pnowojski edited a comment on pull request #11541: URL: https://github.com/apache/flink/pull/11541#issuecomment-644162219 Can you explain what was the deadlock scenario? I haven't got time to fully analyse your solution, but `ConcurrentMap<...> clients` is being used in other

[GitHub] [flink] AHeise commented on a change in pull request #12674: [FLINK-18311] Fix StreamingKafkaITCase on Kafka 2.4.1

2020-06-16 Thread GitBox
AHeise commented on a change in pull request #12674: URL: https://github.com/apache/flink/pull/12674#discussion_r440658673 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/main/java/org/apache/flink/tests/util/kafka/LocalStandaloneKafkaResource.java

[GitHub] [flink] zentol commented on a change in pull request #12674: [FLINK-18311] Fix StreamingKafkaITCase on Kafka 2.4.1

2020-06-16 Thread GitBox
zentol commented on a change in pull request #12674: URL: https://github.com/apache/flink/pull/12674#discussion_r440657166 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/main/java/org/apache/flink/tests/util/kafka/LocalStandaloneKafkaResource.java

[GitHub] [flink] wuchong commented on a change in pull request #12657: [FLINK-18086][tests][e2e][kafka] Migrate SQLClientKafkaITCase to use DDL and new options to create tables

2020-06-16 Thread GitBox
wuchong commented on a change in pull request #12657: URL: https://github.com/apache/flink/pull/12657#discussion_r440655924 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/AutoClosableProcess.java ## @@ -167,6

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

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

2020-06-16 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136406#comment-17136406 ] Kostas Kloudas commented on FLINK-18211: [~fly_in_gis] is right that the {{pipeline.jars}} was

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

2020-06-16 Thread GitBox
godfreyhe commented on pull request #12654: URL: https://github.com/apache/flink/pull/12654#issuecomment-644597192 @twalthr could you help merge this pr ? Thanks~ I will update the [doc](https://github.com/apache/flink/pull/12577) based on this.

[GitHub] [flink] rmetzger closed pull request #12558: [FLINK-17976][docs][k8s/docker] Improvements about custom docker images

2020-06-16 Thread GitBox
rmetzger closed pull request #12558: URL: https://github.com/apache/flink/pull/12558 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] wuchong commented on a change in pull request #12657: [FLINK-18086][tests][e2e][kafka] Migrate SQLClientKafkaITCase to use DDL and new options to create tables

2020-06-16 Thread GitBox
wuchong commented on a change in pull request #12657: URL: https://github.com/apache/flink/pull/12657#discussion_r440651382 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/AutoClosableProcess.java ## @@ -167,6

[GitHub] [flink] twalthr commented on a change in pull request #12660: [FLINK-18065][docs] Document FLIP-65 table and scalar functions

2020-06-16 Thread GitBox
twalthr commented on a change in pull request #12660: URL: https://github.com/apache/flink/pull/12660#discussion_r440650838 ## File path: docs/dev/table/functions/udfs.md ## @@ -22,322 +22,768 @@ specific language governing permissions and limitations under the License. -->

[jira] [Commented] (FLINK-17322) Enable latency tracker would corrupt the broadcast state

2020-06-16 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136400#comment-17136400 ] Arvid Heise commented on FLINK-17322: - Merged to master as 7e7b132f611f5a564e8c7b1e6b195692293fa90f

[jira] [Updated] (FLINK-17322) Enable latency tracker would corrupt the broadcast state

2020-06-16 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-17322: Release Note: (was: Merged to master as 7e7b132f611f5a564e8c7b1e6b195692293fa90f Merged to 1.11

[jira] [Closed] (FLINK-17322) Enable latency tracker would corrupt the broadcast state

2020-06-16 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise closed FLINK-17322. --- Release Note: Merged to master as 7e7b132f611f5a564e8c7b1e6b195692293fa90f Merged to 1.11 as

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

2020-06-16 Thread GitBox
flinkbot commented on pull request #12673: URL: https://github.com/apache/flink/pull/12673#issuecomment-644593843 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] zhijiangW merged pull request #12641: [FLINK-17322][network] Fixes BroadcastRecordWriter overwriting memory segments on first finished BufferConsumer.

2020-06-16 Thread GitBox
zhijiangW merged pull request #12641: URL: https://github.com/apache/flink/pull/12641 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-17954) Do not multiplex remote function state into single PersistedTable

2020-06-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17954: --- Labels: pull-request-available (was: ) > Do not multiplex remote function state into

[jira] [Closed] (FLINK-17891) FlinkYarnSessionCli sets wrong execution.target type

2020-06-16 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-17891. -- Fix Version/s: 1.12.0 1.10.2 1.11.0 Resolution:

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

2020-06-16 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136398#comment-17136398 ] Chesnay Schepler commented on FLINK-18311: -- I'd rather revert the version bump. >

<    1   2   3   4   5   6   7   8   >