[jira] [Commented] (FLINK-10455) Potential Kafka producer leak in case of failures

[ https://issues.apache.org/jira/browse/FLINK-10455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688061#comment-16688061 ] ASF GitHub Bot commented on FLINK-10455: azagrebin opened a new pull request #7107:

[GitHub] tillrohrmann commented on a change in pull request #7094: [FLINK-10877] Cleanup flink-connector-kafka pom file

tillrohrmann commented on a change in pull request #7094: [FLINK-10877] Cleanup flink-connector-kafka pom file URL: https://github.com/apache/flink/pull/7094#discussion_r233846378 ## File path: flink-connectors/flink-connector-kafka/pom.xml ## @@ -140,28 +140,6 @@ under

[jira] [Updated] (FLINK-10764) Add S3 entropy injection end-to-end/IT test

[ https://issues.apache.org/jira/browse/FLINK-10764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-10764: - Fix Version/s: (was: 1.6.3) 1.8.0 > Add S3 entropy injection end-to-end/IT test

[jira] [Updated] (FLINK-10764) Add S3 entropy injection end-to-end/IT test

[ https://issues.apache.org/jira/browse/FLINK-10764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-10764: - Release Note: (was: Fixed via 1.7: 4597daf881f24547f3866db7a9a20a606065115b 1.8:

[jira] [Closed] (FLINK-10764) Add S3 entropy injection end-to-end/IT test

[ https://issues.apache.org/jira/browse/FLINK-10764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-10764. Resolution: Fixed Fixed via 1.7: 4597daf881f24547f3866db7a9a20a606065115b 1.8:

[jira] [Commented] (FLINK-10891) Upgrade Kafka client version to 2.0.1

[ https://issues.apache.org/jira/browse/FLINK-10891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688113#comment-16688113 ] ASF GitHub Bot commented on FLINK-10891: yanghua commented on issue #7101: [FLINK-10891] Upgrade

[GitHub] yanghua commented on issue #7101: [FLINK-10891] Upgrade Kafka client version to 2.0.1

yanghua commented on issue #7101: [FLINK-10891] Upgrade Kafka client version to 2.0.1 URL: https://github.com/apache/flink/pull/7101#issuecomment-439051029 @pnowojski upgraded version of Kafka in file `flink-end-to-end-tests/flink-sql-client-test/pom.xml`

[GitHub] jgrier commented on a change in pull request #7099: [FLINK-10887] [jobmaster] Add source watermark tracking to the JobMaster

jgrier commented on a change in pull request #7099: [FLINK-10887] [jobmaster] Add source watermark tracking to the JobMaster URL: https://github.com/apache/flink/pull/7099#discussion_r233857870 ## File path:

[jira] [Commented] (FLINK-10887) Add source watermark tracking to the JobMaster

[ https://issues.apache.org/jira/browse/FLINK-10887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688127#comment-16688127 ] ASF GitHub Bot commented on FLINK-10887: jgrier commented on a change in pull request #7099:

[jira] [Commented] (FLINK-10820) Simplify the RebalancePartitioner implementation

[ https://issues.apache.org/jira/browse/FLINK-10820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688145#comment-16688145 ] ASF GitHub Bot commented on FLINK-10820: zhijiangW commented on a change in pull request #7051:

[GitHub] jgrier commented on a change in pull request #7099: [FLINK-10887] [jobmaster] Add source watermark tracking to the JobMaster

jgrier commented on a change in pull request #7099: [FLINK-10887] [jobmaster] Add source watermark tracking to the JobMaster URL: https://github.com/apache/flink/pull/7099#discussion_r233862737 ## File path:

[GitHub] yanghua commented on issue #7101: [FLINK-10891] Upgrade Kafka client version to 2.0.1

yanghua commented on issue #7101: [FLINK-10891] Upgrade Kafka client version to 2.0.1 URL: https://github.com/apache/flink/pull/7101#issuecomment-439086693 @pnowojski OK, thank you for reminding me. Actually, I did it a long time ago, but later I found that failure was too frequent. And

[jira] [Commented] (FLINK-10891) Upgrade Kafka client version to 2.0.1

[ https://issues.apache.org/jira/browse/FLINK-10891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688247#comment-16688247 ] ASF GitHub Bot commented on FLINK-10891: yanghua commented on issue #7101: [FLINK-10891] Upgrade

[jira] [Commented] (FLINK-10662) Refactor the ChannelSelector interface for single selected channel

[ https://issues.apache.org/jira/browse/FLINK-10662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688257#comment-16688257 ] Nico Kruber commented on FLINK-10662: - If we never call {{BroadcastPartitioner#selectChannels()}},

[jira] [Created] (FLINK-10902) Jobmanager in HA setup communicates the ip address instead of hostnames

Jeroen Steggink created FLINK-10902: --- Summary: Jobmanager in HA setup communicates the ip address instead of hostnames Key: FLINK-10902 URL: https://issues.apache.org/jira/browse/FLINK-10902

[jira] [Updated] (FLINK-10895) TypeSerializerSnapshotMigrationITCase.testSavepoint test failed on travis

[ https://issues.apache.org/jira/browse/FLINK-10895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-10895: - Description: Failed with: {code:java} testSavepoint[Migrate Savepoint / Backend:

[jira] [Closed] (FLINK-10901) Jobmanager REST ip binds to ip address instead of hostname

[ https://issues.apache.org/jira/browse/FLINK-10901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeroen Steggink closed FLINK-10901. --- Resolution: Duplicate > Jobmanager REST ip binds to ip address instead of hostname >

[GitHub] alpinegizmo commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause

alpinegizmo commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause URL: https://github.com/apache/flink/pull/7070#discussion_r233913599 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -0,0 +1,843 @@ +--- +title:

[GitHub] azagrebin opened a new pull request #7108: [FLINK-10455][Kafka Tx] Close transactional producers in case of failure and termination

azagrebin opened a new pull request #7108: [FLINK-10455][Kafka Tx] Close transactional producers in case of failure and termination URL: https://github.com/apache/flink/pull/7108 1.6 back port of #6989 cc @pnowojski

[GitHub] tillrohrmann commented on a change in pull request #7094: [FLINK-10877] Cleanup flink-connector-kafka pom file

tillrohrmann commented on a change in pull request #7094: [FLINK-10877] Cleanup flink-connector-kafka pom file URL: https://github.com/apache/flink/pull/7094#discussion_r233861403 ## File path: flink-connectors/flink-connector-kafka/pom.xml ## @@ -140,28 +140,6 @@ under

[jira] [Commented] (FLINK-10856) Harden resume from externalized checkpoint E2E test

[ https://issues.apache.org/jira/browse/FLINK-10856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688181#comment-16688181 ] ASF GitHub Bot commented on FLINK-10856: tillrohrmann opened a new pull request #7111:

[jira] [Created] (FLINK-10901) Jobmanager REST ip binds to ip address instead of hostname

Jeroen Steggink created FLINK-10901: --- Summary: Jobmanager REST ip binds to ip address instead of hostname Key: FLINK-10901 URL: https://issues.apache.org/jira/browse/FLINK-10901 Project: Flink

[jira] [Commented] (FLINK-7155) Add Influxdb metrics reporter

[ https://issues.apache.org/jira/browse/FLINK-7155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688041#comment-16688041 ] ASF GitHub Bot commented on FLINK-7155: --- zentol commented on a change in pull request #6976:

[jira] [Commented] (FLINK-10871) ExecutionEnvironment & TableEnvironment should be singleton

[ https://issues.apache.org/jira/browse/FLINK-10871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688120#comment-16688120 ] Hequn Cheng commented on FLINK-10871: - [~fhueske] Hi, thanks for your reply. You are right. I think

[jira] [Commented] (FLINK-10891) Upgrade Kafka client version to 2.0.1

[ https://issues.apache.org/jira/browse/FLINK-10891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688112#comment-16688112 ] ASF GitHub Bot commented on FLINK-10891: yanghua commented on issue #7101: [FLINK-10891] Upgrade

[jira] [Commented] (FLINK-10877) Remove duplicate dependency entries in kafka connector pom

[ https://issues.apache.org/jira/browse/FLINK-10877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688138#comment-16688138 ] ASF GitHub Bot commented on FLINK-10877: tillrohrmann commented on a change in pull request

[jira] [Commented] (FLINK-10900) Mark Kafka 2.0 connector as beta feature

[ https://issues.apache.org/jira/browse/FLINK-10900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688156#comment-16688156 ] ASF GitHub Bot commented on FLINK-10900: pnowojski commented on issue #7109:

[jira] [Updated] (FLINK-10900) Mark Kafka 2.0 connector as beta feature

[ https://issues.apache.org/jira/browse/FLINK-10900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10900: -- Fix Version/s: 1.7.0 > Mark Kafka 2.0 connector as beta feature >

[jira] [Updated] (FLINK-10748) Jobmanager in HA setup, redirects (307) don't work when behind a load balancer

[ https://issues.apache.org/jira/browse/FLINK-10748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeroen Steggink updated FLINK-10748: Description: In a HA Jobmanager setup, connecting to a follower results in a redirect

[jira] [Commented] (FLINK-10603) Reduce kafka test duration

[ https://issues.apache.org/jira/browse/FLINK-10603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688260#comment-16688260 ] vinoyang commented on FLINK-10603: -- [~pnowojski]  Considering that Kafka 0.8 is too far away from the

[GitHub] tillrohrmann opened a new pull request #7117: [BP-1.6][FLINK-10883] Failing batch jobs with NoResourceAvailableException when slot request times out

tillrohrmann opened a new pull request #7117: [BP-1.6][FLINK-10883] Failing batch jobs with NoResourceAvailableException when slot request times out URL: https://github.com/apache/flink/pull/7117 Backport of #7115 to `release-1.6`.

[jira] [Commented] (FLINK-7155) Add Influxdb metrics reporter

[ https://issues.apache.org/jira/browse/FLINK-7155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688042#comment-16688042 ] ASF GitHub Bot commented on FLINK-7155: --- zentol commented on a change in pull request #6976:

[jira] [Commented] (FLINK-10873) Remove tableEnv in DataSetConversions#toTable and DataStreamConversions#toTable

[ https://issues.apache.org/jira/browse/FLINK-10873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688099#comment-16688099 ] Jeff Zhang commented on FLINK-10873: Thanks [~fhueske] for the comment, I am a little confused in

[GitHub] pnowojski opened a new pull request #7109: [FLINK-10900][kafka][docs] Mark universal Kafka connector as beta

pnowojski opened a new pull request #7109: [FLINK-10900][kafka][docs] Mark universal Kafka connector as beta URL: https://github.com/apache/flink/pull/7109 Because of frequent deadlocks and other failures in tests the connector is marked as beta. Those errors are probably only test issues

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688178#comment-16688178 ] ASF GitHub Bot commented on FLINK-10625: twalthr commented on issue #7070: [FLINK-10625]

[GitHub] tillrohrmann opened a new pull request #7113: [BP-1.6][FLINK-10856] Find latest completed checkpoint for resume from externalized checkpoint e2e test

tillrohrmann opened a new pull request #7113: [BP-1.6][FLINK-10856] Find latest completed checkpoint for resume from externalized checkpoint e2e test URL: https://github.com/apache/flink/pull/7113 Backport of #7111 to `release-1.6`.

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688355#comment-16688355 ] ASF GitHub Bot commented on FLINK-10625: alpinegizmo commented on a change in pull request

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688367#comment-16688367 ] ASF GitHub Bot commented on FLINK-10625: alpinegizmo commented on a change in pull request

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688350#comment-16688350 ] ASF GitHub Bot commented on FLINK-10625: alpinegizmo commented on a change in pull request

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688359#comment-16688359 ] ASF GitHub Bot commented on FLINK-10625: alpinegizmo commented on a change in pull request

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688363#comment-16688363 ] ASF GitHub Bot commented on FLINK-10625: alpinegizmo commented on a change in pull request

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688352#comment-16688352 ] ASF GitHub Bot commented on FLINK-10625: alpinegizmo commented on a change in pull request

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688346#comment-16688346 ] ASF GitHub Bot commented on FLINK-10625: alpinegizmo commented on a change in pull request

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688343#comment-16688343 ] ASF GitHub Bot commented on FLINK-10625: alpinegizmo commented on a change in pull request

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688349#comment-16688349 ] ASF GitHub Bot commented on FLINK-10625: alpinegizmo commented on a change in pull request

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688362#comment-16688362 ] ASF GitHub Bot commented on FLINK-10625: alpinegizmo commented on a change in pull request

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688357#comment-16688357 ] ASF GitHub Bot commented on FLINK-10625: alpinegizmo commented on a change in pull request

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688365#comment-16688365 ] ASF GitHub Bot commented on FLINK-10625: alpinegizmo commented on a change in pull request

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688347#comment-16688347 ] ASF GitHub Bot commented on FLINK-10625: alpinegizmo commented on a change in pull request

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688364#comment-16688364 ] ASF GitHub Bot commented on FLINK-10625: alpinegizmo commented on a change in pull request

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688345#comment-16688345 ] ASF GitHub Bot commented on FLINK-10625: alpinegizmo commented on a change in pull request

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688370#comment-16688370 ] ASF GitHub Bot commented on FLINK-10625: alpinegizmo commented on a change in pull request

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688351#comment-16688351 ] ASF GitHub Bot commented on FLINK-10625: alpinegizmo commented on a change in pull request

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688354#comment-16688354 ] ASF GitHub Bot commented on FLINK-10625: alpinegizmo commented on a change in pull request

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688366#comment-16688366 ] ASF GitHub Bot commented on FLINK-10625: alpinegizmo commented on a change in pull request

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688369#comment-16688369 ] ASF GitHub Bot commented on FLINK-10625: alpinegizmo commented on a change in pull request

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688368#comment-16688368 ] ASF GitHub Bot commented on FLINK-10625: alpinegizmo commented on a change in pull request

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688342#comment-16688342 ] ASF GitHub Bot commented on FLINK-10625: alpinegizmo commented on a change in pull request

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688358#comment-16688358 ] ASF GitHub Bot commented on FLINK-10625: alpinegizmo commented on a change in pull request

[GitHub] zentol commented on a change in pull request #6976: [FLINK-7155][metrics] Add new metrics reporter to InfluxDB

zentol commented on a change in pull request #6976: [FLINK-7155][metrics] Add new metrics reporter to InfluxDB URL: https://github.com/apache/flink/pull/6976#discussion_r233838430 ## File path:

[jira] [Updated] (FLINK-10144) Unused import in TaskManagerMessages.scala

[ https://issues.apache.org/jira/browse/FLINK-10144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-10144: - Summary: Unused import in TaskManagerMessages.scala (was: No unused import "import

[jira] [Commented] (FLINK-10144) No unused import "import akka.actor.ActorRef" in class "org.apache.flink.runtime.messages.TaskManagerMessages"

[ https://issues.apache.org/jira/browse/FLINK-10144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688046#comment-16688046 ] ASF GitHub Bot commented on FLINK-10144: zentol closed pull request #6554: [FLINK-10144]delete

[GitHub] SuXingLee opened a new pull request #7106: [hotfix] [docs] fix error about per-job YARN cluster

SuXingLee opened a new pull request #7106: [hotfix] [docs] fix error about per-job YARN cluster URL: https://github.com/apache/flink/pull/7106 ## What is the purpose of the change fix the doc's error about per-job YARN cluster run command. in fact，without the parameter of `-d`

[jira] [Closed] (FLINK-10833) FlinkKafkaProducerITCase.testFlinkKafkaProducerFailTransactionCoordinatorBeforeNotify failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-10833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-10833. - Resolution: Duplicate Fix Version/s: (was: 1.7.0) >

[jira] [Commented] (FLINK-10873) Remove tableEnv in DataSetConversions#toTable and DataStreamConversions#toTable

[ https://issues.apache.org/jira/browse/FLINK-10873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688115#comment-16688115 ] Hequn Cheng commented on FLINK-10873: - [~fhueske] Hi, thanks a lot for your reply. Yes, it is not

[GitHub] zhijiangW commented on a change in pull request #7051: [FLINK-10820][network] Simplify the RebalancePartitioner implementation

zhijiangW commented on a change in pull request #7051: [FLINK-10820][network] Simplify the RebalancePartitioner implementation URL: https://github.com/apache/flink/pull/7051#discussion_r233862113 ## File path:

[jira] [Commented] (FLINK-3967) Provide RethinkDB Sink for Flink

[ https://issues.apache.org/jira/browse/FLINK-3967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688168#comment-16688168 ] ASF GitHub Bot commented on FLINK-3967: --- zentol closed pull request #2031: FLINK-3967 - Flink Sink

[GitHub] twalthr commented on issue #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause

twalthr commented on issue #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause URL: https://github.com/apache/flink/pull/7070#issuecomment-439070596 Thanks for the update @dawidwys. I did a full pass through the document again and corrected a lot of minor things and some bugs. I

[jira] [Commented] (FLINK-10856) Harden resume from externalized checkpoint E2E test

[ https://issues.apache.org/jira/browse/FLINK-10856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688197#comment-16688197 ] ASF GitHub Bot commented on FLINK-10856: tillrohrmann opened a new pull request #7114:

[GitHub] tillrohrmann opened a new pull request #7114: [FLINK-10856] Find latest completed checkpoint for resume from externalized checkpoint e2e test

tillrohrmann opened a new pull request #7114: [FLINK-10856] Find latest completed checkpoint for resume from externalized checkpoint e2e test URL: https://github.com/apache/flink/pull/7114 Backport of #7111 to `release-1.5`.

[GitHub] tillrohrmann opened a new pull request #7112: [BP-1.7][FLINK-10856] Find latest completed checkpoint for resume from externalized checkpoint e2e test

tillrohrmann opened a new pull request #7112: [BP-1.7][FLINK-10856] Find latest completed checkpoint for resume from externalized checkpoint e2e test URL: https://github.com/apache/flink/pull/7112 Backport of #7111 to `release-1.7`.

[GitHub] tillrohrmann opened a new pull request #7116: [BP-1.7][FLINK-10883] Failing batch jobs with NoResourceAvailableException when slot request times out

tillrohrmann opened a new pull request #7116: [BP-1.7][FLINK-10883] Failing batch jobs with NoResourceAvailableException when slot request times out URL: https://github.com/apache/flink/pull/7116 Backport of #7115 to `release-1.7`.

[jira] [Commented] (FLINK-10883) Submitting a jobs without enough slots times out due to a unspecified timeout

[ https://issues.apache.org/jira/browse/FLINK-10883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688312#comment-16688312 ] ASF GitHub Bot commented on FLINK-10883: tillrohrmann opened a new pull request #7115:

[jira] [Updated] (FLINK-10883) Submitting a jobs without enough slots times out due to a unspecified timeout

[ https://issues.apache.org/jira/browse/FLINK-10883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10883: --- Labels: pull-request-available (was: ) > Submitting a jobs without enough slots times out

[jira] [Commented] (FLINK-10877) Remove duplicate dependency entries in kafka connector pom

[ https://issues.apache.org/jira/browse/FLINK-10877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688080#comment-16688080 ] ASF GitHub Bot commented on FLINK-10877: tillrohrmann commented on a change in pull request

[GitHub] tillrohrmann closed pull request #7104: [FLINK-10899] Remove explicit version tag from flink-metrics-availability-test and flink-metrics-reporter-prometheus-test

tillrohrmann closed pull request #7104: [FLINK-10899] Remove explicit version tag from flink-metrics-availability-test and flink-metrics-reporter-prometheus-test URL: https://github.com/apache/flink/pull/7104 This is a PR merged from a forked repository. As GitHub hides the original

[jira] [Commented] (FLINK-10887) Add source watermark tracking to the JobMaster

[ https://issues.apache.org/jira/browse/FLINK-10887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688147#comment-16688147 ] ASF GitHub Bot commented on FLINK-10887: jgrier commented on a change in pull request #7099:

[jira] [Commented] (FLINK-6756) Provide RichAsyncFunction to Scala API suite

[ https://issues.apache.org/jira/browse/FLINK-6756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688148#comment-16688148 ] Dawid Wysakowicz commented on FLINK-6756: - HI [~aphilippot] just wanted to ask if you are still

[GitHub] zentol closed pull request #2031: FLINK-3967 - Flink Sink for Rethink Db

zentol closed pull request #2031: FLINK-3967 - Flink Sink for Rethink Db URL: https://github.com/apache/flink/pull/2031 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this is a foreign pull

[jira] [Updated] (FLINK-3967) Provide RethinkDB Sink for Flink

[ https://issues.apache.org/jira/browse/FLINK-3967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-3967: -- Labels: features pull-request-available (was: features) > Provide RethinkDB Sink for Flink >

[jira] [Updated] (FLINK-8159) Pattern(Flat)SelectFunctions should support RichFunction interface

[ https://issues.apache.org/jira/browse/FLINK-8159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-8159: -- Labels: pull-request-available (was: ) > Pattern(Flat)SelectFunctions should support

[GitHub] pnowojski commented on issue #7101: [FLINK-10891] Upgrade Kafka client version to 2.0.1

pnowojski commented on issue #7101: [FLINK-10891] Upgrade Kafka client version to 2.0.1 URL: https://github.com/apache/flink/pull/7101#issuecomment-439078634 It looks unrelated and it's already reported: https://issues.apache.org/jira/browse/FLINK-10895 Every time you see a test

[jira] [Commented] (FLINK-10891) Upgrade Kafka client version to 2.0.1

[ https://issues.apache.org/jira/browse/FLINK-10891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688215#comment-16688215 ] ASF GitHub Bot commented on FLINK-10891: pnowojski commented on issue #7101: [FLINK-10891]

[GitHub] yanghua edited a comment on issue #7101: [FLINK-10891] Upgrade Kafka client version to 2.0.1

yanghua edited a comment on issue #7101: [FLINK-10891] Upgrade Kafka client version to 2.0.1 URL: https://github.com/apache/flink/pull/7101#issuecomment-439086693 @pnowojski OK, thank you for reminding me. Actually, I did it a long time ago, but later I found that failure was too

[jira] [Commented] (FLINK-10891) Upgrade Kafka client version to 2.0.1

[ https://issues.apache.org/jira/browse/FLINK-10891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688249#comment-16688249 ] ASF GitHub Bot commented on FLINK-10891: yanghua edited a comment on issue #7101: [FLINK-10891]

[GitHub] tillrohrmann opened a new pull request #7115: [FLINK-10883] Failing batch jobs with NoResourceAvailableException when slot request times out

tillrohrmann opened a new pull request #7115: [FLINK-10883] Failing batch jobs with NoResourceAvailableException when slot request times out URL: https://github.com/apache/flink/pull/7115 ## What is the purpose of the change Instead of failing the ExecutionGraph with a generic

[jira] [Assigned] (FLINK-10900) Mark Kafka 2.0 connector as beta feature

[ https://issues.apache.org/jira/browse/FLINK-10900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-10900: - Assignee: Piotr Nowojski > Mark Kafka 2.0 connector as beta feature >

[jira] [Commented] (FLINK-10892) Flink Yarn app name is hard coded

[ https://issues.apache.org/jira/browse/FLINK-10892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688045#comment-16688045 ] Dawid Wysakowicz commented on FLINK-10892: -- Hi [~zjffdu], have you tried using the nm option in

[GitHub] zentol closed pull request #6554: [FLINK-10144]delete unused import akka.actor.ActorRef in TaskManagerMessages.scala

zentol closed pull request #6554: [FLINK-10144]delete unused import akka.actor.ActorRef in TaskManagerMessages.scala URL: https://github.com/apache/flink/pull/6554 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake

[GitHub] zentol commented on a change in pull request #6976: [FLINK-7155][metrics] Add new metrics reporter to InfluxDB

zentol commented on a change in pull request #6976: [FLINK-7155][metrics] Add new metrics reporter to InfluxDB URL: https://github.com/apache/flink/pull/6976#discussion_r233837808 ## File path:

[GitHub] azagrebin opened a new pull request #7107: [FLINK-10455][Kafka Tx] Close transactional producers in case of failure and termination

azagrebin opened a new pull request #7107: [FLINK-10455][Kafka Tx] Close transactional producers in case of failure and termination URL: https://github.com/apache/flink/pull/7107 1.5 back port of #6989 cc @pnowojski This

[GitHub] pnowojski commented on issue #7109: [FLINK-10900][kafka][docs] Mark universal Kafka connector as beta

pnowojski commented on issue #7109: [FLINK-10900][kafka][docs] Mark universal Kafka connector as beta URL: https://github.com/apache/flink/pull/7109#issuecomment-439061104 CC @tzulitai @yanghua This is an automated message

[GitHub] dianfu opened a new pull request #7110: [FLINK-8159] [cep] Pattern(Flat)SelectFunctions should support RichFunction interface

dianfu opened a new pull request #7110: [FLINK-8159] [cep] Pattern(Flat)SelectFunctions should support RichFunction interface URL: https://github.com/apache/flink/pull/7110 [FLINK-6938] [cep] IterativeCondition should support RichFunction interface ## What is the purpose of

[jira] [Commented] (FLINK-8159) Pattern(Flat)SelectFunctions should support RichFunction interface

[ https://issues.apache.org/jira/browse/FLINK-8159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688179#comment-16688179 ] ASF GitHub Bot commented on FLINK-8159: --- dianfu opened a new pull request #7110: [FLINK-8159] [cep]

[GitHub] tillrohrmann opened a new pull request #7111: [FLINK-10856] Find latest completed checkpoint for resume from externalized checkpoint e2e test

tillrohrmann opened a new pull request #7111: [FLINK-10856] Find latest completed checkpoint for resume from externalized checkpoint e2e test URL: https://github.com/apache/flink/pull/7111 ## What is the purpose of the change Find latest completed checkpoint for resume from

[GitHub] alpinegizmo commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause

alpinegizmo commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause URL: https://github.com/apache/flink/pull/7070#discussion_r233917000 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -0,0 +1,843 @@ +--- +title:

[GitHub] alpinegizmo commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause

alpinegizmo commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause URL: https://github.com/apache/flink/pull/7070#discussion_r233902190 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -0,0 +1,843 @@ +--- +title:

[GitHub] alpinegizmo commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause

alpinegizmo commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause URL: https://github.com/apache/flink/pull/7070#discussion_r233908441 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -0,0 +1,843 @@ +--- +title:

[GitHub] alpinegizmo commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause

alpinegizmo commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause URL: https://github.com/apache/flink/pull/7070#discussion_r233889947 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -0,0 +1,843 @@ +--- +title:

[GitHub] alpinegizmo commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause

alpinegizmo commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause URL: https://github.com/apache/flink/pull/7070#discussion_r233901927 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -0,0 +1,843 @@ +--- +title:

  1   2   3   4   >