[GitHub] [flink] flinkbot edited a comment on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #17847: URL: https://github.com/apache/flink/pull/17847#issuecomment-974817636 -- 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 specific comment. To

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 -- 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 specific comment. To

[GitHub] [flink] flinkbot edited a comment on pull request #17133: [FLINK-24138] Architectural tests

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #17133: URL: https://github.com/apache/flink/pull/17133#issuecomment-912323602 -- 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 specific comment. To

[GitHub] [flink] godfreyhe commented on a change in pull request #17670: [FLINK-24760][docs] Update user document for batch window tvf

2021-11-21 Thread GitBox
godfreyhe commented on a change in pull request #17670: URL: https://github.com/apache/flink/pull/17670#discussion_r753819169 ## File path: docs/content.zh/docs/dev/table/sql/queries/window-tvf.md ## @@ -48,15 +48,21 @@ See more how to apply further computations based on windo

[GitHub] [flink] MonsterChenzhuo commented on pull request #17508: [FLINK-24351][docs] Translate "JSON Function" pages into Chinese

2021-11-21 Thread GitBox
MonsterChenzhuo commented on pull request #17508: URL: https://github.com/apache/flink/pull/17508#issuecomment-974634974 @RocMarshal Please go to #17789 to review -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the U

[GitHub] [flink] flinkbot edited a comment on pull request #17554: [FLINK-24624][Kubernetes]Kill cluster when starting kubernetes session or application cluster failed

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #17554: URL: https://github.com/apache/flink/pull/17554#issuecomment-950550174 -- 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 specific comment. To

[GitHub] [flink] godfreyhe commented on a change in pull request #17666: [FLINK-21327][table-planner-blink] Support window TVF in batch mode

2021-11-21 Thread GitBox
godfreyhe commented on a change in pull request #17666: URL: https://github.com/apache/flink/pull/17666#discussion_r753816404 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/batch/sql/WindowTableFunctionTest.scala ## @@ -0,0 +1,

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #24: [Flink 24557] - Add knn algorithm to flink-ml

2021-11-21 Thread GitBox
zhipeng93 commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r753647934 ## File path: flink-ml-api/src/main/java/org/apache/flink/ml/linalg/DenseVector.java ## @@ -42,14 +45,26 @@ public double get(int i) { return val

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * 96a6ba2a83ca22091099ef36201afcbd8e71

[jira] [Updated] (FLINK-24974) blink just translate select ... from a,b to nested loop join.

2021-11-21 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24974: - Environment: was:1 > blink just translate select ... from a,b to nested loop join

[jira] [Updated] (FLINK-24974) blink just translate select ... from a,b to nested loop join.

2021-11-21 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24974: - Fix Version/s: (was: 1.7.3) > blink just translate select ... from a,b to nested loo

[jira] [Updated] (FLINK-24974) blink just translate select ... from a,b to nested loop join.

2021-11-21 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24974: - Component/s: (was: Tests) > blink just translate select ... from a,b to nested loop

[jira] [Reopened] (FLINK-24974) blink just translate select ... from a,b to nested loop join.

2021-11-21 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-24974: -- > blink just translate select ... from a,b to nested loop join. >

[jira] [Updated] (FLINK-24974) blink just translate select ... from a,b to nested loop join.

2021-11-21 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24974: - Affects Version/s: (was: 1.13.3) (was: shaded-14.0) > bli

[jira] [Closed] (FLINK-24974) blink just translate select ... from a,b to nested loop join.

2021-11-21 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-24974. Resolution: Invalid > blink just translate select ... from a,b to nested loop join. >

[jira] [Commented] (FLINK-24939) Support 'SHOW CREATE CATALOG' syntax

2021-11-21 Thread Shen Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447121#comment-17447121 ] Shen Zhu commented on FLINK-24939: -- Hey Yubin([~liyubin117] ), Thanks for your feedbac

[GitHub] [flink] MartijnVisser commented on pull request #17808: [FLINK-24928][flink-runtime-web] Typing improvements for Flink UI

2021-11-21 Thread GitBox
MartijnVisser commented on pull request #17808: URL: https://github.com/apache/flink/pull/17808#issuecomment-974894700 @AHeise Please merge :) -- 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

