[jira] [Commented] (FLINK-4280) New Flink-specific option to set starting position of Kafka consumer without respecting external offsets in ZK / Broker

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

[GitHub] flink issue #2509: [FLINK-4280][kafka-connector] Explicit start position con...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2509 Rebased on recent Kafka consumer changes, fixed failing Kafka 0.10 exactly-once tests, and added integration tests (`testStartFromEarliestOffsets`, `testStartFromLatestOffsets`, and

[jira] [Commented] (FLINK-4883) Prevent UDFs implementations through Scala singleton objects

[ https://issues.apache.org/jira/browse/FLINK-4883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15600886#comment-15600886 ] Renkai Ge commented on FLINK-4883: -- I want to work on this issue. > Prevent UDFs implementations through

[jira] [Commented] (FLINK-4469) Add support for user defined table function in Table API & SQL

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

[GitHub] flink issue #2653: [FLINK-4469] [table] Add support for user defined table f...

Github user wuchong commented on the issue: https://github.com/apache/flink/pull/2653 Hi @fhueske @twalthr , do you have any thoughts on this pull request ? --- 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

[jira] [Commented] (FLINK-4879) class KafkaTableSource should be public just like KafkaTableSink

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

[GitHub] flink issue #2678: [FLINK-4879] [Kafka-Connector] class KafkaTableSource sho...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2678 +1 this looks fine to me, no problem with making it public. --- 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

[jira] [Commented] (FLINK-4879) class KafkaTableSource should be public just like KafkaTableSink

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

[GitHub] flink issue #2678: [FLINK-4879] [Kafka-Connector] class KafkaTableSource sho...

Github user wuchong commented on the issue: https://github.com/apache/flink/pull/2678 +1 to merge this. I think it's fine to make `KafkaTableSource` public, just like `FlinkKafkaConsumerBase`. --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Commented] (FLINK-4879) class KafkaTableSource should be public just like KafkaTableSink

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

[GitHub] flink issue #2678: [FLINK-4879] [Kafka-Connector] class KafkaTableSource sho...

Github user hzyuemeng1 commented on the issue: https://github.com/apache/flink/pull/2678 @wuchong can u help me to inform someone to merge this pr,thanks --- 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

[jira] [Commented] (FLINK-4879) class KafkaTableSource should be public just like KafkaTableSink

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

[GitHub] flink issue #2678: [FLINK-4879] [Kafka-Connector] class KafkaTableSource sho...

Github user hzyuemeng1 commented on the issue: https://github.com/apache/flink/pull/2678 @fhueske @rmetzger ,thanks all for review this pr,I am very interesting in Table SQL,can anyone merge this pr? --- If your project is set up for it, you can reply to this email and have your

[jira] [Commented] (FLINK-4800) Introduce the TimestampedFileInputSplit for Continuous File Processing

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

[jira] [Updated] (FLINK-4800) Introduce the TimestampedFileInputSplit for Continuous File Processing

[ https://issues.apache.org/jira/browse/FLINK-4800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-4800: -- Summary: Introduce the TimestampedFileInputSplit for Continuous File Processing (was:

[jira] [Updated] (FLINK-4800) Introduce the TimestampedFileInputSplit in the Continuous File Processing

[ https://issues.apache.org/jira/browse/FLINK-4800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-4800: -- Summary: Introduce the TimestampedFileInputSplit in the Continuous File Processing (was:

[jira] [Updated] (FLINK-4800) Refactor the ContinuousFileMonitoringFunction code and the related tests.

[ https://issues.apache.org/jira/browse/FLINK-4800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-4800: -- Description: Introduce the TimestampedFileInputSplit which extends the class FileInputSplit

[jira] [Commented] (FLINK-4866) Make Trigger.clear() Abstract to Enforce Implementation

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

[GitHub] flink issue #2672: [FLINK-4866] [streaming] Make Trigger.clear() Abstract to...

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2672 Thanks for your work. 👍 I'll be merging this tomorrow. --- 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

[jira] [Commented] (FLINK-4789) Avoid Kafka partition discovery on restore and share consumer instance for discovery and data consumption

[ https://issues.apache.org/jira/browse/FLINK-4789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15599874#comment-15599874 ] Robert Metzger commented on FLINK-4789: --- This comment is wrong and needs to be updated:

[GitHub] flink pull request #2684: Add EvaluateDataSet Operation for LabeledVector - ...

GitHub user tfournier314 opened a pull request: https://github.com/apache/flink/pull/2684 Add EvaluateDataSet Operation for LabeledVector - This closes #4865 Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into

[GitHub] flink pull request #2668: Add EvaluateDataSetOperation for LabeledVector. Th...

Github user tfournier314 closed the pull request at: https://github.com/apache/flink/pull/2668 --- 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

[GitHub] flink issue #2668: Add EvaluateDataSetOperation for LabeledVector. This clos...

Github user tfournier314 commented on the issue: https://github.com/apache/flink/pull/2668 I'm using IntelliJ and I can't remove scala doc and use java doc instead --- 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

[jira] [Closed] (FLINK-4847) Let RpcEndpoint.start/shutDown throw exceptions

[ https://issues.apache.org/jira/browse/FLINK-4847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4847. Resolution: Fixed Fixed via f63f972932e152822603d7a8bb8bf74bf3f05441 > Let

[jira] [Commented] (FLINK-4851) Add FatalErrorHandler and MetricRegistry to ResourceManager

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

[GitHub] flink issue #2651: [FLINK-4847] Let RpcEndpoint.start/shutDown throw excepti...

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2651 Merged --- 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

[jira] [Commented] (FLINK-4847) Let RpcEndpoint.start/shutDown throw exceptions

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

[jira] [Commented] (FLINK-4851) Add FatalErrorHandler and MetricRegistry to ResourceManager

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

[jira] [Commented] (FLINK-4847) Let RpcEndpoint.start/shutDown throw exceptions

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

[jira] [Closed] (FLINK-4851) Add FatalErrorHandler and MetricRegistry to ResourceManager

[ https://issues.apache.org/jira/browse/FLINK-4851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4851. Resolution: Fixed Fixed via f38bf4484df3e022f389357059ca984c5e3f76a6 > Add FatalErrorHandler and

[GitHub] flink pull request #2651: [FLINK-4847] Let RpcEndpoint.start/shutDown throw ...

Github user tillrohrmann closed the pull request at: https://github.com/apache/flink/pull/2651 --- 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

[GitHub] flink pull request #2655: [FLINK-4851] [rm] Introduce FatalErrorHandler and ...

Github user tillrohrmann closed the pull request at: https://github.com/apache/flink/pull/2655 --- 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] [Closed] (FLINK-4853) Clean up JobManager registration at the ResourceManager

[ https://issues.apache.org/jira/browse/FLINK-4853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4853. Resolution: Fixed Fixed via 0e965ae3e00454575a8920fce7b97842fdb9e3a9 > Clean up JobManager

[GitHub] flink issue #2655: [FLINK-4851] [rm] Introduce FatalErrorHandler and MetricR...

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2655 Merged --- 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

[jira] [Commented] (FLINK-4853) Clean up JobManager registration at the ResourceManager

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

[jira] [Commented] (FLINK-4853) Clean up JobManager registration at the ResourceManager

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

[jira] [Commented] (FLINK-4871) Add memory calculation for TaskManagers and forward MetricRegistry

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

[jira] [Closed] (FLINK-4871) Add memory calculation for TaskManagers and forward MetricRegistry

[ https://issues.apache.org/jira/browse/FLINK-4871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4871. Resolution: Fixed Fixed via 80b6c2a015fa12bd73dfe8ccdb3930de0396e623 > Add memory calculation for

[GitHub] flink pull request #2657: [FLINK-4853] [rm] Harden job manager registration ...

Github user tillrohrmann closed the pull request at: https://github.com/apache/flink/pull/2657 --- 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

[GitHub] flink issue #2657: [FLINK-4853] [rm] Harden job manager registration at the ...

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2657 Merged. --- 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

[jira] [Commented] (FLINK-4871) Add memory calculation for TaskManagers and forward MetricRegistry

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

[GitHub] flink pull request #2669: [FLINK-4871] [mini cluster] Add memory calculation...

Github user tillrohrmann closed the pull request at: https://github.com/apache/flink/pull/2669 --- 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

[GitHub] flink issue #2669: [FLINK-4871] [mini cluster] Add memory calculation for Ta...

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2669 Merged --- 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

[jira] [Closed] (FLINK-4882) Cleanup throws exception clause in HighAvailabilityServices

[ https://issues.apache.org/jira/browse/FLINK-4882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4882. Resolution: Fixed Fixed via 0de5689632bd1f8eac6e436959d80d31df9e5ef9 > Cleanup throws exception

[GitHub] flink issue #2679: [FLINK-4882] [flip-6] Remove exceptions from HighAvailabi...

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2679 Merged --- 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

[jira] [Commented] (FLINK-4882) Cleanup throws exception clause in HighAvailabilityServices

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

[jira] [Commented] (FLINK-4882) Cleanup throws exception clause in HighAvailabilityServices

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

[GitHub] flink pull request #2679: [FLINK-4882] [flip-6] Remove exceptions from HighA...

Github user tillrohrmann closed the pull request at: https://github.com/apache/flink/pull/2679 --- 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] [Commented] (FLINK-3035) Redis as State Backend

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

[GitHub] flink issue #1617: [FLINK-3035] Redis as State Backend

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/1617 @fhueske I'm in favour of closing both, yes. --- 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