[jira] [Commented] (FLINK-6162) Fix bug in ByteArrayOutputStreamWithPos#setPosition

[ https://issues.apache.org/jira/browse/FLINK-6162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15960315#comment-15960315 ] ASF GitHub Bot commented on FLINK-6162: --- Github user wenlong88 commented on the issue:

[GitHub] flink issue #3595: [FLINK-6162]Fix bug in ByteArrayOutputStreamWithPos#setPo...

Github user wenlong88 commented on the issue: https://github.com/apache/flink/pull/3595 hi, @greghogan , do you have any new comment about the changes? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does

[jira] [Commented] (FLINK-6196) Support dynamic schema in Table Function

[ https://issues.apache.org/jira/browse/FLINK-6196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15960284#comment-15960284 ] ASF GitHub Bot commented on FLINK-6196: --- Github user clarkyzl commented on a diff in the pull

[GitHub] flink pull request #3623: [FLINK-6196] [table] Support dynamic schema in Tab...

Github user clarkyzl commented on a diff in the pull request: https://github.com/apache/flink/pull/3623#discussion_r110317256 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/TableFunction.scala --- @@ -131,8 +129,14 @@ abstract class

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15960223#comment-15960223 ] hongyuhong commented on FLINK-6233: --- Hi [~fhueske], i would deal with the out-of-order records like

[jira] [Closed] (FLINK-4869) Store record pointer after record keys

[ https://issues.apache.org/jira/browse/FLINK-4869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-4869. - Resolution: Later > Store record pointer after record keys > -- > >

[jira] [Commented] (FLINK-5781) Generation HTML from ConfigOption

[ https://issues.apache.org/jira/browse/FLINK-5781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15959777#comment-15959777 ] ASF GitHub Bot commented on FLINK-5781: --- Github user zentol commented on the issue:

[GitHub] flink issue #3495: [FLINK-5781][config] Generation HTML from ConfigOption

Github user zentol commented on the issue: https://github.com/apache/flink/pull/3495 Alright here's what i came up with. We define a single antrun task which does the following: Since all *Options classes reside in the same directory we just take a look in there and filter

[jira] [Commented] (FLINK-5966) Document Running Flink on Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-5966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15959759#comment-15959759 ] Larry Wu commented on FLINK-5966: - This is a very good step towards Flink on Kubernetes. Is the your PR

[jira] [Closed] (FLINK-6261) Add support for TUMBLE, HOP, SESSION to batch SQL

[ https://issues.apache.org/jira/browse/FLINK-6261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6261. Resolution: Implemented Fix Version/s: 1.3.0 Implemented with

[jira] [Commented] (FLINK-6261) Add support for TUMBLE, HOP, SESSION to batch SQL

[ https://issues.apache.org/jira/browse/FLINK-6261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15959734#comment-15959734 ] ASF GitHub Bot commented on FLINK-6261: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #3675: [FLINK-6261] [table] Support TUMBLE, HOP, SESSION ...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3675 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-6261) Add support for TUMBLE, HOP, SESSION to batch SQL

[ https://issues.apache.org/jira/browse/FLINK-6261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15959705#comment-15959705 ] ASF GitHub Bot commented on FLINK-6261: --- Github user fhueske commented on the issue:

[GitHub] flink issue #3675: [FLINK-6261] [table] Support TUMBLE, HOP, SESSION group w...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3675 Thanks, will merge this PR :-) --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and

[jira] [Commented] (FLINK-6261) Add support for TUMBLE, HOP, SESSION to batch SQL

[ https://issues.apache.org/jira/browse/FLINK-6261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15959694#comment-15959694 ] ASF GitHub Bot commented on FLINK-6261: --- Github user haohui commented on the issue:

[GitHub] flink issue #3675: [FLINK-6261] [table] Support TUMBLE, HOP, SESSION group w...

Github user haohui commented on the issue: https://github.com/apache/flink/pull/3675 Yes. I agree with you that `FLOOR` / `CEIL` are quite fragile and it is much clearer to use the `TUMBLING` / `HOP` / `SESSION` constructs. --- If your project is set up for it, you can reply to this

[GitHub] flink issue #3495: [FLINK-5781][config] Generation HTML from ConfigOption

Github user zentol commented on the issue: https://github.com/apache/flink/pull/3495 I'm playing around with this right now. Seems like it works; don't know though if the resulting html is what people expected; since you know, it is pretty bare-bones. :) Anyway, I'm looking

[jira] [Commented] (FLINK-5781) Generation HTML from ConfigOption

[ https://issues.apache.org/jira/browse/FLINK-5781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15959687#comment-15959687 ] ASF GitHub Bot commented on FLINK-5781: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-6261) Add support for TUMBLE, HOP, SESSION to batch SQL

[ https://issues.apache.org/jira/browse/FLINK-6261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15959686#comment-15959686 ] ASF GitHub Bot commented on FLINK-6261: --- Github user fhueske commented on the issue:

[GitHub] flink issue #3675: [FLINK-6261] [table] Support TUMBLE, HOP, SESSION group w...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3675 Thanks for the review @haohui! Just to make sure: You're OK with removing support for windows defined as `GROUP BY CEIL(rowtime() TO HOUR)`? Thanks, Fabian --- If your project is

[jira] [Commented] (FLINK-6261) Add support for TUMBLE, HOP, SESSION to batch SQL

[ https://issues.apache.org/jira/browse/FLINK-6261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15959666#comment-15959666 ] ASF GitHub Bot commented on FLINK-6261: --- Github user haohui commented on the issue:

[GitHub] flink issue #3675: [FLINK-6261] [table] Support TUMBLE, HOP, SESSION group w...

Github user haohui commented on the issue: https://github.com/apache/flink/pull/3675 The PR looks pretty good. Thanks @fhueske for improving the documentation. +1 (non-binding) --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Closed] (FLINK-4644) Deprecate "flink.base.dir.path" from ConfigConstants

[ https://issues.apache.org/jira/browse/FLINK-4644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4644. --- Resolution: Fixed Assignee: Stephan Ewen (was: Maximilian Michels) Fix

[jira] [Closed] (FLINK-720) Forbid catching exceptions only with "e.printStackTrace()" using Checkstyle

[ https://issues.apache.org/jira/browse/FLINK-720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-720. -- Resolution: Won't Fix > Forbid catching exceptions only with "e.printStackTrace()" using

[jira] [Commented] (FLINK-5974) Support Mesos DNS

[ https://issues.apache.org/jira/browse/FLINK-5974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15959444#comment-15959444 ] ASF GitHub Bot commented on FLINK-5974: --- GitHub user vijikarthi opened a pull request:

[GitHub] flink pull request #3692: FLINK-5974 Added configurations to support mesos-d...

GitHub user vijikarthi opened a pull request: https://github.com/apache/flink/pull/3692 FLINK-5974 Added configurations to support mesos-dns hostname resolution This PR addresses FLINK-5974 requirements which takes care of handling dynamic host name resolution for JM and TM

[jira] [Closed] (FLINK-6270) Port several network config parameters to ConfigOption

[ https://issues.apache.org/jira/browse/FLINK-6270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6270. --- Resolution: Fixed Fix Version/s: 1.3.0 1.3: e2a4f47ed8c95c7045f79bf9fe59cab39518710b

[jira] [Closed] (FLINK-6269) var could be a val

[ https://issues.apache.org/jira/browse/FLINK-6269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6269. --- Resolution: Fixed Fix Version/s: 1.3.0 1.3: 2cb60043d8fce4a291fbefeddce6598b442b8f01

[jira] [Assigned] (FLINK-6269) var could be a val

[ https://issues.apache.org/jira/browse/FLINK-6269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-6269: --- Assignee: CanBin Zheng (was: Chesnay Schepler) > var could be a val >

[jira] [Commented] (FLINK-6269) var could be a val

[ https://issues.apache.org/jira/browse/FLINK-6269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15959394#comment-15959394 ] ASF GitHub Bot commented on FLINK-6269: --- Github user asfgit closed the pull request at:

[jira] [Assigned] (FLINK-6269) var could be a val

[ https://issues.apache.org/jira/browse/FLINK-6269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-6269: --- Assignee: Chesnay Schepler > var could be a val > -- > >

[jira] [Commented] (FLINK-6256) Fix documentation of ProcessFunction.

[ https://issues.apache.org/jira/browse/FLINK-6256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15959395#comment-15959395 ] ASF GitHub Bot commented on FLINK-6256: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-6270) Port several network config parameters to ConfigOption

[ https://issues.apache.org/jira/browse/FLINK-6270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15959397#comment-15959397 ] ASF GitHub Bot commented on FLINK-6270: --- Github user asfgit closed the pull request at:

[jira] [Closed] (FLINK-6079) Ineffective null check in FlinkKafkaConsumerBase#open()

[ https://issues.apache.org/jira/browse/FLINK-6079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6079. --- Resolution: Fixed Fix Version/s: 1.3.0 1.3: 8890a8db41c45504aa658a1942f40bb9af7dcf30

[jira] [Commented] (FLINK-6079) Ineffective null check in FlinkKafkaConsumerBase#open()

[ https://issues.apache.org/jira/browse/FLINK-6079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15959396#comment-15959396 ] ASF GitHub Bot commented on FLINK-6079: --- Github user asfgit closed the pull request at:

[jira] [Closed] (FLINK-6256) Fix documentation of ProcessFunction.

[ https://issues.apache.org/jira/browse/FLINK-6256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6256. --- Resolution: Fixed 1.3: a6355edd904c2efe2ee37118132b0add5a2e5588 > Fix documentation of

[GitHub] flink pull request #3685: [FLINK-6079] [kafka] Provide meaningful error mess...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3685 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink pull request #3684: [FLINK-6256] Fix outputTag variable name in Side O...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3684 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink pull request #3682: [FLINK-6269][JobManager]var could be val

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3682 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink pull request #3683: [FLINK-6270] Port several network config parameter...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3683 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink pull request #3691: [FLINK-6195] [build] Move gelly-examples jar from ...

GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/3691 [FLINK-6195] [build] Move gelly-examples jar from opt to examples The opt directory should be reserved for Flink JARs which users may optionally move to lib to be loaded by the runtime.

[jira] [Commented] (FLINK-6195) Move gelly-examples jar from opt to examples

[ https://issues.apache.org/jira/browse/FLINK-6195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15959352#comment-15959352 ] ASF GitHub Bot commented on FLINK-6195: --- GitHub user greghogan opened a pull request:

[GitHub] flink pull request #3690: [FLINK-6173] [build] Move gelly-examples jar from ...

Github user greghogan closed the pull request at: https://github.com/apache/flink/pull/3690 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-6173) flink-table not pack-in com.fasterxml.jackson.* in after #FLINK-5414

[ https://issues.apache.org/jira/browse/FLINK-6173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15959344#comment-15959344 ] ASF GitHub Bot commented on FLINK-6173: --- Github user greghogan closed the pull request at:

[jira] [Commented] (FLINK-6173) flink-table not pack-in com.fasterxml.jackson.* in after #FLINK-5414

[ https://issues.apache.org/jira/browse/FLINK-6173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15959338#comment-15959338 ] ASF GitHub Bot commented on FLINK-6173: --- GitHub user greghogan opened a pull request:

[GitHub] flink pull request #3690: [FLINK-6173] [build] Move gelly-examples jar from ...

GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/3690 [FLINK-6173] [build] Move gelly-examples jar from opt to examples The opt directory should be reserved for Flink JARs which users may optionally move to lib to be loaded by the runtime.

[jira] [Closed] (FLINK-6268) Object reuse for Either type

[ https://issues.apache.org/jira/browse/FLINK-6268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-6268. - Resolution: Implemented Implemented in ae17718fb9262f65b89b4551d2aecaab3ee23d9e > Object reuse for

[GitHub] flink pull request #3680: [FLINK-6268] [core] Object reuse for Either type

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3680 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-6268) Object reuse for Either type

[ https://issues.apache.org/jira/browse/FLINK-6268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15959292#comment-15959292 ] ASF GitHub Bot commented on FLINK-6268: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-5435) Cleanup the rules introduced by FLINK-5144 when calcite releases 1.12

[ https://issues.apache.org/jira/browse/FLINK-5435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15959265#comment-15959265 ] ASF GitHub Bot commented on FLINK-5435: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-6257) Post-pass OVER windows

[ https://issues.apache.org/jira/browse/FLINK-6257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15959266#comment-15959266 ] ASF GitHub Bot commented on FLINK-6257: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #3681: [FLINK-6257][table] Consistent naming of {{Process...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3681 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink pull request #3689: [FLINK-5435] [table] Remove FlinkAggregateJoinTran...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3689 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Closed] (FLINK-5435) Cleanup the rules introduced by FLINK-5144 when calcite releases 1.12

[ https://issues.apache.org/jira/browse/FLINK-5435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-5435. Resolution: Fixed Fix Version/s: 1.3.0 Fixed by c5173fa26d3d8a32b0b182a37d34a8eeff6e36d0 >

[jira] [Commented] (FLINK-6216) DataStream unbounded groupby aggregate with early firing

[ https://issues.apache.org/jira/browse/FLINK-6216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15959155#comment-15959155 ] ASF GitHub Bot commented on FLINK-6216: --- Github user shaoxuan-wang closed the pull request at:

[GitHub] flink pull request #3646: [FLINK-6216] [table] DataStream unbounded groupby ...

Github user shaoxuan-wang closed the pull request at: https://github.com/apache/flink/pull/3646 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature

[jira] [Resolved] (FLINK-6052) Potential null access in ZooKeeperCompletedCheckpointStore#getLatestCheckpoint()

[ https://issues.apache.org/jira/browse/FLINK-6052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved FLINK-6052. --- Resolution: Won't Fix > Potential null access in > ZooKeeperCompletedCheckpointStore#getLatestCheckpoint() >

[jira] [Updated] (FLINK-6271) NumericBetweenParametersProvider NullPointer

[ https://issues.apache.org/jira/browse/FLINK-6271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier updated FLINK-6271: -- Summary: NumericBetweenParametersProvider NullPointer (was:

[jira] [Commented] (FLINK-5695) Optimize table type systems based on database semantics

[ https://issues.apache.org/jira/browse/FLINK-5695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15959057#comment-15959057 ] Fabian Hueske commented on FLINK-5695: -- Hi [~sunjincheng121], did you come to a conclusion regarding

[jira] [Commented] (FLINK-6275) Unprotected access to resourceManager in YarnFlinkApplicationMasterRunner#runApplicationMaster

[ https://issues.apache.org/jira/browse/FLINK-6275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15959046#comment-15959046 ] Ted Yu commented on FLINK-6275: --- Similarly, access to haServices in shutdown() doesn't have protection

[jira] [Created] (FLINK-6275) Unprotected access to resourceManager in YarnFlinkApplicationMasterRunner#runApplicationMaster

Ted Yu created FLINK-6275: - Summary: Unprotected access to resourceManager in YarnFlinkApplicationMasterRunner#runApplicationMaster Key: FLINK-6275 URL: https://issues.apache.org/jira/browse/FLINK-6275

[jira] [Commented] (FLINK-6257) Post-pass OVER windows

[ https://issues.apache.org/jira/browse/FLINK-6257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15959015#comment-15959015 ] ASF GitHub Bot commented on FLINK-6257: --- Github user fhueske commented on the issue:

[GitHub] flink issue #3681: [FLINK-6257][table] Consistent naming of {{ProcessFunctio...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3681 Merging --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[jira] [Commented] (FLINK-5435) Cleanup the rules introduced by FLINK-5144 when calcite releases 1.12

[ https://issues.apache.org/jira/browse/FLINK-5435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15959014#comment-15959014 ] ASF GitHub Bot commented on FLINK-5435: --- Github user fhueske commented on the issue:

[GitHub] flink issue #3689: [FLINK-5435] [table] Remove FlinkAggregateJoinTransposeRu...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3689 Merging --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[jira] [Commented] (FLINK-5435) Cleanup the rules introduced by FLINK-5144 when calcite releases 1.12

[ https://issues.apache.org/jira/browse/FLINK-5435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15959006#comment-15959006 ] ASF GitHub Bot commented on FLINK-5435: --- Github user fhueske commented on the issue:

[GitHub] flink issue #3689: [FLINK-5435] [table] Remove FlinkAggregateJoinTransposeRu...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3689 Thanks for the PR @KurtYoung. +1 to merge --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this

[jira] [Commented] (FLINK-5435) Cleanup the rules introduced by FLINK-5144 when calcite releases 1.12

[ https://issues.apache.org/jira/browse/FLINK-5435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15958985#comment-15958985 ] ASF GitHub Bot commented on FLINK-5435: --- GitHub user KurtYoung opened a pull request:

[GitHub] flink pull request #3689: [FLINK-5435] [table] Remove FlinkAggregateJoinTran...

GitHub user KurtYoung opened a pull request: https://github.com/apache/flink/pull/3689 [FLINK-5435] [table] Remove FlinkAggregateJoinTransposeRule and Flink… …RelDecorrelator after calcite updated to 1.12 You can merge this pull request into a Git repository by running:

[jira] [Updated] (FLINK-6274) Replace usages of org.codehaus.jackson

[ https://issues.apache.org/jira/browse/FLINK-6274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6274: -- Component/s: Build System > Replace usages of org.codehaus.jackson >

[jira] [Commented] (FLINK-6271) NumericBetweenParametersProvider NullPinter

[ https://issues.apache.org/jira/browse/FLINK-6271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15958953#comment-15958953 ] ASF GitHub Bot commented on FLINK-6271: --- Github user fpompermaier commented on a diff in the pull

[GitHub] flink pull request #3686: [FLINK-6271][jdbc]Fix nullPointer when there's a s...

Github user fpompermaier commented on a diff in the pull request: https://github.com/apache/flink/pull/3686#discussion_r110164047 --- Diff: flink-connectors/flink-jdbc/src/test/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormatTest.java --- @@ -180,6 +180,52 @@ public void

[jira] [Commented] (FLINK-6270) Port several network config parameters to ConfigOption

[ https://issues.apache.org/jira/browse/FLINK-6270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15958927#comment-15958927 ] ASF GitHub Bot commented on FLINK-6270: --- Github user zentol commented on the issue:

[GitHub] flink issue #3683: [FLINK-6270] Port several network config parameters to Co...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/3683 merging. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[jira] [Commented] (FLINK-6271) NumericBetweenParametersProvider NullPinter

[ https://issues.apache.org/jira/browse/FLINK-6271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15958924#comment-15958924 ] ASF GitHub Bot commented on FLINK-6271: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #3686: [FLINK-6271][jdbc]Fix nullPointer when there's a s...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3686#discussion_r110160658 --- Diff: flink-connectors/flink-jdbc/src/test/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormatTest.java --- @@ -180,6 +180,52 @@ public void

[jira] [Commented] (FLINK-6271) NumericBetweenParametersProvider NullPinter

[ https://issues.apache.org/jira/browse/FLINK-6271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15958918#comment-15958918 ] ASF GitHub Bot commented on FLINK-6271: --- Github user fpompermaier commented on a diff in the pull

[GitHub] flink pull request #3686: [FLINK-6271][jdbc]Fix nullPointer when there's a s...

Github user fpompermaier commented on a diff in the pull request: https://github.com/apache/flink/pull/3686#discussion_r110159791 --- Diff: flink-connectors/flink-jdbc/src/test/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormatTest.java --- @@ -180,6 +180,52 @@ public void

[jira] [Commented] (FLINK-6273) Client can't connect to jobmanager whose hostname contains capital letters

[ https://issues.apache.org/jira/browse/FLINK-6273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15958860#comment-15958860 ] ASF GitHub Bot commented on FLINK-6273: --- GitHub user barcahead opened a pull request:

[GitHub] flink pull request #3688: [FLINK-6273] [core] don't convert hostname to lowe...

GitHub user barcahead opened a pull request: https://github.com/apache/flink/pull/3688 [FLINK-6273] [core] don't convert hostname to lower cases to prevent akka connection failure For akka `Address`, the host part is case sensitive, So if we build remote jobmanager url with lower

[jira] [Commented] (FLINK-6079) Ineffective null check in FlinkKafkaConsumerBase#open()

[ https://issues.apache.org/jira/browse/FLINK-6079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15958840#comment-15958840 ] ASF GitHub Bot commented on FLINK-6079: --- Github user zentol commented on the issue:

[GitHub] flink issue #3685: [FLINK-6079] [kafka] Provide meaningful error message if ...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/3685 merging. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[GitHub] flink issue #3684: [FLINK-6256] Fix outputTag variable name in Side Output d...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/3684 merging. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[jira] [Commented] (FLINK-6256) Fix documentation of ProcessFunction.

[ https://issues.apache.org/jira/browse/FLINK-6256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15958839#comment-15958839 ] ASF GitHub Bot commented on FLINK-6256: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-6269) var could be a val

[ https://issues.apache.org/jira/browse/FLINK-6269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15958838#comment-15958838 ] ASF GitHub Bot commented on FLINK-6269: --- Github user zentol commented on the issue:

[GitHub] flink issue #3682: [FLINK-6269][JobManager]var could be val

Github user zentol commented on the issue: https://github.com/apache/flink/pull/3682 merging. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[jira] [Created] (FLINK-6274) Replace usages of org.codehaus.jackson

Chesnay Schepler created FLINK-6274: --- Summary: Replace usages of org.codehaus.jackson Key: FLINK-6274 URL: https://issues.apache.org/jira/browse/FLINK-6274 Project: Flink Issue Type:

[jira] [Updated] (FLINK-6268) Object reuse for Either type

[ https://issues.apache.org/jira/browse/FLINK-6268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-6268: -- Fix Version/s: 1.3.0 > Object reuse for Either type > > >

[jira] [Assigned] (FLINK-6273) Client can't connect to jobmanager whose hostname contains capital letters

[ https://issues.apache.org/jira/browse/FLINK-6273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yelei Feng reassigned FLINK-6273: - Assignee: Yelei Feng > Client can't connect to jobmanager whose hostname contains capital

[jira] [Created] (FLINK-6273) Client can't connect to jobmanager whose hostname contains capital letters

Yelei Feng created FLINK-6273: - Summary: Client can't connect to jobmanager whose hostname contains capital letters Key: FLINK-6273 URL: https://issues.apache.org/jira/browse/FLINK-6273 Project: Flink

[jira] [Created] (FLINK-6272) Rolling file sink saves incomplete lines on failure

Jakub Nowacki created FLINK-6272: Summary: Rolling file sink saves incomplete lines on failure Key: FLINK-6272 URL: https://issues.apache.org/jira/browse/FLINK-6272 Project: Flink Issue

[jira] [Updated] (FLINK-4769) Migrate Metrics configuration options

[ https://issues.apache.org/jira/browse/FLINK-4769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-4769: Affects Version/s: 1.3.0 > Migrate Metrics configuration options >

[jira] [Assigned] (FLINK-4769) Migrate Metrics configuration options

[ https://issues.apache.org/jira/browse/FLINK-4769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-4769: --- Assignee: Chesnay Schepler > Migrate Metrics configuration options >

[jira] [Updated] (FLINK-4769) Migrate Metrics configuration options

[ https://issues.apache.org/jira/browse/FLINK-4769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-4769: Fix Version/s: 1.3.0 > Migrate Metrics configuration options >

[jira] [Commented] (FLINK-4769) Migrate Metrics configuration options

[ https://issues.apache.org/jira/browse/FLINK-4769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15958787#comment-15958787 ] ASF GitHub Bot commented on FLINK-4769: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #3687: [FLINK-4769] Port metric config parameters to Conf...

GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/3687 [FLINK-4769] Port metric config parameters to ConfigOptions This PR ports all metrics-related config parameters to ConfigOptions. You can merge this pull request into a Git repository by running:

[jira] [Commented] (FLINK-6196) Support dynamic schema in Table Function

[ https://issues.apache.org/jira/browse/FLINK-6196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15958785#comment-15958785 ] ASF GitHub Bot commented on FLINK-6196: --- Github user clarkyzl commented on a diff in the pull

[GitHub] flink pull request #3623: [FLINK-6196] [table] Support dynamic schema in Tab...

Github user clarkyzl commented on a diff in the pull request: https://github.com/apache/flink/pull/3623#discussion_r110141028 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala --- @@ -358,4 +366,120 @@

[jira] [Assigned] (FLINK-5376) Misleading log statements in UnorderedStreamElementQueue

[ https://issues.apache.org/jira/browse/FLINK-5376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-5376: --- Assignee: Chesnay Schepler > Misleading log statements in

[jira] [Commented] (FLINK-6268) Object reuse for Either type

[ https://issues.apache.org/jira/browse/FLINK-6268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15958745#comment-15958745 ] ASF GitHub Bot commented on FLINK-6268: --- Github user zentol commented on the issue:

  1   2   >