[jira] [Updated] (FLINK-14616) Clarify the ordering guarantees in the "The Broadcast State Pattern"

2021-11-21 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-14616: --- Labels: auto-deprioritized-major auto-deprioritized-minor broadcast (was: auto-deprioriti

[jira] [Updated] (FLINK-14615) Add Flink Web UI capabilities for savepoint

2021-11-21 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-14615: --- Labels: auto-deprioritized-major auto-deprioritized-minor usability (was: auto-deprioriti

[jira] [Updated] (FLINK-14565) Shutdown SystemResourcesCounter on (JM|TM)MetricGroup closed

2021-11-21 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-14565: --- Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available (was: au

[jira] [Updated] (FLINK-16682) Make batch size configurable for orc reader

2021-11-21 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16682: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Fli

[jira] [Updated] (FLINK-14514) Improve interface of FunctionContext#getJobParameter

2021-11-21 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-14514: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-14508) google protobuf is not shaded

2021-11-21 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-14508: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-16452) Insert into static partition doesn't support order by or limit

2021-11-21 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16452: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Fli

[jira] [Updated] (FLINK-14438) Fix RowTypeInfo.equals()

2021-11-21 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-14438: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-14523) Flink Stops Consuming from Kafka after Leader Election

2021-11-21 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-14523: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-10408) Cannot use window information in Table functions

2021-11-21 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10408: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Fli

[jira] [Updated] (FLINK-14412) Rename ML Pipeline to MLPipeline

2021-11-21 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-14412: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-10280) json that contains an object can not be parsed

2021-11-21 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10280: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Fli

[jira] [Updated] (FLINK-10409) Collection data sink does not propagate exceptions

2021-11-21 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10409: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Fli

[jira] [Updated] (FLINK-14550) Can't use proctime attribute when register datastream to flink table which uses some fields in the nested fields

2021-11-21 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-14550: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-10382) Writer has already been opened while using AvroKeyValueSinkWriter and BucketingSink

2021-11-21 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10382: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Fli

[jira] [Updated] (FLINK-16468) BlobClient rapid retrieval retries on failure opens too many sockets

2021-11-21 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16468: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Fli

[jira] [Updated] (FLINK-10305) flink-conf.yaml grows continuously

2021-11-21 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10305: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Fli

[jira] [Updated] (FLINK-10442) Make declined savepoints visible in WebUI

2021-11-21 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10442: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Fli

[jira] [Updated] (FLINK-16506) SqlCreateTable can not get the original text when there exists non-ascii char in the column definition

2021-11-21 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16506: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Fli

[jira] [Updated] (FLINK-10346) MemoryStateBackend does not clean up checkpoint directory

2021-11-21 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10346: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Fli

[jira] [Updated] (FLINK-14458) Assert implementation classes of catalog objects

2021-11-21 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-14458: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Commented] (FLINK-24803) Fix cast BINARY/VARBINARY to STRING

2021-11-21 Thread Shen Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447166#comment-17447166 ] Shen Zhu commented on FLINK-24803: -- Hi Timo([~twalthr] ), Marios([~matriv]), I'm intere

[jira] [Closed] (FLINK-24969) pyflink/table/tests/test_pandas_udf.py hangs on azure

2021-11-21 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-24969. --- Resolution: Duplicate It seems that it should be caused by the same reason as FLINK-24764. I'm closing this

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #24: [Flink 24557] - Add knn algorithm to flink-ml

2021-11-21 Thread GitBox
yunfengzhou-hub commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r753894135 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/KnnModel.java ## @@ -0,0 +1,343 @@ +package org.apache.flink.ml.clas

[GitHub] [flink] wangyang0918 commented on a change in pull request #17554: [FLINK-24624][Kubernetes]Kill cluster when starting kubernetes session or application cluster failed

2021-11-21 Thread GitBox
wangyang0918 commented on a change in pull request #17554: URL: https://github.com/apache/flink/pull/17554#discussion_r753895825 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesClusterDescriptor.java ## @@ -256,39 +247,50 @@ private String ge

