[GitHub] [flink] flinkbot edited a comment on pull request #14602: [FLINK-20345][table-planner-blink] Adds an Expand node only if there are multiple distinct aggregate functions in an Aggregate when e

2021-01-10 Thread GitBox
flinkbot edited a comment on pull request #14602: URL: https://github.com/apache/flink/pull/14602#issuecomment-757429107 ## CI report: * a71f6e566fc51fbaf1fcd9a426b7e27b4e1f6c42 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14584: [FLINK-20850][runtime] Removing usage of CoLocationConstraints

2021-01-10 Thread GitBox
flinkbot edited a comment on pull request #14584: URL: https://github.com/apache/flink/pull/14584#issuecomment-756612102 ## CI report: * bbabee468dc4cea40929884682260ca046e63b48 Azure:

[jira] [Commented] (FLINK-20919) After the flink batch job is completed, the yarn application cannot be completed.

2021-01-10 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17262459#comment-17262459 ] Yang Wang commented on FLINK-20919: --- Normally, Flink resourcemanager will deregister the application

[GitHub] [flink] wangyang0918 commented on a change in pull request #14597: [FLINK-20905][k8s] Format the description of 'kubernetes.container.image' option

2021-01-10 Thread GitBox
wangyang0918 commented on a change in pull request #14597: URL: https://github.com/apache/flink/pull/14597#discussion_r554848805 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/configuration/KubernetesConfigOptions.java ## @@ -195,9 +196,16 @@

[GitHub] [flink] flinkbot edited a comment on pull request #14584: [FLINK-20850][runtime] Removing usage of CoLocationConstraints

2021-01-10 Thread GitBox
flinkbot edited a comment on pull request #14584: URL: https://github.com/apache/flink/pull/14584#issuecomment-756612102 ## CI report: * bbabee468dc4cea40929884682260ca046e63b48 Azure:

[GitHub] [flink] XComp commented on pull request #14584: [FLINK-20850][runtime] Removing usage of CoLocationConstraints

2021-01-10 Thread GitBox
XComp commented on pull request #14584: URL: https://github.com/apache/flink/pull/14584#issuecomment-757673753 The refactoring is ready to be reviewed. Please also have a look at the docs changes that were necessary due to the refactoring. @zhuzhurk It would be helpful for you to have a

[GitHub] [flink] flinkbot edited a comment on pull request #14604: [FLINK-20861][format/json] Provide an option for serializing DECIMALs in JSON as plain number instead of scientific notation

2021-01-10 Thread GitBox
flinkbot edited a comment on pull request #14604: URL: https://github.com/apache/flink/pull/14604#issuecomment-757521857 ## CI report: * 6f16ecba1741139347662f1a892cca2885b603c9 Azure:

[GitHub] [flink] leonardBang commented on a change in pull request #14536: [FLINK-20812][Connector][Hbase] hbase in sql mode,can use 'properties.*' add Configuration parameter.

2021-01-10 Thread GitBox
leonardBang commented on a change in pull request #14536: URL: https://github.com/apache/flink/pull/14536#discussion_r554797775 ## File path: flink-connectors/flink-connector-hbase-base/src/main/java/org/apache/flink/connector/hbase/source/AbstractHBaseDynamicTableSource.java

[jira] [Created] (FLINK-20922) row() function cannot accpet . as arguments

2021-01-10 Thread Kevin Ma (Jira)
Kevin Ma created FLINK-20922: - Summary: row() function cannot accpet . as arguments Key: FLINK-20922 URL: https://issues.apache.org/jira/browse/FLINK-20922 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #14516: [FLINK-20783][table-planner-blink] Separate implementation of ExecNode and PhysicalNode in batch join

2021-01-10 Thread GitBox
flinkbot edited a comment on pull request #14516: URL: https://github.com/apache/flink/pull/14516#issuecomment-752024061 ## CI report: * 61ab76b08a6b4603d6f9dd554bddd742a8d6fde9 UNKNOWN * 7422b497591e2888b6ec9cc4136d5dffa46b550d Azure:

[jira] [Created] (FLINK-20921) Support SqlTimeTypeInfo in Python DataStream