[GitHub] [flink] flinkbot edited a comment on pull request #17736: [FLINK-24694][docs-zh] Translate "Checkpointing under backpressure" page into Chinese

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #17736: URL: https://github.com/apache/flink/pull/17736#issuecomment-964148175 ## CI report: * 8171263c979b3bb12394d08700361b3632f74191 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17736: [FLINK-24694][docs-zh] Translate "Checkpointing under backpressure" page into Chinese

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #17736: URL: https://github.com/apache/flink/pull/17736#issuecomment-964148175 ## CI report: * 8171263c979b3bb12394d08700361b3632f74191 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] maosuhan commented on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-21 Thread GitBox
maosuhan commented on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-975009706 @flinkbot run azure -- 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 specific

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * 96a6ba2a83ca22091099ef36201afcbd8e71

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * 96a6ba2a83ca22091099ef36201afcbd8e71

[jira] [Closed] (FLINK-16937) ParquetTableSource should generate correct isFilterPushedDown

2021-11-21 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-16937. Resolution: Won't Fix ParquetTableSource is removed in latest version. > ParquetTableSource shoul

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #24: [Flink 24557] - Add knn algorithm to flink-ml

2021-11-21 Thread GitBox
yunfengzhou-hub commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r753896511 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/KnnParams.java ## @@ -0,0 +1,32 @@ +package org.apache.flink.ml.clas

[jira] [Commented] (FLINK-24758) filesystem sink: partition.time-extractor.kind support "yyyyMMdd"

2021-11-21 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447175#comment-17447175 ] Jingsong Lee commented on FLINK-24758: -- CC: [~jark]  > filesystem sink: partition.

[jira] [Commented] (FLINK-24953) Optime hive parallelism inference

2021-11-21 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447174#comment-17447174 ] Jingsong Lee commented on FLINK-24953: -- cc: [~jark]  > Optime hive parallelism inf

[jira] [Commented] (FLINK-24961) When the DDL statement is different from the actual schema in the database, ArrayIndexOutOfBoundsException will be reported

2021-11-21 Thread Fangliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447177#comment-17447177 ] Fangliang Liu commented on FLINK-24961: --- Hi  [~jark] [~lzljs3620320], Take a look,

[GitHub] [flink] Myasuka commented on pull request #17833: [FLINK-24785][runtime] Relocate RocksDB's log under flink log directory by default

2021-11-21 Thread GitBox
Myasuka commented on pull request #17833: URL: https://github.com/apache/flink/pull/17833#issuecomment-975029611 @SteNicholas Why not follow Flink's [code contribution process](https://flink.apache.org/contributing/contribute-code.html#code-contribution-process) to make the assignment in J

[jira] [Updated] (FLINK-24947) Flink on k8s support HostNetWork model

2021-11-21 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-24947: -- Priority: Major (was: Minor) > Flink on k8s support HostNetWork model > -

[jira] [Updated] (FLINK-24947) Flink on k8s support HostNetWork model

2021-11-21 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-24947: -- Fix Version/s: 1.15.0 > Flink on k8s support HostNetWork model > -

[jira] [Commented] (FLINK-24947) Flink on k8s support HostNetWork model

2021-11-21 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447179#comment-17447179 ] Yang Wang commented on FLINK-24947: --- Thanks for your detailed comments. I am curious

[jira] [Created] (FLINK-24975) Add hooks and extension points to FlinkSQL

2021-11-21 Thread junbiao chen (Jira)
junbiao chen created FLINK-24975: Summary: Add hooks and extension points to FlinkSQL Key: FLINK-24975 URL: https://issues.apache.org/jira/browse/FLINK-24975 Project: Flink Issue Type: New Fe

[jira] [Updated] (FLINK-24975) Add hooks and extension points to FlinkSQL

2021-11-21 Thread junbiao chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] junbiao chen updated FLINK-24975: - Component/s: Table SQL / Planner > Add hooks and extension points to FlinkSQL >

[jira] [Commented] (FLINK-24967) Make the IO pattern configureable in state benchmarks

2021-11-21 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447186#comment-17447186 ] Yun Tang commented on FLINK-24967: -- I think introducing various size of state related o

[GitHub] [flink] flinkbot edited a comment on pull request #17736: [FLINK-24694][docs-zh] Translate "Checkpointing under backpressure" page into Chinese

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #17736: URL: https://github.com/apache/flink/pull/17736#issuecomment-964148175 ## CI report: * 24962d92cd64eb08c3c404fcb9aff1b54be54eab Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-24926) Key group is not in KeyGroupRange when joining two streams with table API

2021-11-21 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447187#comment-17447187 ] Yun Tang commented on FLINK-24926: -- [~liuhb86] Can you repeat this error every time? I

[GitHub] [flink] Myasuka closed pull request #17846: [FLINK-24918][Runtime/State Backends]Support to specify the data dir …

2021-11-21 Thread GitBox
Myasuka closed pull request #17846: URL: https://github.com/apache/flink/pull/17846 -- 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 specific comment. To unsubscribe, e-mail: issues-unsubsc

[jira] [Commented] (FLINK-24918) Support to specify the data dir for state benchmark

2021-11-21 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447188#comment-17447188 ] Yun Tang commented on FLINK-24918: -- Merged in flink-master: 726eead617bb3392df6a6ef1681

[jira] [Commented] (FLINK-24975) Add hooks and extension points to FlinkSQL

2021-11-21 Thread Wenlong Lyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447194#comment-17447194 ] Wenlong Lyu commented on FLINK-24975: - hi, [~dahaishuantuoba], it is an interesting

[jira] [Commented] (FLINK-24949) KafkaITCase.testBigRecordJob fails on azure

2021-11-21 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447195#comment-17447195 ] Jiangjie Qin commented on FLINK-24949: -- [~gaoyunhaii] not sure if this is the same

[GitHub] [flink] dailai commented on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

2021-11-21 Thread GitBox
dailai commented on pull request #17847: URL: https://github.com/apache/flink/pull/17847#issuecomment-975096035 不支持upsert么 -- 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 specific comment.

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #28: [Flink-24556] Add Estimator and Transformer for logistic regression

2021-11-21 Thread GitBox
yunfengzhou-hub commented on a change in pull request #28: URL: https://github.com/apache/flink-ml/pull/28#discussion_r753930171 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/HasL2.java ## @@ -0,0 +1,42 @@ +/* + * Licensed to the Apache Software Fou

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #28: [Flink-24556] Add Estimator and Transformer for logistic regression

2021-11-21 Thread GitBox
yunfengzhou-hub commented on a change in pull request #28: URL: https://github.com/apache/flink-ml/pull/28#discussion_r753928296 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/HasBatchSize.java ## @@ -0,0 +1,43 @@ +/* + * Licensed to the Apache Softw

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #24: [Flink 24557] - Add knn algorithm to flink-ml

2021-11-21 Thread GitBox
yunfengzhou-hub commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r753905182 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/EuclideanDistance.java ## @@ -0,0 +1,272 @@ +package org.apache.flin

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #24: [Flink 24557] - Add knn algorithm to flink-ml

2021-11-21 Thread GitBox
yunfengzhou-hub commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r753910367 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/KnnModel.java ## @@ -0,0 +1,594 @@ +package org.apache.flink.ml.clas

[GitHub] [flink] gaurav726 commented on a change in pull request #17754: [FLINK-24861][connector][jdbc] Fix false cache lookup for empty data

2021-11-21 Thread GitBox
gaurav726 commented on a change in pull request #17754: URL: https://github.com/apache/flink/pull/17754#discussion_r753941893 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcRowDataLookupFunction.java ## @@ -146,10 +1

[GitHub] [flink] gaurav726 commented on a change in pull request #17754: [FLINK-24861][connector][jdbc] Fix false cache lookup for empty data

2021-11-21 Thread GitBox
gaurav726 commented on a change in pull request #17754: URL: https://github.com/apache/flink/pull/17754#discussion_r753941893 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcRowDataLookupFunction.java ## @@ -146,10 +1

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * 96a6ba2a83ca22091099ef36201afcbd8e71

[GitHub] [flink] JasonLeeCoding commented on pull request #17690: [FLINK-24490][docs] The sample code is wrong in Apache Kafka Connector page

2021-11-21 Thread GitBox
JasonLeeCoding commented on pull request #17690: URL: https://github.com/apache/flink/pull/17690#issuecomment-975149201 @flinkbot run azure -- 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 sp