2021-01-10 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-20921: Summary: Support SqlTimeTypeInfo in Python DataStream Key: FLINK-20921 URL: https://issues.apache.org/jira/browse/FLINK-20921 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-20685) Flink connect incorrect address of yarn's resouceManager scheduler

2021-01-10 Thread Spongebob (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Spongebob closed FLINK-20685. - Resolution: Not A Problem > Flink connect incorrect address of yarn's resouceManager scheduler >

[jira] [Assigned] (FLINK-20909) MiniBatch Interval derivation does not work well when enable miniBatch optimization in a job which contains deduplicate on row and unbounded aggregate.

2021-01-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20909: --- Assignee: Andy > MiniBatch Interval derivation does not work well when enable miniBatch >

[jira] [Commented] (FLINK-20911) Support to modify RocksDB LOG level

2021-01-10 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17262419#comment-17262419 ] Yun Tang commented on FLINK-20911: -- I think the log level should be configurable and we could add

[jira] [Commented] (FLINK-20912) Increase Log and Metric: Time consumed by Checkpoint Restore

2021-01-10 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17262410#comment-17262410 ] Yun Tang commented on FLINK-20912: -- The logs have been added in FLINK-19013, and I think the metrics

[jira] [Commented] (FLINK-20909) MiniBatch Interval derivation does not work well when enable miniBatch optimization in a job which contains deduplicate on row and unbounded aggregate.

2021-01-10 Thread Andy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17262409#comment-17262409 ] Andy commented on FLINK-20909: -- [~jark] It's my pleasure, thanks very much. > MiniBatch Interval

[GitHub] [flink] flinkbot edited a comment on pull request #14516: [FLINK-20783][table-planner-blink] Separate implementation of ExecNode and PhysicalNode in batch join

2021-01-10 Thread GitBox
flinkbot edited a comment on pull request #14516: URL: https://github.com/apache/flink/pull/14516#issuecomment-752024061 ## CI report: * 61ab76b08a6b4603d6f9dd554bddd742a8d6fde9 UNKNOWN * 7422b497591e2888b6ec9cc4136d5dffa46b550d Azure:

[jira] [Comment Edited] (FLINK-20832) flink.apache.org site Typography exception

2021-01-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17261333#comment-17261333 ] Jark Wu edited comment on FLINK-20832 at 1/11/21, 6:10 AM: --- Fixed in -

[GitHub] [flink] wuchong merged pull request #14592: [BP-1.11][FLINK-20832][docs] Deliver bootstrap css and js ourselves

2021-01-10 Thread GitBox
wuchong merged pull request #14592: URL: https://github.com/apache/flink/pull/14592 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] wuchong merged pull request #14590: [BP-1.12][FLINK-20832][docs] Deliver bootstrap css and js ourselves

2021-01-10 Thread GitBox
wuchong merged pull request #14590: URL: https://github.com/apache/flink/pull/14590 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] [Comment Edited] (FLINK-20460) Support async lookup for HBase connector

2021-01-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17262403#comment-17262403 ] Jark Wu edited comment on FLINK-20460 at 1/11/21, 6:07 AM: --- I would suggest to

[jira] [Commented] (FLINK-20460) Support async lookup for HBase connector

2021-01-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17262403#comment-17262403 ] Jark Wu commented on FLINK-20460: - I would suggest to support this feature only in HBase 2.2 first.

[jira] [Updated] (FLINK-20909) MiniBatch Interval derivation does not work well when enable miniBatch optimization in a job which contains deduplicate on row and unbounded aggregate.

2021-01-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20909: Affects Version/s: 1.12.0 > MiniBatch Interval derivation does not work well when enable miniBatch >

[jira] [Updated] (FLINK-20909) MiniBatch Interval derivation does not work well when enable miniBatch optimization in a job which contains deduplicate on row and unbounded aggregate.

2021-01-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20909: Priority: Major (was: Minor) > MiniBatch Interval derivation does not work well when enable miniBatch >

[jira] [Updated] (FLINK-20909) MiniBatch Interval derivation does not work well when enable miniBatch optimization in a job which contains deduplicate on row and unbounded aggregate.

2021-01-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20909: Fix Version/s: 1.13.0 > MiniBatch Interval derivation does not work well when enable miniBatch >

[jira] [Commented] (FLINK-20909) MiniBatch Interval derivation does not work well when enable miniBatch optimization in a job which contains deduplicate on row and unbounded aggregate.

2021-01-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17262402#comment-17262402 ] Jark Wu commented on FLINK-20909: - Do you want to fix this [~qingru zhang]? > MiniBatch Interval

[jira] [Assigned] (FLINK-20487) Support to consume retractions for window aggregate operator

2021-01-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20487: --- Assignee: Andy > Support to consume retractions for window aggregate operator >

[jira] [Updated] (FLINK-20917) Support ALTER TABLE ... DROP PARTITION statement

2021-01-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20917: Summary: Support ALTER TABLE ... DROP PARTITION statement (was: can not drop hive partition on flink) >

[GitHub] [flink] flinkbot edited a comment on pull request #14570: [FLINK-20798][k8s] Use namespaced kubernetes client when creating FlinkKubeClient

2021-01-10 Thread GitBox
flinkbot edited a comment on pull request #14570: URL: https://github.com/apache/flink/pull/14570#issuecomment-755308058 ## CI report: * 5702612b137a9e3fd4b78b77af965c8d9a067dda Azure:

[jira] [Updated] (FLINK-20917) can not drop hive partition on flink

2021-01-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20917: Component/s: (was: API / Core) Table SQL / API > can not drop hive partition on

[jira] [Commented] (FLINK-20917) can not drop hive partition on flink

2021-01-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17262398#comment-17262398 ] Jark Wu commented on FLINK-20917: - {{ALTER TABLE ... DROP PARTITION}} is not supported in Flink yet.

[GitHub] [flink] flinkbot edited a comment on pull request #14570: [FLINK-20798][k8s] Use namespaced kubernetes client when creating FlinkKubeClient

2021-01-10 Thread GitBox
flinkbot edited a comment on pull request #14570: URL: https://github.com/apache/flink/pull/14570#issuecomment-755308058 ## CI report: * 5702612b137a9e3fd4b78b77af965c8d9a067dda Azure:

[jira] [Assigned] (FLINK-20905) Format the description of 'kubernetes.container.image' option

2021-01-10 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-20905: Assignee: Ruguo Yu > Format the description of 'kubernetes.container.image' option >

[GitHub] [flink] flinkbot edited a comment on pull request #14597: [FLINK-20905][k8s] Format the description of 'kubernetes.container.image' option

2021-01-10 Thread GitBox
flinkbot edited a comment on pull request #14597: URL: https://github.com/apache/flink/pull/14597#issuecomment-757131762 ## CI report: * b90ef4dcd75edb458da7a051f0d98e046ff4aad5 Azure:

[jira] [Updated] (FLINK-20913) Improve new HiveConf(jobConf, HiveConf.class)

2021-01-10 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingxing Di updated FLINK-20913: Summary: Improve new HiveConf(jobConf, HiveConf.class) (was: Improve new HiveConf) > Improve

[jira] [Updated] (FLINK-20913) Improve new HiveConf

2021-01-10 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingxing Di updated FLINK-20913: Description: When we query hive tables We got an Exception in 

[GitHub] [flink] flinkbot edited a comment on pull request #14597: [FLINK-20905][k8s] Format the description of 'kubernetes.container.image' option

2021-01-10 Thread GitBox
flinkbot edited a comment on pull request #14597: URL: https://github.com/apache/flink/pull/14597#issuecomment-757131762 ## CI report: * b90ef4dcd75edb458da7a051f0d98e046ff4aad5 Azure:

[GitHub] [flink] yuruguo commented on a change in pull request #14597: [FLINK-20905][k8s] Format the description of 'kubernetes.container.image' option

2021-01-10 Thread GitBox
yuruguo commented on a change in pull request #14597: URL: https://github.com/apache/flink/pull/14597#discussion_r554714943 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/configuration/KubernetesConfigOptions.java ## @@ -195,9 +196,16 @@

[jira] [Commented] (FLINK-20714) Hive delegation token is not obtained when using `kinit` to submit Yarn per-job

2021-01-10 Thread jackwangcs (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17262387#comment-17262387 ] jackwangcs commented on FLINK-20714: Hi [~lirui], in the current implementation, I will use a

[jira] [Updated] (FLINK-20913) Improve new HiveConf

2021-01-10 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingxing Di updated FLINK-20913: Summary: Improve new HiveConf (was: Got TTransportException while querying Hive tables) >

[jira] [Commented] (FLINK-20714) Hive delegation token is not obtained when using `kinit` to submit Yarn per-job

2021-01-10 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17262381#comment-17262381 ] Rui Li commented on FLINK-20714: [~trohrmann] I don't think it's documented. And yes that's a good

[jira] [Created] (FLINK-20920) Document how to connect to kerberized HMS

2021-01-10 Thread Rui Li (Jira)
Rui Li created FLINK-20920: -- Summary: Document how to connect to kerberized HMS Key: FLINK-20920 URL: https://issues.apache.org/jira/browse/FLINK-20920 Project: Flink Issue Type: Task

[jira] [Commented] (FLINK-20675) Asynchronous checkpoint failure would not fail the job anymore

2021-01-10 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17262380#comment-17262380 ] Yun Tang commented on FLINK-20675: -- [~pnowojski], thanks for your reminder. I tried to [modify

[jira] [Commented] (FLINK-20496) RocksDB partitioned index filter option

2021-01-10 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17262377#comment-17262377 ] Yun Tang commented on FLINK-20496: -- [~fanrui] Thanks for your feedback. [~liuyufei] Could you please

[GitHub] [flink] flinkbot edited a comment on pull request #14602: [FLINK-20345][table-planner-blink] Adds an Expand node only if there are multiple distinct aggregate functions in an Aggregate when e

2021-01-10 Thread GitBox
flinkbot edited a comment on pull request #14602: URL: https://github.com/apache/flink/pull/14602#issuecomment-757429107 ## CI report: * a46ed68b301d96a6a26c3b7cb8899568ad81a7c8 Azure:

[GitHub] [flink] zhuxiaoshang commented on a change in pull request #14530: [FLINK-20348][kafka] Make "schema-registry.subject" optional for Kafka sink with avro-confluent format

2021-01-10 Thread GitBox
zhuxiaoshang commented on a change in pull request #14530: URL: https://github.com/apache/flink/pull/14530#discussion_r554588155 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaOptionsTest.java ## @@

[jira] [Commented] (FLINK-20919) After the flink batch job is completed, the yarn application cannot be completed.

2021-01-10 Thread Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17262371#comment-17262371 ] Wu commented on FLINK-20919: You can see the unfinished yarn application in the attachment. > After the

[jira] [Commented] (FLINK-20918) Avoid excessive flush of Hadoop output stream

2021-01-10 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17262369#comment-17262369 ] Paul Lin commented on FLINK-20918: -- I'd like to take this issue if we agree. > Avoid excessive flush

[jira] [Comment Edited] (FLINK-20918) Avoid excessive flush of Hadoop output stream

2021-01-10 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17262369#comment-17262369 ] Paul Lin edited comment on FLINK-20918 at 1/11/21, 3:35 AM: I'd like to take

[jira] [Created] (FLINK-20919) After the flink batch job is completed, the yarn application cannot be completed.

2021-01-10 Thread Wu (Jira)
Wu created FLINK-20919: -- Summary: After the flink batch job is completed, the yarn application cannot be completed. Key: FLINK-20919 URL: https://issues.apache.org/jira/browse/FLINK-20919 Project: Flink

[jira] [Created] (FLINK-20918) Avoid excessive flush of Hadoop output stream

2021-01-10 Thread Paul Lin (Jira)
Paul Lin created FLINK-20918: Summary: Avoid excessive flush of Hadoop output stream Key: FLINK-20918 URL: https://issues.apache.org/jira/browse/FLINK-20918 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #14602: [FLINK-20345][table-planner-blink] Adds an Expand node only if there are multiple distinct aggregate functions in an Aggregate when e

2021-01-10 Thread GitBox
flinkbot edited a comment on pull request #14602: URL: https://github.com/apache/flink/pull/14602#issuecomment-757429107 ## CI report: * a46ed68b301d96a6a26c3b7cb8899568ad81a7c8 Azure:

[jira] [Commented] (FLINK-20905) Format the description of 'kubernetes.container.image' option

2021-01-10 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17262368#comment-17262368 ] Yang Wang commented on FLINK-20905: --- [~xintongsong] Could you please assign this ticket to

[GitHub] [flink] wangyang0918 commented on a change in pull request #14597: [FLINK-20905][k8s] Format the description of 'kubernetes.container.image' option

2021-01-10 Thread GitBox
wangyang0918 commented on a change in pull request #14597: URL: https://github.com/apache/flink/pull/14597#discussion_r554672276 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/configuration/KubernetesConfigOptions.java ## @@ -195,9 +196,16 @@

[GitHub] [flink] flinkbot edited a comment on pull request #14604: [FLINK-20861][format/json] Provide an option for serializing DECIMALs in JSON as plain number instead of scientific notation

2021-01-10 Thread GitBox
flinkbot edited a comment on pull request #14604: URL: https://github.com/apache/flink/pull/14604#issuecomment-757521857 ## CI report: * 1cd9b1e046103d9209dfaaa3054dfae600c14de5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14604: [FLINK-20861][format/json] Provide an option for serializing DECIMALs in JSON as plain number instead of scientific notation

2021-01-10 Thread GitBox
flinkbot edited a comment on pull request #14604: URL: https://github.com/apache/flink/pull/14604#issuecomment-757521857 ## CI report: * 1cd9b1e046103d9209dfaaa3054dfae600c14de5 Azure:

[jira] [Created] (FLINK-20917) can not drop hive partition on flink

2021-01-10 Thread Spongebob (Jira)
Spongebob created FLINK-20917: - Summary: can not drop hive partition on flink Key: FLINK-20917 URL: https://issues.apache.org/jira/browse/FLINK-20917 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-20910) Remove restriction on StreamPhysicalGroupWindowAggregate which only supports insert-only input node

2021-01-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20910. --- Resolution: Fixed > Remove restriction on StreamPhysicalGroupWindowAggregate which only supports >

[jira] [Commented] (FLINK-20915) Move docker-entrypoint.sh logic into disrtibution

2021-01-10 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17262353#comment-17262353 ] Yang Wang commented on FLINK-20915: --- I am totally +1 for this efforts. If we could make the

[GitHub] [flink] wuchong commented on pull request #14604: [FLINK-20861][format/json] Provide an option for serializing DECIMALs in JSON as plain number instead of scientific notation

2021-01-10 Thread GitBox
wuchong commented on pull request #14604: URL: https://github.com/apache/flink/pull/14604#issuecomment-757593071 cc @fsk119 This is an automated message from the Apache Git Service. To respond to the message, please log on

[jira] [Commented] (FLINK-20309) UnalignedCheckpointTestBase.execute is failed

2021-01-10 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17262349#comment-17262349 ] Huang Xingbo commented on FLINK-20309: -- another instance

[jira] [Updated] (FLINK-20916) Typo in test for CVE-2020-17519

2021-01-10 Thread nate (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nate updated FLINK-20916: - Description:   The

[GitHub] [flink] flinkbot edited a comment on pull request #14570: [FLINK-20798][k8s] Use namespaced kubernetes client when creating FlinkKubeClient

2021-01-10 Thread GitBox
flinkbot edited a comment on pull request #14570: URL: https://github.com/apache/flink/pull/14570#issuecomment-755308058 ## CI report: * 5702612b137a9e3fd4b78b77af965c8d9a067dda Azure:

[jira] [Created] (FLINK-20916) Typo in test for CVE-2020-17519

2021-01-10 Thread nate (Jira)
nate created FLINK-20916: Summary: Typo in test for CVE-2020-17519 Key: FLINK-20916 URL: https://issues.apache.org/jira/browse/FLINK-20916 Project: Flink Issue Type: Bug Components:

[GitHub] [flink] flinkbot edited a comment on pull request #14570: [FLINK-20798][k8s] Use namespaced kubernetes client when creating FlinkKubeClient

2021-01-10 Thread GitBox
flinkbot edited a comment on pull request #14570: URL: https://github.com/apache/flink/pull/14570#issuecomment-755308058 ## CI report: * 5702612b137a9e3fd4b78b77af965c8d9a067dda Azure:

[GitHub] [flink] wangyang0918 commented on pull request #14570: [FLINK-20798][k8s] Use namespaced kubernetes client when creating FlinkKubeClient

2021-01-10 Thread GitBox
wangyang0918 commented on pull request #14570: URL: https://github.com/apache/flink/pull/14570#issuecomment-757584597 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Updated] (FLINK-20913) Got TTransportException while querying Hive tables

2021-01-10 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingxing Di updated FLINK-20913: Description: When we query hive tables We got an Exception in 

[jira] [Commented] (FLINK-20906) Update copyright year to 2021 for NOTICE files

2021-01-10 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17262331#comment-17262331 ] Xintong Song commented on FLINK-20906: -- I found many NOTICE files in `flink-shaded` still have the

[jira] [Commented] (FLINK-20906) Update copyright year to 2021 for NOTICE files

2021-01-10 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17262328#comment-17262328 ] Xintong Song commented on FLINK-20906: -- [~chesnay], Thanks for the reminder. IIUC, we should do

[jira] [Created] (FLINK-20915) Move docker-entrypoint.sh logic into disrtibution

2021-01-10 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-20915: Summary: Move docker-entrypoint.sh logic into disrtibution Key: FLINK-20915 URL: https://issues.apache.org/jira/browse/FLINK-20915 Project: Flink

[GitHub] [flink] stevenzwu commented on pull request #14595: [FLINK-20871][API/DataStream] Make DataStream#executeAndCollectWithCl…

2021-01-10 Thread GitBox
stevenzwu commented on pull request #14595: URL: https://github.com/apache/flink/pull/14595#issuecomment-757566603 Regarding the whitespace format change, I have run `mvn com.diffplug.spotless:spotless-maven-plugin:apply` to verify

[GitHub] [flink] flinkbot edited a comment on pull request #14604: [FLINK-20861][format/json] Provide an option for serializing DECIMALs in JSON as plain number instead of scientific notation

2021-01-10 Thread GitBox
flinkbot edited a comment on pull request #14604: URL: https://github.com/apache/flink/pull/14604#issuecomment-757521857 ## CI report: * 1cd9b1e046103d9209dfaaa3054dfae600c14de5 Azure:

[jira] [Reopened] (FLINK-20906) Update copyright year to 2021 for NOTICE files

2021-01-10 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-20906: -- Reopening since this should also be done for flink-shaded. > Update copyright year to

[GitHub] [flink] flinkbot edited a comment on pull request #14601: [FLINK-20907][docs] replaces deprecated syntax in Table API doc

2021-01-10 Thread GitBox
flinkbot edited a comment on pull request #14601: URL: https://github.com/apache/flink/pull/14601#issuecomment-757334539 ## CI report: * 946825fe2bbb148d9f8723726454645ba8e54864 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14601: [FLINK-20907][docs] replaces deprecated syntax in Table API doc

2021-01-10 Thread GitBox
flinkbot edited a comment on pull request #14601: URL: https://github.com/apache/flink/pull/14601#issuecomment-757334539 ## CI report: * 2e7774f16f2809e59ad6806d31ff06ddb7b50bba Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14604: [FLINK-20861][format/json] Provide an option for serializing DECIMALs in JSON as plain number instead of scientific notation

2021-01-10 Thread GitBox
flinkbot edited a comment on pull request #14604: URL: https://github.com/apache/flink/pull/14604#issuecomment-757521857 ## CI report: * 1cd9b1e046103d9209dfaaa3054dfae600c14de5 Azure:

[GitHub] [flink] flinkbot commented on pull request #14604: [FLINK-20861][format/json] Provide an option for serializing DECIMALs in JSON as plain number instead of scientific notation

2021-01-10 Thread GitBox
flinkbot commented on pull request #14604: URL: https://github.com/apache/flink/pull/14604#issuecomment-757521857 ## CI report: * 1cd9b1e046103d9209dfaaa3054dfae600c14de5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #14601: [FLINK-20907][docs] replaces deprecated syntax in Table API doc

2021-01-10 Thread GitBox
flinkbot edited a comment on pull request #14601: URL: https://github.com/apache/flink/pull/14601#issuecomment-757334539 ## CI report: * 2e7774f16f2809e59ad6806d31ff06ddb7b50bba Azure:

[GitHub] [flink] flinkbot commented on pull request #14604: [FLINK-20861][format/json] Provide an option for serializing DECIMALs in JSON as plain number instead of scientific notation

2021-01-10 Thread GitBox
flinkbot commented on pull request #14604: URL: https://github.com/apache/flink/pull/14604#issuecomment-757517636 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-20861) Provide an option for serializing DECIMALs in JSON as plain number instead of scientific notation

2021-01-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20861: --- Labels: pull-request-available (was: ) > Provide an option for serializing DECIMALs in

[GitHub] [flink] lmagic233 opened a new pull request #14604: [FLINK-20861][format/json] Provide an option for serializing DECIMALs in JSON as plain number instead of scientific notation

2021-01-10 Thread GitBox
lmagic233 opened a new pull request #14604: URL: https://github.com/apache/flink/pull/14604 ## What is the purpose of the change This PR introduces option `json.encode.decimal-as-plain-number` for JSON formats. ## Brief change log - Add this option in `JsonOptions`.

[GitHub] [flink] flinkbot edited a comment on pull request #14601: [FLINK-20907][docs] replaces deprecated syntax in Table API doc

2021-01-10 Thread GitBox
flinkbot edited a comment on pull request #14601: URL: https://github.com/apache/flink/pull/14601#issuecomment-757334539 ## CI report: * 86f784852d0c844f07dd0bb2a3965a5ec008bf36 Azure:

[GitHub] [flink] sv3ndk commented on a change in pull request #14601: [FLINK-20907][docs] replaces deprecated syntax in Table API doc

2021-01-10 Thread GitBox
sv3ndk commented on a change in pull request #14601: URL: https://github.com/apache/flink/pull/14601#discussion_r554598681 ## File path: docs/dev/table/common.md ## @@ -51,18 +51,18 @@ All Table API and SQL programs for batch and streaming follow the same pattern. // create

[GitHub] [flink] zhuzhurk commented on pull request #14579: [FLINK-20619] Removed InputDependencyConstraint

2021-01-10 Thread GitBox
zhuzhurk commented on pull request #14579: URL: https://github.com/apache/flink/pull/14579#issuecomment-757510492 The commit to deprecate `InputDependencyConstraint` looks good to me. This is an automated message from the

[GitHub] [flink] zhuxiaoshang commented on a change in pull request #14530: [FLINK-20348][kafka] Make "schema-registry.subject" optional for Kafka sink with avro-confluent format

2021-01-10 Thread GitBox
zhuxiaoshang commented on a change in pull request #14530: URL: https://github.com/apache/flink/pull/14530#discussion_r554588155 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaOptionsTest.java ## @@

[GitHub] [flink] zhuxiaoshang commented on a change in pull request #14530: [FLINK-20348][kafka] Make "schema-registry.subject" optional for Kafka sink with avro-confluent format

2021-01-10 Thread GitBox
zhuxiaoshang commented on a change in pull request #14530: URL: https://github.com/apache/flink/pull/14530#discussion_r554588155 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaOptionsTest.java ## @@

[jira] [Commented] (FLINK-20887) Non-deterministic functions return different values even if it is referred with the same column name

2021-01-10 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17262211#comment-17262211 ] Leonard Xu commented on FLINK-20887: Hi, [~TsReaper] I think it's not related to the 

[GitHub] [flink] flinkbot edited a comment on pull request #14584: [FLINK-20850][runtime] Removing usage of CoLocationConstraints

2021-01-10 Thread GitBox
flinkbot edited a comment on pull request #14584: URL: https://github.com/apache/flink/pull/14584#issuecomment-756612102 ## CI report: * bbabee468dc4cea40929884682260ca046e63b48 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14603: [FLINK-20914][core] Format the description of 'security.ssl.internal.session-cache-size' option

2021-01-10 Thread GitBox
flinkbot edited a comment on pull request #14603: URL: https://github.com/apache/flink/pull/14603#issuecomment-757454328 ## CI report: * 09e9047294412bf2d37814d71b0978d3cfeed77b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14584: [FLINK-20850][runtime] Removing usage of CoLocationConstraints

2021-01-10 Thread GitBox
flinkbot edited a comment on pull request #14584: URL: https://github.com/apache/flink/pull/14584#issuecomment-756612102 ## CI report: * 4393af4fff1792cefbc7d9489e137bd4b0387457 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14584: [FLINK-20850][runtime] Removing usage of CoLocationConstraints

2021-01-10 Thread GitBox
flinkbot edited a comment on pull request #14584: URL: https://github.com/apache/flink/pull/14584#issuecomment-756612102 ## CI report: * 4393af4fff1792cefbc7d9489e137bd4b0387457 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14603: [FLINK-20914][core] Format the description of 'security.ssl.internal.session-cache-size' option

2021-01-10 Thread GitBox
flinkbot edited a comment on pull request #14603: URL: https://github.com/apache/flink/pull/14603#issuecomment-757454328 ## CI report: * 09e9047294412bf2d37814d71b0978d3cfeed77b Azure:

[GitHub] [flink] flinkbot commented on pull request #14603: [FLINK-20914][core] Format the description of 'security.ssl.internal.session-cache-size' option

2021-01-10 Thread GitBox
flinkbot commented on pull request #14603: URL: https://github.com/apache/flink/pull/14603#issuecomment-757454328 ## CI report: * 09e9047294412bf2d37814d71b0978d3cfeed77b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #14603: [FLINK-20914][core] Format the description of 'security.ssl.internal.session-cache-size' option

2021-01-10 Thread GitBox
flinkbot commented on pull request #14603: URL: https://github.com/apache/flink/pull/14603#issuecomment-757452101 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] [Commented] (FLINK-20908) ShardConsumerFanOutTest.testStartFromLatestIsTranslatedToTimestamp test failed with AssertionError

2021-01-10 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17262145#comment-17262145 ] Danny Cranmer commented on FLINK-20908: --- This test captures the current timestamp and checks that

[GitHub] [flink] yuruguo opened a new pull request #14603: [FLINK-20914][core] Format the description of 'security.ssl.internal.…

2021-01-10 Thread GitBox
yuruguo opened a new pull request #14603: URL: https://github.com/apache/flink/pull/14603 …session-cache-size' option ## What is the purpose of the change The description of ConfigOption 'security.ssl.internal.session-cache-size' has a URL link, so a reasonable way is

[jira] [Updated] (FLINK-20913) Got TTransportException while querying Hive tables

2021-01-10 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingxing Di updated FLINK-20913: Description: When we query hive tables We will got an Exception in 

[jira] [Updated] (FLINK-20914) Format the description of 'security.ssl.internal.session-cache-size' option

2021-01-10 Thread Ruguo Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruguo Yu updated FLINK-20914: - Description: The description of ConfigOption 'security.ssl.internal.session-cache-size' has a URL

[jira] [Updated] (FLINK-20914) Format the description of 'security.ssl.internal.session-cache-size' option

2021-01-10 Thread Ruguo Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruguo Yu updated FLINK-20914: - Description: The description of ConfigOption 'security.ssl.internal.session-cache-size' has a URL

[jira] [Created] (FLINK-20914) Format the description of 'security.ssl.internal.session-cache-size' option

2021-01-10 Thread Ruguo Yu (Jira)
Ruguo Yu created FLINK-20914: Summary: Format the description of 'security.ssl.internal.session-cache-size' option Key: FLINK-20914 URL: https://issues.apache.org/jira/browse/FLINK-20914 Project: Flink

  1   2   >