[GitHub] [flink] flinkbot edited a comment on pull request #17690: [FLINK-24490][docs] The sample code is wrong in Apache Kafka Connector page

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #17690: URL: https://github.com/apache/flink/pull/17690#issuecomment-961660965 ## CI report: * adaacc288130da0e5ab487b1c669a3a730095eb5 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17690: [FLINK-24490][docs] The sample code is wrong in Apache Kafka Connector page

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #17690: URL: https://github.com/apache/flink/pull/17690#issuecomment-961660965 ## CI report: * adaacc288130da0e5ab487b1c669a3a730095eb5 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-24975) Add hooks and extension points to FlinkSQL

2021-11-21 Thread junbiao chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447203#comment-17447203 ] junbiao chen commented on FLINK-24975: -- [~wenlong.lwl] I have developed some optimi

[jira] [Comment Edited] (FLINK-24975) Add hooks and extension points to FlinkSQL

2021-11-21 Thread junbiao chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447203#comment-17447203 ] junbiao chen edited comment on FLINK-24975 at 11/22/21, 6:06 AM: -

[GitHub] [flink] flinkbot edited a comment on pull request #17690: [FLINK-24490][docs] The sample code is wrong in Apache Kafka Connector page

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #17690: URL: https://github.com/apache/flink/pull/17690#issuecomment-961660965 ## CI report: * adaacc288130da0e5ab487b1c669a3a730095eb5 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #28: [Flink-24556] Add Estimator and Transformer for logistic regression

2021-11-21 Thread GitBox
zhipeng93 commented on a change in pull request #28: URL: https://github.com/apache/flink-ml/pull/28#discussion_r753980720 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linear/LogisticRegressionModel.java ## @@ -0,0 +1,220 @@ +/* + * Licensed to t

[jira] [Comment Edited] (FLINK-24002) Support count window with the window TVF

2021-11-21 Thread Yuepeng Pan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17440889#comment-17440889 ] Yuepeng Pan edited comment on FLINK-24002 at 11/22/21, 6:36 AM: --

[GitHub] [flink] flinkbot edited a comment on pull request #17805: [FLINK-24708][planner] Fix wrong results of the IN operator

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #17805: URL: https://github.com/apache/flink/pull/17805#issuecomment-969943622 ## CI report: * 067f050f59f186f274c40bc349d74aadd34a23bd Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17805: [FLINK-24708][planner] Fix wrong results of the IN operator

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #17805: URL: https://github.com/apache/flink/pull/17805#issuecomment-969943622 ## CI report: * 067f050f59f186f274c40bc349d74aadd34a23bd Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink-ml] zhipeng93 commented on pull request #28: [Flink-24556] Add Estimator and Transformer for logistic regression

2021-11-21 Thread GitBox
zhipeng93 commented on pull request #28: URL: https://github.com/apache/flink-ml/pull/28#issuecomment-975178654 Hi @yunfengzhou-hub, thanks for the review. This PR is updated according to your comments. -- This is an automated message from the Apache Git Service. To respond to the messag

[GitHub] [flink-ml] zhipeng93 edited a comment on pull request #28: [Flink-24556] Add Estimator and Transformer for logistic regression

2021-11-21 Thread GitBox
zhipeng93 edited a comment on pull request #28: URL: https://github.com/apache/flink-ml/pull/28#issuecomment-975178654 -- 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 specific comment. To un

[GitHub] [flink] Airblader commented on a change in pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

2021-11-21 Thread GitBox
Airblader commented on a change in pull request #17847: URL: https://github.com/apache/flink/pull/17847#discussion_r753988501 ## File path: flink-connectors/flink-connector-mongodb/src/main/java/org/apache/flink/mongodb/table/MongodbDynamicTableSourceSinkFactory.java ## @@ -0,

[GitHub] [flink] Airblader commented on a change in pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

2021-11-21 Thread GitBox
Airblader commented on a change in pull request #17847: URL: https://github.com/apache/flink/pull/17847#discussion_r753989519 ## File path: flink-connectors/flink-connector-mongodb/src/main/java/org/apache/flink/mongodb/table/MongodbDynamicTableSourceSinkFactory.java ## @@ -0,

[GitHub] [flink] JingsongLi commented on a change in pull request #17699: [FLINK-20370][table] Fix wrong results when sink primary key is not the same with query result's changelog upsert key

2021-11-21 Thread GitBox
JingsongLi commented on a change in pull request #17699: URL: https://github.com/apache/flink/pull/17699#discussion_r753992140 ## File path: docs/layouts/shortcodes/generated/execution_config_configuration.html ## @@ -58,6 +58,12 @@ Enum The NOT NULL c

[GitHub] [flink] flinkbot edited a comment on pull request #17822: Release 1.14 kafka3.0 bug

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #17822: URL: https://github.com/apache/flink/pull/17822#issuecomment-971696959 ## CI report: * d3df986a75e34e1ed475b2e1236b7770698e7bd1 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Closed] (FLINK-24608) Sinks built with the unified sink framework do not receive timestamps when used in Table API

2021-11-21 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-24608. Fix Version/s: 1.15.0 1.14.1 Release Note: This adds an additional operator

[GitHub] [flink] flinkbot edited a comment on pull request #17822: Release 1.14 kafka3.0 bug

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #17822: URL: https://github.com/apache/flink/pull/17822#issuecomment-971696959 ## CI report: * d3df986a75e34e1ed475b2e1236b7770698e7bd1 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] JingsongLi commented on a change in pull request #17699: [FLINK-20370][table] Fix wrong results when sink primary key is not the same with query result's changelog upsert key

2021-11-21 Thread GitBox
JingsongLi commented on a change in pull request #17699: URL: https://github.com/apache/flink/pull/17699#discussion_r753993288 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/program/FlinkChangelogModeInferenceProgram.scala ###

[GitHub] [flink] twalthr closed pull request #17800: [FLINK-24781] Add to string casting rules

2021-11-21 Thread GitBox
twalthr closed pull request #17800: URL: https://github.com/apache/flink/pull/17800 -- 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 specific comment. To unsubscribe, e-mail: issues-unsubsc

[jira] [Closed] (FLINK-24781) Port from string casting logic to CastRule

2021-11-21 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-24781. Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master: commit 9f7eef293f723800945a9759c5

[GitHub] [flink] SteNicholas commented on pull request #17833: [FLINK-24785][runtime] Relocate RocksDB's log under flink log directory by default

2021-11-21 Thread GitBox
SteNicholas commented on pull request #17833: URL: https://github.com/apache/flink/pull/17833#issuecomment-975197030 > @SteNicholas Why not follow Flink's [code contribution process](https://flink.apache.org/contributing/contribute-code.html#code-contribution-process) to make the assignmen

[jira] [Updated] (FLINK-24947) Flink on k8s support HostNetWork model

2021-11-21 Thread liuzhuo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liuzhuo updated FLINK-24947: Attachment: (was: image-2021-11-22-15-23-17-881.png) > Flink on k8s support HostNetWork model > --

[jira] [Updated] (FLINK-24947) Flink on k8s support HostNetWork model

2021-11-21 Thread liuzhuo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liuzhuo updated FLINK-24947: Attachment: image-2021-11-22-15-23-17-881.png > Flink on k8s support HostNetWork model > -

[jira] [Commented] (FLINK-24947) Flink on k8s support HostNetWork model

2021-11-21 Thread liuzhuo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447227#comment-17447227 ] liuzhuo commented on FLINK-24947: - It seems feasible to create the Service on the client

[GitHub] [flink] zuston edited a comment on pull request #17837: [FLINK-24963] Remove the tail separator when outputting yarn queue names

2021-11-21 Thread GitBox
zuston edited a comment on pull request #17837: URL: https://github.com/apache/flink/pull/17837#issuecomment-973923338 @tillrohrmann @becketqin Could you help review it? Thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] fsk119 closed pull request #14444: [FLINK-20091][avro] add ignore-parse-error for avro formats

2021-11-21 Thread GitBox
fsk119 closed pull request #1: URL: https://github.com/apache/flink/pull/1 -- 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 specific comment. To unsubscribe, e-mail: issues-unsubscr

<    1   2   3   4   >